protocol-resilience-test/llcinitial/src/main/java/fixtures/llcresi/DpgClientBuilder.java [42:306]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - @ServiceClientBuilder(serviceClients = { DpgClient.class, DpgAsyncClient.class }) public final class DpgClientBuilder implements HttpTrait, ConfigurationTrait { @Generated private static final String SDK_NAME = "name"; @Generated private static final String SDK_VERSION = "version"; @Generated private static final Map PROPERTIES = CoreUtils.getProperties("fixtures-llcresi.properties"); @Generated private final List pipelinePolicies; /** * Create an instance of the DpgClientBuilder. */ @Generated public DpgClientBuilder() { this.pipelinePolicies = new ArrayList<>(); } /* * The HTTP pipeline to send requests through. */ @Generated private HttpPipeline pipeline; /** * {@inheritDoc}. */ @Generated @Override public DpgClientBuilder pipeline(HttpPipeline pipeline) { if (this.pipeline != null && pipeline == null) { LOGGER.atInfo().log("HttpPipeline is being set to 'null' when it was previously configured."); } this.pipeline = pipeline; return this; } /* * The HTTP client used to send the request. */ @Generated private HttpClient httpClient; /** * {@inheritDoc}. */ @Generated @Override public DpgClientBuilder httpClient(HttpClient httpClient) { this.httpClient = httpClient; return this; } /* * The logging configuration for HTTP requests and responses. */ @Generated private HttpLogOptions httpLogOptions; /** * {@inheritDoc}. */ @Generated @Override public DpgClientBuilder httpLogOptions(HttpLogOptions httpLogOptions) { this.httpLogOptions = httpLogOptions; return this; } /* * The client options such as application ID and custom headers to set on a request. */ @Generated private ClientOptions clientOptions; /** * {@inheritDoc}. */ @Generated @Override public DpgClientBuilder clientOptions(ClientOptions clientOptions) { this.clientOptions = clientOptions; return this; } /* * The retry options to configure retry policy for failed requests. */ @Generated private RetryOptions retryOptions; /** * {@inheritDoc}. */ @Generated @Override public DpgClientBuilder retryOptions(RetryOptions retryOptions) { this.retryOptions = retryOptions; return this; } /** * {@inheritDoc}. */ @Generated @Override public DpgClientBuilder addPolicy(HttpPipelinePolicy customPolicy) { Objects.requireNonNull(customPolicy, "'customPolicy' cannot be null."); pipelinePolicies.add(customPolicy); return this; } /* * The configuration store that is used during construction of the service client. */ @Generated private Configuration configuration; /** * {@inheritDoc}. */ @Generated @Override public DpgClientBuilder configuration(Configuration configuration) { this.configuration = configuration; return this; } /* * server parameter */ @Generated private String host; /** * Sets server parameter. * * @param host the host value. * @return the DpgClientBuilder. */ @Generated public DpgClientBuilder host(String host) { this.host = host; return this; } /* * Service version */ @Generated private DpgServiceVersion serviceVersion; /** * Sets Service version. * * @param serviceVersion the serviceVersion value. * @return the DpgClientBuilder. */ @Generated public DpgClientBuilder serviceVersion(DpgServiceVersion serviceVersion) { this.serviceVersion = serviceVersion; return this; } /* * The retry policy that will attempt to retry failed requests, if applicable. */ @Generated private RetryPolicy retryPolicy; /** * Sets The retry policy that will attempt to retry failed requests, if applicable. * * @param retryPolicy the retryPolicy value. * @return the DpgClientBuilder. */ @Generated public DpgClientBuilder retryPolicy(RetryPolicy retryPolicy) { this.retryPolicy = retryPolicy; return this; } /** * Builds an instance of DpgClientImpl with the provided parameters. * * @return an instance of DpgClientImpl. */ @Generated private DpgClientImpl buildInnerClient() { this.validateClient(); HttpPipeline localPipeline = (pipeline != null) ? pipeline : createHttpPipeline(); String localHost = (host != null) ? host : "http://localhost:3000"; DpgServiceVersion localServiceVersion = (serviceVersion != null) ? serviceVersion : DpgServiceVersion.getLatest(); DpgClientImpl client = new DpgClientImpl(localPipeline, JacksonAdapter.createDefaultSerializerAdapter(), localHost, localServiceVersion); return client; } @Generated private void validateClient() { // This method is invoked from 'buildInnerClient'/'buildClient' method. // Developer can customize this method, to validate that the necessary conditions are met for the new client. } @Generated private HttpPipeline createHttpPipeline() { Configuration buildConfiguration = (configuration == null) ? Configuration.getGlobalConfiguration() : configuration; HttpLogOptions localHttpLogOptions = this.httpLogOptions == null ? new HttpLogOptions() : this.httpLogOptions; ClientOptions localClientOptions = this.clientOptions == null ? new ClientOptions() : this.clientOptions; List policies = new ArrayList<>(); String clientName = PROPERTIES.getOrDefault(SDK_NAME, "UnknownName"); String clientVersion = PROPERTIES.getOrDefault(SDK_VERSION, "UnknownVersion"); String applicationId = CoreUtils.getApplicationId(localClientOptions, localHttpLogOptions); policies.add(new UserAgentPolicy(applicationId, clientName, clientVersion, buildConfiguration)); policies.add(new RequestIdPolicy()); policies.add(new AddHeadersFromContextPolicy()); HttpHeaders headers = CoreUtils.createHttpHeadersFromClientOptions(localClientOptions); if (headers != null) { policies.add(new AddHeadersPolicy(headers)); } this.pipelinePolicies.stream() .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_CALL) .forEach(p -> policies.add(p)); HttpPolicyProviders.addBeforeRetryPolicies(policies); policies.add(ClientBuilderUtil.validateAndGetRetryPolicy(retryPolicy, retryOptions, new RetryPolicy())); policies.add(new AddDatePolicy()); this.pipelinePolicies.stream() .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_RETRY) .forEach(p -> policies.add(p)); HttpPolicyProviders.addAfterRetryPolicies(policies); policies.add(new HttpLoggingPolicy(localHttpLogOptions)); HttpPipeline httpPipeline = new HttpPipelineBuilder().policies(policies.toArray(new HttpPipelinePolicy[0])) .httpClient(httpClient) .clientOptions(localClientOptions) .build(); return httpPipeline; } /** * Builds an instance of DpgAsyncClient class. * * @return an instance of DpgAsyncClient. */ @Generated public DpgAsyncClient buildAsyncClient() { return new DpgAsyncClient(buildInnerClient().getParams()); } /** * Builds an instance of DpgClient class. * * @return an instance of DpgClient. */ @Generated public DpgClient buildClient() { return new DpgClient(buildInnerClient().getParams()); } private static final ClientLogger LOGGER = new ClientLogger(DpgClientBuilder.class); - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - protocol-resilience-test/llcupdate1/src/main/java/fixtures/llcresi/DpgClientBuilder.java [42:306]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - @ServiceClientBuilder(serviceClients = { DpgClient.class, DpgAsyncClient.class }) public final class DpgClientBuilder implements HttpTrait, ConfigurationTrait { @Generated private static final String SDK_NAME = "name"; @Generated private static final String SDK_VERSION = "version"; @Generated private static final Map PROPERTIES = CoreUtils.getProperties("fixtures-llcresi.properties"); @Generated private final List pipelinePolicies; /** * Create an instance of the DpgClientBuilder. */ @Generated public DpgClientBuilder() { this.pipelinePolicies = new ArrayList<>(); } /* * The HTTP pipeline to send requests through. */ @Generated private HttpPipeline pipeline; /** * {@inheritDoc}. */ @Generated @Override public DpgClientBuilder pipeline(HttpPipeline pipeline) { if (this.pipeline != null && pipeline == null) { LOGGER.atInfo().log("HttpPipeline is being set to 'null' when it was previously configured."); } this.pipeline = pipeline; return this; } /* * The HTTP client used to send the request. */ @Generated private HttpClient httpClient; /** * {@inheritDoc}. */ @Generated @Override public DpgClientBuilder httpClient(HttpClient httpClient) { this.httpClient = httpClient; return this; } /* * The logging configuration for HTTP requests and responses. */ @Generated private HttpLogOptions httpLogOptions; /** * {@inheritDoc}. */ @Generated @Override public DpgClientBuilder httpLogOptions(HttpLogOptions httpLogOptions) { this.httpLogOptions = httpLogOptions; return this; } /* * The client options such as application ID and custom headers to set on a request. */ @Generated private ClientOptions clientOptions; /** * {@inheritDoc}. */ @Generated @Override public DpgClientBuilder clientOptions(ClientOptions clientOptions) { this.clientOptions = clientOptions; return this; } /* * The retry options to configure retry policy for failed requests. */ @Generated private RetryOptions retryOptions; /** * {@inheritDoc}. */ @Generated @Override public DpgClientBuilder retryOptions(RetryOptions retryOptions) { this.retryOptions = retryOptions; return this; } /** * {@inheritDoc}. */ @Generated @Override public DpgClientBuilder addPolicy(HttpPipelinePolicy customPolicy) { Objects.requireNonNull(customPolicy, "'customPolicy' cannot be null."); pipelinePolicies.add(customPolicy); return this; } /* * The configuration store that is used during construction of the service client. */ @Generated private Configuration configuration; /** * {@inheritDoc}. */ @Generated @Override public DpgClientBuilder configuration(Configuration configuration) { this.configuration = configuration; return this; } /* * server parameter */ @Generated private String host; /** * Sets server parameter. * * @param host the host value. * @return the DpgClientBuilder. */ @Generated public DpgClientBuilder host(String host) { this.host = host; return this; } /* * Service version */ @Generated private DpgServiceVersion serviceVersion; /** * Sets Service version. * * @param serviceVersion the serviceVersion value. * @return the DpgClientBuilder. */ @Generated public DpgClientBuilder serviceVersion(DpgServiceVersion serviceVersion) { this.serviceVersion = serviceVersion; return this; } /* * The retry policy that will attempt to retry failed requests, if applicable. */ @Generated private RetryPolicy retryPolicy; /** * Sets The retry policy that will attempt to retry failed requests, if applicable. * * @param retryPolicy the retryPolicy value. * @return the DpgClientBuilder. */ @Generated public DpgClientBuilder retryPolicy(RetryPolicy retryPolicy) { this.retryPolicy = retryPolicy; return this; } /** * Builds an instance of DpgClientImpl with the provided parameters. * * @return an instance of DpgClientImpl. */ @Generated private DpgClientImpl buildInnerClient() { this.validateClient(); HttpPipeline localPipeline = (pipeline != null) ? pipeline : createHttpPipeline(); String localHost = (host != null) ? host : "http://localhost:3000"; DpgServiceVersion localServiceVersion = (serviceVersion != null) ? serviceVersion : DpgServiceVersion.getLatest(); DpgClientImpl client = new DpgClientImpl(localPipeline, JacksonAdapter.createDefaultSerializerAdapter(), localHost, localServiceVersion); return client; } @Generated private void validateClient() { // This method is invoked from 'buildInnerClient'/'buildClient' method. // Developer can customize this method, to validate that the necessary conditions are met for the new client. } @Generated private HttpPipeline createHttpPipeline() { Configuration buildConfiguration = (configuration == null) ? Configuration.getGlobalConfiguration() : configuration; HttpLogOptions localHttpLogOptions = this.httpLogOptions == null ? new HttpLogOptions() : this.httpLogOptions; ClientOptions localClientOptions = this.clientOptions == null ? new ClientOptions() : this.clientOptions; List policies = new ArrayList<>(); String clientName = PROPERTIES.getOrDefault(SDK_NAME, "UnknownName"); String clientVersion = PROPERTIES.getOrDefault(SDK_VERSION, "UnknownVersion"); String applicationId = CoreUtils.getApplicationId(localClientOptions, localHttpLogOptions); policies.add(new UserAgentPolicy(applicationId, clientName, clientVersion, buildConfiguration)); policies.add(new RequestIdPolicy()); policies.add(new AddHeadersFromContextPolicy()); HttpHeaders headers = CoreUtils.createHttpHeadersFromClientOptions(localClientOptions); if (headers != null) { policies.add(new AddHeadersPolicy(headers)); } this.pipelinePolicies.stream() .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_CALL) .forEach(p -> policies.add(p)); HttpPolicyProviders.addBeforeRetryPolicies(policies); policies.add(ClientBuilderUtil.validateAndGetRetryPolicy(retryPolicy, retryOptions, new RetryPolicy())); policies.add(new AddDatePolicy()); this.pipelinePolicies.stream() .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_RETRY) .forEach(p -> policies.add(p)); HttpPolicyProviders.addAfterRetryPolicies(policies); policies.add(new HttpLoggingPolicy(localHttpLogOptions)); HttpPipeline httpPipeline = new HttpPipelineBuilder().policies(policies.toArray(new HttpPipelinePolicy[0])) .httpClient(httpClient) .clientOptions(localClientOptions) .build(); return httpPipeline; } /** * Builds an instance of DpgAsyncClient class. * * @return an instance of DpgAsyncClient. */ @Generated public DpgAsyncClient buildAsyncClient() { return new DpgAsyncClient(buildInnerClient().getParams()); } /** * Builds an instance of DpgClient class. * * @return an instance of DpgClient. */ @Generated public DpgClient buildClient() { return new DpgClient(buildInnerClient().getParams()); } private static final ClientLogger LOGGER = new ClientLogger(DpgClientBuilder.class); - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -