Added get recording result api. (Azure#45825)

* init commit

* Changelog

Author: amariwest-msft

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

@@ -4,6 +4,8 @@
 
 ### Features Added
 
+- Support for recording result api.
+
 ### Breaking Changes
 
 ### Bugs Fixed

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

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

@@ -346,7 +346,7 @@ private TranscriptionOptionsInternal getTranscriptionOptionsInternal(Transcripti
             .setLocale(transcriptionOptions.getLocale())
             .setStartTranscription(transcriptionOptions.getStartTranscription())
             .setEnableIntermediateResults(transcriptionOptions.isIntermediateResultsEnabled())
-            .setSpeechRecognitionModelEndpointId(transcriptionOptions.getSpeechRecognitionModelEndpointId());
+            .setSpeechModelEndpointId(transcriptionOptions.getSpeechRecognitionModelEndpointId());
     }
 
     /**

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

@@ -840,7 +840,7 @@ Mono<Response<Void>> startTranscriptionWithResponseInternal(StartTranscriptionOp
             if (options != null) {
                 request.setLocale(options.getLocale());
                 request.setOperationContext(options.getOperationContext());
-                request.setSpeechRecognitionModelEndpointId(options.getSpeechRecognitionModelEndpointId());
+                request.setSpeechModelEndpointId(options.getSpeechRecognitionModelEndpointId());
             }
             return contentsInternal.startTranscriptionWithResponseAsync(callConnectionId, request, context);
         } catch (RuntimeException ex) {
@@ -936,7 +936,7 @@ Mono<Response<Void>> updateTranscriptionWithResponseInternal(String locale, Stri
             context = context == null ? Context.NONE : context;
             UpdateTranscriptionRequestInternal request = new UpdateTranscriptionRequestInternal();
             request.setLocale(locale);
-            request.setSpeechRecognitionModelEndpointId(speechRecognitionModelEndpointId);
+            request.setSpeechModelEndpointId(speechRecognitionModelEndpointId);
             request.setOperationContext(operationContext);
             return contentsInternal.updateTranscriptionWithResponseAsync(callConnectionId, request, context);
         } catch (RuntimeException ex) {

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

@@ -19,6 +19,8 @@
 import java.security.InvalidParameterException;
 import java.util.Objects;
 
+import com.azure.communication.callautomation.models.RecordingResult;
+
 /**
  * CallRecording.
  */
@@ -163,6 +165,33 @@ public Response<RecordingStateResult> getStateWithResponse(String recordingId, C
         return callRecordingAsync.getStateWithResponseInternal(recordingId, context).block();
     }
 
+    /**
+    * Get the recording result by recording id.
+    *
+    * @param recordingId The recording id to stop.
+    * @throws HttpResponseException thrown if the request is rejected by server.
+    * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+    * @return Response for a successful get recording state request.
+    */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public RecordingResult getRecordingResult(String recordingId) {
+        return callRecordingAsync.getRecordingResult(recordingId).block();
+    }
+
+    /**
+     * Get the recording result by recording id.
+     *
+     * @param recordingId The recording id to stop.
+     * @param context A {@link Context} representing the request context.
+     * @throws HttpResponseException thrown if the request is rejected by server.
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+     * @return Response for a successful get recording state request.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public Response<RecordingResult> getRecordingResult(String recordingId, Context context) {
+        return callRecordingAsync.getRecordingResultResponseInternal(recordingId, context).block();
+    }
+
     /**
      * Download the recording content, e.g. Recording's metadata, Recording video, etc., from
      * {@code endpoint} and write it in the {@link OutputStream} passed as parameter.

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

@@ -20,6 +20,7 @@
 import java.util.stream.Collectors;
 
 import com.azure.communication.callautomation.implementation.CallRecordingsImpl;
+import com.azure.communication.callautomation.implementation.accesshelpers.RecordingResultResponseConstructorProxy;
 import com.azure.communication.callautomation.implementation.accesshelpers.RecordingStateResponseConstructorProxy;
 import com.azure.communication.callautomation.implementation.converters.CommunicationIdentifierConverter;
 import com.azure.communication.callautomation.implementation.models.CallLocatorInternal;
@@ -39,6 +40,7 @@
 import com.azure.communication.callautomation.models.DownloadToFileOptions;
 import com.azure.communication.callautomation.models.GroupCallLocator;
 import com.azure.communication.callautomation.models.ParallelDownloadOptions;
+import com.azure.communication.callautomation.models.RecordingResult;
 import com.azure.communication.callautomation.models.RecordingStateResult;
 import com.azure.communication.callautomation.models.RoomCallLocator;
 import com.azure.communication.callautomation.models.ServerCallLocator;
@@ -342,6 +344,45 @@ Mono<Response<RecordingStateResult>> getStateWithResponseInternal(String recordi
         }
     }
 
+    /**
+    * Get recording result by recording id.
+    *
+    * @param recordingId Recording id to stop.
+    * @throws HttpResponseException thrown if the request is rejected by server.
+    * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+    * @return Response for a successful get recording state request.
+    */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public Mono<RecordingResult> getRecordingResult(String recordingId) {
+        return getRecordingResultResponse(recordingId).flatMap(response -> Mono.just(response.getValue()));
+    }
+
+    /**
+     * Get recording result by recording id.
+     *
+     * @param recordingId Recording id to stop.
+     * @throws HttpResponseException thrown if the request is rejected by server.
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+     * @return Response for a successful get recording state request.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public Mono<Response<RecordingResult>> getRecordingResultResponse(String recordingId) {
+        return getRecordingResultResponseInternal(recordingId, null);
+    }
+
+    Mono<Response<RecordingResult>> getRecordingResultResponseInternal(String recordingId, Context context) {
+        try {
+            return withContext(contextValue -> {
+                contextValue = context == null ? contextValue : context;
+                return callRecordingsInternal.getRecordingResultWithResponseAsync(recordingId, contextValue)
+                    .map(response -> new SimpleResponse<>(response,
+                        RecordingResultResponseConstructorProxy.create(response.getValue())));
+            });
+        } catch (RuntimeException ex) {
+            return monoError(logger, ex);
+        }
+    }
+
     /**
      * Download the recording content, e.g. Recording's metadata, Recording video, from the ACS endpoint
      * passed as parameter.

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

@@ -12,6 +12,8 @@
 import com.azure.communication.callautomation.implementation.models.CancelAddParticipantResponse;
 import com.azure.communication.callautomation.implementation.models.CommunicationErrorResponseException;
 import com.azure.communication.callautomation.implementation.models.GetParticipantsResponseInternal;
+import com.azure.communication.callautomation.implementation.models.MoveParticipantsRequest;
+import com.azure.communication.callautomation.implementation.models.MoveParticipantsResponse;
 import com.azure.communication.callautomation.implementation.models.MuteParticipantsRequestInternal;
 import com.azure.communication.callautomation.implementation.models.MuteParticipantsResultInternal;
 import com.azure.communication.callautomation.implementation.models.RemoveParticipantRequestInternal;
@@ -169,6 +171,16 @@ Mono<Response<CancelAddParticipantResponse>> cancelAddParticipant(@HostParam("en
             @HeaderParam("repeatability-request-id") String repeatabilityRequestId,
             @HeaderParam("repeatability-first-sent") String repeatabilityFirstSent, Context context);
 
+        @Post("/calling/callConnections/{callConnectionId}/participants:moveHere")
+        @ExpectedResponses({ 202 })
+        @UnexpectedResponseExceptionType(CommunicationErrorResponseException.class)
+        Mono<Response<MoveParticipantsResponse>> moveParticipants(@HostParam("endpoint") String endpoint,
+            @PathParam("callConnectionId") String callConnectionId, @QueryParam("api-version") String apiVersion,
+            @BodyParam("application/json") MoveParticipantsRequest moveParticipantRequest,
+            @HeaderParam("Accept") String accept,
+            @HeaderParam("repeatability-request-id") String repeatabilityRequestId,
+            @HeaderParam("repeatability-first-sent") String repeatabilityFirstSent, Context context);
+
         @Get("/calling/callConnections/{callConnectionId}/participants/{participantRawId}")
         @ExpectedResponses({ 200 })
         @UnexpectedResponseExceptionType(CommunicationErrorResponseException.class)
@@ -1230,6 +1242,113 @@ public CancelAddParticipantResponse cancelAddParticipant(String callConnectionId
         return cancelAddParticipantWithResponse(callConnectionId, cancelAddParticipantRequest, Context.NONE).getValue();
     }
 
+    /**
+     * Add a participant to the call.
+     * 
+     * @param callConnectionId The call connection Id.
+     * @param moveParticipantRequest The move participants request.
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws CommunicationErrorResponseException thrown if the request is rejected by server.
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+     * @return the response payload for moving participants to the call along with {@link Response} on successful
+     * completion of {@link Mono}.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public Mono<Response<MoveParticipantsResponse>> moveParticipantsWithResponseAsync(String callConnectionId,
+        MoveParticipantsRequest moveParticipantRequest) {
+        return FluxUtil.withContext(
+            context -> moveParticipantsWithResponseAsync(callConnectionId, moveParticipantRequest, context));
+    }
+
+    /**
+     * Add a participant to the call.
+     * 
+     * @param callConnectionId The call connection Id.
+     * @param moveParticipantRequest The move participants request.
+     * @param context The context to associate with this operation.
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws CommunicationErrorResponseException thrown if the request is rejected by server.
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+     * @return the response payload for moving participants to the call along with {@link Response} on successful
+     * completion of {@link Mono}.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public Mono<Response<MoveParticipantsResponse>> moveParticipantsWithResponseAsync(String callConnectionId,
+        MoveParticipantsRequest moveParticipantRequest, Context context) {
+        final String accept = "application/json";
+        return service.moveParticipants(this.client.getEndpoint(), callConnectionId, this.client.getApiVersion(),
+            moveParticipantRequest, accept, CoreUtils.randomUuid().toString(),
+            DateTimeRfc1123.toRfc1123String(OffsetDateTime.now()), context);
+    }
+
+    /**
+     * Add a participant to the call.
+     * 
+     * @param callConnectionId The call connection Id.
+     * @param moveParticipantRequest The move participants request.
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws CommunicationErrorResponseException thrown if the request is rejected by server.
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+     * @return the response payload for moving participants to the call on successful completion of {@link Mono}.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public Mono<MoveParticipantsResponse> moveParticipantsAsync(String callConnectionId,
+        MoveParticipantsRequest moveParticipantRequest) {
+        return moveParticipantsWithResponseAsync(callConnectionId, moveParticipantRequest)
+            .flatMap(res -> Mono.justOrEmpty(res.getValue()));
+    }
+
+    /**
+     * Add a participant to the call.
+     * 
+     * @param callConnectionId The call connection Id.
+     * @param moveParticipantRequest The move participants request.
+     * @param context The context to associate with this operation.
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws CommunicationErrorResponseException thrown if the request is rejected by server.
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+     * @return the response payload for moving participants to the call on successful completion of {@link Mono}.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public Mono<MoveParticipantsResponse> moveParticipantsAsync(String callConnectionId,
+        MoveParticipantsRequest moveParticipantRequest, Context context) {
+        return moveParticipantsWithResponseAsync(callConnectionId, moveParticipantRequest, context)
+            .flatMap(res -> Mono.justOrEmpty(res.getValue()));
+    }
+
+    /**
+     * Add a participant to the call.
+     * 
+     * @param callConnectionId The call connection Id.
+     * @param moveParticipantRequest The move participants request.
+     * @param context The context to associate with this operation.
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws CommunicationErrorResponseException thrown if the request is rejected by server.
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+     * @return the response payload for moving participants to the call along with {@link Response}.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public Response<MoveParticipantsResponse> moveParticipantsWithResponse(String callConnectionId,
+        MoveParticipantsRequest moveParticipantRequest, Context context) {
+        return moveParticipantsWithResponseAsync(callConnectionId, moveParticipantRequest, context).block();
+    }
+
+    /**
+     * Add a participant to the call.
+     * 
+     * @param callConnectionId The call connection Id.
+     * @param moveParticipantRequest The move participants request.
+     * @throws IllegalArgumentException thrown if parameters fail the validation.
+     * @throws CommunicationErrorResponseException thrown if the request is rejected by server.
+     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+     * @return the response payload for moving participants to the call.
+     */
+    @ServiceMethod(returns = ReturnType.SINGLE)
+    public MoveParticipantsResponse moveParticipants(String callConnectionId,
+        MoveParticipantsRequest moveParticipantRequest) {
+        return moveParticipantsWithResponse(callConnectionId, moveParticipantRequest, Context.NONE).getValue();
+    }
+
     /**
      * Get participant from a call.
      * 

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

@@ -64,7 +64,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/accesshelpers/RecordingResultResponseConstructorProxy.java

@@ -0,0 +1,57 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.communication.callautomation.implementation.accesshelpers;
+
+import com.azure.communication.callautomation.implementation.models.RecordingResultResponse;
+import com.azure.communication.callautomation.models.RecordingResult;
+
+/**
+ * Helper class to access private values of {@link RecordingResult} across package boundaries.
+ */
+public final class RecordingResultResponseConstructorProxy {
+    private static RecordingResultResponseConstructorAccessor accessor;
+
+    private RecordingResultResponseConstructorProxy() {
+    }
+
+    /**
+     * Type defining the methods to set the non-public properties of a {@link RecordingResultResponseConstructorAccessor}
+     * instance.
+     */
+    public interface RecordingResultResponseConstructorAccessor {
+        /**
+         * Creates a new instance of {@link RecordingResult} backed by an internal instance of
+         * {@link RecordingResultResponse}.
+         *
+         * @param internalResponse The internal response.
+         * @return A new instance of {@link RecordingResult}.
+         */
+        RecordingResult create(RecordingResultResponse internalResponse);
+    }
+
+    /**
+     * The method called from {@link RecordingResult} to set it's accessor.
+     *
+     * @param accessor The accessor.
+     */
+    public static void setAccessor(final RecordingResultResponseConstructorAccessor accessor) {
+        RecordingResultResponseConstructorProxy.accessor = accessor;
+    }
+
+    /**
+     * Creates a new instance of {@link RecordingResult} backed by an internal instance of
+     * {@link RecordingResultResponse}.
+     *
+     * @param internalResponse The internal response.
+     * @return A new instance of {@link RecordingResult}.
+     */
+    public static RecordingResult create(RecordingResultResponse internalResponse) {
+        if (accessor == null) {
+            new RecordingResult();
+        }
+
+        assert accessor != null;
+        return accessor.create(internalResponse);
+    }
+}