public StsAccount generate()

in src/main/java/com/aliyun/odps/kafka/connect/account/impl/STSAccountGenerator.java [16:40]

• 24 lines of code
• 1 McCabe index (conditional complexity)

  public StsAccount generate(MaxComputeSinkConnectorConfig config) {
    Map<String, String> env = System.getenv();
    String ak = env.getOrDefault("ACCESS_ID", "");
    String sk = env.getOrDefault("ACCESS_KEY", "");

    String
        accountId =
        config.getString(MaxComputeSinkConnectorConfig.BaseParameter.ACCOUNT_ID.getName());
    String
        regionId =
        config.getString(MaxComputeSinkConnectorConfig.BaseParameter.REGION_ID.getName());
    String
        roleName =
        config.getString(MaxComputeSinkConnectorConfig.BaseParameter.ROLE_NAME.getName());
    String
        stsEndpoint =
        config.getString(MaxComputeSinkConnectorConfig.BaseParameter.STS_ENDPOINT.getName());
    StsUserBo
        stsUserBo =
        stsService.getAssumeRole(accountId, regionId, stsEndpoint, ak, sk, roleName);
    String token = stsUserBo.getToken();
    String id = stsUserBo.getAk();
    String key = stsUserBo.getSk();
    return new StsAccount(id, key, token);
  }