aheh/ChessServer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Simplify ut.

Browse Source
This commit is contained in:
Anduin Xue
2023-12-11 07:25:17 +00:00
parent 92e553e5e9
commit 1f1869fce4
2 changed files with 6 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/Aiursoft.ChessServer.Tests/BasicTests.cs
+6 -9
View File
@@ -84,22 +84,19 @@ public class BasicTests
[DataRow(9)]
public async Task TestConnect(int gameId)
{
var tester = new WebSocketTester();
var socket = new ClientWebSocket();
await socket.ConnectAsync(new Uri(_endpointUrl.Replace("http", "ws") + $"/games/{gameId}.ws"),
CancellationToken.None);
await Task.Factory.StartNew(() => tester.Monitor(socket));
var endPoint = _endpointUrl.Replace("http", "ws") + $"/games/{gameId}.ws";
var socket = await endPoint.ConnectAsWebSocketServer();
await Task.Factory.StartNew(() => socket.Listen());
await _http.PostAsync(_endpointUrl + $"/games/{gameId}/move/w/e4", new StringContent(""));
await Task.Delay(50);
Assert.AreEqual("rnbqkbnr/pppppppp/8/8/4P3/8/PPPP1PPP/RNBQKBNR b KQkq e3 0 1", tester.LastMessage);
Assert.AreEqual("rnbqkbnr/pppppppp/8/8/4P3/8/PPPP1PPP/RNBQKBNR b KQkq e3 0 1", socket.LastMessage);
await _http.PostAsync(_endpointUrl + $"/games/{gameId}/move/b/e5", new StringContent(""));
await Task.Delay(50);
Assert.AreEqual("rnbqkbnr/pppp1ppp/8/4p3/4P3/8/PPPP1PPP/RNBQKBNR w KQkq e6 0 2", tester.LastMessage);
Assert.AreEqual("rnbqkbnr/pppp1ppp/8/4p3/4P3/8/PPPP1PPP/RNBQKBNR w KQkq e6 0 2", socket.LastMessage);
await socket.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None);
await socket.Close();
}
[TestMethod]
tests/Aiursoft.ChessServer.Tests/WebSocketTester.cs
-29
View File
@@ -1,29 +0,0 @@
using System.Net.WebSockets;
using System.Text;
namespace Aiursoft.ChessServer.Tests;
public class WebSocketTester
{
public string LastMessage { get; private set; } = string.Empty;
public async Task Monitor(WebSocket socket)
{
var buffer = new ArraySegment<byte>(new byte[2048]);
while (true)
{
var result = await socket.ReceiveAsync(buffer, CancellationToken.None);
switch (result.MessageType)
{
case WebSocketMessageType.Close:
await socket.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None);
return;
case WebSocketMessageType.Text:
LastMessage = Encoding.UTF8.GetString(buffer.Array!, 0, result.Count);
break;
default:
throw new ArgumentOutOfRangeException();
}
}
}
}