mirror of
https://github.com/wiremock/WireMock.Net.git
synced 2026-04-17 14:40:00 +02:00
WireMock.Net.RestClient.AwesomeAssertions (#1427)
* WireMock.Net.RestClient.AwesomeAssertions * ok * atpath * fix test * sonar fixes * ports
This commit is contained in:
@@ -156,6 +156,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WireMock.Net.TestWebApplica
|
|||||||
EndProject
|
EndProject
|
||||||
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WireMock.Net.TestWebApplication", "test\WireMock.Net.TestWebApplication\WireMock.Net.TestWebApplication.csproj", "{3B05CC76-C3CB-8667-6B65-3129DFB25681}"
|
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WireMock.Net.TestWebApplication", "test\WireMock.Net.TestWebApplication\WireMock.Net.TestWebApplication.csproj", "{3B05CC76-C3CB-8667-6B65-3129DFB25681}"
|
||||||
EndProject
|
EndProject
|
||||||
|
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WireMock.Net.RestClient.AwesomeAssertions", "src\WireMock.Net.RestClient.AwesomeAssertions\WireMock.Net.RestClient.AwesomeAssertions.csproj", "{F4B2B967-98D7-4D93-9A5C-5EF7B84B941A}"
|
||||||
|
EndProject
|
||||||
Global
|
Global
|
||||||
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
||||||
Debug|Any CPU = Debug|Any CPU
|
Debug|Any CPU = Debug|Any CPU
|
||||||
@@ -850,6 +852,18 @@ Global
|
|||||||
{3B05CC76-C3CB-8667-6B65-3129DFB25681}.Release|x64.Build.0 = Release|Any CPU
|
{3B05CC76-C3CB-8667-6B65-3129DFB25681}.Release|x64.Build.0 = Release|Any CPU
|
||||||
{3B05CC76-C3CB-8667-6B65-3129DFB25681}.Release|x86.ActiveCfg = Release|Any CPU
|
{3B05CC76-C3CB-8667-6B65-3129DFB25681}.Release|x86.ActiveCfg = Release|Any CPU
|
||||||
{3B05CC76-C3CB-8667-6B65-3129DFB25681}.Release|x86.Build.0 = Release|Any CPU
|
{3B05CC76-C3CB-8667-6B65-3129DFB25681}.Release|x86.Build.0 = Release|Any CPU
|
||||||
|
{F4B2B967-98D7-4D93-9A5C-5EF7B84B941A}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||||
|
{F4B2B967-98D7-4D93-9A5C-5EF7B84B941A}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||||
|
{F4B2B967-98D7-4D93-9A5C-5EF7B84B941A}.Debug|x64.ActiveCfg = Debug|Any CPU
|
||||||
|
{F4B2B967-98D7-4D93-9A5C-5EF7B84B941A}.Debug|x64.Build.0 = Debug|Any CPU
|
||||||
|
{F4B2B967-98D7-4D93-9A5C-5EF7B84B941A}.Debug|x86.ActiveCfg = Debug|Any CPU
|
||||||
|
{F4B2B967-98D7-4D93-9A5C-5EF7B84B941A}.Debug|x86.Build.0 = Debug|Any CPU
|
||||||
|
{F4B2B967-98D7-4D93-9A5C-5EF7B84B941A}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||||
|
{F4B2B967-98D7-4D93-9A5C-5EF7B84B941A}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||||
|
{F4B2B967-98D7-4D93-9A5C-5EF7B84B941A}.Release|x64.ActiveCfg = Release|Any CPU
|
||||||
|
{F4B2B967-98D7-4D93-9A5C-5EF7B84B941A}.Release|x64.Build.0 = Release|Any CPU
|
||||||
|
{F4B2B967-98D7-4D93-9A5C-5EF7B84B941A}.Release|x86.ActiveCfg = Release|Any CPU
|
||||||
|
{F4B2B967-98D7-4D93-9A5C-5EF7B84B941A}.Release|x86.Build.0 = Release|Any CPU
|
||||||
EndGlobalSection
|
EndGlobalSection
|
||||||
GlobalSection(SolutionProperties) = preSolution
|
GlobalSection(SolutionProperties) = preSolution
|
||||||
HideSolutionNode = FALSE
|
HideSolutionNode = FALSE
|
||||||
@@ -914,6 +928,7 @@ Global
|
|||||||
{2CE8E3A6-59CC-FE9C-9399-AD54E1FA862B} = {985E0ADB-D4B4-473A-AA40-567E279B7946}
|
{2CE8E3A6-59CC-FE9C-9399-AD54E1FA862B} = {985E0ADB-D4B4-473A-AA40-567E279B7946}
|
||||||
{2EA75541-E63A-37B7-DA0A-BEA82ECD7652} = {985E0ADB-D4B4-473A-AA40-567E279B7946}
|
{2EA75541-E63A-37B7-DA0A-BEA82ECD7652} = {985E0ADB-D4B4-473A-AA40-567E279B7946}
|
||||||
{3B05CC76-C3CB-8667-6B65-3129DFB25681} = {0BB8B634-407A-4610-A91F-11586990767A}
|
{3B05CC76-C3CB-8667-6B65-3129DFB25681} = {0BB8B634-407A-4610-A91F-11586990767A}
|
||||||
|
{F4B2B967-98D7-4D93-9A5C-5EF7B84B941A} = {8F890C6F-9ACC-438D-928A-AD61CDA862F2}
|
||||||
EndGlobalSection
|
EndGlobalSection
|
||||||
GlobalSection(ExtensibilityGlobals) = postSolution
|
GlobalSection(ExtensibilityGlobals) = postSolution
|
||||||
SolutionGuid = {DC539027-9852-430C-B19F-FD035D018458}
|
SolutionGuid = {DC539027-9852-430C-B19F-FD035D018458}
|
||||||
|
|||||||
@@ -25,7 +25,7 @@ public partial class WireMockAssertions
|
|||||||
|
|
||||||
public (Func<IReadOnlyList<IRequestMessage>, IReadOnlyList<IRequestMessage>> Filter, Func<IReadOnlyList<IRequestMessage>, bool> Condition) BuildFilterAndCondition(Func<IRequestMessage, bool> predicate)
|
public (Func<IReadOnlyList<IRequestMessage>, IReadOnlyList<IRequestMessage>> Filter, Func<IReadOnlyList<IRequestMessage>, bool> Condition) BuildFilterAndCondition(Func<IRequestMessage, bool> predicate)
|
||||||
{
|
{
|
||||||
Func<IReadOnlyList<IRequestMessage>, IReadOnlyList<IRequestMessage>> filter = requests => requests.Where(predicate).ToList();
|
IReadOnlyList<IRequestMessage> filter(IReadOnlyList<IRequestMessage> requests) => requests.Where(predicate).ToList();
|
||||||
|
|
||||||
return (filter, requests => (CallsCount is null && filter(requests).Any()) || CallsCount == filter(requests).Count);
|
return (filter, requests => (CallsCount is null && filter(requests).Any()) || CallsCount == filter(requests).Count);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -9,19 +9,13 @@ namespace WireMock.AwesomeAssertions;
|
|||||||
/// <summary>
|
/// <summary>
|
||||||
/// Contains a number of methods to assert that the <see cref="IWireMockServer"/> is in the expected state.
|
/// Contains a number of methods to assert that the <see cref="IWireMockServer"/> is in the expected state.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public class WireMockReceivedAssertions : ReferenceTypeAssertions<IWireMockServer, WireMockReceivedAssertions>
|
/// <remarks>
|
||||||
|
/// Create a WireMockReceivedAssertions.
|
||||||
|
/// </remarks>
|
||||||
|
/// <param name="server">The <see cref="IWireMockServer"/>.</param>
|
||||||
|
/// <param name="chain">The assertion chain</param>
|
||||||
|
public class WireMockReceivedAssertions(IWireMockServer server, AssertionChain chain) : ReferenceTypeAssertions<IWireMockServer, WireMockReceivedAssertions>(server, chain)
|
||||||
{
|
{
|
||||||
private readonly AssertionChain _chain;
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Create a WireMockReceivedAssertions.
|
|
||||||
/// </summary>
|
|
||||||
/// <param name="server">The <see cref="IWireMockServer"/>.</param>
|
|
||||||
/// <param name="chain">The assertion chain</param>
|
|
||||||
public WireMockReceivedAssertions(IWireMockServer server, AssertionChain chain) : base(server, chain)
|
|
||||||
{
|
|
||||||
_chain = chain;
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Asserts if <see cref="IWireMockServer"/> has received no calls.
|
/// Asserts if <see cref="IWireMockServer"/> has received no calls.
|
||||||
@@ -29,7 +23,7 @@ public class WireMockReceivedAssertions : ReferenceTypeAssertions<IWireMockServe
|
|||||||
/// <returns><see cref="WireMockAssertions"/></returns>
|
/// <returns><see cref="WireMockAssertions"/></returns>
|
||||||
public WireMockAssertions HaveReceivedNoCalls()
|
public WireMockAssertions HaveReceivedNoCalls()
|
||||||
{
|
{
|
||||||
return new WireMockAssertions(Subject, 0, _chain);
|
return new WireMockAssertions(Subject, 0, CurrentAssertionChain);
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -38,7 +32,7 @@ public class WireMockReceivedAssertions : ReferenceTypeAssertions<IWireMockServe
|
|||||||
/// <returns><see cref="WireMockAssertions"/></returns>
|
/// <returns><see cref="WireMockAssertions"/></returns>
|
||||||
public WireMockAssertions HaveReceivedACall()
|
public WireMockAssertions HaveReceivedACall()
|
||||||
{
|
{
|
||||||
return new WireMockAssertions(Subject, null, _chain);
|
return new WireMockAssertions(Subject, null, CurrentAssertionChain);
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -48,7 +42,7 @@ public class WireMockReceivedAssertions : ReferenceTypeAssertions<IWireMockServe
|
|||||||
/// <returns><see cref="WireMockANumberOfCallsAssertions"/></returns>
|
/// <returns><see cref="WireMockANumberOfCallsAssertions"/></returns>
|
||||||
public WireMockANumberOfCallsAssertions HaveReceived(int callsCount)
|
public WireMockANumberOfCallsAssertions HaveReceived(int callsCount)
|
||||||
{
|
{
|
||||||
return new WireMockANumberOfCallsAssertions(Subject, callsCount, _chain);
|
return new WireMockANumberOfCallsAssertions(Subject, callsCount, CurrentAssertionChain);
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
|||||||
@@ -7,22 +7,16 @@ using WireMock.Server;
|
|||||||
// ReSharper disable once CheckNamespace
|
// ReSharper disable once CheckNamespace
|
||||||
namespace WireMock.FluentAssertions;
|
namespace WireMock.FluentAssertions;
|
||||||
|
|
||||||
public partial class WireMockAssertions
|
public partial class WireMockAssertions(IWireMockServer subject, int? callsCount)
|
||||||
{
|
{
|
||||||
public const string Any = "*";
|
public const string Any = "*";
|
||||||
|
|
||||||
public int? CallsCount { get; }
|
public int? CallsCount { get; } = callsCount;
|
||||||
public IReadOnlyList<IRequestMessage> RequestMessages { get; private set; }
|
public IReadOnlyList<IRequestMessage> RequestMessages { get; private set; } = subject.LogEntries.Select(logEntry => logEntry.RequestMessage).OfType<IRequestMessage>().ToList();
|
||||||
|
|
||||||
public WireMockAssertions(IWireMockServer subject, int? callsCount)
|
|
||||||
{
|
|
||||||
CallsCount = callsCount;
|
|
||||||
RequestMessages = subject.LogEntries.Select(logEntry => logEntry.RequestMessage).ToList();
|
|
||||||
}
|
|
||||||
|
|
||||||
public (Func<IReadOnlyList<IRequestMessage>, IReadOnlyList<IRequestMessage>> Filter, Func<IReadOnlyList<IRequestMessage>, bool> Condition) BuildFilterAndCondition(Func<IRequestMessage, bool> predicate)
|
public (Func<IReadOnlyList<IRequestMessage>, IReadOnlyList<IRequestMessage>> Filter, Func<IReadOnlyList<IRequestMessage>, bool> Condition) BuildFilterAndCondition(Func<IRequestMessage, bool> predicate)
|
||||||
{
|
{
|
||||||
Func<IReadOnlyList<IRequestMessage>, IReadOnlyList<IRequestMessage>> filter = requests => requests.Where(predicate).ToList();
|
IReadOnlyList<IRequestMessage> filter(IReadOnlyList<IRequestMessage> requests) => requests.Where(predicate).ToList();
|
||||||
|
|
||||||
return (filter, requests => (CallsCount is null && filter(requests).Any()) || CallsCount == filter(requests).Count);
|
return (filter, requests => (CallsCount is null && filter(requests).Any()) || CallsCount == filter(requests).Count);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -104,11 +104,11 @@ internal static class WireMockActivitySource
|
|||||||
// Set status based on HTTP status code (using standard otel.status_code tag)
|
// Set status based on HTTP status code (using standard otel.status_code tag)
|
||||||
if (statusCodeInt.Value >= 400)
|
if (statusCodeInt.Value >= 400)
|
||||||
{
|
{
|
||||||
activity.SetTag("otel.status_code", "ERROR");
|
activity.SetTag(WireMockSemanticConventions.OtelStatusCode, "ERROR");
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
activity.SetTag("otel.status_code", "OK");
|
activity.SetTag(WireMockSemanticConventions.OtelStatusCode, "OK");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -191,7 +191,7 @@ internal static class WireMockActivitySource
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Use standard OpenTelemetry exception semantic conventions
|
// Use standard OpenTelemetry exception semantic conventions
|
||||||
activity.SetTag("otel.status_code", "ERROR");
|
activity.SetTag(WireMockSemanticConventions.OtelStatusCode, "ERROR");
|
||||||
activity.SetTag("otel.status_description", exception.Message);
|
activity.SetTag("otel.status_description", exception.Message);
|
||||||
activity.SetTag("exception.type", exception.GetType().FullName);
|
activity.SetTag("exception.type", exception.GetType().FullName);
|
||||||
activity.SetTag("exception.message", exception.Message);
|
activity.SetTag("exception.message", exception.Message);
|
||||||
@@ -250,6 +250,6 @@ internal static class WireMockActivitySource
|
|||||||
activity.SetTag(WireMockSemanticConventions.WebSocketMessageContent, textContent);
|
activity.SetTag(WireMockSemanticConventions.WebSocketMessageContent, textContent);
|
||||||
}
|
}
|
||||||
|
|
||||||
activity.SetTag("otel.status_code", "OK");
|
activity.SetTag(WireMockSemanticConventions.OtelStatusCode, "OK");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -7,6 +7,8 @@ namespace WireMock.Owin.ActivityTracing;
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
internal static class WireMockSemanticConventions
|
internal static class WireMockSemanticConventions
|
||||||
{
|
{
|
||||||
|
public const string OtelStatusCode = "otel.status_code";
|
||||||
|
|
||||||
// Standard HTTP semantic conventions (OpenTelemetry)
|
// Standard HTTP semantic conventions (OpenTelemetry)
|
||||||
public const string HttpMethod = "http.request.method";
|
public const string HttpMethod = "http.request.method";
|
||||||
public const string HttpUrl = "url.full";
|
public const string HttpUrl = "url.full";
|
||||||
|
|||||||
@@ -74,6 +74,8 @@ internal static class PortUtils
|
|||||||
socket.Close();
|
socket.Close();
|
||||||
socket.Dispose();
|
socket.Dispose();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Thread.Sleep(100); // Give the OS some time to release the ports
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -11,8 +11,6 @@ internal class WebSocketMessageBuilder : IWebSocketMessageBuilder
|
|||||||
|
|
||||||
public byte[]? MessageBytes { get; private set; }
|
public byte[]? MessageBytes { get; private set; }
|
||||||
|
|
||||||
public object? MessageData { get; private set; }
|
|
||||||
|
|
||||||
public TimeSpan? Delay { get; private set; }
|
public TimeSpan? Delay { get; private set; }
|
||||||
|
|
||||||
public WebSocketMessageType Type { get; private set; }
|
public WebSocketMessageType Type { get; private set; }
|
||||||
@@ -41,7 +39,7 @@ internal class WebSocketMessageBuilder : IWebSocketMessageBuilder
|
|||||||
|
|
||||||
public IWebSocketMessageBuilder WithDelay(int delayInMilliseconds)
|
public IWebSocketMessageBuilder WithDelay(int delayInMilliseconds)
|
||||||
{
|
{
|
||||||
Guard.Condition(delayInMilliseconds, d => d >= 0, nameof(delayInMilliseconds));
|
Guard.Condition(delayInMilliseconds, d => d >= 0);
|
||||||
return WithDelay(TimeSpan.FromMilliseconds(delayInMilliseconds));
|
return WithDelay(TimeSpan.FromMilliseconds(delayInMilliseconds));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,26 @@
|
|||||||
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
|
// ReSharper disable once CheckNamespace
|
||||||
|
namespace WireMock.Client.AwesomeAssertions;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Provides assertion methods to verify the number of calls made to a WireMock server.
|
||||||
|
/// This class is used in the context of AwesomeAssertions.
|
||||||
|
/// </summary>
|
||||||
|
/// <remarks>
|
||||||
|
/// Initializes a new instance of the <see cref="WireMockAdminApiANumberOfCallsAssertions"/> class.
|
||||||
|
/// </remarks>
|
||||||
|
/// <param name="adminApi">The WireMock Admin API to assert against.</param>
|
||||||
|
/// <param name="callsCount">The expected number of calls to assert.</param>
|
||||||
|
/// <param name="chain">The assertion chain</param>
|
||||||
|
public class WireMockAdminApiANumberOfCallsAssertions(IWireMockAdminApi adminApi, int callsCount, AssertionChain chain)
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// Returns an instance of <see cref="WireMockAdminApiAssertions"/> which can be used to assert the expected number of calls.
|
||||||
|
/// </summary>
|
||||||
|
/// <returns>A <see cref="WireMockAdminApiAssertions"/> instance for asserting the number of calls to the server.</returns>
|
||||||
|
public WireMockAdminApiAssertions Calls()
|
||||||
|
{
|
||||||
|
return new WireMockAdminApiAssertions(adminApi, callsCount, chain);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,83 @@
|
|||||||
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
|
using WireMock.Extensions;
|
||||||
|
using WireMock.Matchers;
|
||||||
|
|
||||||
|
// ReSharper disable once CheckNamespace
|
||||||
|
namespace WireMock.Client.AwesomeAssertions;
|
||||||
|
|
||||||
|
#pragma warning disable CS1591
|
||||||
|
public partial class WireMockAdminApiAssertions
|
||||||
|
{
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndWhichConstraint<WireMockAdminApiAssertions, string> AtAbsolutePath(string absolutePath, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
_ = AtAbsolutePath(new ExactMatcher(true, absolutePath), because, becauseArgs);
|
||||||
|
|
||||||
|
return new AndWhichConstraint<WireMockAdminApiAssertions, string>(this, absolutePath);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndWhichConstraint<WireMockAdminApiAssertions, IStringMatcher> AtAbsolutePath(IStringMatcher absolutePathMatcher, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
var (filter, condition) = BuildFilterAndCondition(request => absolutePathMatcher.IsPerfectMatch(request.AbsolutePath));
|
||||||
|
|
||||||
|
var absolutePath = absolutePathMatcher.GetPatterns().FirstOrDefault().GetPattern();
|
||||||
|
|
||||||
|
chain
|
||||||
|
.BecauseOf(because, becauseArgs)
|
||||||
|
.Given(() => RequestMessages)
|
||||||
|
.ForCondition(requests => CallsCount == 0 || requests.Any())
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called at address matching the absolute path {0}{reason}, but no calls were made.",
|
||||||
|
absolutePath
|
||||||
|
)
|
||||||
|
.Then
|
||||||
|
.ForCondition(condition)
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called at address matching the absolute path {0}{reason}, but didn't find it among the calls to {1}.",
|
||||||
|
_ => absolutePath,
|
||||||
|
requests => requests.Select(request => request.AbsolutePath)
|
||||||
|
);
|
||||||
|
|
||||||
|
FilterRequestMessages(filter);
|
||||||
|
|
||||||
|
return new AndWhichConstraint<WireMockAdminApiAssertions, IStringMatcher>(this, absolutePathMatcher);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndWhichConstraint<WireMockAdminApiAssertions, string> AtPath(string path, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
_ = AtPath(new ExactMatcher(true, path), because, becauseArgs);
|
||||||
|
|
||||||
|
return new AndWhichConstraint<WireMockAdminApiAssertions, string>(this, path);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndWhichConstraint<WireMockAdminApiAssertions, IStringMatcher> AtPath(IStringMatcher pathMatcher, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
var (filter, condition) = BuildFilterAndCondition(request => pathMatcher.IsPerfectMatch(request.Path));
|
||||||
|
|
||||||
|
var path = pathMatcher.GetPatterns().FirstOrDefault().GetPattern();
|
||||||
|
|
||||||
|
chain
|
||||||
|
.BecauseOf(because, becauseArgs)
|
||||||
|
.Given(() => RequestMessages)
|
||||||
|
.ForCondition(requests => CallsCount == 0 || requests.Any())
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called at address matching the path {0}{reason}, but no calls were made.",
|
||||||
|
path
|
||||||
|
)
|
||||||
|
.Then
|
||||||
|
.ForCondition(condition)
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called at address matching the path {0}{reason}, but didn't find it among the calls to {1}.",
|
||||||
|
_ => path,
|
||||||
|
requests => requests.Select(request => request.Path)
|
||||||
|
);
|
||||||
|
|
||||||
|
FilterRequestMessages(filter);
|
||||||
|
|
||||||
|
return new AndWhichConstraint<WireMockAdminApiAssertions, IStringMatcher>(this, pathMatcher);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,83 @@
|
|||||||
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
|
using WireMock.Extensions;
|
||||||
|
using WireMock.Matchers;
|
||||||
|
|
||||||
|
// ReSharper disable once CheckNamespace
|
||||||
|
namespace WireMock.Client.AwesomeAssertions;
|
||||||
|
|
||||||
|
#pragma warning disable CS1591
|
||||||
|
public partial class WireMockAdminApiAssertions
|
||||||
|
{
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndWhichConstraint<WireMockAdminApiAssertions, string> AtAbsoluteUrl(string absoluteUrl, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
_ = AtAbsoluteUrl(new ExactMatcher(true, absoluteUrl), because, becauseArgs);
|
||||||
|
|
||||||
|
return new AndWhichConstraint<WireMockAdminApiAssertions, string>(this, absoluteUrl);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndWhichConstraint<WireMockAdminApiAssertions, IStringMatcher> AtAbsoluteUrl(IStringMatcher absoluteUrlMatcher, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
var (filter, condition) = BuildFilterAndCondition(request => absoluteUrlMatcher.IsPerfectMatch(request.AbsoluteUrl));
|
||||||
|
|
||||||
|
var absoluteUrl = absoluteUrlMatcher.GetPatterns().FirstOrDefault().GetPattern();
|
||||||
|
|
||||||
|
chain
|
||||||
|
.BecauseOf(because, becauseArgs)
|
||||||
|
.Given(() => RequestMessages)
|
||||||
|
.ForCondition(requests => CallsCount == 0 || requests.Any())
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called at address matching the absolute url {0}{reason}, but no calls were made.",
|
||||||
|
absoluteUrl
|
||||||
|
)
|
||||||
|
.Then
|
||||||
|
.ForCondition(condition)
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called at address matching the absolute url {0}{reason}, but didn't find it among the calls to {1}.",
|
||||||
|
_ => absoluteUrl,
|
||||||
|
requests => requests.Select(request => request.AbsoluteUrl)
|
||||||
|
);
|
||||||
|
|
||||||
|
FilterRequestMessages(filter);
|
||||||
|
|
||||||
|
return new AndWhichConstraint<WireMockAdminApiAssertions, IStringMatcher>(this, absoluteUrlMatcher);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndWhichConstraint<WireMockAdminApiAssertions, string> AtUrl(string url, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
_ = AtUrl(new ExactMatcher(true, url), because, becauseArgs);
|
||||||
|
|
||||||
|
return new AndWhichConstraint<WireMockAdminApiAssertions, string>(this, url);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndWhichConstraint<WireMockAdminApiAssertions, IStringMatcher> AtUrl(IStringMatcher urlMatcher, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
var (filter, condition) = BuildFilterAndCondition(request => urlMatcher.IsPerfectMatch(request.Url));
|
||||||
|
|
||||||
|
var url = urlMatcher.GetPatterns().FirstOrDefault().GetPattern();
|
||||||
|
|
||||||
|
chain
|
||||||
|
.BecauseOf(because, becauseArgs)
|
||||||
|
.Given(() => RequestMessages)
|
||||||
|
.ForCondition(requests => CallsCount == 0 || requests.Any())
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called at address matching the url {0}{reason}, but no calls were made.",
|
||||||
|
url
|
||||||
|
)
|
||||||
|
.Then
|
||||||
|
.ForCondition(condition)
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called at address matching the url {0}{reason}, but didn't find it among the calls to {1}.",
|
||||||
|
_ => url,
|
||||||
|
requests => requests.Select(request => request.Url)
|
||||||
|
);
|
||||||
|
|
||||||
|
FilterRequestMessages(filter);
|
||||||
|
|
||||||
|
return new AndWhichConstraint<WireMockAdminApiAssertions, IStringMatcher>(this, urlMatcher);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,33 @@
|
|||||||
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
|
#pragma warning disable CS1591
|
||||||
|
// ReSharper disable once CheckNamespace
|
||||||
|
namespace WireMock.Client.AwesomeAssertions;
|
||||||
|
|
||||||
|
public partial class WireMockAdminApiAssertions
|
||||||
|
{
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndWhichConstraint<WireMockAdminApiAssertions, string> FromClientIP(string clientIP, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
var (filter, condition) = BuildFilterAndCondition(request => string.Equals(request.ClientIP, clientIP, StringComparison.OrdinalIgnoreCase));
|
||||||
|
|
||||||
|
chain
|
||||||
|
.BecauseOf(because, becauseArgs)
|
||||||
|
.Given(() => RequestMessages)
|
||||||
|
.ForCondition(requests => CallsCount == 0 || requests.Any())
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called from client IP {0}{reason}, but no calls were made.",
|
||||||
|
clientIP
|
||||||
|
)
|
||||||
|
.Then
|
||||||
|
.ForCondition(condition)
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called from client IP {0}{reason}, but didn't find it among the calls from IP(s) {1}.",
|
||||||
|
_ => clientIP, requests => requests.Select(request => request.ClientIP)
|
||||||
|
);
|
||||||
|
|
||||||
|
FilterRequestMessages(filter);
|
||||||
|
|
||||||
|
return new AndWhichConstraint<WireMockAdminApiAssertions, string>(this, clientIP);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,81 @@
|
|||||||
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
|
#pragma warning disable CS1591
|
||||||
|
using WireMock.Admin.Requests;
|
||||||
|
using WireMock.Constants;
|
||||||
|
|
||||||
|
// ReSharper disable once CheckNamespace
|
||||||
|
namespace WireMock.Client.AwesomeAssertions;
|
||||||
|
|
||||||
|
public partial class WireMockAdminApiAssertions
|
||||||
|
{
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> UsingConnect(string because = "", params object[] becauseArgs)
|
||||||
|
=> UsingMethod(HttpRequestMethod.CONNECT, because, becauseArgs);
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> UsingDelete(string because = "", params object[] becauseArgs)
|
||||||
|
=> UsingMethod(HttpRequestMethod.DELETE, because, becauseArgs);
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> UsingGet(string because = "", params object[] becauseArgs)
|
||||||
|
=> UsingMethod(HttpRequestMethod.GET, because, becauseArgs);
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> UsingHead(string because = "", params object[] becauseArgs)
|
||||||
|
=> UsingMethod(HttpRequestMethod.HEAD, because, becauseArgs);
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> UsingOptions(string because = "", params object[] becauseArgs)
|
||||||
|
=> UsingMethod(HttpRequestMethod.OPTIONS, because, becauseArgs);
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> UsingPost(string because = "", params object[] becauseArgs)
|
||||||
|
=> UsingMethod(HttpRequestMethod.POST, because, becauseArgs);
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> UsingPatch(string because = "", params object[] becauseArgs)
|
||||||
|
=> UsingMethod(HttpRequestMethod.PATCH, because, becauseArgs);
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> UsingPut(string because = "", params object[] becauseArgs)
|
||||||
|
=> UsingMethod(HttpRequestMethod.PUT, because, becauseArgs);
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> UsingTrace(string because = "", params object[] becauseArgs)
|
||||||
|
=> UsingMethod(HttpRequestMethod.TRACE, because, becauseArgs);
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> UsingAnyMethod(string because = "", params object[] becauseArgs)
|
||||||
|
=> UsingMethod(Any, because, becauseArgs);
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> UsingMethod(string method, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
var any = method == Any;
|
||||||
|
Func<LogRequestModel, bool> predicate = request => (any && !string.IsNullOrEmpty(request.Method)) ||
|
||||||
|
string.Equals(request.Method, method, StringComparison.OrdinalIgnoreCase);
|
||||||
|
|
||||||
|
var (filter, condition) = BuildFilterAndCondition(predicate);
|
||||||
|
|
||||||
|
chain
|
||||||
|
.BecauseOf(because, becauseArgs)
|
||||||
|
.Given(() => RequestMessages)
|
||||||
|
.ForCondition(requests => CallsCount == 0 || requests.Any())
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called using method {0}{reason}, but no calls were made.",
|
||||||
|
method
|
||||||
|
)
|
||||||
|
.Then
|
||||||
|
.ForCondition(condition)
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called using method {0}{reason}, but didn't find it among the methods {1}.",
|
||||||
|
_ => method,
|
||||||
|
requests => requests.Select(request => request.Method)
|
||||||
|
);
|
||||||
|
|
||||||
|
FilterRequestMessages(filter);
|
||||||
|
|
||||||
|
return new AndConstraint<WireMockAdminApiAssertions>(this);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,146 @@
|
|||||||
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
|
#pragma warning disable CS1591
|
||||||
|
using AnyOfTypes;
|
||||||
|
using Newtonsoft.Json;
|
||||||
|
using Newtonsoft.Json.Linq;
|
||||||
|
using WireMock.Admin.Requests;
|
||||||
|
using WireMock.Extensions;
|
||||||
|
using WireMock.Matchers;
|
||||||
|
using WireMock.Models;
|
||||||
|
|
||||||
|
// ReSharper disable once CheckNamespace
|
||||||
|
namespace WireMock.Client.AwesomeAssertions;
|
||||||
|
|
||||||
|
public partial class WireMockAdminApiAssertions
|
||||||
|
{
|
||||||
|
private const string MessageFormatNoCalls = "Expected {context:wiremockadminapi} to have been called using body {0}{reason}, but no calls were made.";
|
||||||
|
private const string MessageFormat = "Expected {context:wiremockadminapi} to have been called using body {0}{reason}, but didn't find it among the body/bodies {1}.";
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> WithBody(string body, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
return WithBody(new WildcardMatcher(body), because, becauseArgs);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> WithBody(IStringMatcher matcher, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
var (filter, condition) = BuildFilterAndCondition(r => r.Body, matcher);
|
||||||
|
|
||||||
|
return ExecuteAssertionWithBodyStringMatcher(matcher, because, becauseArgs, condition, filter, r => r.Body);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> WithBodyAsJson(object body, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
return WithBodyAsJson(new JsonMatcher(body), because, becauseArgs);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> WithBodyAsJson(string body, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
return WithBodyAsJson(new JsonMatcher(body), because, becauseArgs);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> WithBodyAsJson(IObjectMatcher matcher, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
var (filter, condition) = BuildFilterAndCondition(r => r.BodyAsJson, matcher);
|
||||||
|
|
||||||
|
return ExecuteAssertionWithBodyAsIObjectMatcher(matcher, because, becauseArgs, condition, filter, r => r.BodyAsJson);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> WithBodyAsBytes(byte[] body, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
return WithBodyAsBytes(new ExactObjectMatcher(body), because, becauseArgs);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> WithBodyAsBytes(ExactObjectMatcher matcher, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
var (filter, condition) = BuildFilterAndCondition(r => r.BodyAsBytes, matcher);
|
||||||
|
|
||||||
|
return ExecuteAssertionWithBodyAsIObjectMatcher(matcher, because, becauseArgs, condition, filter, r => r.BodyAsBytes);
|
||||||
|
}
|
||||||
|
|
||||||
|
private AndConstraint<WireMockAdminApiAssertions> ExecuteAssertionWithBodyStringMatcher(
|
||||||
|
IStringMatcher matcher,
|
||||||
|
string because,
|
||||||
|
object[] becauseArgs,
|
||||||
|
Func<IReadOnlyList<LogRequestModel>, bool> condition,
|
||||||
|
Func<IReadOnlyList<LogRequestModel>, IReadOnlyList<LogRequestModel>> filter,
|
||||||
|
Func<LogRequestModel, object?> expression
|
||||||
|
)
|
||||||
|
{
|
||||||
|
chain
|
||||||
|
.BecauseOf(because, becauseArgs)
|
||||||
|
.Given(() => RequestMessages)
|
||||||
|
.ForCondition(requests => CallsCount == 0 || requests.Any())
|
||||||
|
.FailWith(
|
||||||
|
MessageFormatNoCalls,
|
||||||
|
FormatBody(matcher.GetPatterns())
|
||||||
|
)
|
||||||
|
.Then
|
||||||
|
.ForCondition(condition)
|
||||||
|
.FailWith(
|
||||||
|
MessageFormat,
|
||||||
|
_ => FormatBody(matcher.GetPatterns()),
|
||||||
|
requests => FormatBodies(requests.Select(expression))
|
||||||
|
);
|
||||||
|
|
||||||
|
FilterRequestMessages(filter);
|
||||||
|
|
||||||
|
return new AndConstraint<WireMockAdminApiAssertions>(this);
|
||||||
|
}
|
||||||
|
|
||||||
|
private AndConstraint<WireMockAdminApiAssertions> ExecuteAssertionWithBodyAsIObjectMatcher(
|
||||||
|
IObjectMatcher matcher,
|
||||||
|
string because,
|
||||||
|
object[] becauseArgs,
|
||||||
|
Func<IReadOnlyList<LogRequestModel>, bool> condition,
|
||||||
|
Func<IReadOnlyList<LogRequestModel>, IReadOnlyList<LogRequestModel>> filter,
|
||||||
|
Func<LogRequestModel, object?> expression
|
||||||
|
)
|
||||||
|
{
|
||||||
|
chain
|
||||||
|
.BecauseOf(because, becauseArgs)
|
||||||
|
.Given(() => RequestMessages)
|
||||||
|
.ForCondition(requests => CallsCount == 0 || requests.Any())
|
||||||
|
.FailWith(
|
||||||
|
MessageFormatNoCalls,
|
||||||
|
FormatBody(matcher.Value)
|
||||||
|
)
|
||||||
|
.Then
|
||||||
|
.ForCondition(condition)
|
||||||
|
.FailWith(
|
||||||
|
MessageFormat,
|
||||||
|
_ => FormatBody(matcher.Value),
|
||||||
|
requests => FormatBodies(requests.Select(expression))
|
||||||
|
);
|
||||||
|
|
||||||
|
FilterRequestMessages(filter);
|
||||||
|
|
||||||
|
return new AndConstraint<WireMockAdminApiAssertions>(this);
|
||||||
|
}
|
||||||
|
|
||||||
|
private static string? FormatBody(object? body)
|
||||||
|
{
|
||||||
|
return body switch
|
||||||
|
{
|
||||||
|
null => null,
|
||||||
|
string str => str,
|
||||||
|
AnyOf<string, StringPattern>[] stringPatterns => FormatBodies(stringPatterns.Select(p => p.GetPattern())),
|
||||||
|
byte[] bytes => $"byte[{bytes.Length}] {{...}}",
|
||||||
|
JToken jToken => jToken.ToString(Formatting.None),
|
||||||
|
_ => JToken.FromObject(body).ToString(Formatting.None)
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
private static string? FormatBodies(IEnumerable<object?> bodies)
|
||||||
|
{
|
||||||
|
var valueAsArray = bodies as object[] ?? bodies.ToArray();
|
||||||
|
return valueAsArray.Length == 1 ? FormatBody(valueAsArray[0]) : $"[ {string.Join(", ", valueAsArray.Select(FormatBody))} ]";
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,157 @@
|
|||||||
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
|
#pragma warning disable CS1591
|
||||||
|
|
||||||
|
// ReSharper disable once CheckNamespace
|
||||||
|
namespace WireMock.Client.AwesomeAssertions;
|
||||||
|
|
||||||
|
public partial class WireMockAdminApiAssertions
|
||||||
|
{
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndWhichConstraint<WireMockAdminApiAssertions, string> WitHeaderKey(string expectedKey, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
var (filter, condition) = BuildFilterAndCondition(request =>
|
||||||
|
{
|
||||||
|
return request.Headers?.Any(h => h.Key == expectedKey) == true;
|
||||||
|
});
|
||||||
|
|
||||||
|
chain
|
||||||
|
.BecauseOf(because, becauseArgs)
|
||||||
|
.Given(() => RequestMessages)
|
||||||
|
.ForCondition(requests => CallsCount == 0 || requests.Any())
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called with Header {0}{reason}.",
|
||||||
|
expectedKey
|
||||||
|
)
|
||||||
|
.Then
|
||||||
|
.ForCondition(condition)
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called with Header {0}{reason}, but didn't find it among the calls with Header(s) {1}.",
|
||||||
|
_ => expectedKey,
|
||||||
|
requests => requests.Select(request => request.Headers)
|
||||||
|
);
|
||||||
|
|
||||||
|
FilterRequestMessages(filter);
|
||||||
|
|
||||||
|
return new AndWhichConstraint<WireMockAdminApiAssertions, string>(this, expectedKey);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> WithHeader(string expectedKey, string value, string because = "", params object[] becauseArgs)
|
||||||
|
=> WithHeader(expectedKey, new[] { value }, because, becauseArgs);
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> WithHeader(string expectedKey, string[] expectedValues, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
var (filter, condition) = BuildFilterAndCondition(request =>
|
||||||
|
{
|
||||||
|
var headers = request.Headers?.ToArray() ?? [];
|
||||||
|
|
||||||
|
var matchingHeaderValues = headers.Where(h => h.Key == expectedKey).SelectMany(h => h.Value.ToArray()).ToArray();
|
||||||
|
|
||||||
|
if (expectedValues.Length == 1 && matchingHeaderValues.Length == 1)
|
||||||
|
{
|
||||||
|
return matchingHeaderValues[0] == expectedValues[0];
|
||||||
|
}
|
||||||
|
|
||||||
|
var trimmedHeaderValues = string.Join(",", matchingHeaderValues.Select(x => x)).Split(',').Select(x => x.Trim()).ToArray();
|
||||||
|
return expectedValues.Any(trimmedHeaderValues.Contains);
|
||||||
|
});
|
||||||
|
|
||||||
|
chain
|
||||||
|
.BecauseOf(because, becauseArgs)
|
||||||
|
.Given(() => RequestMessages)
|
||||||
|
.ForCondition(requests => CallsCount == 0 || requests.Any())
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called with Header {0} and Values {1}{reason}.",
|
||||||
|
expectedKey,
|
||||||
|
expectedValues
|
||||||
|
)
|
||||||
|
.Then
|
||||||
|
.ForCondition(condition)
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called with Header {0} and Values {1}{reason}, but didn't find it among the calls with Header(s) {2}.",
|
||||||
|
_ => expectedKey,
|
||||||
|
_ => expectedValues,
|
||||||
|
requests => requests.Select(request => request.Headers)
|
||||||
|
);
|
||||||
|
|
||||||
|
FilterRequestMessages(filter);
|
||||||
|
|
||||||
|
return new AndConstraint<WireMockAdminApiAssertions>(this);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> WithoutHeaderKey(string unexpectedKey, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
var (filter, condition) = BuildFilterAndCondition(request =>
|
||||||
|
{
|
||||||
|
return request.Headers?.Any(h => h.Key == unexpectedKey) != true;
|
||||||
|
});
|
||||||
|
|
||||||
|
chain
|
||||||
|
.BecauseOf(because, becauseArgs)
|
||||||
|
.Given(() => RequestMessages)
|
||||||
|
.ForCondition(requests => CallsCount == 0 || requests.Any())
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} not to have been called with Header {0}{reason}.",
|
||||||
|
unexpectedKey
|
||||||
|
)
|
||||||
|
.Then
|
||||||
|
.ForCondition(condition)
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} not to have been called with Header {0}{reason}, but found it among the calls with Header(s) {1}.",
|
||||||
|
_ => unexpectedKey,
|
||||||
|
requests => requests.Select(request => request.Headers)
|
||||||
|
);
|
||||||
|
|
||||||
|
FilterRequestMessages(filter);
|
||||||
|
|
||||||
|
return new AndConstraint<WireMockAdminApiAssertions>(this);
|
||||||
|
}
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> WithoutHeader(string unexpectedKey, string value, string because = "", params object[] becauseArgs)
|
||||||
|
=> WithoutHeader(unexpectedKey, new[] { value }, because, becauseArgs);
|
||||||
|
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndConstraint<WireMockAdminApiAssertions> WithoutHeader(string unexpectedKey, string[] expectedValues, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
var (filter, condition) = BuildFilterAndCondition(request =>
|
||||||
|
{
|
||||||
|
var headers = request.Headers?.ToArray() ?? [];
|
||||||
|
|
||||||
|
var matchingHeaderValues = headers.Where(h => h.Key == unexpectedKey).SelectMany(h => h.Value.ToArray()).ToArray();
|
||||||
|
|
||||||
|
if (expectedValues.Length == 1 && matchingHeaderValues.Length == 1)
|
||||||
|
{
|
||||||
|
return matchingHeaderValues[0] != expectedValues[0];
|
||||||
|
}
|
||||||
|
|
||||||
|
var trimmedHeaderValues = string.Join(",", matchingHeaderValues.Select(x => x)).Split(',').Select(x => x.Trim()).ToArray();
|
||||||
|
return !expectedValues.Any(trimmedHeaderValues.Contains);
|
||||||
|
});
|
||||||
|
|
||||||
|
chain
|
||||||
|
.BecauseOf(because, becauseArgs)
|
||||||
|
.Given(() => RequestMessages)
|
||||||
|
.ForCondition(requests => CallsCount == 0 || requests.Any())
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} not to have been called with Header {0} and Values {1}{reason}.",
|
||||||
|
unexpectedKey,
|
||||||
|
expectedValues
|
||||||
|
)
|
||||||
|
.Then
|
||||||
|
.ForCondition(condition)
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} not to have been called with Header {0} and Values {1}{reason}, but found it among the calls with Header(s) {2}.",
|
||||||
|
_ => unexpectedKey,
|
||||||
|
_ => expectedValues,
|
||||||
|
requests => requests.Select(request => request.Headers)
|
||||||
|
);
|
||||||
|
|
||||||
|
FilterRequestMessages(filter);
|
||||||
|
|
||||||
|
return new AndConstraint<WireMockAdminApiAssertions>(this);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,34 @@
|
|||||||
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
|
#pragma warning disable CS1591
|
||||||
|
// ReSharper disable once CheckNamespace
|
||||||
|
namespace WireMock.Client.AwesomeAssertions;
|
||||||
|
|
||||||
|
public partial class WireMockAdminApiAssertions
|
||||||
|
{
|
||||||
|
[CustomAssertion]
|
||||||
|
public AndWhichConstraint<WireMockAdminApiAssertions, string> WithProxyUrl(string proxyUrl, string because = "", params object[] becauseArgs)
|
||||||
|
{
|
||||||
|
var (filter, condition) = BuildFilterAndCondition(request => string.Equals(request.ProxyUrl, proxyUrl, StringComparison.OrdinalIgnoreCase));
|
||||||
|
|
||||||
|
chain
|
||||||
|
.BecauseOf(because, becauseArgs)
|
||||||
|
.Given(() => RequestMessages)
|
||||||
|
.ForCondition(requests => CallsCount == 0 || requests.Any())
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called with proxy url {0}{reason}, but no calls were made.",
|
||||||
|
proxyUrl
|
||||||
|
)
|
||||||
|
.Then
|
||||||
|
.ForCondition(condition)
|
||||||
|
.FailWith(
|
||||||
|
"Expected {context:wiremockadminapi} to have been called with proxy url {0}{reason}, but didn't find it among the calls with {1}.",
|
||||||
|
_ => proxyUrl,
|
||||||
|
requests => requests.Select(request => request.ProxyUrl)
|
||||||
|
);
|
||||||
|
|
||||||
|
FilterRequestMessages(filter);
|
||||||
|
|
||||||
|
return new AndWhichConstraint<WireMockAdminApiAssertions, string>(this, proxyUrl);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,42 @@
|
|||||||
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
|
#pragma warning disable CS1591
|
||||||
|
using WireMock.Admin.Requests;
|
||||||
|
using WireMock.Matchers;
|
||||||
|
|
||||||
|
// ReSharper disable once CheckNamespace
|
||||||
|
namespace WireMock.Client.AwesomeAssertions;
|
||||||
|
|
||||||
|
public partial class WireMockAdminApiAssertions(IWireMockAdminApi subject, int? callsCount, AssertionChain chain)
|
||||||
|
{
|
||||||
|
public const string Any = "*";
|
||||||
|
|
||||||
|
public int? CallsCount { get; } = callsCount;
|
||||||
|
|
||||||
|
public IReadOnlyList<LogRequestModel> RequestMessages { get; private set; } = subject.GetRequestsAsync().GetAwaiter().GetResult()
|
||||||
|
.Select(logEntry => logEntry.Request)
|
||||||
|
.OfType<LogRequestModel>()
|
||||||
|
.ToList();
|
||||||
|
|
||||||
|
public (Func<IReadOnlyList<LogRequestModel>, IReadOnlyList<LogRequestModel>> Filter, Func<IReadOnlyList<LogRequestModel>, bool> Condition) BuildFilterAndCondition(Func<LogRequestModel, bool> predicate)
|
||||||
|
{
|
||||||
|
IReadOnlyList<LogRequestModel> filter(IReadOnlyList<LogRequestModel> requests) => requests.Where(predicate).ToList();
|
||||||
|
|
||||||
|
return (filter, requests => (CallsCount is null && filter(requests).Any()) || CallsCount == filter(requests).Count);
|
||||||
|
}
|
||||||
|
|
||||||
|
public (Func<IReadOnlyList<LogRequestModel>, IReadOnlyList<LogRequestModel>> Filter, Func<IReadOnlyList<LogRequestModel>, bool> Condition) BuildFilterAndCondition(Func<LogRequestModel, string?> expression, IStringMatcher matcher)
|
||||||
|
{
|
||||||
|
return BuildFilterAndCondition(r => matcher.IsMatch(expression(r)).IsPerfect());
|
||||||
|
}
|
||||||
|
|
||||||
|
public (Func<IReadOnlyList<LogRequestModel>, IReadOnlyList<LogRequestModel>> Filter, Func<IReadOnlyList<LogRequestModel>, bool> Condition) BuildFilterAndCondition(Func<LogRequestModel, object?> expression, IObjectMatcher matcher)
|
||||||
|
{
|
||||||
|
return BuildFilterAndCondition(r => matcher.IsMatch(expression(r)).IsPerfect());
|
||||||
|
}
|
||||||
|
|
||||||
|
public void FilterRequestMessages(Func<IReadOnlyList<LogRequestModel>, IReadOnlyList<LogRequestModel>> filter)
|
||||||
|
{
|
||||||
|
RequestMessages = filter(RequestMessages).ToList();
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,50 @@
|
|||||||
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
|
using AwesomeAssertions.Primitives;
|
||||||
|
|
||||||
|
// ReSharper disable once CheckNamespace
|
||||||
|
namespace WireMock.Client.AwesomeAssertions;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Contains a number of methods to assert that the <see cref="IWireMockAdminApi"/> is in the expected state.
|
||||||
|
/// </summary>
|
||||||
|
/// <remarks>
|
||||||
|
/// Create a WireMockReceivedAssertions.
|
||||||
|
/// </remarks>
|
||||||
|
/// <param name="adminApi">The <see cref="IWireMockAdminApi"/>.</param>
|
||||||
|
/// <param name="chain">The assertion chain</param>
|
||||||
|
public class WireMockAdminApiReceivedAssertions(IWireMockAdminApi adminApi, AssertionChain chain) :
|
||||||
|
ReferenceTypeAssertions<IWireMockAdminApi, WireMockAdminApiReceivedAssertions>(adminApi, chain)
|
||||||
|
{
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Asserts if <see cref="IWireMockAdminApi"/> has received no calls.
|
||||||
|
/// </summary>
|
||||||
|
/// <returns><see cref="WireMockAdminApiAssertions"/></returns>
|
||||||
|
public WireMockAdminApiAssertions HaveReceivedNoCalls()
|
||||||
|
{
|
||||||
|
return new WireMockAdminApiAssertions(Subject, 0, CurrentAssertionChain);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Asserts if <see cref="IWireMockAdminApi"/> has received a call.
|
||||||
|
/// </summary>
|
||||||
|
/// <returns><see cref="WireMockAdminApiAssertions"/></returns>
|
||||||
|
public WireMockAdminApiAssertions HaveReceivedACall()
|
||||||
|
{
|
||||||
|
return new WireMockAdminApiAssertions(Subject, null, CurrentAssertionChain);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Asserts if <see cref="IWireMockAdminApi"/> has received n-calls.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="callsCount"></param>
|
||||||
|
/// <returns><see cref="WireMockAdminApiANumberOfCallsAssertions"/></returns>
|
||||||
|
public WireMockAdminApiANumberOfCallsAssertions HaveReceived(int callsCount)
|
||||||
|
{
|
||||||
|
return new WireMockAdminApiANumberOfCallsAssertions(Subject, callsCount, CurrentAssertionChain);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <inheritdoc />
|
||||||
|
protected override string Identifier => "wiremockadminapi";
|
||||||
|
}
|
||||||
@@ -0,0 +1,20 @@
|
|||||||
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
|
// ReSharper disable once CheckNamespace
|
||||||
|
namespace WireMock.Client.AwesomeAssertions;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Contains extension methods for custom assertions in unit tests.
|
||||||
|
/// </summary>
|
||||||
|
public static class WireMockAdminApiExtensions
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// Returns a <see cref="WireMockAdminApiReceivedAssertions"/> object that can be used to assert the current <see cref="IWireMockAdminApi"/>.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="instance">The WireMock Admin API client.</param>
|
||||||
|
/// <returns><see cref="WireMockAdminApiReceivedAssertions"/></returns>
|
||||||
|
public static WireMockAdminApiReceivedAssertions Should(this IWireMockAdminApi instance)
|
||||||
|
{
|
||||||
|
return new WireMockAdminApiReceivedAssertions(instance, AssertionChain.GetOrCreate());
|
||||||
|
}
|
||||||
|
}
|
||||||
4
src/WireMock.Net.RestClient.AwesomeAssertions/Usings.cs
Normal file
4
src/WireMock.Net.RestClient.AwesomeAssertions/Usings.cs
Normal file
@@ -0,0 +1,4 @@
|
|||||||
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
|
global using AwesomeAssertions;
|
||||||
|
global using AwesomeAssertions.Execution;
|
||||||
@@ -0,0 +1,43 @@
|
|||||||
|
<Project Sdk="Microsoft.NET.Sdk">
|
||||||
|
|
||||||
|
<PropertyGroup>
|
||||||
|
<Description>AwesomeAssertions extensions for WireMock.Net RestClient</Description>
|
||||||
|
<AssemblyTitle>WireMock.Net.RestClient.AwesomeAssertions</AssemblyTitle>
|
||||||
|
<Authors>Stef Heyenrath</Authors>
|
||||||
|
<TargetFramework>netstandard2.0</TargetFramework>
|
||||||
|
<GenerateDocumentationFile>true</GenerateDocumentationFile>
|
||||||
|
<AssemblyName>WireMock.Net.RestClient.AwesomeAssertions</AssemblyName>
|
||||||
|
<PackageId>WireMock.Net.RestClient.AwesomeAssertions</PackageId>
|
||||||
|
<PackageTags>wiremock;AwesomeAssertions;UnitTest;Assert;Assertions;restclient</PackageTags>
|
||||||
|
<RootNamespace>WireMock.Client.AwesomeAssertions</RootNamespace>
|
||||||
|
<ProjectGuid>{F4B2B967-7878-4D93-9A5C-5EF7B84B941A}</ProjectGuid>
|
||||||
|
<PublishRepositoryUrl>true</PublishRepositoryUrl>
|
||||||
|
<AllowedOutputExtensionsInPackageBuildOutputFolder>$(AllowedOutputExtensionsInPackageBuildOutputFolder);.pdb</AllowedOutputExtensionsInPackageBuildOutputFolder>
|
||||||
|
<EmbedUntrackedSources>true</EmbedUntrackedSources>
|
||||||
|
<AutoGenerateBindingRedirects>true</AutoGenerateBindingRedirects>
|
||||||
|
<GenerateBindingRedirectsOutputType>true</GenerateBindingRedirectsOutputType>
|
||||||
|
<SignAssembly>true</SignAssembly>
|
||||||
|
<AssemblyOriginatorKeyFile>../WireMock.Net/WireMock.Net.snk</AssemblyOriginatorKeyFile>
|
||||||
|
<!--<DelaySign>true</DelaySign>-->
|
||||||
|
<PublicSign Condition=" '$(OS)' != 'Windows_NT' ">true</PublicSign>
|
||||||
|
<PackageLicenseExpression>MIT</PackageLicenseExpression>
|
||||||
|
</PropertyGroup>
|
||||||
|
|
||||||
|
<PropertyGroup Condition="'$(Configuration)' == 'Debug - Sonar'">
|
||||||
|
<CodeAnalysisRuleSet>../WireMock.Net/WireMock.Net.ruleset</CodeAnalysisRuleSet>
|
||||||
|
</PropertyGroup>
|
||||||
|
|
||||||
|
<PropertyGroup Condition=" '$(Configuration)' == 'Release' ">
|
||||||
|
<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
|
||||||
|
</PropertyGroup>
|
||||||
|
|
||||||
|
<ItemGroup>
|
||||||
|
<PackageReference Include="AwesomeAssertions" Version="9.4.0" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
<ItemGroup>
|
||||||
|
<ProjectReference Include="..\WireMock.Net.Minimal\WireMock.Net.Minimal.csproj" />
|
||||||
|
<ProjectReference Include="..\WireMock.Net.RestClient\WireMock.Net.RestClient.csproj" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
</Project>
|
||||||
@@ -1,21 +0,0 @@
|
|||||||
// Copyright © WireMock.Net
|
|
||||||
|
|
||||||
namespace System.Collections.Generic;
|
|
||||||
|
|
||||||
internal static class EnumerableExtensions
|
|
||||||
{
|
|
||||||
//internal static IEnumerable<T> ReverseEx<T>(this IEnumerable<T> source)
|
|
||||||
//{
|
|
||||||
// var stack = new Stack<T>();
|
|
||||||
|
|
||||||
// foreach (var item in source)
|
|
||||||
// {
|
|
||||||
// stack.Push(item);
|
|
||||||
// }
|
|
||||||
|
|
||||||
// while (stack.Count > 0)
|
|
||||||
// {
|
|
||||||
// yield return stack.Pop();
|
|
||||||
// }
|
|
||||||
//}
|
|
||||||
}
|
|
||||||
@@ -1,11 +1,7 @@
|
|||||||
// Copyright © WireMock.Net
|
// Copyright © WireMock.Net
|
||||||
|
|
||||||
using System.Collections.Generic;
|
|
||||||
using System.IO;
|
|
||||||
using System.Linq;
|
|
||||||
using System.Net.Http.Headers;
|
using System.Net.Http.Headers;
|
||||||
using System.Text;
|
using System.Text;
|
||||||
using System.Threading.Tasks;
|
|
||||||
using Stef.Validation;
|
using Stef.Validation;
|
||||||
using WireMock.Constants;
|
using WireMock.Constants;
|
||||||
using WireMock.Matchers;
|
using WireMock.Matchers;
|
||||||
@@ -16,7 +12,7 @@ namespace WireMock.Util;
|
|||||||
internal static class BodyParser
|
internal static class BodyParser
|
||||||
{
|
{
|
||||||
private static readonly Encoding DefaultEncoding = new UTF8Encoding(encoderShouldEmitUTF8Identifier: false, throwOnInvalidBytes: true);
|
private static readonly Encoding DefaultEncoding = new UTF8Encoding(encoderShouldEmitUTF8Identifier: false, throwOnInvalidBytes: true);
|
||||||
private static readonly Encoding[] SupportedBodyAsStringEncodingForMultipart = [ DefaultEncoding, Encoding.ASCII ];
|
private static readonly Encoding[] SupportedBodyAsStringEncodingForMultipart = [DefaultEncoding, Encoding.ASCII];
|
||||||
|
|
||||||
/*
|
/*
|
||||||
HEAD - No defined body semantics.
|
HEAD - No defined body semantics.
|
||||||
@@ -156,7 +152,7 @@ internal static class BodyParser
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Try to get the body as String, FormUrlEncoded or Json
|
// Try to get the body as String, FormUrlEncoded or Json
|
||||||
try
|
if (IsProbablyText(data.BodyAsBytes))
|
||||||
{
|
{
|
||||||
data.BodyAsString = DefaultEncoding.GetString(data.BodyAsBytes);
|
data.BodyAsString = DefaultEncoding.GetString(data.BodyAsBytes);
|
||||||
data.Encoding = DefaultEncoding;
|
data.Encoding = DefaultEncoding;
|
||||||
@@ -168,15 +164,8 @@ internal static class BodyParser
|
|||||||
QueryStringParser.TryParse(data.BodyAsString, false, out var nameValueCollection)
|
QueryStringParser.TryParse(data.BodyAsString, false, out var nameValueCollection)
|
||||||
)
|
)
|
||||||
{
|
{
|
||||||
try
|
data.BodyAsFormUrlEncoded = nameValueCollection;
|
||||||
{
|
data.DetectedBodyType = BodyType.FormUrlEncoded;
|
||||||
data.BodyAsFormUrlEncoded = nameValueCollection;
|
|
||||||
data.DetectedBodyType = BodyType.FormUrlEncoded;
|
|
||||||
}
|
|
||||||
catch
|
|
||||||
{
|
|
||||||
// Deserialize FormUrlEncoded failed, just ignore.
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// If string is not null or empty, try to deserialize the string to a JObject
|
// If string is not null or empty, try to deserialize the string to a JObject
|
||||||
@@ -193,14 +182,10 @@ internal static class BodyParser
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch
|
|
||||||
{
|
|
||||||
// Reading as string failed, just ignore
|
|
||||||
}
|
|
||||||
|
|
||||||
return data;
|
return data;
|
||||||
}
|
}
|
||||||
|
|
||||||
private static async Task<(string? ContentType, byte[] Bytes)> ReadBytesAsync(Stream stream, string? contentEncoding = null, bool decompressGZipAndDeflate = true)
|
private static async Task<(string? ContentType, byte[] Bytes)> ReadBytesAsync(Stream stream, string? contentEncoding = null, bool decompressGZipAndDeflate = true)
|
||||||
{
|
{
|
||||||
using var memoryStream = new MemoryStream();
|
using var memoryStream = new MemoryStream();
|
||||||
@@ -215,4 +200,39 @@ internal static class BodyParser
|
|||||||
|
|
||||||
return (null, data);
|
return (null, data);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public static bool IsProbablyText(byte[] data)
|
||||||
|
{
|
||||||
|
if (data.Length == 0)
|
||||||
|
{
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 1) Quick binary detection
|
||||||
|
for (int i = 0; i < data.Length; i++)
|
||||||
|
{
|
||||||
|
if (data[i] == 0)
|
||||||
|
{
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// 2) Validate UTF-8
|
||||||
|
string text;
|
||||||
|
try
|
||||||
|
{
|
||||||
|
text = DefaultEncoding.GetString(data);
|
||||||
|
}
|
||||||
|
catch
|
||||||
|
{
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 3) Count printable characters
|
||||||
|
var printable = text.Count(c => !char.IsControl(c) || char.IsWhiteSpace(c));
|
||||||
|
var ratio = (double)printable / text.Length;
|
||||||
|
|
||||||
|
// Threshold commonly used by tools like git
|
||||||
|
return ratio > 0.85;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@@ -42,16 +42,16 @@ public interface IWebSocketBuilder
|
|||||||
/// <summary>
|
/// <summary>
|
||||||
/// Configure message sending based on message content matching
|
/// Configure message sending based on message content matching
|
||||||
/// </summary>
|
/// </summary>
|
||||||
/// <param name="condition">String to match in message text</param>
|
/// <param name="wildcardPattern">String to match in message text</param>
|
||||||
[PublicAPI]
|
[PublicAPI]
|
||||||
IWebSocketMessageConditionBuilder WhenMessage(string condition);
|
IWebSocketMessageConditionBuilder WhenMessage(string wildcardPattern);
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Configure message sending based on message content matching
|
/// Configure message sending based on message content matching
|
||||||
/// </summary>
|
/// </summary>
|
||||||
/// <param name="condition">Bytes to match in message</param>
|
/// <param name="exactPattern">Bytes to match in message</param>
|
||||||
[PublicAPI]
|
[PublicAPI]
|
||||||
IWebSocketMessageConditionBuilder WhenMessage(byte[] condition);
|
IWebSocketMessageConditionBuilder WhenMessage(byte[] exactPattern);
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Configure message sending based on IMatcher
|
/// Configure message sending based on IMatcher
|
||||||
|
|||||||
@@ -27,7 +27,6 @@
|
|||||||
<Compile Include="..\WireMock.Net.Minimal\Util\PortUtils.cs" Link="Util\PortUtils.cs" />
|
<Compile Include="..\WireMock.Net.Minimal\Util\PortUtils.cs" Link="Util\PortUtils.cs" />
|
||||||
<Compile Include="..\WireMock.Net.Minimal\Constants\WireMockConstants.cs" Link="Constants\WireMockConstants.cs" />
|
<Compile Include="..\WireMock.Net.Minimal\Constants\WireMockConstants.cs" Link="Constants\WireMockConstants.cs" />
|
||||||
<Compile Include="..\WireMock.Net.Shared\Constants\RegexConstants.cs" Link="Constants\RegexConstants.cs" />
|
<Compile Include="..\WireMock.Net.Shared\Constants\RegexConstants.cs" Link="Constants\RegexConstants.cs" />
|
||||||
<Compile Include="..\WireMock.Net.Shared\Extensions\EnumerableExtensions.cs" Link="Extensions\EnumerableExtensions.cs" />
|
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
|
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
|
|||||||
File diff suppressed because it is too large
Load Diff
@@ -52,7 +52,7 @@ public class WireMockAssertionsTests : IDisposable
|
|||||||
}
|
}
|
||||||
|
|
||||||
[Fact]
|
[Fact]
|
||||||
public async Task HaveReceived1Calls_AtAbsoluteUrl_WhenACallWasMadeToAbsoluteUrl_Should_BeOK()
|
public async Task HaveReceived1Call_AtAbsoluteUrl_WhenACallWasMadeToAbsoluteUrl_Should_BeOK()
|
||||||
{
|
{
|
||||||
await _httpClient.GetAsync("anyurl", _ct);
|
await _httpClient.GetAsync("anyurl", _ct);
|
||||||
|
|
||||||
@@ -62,7 +62,7 @@ public class WireMockAssertionsTests : IDisposable
|
|||||||
}
|
}
|
||||||
|
|
||||||
[Fact]
|
[Fact]
|
||||||
public async Task HaveReceived1Calls_AtAbsoluteUrl2_WhenACallWasMadeToAbsoluteUrl_Should_BeOK()
|
public async Task HaveReceived1Call_AtAbsoluteUrl2_WhenACallWasMadeToAbsoluteUrl_Should_BeOK()
|
||||||
{
|
{
|
||||||
await _httpClient.GetAsync("anyurl", _ct);
|
await _httpClient.GetAsync("anyurl", _ct);
|
||||||
|
|
||||||
@@ -72,7 +72,7 @@ public class WireMockAssertionsTests : IDisposable
|
|||||||
}
|
}
|
||||||
|
|
||||||
[Fact]
|
[Fact]
|
||||||
public async Task HaveReceived1Calls_AtAbsoluteUrlUsingPost_WhenAPostCallWasMadeToAbsoluteUrl_Should_BeOK()
|
public async Task HaveReceived1Call_AtAbsoluteUrlUsingPost_WhenAPostCallWasMadeToAbsoluteUrl_Should_BeOK()
|
||||||
{
|
{
|
||||||
await _httpClient.PostAsync("anyurl", new StringContent(""), _ct);
|
await _httpClient.PostAsync("anyurl", new StringContent(""), _ct);
|
||||||
|
|
||||||
@@ -162,7 +162,7 @@ public class WireMockAssertionsTests : IDisposable
|
|||||||
}
|
}
|
||||||
|
|
||||||
[Fact]
|
[Fact]
|
||||||
public async Task HaveReceived1Calls_AtAbsolutePath_WhenACallWasMadeToAbsolutePath_Should_BeOK()
|
public async Task HaveReceived1Call_AtAbsolutePath_WhenACallWasMadeToAbsolutePath_Should_BeOK()
|
||||||
{
|
{
|
||||||
await _httpClient.GetAsync("anypath", _ct);
|
await _httpClient.GetAsync("anypath", _ct);
|
||||||
|
|
||||||
@@ -172,7 +172,7 @@ public class WireMockAssertionsTests : IDisposable
|
|||||||
}
|
}
|
||||||
|
|
||||||
[Fact]
|
[Fact]
|
||||||
public async Task HaveReceived1Calls_AtAbsolutePathUsingPost_WhenAPostCallWasMadeToAbsolutePath_Should_BeOK()
|
public async Task HaveReceived1Call_AtAbsolutePathUsingPost_WhenAPostCallWasMadeToAbsolutePath_Should_BeOK()
|
||||||
{
|
{
|
||||||
await _httpClient.PostAsync("anypath", new StringContent(""), _ct);
|
await _httpClient.PostAsync("anypath", new StringContent(""), _ct);
|
||||||
|
|
||||||
@@ -241,6 +241,106 @@ public class WireMockAssertionsTests : IDisposable
|
|||||||
.WithMessage($"Expected _server to have been called at address matching the absolute path \"/anypath\", but didn't find it among the calls to {{\"/\"}}.");
|
.WithMessage($"Expected _server to have been called at address matching the absolute path \"/anypath\", but didn't find it among the calls to {{\"/\"}}.");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task HaveReceivedNoCalls_AtPath_WhenACallWasNotMadeToPath_Should_BeOK()
|
||||||
|
{
|
||||||
|
await _httpClient.GetAsync("xxx", _ct);
|
||||||
|
|
||||||
|
_server.Should()
|
||||||
|
.HaveReceivedNoCalls()
|
||||||
|
.AtPath("anypath");
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task HaveReceived0Calls_AtPath_WhenACallWasNotMadeToPath_Should_BeOK()
|
||||||
|
{
|
||||||
|
await _httpClient.GetAsync("xxx", _ct);
|
||||||
|
|
||||||
|
_server.Should()
|
||||||
|
.HaveReceived(0).Calls()
|
||||||
|
.AtPath("anypath");
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task HaveReceived1Call_AtPath_WhenACallWasMadeToPath_Should_BeOK()
|
||||||
|
{
|
||||||
|
await _httpClient.GetAsync("anypath", _ct);
|
||||||
|
|
||||||
|
_server.Should()
|
||||||
|
.HaveReceived(1).Calls()
|
||||||
|
.AtPath("/anypath");
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task HaveReceived1Call_AtPathUsingPost_WhenAPostCallWasMadeToPath_Should_BeOK()
|
||||||
|
{
|
||||||
|
await _httpClient.PostAsync("anypath", new StringContent(""), _ct);
|
||||||
|
|
||||||
|
_server.Should()
|
||||||
|
.HaveReceived(1).Calls()
|
||||||
|
.AtPath("/anypath")
|
||||||
|
.And
|
||||||
|
.UsingPost();
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task HaveReceived2Calls_AtPath_WhenACallWasMadeToPath_Should_BeOK()
|
||||||
|
{
|
||||||
|
await _httpClient.GetAsync("anypath", _ct);
|
||||||
|
|
||||||
|
await _httpClient.GetAsync("anypath", _ct);
|
||||||
|
|
||||||
|
_server.Should()
|
||||||
|
.HaveReceived(2).Calls()
|
||||||
|
.AtPath("/anypath");
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task HaveReceivedACall_AtPath_WhenACallWasMadeToPath_Should_BeOK()
|
||||||
|
{
|
||||||
|
await _httpClient.GetAsync("anypath", _ct);
|
||||||
|
|
||||||
|
_server.Should()
|
||||||
|
.HaveReceivedACall()
|
||||||
|
.AtPath(new WildcardMatcher("/any*"));
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task HaveReceivedACall_AtPathWildcardMatcher_WhenACallWasMadeToPath_Should_BeOK()
|
||||||
|
{
|
||||||
|
await _httpClient.GetAsync("anypath", _ct);
|
||||||
|
|
||||||
|
_server.Should()
|
||||||
|
.HaveReceivedACall()
|
||||||
|
.AtPath("/anypath");
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public void HaveReceivedACall_AtPath_Should_ThrowWhenNoCallsWereMade()
|
||||||
|
{
|
||||||
|
Action act = () => _server.Should()
|
||||||
|
.HaveReceivedACall()
|
||||||
|
.AtPath("anypath");
|
||||||
|
|
||||||
|
act.Should()
|
||||||
|
.Throw<Exception>()
|
||||||
|
.WithMessage("Expected _server to have been called at address matching the path \"anypath\", but no calls were made.");
|
||||||
|
}
|
||||||
|
|
||||||
|
[Fact]
|
||||||
|
public async Task HaveReceivedACall_AtPath_Should_ThrowWhenNoCallsMatchingThePathWereMade()
|
||||||
|
{
|
||||||
|
await _httpClient.GetAsync("", _ct);
|
||||||
|
|
||||||
|
Action act = () => _server.Should()
|
||||||
|
.HaveReceivedACall()
|
||||||
|
.AtPath("/anypath");
|
||||||
|
|
||||||
|
act.Should()
|
||||||
|
.Throw<Exception>()
|
||||||
|
.WithMessage($"Expected _server to have been called at address matching the path \"/anypath\", but didn't find it among the calls to {{\"/\"}}.");
|
||||||
|
}
|
||||||
|
|
||||||
[Fact]
|
[Fact]
|
||||||
public async Task HaveReceivedACall_WithHeader_WhenACallWasMadeWithExpectedHeader_Should_BeOK()
|
public async Task HaveReceivedACall_WithHeader_WhenACallWasMadeWithExpectedHeader_Should_BeOK()
|
||||||
{
|
{
|
||||||
@@ -332,7 +432,6 @@ public class WireMockAssertionsTests : IDisposable
|
|||||||
public async Task HaveReceivedACall_WithHeader_ShouldCheckAllRequests()
|
public async Task HaveReceivedACall_WithHeader_ShouldCheckAllRequests()
|
||||||
{
|
{
|
||||||
// Arrange
|
// Arrange
|
||||||
var cancellationToken = _ct;
|
|
||||||
using var server = WireMockServer.Start();
|
using var server = WireMockServer.Start();
|
||||||
using var client1 = server.CreateClient();
|
using var client1 = server.CreateClient();
|
||||||
|
|
||||||
@@ -346,7 +445,7 @@ public class WireMockAssertionsTests : IDisposable
|
|||||||
{
|
{
|
||||||
Authorization = new AuthenticationHeaderValue("Bearer", "invalidToken")
|
Authorization = new AuthenticationHeaderValue("Bearer", "invalidToken")
|
||||||
}
|
}
|
||||||
}, cancellationToken);
|
}, _ct);
|
||||||
|
|
||||||
// Act 2
|
// Act 2
|
||||||
var task2 = client2.SendAsync(new HttpRequestMessage(HttpMethod.Get, "/")
|
var task2 = client2.SendAsync(new HttpRequestMessage(HttpMethod.Get, "/")
|
||||||
@@ -355,7 +454,7 @@ public class WireMockAssertionsTests : IDisposable
|
|||||||
{
|
{
|
||||||
Authorization = new AuthenticationHeaderValue("Bearer", "validToken")
|
Authorization = new AuthenticationHeaderValue("Bearer", "validToken")
|
||||||
}
|
}
|
||||||
}, cancellationToken);
|
}, _ct);
|
||||||
|
|
||||||
await Task.WhenAll(task1, task2);
|
await Task.WhenAll(task1, task2);
|
||||||
|
|
||||||
@@ -625,7 +724,7 @@ public class WireMockAssertionsTests : IDisposable
|
|||||||
}
|
}
|
||||||
|
|
||||||
[Fact]
|
[Fact]
|
||||||
public async Task HaveReceived1Calls_AtAbsoluteUrlUsingPost_ShouldChain()
|
public async Task HaveReceived1Call_AtAbsoluteUrlUsingPost_ShouldChain()
|
||||||
{
|
{
|
||||||
// Arrange
|
// Arrange
|
||||||
var server = WireMockServer.Start();
|
var server = WireMockServer.Start();
|
||||||
|
|||||||
@@ -735,11 +735,9 @@ message Other {
|
|||||||
|
|
||||||
private static WireMockServer Given_When_ServerStarted_And_RunningOnHttpAndGrpc()
|
private static WireMockServer Given_When_ServerStarted_And_RunningOnHttpAndGrpc()
|
||||||
{
|
{
|
||||||
var ports = PortUtils.FindFreeTcpPorts(2);
|
|
||||||
|
|
||||||
var settings = new WireMockServerSettings
|
var settings = new WireMockServerSettings
|
||||||
{
|
{
|
||||||
Urls = [$"http://*:{ports[0]}/", $"grpc://*:{ports[1]}/"],
|
Urls = [$"http://*:0", $"grpc://*:0/"],
|
||||||
StartAdminInterface = true
|
StartAdminInterface = true
|
||||||
};
|
};
|
||||||
return WireMockServer.Start(settings);
|
return WireMockServer.Start(settings);
|
||||||
|
|||||||
@@ -63,7 +63,7 @@ public class WireMockActivitySourceTests
|
|||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
activity.GetTagItem(WireMockSemanticConventions.HttpStatusCode).Should().Be(200);
|
activity.GetTagItem(WireMockSemanticConventions.HttpStatusCode).Should().Be(200);
|
||||||
activity.GetTagItem("otel.status_code").Should().Be("OK");
|
activity.GetTagItem(WireMockSemanticConventions.OtelStatusCode).Should().Be("OK");
|
||||||
activity.GetTagItem(WireMockSemanticConventions.ResponseBody).Should().Be("ok");
|
activity.GetTagItem(WireMockSemanticConventions.ResponseBody).Should().Be("ok");
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -82,7 +82,7 @@ public class WireMockActivitySourceTests
|
|||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
activity.GetTagItem(WireMockSemanticConventions.HttpStatusCode).Should().Be(500);
|
activity.GetTagItem(WireMockSemanticConventions.HttpStatusCode).Should().Be(500);
|
||||||
activity.GetTagItem("otel.status_code").Should().Be("ERROR");
|
activity.GetTagItem(WireMockSemanticConventions.OtelStatusCode).Should().Be("ERROR");
|
||||||
}
|
}
|
||||||
|
|
||||||
[Fact]
|
[Fact]
|
||||||
@@ -182,7 +182,7 @@ public class WireMockActivitySourceTests
|
|||||||
WireMockActivitySource.RecordException(activity, exception);
|
WireMockActivitySource.RecordException(activity, exception);
|
||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
activity.GetTagItem("otel.status_code").Should().Be("ERROR");
|
activity.GetTagItem(WireMockSemanticConventions.OtelStatusCode).Should().Be("ERROR");
|
||||||
activity.GetTagItem("otel.status_description").Should().Be("boom");
|
activity.GetTagItem("otel.status_description").Should().Be("boom");
|
||||||
activity.GetTagItem("exception.type").Should().Be(typeof(InvalidOperationException).FullName);
|
activity.GetTagItem("exception.type").Should().Be(typeof(InvalidOperationException).FullName);
|
||||||
activity.GetTagItem("exception.message").Should().Be("boom");
|
activity.GetTagItem("exception.message").Should().Be("boom");
|
||||||
|
|||||||
@@ -50,6 +50,7 @@
|
|||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<ProjectReference Include="..\..\src\WireMock.Net.AwesomeAssertions\WireMock.Net.AwesomeAssertions.csproj" />
|
<ProjectReference Include="..\..\src\WireMock.Net.AwesomeAssertions\WireMock.Net.AwesomeAssertions.csproj" />
|
||||||
<ProjectReference Include="..\..\src\WireMock.Net.Matchers.CSharpCode\WireMock.Net.Matchers.CSharpCode.csproj" />
|
<ProjectReference Include="..\..\src\WireMock.Net.Matchers.CSharpCode\WireMock.Net.Matchers.CSharpCode.csproj" />
|
||||||
|
<ProjectReference Include="..\..\src\WireMock.Net.RestClient.AwesomeAssertions\WireMock.Net.RestClient.AwesomeAssertions.csproj" />
|
||||||
<ProjectReference Include="..\..\src\WireMock.Net.RestClient\WireMock.Net.RestClient.csproj" />
|
<ProjectReference Include="..\..\src\WireMock.Net.RestClient\WireMock.Net.RestClient.csproj" />
|
||||||
<ProjectReference Include="..\..\src\WireMock.Net.xUnit.v3\WireMock.Net.xUnit.v3.csproj" />
|
<ProjectReference Include="..\..\src\WireMock.Net.xUnit.v3\WireMock.Net.xUnit.v3.csproj" />
|
||||||
<ProjectReference Include="..\..\src\WireMock.Net\WireMock.Net.csproj" />
|
<ProjectReference Include="..\..\src\WireMock.Net\WireMock.Net.csproj" />
|
||||||
|
|||||||
Reference in New Issue
Block a user