cnblogs
diff --git a/‎Cnblogs.DashScope.Sdk.sln.DotSettings
Lines changed: 2 additions & 0 deletions b/‎Cnblogs.DashScope.Sdk.sln.DotSettings
Lines changed: 2 additions & 0 deletions
diff --git a/‎src/Cnblogs.DashScope.AI/Cnblogs.DashScope.AI.csproj
Lines changed: 1 addition & 1 deletion b/‎src/Cnblogs.DashScope.AI/Cnblogs.DashScope.AI.csproj
Lines changed: 1 addition & 1 deletion
diff --git a/‎src/Cnblogs.DashScope.AspNetCore/DashScopeClientAspNetCore.cs
Lines changed: 13 additions & 2 deletions b/‎src/Cnblogs.DashScope.AspNetCore/DashScopeClientAspNetCore.cs
Lines changed: 13 additions & 2 deletions
diff --git a/‎src/Cnblogs.DashScope.Core/DashScopeClientWebSocketPool.cs
Lines changed: 14 additions & 5 deletions b/‎src/Cnblogs.DashScope.Core/DashScopeClientWebSocketPool.cs
Lines changed: 14 additions & 5 deletions
diff --git a/‎src/Cnblogs.DashScope.Core/DashScopeWebSocketRequest.cs
Lines changed: 2 additions & 2 deletions b/‎src/Cnblogs.DashScope.Core/DashScopeWebSocketRequest.cs
Lines changed: 2 additions & 2 deletions
diff --git a/‎src/Cnblogs.DashScope.Core/DashScopeWebSocketRequestHeader.cs
Lines changed: 2 additions & 2 deletions b/‎src/Cnblogs.DashScope.Core/DashScopeWebSocketRequestHeader.cs
Lines changed: 2 additions & 2 deletions
diff --git a/‎src/Cnblogs.DashScope.Core/DashScopeWebSocketRequestPayload.cs
Lines changed: 1 addition & 1 deletion b/‎src/Cnblogs.DashScope.Core/DashScopeWebSocketRequestPayload.cs
Lines changed: 1 addition & 1 deletion
diff --git a/‎src/Cnblogs.DashScope.Core/Internals/ClientWebSocketWrapper.cs
Lines changed: 15 additions & 8 deletions b/‎src/Cnblogs.DashScope.Core/Internals/ClientWebSocketWrapper.cs
Lines changed: 15 additions & 8 deletions
diff --git a/‎src/Cnblogs.DashScope.Core/Internals/DashScopeDefaults.cs
Lines changed: 1 addition & 1 deletion b/‎src/Cnblogs.DashScope.Core/Internals/DashScopeDefaults.cs
Lines changed: 1 addition & 1 deletion
diff --git a/‎src/Cnblogs.DashScope.Core/SpeechSynthesizerParameters.cs
Lines changed: 1 addition & 1 deletion b/‎src/Cnblogs.DashScope.Core/SpeechSynthesizerParameters.cs
Lines changed: 1 addition & 1 deletion
diff --git a/‎src/Cnblogs.DashScope.Core/SpeechSynthesizerSocketSession.cs
Lines changed: 23 additions & 11 deletions b/‎src/Cnblogs.DashScope.Core/SpeechSynthesizerSocketSession.cs
Lines changed: 23 additions & 11 deletions
diff --git a/‎test/Cnblogs.DashScope.Sdk.UnitTests/BaiChuanApiTests.cs
Lines changed: 31 additions & 2 deletions b/‎test/Cnblogs.DashScope.Sdk.UnitTests/BaiChuanApiTests.cs
Lines changed: 31 additions & 2 deletions
diff --git a/‎test/Cnblogs.DashScope.Sdk.UnitTests/Cnblogs.DashScope.Sdk.UnitTests.csproj
Lines changed: 0 additions & 1 deletion b/‎test/Cnblogs.DashScope.Sdk.UnitTests/Cnblogs.DashScope.Sdk.UnitTests.csproj
Lines changed: 0 additions & 1 deletion
diff --git a/‎test/Cnblogs.DashScope.Sdk.UnitTests/DashScopeClientWebSocketTests.cs
Lines changed: 1 addition & 0 deletions b/‎test/Cnblogs.DashScope.Sdk.UnitTests/DashScopeClientWebSocketTests.cs
Lines changed: 1 addition & 0 deletions
@@ -1,6 +1,8 @@
 <wpf:ResourceDictionary xml:space="preserve" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:s="clr-namespace:System;assembly=mscorlib" xmlns:ss="urn:shemas-jetbrains-com:settings-storage-xaml" xmlns:wpf="http://schemas.microsoft.com/winfx/2006/xaml/presentation">
