public void configure()

in src/main/java/software/amazon/msk/auth/iam/IAMOAuthBearerLoginCallbackHandler.java [76:93]

15 lines of code
2 McCabe index (conditional complexity)


    public void configure(Map<String, ?> configs,
                          @NonNull String saslMechanism,
                          @NonNull List<AppConfigurationEntry> jaasConfigEntries) {
        if (!OAuthBearerLoginModule.OAUTHBEARER_MECHANISM.equals(saslMechanism)) {
            throw new IllegalArgumentException(String.format("Unexpected SASL mechanism: %s", saslMechanism));
        }

        final Optional<AppConfigurationEntry> configEntry = jaasConfigEntries.stream()
                .filter(j -> OAuthBearerLoginModule.class.getCanonicalName()
                        .equals(j.getLoginModuleName()))
                .findFirst();

        credentialsProvider = configEntry.map(c -> (AwsCredentialsProvider) new MSKCredentialProvider(c.getOptions()))
                .orElse(DefaultCredentialsProvider.create());

        awsRegionProvider = new DefaultAwsRegionProviderChain();
        configured = true;
    }