Rhurey/remove sync (Azure#52946)

* Remove sync API's and make AgentOptions internal

* Parsing errors are errors

* Update changelog

* Update test

* Latest TS Update

* Change casing of file

* Update for moved spec files

Author: rhurey

sdk/ai/Azure.AI.VoiceLive/CHANGELOG.md

@@ -1,14 +1,33 @@
 # Release History
 
-## 1.0.0-beta.4 (Unreleased)
-
-### Features Added
+## 1.0.0-beta.4 (2025-09-30)
 
 ### Breaking Changes
 
-### Bugs Fixed
-
-### Other Changes
+- Removed all synchronous methods from `VoiceLiveClient` and `VoiceLiveSession` classes.
+  - `VoiceLiveClient.StartSession()` - use `StartSessionAsync()` instead
+  - `VoiceLiveSession.AddItem()` - use `AddItemAsync()` instead
+  - `VoiceLiveSession.AppendAudioToTurn()` - use `AppendAudioToTurnAsync()` instead
+  - `VoiceLiveSession.CancelAudioTurn()` - use `CancelAudioTurnAsync()` instead
+  - `VoiceLiveSession.CancelResponse()` - use `CancelResponseAsync()` instead
+  - `VoiceLiveSession.ClearInputAudio()` - use `ClearInputAudioAsync()` instead
+  - `VoiceLiveSession.ClearStreamingAudio()` - use `ClearStreamingAudioAsync()` instead
+  - `VoiceLiveSession.Close()` - use `CloseAsync()` instead
+  - `VoiceLiveSession.CommitInputAudio()` - use `CommitInputAudioAsync()` instead
+  - `VoiceLiveSession.ConfigureSession()` - use `ConfigureSessionAsync()` instead
+  - `VoiceLiveSession.Connect()` - use `ConnectAsync()` instead
+  - `VoiceLiveSession.ConnectAvatar()` - use `ConnectAvatarAsync()` instead
+  - `VoiceLiveSession.DeleteItem()` - use `DeleteItemAsync()` instead
+  - `VoiceLiveSession.EndAudioTurn()` - use `EndAudioTurnAsync()` instead
+  - `VoiceLiveSession.GetUpdates()` - use `GetUpdatesAsync()` instead
+  - `VoiceLiveSession.ReceiveUpdates()` - use `ReceiveUpdatesAsync()` instead
+  - `VoiceLiveSession.RequestItemRetrieval()` - use `RequestItemRetrievalAsync()` instead
+  - `VoiceLiveSession.SendCommand()` - use `SendCommandAsync()` instead
+  - `VoiceLiveSession.SendInputAudio()` - use `SendInputAudioAsync()` instead
+  - `VoiceLiveSession.StartAudioTurn()` - use `StartAudioTurnAsync()` instead
+  - `VoiceLiveSession.StartResponse()` - use `StartResponseAsync()` instead
+  - `VoiceLiveSession.TruncateConversation()` - use `TruncateConversationAsync()` instead
+- Removed `RespondingAgentOptions` and associated property usage.
 
 ## 1.0.0-beta.3 (2025-09-26)
 

sdk/ai/Azure.AI.VoiceLive/api/Azure.AI.VoiceLive.net8.0.cs

@@ -0,0 +1,14 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+#nullable disable
+
+using System;
+using System.Collections.Generic;
+
+namespace Azure.AI.VoiceLive
+{
+    /// <summary> Configuration for the agent. </summary>
+    internal partial class RespondingAgentOptions
+    {}
+}

sdk/ai/Azure.AI.VoiceLive/api/Azure.AI.VoiceLive.netstandard2.0.cs

@@ -74,19 +74,6 @@ protected internal virtual async Task ConnectAsync(IDictionary<string, string> h
             }
         }
 
-        /// <summary>
-        /// Initializes an underlying <see cref="WebSocket"/> instance for communication with the VoiceLive service and
-        /// then connects to the service using this socket.
-        /// </summary>
-        /// <param name="cancellationToken">The cancellation token to use.</param>
-        /// <param name="headers">Headers to send.</param>
-        protected internal virtual void Connect(IDictionary<string, string> headers, CancellationToken cancellationToken = default)
-        {
-#pragma warning disable AZC0106
-            ConnectAsync(headers, cancellationToken).EnsureCompleted();
-#pragma warning restore AZC0106
-        }
-
         /// <summary>
         /// Closes the WebSocket connection gracefully.
         /// </summary>
