Call Automation GA changes

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

@@ -4,11 +4,11 @@
 
 ### Features Added
 
-### Breaking Changes
-
-### Bugs Fixed
-
-### Other Changes
+- Added support for Teams multipersona users in create call, add participant, transfer, and redirect scenarios in OPS calls
+- Added TeamsAppSource for use when creating outbound OPS calls
+- Recording with the call connection ID is now supported. OPS calls can be recorded using the call connection ID.
+- Added StartRecordingFailed event to indicate when the start recording API is unable to initiate the recording.
+- Adds support for SIP headers prefixed with 'X-' and 'X-MS-Custom-' within the CustomCallingContext.
 
 ## 1.4.1 (2025-06-19)
 

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

@@ -22,7 +22,7 @@ This package contains a Java SDK for Azure Communication Call Automation Service
 <dependency>
     <groupId>com.azure</groupId>
     <artifactId>azure-communication-callautomation</artifactId>
-    <version>1.4.1</version>
+    <version>1.5.0</version>
 </dependency>
 ```
 
@@ -41,61 +41,6 @@ This is the restart of Call Automation Service. It is renamed to Call Automation
 
 `CallAutomationEventParser` provides the functionality to handle events from the ACS resource.
 
-## Examples
-
-### Handle Mid-Connection events with CallAutomation's EventProcessor
-
-To easily handle mid-connection events, Call Automation's SDK provides easier way to handle these events.
-Take a look at `CallAutomationEventProcessor`. This will ensure correlation between call and events more easily.
-
-```Java
-@RestController
-public class ActionController {
-    // Controller implementation...
-
-    @RequestMapping(value = "/api/events", method = POST)
-    public ResponseEntity<?> handleCallEvents(@RequestBody String requestBody) {
-        try {
-            CallAutomationAsyncClient client = getCallAutomationAsyncClient();
-            client.getEventProcessor().processEvents(requestBody);
-
-            return new ResponseEntity<>(HttpStatus.OK);
-        } catch (Exception e) {
-            return new ResponseEntity<>(HttpStatus.INTERNAL_SERVER_ERROR);
-        }
-    }
-}
-```
-
-`processEvents` is required for EventProcessor to work.
-After event is being consumed by EventProcessor, you can start using its feature.
-
-See below for example: where you are making a call with `CreateCall`, and wait for `CallConnected` event of the call.
-
-```Java
-public class commandClass {
-    // Class implementation...
-
-    public void createCallCommand() {
-        CallAutomationAsyncClient client = getCallAutomationAsyncClient(); // Should be the same instance as the one used in the example above.
-        String callbackUrl = "<YOUR_CALL_BACK_URL>";
-        CallInvite callInvite = new CallInvite(new CommunicationUserIdentifier("<TARGET_USER_ID>"));
-        CreateCallResult result = client.createCall(callInvite, callbackUrl).block();
-
-        try {
-            // This will wait until CallConnected event is arrived or Timesout!
-            CreateCallEventResult eventResult = result.waitForEventProcessorAsync(Duration.ofSeconds(30)).block();
-            CallConnected returnedEvent = eventResult.successResult();
-        } catch (Exception e) {
-            // Timeout exception happend!
-            // Call likely was never answered.
-        }
-    }
-}
-```
-
-If timeout was not set when calling "waitForEventProcessorAsync", the default timeout is 4 minutes.
-
 ## Troubleshooting
 
 If you receive a CommunicationErrorException with the message: "Action is invalid when call is not in Established state." This usually means the call has ended. This can occur if the participants all leave

sdk/communication/azure-communication-callautomation/assets.json

@@ -2,5 +2,5 @@
   "AssetsRepo": "Azure/azure-sdk-assets",
   "AssetsRepoPrefixPath": "java",
   "TagPrefix": "java/communication/azure-communication-callautomation",
-  "Tag": "java/communication/azure-communication-callautomation_33108318f9"
+  "Tag": "java/communication/azure-communication-callautomation_89c8cc481e"
 }

sdk/communication/azure-communication-callautomation/pom.xml

@@ -96,7 +96,8 @@
     <dependency>
       <groupId>org.hamcrest</groupId>
       <artifactId>hamcrest-all</artifactId>
-      <version>1.3</version> <!-- {x-version-update;org.hamcrest:hamcrest-all;external_dependency} -->
+      <version>1.3</version>
+      <!-- {x-version-update;org.hamcrest:hamcrest-all;external_dependency} -->
       <scope>test</scope>
     </dependency>
     <dependency>

sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/CallAutomationAsyncClient.java

@@ -11,6 +11,7 @@
 import com.azure.communication.callautomation.implementation.converters.CommunicationIdentifierConverter;
 import com.azure.communication.callautomation.implementation.converters.CommunicationUserIdentifierConverter;
 import com.azure.communication.callautomation.implementation.converters.PhoneNumberIdentifierConverter;
+import com.azure.communication.callautomation.implementation.converters.MicrosoftTeamsAppIdentifierConverter;
 import com.azure.communication.callautomation.implementation.models.AnswerCallRequestInternal;
 import com.azure.communication.callautomation.implementation.models.AudioFormatInternal;
 import com.azure.communication.callautomation.implementation.models.CallIntelligenceOptionsInternal;
@@ -239,6 +240,11 @@ private CreateCallRequestInternal getCreateCallRequestInternal(CreateCallOptions
             request.setTranscriptionOptions(transcriptionOptionsInternal);
         }
 
+        if (createCallOptions.getTeamsAppSource() != null) {
+            request
+                .setTeamsAppSource(MicrosoftTeamsAppIdentifierConverter.convert(createCallOptions.getTeamsAppSource()));
+        }
+
         return request;
     }
 
@@ -278,6 +284,11 @@ private CreateCallRequestInternal getCreateCallRequestInternal(CreateGroupCallOp
             request.setTranscriptionOptions(transcriptionOptionsInternal);
         }
 
+        if (createCallGroupOptions.getTeamsAppSource() != null) {
+            request.setTeamsAppSource(
+                MicrosoftTeamsAppIdentifierConverter.convert(createCallGroupOptions.getTeamsAppSource()));
+        }
+
         return request;
     }
 

sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/CallAutomationServiceVersion.java

@@ -33,7 +33,11 @@ public enum CallAutomationServiceVersion implements ServiceVersion {
     /**
     * Service version {@code 2025-05-15}.
     */
-    V2025_05_15("2025-05-15");
+    V2025_05_15("2025-05-15"),
+    /**
+    * Service version {@code 2025-06-15}.
+    */
+    V2025_06_15("2025-06-15");
 
     private final String version;
 
@@ -55,6 +59,6 @@ public String getVersion() {
      * @return The latest {@link CallAutomationServiceVersion} object.
      */
     public static CallAutomationServiceVersion getLatest() {
-        return V2025_05_15;
+        return V2025_06_15;
     }
 }

sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/CallConnectionAsync.java

@@ -38,6 +38,7 @@
 import com.azure.communication.common.MicrosoftTeamsAppIdentifier;
 import com.azure.communication.common.MicrosoftTeamsUserIdentifier;
 import com.azure.communication.common.PhoneNumberIdentifier;
+import com.azure.communication.common.TeamsExtensionUserIdentifier;
 import com.azure.core.annotation.ReturnType;
 import com.azure.core.annotation.ServiceMethod;
 import com.azure.core.exception.HttpResponseException;
@@ -259,6 +260,10 @@ public Mono<TransferCallResult> transferCallToParticipant(CommunicationIdentifie
             return transferCallToParticipantWithResponse(
                 new TransferCallToParticipantOptions((MicrosoftTeamsAppIdentifier) targetParticipant))
                     .flatMap(FluxUtil::toMono);
+        } else if (targetParticipant instanceof TeamsExtensionUserIdentifier) {
+            return transferCallToParticipantWithResponse(
+                new TransferCallToParticipantOptions((TeamsExtensionUserIdentifier) targetParticipant))
+                    .flatMap(FluxUtil::toMono);
         } else {
             throw logger.logExceptionAsError(new IllegalArgumentException("targetParticipant type is invalid."));
         }

sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/CallRecordingAsync.java

@@ -186,6 +186,9 @@ private StartCallRecordingRequestInternal getStartCallRecordingRequest(StartReco
         if (options.isPauseOnStart() != null) {
             request.setPauseOnStart(options.isPauseOnStart());
         }
+        if (options.getCallConnectionId() != null) {
+            request.setCallConnectionId(options.getCallConnectionId());
+        }
         return request;
     }
 

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

@@ -275,7 +275,7 @@ public AzureCommunicationCallAutomationServiceImplBuilder retryPolicy(RetryPolic
     public AzureCommunicationCallAutomationServiceImpl buildClient() {
         this.validateClient();
         HttpPipeline localPipeline = (pipeline != null) ? pipeline : createHttpPipeline();
-        String localApiVersion = (apiVersion != null) ? apiVersion : "2025-05-15";
+        String localApiVersion = (apiVersion != null) ? apiVersion : "2025-06-15";
         SerializerAdapter localSerializerAdapter
             = (serializerAdapter != null) ? serializerAdapter : JacksonAdapter.createDefaultSerializerAdapter();
         AzureCommunicationCallAutomationServiceImpl client = new AzureCommunicationCallAutomationServiceImpl(

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

@@ -63,7 +63,7 @@ public final class CallRecordingsImpl {
     @ServiceInterface(name = "AzureCommunicationCallAutomationServiceCallRecordings")
     public interface CallRecordingsService {
         @Post("/calling/recordings")
-        @ExpectedResponses({ 200 })
+        @ExpectedResponses({ 200, 202 })
         @UnexpectedResponseExceptionType(CommunicationErrorResponseException.class)
         Mono<Response<RecordingStateResponseInternal>> startRecording(@HostParam("endpoint") String endpoint,
             @QueryParam("api-version") String apiVersion,

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

@@ -10,12 +10,14 @@
 import com.azure.communication.callautomation.implementation.models.MicrosoftTeamsAppIdentifierModel;
 import com.azure.communication.callautomation.implementation.models.MicrosoftTeamsUserIdentifierModel;
 import com.azure.communication.callautomation.implementation.models.PhoneNumberIdentifierModel;
+import com.azure.communication.callautomation.implementation.models.TeamsExtensionUserIdentifierModel;
 import com.azure.communication.common.CommunicationCloudEnvironment;
 import com.azure.communication.common.CommunicationIdentifier;
 import com.azure.communication.common.CommunicationUserIdentifier;
 import com.azure.communication.common.MicrosoftTeamsAppIdentifier;
 import com.azure.communication.common.MicrosoftTeamsUserIdentifier;
 import com.azure.communication.common.PhoneNumberIdentifier;
+import com.azure.communication.common.TeamsExtensionUserIdentifier;
 import com.azure.communication.common.UnknownIdentifier;
 
 import java.util.ArrayList;
@@ -66,6 +68,25 @@ public static CommunicationIdentifier convert(CommunicationIdentifierModel ident
                         CommunicationCloudEnvironment.fromString(teamsUserIdentifierModel.getCloud().toString()));
         }
 
+        if (kind == CommunicationIdentifierModelKind.TEAMS_EXTENSION_USER
+            && identifier.getTeamsExtensionUser() != null) {
+            TeamsExtensionUserIdentifierModel teamsExtensionUserIdentifierModel = identifier.getTeamsExtensionUser();
+            Objects.requireNonNull(teamsExtensionUserIdentifierModel.getUserId(),
+                "'UserID' of the CommunicationIdentifierModel cannot be null.");
+            Objects.requireNonNull(teamsExtensionUserIdentifierModel.getResourceId(),
+                "'ResourceId' of the CommunicationIdentifierModel cannot be null.");
+            Objects.requireNonNull(teamsExtensionUserIdentifierModel.getTenantId(),
+                "'TenantId' of the CommunicationIdentifierModel cannot be null.");
+            Objects.requireNonNull(teamsExtensionUserIdentifierModel.getCloud(),
+                "'Cloud' of the CommunicationIdentifierModel cannot be null.");
+            Objects.requireNonNull(rawId, "'RawID' of the CommunicationIdentifierModel cannot be null.");
+            return new TeamsExtensionUserIdentifier(teamsExtensionUserIdentifierModel.getUserId(),
+                teamsExtensionUserIdentifierModel.getTenantId(), teamsExtensionUserIdentifierModel.getResourceId())
+                    .setRawId(rawId)
+                    .setCloudEnvironment(CommunicationCloudEnvironment
+                        .fromString(teamsExtensionUserIdentifierModel.getCloud().toString()));
+        }
+
         if (kind == CommunicationIdentifierModelKind.MICROSOFT_TEAMS_APP && identifier.getMicrosoftTeamsApp() != null) {
             MicrosoftTeamsAppIdentifierModel teamsUserIdentifierModel = identifier.getMicrosoftTeamsApp();
             Objects.requireNonNull(teamsUserIdentifierModel.getAppId(),
@@ -122,6 +143,17 @@ public static CommunicationIdentifierModel convert(CommunicationIdentifier ident
                         .fromString(teamsAppIdentifier.getCloudEnvironment().toString())));
         }
 
+        if (identifier instanceof TeamsExtensionUserIdentifier) {
+            TeamsExtensionUserIdentifier teamsExtensionUserIdentifier = (TeamsExtensionUserIdentifier) identifier;
+            return new CommunicationIdentifierModel().setRawId(teamsExtensionUserIdentifier.getRawId())
+                .setTeamsExtensionUser(
+                    new TeamsExtensionUserIdentifierModel().setResourceId(teamsExtensionUserIdentifier.getResourceId())
+                        .setUserId(teamsExtensionUserIdentifier.getUserId())
+                        .setTenantId(teamsExtensionUserIdentifier.getTenantId())
+                        .setCloud(CommunicationCloudEnvironmentModel
+                            .fromString(teamsExtensionUserIdentifier.getCloudEnvironment().toString())));
+        }
+
         if (identifier instanceof UnknownIdentifier) {
             UnknownIdentifier unknownIdentifier = (UnknownIdentifier) identifier;
             return new CommunicationIdentifierModel().setRawId(unknownIdentifier.getId());
@@ -171,6 +203,9 @@ private static CommunicationIdentifierModelKind extractKind(CommunicationIdentif
         if (identifier.getMicrosoftTeamsApp() != null) {
             return CommunicationIdentifierModelKind.MICROSOFT_TEAMS_APP;
         }
+        if (identifier.getTeamsExtensionUser() != null) {
+            return CommunicationIdentifierModelKind.TEAMS_EXTENSION_USER;
+        }
         return CommunicationIdentifierModelKind.UNKNOWN;
     }
 }

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

@@ -55,6 +55,12 @@ public final class CommunicationIdentifierModel implements JsonSerializable<Comm
     @Generated
     private MicrosoftTeamsAppIdentifierModel microsoftTeamsApp;
 
+    /*
+     * The Microsoft Teams Extension user.
+     */
+    @Generated
+    private TeamsExtensionUserIdentifierModel teamsExtensionUser;
+
     /**
      * Creates an instance of CommunicationIdentifierModel class.
      */
@@ -194,6 +200,28 @@ public CommunicationIdentifierModel setMicrosoftTeamsApp(MicrosoftTeamsAppIdenti
         return this;
     }
 
+    /**
+     * Get the teamsExtensionUser property: The Microsoft Teams Extension user.
+     * 
+     * @return the teamsExtensionUser value.
+     */
+    @Generated
+    public TeamsExtensionUserIdentifierModel getTeamsExtensionUser() {
+        return this.teamsExtensionUser;
+    }
+
+    /**
+     * Set the teamsExtensionUser property: The Microsoft Teams Extension user.
+     * 
+     * @param teamsExtensionUser the teamsExtensionUser value to set.
+     * @return the CommunicationIdentifierModel object itself.
+     */
+    @Generated
+    public CommunicationIdentifierModel setTeamsExtensionUser(TeamsExtensionUserIdentifierModel teamsExtensionUser) {
+        this.teamsExtensionUser = teamsExtensionUser;
+        return this;
+    }
+
     /**
      * {@inheritDoc}
      */
@@ -207,6 +235,7 @@ public JsonWriter toJson(JsonWriter jsonWriter) throws IOException {
         jsonWriter.writeJsonField("phoneNumber", this.phoneNumber);
         jsonWriter.writeJsonField("microsoftTeamsUser", this.microsoftTeamsUser);
         jsonWriter.writeJsonField("microsoftTeamsApp", this.microsoftTeamsApp);
+        jsonWriter.writeJsonField("teamsExtensionUser", this.teamsExtensionUser);
         return jsonWriter.writeEndObject();
     }
 
@@ -242,6 +271,9 @@ public static CommunicationIdentifierModel fromJson(JsonReader jsonReader) throw
                 } else if ("microsoftTeamsApp".equals(fieldName)) {
                     deserializedCommunicationIdentifierModel.microsoftTeamsApp
                         = MicrosoftTeamsAppIdentifierModel.fromJson(reader);
+                } else if ("teamsExtensionUser".equals(fieldName)) {
+                    deserializedCommunicationIdentifierModel.teamsExtensionUser
+                        = TeamsExtensionUserIdentifierModel.fromJson(reader);
                 } else {
                     reader.skipChildren();
                 }

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

@@ -42,6 +42,12 @@ public final class CommunicationIdentifierModelKind extends ExpandableStringEnum
     @Generated
     public static final CommunicationIdentifierModelKind MICROSOFT_TEAMS_APP = fromString("microsoftTeamsApp");
 
+    /**
+     * Static value teamsExtensionUser for CommunicationIdentifierModelKind.
+     */
+    @Generated
+    public static final CommunicationIdentifierModelKind TEAMS_EXTENSION_USER = fromString("teamsExtensionUser");
+
     /**
      * Creates a new instance of CommunicationIdentifierModelKind value.
      *