private static void validateProfileName()

in src/main/java/software/amazon/event/kafkaconnector/EventBridgeSinkConfigValidator.java [237:259]

• 18 lines of code
• 4 McCabe index (conditional complexity)

  private static void validateProfileName(ConfigValue configValue, EnvVarGetter envVarGetter) {
    var profileName = (String) configValue.value();
    // optional parameter
    if (profileName == null || profileName.trim().isBlank()) {
      return;
    }

    // throw if this config parameter and any AWS environment variables which overwrite its behavior
    // (from DefaultCredentialsProvider chain) are set
    var conflictingAwsEnvVars =
        Stream.of(AWS_PROFILE, AWS_SECRET_ACCESS_KEY, AWS_SESSION_TOKEN, AWS_ACCESS_KEY_ID)
            .map(Enum::toString)
            .filter(env -> (envVarGetter.get(env) != null))
            .collect(Collectors.toList());

    if (!conflictingAwsEnvVars.isEmpty()) {
      throw new ConfigException(
          String.format(
              "\"%s\" environment variable(s) are set. "
                  + "Unset the environment variable for \"%s\" to take effect.",
              conflictingAwsEnvVars, AWS_PROFILE_NAME_CONFIG));
    }
  }