@@ -110,17 +97,6 @@ await WebSocket.CloseAsync(
             }
         }
 
-        /// <summary>
-        /// Closes the WebSocket connection gracefully.
-        /// </summary>
-        /// <param name="cancellationToken">The cancellation token to use.</param>
-        public virtual void Close(CancellationToken cancellationToken = default)
-        {
-#pragma warning disable AZC0107
-            CloseAsync(cancellationToken).EnsureCompleted();
-#pragma warning restore AZC0107
-        }
-
         /// <summary>
         /// Gets the current state of the WebSocket connection.
         /// </summary>

sdk/ai/Azure.AI.VoiceLive/src/Customizations/RespondingAgentOptions.cs

@@ -68,20 +68,6 @@ public async IAsyncEnumerable<SessionUpdate> GetUpdatesAsync([EnumeratorCancella
             }
         }
 
-        /// <summary>
-        /// Gets all server events from the VoiceLive service synchronously.
-        /// </summary>
-        /// <param name="cancellationToken">The cancellation token to use.</param>
-        /// <returns>An enumerable of VoiceLive server events.</returns>
-        /// <remarks>
-        /// This method provides synchronous access to all server events from the service.
-        /// For better performance and resource utilization, consider using <see cref="GetUpdatesAsync(CancellationToken)"/> instead.
-        /// </remarks>
-        public IEnumerable<SessionUpdate> GetUpdates(CancellationToken cancellationToken = default)
-        {
-            return GetUpdatesAsync(cancellationToken).ToBlockingEnumerable(cancellationToken);
-        }
-
         /// <summary>
         /// Gets server events of a specific type from the VoiceLive service.
         /// </summary>
@@ -130,25 +116,13 @@ private IEnumerable<SessionUpdate> ProcessMessage(BinaryData message)
             }
 
             SessionUpdate sessionUpdate = null;
-            try
-            {
-                // Try to parse as JSON first
-                using JsonDocument document = JsonDocument.Parse(message);
-                JsonElement root = document.RootElement;
 
-                // Deserialize as a server event
-                sessionUpdate = SessionUpdate.DeserializeSessionUpdate(root, ModelSerializationExtensions.WireOptions);
-            }
-            catch (JsonException)
-            {
-                // If JSON parsing fails, ignore the message
-                yield break;
-            }
-            catch (Exception)
-            {
-                // If deserialization fails completely, ignore the message
-                yield break;
-            }
+            // Try to parse as JSON first
+            using JsonDocument document = JsonDocument.Parse(message);
+            JsonElement root = document.RootElement;
+
+            // Deserialize as a server event
+            sessionUpdate = SessionUpdate.DeserializeSessionUpdate(root, ModelSerializationExtensions.WireOptions);
 
             if (sessionUpdate != null)
             {

sdk/ai/Azure.AI.VoiceLive/src/Customizations/VoiceLiveSession.Commands.cs

@@ -139,60 +139,6 @@ public virtual async Task SendInputAudioAsync(Stream audio, CancellationToken ca
             }
         }
 
-        /// <summary>
-        /// Transmits audio data from a stream, ending the client turn once the stream is complete.
-        /// </summary>
-        /// <param name="audio">The audio stream to transmit.</param>
-        /// <param name="cancellationToken">An optional cancellation token.</param>
-        /// <exception cref="ArgumentNullException">Thrown when <paramref name="audio"/> is null.</exception>
-        /// <exception cref="InvalidOperationException">Thrown when another audio stream is already being sent.</exception>
-        public virtual void SendInputAudio(Stream audio, CancellationToken cancellationToken = default)
-        {
-            Argument.AssertNotNull(audio, nameof(audio));
-            ThrowIfDisposed();
-
-            using (_audioSendSemaphore.AutoReleaseWait(cancellationToken))
-            {
-                if (_isSendingAudioStream)
-                {
-                    throw new InvalidOperationException("Only one stream of audio may be sent at once.");
-                }
-                _isSendingAudioStream = true;
-            }
-
-            byte[] buffer = null;
-            try
-            {
-                buffer = ArrayPool<byte>.Shared.Rent(1024 * 16);
-                while (true)
-                {
-                    int bytesRead = audio.Read(buffer, 0, buffer.Length);
-                    if (bytesRead == 0)
-                    {
-                        break;
-                    }
-
-                    ReadOnlyMemory<byte> audioMemory = buffer.AsMemory(0, bytesRead);
-                    BinaryData audioData = BinaryData.FromBytes(audioMemory);
-                    string base64Audio = Convert.ToBase64String(audioData.ToArray());
-                    ClientEventInputAudioBufferAppend appendCommand = new(base64Audio);
-                    BinaryData requestData = BinaryData.FromObjectAsJson(appendCommand);
-                    SendCommand(requestData, cancellationToken);
-                }
-            }
-            finally
-            {
-                if (buffer is not null)
-                {
-                    ArrayPool<byte>.Shared.Return(buffer);
-                }
-                using (_audioSendSemaphore.AutoReleaseWait(cancellationToken))
-                {
-                    _isSendingAudioStream = false;
-                }
-            }
-        }
-
         /// <summary>
         /// Sends a command to the service asynchronously.
         /// </summary>