+	<s:Boolean x:Key="/Default/Environment/Filtering/ExcludeCoverageFilters/=Cnblogs_002EDashScope_002EAI_002EUnitTests_003B_002A_003B_002A_003B_002A/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/Environment/Filtering/ExcludeCoverageFilters/=Cnblogs_002EDashScope_002ESample_003B_002A_003B_002A_003B_002A/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/Environment/Filtering/ExcludeCoverageFilters/=Cnblogs_002EDashScope_002ESdk_002ESnapshotGenerator_003B_002A_003B_002A_003B_002A/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/Environment/Filtering/ExcludeCoverageFilters/=Cnblogs_002EDashScope_002ESdk_002EUnitTests_003B_002A_003B_002A_003B_002A/@EntryIndexedValue">True</s:Boolean>
+	<s:Boolean x:Key="/Default/Environment/Filtering/ExcludeCoverageFilters/=Cnblogs_002EDashScope_002ETests_002EShared_003B_002A_003B_002A_003B_002A/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/Environment/Filtering/ExcludeCoverageFilters/=Cnblogs_002EDashScope_002EWebSample_002EClient_003B_002A_003B_002A_003B_002A/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/Environment/Filtering/ExcludeCoverageFilters/=Cnblogs_002EDashScope_002EWebSample_003B_002A_003B_002A_003B_002A/@EntryIndexedValue">True</s:Boolean></wpf:ResourceDictionary>
@@ -11,7 +11,7 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="JsonSchema.Net.Generation" Version="5.0.2" />
+    <PackageReference Include="JsonSchema.Net.Generation" Version="5.0.3" />
     <PackageReference Include="Microsoft.Extensions.AI.Abstractions" Version="9.5.0" />
   </ItemGroup>
 
 
@@ -5,5 +5,16 @@ namespace Cnblogs.DashScope.AspNetCore;
 /// <summary>
 /// The <see cref="DashScopeClientCore"/> with DI and options pattern support.
 /// </summary>
-public class DashScopeClientAspNetCore(IHttpClientFactory factory, DashScopeClientWebSocketPool pool)
-    : DashScopeClientCore(factory.CreateClient(DashScopeAspNetCoreDefaults.DefaultHttpClientName), pool);
+public class DashScopeClientAspNetCore
+    : DashScopeClientCore
+{
+    /// <summary>
+    /// The <see cref="DashScopeClientCore"/> with DI and options pattern support.
+    /// </summary>
+    /// <param name="factory">The factory to create <see cref="HttpClient"/>.</param>
+    /// <param name="pool">The socket pool for WebSocket API calls.</param>
+    public DashScopeClientAspNetCore(IHttpClientFactory factory, DashScopeClientWebSocketPool pool)
+        : base(factory.CreateClient(DashScopeAspNetCoreDefaults.DefaultHttpClientName), pool)
+    {
+    }
+}
@@ -5,11 +5,20 @@ namespace Cnblogs.DashScope.Core;
 /// <summary>
 /// Socket pool for DashScope API.
 /// </summary>
