protected void configureHttpClientBuilder()

in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientFactory.java [73:96]

22 lines of code
5 McCabe index (conditional complexity)


    protected void configureHttpClientBuilder(
            HttpAsyncClientBuilder httpClientBuilder, RestClientConfig networkClientConfig) {
        if (networkClientConfig.getPassword() != null
                && networkClientConfig.getUsername() != null) {
            final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
            credentialsProvider.setCredentials(
                    AuthScope.ANY,
                    new UsernamePasswordCredentials(
                            networkClientConfig.getUsername(), networkClientConfig.getPassword()));

            httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
        }

        if (networkClientConfig.isAllowInsecure().orElse(false)) {
            try {
                httpClientBuilder.setSSLContext(
                        SSLContexts.custom().loadTrustMaterial(new TrustAllStrategy()).build());
            } catch (final NoSuchAlgorithmException
                    | KeyStoreException
                    | KeyManagementException ex) {
                throw new IllegalStateException("Unable to create custom SSL context", ex);
            }
        }
    }