@@ -209,21 +155,6 @@ internal virtual async Task SendCommandAsync(ClientEvent command, CancellationTo
             await SendCommandAsync(data, cancellationToken).ConfigureAwait(false);
         }
 
-        /// <summary>
-        /// Sends a command to the service.
-        /// </summary>
-        /// <param name="command">The command to send.</param>
-        /// <param name="cancellationToken">The cancellation token to use.</param>
-        /// <exception cref="ArgumentNullException">Thrown when <paramref name="command"/> is null.</exception>
-        internal virtual void SendCommand(ClientEvent command, CancellationToken cancellationToken = default)
-        {
-            Argument.AssertNotNull(command, nameof(command));
-            ThrowIfDisposed();
-
-            BinaryData data = BinaryData.FromObjectAsJson(command);
-            SendCommand(data, cancellationToken);
-        }
-
         /// <summary>
         /// Sends raw data to the service asynchronously.
         /// </summary>
@@ -274,20 +205,6 @@ public virtual async Task SendCommandAsync(RequestContent data, CancellationToke
             await SendCommandAsync(BinaryData.FromStream(ms), cancellationToken).ConfigureAwait(false);
         }
 
-#pragma warning disable AZC0107 // Client methods should return approved types
-        /// <summary>
-        /// Sends raw data to the service.
-        /// </summary>
-        /// <param name="data">The data to send.</param>
-        /// <param name="cancellationToken">The cancellation token to use.</param>
-        /// <exception cref="ArgumentNullException">Thrown when <paramref name="data"/> is null.</exception>
-        public virtual void SendCommand(BinaryData data, CancellationToken cancellationToken = default)
-        {
-            // ClientWebSocket does not include a synchronous Send()
-            SendCommandAsync(data, cancellationToken).EnsureCompleted();
-        }
-#pragma warning restore AZC0107
-
         /// <summary>
         /// Receives updates from the service asynchronously.
         /// </summary>
@@ -308,16 +225,6 @@ public virtual async IAsyncEnumerable<BinaryData> ReceiveUpdatesAsync([Enumerato
             }
         }
 
-        /// <summary>
-        /// Receives updates from the service.
-        /// </summary>
-        /// <param name="cancellationToken">The cancellation token to use.</param>
-        /// <returns>An enumerable of binary data messages.</returns>
-        public virtual IEnumerable<BinaryData> ReceiveUpdates(CancellationToken cancellationToken = default)
-        {
-            throw new NotSupportedException("Synchronous enumeration of WebSocket messages is not supported. Use ReceiveUpdatesAsync instead.");
-        }
-
         /// <inheritdoc/>
         public void Dispose()
         {

sdk/ai/Azure.AI.VoiceLive/src/Customizations/VoiceLiveSession.Protocol.cs

@@ -0,0 +1,17 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+#nullable disable
+
+using System;
+using System.Collections.Generic;
+
+namespace Azure.AI.VoiceLive
+{
+    /// <summary> Base for session configuration in the response. </summary>
+    public partial class VoiceLiveSessionResponse : VoiceLiveSessionOptions
+    {
+        /// <summary> The agent configuration for the session, if applicable. </summary>
+        internal RespondingAgentOptions Agent { get; }
+    }
+}