-/// <param name="options"></param>
-public sealed class DashScopeClientWebSocketPool(DashScopeOptions options) : IDisposable
+public sealed class DashScopeClientWebSocketPool : IDisposable
 {
     private readonly ConcurrentBag<DashScopeClientWebSocket> _available = new();
     private readonly ConcurrentBag<DashScopeClientWebSocket> _active = new();
+    private readonly DashScopeOptions _options;
+
+    /// <summary>
+    /// Socket pool for DashScope API.
+    /// </summary>
+    /// <param name="options">Options for DashScope sdk.</param>
+    public DashScopeClientWebSocketPool(DashScopeOptions options)
+    {
+        _options = options;
+    }
 
     internal void ReturnSocketAsync(DashScopeClientWebSocket socket)
     {
@@ -49,7 +58,7 @@ public async Task<DashScopeClientWebSocketWrapper> RentSocketAsync<TOutput>(
             }
             else
             {
-                socket = await InitializeNewSocketAsync<TOutput>(options.BaseWebsocketAddress, cancellationToken);
+                socket = await InitializeNewSocketAsync<TOutput>(_options.BaseWebsocketAddress, cancellationToken);
                 found = true;
             }
         }
@@ -68,12 +77,12 @@ private async Task<DashScopeClientWebSocket> InitializeNewSocketAsync<TOutput>(
         CancellationToken cancellationToken = default)
         where TOutput : class
     {
-        if (_available.Count + _active.Count >= options.SocketPoolSize)
+        if (_available.Count + _active.Count >= _options.SocketPoolSize)
         {
             throw new InvalidOperationException("[DashScopeSDK] Socket pool is full");
         }
 
-        var socket = new DashScopeClientWebSocket(options.ApiKey, options.WorkspaceId);
+        var socket = new DashScopeClientWebSocket(_options.ApiKey, _options.WorkspaceId);
         await socket.ConnectAsync<TOutput>(new Uri(url), cancellationToken);
         return socket;
     }
 
@@ -12,10 +12,10 @@ public class DashScopeWebSocketRequest<TInput, TParameter>
     /// <summary>
     /// Metadata of the request.
     /// </summary>
-    public required DashScopeWebSocketRequestHeader Header { get; set; }
+    public DashScopeWebSocketRequestHeader Header { get; set; } = new();
 
     /// <summary>
     /// Payload of the request.
     /// </summary>
-    public required DashScopeWebSocketRequestPayload<TInput, TParameter> Payload { get; set; }
+    public DashScopeWebSocketRequestPayload<TInput, TParameter> Payload { get; set; } = new();
 }
@@ -8,12 +8,12 @@ public class DashScopeWebSocketRequestHeader
     /// <summary>
     /// Action name.
     /// </summary>
-    public required string Action { get; set; }
+    public string Action { get; set; } = string.Empty;
 
     /// <summary>
     /// UUID for task.
     /// </summary>
-    public required string TaskId { get; set; }
+    public string TaskId { get; set; } = string.Empty;
 
     /// <summary>
     /// Streaming type.
 
@@ -37,5 +37,5 @@ public class DashScopeWebSocketRequestPayload<TInput, TParameter>
     /// <summary>
     /// The input of the request.
     /// </summary>
-    public required TInput Input { get; set; }
+    public TInput Input { get; set; } = null!;
 }
@@ -2,39 +2,46 @@
 
 namespace Cnblogs.DashScope.Core.Internals;
 
