DeviceUpdateClientBuilder.java
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License.
// Code generated by Microsoft (R) AutoRest Code Generator.
package com.azure.iot.deviceupdate;
import com.azure.core.annotation.Generated;
import com.azure.core.annotation.ServiceClientBuilder;
import com.azure.core.credential.TokenCredential;
import com.azure.core.http.HttpClient;
import com.azure.core.http.HttpHeaders;
import com.azure.core.http.HttpPipeline;
import com.azure.core.http.HttpPipelineBuilder;
import com.azure.core.http.HttpPipelinePosition;
import com.azure.core.http.policy.AddHeadersPolicy;
import com.azure.core.http.policy.BearerTokenAuthenticationPolicy;
import com.azure.core.http.policy.CookiePolicy;
import com.azure.core.http.policy.HttpLogOptions;
import com.azure.core.http.policy.HttpLoggingPolicy;
import com.azure.core.http.policy.HttpPipelinePolicy;
import com.azure.core.http.policy.HttpPolicyProviders;
import com.azure.core.http.policy.RetryPolicy;
import com.azure.core.http.policy.UserAgentPolicy;
import com.azure.core.util.ClientOptions;
import com.azure.core.util.Configuration;
import com.azure.core.util.CoreUtils;
import com.azure.core.util.serializer.JacksonAdapter;
import com.azure.iot.deviceupdate.implementation.DeviceUpdateClientImpl;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/** A builder for creating a new instance of the DeviceUpdateClient type. */
@ServiceClientBuilder(
serviceClients = {
DeviceUpdateClient.class,
DeviceManagementClient.class,
DeviceUpdateAsyncClient.class,
DeviceManagementAsyncClient.class
})
public final class DeviceUpdateClientBuilder {
@Generated private static final String SDK_NAME = "name";
@Generated private static final String SDK_VERSION = "version";
@Generated static final String[] DEFAULT_SCOPES = new String[] {"https://api.adu.microsoft.com/.default"};
@Generated
private final Map<String, String> properties = CoreUtils.getProperties("azure-iot-deviceupdate.properties");
/** Create an instance of the DeviceUpdateClientBuilder. */
@Generated
public DeviceUpdateClientBuilder() {
this.pipelinePolicies = new ArrayList<>();
}
/*
* Account endpoint.
*/
@Generated private String endpoint;
/**
* Sets Account endpoint.
*
* @param endpoint the endpoint value.
* @return the DeviceUpdateClientBuilder.
*/
@Generated
public DeviceUpdateClientBuilder endpoint(String endpoint) {
this.endpoint = endpoint;
return this;
}
/*
* Account instance identifier.
*/
@Generated private String instanceId;
/**
* Sets Account instance identifier.
*
* @param instanceId the instanceId value.
* @return the DeviceUpdateClientBuilder.
*/
@Generated
public DeviceUpdateClientBuilder instanceId(String instanceId) {
this.instanceId = instanceId;
return this;
}
/*
* Service version
*/
@Generated private DeviceUpdateServiceVersion serviceVersion;
/**
* Sets Service version.
*
* @param serviceVersion the serviceVersion value.
* @return the DeviceUpdateClientBuilder.
*/
@Generated
public DeviceUpdateClientBuilder serviceVersion(DeviceUpdateServiceVersion serviceVersion) {
this.serviceVersion = serviceVersion;
return this;
}
/*
* The HTTP pipeline to send requests through
*/
@Generated private HttpPipeline pipeline;
/**
* Sets The HTTP pipeline to send requests through.
*
* @param pipeline the pipeline value.
* @return the DeviceUpdateClientBuilder.
*/
@Generated
public DeviceUpdateClientBuilder pipeline(HttpPipeline pipeline) {
this.pipeline = pipeline;
return this;
}
/*
* The HTTP client used to send the request.
*/
@Generated private HttpClient httpClient;
/**
* Sets The HTTP client used to send the request.
*
* @param httpClient the httpClient value.
* @return the DeviceUpdateClientBuilder.
*/
@Generated
public DeviceUpdateClientBuilder httpClient(HttpClient httpClient) {
this.httpClient = httpClient;
return this;
}
/*
* The configuration store that is used during construction of the service
* client.
*/
@Generated private Configuration configuration;
/**
* Sets The configuration store that is used during construction of the service client.
*
* @param configuration the configuration value.
* @return the DeviceUpdateClientBuilder.
*/
@Generated
public DeviceUpdateClientBuilder configuration(Configuration configuration) {
this.configuration = configuration;
return this;
}
/*
* The TokenCredential used for authentication.
*/
@Generated private TokenCredential tokenCredential;
/**
* Sets The TokenCredential used for authentication.
*
* @param tokenCredential the tokenCredential value.
* @return the DeviceUpdateClientBuilder.
*/
@Generated
public DeviceUpdateClientBuilder credential(TokenCredential tokenCredential) {
this.tokenCredential = tokenCredential;
return this;
}
/*
* The logging configuration for HTTP requests and responses.
*/
@Generated private HttpLogOptions httpLogOptions;
/**
* Sets The logging configuration for HTTP requests and responses.
*
* @param httpLogOptions the httpLogOptions value.
* @return the DeviceUpdateClientBuilder.
*/
@Generated
public DeviceUpdateClientBuilder httpLogOptions(HttpLogOptions httpLogOptions) {
this.httpLogOptions = httpLogOptions;
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 DeviceUpdateClientBuilder.
*/
@Generated
public DeviceUpdateClientBuilder retryPolicy(RetryPolicy retryPolicy) {
this.retryPolicy = retryPolicy;
return this;
}
/*
* The list of Http pipeline policies to add.
*/
@Generated private final List<HttpPipelinePolicy> pipelinePolicies;
/*
* The client options such as application ID and custom headers to set on a
* request.
*/
@Generated private ClientOptions clientOptions;
/**
* Sets The client options such as application ID and custom headers to set on a request.
*
* @param clientOptions the clientOptions value.
* @return the DeviceUpdateClientBuilder.
*/
@Generated
public DeviceUpdateClientBuilder clientOptions(ClientOptions clientOptions) {
this.clientOptions = clientOptions;
return this;
}
/**
* Adds a custom Http pipeline policy.
*
* @param customPolicy The custom Http pipeline policy to add.
* @return the DeviceUpdateClientBuilder.
*/
@Generated
public DeviceUpdateClientBuilder addPolicy(HttpPipelinePolicy customPolicy) {
pipelinePolicies.add(customPolicy);
return this;
}
/**
* Builds an instance of DeviceUpdateClientImpl with the provided parameters.
*
* @return an instance of DeviceUpdateClientImpl.
*/
@Generated
private DeviceUpdateClientImpl buildInnerClient() {
if (serviceVersion == null) {
this.serviceVersion = DeviceUpdateServiceVersion.getLatest();
}
if (pipeline == null) {
this.pipeline = createHttpPipeline();
}
DeviceUpdateClientImpl client =
new DeviceUpdateClientImpl(
pipeline,
JacksonAdapter.createDefaultSerializerAdapter(),
endpoint,
instanceId,
serviceVersion);
return client;
}
@Generated
private HttpPipeline createHttpPipeline() {
Configuration buildConfiguration =
(configuration == null) ? Configuration.getGlobalConfiguration() : configuration;
if (httpLogOptions == null) {
httpLogOptions = new HttpLogOptions();
}
if (clientOptions == null) {
clientOptions = new ClientOptions();
}
List<HttpPipelinePolicy> policies = new ArrayList<>();
String clientName = properties.getOrDefault(SDK_NAME, "UnknownName");
String clientVersion = properties.getOrDefault(SDK_VERSION, "UnknownVersion");
String applicationId = CoreUtils.getApplicationId(clientOptions, httpLogOptions);
policies.add(new UserAgentPolicy(applicationId, clientName, clientVersion, buildConfiguration));
HttpHeaders headers = new HttpHeaders();
clientOptions.getHeaders().forEach(header -> headers.set(header.getName(), header.getValue()));
if (headers.getSize() > 0) {
policies.add(new AddHeadersPolicy(headers));
}
policies.addAll(
this.pipelinePolicies.stream()
.filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_CALL)
.collect(Collectors.toList()));
HttpPolicyProviders.addBeforeRetryPolicies(policies);
policies.add(retryPolicy == null ? new RetryPolicy() : retryPolicy);
policies.add(new CookiePolicy());
if (tokenCredential != null) {
policies.add(new BearerTokenAuthenticationPolicy(tokenCredential, DEFAULT_SCOPES));
}
policies.addAll(
this.pipelinePolicies.stream()
.filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_RETRY)
.collect(Collectors.toList()));
HttpPolicyProviders.addAfterRetryPolicies(policies);
policies.add(new HttpLoggingPolicy(httpLogOptions));
HttpPipeline httpPipeline =
new HttpPipelineBuilder()
.policies(policies.toArray(new HttpPipelinePolicy[0]))
.httpClient(httpClient)
.clientOptions(clientOptions)
.build();
return httpPipeline;
}
/**
* Builds an instance of DeviceUpdateAsyncClient async client.
*
* @return an instance of DeviceUpdateAsyncClient.
*/
@Generated
public DeviceUpdateAsyncClient buildDeviceUpdateAsyncClient() {
return new DeviceUpdateAsyncClient(buildInnerClient().getDeviceUpdates());
}
/**
* Builds an instance of DeviceManagementAsyncClient async client.
*
* @return an instance of DeviceManagementAsyncClient.
*/
@Generated
public DeviceManagementAsyncClient buildDeviceManagementAsyncClient() {
return new DeviceManagementAsyncClient(buildInnerClient().getDeviceManagements());
}
/**
* Builds an instance of DeviceUpdateClient sync client.
*
* @return an instance of DeviceUpdateClient.
*/
@Generated
public DeviceUpdateClient buildDeviceUpdateClient() {
return new DeviceUpdateClient(buildInnerClient().getDeviceUpdates());
}
/**
* Builds an instance of DeviceManagementClient sync client.
*
* @return an instance of DeviceManagementClient.
*/
@Generated
public DeviceManagementClient buildDeviceManagementClient() {
return new DeviceManagementClient(buildInnerClient().getDeviceManagements());
}
}