merging from main

sdk/communication/azure-communication-callautomation/CHANGELOG.md

@@ -1,6 +1,6 @@
 # Release History
 
-## 1.4.0 (2025-06-04)
+## 1.5.0 (Unreleased)
 
 ### Features Added
 

sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/AzureCommunicationCallAutomationServiceImpl.java

@@ -29,12 +29,12 @@
 import com.azure.core.http.rest.Response;
 import com.azure.core.http.rest.RestProxy;
 import com.azure.core.util.Context;
-import com.azure.core.util.CoreUtils;
 import com.azure.core.util.DateTimeRfc1123;
 import com.azure.core.util.FluxUtil;
 import com.azure.core.util.serializer.JacksonAdapter;
 import com.azure.core.util.serializer.SerializerAdapter;
 import java.time.OffsetDateTime;
+import java.util.UUID;
 import reactor.core.publisher.Mono;
 
 /**
@@ -192,7 +192,7 @@ public CallRecordingsImpl getCallRecordings() {
      * service to perform REST calls.
      */
     @Host("{endpoint}")
-    @ServiceInterface(name = "AzureCommunicationCallAutomationService")
+    @ServiceInterface(name = "AzureCommunicationCa")
     public interface AzureCommunicationCallAutomationServiceService {
         @Post("/calling/callConnections")
         @ExpectedResponses({ 201 })
@@ -256,7 +256,11 @@ Mono<Response<CallConnectionPropertiesInternal>> connect(@HostParam("endpoint")
     @ServiceMethod(returns = ReturnType.SINGLE)
     public Mono<Response<CallConnectionPropertiesInternal>>
         createCallWithResponseAsync(CreateCallRequestInternal createCallRequest) {
-        return FluxUtil.withContext(context -> createCallWithResponseAsync(createCallRequest, context));
+        final String accept = "application/json";
+        String repeatabilityRequestId = UUID.randomUUID().toString();
+        String repeatabilityFirstSent = DateTimeRfc1123.toRfc1123String(OffsetDateTime.now());
+        return FluxUtil.withContext(context -> service.createCall(this.getEndpoint(), this.getApiVersion(),
+            createCallRequest, accept, repeatabilityRequestId, repeatabilityFirstSent, context));
     }
 
     /**
@@ -273,8 +277,10 @@ Mono<Response<CallConnectionPropertiesInternal>> connect(@HostParam("endpoint")
     public Mono<Response<CallConnectionPropertiesInternal>>
         createCallWithResponseAsync(CreateCallRequestInternal createCallRequest, Context context) {
         final String accept = "application/json";
+        String repeatabilityRequestId = UUID.randomUUID().toString();
+        String repeatabilityFirstSent = DateTimeRfc1123.toRfc1123String(OffsetDateTime.now());
         return service.createCall(this.getEndpoint(), this.getApiVersion(), createCallRequest, accept,
-            CoreUtils.randomUuid().toString(), DateTimeRfc1123.toRfc1123String(OffsetDateTime.now()), context);
+            repeatabilityRequestId, repeatabilityFirstSent, context);
     }
 
     /**
@@ -351,7 +357,11 @@ public CallConnectionPropertiesInternal createCall(CreateCallRequestInternal cre
     @ServiceMethod(returns = ReturnType.SINGLE)
     public Mono<Response<CallConnectionPropertiesInternal>>
         answerCallWithResponseAsync(AnswerCallRequestInternal answerCallRequest) {
-        return FluxUtil.withContext(context -> answerCallWithResponseAsync(answerCallRequest, context));
+        final String accept = "application/json";
+        String repeatabilityRequestId = UUID.randomUUID().toString();
+        String repeatabilityFirstSent = DateTimeRfc1123.toRfc1123String(OffsetDateTime.now());
+        return FluxUtil.withContext(context -> service.answerCall(this.getEndpoint(), this.getApiVersion(),
+            answerCallRequest, accept, repeatabilityRequestId, repeatabilityFirstSent, context));
     }
 
     /**
@@ -370,8 +380,10 @@ public CallConnectionPropertiesInternal createCall(CreateCallRequestInternal cre
     public Mono<Response<CallConnectionPropertiesInternal>>
         answerCallWithResponseAsync(AnswerCallRequestInternal answerCallRequest, Context context) {
         final String accept = "application/json";
+        String repeatabilityRequestId = UUID.randomUUID().toString();
+        String repeatabilityFirstSent = DateTimeRfc1123.toRfc1123String(OffsetDateTime.now());
         return service.answerCall(this.getEndpoint(), this.getApiVersion(), answerCallRequest, accept,
-            CoreUtils.randomUuid().toString(), DateTimeRfc1123.toRfc1123String(OffsetDateTime.now()), context);
+            repeatabilityRequestId, repeatabilityFirstSent, context);
     }
 
     /**
@@ -453,7 +465,11 @@ public CallConnectionPropertiesInternal answerCall(AnswerCallRequestInternal ans
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     public Mono<Response<Void>> redirectCallWithResponseAsync(RedirectCallRequestInternal redirectCallRequest) {
-        return FluxUtil.withContext(context -> redirectCallWithResponseAsync(redirectCallRequest, context));
+        final String accept = "application/json";
+        String repeatabilityRequestId = UUID.randomUUID().toString();
+        String repeatabilityFirstSent = DateTimeRfc1123.toRfc1123String(OffsetDateTime.now());
+        return FluxUtil.withContext(context -> service.redirectCall(this.getEndpoint(), this.getApiVersion(),
+            redirectCallRequest, accept, repeatabilityRequestId, repeatabilityFirstSent, context));
     }
 
     /**
@@ -470,8 +486,10 @@ public Mono<Response<Void>> redirectCallWithResponseAsync(RedirectCallRequestInt
     public Mono<Response<Void>> redirectCallWithResponseAsync(RedirectCallRequestInternal redirectCallRequest,
         Context context) {
         final String accept = "application/json";
+        String repeatabilityRequestId = UUID.randomUUID().toString();
+        String repeatabilityFirstSent = DateTimeRfc1123.toRfc1123String(OffsetDateTime.now());
         return service.redirectCall(this.getEndpoint(), this.getApiVersion(), redirectCallRequest, accept,
-            CoreUtils.randomUuid().toString(), DateTimeRfc1123.toRfc1123String(OffsetDateTime.now()), context);
+            repeatabilityRequestId, repeatabilityFirstSent, context);
     }
 
     /**
@@ -542,7 +560,11 @@ public void redirectCall(RedirectCallRequestInternal redirectCallRequest) {
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     public Mono<Response<Void>> rejectCallWithResponseAsync(RejectCallRequestInternal rejectCallRequest) {
-        return FluxUtil.withContext(context -> rejectCallWithResponseAsync(rejectCallRequest, context));
+        final String accept = "application/json";
+        String repeatabilityRequestId = UUID.randomUUID().toString();
+        String repeatabilityFirstSent = DateTimeRfc1123.toRfc1123String(OffsetDateTime.now());
+        return FluxUtil.withContext(context -> service.rejectCall(this.getEndpoint(), this.getApiVersion(),
+            rejectCallRequest, accept, repeatabilityRequestId, repeatabilityFirstSent, context));
     }
 
     /**
@@ -559,8 +581,10 @@ public Mono<Response<Void>> rejectCallWithResponseAsync(RejectCallRequestInterna
     public Mono<Response<Void>> rejectCallWithResponseAsync(RejectCallRequestInternal rejectCallRequest,
         Context context) {
         final String accept = "application/json";
+        String repeatabilityRequestId = UUID.randomUUID().toString();
+        String repeatabilityFirstSent = DateTimeRfc1123.toRfc1123String(OffsetDateTime.now());
         return service.rejectCall(this.getEndpoint(), this.getApiVersion(), rejectCallRequest, accept,
-            CoreUtils.randomUuid().toString(), DateTimeRfc1123.toRfc1123String(OffsetDateTime.now()), context);
+            repeatabilityRequestId, repeatabilityFirstSent, context);
     }
 
     /**
@@ -634,7 +658,11 @@ public void rejectCall(RejectCallRequestInternal rejectCallRequest) {
     @ServiceMethod(returns = ReturnType.SINGLE)
     public Mono<Response<CallConnectionPropertiesInternal>>
         connectWithResponseAsync(ConnectRequestInternal connectRequest) {
-        return FluxUtil.withContext(context -> connectWithResponseAsync(connectRequest, context));
+        final String accept = "application/json";
+        String repeatabilityRequestId = UUID.randomUUID().toString();
+        String repeatabilityFirstSent = DateTimeRfc1123.toRfc1123String(OffsetDateTime.now());
+        return FluxUtil.withContext(context -> service.connect(this.getEndpoint(), this.getApiVersion(), connectRequest,
+            accept, repeatabilityRequestId, repeatabilityFirstSent, context));
     }
 
     /**
@@ -653,8 +681,10 @@ public void rejectCall(RejectCallRequestInternal rejectCallRequest) {
     public Mono<Response<CallConnectionPropertiesInternal>>
         connectWithResponseAsync(ConnectRequestInternal connectRequest, Context context) {
         final String accept = "application/json";
-        return service.connect(this.getEndpoint(), this.getApiVersion(), connectRequest, accept,
-            CoreUtils.randomUuid().toString(), DateTimeRfc1123.toRfc1123String(OffsetDateTime.now()), context);
+        String repeatabilityRequestId = UUID.randomUUID().toString();
+        String repeatabilityFirstSent = DateTimeRfc1123.toRfc1123String(OffsetDateTime.now());
+        return service.connect(this.getEndpoint(), this.getApiVersion(), connectRequest, accept, repeatabilityRequestId,
+            repeatabilityFirstSent, context);
     }
 
     /**

sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/AzureCommunicationCallAutomationServiceImplBuilder.java

@@ -12,6 +12,7 @@
 import com.azure.core.client.traits.HttpTrait;
 import com.azure.core.credential.AzureKeyCredential;
 import com.azure.core.http.HttpClient;
+import com.azure.core.http.HttpHeaderName;
 import com.azure.core.http.HttpHeaders;
 import com.azure.core.http.HttpPipeline;
 import com.azure.core.http.HttpPipelineBuilder;
@@ -20,8 +21,8 @@
 import com.azure.core.http.policy.AddHeadersFromContextPolicy;
 import com.azure.core.http.policy.AddHeadersPolicy;
 import com.azure.core.http.policy.AzureKeyCredentialPolicy;
-import com.azure.core.http.policy.HttpLogOptions;
 import com.azure.core.http.policy.HttpLoggingPolicy;
+import com.azure.core.http.policy.HttpLogOptions;
 import com.azure.core.http.policy.HttpPipelinePolicy;
 import com.azure.core.http.policy.HttpPolicyProviders;
 import com.azure.core.http.policy.RequestIdPolicy;
@@ -32,7 +33,6 @@
 import com.azure.core.util.Configuration;
 import com.azure.core.util.CoreUtils;
 import com.azure.core.util.builder.ClientBuilderUtil;
-import com.azure.core.util.logging.ClientLogger;
 import com.azure.core.util.serializer.JacksonAdapter;
 import com.azure.core.util.serializer.SerializerAdapter;
 import java.util.ArrayList;
@@ -71,37 +71,34 @@ public AzureCommunicationCallAutomationServiceImplBuilder() {
     }
 
     /*
-     * The HTTP client used to send the request.
+     * The HTTP pipeline to send requests through.
      */
     @Generated
-    private HttpClient httpClient;
+    private HttpPipeline pipeline;
 
     /**
      * {@inheritDoc}.
      */
     @Generated
     @Override
-    public AzureCommunicationCallAutomationServiceImplBuilder httpClient(HttpClient httpClient) {
-        this.httpClient = httpClient;
+    public AzureCommunicationCallAutomationServiceImplBuilder pipeline(HttpPipeline pipeline) {
+        this.pipeline = pipeline;
         return this;
     }
 
     /*
-     * The HTTP pipeline to send requests through.
+     * The HTTP client used to send the request.
      */
     @Generated
-    private HttpPipeline pipeline;
+    private HttpClient httpClient;
 
     /**
      * {@inheritDoc}.
      */
     @Generated
     @Override
-    public AzureCommunicationCallAutomationServiceImplBuilder 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;
+    public AzureCommunicationCallAutomationServiceImplBuilder httpClient(HttpClient httpClient) {
+        this.httpClient = httpClient;
         return this;
     }
 
@@ -273,7 +270,6 @@ public AzureCommunicationCallAutomationServiceImplBuilder retryPolicy(RetryPolic
      */
     @Generated
     public AzureCommunicationCallAutomationServiceImpl buildClient() {
-        this.validateClient();
         HttpPipeline localPipeline = (pipeline != null) ? pipeline : createHttpPipeline();
         String localApiVersion = (apiVersion != null) ? apiVersion : "2025-06-15";
         SerializerAdapter localSerializerAdapter
@@ -283,13 +279,6 @@ public AzureCommunicationCallAutomationServiceImpl buildClient() {
         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.
-        Objects.requireNonNull(endpoint, "'endpoint' cannot be null.");
-    }
-
     @Generated
     private HttpPipeline createHttpPipeline() {
         Configuration buildConfiguration
@@ -303,8 +292,10 @@ private HttpPipeline createHttpPipeline() {
         policies.add(new UserAgentPolicy(applicationId, clientName, clientVersion, buildConfiguration));
         policies.add(new RequestIdPolicy());
         policies.add(new AddHeadersFromContextPolicy());
-        HttpHeaders headers = CoreUtils.createHttpHeadersFromClientOptions(localClientOptions);
-        if (headers != null) {
+        HttpHeaders headers = new HttpHeaders();
+        localClientOptions.getHeaders()
+            .forEach(header -> headers.set(HttpHeaderName.fromString(header.getName()), header.getValue()));
+        if (headers.getSize() > 0) {
             policies.add(new AddHeadersPolicy(headers));
         }
         this.pipelinePolicies.stream()
@@ -327,7 +318,4 @@ private HttpPipeline createHttpPipeline() {
             .build();
         return httpPipeline;
     }
-
-    private static final ClientLogger LOGGER
-        = new ClientLogger(AzureCommunicationCallAutomationServiceImplBuilder.class);
 }