test: 增加单元测试

Author: ArgoZhang

src/BootstrapBlazor/Services/TcpSocket/DataPackage/DataPackageAdapterOfGeneric.cs

@@ -43,12 +43,11 @@ public interface IDataPackageAdapter
     /// <summary>
     /// Attempts to convert the specified binary data into an object representation.
     /// </summary>
-    /// <remarks>This method does not throw exceptions for invalid input. Instead, it returns <see
-    /// langword="false"/>  if the conversion fails, and <paramref name="entity"/> will be <see
-    /// langword="null"/>.</remarks>
+    /// <remarks>This method does not throw an exception if the conversion fails. Instead, it returns  <see
+    /// langword="false"/> and sets <paramref name="entity"/> to <see langword="null"/>.</remarks>
     /// <param name="data">The binary data to be converted. Must not be empty.</param>
     /// <param name="entity">When this method returns <see langword="true"/>, contains the converted object.  When this method returns <see
-    /// langword="false"/>, the value is <see langword="null"/>.</param>
+    /// langword="false"/>, contains <see langword="null"/>.</param>
     /// <returns><see langword="true"/> if the conversion was successful; otherwise, <see langword="false"/>.</returns>
     bool TryConvertTo(ReadOnlyMemory<byte> data, [NotNullWhen(true)] out object? entity);
 }

src/BootstrapBlazor/Services/TcpSocket/DataPackage/IDataPackageAdapter.cs

@@ -482,6 +482,44 @@ public async Task TryConvertTo_Ok()
         Assert.NotNull(entity);
         Assert.Equal(entity.Header, [1, 2, 3, 4, 5]);
         Assert.Equal(entity.Body, [3, 4]);
+
+        // 测试异常流程
+        var adapter2 = new DataPackageAdapter();
+        var result = adapter2.TryConvertTo(data, out var t);
+        Assert.False(result);
+        Assert.Null(t);
+    }
+
+    [Fact]
+    public async Task TryConvertTo_Null()
+    {
+        var port = 8890;
+        var server = StartTcpServer(port, MockSplitPackageAsync);
+        var client = CreateClient();
+        var tcs = new TaskCompletionSource();
+        MockEntity? entity = null;
+
+        // 设置数据适配器
+        var adapter = new MockErrorEntityDataPackageAdapter
+        {
+            DataPackageHandler = new FixLengthDataPackageHandler(7),
+        };
+        client.SetDataPackageAdapter<MockEntity>(adapter, t =>
+        {
+            entity = t;
+            tcs.SetResult();
+            return Task.CompletedTask;
+        });
+
+        // 连接 TCP Server
+        var connect = await client.ConnectAsync("localhost", port);
+
+        // 发送数据
+        var data = new ReadOnlyMemory<byte>([1, 2, 3, 4, 5]);
+        await client.SendAsync(data);
+        await tcs.Task;
+
+        Assert.Null(entity);
     }
 
     private static TcpListener StartTcpServer(int port, Func<TcpClient, Task> handler)
@@ -701,6 +739,15 @@ public override bool TryConvertTo(ReadOnlyMemory<byte> data, [NotNullWhen(true)]
         }
     }
 
+    class MockErrorEntityDataPackageAdapter : DataPackageAdapter
+    {
+        public override bool TryConvertTo(ReadOnlyMemory<byte> data, [NotNullWhen(true)] out object? entity)
+        {
+            entity = new Foo();
+            return true;
+        }
+    }
+
     class MockEntity
     {
         public byte[]? Header { get; set; }