Adding repeatable headers to start recording (Azure#31701)

Author: cochi2

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

@@ -22,6 +22,7 @@
 import com.azure.communication.callautomation.models.GroupCallLocator;
 import com.azure.communication.callautomation.models.ParallelDownloadOptions;
 import com.azure.communication.callautomation.models.RecordingStateResult;
+import com.azure.communication.callautomation.models.RepeatabilityHeaders;
 import com.azure.communication.callautomation.models.ServerCallLocator;
 import com.azure.communication.callautomation.models.StartRecordingOptions;
 import com.azure.core.annotation.ReturnType;
@@ -51,10 +52,12 @@
 import java.nio.file.Path;
 import java.nio.file.StandardOpenOption;
 import java.security.InvalidParameterException;
+import java.time.Instant;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Objects;
 import java.util.Set;
+import java.util.UUID;
 import java.util.stream.Collectors;
 
 import static com.azure.core.util.FluxUtil.monoError;
@@ -120,10 +123,19 @@ Mono<Response<RecordingStateResult>> startRecordingWithResponseInternal(StartRec
             }
             StartCallRecordingRequestInternal request = getStartCallRecordingRequest(options);
 
+            if (options.getRepeatabilityHeaders() == null) {
+                RepeatabilityHeaders autoRepeatabilityHeaders = new RepeatabilityHeaders(UUID.randomUUID(), Instant.now());
+                options.setRepeatabilityHeaders(autoRepeatabilityHeaders);
+            }
+
             return withContext(contextValue -> {
                 contextValue = context == null ? contextValue : context;
                 return contentsInternal
-                    .recordingWithResponseAsync(request, null, null, contextValue)
+                    .recordingWithResponseAsync(
+                        request,
+                        options.getRepeatabilityHeaders().getRepeatabilityRequestId(),
+                        options.getRepeatabilityHeaders().getRepeatabilityFirstSentInHttpDateFormat(),
+                        contextValue)
                     .onErrorMap(HttpResponseException.class, ErrorConstructorProxy::create)
                     .map(response ->
                         new SimpleResponse<>(response, RecordingStateResponseConstructorProxy.create(response.getValue()))

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

@@ -29,6 +29,8 @@ public class StartRecordingOptions {
 
     private List<CommunicationIdentifier> audioChannelParticipantOrdering;
 
+    private RepeatabilityHeaders repeatabilityHeaders;
+
     /**
      * Constructor
      *
@@ -156,4 +158,25 @@ public StartRecordingOptions setAudioChannelParticipantOrdering(List<Communicati
         this.audioChannelParticipantOrdering = audioChannelParticipantOrdering;
         return this;
     }
+
+    /**
+     * Get the Repeatability headers configuration.
+     *
+     * @return the repeatabilityHeaders
+     */
+    public RepeatabilityHeaders getRepeatabilityHeaders() {
+        return repeatabilityHeaders;
+    }
+
+
+    /**
+     * Set the repeatability headers
+     *
+     * @param repeatabilityHeaders The repeatability headers configuration.
+     * @return the StartRecordingOptions object itself.
+     */
+    public StartRecordingOptions setRepeatabilityHeaders(RepeatabilityHeaders repeatabilityHeaders) {
+        this.repeatabilityHeaders = repeatabilityHeaders;
+        return this;
+    }
 }