CallAutomation GA5 Changes (#45494)

* ga5 changes

* ga5 api changes

* Made GA5 changes and recorded the live tests. (#45409)

* Addressing arb comments

* Added the parser for the dtmf data. (#45347)

* Added the parser for the dtmf data.

* Removed dtmf meta data.

---------

Co-authored-by: Vinothini Dharmaraj <[email protected]>

* updating the white space difference

* addressing the arb comments

* GA5 Javadoc Issues (#45432)

* Fixed Javadoc issues in StreamingData.java & TranscriptionOptions.java

* Renamed MediaStreamingContent class to MediaStreamingContentType. Renamed getChannels() to getChannelType() in AudioMetaData.java

* Re-recorded tests and fixed linting issues (unused imports). (#45448)

* updating java missing fields

* lint errors

* moving transport url

* Addressing the ARB Comments

* addressing the arb comments

* addressing all arb comments

* updating the transcription and media streaming options

* Fixed Javadoc issues + updated ga5 version. (#45496)

* Fixing the lint errors

* fixing the lint error

* updating the changelog

* Updating the changelog and release date

* changing the release date

* Increment package versions for communication/azure-communication-callautomation releases (#45603)

* taking the main changes for the dependancy package updates

* dependancy package updates

* updating the identity package

* updating the cutomization for the getparticipant

* version number update

* running latest autorest

* version update

* updating readme version

---------

Co-authored-by: v-pivamshi <[email protected]>
Co-authored-by: v-saasomani <[email protected]>
Co-authored-by: Azure SDK Bot <[email protected]>

Author: 4 people

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

@@ -4,8 +4,6 @@
 
 ### Features Added
 
-- Support for recording result api.
-
 ### Breaking Changes
 
 ### Bugs Fixed
@@ -22,16 +20,16 @@
 - Upgraded `azure-core-http-netty` from `1.15.11` to version `1.15.12`.
 - Upgraded `azure-core` from `1.55.3` to version `1.55.4`.
 
-
 ## 1.4.0 (2025-06-05)
 
 ### Features Added
 
-### Breaking Changes
-
-### Bugs Fixed
-
-### Other Changes
+- Real-time transcription support
+- Audio and DTMF streaming capabilities
+- Integration of ConnectAPI for seamless streaming and transcription
+- Improved media streaming with bidirectional functionality, allowing audio formats in both directions, currently supporting sample rates of 24kHz and 16kHz
+- Support for custom speech models has been integrated into transcription
+- A confidence level for recognized speech has been introduced, ranging from 0.0 to 1.0 when available
 
 ## 1.3.3 (2025-03-24)
 
@@ -54,6 +52,16 @@
 - Upgraded `azure-core-http-netty` from `1.15.7` to version `1.15.10`.
 - Upgraded `azure-core` from `1.54.1` to version `1.55.2`.
 
+## 1.3.1 (2024-12-04)
+
+### Other Changes
+
+#### Dependency Updates
+
+- Upgraded `azure-core` from `1.53.0` to version `1.54.1`.
+- Upgraded `azure-core-http-netty` from `1.15.5` to version `1.15.7`.
+- Upgraded `azure-communication-common` from `1.3.7` to version `1.3.8`.
+
 ## 1.4.0-beta.1 (2024-11-22)
 
 ### Features Added

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.0-beta.2</version>
+    <version>1.4.1</version>
 </dependency>
 ```
 

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_d495ba2a2c"
+  "Tag": "java/communication/azure-communication-callautomation_33108318f9"
 }

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

@@ -95,6 +95,12 @@
       <version>9.37.3</version> <!-- {x-version-update;com.nimbusds:nimbus-jose-jwt;external_dependency} -->
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>org.hamcrest</groupId>
+      <artifactId>hamcrest-all</artifactId>
+      <version>1.3</version> <!-- {x-version-update;org.hamcrest:hamcrest-all;external_dependency} -->
+      <scope>test</scope>
+    </dependency>
     <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-identity</artifactId>

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

@@ -42,14 +42,6 @@ public final class CallAutomationClient {
         this.callAutomationAsyncClient = callAutomationAsyncClient;
     }
 
-    /**
-     * Get the event processor for handling events.
-     * @return {@link CallAutomationEventProcessor} as event processor
-     */
-    public CallAutomationEventProcessor getEventProcessor() {
-        return callAutomationAsyncClient.getEventProcessor();
-    }
-
     /**
      * Get Source Identity that is used for create and answer call
      * @return {@link CommunicationUserIdentifier} represent source

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

@@ -101,17 +101,6 @@ public CallAutomationClientBuilder endpoint(String endpoint) {
         return this;
     }
 
-    /**
-     * Set pma endpoint override of the service.
-     *
-     * @param pmaEndpoint url of the service.
-     * @return CallAutomationClientBuilder object.
-     */
-    public CallAutomationClientBuilder pmaEndpoint(String pmaEndpoint) {
-        this.pmaEndpoint = Objects.requireNonNull(pmaEndpoint, "'pmaEndpoint' cannot be null.");
-        return this;
-    }
-
     /**
      * Sets the {@link HttpPipeline} to use for the service client.
      *
@@ -319,7 +308,7 @@ public CallAutomationClientBuilder addPolicy(HttpPipelinePolicy customPolicy) {
      * and {@link #retryPolicy(RetryPolicy)} have been set.
      */
     public CallAutomationAsyncClient buildAsyncClient() {
-        return new CallAutomationAsyncClient(createServiceImpl(), sourceIdentity, new CallAutomationEventProcessor());
+        return new CallAutomationAsyncClient(createServiceImpl(), sourceIdentity);
     }
 
     /**

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

@@ -23,29 +23,14 @@
 import com.azure.communication.callautomation.models.events.ContinuousDtmfRecognitionToneFailed;
 import com.azure.communication.callautomation.models.events.ContinuousDtmfRecognitionToneReceived;
 import com.azure.communication.callautomation.models.events.CreateCallFailed;
-import com.azure.communication.callautomation.models.events.DialogCompleted;
-import com.azure.communication.callautomation.models.events.DialogConsent;
-import com.azure.communication.callautomation.models.events.DialogFailed;
-import com.azure.communication.callautomation.models.events.DialogHangup;
-import com.azure.communication.callautomation.models.events.DialogLanguageChange;
-import com.azure.communication.callautomation.models.events.DialogSensitivityUpdate;
-import com.azure.communication.callautomation.models.events.DialogStarted;
-import com.azure.communication.callautomation.models.events.DialogTransfer;
-import com.azure.communication.callautomation.models.events.HoldAudioCompleted;
-import com.azure.communication.callautomation.models.events.HoldAudioPaused;
-import com.azure.communication.callautomation.models.events.HoldAudioResumed;
-import com.azure.communication.callautomation.models.events.HoldAudioStarted;
 import com.azure.communication.callautomation.models.events.HoldFailed;
-import com.azure.communication.callautomation.models.events.IncomingCall;
 import com.azure.communication.callautomation.models.events.MediaStreamingFailed;
 import com.azure.communication.callautomation.models.events.MediaStreamingStarted;
 import com.azure.communication.callautomation.models.events.MediaStreamingStopped;
 import com.azure.communication.callautomation.models.events.ParticipantsUpdated;
 import com.azure.communication.callautomation.models.events.PlayCanceled;
 import com.azure.communication.callautomation.models.events.PlayCompleted;
 import com.azure.communication.callautomation.models.events.PlayFailed;
-import com.azure.communication.callautomation.models.events.PlayPaused;
-import com.azure.communication.callautomation.models.events.PlayResumed;
 import com.azure.communication.callautomation.models.events.PlayStarted;
 import com.azure.communication.callautomation.models.events.RecognizeCanceled;
 import com.azure.communication.callautomation.models.events.RecognizeCompleted;
@@ -55,7 +40,6 @@
 import com.azure.communication.callautomation.models.events.RemoveParticipantSucceeded;
 import com.azure.communication.callautomation.models.events.SendDtmfTonesCompleted;
 import com.azure.communication.callautomation.models.events.SendDtmfTonesFailed;
-import com.azure.communication.callautomation.models.events.StartRecordingFailed;
 import com.azure.communication.callautomation.models.events.TranscriptionFailed;
 import com.azure.communication.callautomation.models.events.TranscriptionResumed;
 import com.azure.communication.callautomation.models.events.TranscriptionStarted;
@@ -123,8 +107,6 @@ private static CallAutomationEventBase parseSingleCloudEvent(String data, String
                 ret = CallConnected.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.CallDisconnected")) {
                 ret = CallDisconnected.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.IncomingCall")) {
-                ret = IncomingCall.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.AddParticipantFailed")) {
                 ret = AddParticipantFailed.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.AddParticipantSucceeded")) {
@@ -137,8 +119,6 @@ private static CallAutomationEventBase parseSingleCloudEvent(String data, String
                 ret = ParticipantsUpdated.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.RecordingStateChanged")) {
                 ret = RecordingStateChanged.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.StartRecordingFailed")) {
-                ret = StartRecordingFailed.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.PlayCompleted")) {
                 ret = PlayCompleted.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.PlayFailed")) {
@@ -147,10 +127,6 @@ private static CallAutomationEventBase parseSingleCloudEvent(String data, String
                 ret = PlayStarted.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.PlayCanceled")) {
                 ret = PlayCanceled.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.PlayPaused")) {
-                ret = PlayPaused.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.PlayResumed")) {
-                ret = PlayResumed.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.RecognizeCompleted")) {
                 ret = RecognizeCompleted.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.RecognizeFailed")) {
@@ -175,22 +151,6 @@ private static CallAutomationEventBase parseSingleCloudEvent(String data, String
                 ret = CancelAddParticipantSucceeded.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.CancelAddParticipantFailed")) {
                 ret = CancelAddParticipantFailed.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.DialogStarted")) {
-                ret = DialogStarted.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.DialogCompleted")) {
-                ret = DialogCompleted.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.DialogFailed")) {
-                ret = DialogFailed.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.DialogConsent")) {
-                ret = DialogConsent.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.DialogHangup")) {
-                ret = DialogHangup.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.DialogLanguageChange")) {
-                ret = DialogLanguageChange.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.DialogTransfer")) {
-                ret = DialogTransfer.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.DialogSensitivityUpdate")) {
-                ret = DialogSensitivityUpdate.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.TranscriptionStarted")) {
                 ret = TranscriptionStarted.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.TranscriptionFailed")) {
@@ -205,14 +165,6 @@ private static CallAutomationEventBase parseSingleCloudEvent(String data, String
                 ret = AnswerFailed.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.CreateCallFailed")) {
                 ret = CreateCallFailed.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.HoldAudioCompleted")) {
-                ret = HoldAudioCompleted.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.HoldAudioStarted")) {
-                ret = HoldAudioStarted.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.HoldAudioPaused")) {
-                ret = HoldAudioPaused.fromJson(jsonReader);
-            } else if (Objects.equals(eventType, "Microsoft.Communication.HoldAudioResumed")) {
-                ret = HoldAudioResumed.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.HoldFailed")) {
                 ret = HoldFailed.fromJson(jsonReader);
             } else if (Objects.equals(eventType, "Microsoft.Communication.ConnectFailed")) {