-internal sealed class ClientWebSocketWrapper(ClientWebSocket socket) : IClientWebSocket
+internal sealed class ClientWebSocketWrapper : IClientWebSocket
 {
+    private readonly ClientWebSocket _socket;
+
+    public ClientWebSocketWrapper(ClientWebSocket socket)
+    {
+        _socket = socket;
+    }
+
     /// <inheritdoc />
     public void Dispose()
     {
-        socket.Dispose();
+        _socket.Dispose();
     }
 
     /// <inheritdoc />
-    public ClientWebSocketOptions Options => socket.Options;
+    public ClientWebSocketOptions Options => _socket.Options;
 
     /// <inheritdoc />
-    public WebSocketCloseStatus? CloseStatus => socket.CloseStatus;
+    public WebSocketCloseStatus? CloseStatus => _socket.CloseStatus;
 
     /// <inheritdoc />
-    public Task ConnectAsync(Uri uri, CancellationToken cancellation) => socket.ConnectAsync(uri, cancellation);
+    public Task ConnectAsync(Uri uri, CancellationToken cancellation) => _socket.ConnectAsync(uri, cancellation);
 
     /// <inheritdoc />
     public Task SendAsync(
         ArraySegment<byte> buffer,
         WebSocketMessageType messageType,
         bool endOfMessage,
         CancellationToken cancellationToken)
-        => socket.SendAsync(buffer, messageType, endOfMessage, cancellationToken);
+        => _socket.SendAsync(buffer, messageType, endOfMessage, cancellationToken);
 
     /// <inheritdoc />
     public Task<WebSocketReceiveResult> ReceiveAsync(ArraySegment<byte> buffer, CancellationToken cancellationToken)
-        => socket.ReceiveAsync(buffer, cancellationToken);
+        => _socket.ReceiveAsync(buffer, cancellationToken);
 
     /// <inheritdoc />
     public Task CloseAsync(
         WebSocketCloseStatus closeStatus,
         string? statusDescription,
         CancellationToken cancellationToken)
-        => socket.CloseAsync(closeStatus, statusDescription, cancellationToken);
+        => _socket.CloseAsync(closeStatus, statusDescription, cancellationToken);
 }
@@ -25,6 +25,6 @@ public static class DashScopeDefaults
         new()
         {
             DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull,
-            PropertyNamingPolicy = JsonNamingPolicy.SnakeCaseLower,
+            PropertyNamingPolicy = JsonSnakeCaseLowerNamingPolicy.SnakeCaseLower,
         };
 }
@@ -13,7 +13,7 @@ public class SpeechSynthesizerParameters
     /// <summary>
     /// The voice to use.
     /// </summary>
-    public required string Voice { get; set; }
+    public string Voice { get; set; } = string.Empty;
 
     /// <summary>
     /// Output file format, can be pcm, wav or mp3.
 
@@ -3,11 +3,23 @@
 /// <summary>
 /// Represents a socket-based TTS session.
 /// </summary>
-/// <param name="socket">Underlying websocket.</param>
-/// <param name="modelId">Model name to use.</param>
-public sealed class SpeechSynthesizerSocketSession(DashScopeClientWebSocketWrapper socket, string modelId)
+public sealed class SpeechSynthesizerSocketSession
     : IDisposable
 {
+    private readonly DashScopeClientWebSocketWrapper _socket;
+    private readonly string _modelId;
+
+    /// <summary>
+    /// Represents a socket-based TTS session.
+    /// </summary>
+    /// <param name="socket">Underlying websocket.</param>
+    /// <param name="modelId">Model name to use.</param>
+    public SpeechSynthesizerSocketSession(DashScopeClientWebSocketWrapper socket, string modelId)
+    {
+        _socket = socket;
+        _modelId = modelId;
+    }
+
     /// <summary>
     /// Send a run-task command, use random GUID as taskId.
     /// </summary>
@@ -49,13 +61,13 @@ public async Task<string> RunTaskAsync(
                 TaskGroup = "audio",
                 Task = "tts",
                 Function = "SpeechSynthesizer",
-                Model = modelId,
+                Model = _modelId,
                 Parameters = parameters
             }
         };
-        socket.ResetTask();
-        await socket.SendMessageAsync(command, cancellationToken);
-        await socket.TaskStarted;
+        _socket.ResetTask();
+        await _socket.SendMessageAsync(command, cancellationToken);
+        await _socket.TaskStarted;
         return taskId;
     }
 
@@ -78,7 +90,7 @@ public async Task ContinueTaskAsync(string taskId, string input, CancellationTok
                 Input = new SpeechSynthesizerInput() { Text = input }
             }
         };
-        await socket.SendMessageAsync(command, cancellationToken);
+        await _socket.SendMessageAsync(command, cancellationToken);
     }
 
     /// <summary>
