mirror of
https://github.com/wiremock/WireMock.Net.git
synced 2026-04-17 05:59:39 +02:00
match
This commit is contained in:
@@ -1,8 +1,8 @@
|
|||||||
// Copyright © WireMock.Net
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
using System;
|
using System.Net.WebSockets;
|
||||||
using System.Threading.Tasks;
|
|
||||||
using Stef.Validation;
|
using Stef.Validation;
|
||||||
|
using WireMock.Matchers;
|
||||||
using WireMock.Settings;
|
using WireMock.Settings;
|
||||||
using WireMock.Types;
|
using WireMock.Types;
|
||||||
|
|
||||||
@@ -10,6 +10,8 @@ namespace WireMock.WebSockets;
|
|||||||
|
|
||||||
internal class WebSocketBuilder : IWebSocketBuilder
|
internal class WebSocketBuilder : IWebSocketBuilder
|
||||||
{
|
{
|
||||||
|
private readonly List<(IMatcher matcher, List<WebSocketMessageBuilder> messages)> _conditionalMessages = [];
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
public string? AcceptProtocol { get; private set; }
|
public string? AcceptProtocol { get; private set; }
|
||||||
|
|
||||||
@@ -98,10 +100,34 @@ internal class WebSocketBuilder : IWebSocketBuilder
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public IWebSocketMessageConditionBuilder WhenMessage(string condition)
|
||||||
|
{
|
||||||
|
Guard.NotNull(condition);
|
||||||
|
// Use RegexMatcher for substring matching - escape special chars and wrap with wildcards
|
||||||
|
// Convert the string to a wildcard pattern that matches if it contains the condition
|
||||||
|
var pattern = $"*{condition}*";
|
||||||
|
var matcher = new WildcardMatcher(MatchBehaviour.AcceptOnMatch, pattern);
|
||||||
|
return new WebSocketMessageConditionBuilder(this, matcher);
|
||||||
|
}
|
||||||
|
|
||||||
|
public IWebSocketMessageConditionBuilder WhenMessage(byte[] condition)
|
||||||
|
{
|
||||||
|
Guard.NotNull(condition);
|
||||||
|
// Use ExactObjectMatcher for byte matching
|
||||||
|
var matcher = new ExactObjectMatcher(MatchBehaviour.AcceptOnMatch, condition);
|
||||||
|
return new WebSocketMessageConditionBuilder(this, matcher);
|
||||||
|
}
|
||||||
|
|
||||||
|
public IWebSocketMessageConditionBuilder WhenMessage(IMatcher matcher)
|
||||||
|
{
|
||||||
|
Guard.NotNull(matcher);
|
||||||
|
return new WebSocketMessageConditionBuilder(this, matcher);
|
||||||
|
}
|
||||||
|
|
||||||
public IWebSocketBuilder WithMessageHandler(Func<WebSocketMessage, IWebSocketContext, Task> handler)
|
public IWebSocketBuilder WithMessageHandler(Func<WebSocketMessage, IWebSocketContext, Task> handler)
|
||||||
{
|
{
|
||||||
MessageHandler = Guard.NotNull(handler);
|
MessageHandler = Guard.NotNull(handler);
|
||||||
IsEcho = false; // Disable echo if custom handler is set
|
IsEcho = false;
|
||||||
return this;
|
return this;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -154,6 +180,82 @@ internal class WebSocketBuilder : IWebSocketBuilder
|
|||||||
return this;
|
return this;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
internal IWebSocketBuilder AddConditionalMessage(IMatcher matcher, WebSocketMessageBuilder messageBuilder)
|
||||||
|
{
|
||||||
|
_conditionalMessages.Add((matcher, new List<WebSocketMessageBuilder> { messageBuilder }));
|
||||||
|
SetupConditionalHandler();
|
||||||
|
return this;
|
||||||
|
}
|
||||||
|
|
||||||
|
internal IWebSocketBuilder AddConditionalMessages(IMatcher matcher, List<WebSocketMessageBuilder> messages)
|
||||||
|
{
|
||||||
|
_conditionalMessages.Add((matcher, messages));
|
||||||
|
SetupConditionalHandler();
|
||||||
|
return this;
|
||||||
|
}
|
||||||
|
|
||||||
|
private void SetupConditionalHandler()
|
||||||
|
{
|
||||||
|
if (_conditionalMessages.Count == 0)
|
||||||
|
{
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
WithMessageHandler(async (message, context) =>
|
||||||
|
{
|
||||||
|
// Check each condition in order
|
||||||
|
foreach (var (matcher, messages) in _conditionalMessages)
|
||||||
|
{
|
||||||
|
// Try to match the message
|
||||||
|
if (await MatchMessageAsync(message, matcher) )
|
||||||
|
{
|
||||||
|
// Execute the corresponding messages
|
||||||
|
foreach (var messageBuilder in messages)
|
||||||
|
{
|
||||||
|
if (messageBuilder.Delay.HasValue)
|
||||||
|
{
|
||||||
|
await Task.Delay(messageBuilder.Delay.Value);
|
||||||
|
}
|
||||||
|
|
||||||
|
await SendMessageAsync(context, messageBuilder);
|
||||||
|
|
||||||
|
// If this message should close the connection, do it after sending
|
||||||
|
if (messageBuilder.ShouldClose)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
await Task.Delay(100); // Small delay to ensure message is sent
|
||||||
|
await context.CloseAsync(WebSocketCloseStatus.NormalClosure, "Closed by handler");
|
||||||
|
}
|
||||||
|
catch
|
||||||
|
{
|
||||||
|
// Ignore errors during close
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return; // Stop after first match
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
private static async Task<bool> MatchMessageAsync(WebSocketMessage message, IMatcher matcher)
|
||||||
|
{
|
||||||
|
if (message.MessageType == WebSocketMessageType.Text && matcher is IStringMatcher stringMatcher)
|
||||||
|
{
|
||||||
|
var result = stringMatcher.IsMatch(message.Text);
|
||||||
|
return result.IsPerfect();
|
||||||
|
}
|
||||||
|
|
||||||
|
if (message.MessageType == WebSocketMessageType.Binary && matcher is IBytesMatcher bytesMatcher && message.Bytes != null)
|
||||||
|
{
|
||||||
|
var result = await bytesMatcher.IsMatchAsync(message.Bytes);
|
||||||
|
return result.IsPerfect();
|
||||||
|
}
|
||||||
|
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
private static async Task SendMessageAsync(IWebSocketContext context, WebSocketMessageBuilder messageBuilder)
|
private static async Task SendMessageAsync(IWebSocketContext context, WebSocketMessageBuilder messageBuilder)
|
||||||
{
|
{
|
||||||
switch (messageBuilder.Type)
|
switch (messageBuilder.Type)
|
||||||
|
|||||||
@@ -16,6 +16,8 @@ internal class WebSocketMessageBuilder : IWebSocketMessageBuilder
|
|||||||
|
|
||||||
public MessageType Type { get; private set; }
|
public MessageType Type { get; private set; }
|
||||||
|
|
||||||
|
public bool ShouldClose { get; private set; }
|
||||||
|
|
||||||
public IWebSocketMessageBuilder WithText(string text)
|
public IWebSocketMessageBuilder WithText(string text)
|
||||||
{
|
{
|
||||||
MessageText = Guard.NotNull(text);
|
MessageText = Guard.NotNull(text);
|
||||||
@@ -50,6 +52,12 @@ internal class WebSocketMessageBuilder : IWebSocketMessageBuilder
|
|||||||
return this;
|
return this;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public IWebSocketMessageBuilder AndClose()
|
||||||
|
{
|
||||||
|
ShouldClose = true;
|
||||||
|
return this;
|
||||||
|
}
|
||||||
|
|
||||||
internal enum MessageType
|
internal enum MessageType
|
||||||
{
|
{
|
||||||
Text,
|
Text,
|
||||||
|
|||||||
@@ -0,0 +1,36 @@
|
|||||||
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
|
using WireMock.Matchers;
|
||||||
|
using Stef.Validation;
|
||||||
|
|
||||||
|
namespace WireMock.WebSockets;
|
||||||
|
|
||||||
|
internal class WebSocketMessageConditionBuilder : IWebSocketMessageConditionBuilder
|
||||||
|
{
|
||||||
|
private readonly WebSocketBuilder _parent;
|
||||||
|
private readonly IMatcher _matcher;
|
||||||
|
|
||||||
|
public WebSocketMessageConditionBuilder(WebSocketBuilder parent, IMatcher matcher)
|
||||||
|
{
|
||||||
|
_parent = Guard.NotNull(parent);
|
||||||
|
_matcher = Guard.NotNull(matcher);
|
||||||
|
}
|
||||||
|
|
||||||
|
public IWebSocketBuilder SendMessage(Action<IWebSocketMessageBuilder> configure)
|
||||||
|
{
|
||||||
|
Guard.NotNull(configure);
|
||||||
|
var messageBuilder = new WebSocketMessageBuilder();
|
||||||
|
configure(messageBuilder);
|
||||||
|
|
||||||
|
return _parent.AddConditionalMessage(_matcher, messageBuilder);
|
||||||
|
}
|
||||||
|
|
||||||
|
public IWebSocketBuilder SendMessages(Action<IWebSocketMessagesBuilder> configure)
|
||||||
|
{
|
||||||
|
Guard.NotNull(configure);
|
||||||
|
var messagesBuilder = new WebSocketMessagesBuilder();
|
||||||
|
configure(messagesBuilder);
|
||||||
|
|
||||||
|
return _parent.AddConditionalMessages(_matcher, messagesBuilder.Messages);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,6 +1,7 @@
|
|||||||
// Copyright © WireMock.Net
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
using JetBrains.Annotations;
|
using JetBrains.Annotations;
|
||||||
|
using WireMock.Matchers;
|
||||||
using WireMock.Settings;
|
using WireMock.Settings;
|
||||||
using WireMock.Types;
|
using WireMock.Types;
|
||||||
|
|
||||||
@@ -37,6 +38,27 @@ public interface IWebSocketBuilder
|
|||||||
[PublicAPI]
|
[PublicAPI]
|
||||||
IWebSocketBuilder SendMessages(Action<IWebSocketMessagesBuilder> configure);
|
IWebSocketBuilder SendMessages(Action<IWebSocketMessagesBuilder> configure);
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Configure message sending based on message content matching
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="condition">String to match in message text</param>
|
||||||
|
[PublicAPI]
|
||||||
|
IWebSocketMessageConditionBuilder WhenMessage(string condition);
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Configure message sending based on message content matching
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="condition">Bytes to match in message</param>
|
||||||
|
[PublicAPI]
|
||||||
|
IWebSocketMessageConditionBuilder WhenMessage(byte[] condition);
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Configure message sending based on IMatcher
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="matcher">IMatcher to match the message</param>
|
||||||
|
[PublicAPI]
|
||||||
|
IWebSocketMessageConditionBuilder WhenMessage(IMatcher matcher);
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Handle incoming WebSocket messages
|
/// Handle incoming WebSocket messages
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
|||||||
@@ -43,4 +43,10 @@ public interface IWebSocketMessageBuilder
|
|||||||
/// <param name="delayInMilliseconds">The delay in milliseconds before sending the message</param>
|
/// <param name="delayInMilliseconds">The delay in milliseconds before sending the message</param>
|
||||||
[PublicAPI]
|
[PublicAPI]
|
||||||
IWebSocketMessageBuilder WithDelay(int delayInMilliseconds);
|
IWebSocketMessageBuilder WithDelay(int delayInMilliseconds);
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Close the WebSocket connection after this message
|
||||||
|
/// </summary>
|
||||||
|
[PublicAPI]
|
||||||
|
IWebSocketMessageBuilder AndClose();
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,25 @@
|
|||||||
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
|
using JetBrains.Annotations;
|
||||||
|
|
||||||
|
namespace WireMock.WebSockets;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// WebSocket Message Condition Builder interface for building conditional message responses
|
||||||
|
/// </summary>
|
||||||
|
public interface IWebSocketMessageConditionBuilder
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// Configure and send a message when the condition matches
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="configure">Action to configure the message</param>
|
||||||
|
[PublicAPI]
|
||||||
|
IWebSocketBuilder SendMessage(Action<IWebSocketMessageBuilder> configure);
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Configure and send multiple messages when the condition matches
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="configure">Action to configure the messages</param>
|
||||||
|
[PublicAPI]
|
||||||
|
IWebSocketBuilder SendMessages(Action<IWebSocketMessagesBuilder> configure);
|
||||||
|
}
|
||||||
@@ -29,4 +29,24 @@ internal static class ClientWebSocketExtensions
|
|||||||
|
|
||||||
return Encoding.UTF8.GetString(receiveBuffer, 0, result.Count);
|
return Encoding.UTF8.GetString(receiveBuffer, 0, result.Count);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
internal static async Task<byte[]> ReceiveAsBytesAsync(this ClientWebSocket client, int bufferSize = 1024, CancellationToken cancellationToken = default)
|
||||||
|
{
|
||||||
|
var receiveBuffer = new byte[bufferSize];
|
||||||
|
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), cancellationToken);
|
||||||
|
|
||||||
|
if (result.MessageType != WebSocketMessageType.Binary)
|
||||||
|
{
|
||||||
|
throw new InvalidOperationException($"Expected a binary message but received a {result.MessageType} message.");
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!result.EndOfMessage)
|
||||||
|
{
|
||||||
|
throw new InvalidOperationException("Received message is too large for the buffer. Consider increasing the buffer size.");
|
||||||
|
}
|
||||||
|
|
||||||
|
var receivedData = new byte[result.Count];
|
||||||
|
Array.Copy(receiveBuffer, receivedData, result.Count);
|
||||||
|
return receivedData;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@@ -86,13 +86,8 @@ public class WebSocketIntegrationTests(ITestOutputHelper output)
|
|||||||
var testMessage = "Any message from client";
|
var testMessage = "Any message from client";
|
||||||
await client.SendAsync(testMessage);
|
await client.SendAsync(testMessage);
|
||||||
|
|
||||||
var receiveBuffer = new byte[1024];
|
|
||||||
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
|
||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
result.MessageType.Should().Be(WebSocketMessageType.Text);
|
var received = await client.ReceiveAsTextAsync();
|
||||||
result.EndOfMessage.Should().BeTrue();
|
|
||||||
var received = Encoding.UTF8.GetString(receiveBuffer, 0, result.Count);
|
|
||||||
received.Should().Be(responseMessage);
|
received.Should().Be(responseMessage);
|
||||||
|
|
||||||
await client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
await client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
||||||
@@ -132,10 +127,7 @@ public class WebSocketIntegrationTests(ITestOutputHelper output)
|
|||||||
{
|
{
|
||||||
await client.SendAsync(testMessage);
|
await client.SendAsync(testMessage);
|
||||||
|
|
||||||
var receiveBuffer = new byte[1024];
|
var received = await client.ReceiveAsTextAsync();
|
||||||
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
|
||||||
var received = Encoding.UTF8.GetString(receiveBuffer, 0, result.Count);
|
|
||||||
|
|
||||||
received.Should().Be(responseMessage, $"should always return the fixed response regardless of input message '{testMessage}'");
|
received.Should().Be(responseMessage, $"should always return the fixed response regardless of input message '{testMessage}'");
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -175,14 +167,8 @@ public class WebSocketIntegrationTests(ITestOutputHelper output)
|
|||||||
var testMessage = "Any message from client";
|
var testMessage = "Any message from client";
|
||||||
await client.SendAsync(testMessage);
|
await client.SendAsync(testMessage);
|
||||||
|
|
||||||
var receiveBuffer = new byte[1024];
|
|
||||||
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
|
||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
result.MessageType.Should().Be(WebSocketMessageType.Binary);
|
var receivedData = await client.ReceiveAsBytesAsync();
|
||||||
result.EndOfMessage.Should().BeTrue();
|
|
||||||
var receivedData = new byte[result.Count];
|
|
||||||
Array.Copy(receiveBuffer, receivedData, result.Count);
|
|
||||||
receivedData.Should().BeEquivalentTo(responseBytes);
|
receivedData.Should().BeEquivalentTo(responseBytes);
|
||||||
|
|
||||||
await client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
await client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
||||||
@@ -222,12 +208,7 @@ public class WebSocketIntegrationTests(ITestOutputHelper output)
|
|||||||
{
|
{
|
||||||
await client.SendAsync(testMessage);
|
await client.SendAsync(testMessage);
|
||||||
|
|
||||||
var receiveBuffer = new byte[1024];
|
var receivedData = await client.ReceiveAsBytesAsync();
|
||||||
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
|
||||||
|
|
||||||
result.MessageType.Should().Be(WebSocketMessageType.Binary);
|
|
||||||
var receivedData = new byte[result.Count];
|
|
||||||
Array.Copy(receiveBuffer, receivedData, result.Count);
|
|
||||||
receivedData.Should().BeEquivalentTo(responseBytes, $"should always return the fixed bytes regardless of input message '{testMessage}'");
|
receivedData.Should().BeEquivalentTo(responseBytes, $"should always return the fixed bytes regardless of input message '{testMessage}'");
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -272,13 +253,8 @@ public class WebSocketIntegrationTests(ITestOutputHelper output)
|
|||||||
var testMessage = "Any message from client";
|
var testMessage = "Any message from client";
|
||||||
await client.SendAsync(testMessage);
|
await client.SendAsync(testMessage);
|
||||||
|
|
||||||
var receiveBuffer = new byte[2048];
|
|
||||||
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
|
||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
result.MessageType.Should().Be(WebSocketMessageType.Text);
|
var received = await client.ReceiveAsTextAsync();
|
||||||
result.EndOfMessage.Should().BeTrue();
|
|
||||||
var received = Encoding.UTF8.GetString(receiveBuffer, 0, result.Count);
|
|
||||||
|
|
||||||
var json = JObject.Parse(received);
|
var json = JObject.Parse(received);
|
||||||
json["status"]!.ToString().Should().Be("ok");
|
json["status"]!.ToString().Should().Be("ok");
|
||||||
@@ -326,9 +302,7 @@ public class WebSocketIntegrationTests(ITestOutputHelper output)
|
|||||||
{
|
{
|
||||||
await client.SendAsync(testMessage);
|
await client.SendAsync(testMessage);
|
||||||
|
|
||||||
var receiveBuffer = new byte[2048];
|
var received = await client.ReceiveAsTextAsync();
|
||||||
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
|
||||||
var received = Encoding.UTF8.GetString(receiveBuffer, 0, result.Count);
|
|
||||||
|
|
||||||
var json = JObject.Parse(received);
|
var json = JObject.Parse(received);
|
||||||
json["id"]!.Value<int>().Should().Be(42);
|
json["id"]!.Value<int>().Should().Be(42);
|
||||||
@@ -368,9 +342,7 @@ public class WebSocketIntegrationTests(ITestOutputHelper output)
|
|||||||
{
|
{
|
||||||
await client.SendAsync(testMessage);
|
await client.SendAsync(testMessage);
|
||||||
|
|
||||||
var receiveBuffer = new byte[1024];
|
var received = await client.ReceiveAsTextAsync();
|
||||||
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
|
||||||
var received = Encoding.UTF8.GetString(receiveBuffer, 0, result.Count);
|
|
||||||
|
|
||||||
received.Should().Be(testMessage, $"message '{testMessage}' should be echoed back");
|
received.Should().Be(testMessage, $"message '{testMessage}' should be echoed back");
|
||||||
}
|
}
|
||||||
@@ -406,13 +378,9 @@ public class WebSocketIntegrationTests(ITestOutputHelper output)
|
|||||||
// Act
|
// Act
|
||||||
await client.SendAsync(new ArraySegment<byte>(testData), WebSocketMessageType.Binary, true, CancellationToken.None);
|
await client.SendAsync(new ArraySegment<byte>(testData), WebSocketMessageType.Binary, true, CancellationToken.None);
|
||||||
|
|
||||||
var receiveBuffer = new byte[1024];
|
var receivedData = await client.ReceiveAsBytesAsync();
|
||||||
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
|
||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
result.MessageType.Should().Be(WebSocketMessageType.Binary);
|
|
||||||
var receivedData = new byte[result.Count];
|
|
||||||
Array.Copy(receiveBuffer, receivedData, result.Count);
|
|
||||||
receivedData.Should().BeEquivalentTo(testData);
|
receivedData.Should().BeEquivalentTo(testData);
|
||||||
|
|
||||||
await client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
await client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
||||||
@@ -492,9 +460,7 @@ public class WebSocketIntegrationTests(ITestOutputHelper output)
|
|||||||
// Act
|
// Act
|
||||||
await client.SendAsync("/help");
|
await client.SendAsync("/help");
|
||||||
|
|
||||||
var receiveBuffer = new byte[1024];
|
var received = await client.ReceiveAsTextAsync();
|
||||||
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
|
||||||
var received = Encoding.UTF8.GetString(receiveBuffer, 0, result.Count);
|
|
||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
received.Should().Contain("Available commands");
|
received.Should().Contain("Available commands");
|
||||||
@@ -577,9 +543,7 @@ public class WebSocketIntegrationTests(ITestOutputHelper output)
|
|||||||
{
|
{
|
||||||
await client.SendAsync(command);
|
await client.SendAsync(command);
|
||||||
|
|
||||||
var receiveBuffer = new byte[1024];
|
var received = await client.ReceiveAsTextAsync();
|
||||||
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
|
||||||
var received = Encoding.UTF8.GetString(receiveBuffer, 0, result.Count);
|
|
||||||
|
|
||||||
assertion(received);
|
assertion(received);
|
||||||
}
|
}
|
||||||
@@ -590,7 +554,7 @@ public class WebSocketIntegrationTests(ITestOutputHelper output)
|
|||||||
}
|
}
|
||||||
|
|
||||||
[Fact]
|
[Fact]
|
||||||
public async Task SendJsonAsync_Should_Send_Json_Response()
|
public async Task WhenMessage_Should_Handle_Multiple_Conditions_Fluently()
|
||||||
{
|
{
|
||||||
// Arrange
|
// Arrange
|
||||||
using var server = WireMockServer.Start(new WireMockServerSettings
|
using var server = WireMockServer.Start(new WireMockServerSettings
|
||||||
@@ -601,107 +565,43 @@ public class WebSocketIntegrationTests(ITestOutputHelper output)
|
|||||||
|
|
||||||
server
|
server
|
||||||
.Given(Request.Create()
|
.Given(Request.Create()
|
||||||
.WithPath("/ws/json")
|
.WithPath("/ws/conditional")
|
||||||
.WithWebSocketUpgrade()
|
.WithWebSocketUpgrade()
|
||||||
)
|
)
|
||||||
.RespondWith(Response.Create()
|
.RespondWith(Response.Create()
|
||||||
.WithHeader("x", "y")
|
|
||||||
.WithWebSocket(ws => ws
|
.WithWebSocket(ws => ws
|
||||||
.WithMessageHandler(async (msg, ctx) =>
|
.WhenMessage("/help").SendMessage(m => m.WithText("Available commands: /help, /time, /echo <text>"))
|
||||||
{
|
.WhenMessage("/time").SendMessage(m => m.WithText($"Server time: {DateTime.UtcNow:yyyy-MM-dd HH:mm:ss} UTC"))
|
||||||
var response = new
|
.WhenMessage("/echo ").SendMessage(m => m.WithText("echo response"))
|
||||||
{
|
|
||||||
timestamp = DateTime.UtcNow,
|
|
||||||
message = msg.Text,
|
|
||||||
length = msg.Text?.Length ?? 0,
|
|
||||||
type = msg.MessageType.ToString()
|
|
||||||
};
|
|
||||||
await ctx.SendAsJsonAsync(response);
|
|
||||||
})
|
|
||||||
)
|
)
|
||||||
);
|
);
|
||||||
|
|
||||||
using var client = new ClientWebSocket();
|
using var client = new ClientWebSocket();
|
||||||
var uri = new Uri($"{server.Url!}/ws/json");
|
var uri = new Uri($"{server.Url!}/ws/conditional");
|
||||||
await client.ConnectAsync(uri, CancellationToken.None);
|
await client.ConnectAsync(uri, CancellationToken.None);
|
||||||
|
|
||||||
// Act
|
var testCases = new (string message, string expectedContains)[]
|
||||||
var testMessage = "Test JSON message";
|
|
||||||
await client.SendAsync(testMessage);
|
|
||||||
|
|
||||||
var receiveBuffer = new byte[2048];
|
|
||||||
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
|
||||||
var received = Encoding.UTF8.GetString(receiveBuffer, 0, result.Count);
|
|
||||||
|
|
||||||
// Assert
|
|
||||||
result.MessageType.Should().Be(WebSocketMessageType.Text);
|
|
||||||
|
|
||||||
var json = JObject.Parse(received);
|
|
||||||
json["message"]!.ToString().Should().Be(testMessage);
|
|
||||||
json["length"]!.Value<int>().Should().Be(testMessage.Length);
|
|
||||||
json["type"]!.ToString().Should().Be("Text");
|
|
||||||
json["timestamp"].Should().NotBeNull();
|
|
||||||
|
|
||||||
await client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
|
||||||
}
|
|
||||||
|
|
||||||
[Fact]
|
|
||||||
public async Task SendJsonAsync_Should_Handle_Multiple_Json_Messages()
|
|
||||||
{
|
|
||||||
// Arrange
|
|
||||||
using var server = WireMockServer.Start(new WireMockServerSettings
|
|
||||||
{
|
{
|
||||||
Logger = new TestOutputHelperWireMockLogger(output),
|
("/help", "Available commands"),
|
||||||
Urls = ["ws://localhost:0"]
|
("/time", "Server time"),
|
||||||
});
|
("/echo test", "echo response")
|
||||||
|
};
|
||||||
server
|
|
||||||
.Given(Request.Create()
|
|
||||||
.WithPath("/ws/json")
|
|
||||||
.WithWebSocketUpgrade()
|
|
||||||
)
|
|
||||||
.RespondWith(Response.Create()
|
|
||||||
.WithWebSocket(ws => ws
|
|
||||||
.WithMessageHandler(async (msg, ctx) =>
|
|
||||||
{
|
|
||||||
var response = new
|
|
||||||
{
|
|
||||||
timestamp = DateTime.UtcNow,
|
|
||||||
message = msg.Text,
|
|
||||||
length = msg.Text?.Length ?? 0,
|
|
||||||
type = msg.MessageType.ToString(),
|
|
||||||
connectionId = ctx.ConnectionId.ToString()
|
|
||||||
};
|
|
||||||
await ctx.SendAsJsonAsync(response);
|
|
||||||
})
|
|
||||||
)
|
|
||||||
);
|
|
||||||
|
|
||||||
using var client = new ClientWebSocket();
|
|
||||||
var uri = new Uri($"{server.Url!}/ws/json");
|
|
||||||
await client.ConnectAsync(uri, CancellationToken.None);
|
|
||||||
|
|
||||||
var testMessages = new[] { "First", "Second", "Third" };
|
|
||||||
|
|
||||||
// Act & Assert
|
// Act & Assert
|
||||||
foreach (var testMessage in testMessages)
|
foreach (var (message, expectedContains) in testCases)
|
||||||
{
|
{
|
||||||
await client.SendAsync(testMessage);
|
await client.SendAsync(message);
|
||||||
|
|
||||||
var receiveBuffer = new byte[2048];
|
var received = await client.ReceiveAsTextAsync();
|
||||||
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
|
||||||
var received = Encoding.UTF8.GetString(receiveBuffer, 0, result.Count);
|
|
||||||
|
|
||||||
var json = JObject.Parse(received);
|
received.Should().Contain(expectedContains, $"message '{message}' should return response containing '{expectedContains}'");
|
||||||
json["message"]!.ToString().Should().Be(testMessage);
|
|
||||||
json["length"]!.Value<int>().Should().Be(testMessage.Length);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
await client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
await client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
||||||
}
|
}
|
||||||
|
|
||||||
[Fact]
|
[Fact]
|
||||||
public async Task SendJsonAsync_Should_Serialize_Complex_Objects()
|
public async Task WhenMessage_Should_Close_Connection_When_AndClose_Is_Used()
|
||||||
{
|
{
|
||||||
// Arrange
|
// Arrange
|
||||||
using var server = WireMockServer.Start(new WireMockServerSettings
|
using var server = WireMockServer.Start(new WireMockServerSettings
|
||||||
@@ -712,420 +612,43 @@ public class WebSocketIntegrationTests(ITestOutputHelper output)
|
|||||||
|
|
||||||
server
|
server
|
||||||
.Given(Request.Create()
|
.Given(Request.Create()
|
||||||
.WithPath("/ws/json")
|
.WithPath("/ws/close")
|
||||||
.WithWebSocketUpgrade()
|
.WithWebSocketUpgrade()
|
||||||
)
|
)
|
||||||
.RespondWith(Response.Create()
|
.RespondWith(Response.Create()
|
||||||
.WithWebSocket(ws => ws
|
.WithWebSocket(ws => ws
|
||||||
.WithMessageHandler(async (msg, ctx) =>
|
.WhenMessage("/close").SendMessage(m => m.WithText("Closing connection").AndClose())
|
||||||
{
|
|
||||||
var response = new
|
|
||||||
{
|
|
||||||
status = "success",
|
|
||||||
data = new
|
|
||||||
{
|
|
||||||
originalMessage = msg.Text,
|
|
||||||
processedAt = DateTime.UtcNow,
|
|
||||||
metadata = new
|
|
||||||
{
|
|
||||||
length = msg.Text?.Length ?? 0,
|
|
||||||
type = msg.MessageType.ToString()
|
|
||||||
}
|
|
||||||
},
|
|
||||||
nested = new[]
|
|
||||||
{
|
|
||||||
new { id = 1, name = "Item1" },
|
|
||||||
new { id = 2, name = "Item2" }
|
|
||||||
}
|
|
||||||
};
|
|
||||||
await ctx.SendAsJsonAsync(response);
|
|
||||||
})
|
|
||||||
)
|
)
|
||||||
);
|
);
|
||||||
|
|
||||||
using var client = new ClientWebSocket();
|
using var client = new ClientWebSocket();
|
||||||
var uri = new Uri($"{server.Url!}/ws/json");
|
var uri = new Uri($"{server.Url!}/ws/close");
|
||||||
await client.ConnectAsync(uri, CancellationToken.None);
|
await client.ConnectAsync(uri, CancellationToken.None);
|
||||||
|
|
||||||
// Act
|
// Act
|
||||||
var testMessage = "Complex test";
|
await client.SendAsync("/close");
|
||||||
await client.SendAsync(testMessage);
|
|
||||||
|
|
||||||
var receiveBuffer = new byte[2048];
|
var received = await client.ReceiveAsTextAsync();
|
||||||
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
|
||||||
var received = Encoding.UTF8.GetString(receiveBuffer, 0, result.Count);
|
|
||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
var json = JObject.Parse(received);
|
received.Should().Contain("Closing connection");
|
||||||
json["status"]!.ToString().Should().Be("success");
|
|
||||||
json["data"]!["originalMessage"]!.ToString().Should().Be(testMessage);
|
|
||||||
json["data"]!["metadata"]!["length"]!.Value<int>().Should().Be(testMessage.Length);
|
|
||||||
json["nested"]!.Should().HaveCount(2);
|
|
||||||
json["nested"]![0]!["id"]!.Value<int>().Should().Be(1);
|
|
||||||
|
|
||||||
await client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
|
||||||
}
|
|
||||||
|
|
||||||
[Fact]
|
|
||||||
public async Task Broadcast_Should_Send_Message_To_All_Connected_Clients()
|
|
||||||
{
|
|
||||||
// Arrange
|
|
||||||
using var server = WireMockServer.Start(new WireMockServerSettings
|
|
||||||
{
|
|
||||||
Logger = new TestOutputHelperWireMockLogger(output),
|
|
||||||
Urls = ["ws://localhost:0"]
|
|
||||||
});
|
|
||||||
|
|
||||||
var broadcastMappingGuid = Guid.NewGuid();
|
|
||||||
|
|
||||||
server
|
|
||||||
.Given(Request.Create()
|
|
||||||
.WithPath("/ws/broadcast")
|
|
||||||
.WithWebSocketUpgrade()
|
|
||||||
)
|
|
||||||
.WithGuid(broadcastMappingGuid)
|
|
||||||
.RespondWith(Response.Create()
|
|
||||||
.WithWebSocket(ws => ws
|
|
||||||
.WithBroadcast()
|
|
||||||
.WithMessageHandler(async (message, context) =>
|
|
||||||
{
|
|
||||||
if (message.MessageType == WebSocketMessageType.Text)
|
|
||||||
{
|
|
||||||
var text = message.Text ?? string.Empty;
|
|
||||||
var timestamp = DateTime.UtcNow.ToString("HH:mm:ss");
|
|
||||||
var broadcastMessage = $"[{timestamp}] Broadcast: {text}";
|
|
||||||
|
|
||||||
// Broadcast to all connected clients
|
|
||||||
await context.BroadcastTextAsync(broadcastMessage);
|
|
||||||
}
|
|
||||||
})
|
|
||||||
)
|
|
||||||
);
|
|
||||||
|
|
||||||
// Connect multiple clients
|
|
||||||
using var client1 = new ClientWebSocket();
|
|
||||||
using var client2 = new ClientWebSocket();
|
|
||||||
using var client3 = new ClientWebSocket();
|
|
||||||
|
|
||||||
var uri = new Uri($"{server.Url!}/ws/broadcast");
|
|
||||||
|
|
||||||
await client1.ConnectAsync(uri, CancellationToken.None);
|
|
||||||
await client2.ConnectAsync(uri, CancellationToken.None);
|
|
||||||
await client3.ConnectAsync(uri, CancellationToken.None);
|
|
||||||
|
|
||||||
// Wait a moment for all connections to be registered
|
|
||||||
await Task.Delay(100);
|
|
||||||
|
|
||||||
// Act - Send message from client1
|
|
||||||
var testMessage = "Hello everyone!";
|
|
||||||
await client1.SendAsync(testMessage);
|
|
||||||
|
|
||||||
// Assert - All clients should receive the broadcast
|
|
||||||
var receiveBuffer1 = new byte[1024];
|
|
||||||
var result1 = await client1.ReceiveAsync(new ArraySegment<byte>(receiveBuffer1), CancellationToken.None);
|
|
||||||
var received1 = Encoding.UTF8.GetString(receiveBuffer1, 0, result1.Count);
|
|
||||||
|
|
||||||
var receiveBuffer2 = new byte[1024];
|
|
||||||
var result2 = await client2.ReceiveAsync(new ArraySegment<byte>(receiveBuffer2), CancellationToken.None);
|
|
||||||
var received2 = Encoding.UTF8.GetString(receiveBuffer2, 0, result2.Count);
|
|
||||||
|
|
||||||
var receiveBuffer3 = new byte[1024];
|
|
||||||
var result3 = await client3.ReceiveAsync(new ArraySegment<byte>(receiveBuffer3), CancellationToken.None);
|
|
||||||
var received3 = Encoding.UTF8.GetString(receiveBuffer3, 0, result3.Count);
|
|
||||||
|
|
||||||
received1.Should().Contain("Broadcast:").And.Contain(testMessage);
|
|
||||||
received2.Should().Contain("Broadcast:").And.Contain(testMessage);
|
|
||||||
received3.Should().Contain("Broadcast:").And.Contain(testMessage);
|
|
||||||
|
|
||||||
// All should receive the same message
|
|
||||||
received1.Should().Be(received2);
|
|
||||||
received2.Should().Be(received3);
|
|
||||||
|
|
||||||
await client1.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
|
||||||
await client2.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
|
||||||
await client3.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
|
||||||
}
|
|
||||||
|
|
||||||
[Fact]
|
|
||||||
public async Task Broadcast_Should_Only_Send_To_Open_Connections()
|
|
||||||
{
|
|
||||||
// Arrange
|
|
||||||
using var server = WireMockServer.Start(new WireMockServerSettings
|
|
||||||
{
|
|
||||||
Logger = new TestOutputHelperWireMockLogger(output),
|
|
||||||
Urls = ["ws://localhost:0"]
|
|
||||||
});
|
|
||||||
|
|
||||||
var broadcastMappingGuid = Guid.NewGuid();
|
|
||||||
|
|
||||||
server
|
|
||||||
.Given(Request.Create()
|
|
||||||
.WithPath("/ws/broadcast")
|
|
||||||
.WithWebSocketUpgrade()
|
|
||||||
)
|
|
||||||
.WithGuid(broadcastMappingGuid)
|
|
||||||
.RespondWith(Response.Create()
|
|
||||||
.WithWebSocket(ws => ws
|
|
||||||
.WithBroadcast()
|
|
||||||
.WithMessageHandler(async (message, context) =>
|
|
||||||
{
|
|
||||||
if (message.MessageType == WebSocketMessageType.Text)
|
|
||||||
{
|
|
||||||
await context.BroadcastTextAsync($"Broadcast: {message.Text}");
|
|
||||||
}
|
|
||||||
})
|
|
||||||
)
|
|
||||||
);
|
|
||||||
|
|
||||||
using var client1 = new ClientWebSocket();
|
|
||||||
using var client2 = new ClientWebSocket();
|
|
||||||
|
|
||||||
var uri = new Uri($"{server.Url!}/ws/broadcast");
|
|
||||||
|
|
||||||
await client1.ConnectAsync(uri, CancellationToken.None);
|
|
||||||
await client2.ConnectAsync(uri, CancellationToken.None);
|
|
||||||
|
|
||||||
await Task.Delay(100);
|
|
||||||
|
|
||||||
// Close client2
|
|
||||||
await client2.CloseAsync(WebSocketCloseStatus.NormalClosure, "Leaving", CancellationToken.None);
|
|
||||||
await Task.Delay(100);
|
|
||||||
|
|
||||||
// Act - Send message from client1 (client2 is now closed)
|
|
||||||
var testMessage = "Still here";
|
|
||||||
await client1.SendAsync(testMessage);
|
|
||||||
|
|
||||||
// Assert - Only client1 should receive
|
|
||||||
var receiveBuffer1 = new byte[1024];
|
|
||||||
var result1 = await client1.ReceiveAsync(new ArraySegment<byte>(receiveBuffer1), CancellationToken.None);
|
|
||||||
var received1 = Encoding.UTF8.GetString(receiveBuffer1, 0, result1.Count);
|
|
||||||
|
|
||||||
received1.Should().Contain("Broadcast:").And.Contain(testMessage);
|
|
||||||
client2.State.Should().Be(WebSocketState.Closed);
|
|
||||||
|
|
||||||
await client1.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
|
||||||
}
|
|
||||||
|
|
||||||
[Fact]
|
|
||||||
public async Task BroadcastJson_Should_Send_Json_To_All_Clients()
|
|
||||||
{
|
|
||||||
// Arrange
|
|
||||||
using var server = WireMockServer.Start(new WireMockServerSettings
|
|
||||||
{
|
|
||||||
Logger = new TestOutputHelperWireMockLogger(output),
|
|
||||||
Urls = ["ws://localhost:0"]
|
|
||||||
});
|
|
||||||
|
|
||||||
var broadcastMappingGuid = Guid.NewGuid();
|
|
||||||
|
|
||||||
server
|
|
||||||
.Given(Request.Create()
|
|
||||||
.WithPath("/ws/broadcast-json")
|
|
||||||
.WithWebSocketUpgrade()
|
|
||||||
)
|
|
||||||
.WithGuid(broadcastMappingGuid)
|
|
||||||
.RespondWith(Response.Create()
|
|
||||||
.WithWebSocket(ws => ws
|
|
||||||
.WithBroadcast()
|
|
||||||
.WithMessageHandler(async (message, context) =>
|
|
||||||
{
|
|
||||||
if (message.MessageType == WebSocketMessageType.Text)
|
|
||||||
{
|
|
||||||
var data = new
|
|
||||||
{
|
|
||||||
sender = context.ConnectionId,
|
|
||||||
message = message.Text,
|
|
||||||
timestamp = DateTime.UtcNow,
|
|
||||||
type = "broadcast"
|
|
||||||
};
|
|
||||||
await context.BroadcastJsonAsync(data);
|
|
||||||
}
|
|
||||||
})
|
|
||||||
)
|
|
||||||
);
|
|
||||||
|
|
||||||
using var client1 = new ClientWebSocket();
|
|
||||||
using var client2 = new ClientWebSocket();
|
|
||||||
|
|
||||||
var uri = new Uri($"{server.Url!}/ws/broadcast-json");
|
|
||||||
|
|
||||||
await client1.ConnectAsync(uri, CancellationToken.None);
|
|
||||||
await client2.ConnectAsync(uri, CancellationToken.None);
|
|
||||||
|
|
||||||
await Task.Delay(100);
|
|
||||||
|
|
||||||
// Act - Send message from client1
|
|
||||||
var testMessage = "JSON broadcast test";
|
|
||||||
await client1.SendAsync(testMessage);
|
|
||||||
|
|
||||||
// Assert - Both clients should receive JSON
|
|
||||||
var receiveBuffer1 = new byte[2048];
|
|
||||||
var result1 = await client1.ReceiveAsync(new ArraySegment<byte>(receiveBuffer1), CancellationToken.None);
|
|
||||||
var received1 = Encoding.UTF8.GetString(receiveBuffer1, 0, result1.Count);
|
|
||||||
|
|
||||||
var receiveBuffer2 = new byte[2048];
|
|
||||||
var result2 = await client2.ReceiveAsync(new ArraySegment<byte>(receiveBuffer2), CancellationToken.None);
|
|
||||||
var received2 = Encoding.UTF8.GetString(receiveBuffer2, 0, result2.Count);
|
|
||||||
|
|
||||||
var json1 = JObject.Parse(received1);
|
|
||||||
var json2 = JObject.Parse(received2);
|
|
||||||
|
|
||||||
json1["message"]!.ToString().Should().Be(testMessage);
|
|
||||||
json1["type"]!.ToString().Should().Be("broadcast");
|
|
||||||
json1["sender"].Should().NotBeNull();
|
|
||||||
|
|
||||||
json2["message"]!.ToString().Should().Be(testMessage);
|
|
||||||
json2["type"]!.ToString().Should().Be("broadcast");
|
|
||||||
|
|
||||||
// Both should have the same content
|
|
||||||
json1["message"]!.ToString().Should().Be(json2["message"]!.ToString());
|
|
||||||
|
|
||||||
await client1.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
|
||||||
await client2.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
|
||||||
}
|
|
||||||
|
|
||||||
[Fact]
|
|
||||||
public async Task Broadcast_Should_Handle_Multiple_Sequential_Messages()
|
|
||||||
{
|
|
||||||
// Arrange
|
|
||||||
using var server = WireMockServer.Start(new WireMockServerSettings
|
|
||||||
{
|
|
||||||
Logger = new TestOutputHelperWireMockLogger(output),
|
|
||||||
Urls = ["ws://localhost:0"]
|
|
||||||
});
|
|
||||||
|
|
||||||
var broadcastMappingGuid = Guid.NewGuid();
|
|
||||||
var messageCount = 0;
|
|
||||||
|
|
||||||
server
|
|
||||||
.Given(Request.Create()
|
|
||||||
.WithPath("/ws/broadcast")
|
|
||||||
.WithWebSocketUpgrade()
|
|
||||||
)
|
|
||||||
.WithGuid(broadcastMappingGuid)
|
|
||||||
.RespondWith(Response.Create()
|
|
||||||
.WithWebSocket(ws => ws
|
|
||||||
.WithBroadcast()
|
|
||||||
.WithMessageHandler(async (message, context) =>
|
|
||||||
{
|
|
||||||
if (message.MessageType == WebSocketMessageType.Text)
|
|
||||||
{
|
|
||||||
Interlocked.Increment(ref messageCount);
|
|
||||||
await context.BroadcastTextAsync($"Message {messageCount}: {message.Text}");
|
|
||||||
}
|
|
||||||
})
|
|
||||||
)
|
|
||||||
);
|
|
||||||
|
|
||||||
using var client1 = new ClientWebSocket();
|
|
||||||
using var client2 = new ClientWebSocket();
|
|
||||||
|
|
||||||
var uri = new Uri($"{server.Url!}/ws/broadcast");
|
|
||||||
|
|
||||||
await client1.ConnectAsync(uri, CancellationToken.None);
|
|
||||||
await client2.ConnectAsync(uri, CancellationToken.None);
|
|
||||||
|
|
||||||
await Task.Delay(100);
|
|
||||||
|
|
||||||
var messages = new[] { "First", "Second", "Third" };
|
|
||||||
|
|
||||||
// Act & Assert
|
|
||||||
foreach (var msg in messages)
|
|
||||||
{
|
|
||||||
await client1.SendAsync(msg);
|
|
||||||
|
|
||||||
var receiveBuffer1 = new byte[1024];
|
|
||||||
var result1 = await client1.ReceiveAsync(new ArraySegment<byte>(receiveBuffer1), CancellationToken.None);
|
|
||||||
var received1 = Encoding.UTF8.GetString(receiveBuffer1, 0, result1.Count);
|
|
||||||
|
|
||||||
var receiveBuffer2 = new byte[1024];
|
|
||||||
var result2 = await client2.ReceiveAsync(new ArraySegment<byte>(receiveBuffer2), CancellationToken.None);
|
|
||||||
var received2 = Encoding.UTF8.GetString(receiveBuffer2, 0, result2.Count);
|
|
||||||
|
|
||||||
received1.Should().Contain(msg);
|
|
||||||
received2.Should().Contain(msg);
|
|
||||||
received1.Should().Be(received2);
|
|
||||||
}
|
|
||||||
|
|
||||||
await client1.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
|
||||||
await client2.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
|
||||||
}
|
|
||||||
|
|
||||||
[Fact]
|
|
||||||
public async Task Broadcast_Should_Work_With_Many_Clients()
|
|
||||||
{
|
|
||||||
// Arrange
|
|
||||||
using var server = WireMockServer.Start(new WireMockServerSettings
|
|
||||||
{
|
|
||||||
Logger = new TestOutputHelperWireMockLogger(output),
|
|
||||||
Urls = ["ws://localhost:0"]
|
|
||||||
});
|
|
||||||
|
|
||||||
var broadcastMappingGuid = Guid.NewGuid();
|
|
||||||
|
|
||||||
server
|
|
||||||
.Given(Request.Create()
|
|
||||||
.WithPath("/ws/broadcast")
|
|
||||||
.WithWebSocketUpgrade()
|
|
||||||
)
|
|
||||||
.WithGuid(broadcastMappingGuid)
|
|
||||||
.RespondWith(Response.Create()
|
|
||||||
.WithWebSocket(ws => ws
|
|
||||||
.WithBroadcast()
|
|
||||||
.WithMessageHandler(async (message, context) =>
|
|
||||||
{
|
|
||||||
if (message.MessageType == WebSocketMessageType.Text)
|
|
||||||
{
|
|
||||||
await context.BroadcastTextAsync($"Broadcast: {message.Text}");
|
|
||||||
}
|
|
||||||
})
|
|
||||||
)
|
|
||||||
);
|
|
||||||
|
|
||||||
var uri = new Uri($"{server.Url!}/ws/broadcast");
|
|
||||||
const int clientCount = 3;
|
|
||||||
var clients = new List<ClientWebSocket>();
|
|
||||||
|
|
||||||
|
// Try to receive again - this will complete the close handshake
|
||||||
|
// and update the client state to Closed
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
// Connect multiple clients
|
var receiveBuffer = new byte[1024];
|
||||||
for (int i = 0; i < clientCount; i++)
|
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
||||||
{
|
|
||||||
var client = new ClientWebSocket();
|
// If we get here, the message type should be Close
|
||||||
await client.ConnectAsync(uri, CancellationToken.None);
|
result.MessageType.Should().Be(WebSocketMessageType.Close);
|
||||||
clients.Add(client);
|
|
||||||
}
|
|
||||||
|
|
||||||
await Task.Delay(100); // Give time for all connections to register
|
|
||||||
|
|
||||||
// Act - Send message from first client
|
|
||||||
var testMessage = "Mass broadcast";
|
|
||||||
await clients[0].SendAsync(testMessage);
|
|
||||||
|
|
||||||
// Assert - All clients should receive
|
|
||||||
var receiveTasks = clients.Select(async client =>
|
|
||||||
{
|
|
||||||
var receiveBuffer = new byte[1024];
|
|
||||||
var result = await client.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
|
|
||||||
return Encoding.UTF8.GetString(receiveBuffer, 0, result.Count);
|
|
||||||
}).ToList();
|
|
||||||
|
|
||||||
var received = await Task.WhenAll(receiveTasks);
|
|
||||||
|
|
||||||
received.Should().HaveCount(clientCount);
|
|
||||||
received.Should().OnlyContain(msg => msg.Contains("Broadcast:") && msg.Contains(testMessage));
|
|
||||||
}
|
}
|
||||||
finally
|
catch (WebSocketException)
|
||||||
{
|
{
|
||||||
// Cleanup
|
// Connection was closed, which is expected
|
||||||
foreach (var client in clients)
|
|
||||||
{
|
|
||||||
if (client.State == WebSocketState.Open)
|
|
||||||
{
|
|
||||||
await client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None);
|
|
||||||
}
|
|
||||||
client.Dispose();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Verify the connection is CloseReceived
|
||||||
|
client.State.Should().Be(WebSocketState.CloseReceived);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user