@@ -96,7 +108,7 @@ public async Task FinishTaskAsync(string taskId, CancellationToken cancellationT
                 Input = new SpeechSynthesizerInput()
             }
         };
-        await socket.SendMessageAsync(command, cancellationToken);
+        await _socket.SendMessageAsync(command, cancellationToken);
     }
 
     /// <summary>
@@ -105,14 +117,14 @@ public async Task FinishTaskAsync(string taskId, CancellationToken cancellationT
     /// <returns></returns>
     public IAsyncEnumerable<byte> GetAudioAsync()
     {
-        return socket.BinaryOutput;
+        return _socket.BinaryOutput;
     }
 
     private void Dispose(bool disposing)
     {
         if (disposing)
         {
-            socket.Dispose();
+            _socket.Dispose();
         }
     }
 
 
@@ -22,19 +22,32 @@ public async Task BaiChuanTextGeneration_UseEnum_SuccessAsync()
                 s => s.Model == "baichuan-7b-v1" && s.Input.Prompt == Cases.Prompt && s.Parameters == null));
     }
 
+    [Fact]
+    public async Task BaiChuanTextGeneration_UseInvalidEnum_SuccessAsync()
+    {
+        // Arrange
+        var client = Substitute.For<IDashScopeClient>();
+
+        // Act
+        var act = async () => await client.GetBaiChuanTextCompletionAsync((BaiChuanLlm)(-1), Cases.Prompt);
+
+        // Assert
+        await Assert.ThrowsAsync<ArgumentOutOfRangeException>(act);
+    }
+
     [Fact]
     public async Task BaiChuanTextGeneration_CustomModel_SuccessAsync()
     {
         // Arrange
         var client = Substitute.For<IDashScopeClient>();
 
         // Act
-        _ = await client.GetBaiChuanTextCompletionAsync(BaiChuanLlm.BaiChuan7B, Cases.Prompt);
+        _ = await client.GetBaiChuanTextCompletionAsync(Cases.CustomModelName, Cases.Prompt);
 
         // Assert
         _ = await client.Received().GetTextCompletionAsync(
             Arg.Is<ModelRequest<TextGenerationInput, ITextGenerationParameters>>(
-                s => s.Model == "baichuan-7b-v1" && s.Input.Prompt == Cases.Prompt && s.Parameters == null));
+                s => s.Model == Cases.CustomModelName && s.Input.Prompt == Cases.Prompt && s.Parameters == null));
     }
 
     [Fact]
@@ -43,6 +56,22 @@ public async Task BaiChuan2TextGeneration_UseEnum_SuccessAsync()
         // Arrange
         var client = Substitute.For<IDashScopeClient>();
 
+        // Act
+        var act = async () => await client.GetBaiChuanTextCompletionAsync(
+            (BaiChuan2Llm)(-1),
+            Cases.TextMessages,
+            ResultFormats.Message);
+
+        // Assert
+        await Assert.ThrowsAsync<ArgumentOutOfRangeException>(act);
+    }
+
+    [Fact]
+    public async Task BaiChuan2TextGeneration_UseInvalidEnum_SuccessAsync()
+    {
+        // Arrange
+        var client = Substitute.For<IDashScopeClient>();
+
         // Act
         _ = await client.GetBaiChuanTextCompletionAsync(
             BaiChuan2Llm.BaiChuan2_13BChatV1,
 
@@ -11,7 +11,6 @@
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>
-    <PackageReference Include="FluentAssertions" Version="8.2.0"/>
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.13.0"/>
     <PackageReference Include="NSubstitute" Version="5.3.0"/>
     <PackageReference Include="xunit" Version="2.9.3"/>
 
@@ -88,6 +88,7 @@ public async Task ResetOutput_WithInitialOutput_CompleteThenCreateNewOutputAsync
         // Arrange
         var socket = Substitute.For<IClientWebSocket>();
         var client = new DashScopeClientWebSocket(socket);
+        client.ResetOutput();
         var oldOutput = client.BinaryOutput;
         var oldSignal = client.TaskStarted;