WebHook - Transform Url (#824)

* WebHook - Url

* .
This commit is contained in:
Stef Heyenrath
2022-10-15 08:55:05 +02:00
committed by GitHub
parent 55afc8041f
commit 36037627bc
6 changed files with 231 additions and 178 deletions
@@ -0,0 +1,8 @@
{
"profiles": {
"WSL": {
"commandName": "WSL2",
"distributionName": ""
}
}
}
+9 -5
View File
@@ -44,37 +44,41 @@ internal class WebhookSender
IBodyData? bodyData; IBodyData? bodyData;
IDictionary<string, WireMockList<string>>? headers; IDictionary<string, WireMockList<string>>? headers;
string webhookRequestUrl;
if (webhookRequest.UseTransformer == true) if (webhookRequest.UseTransformer == true)
{ {
ITransformer responseMessageTransformer; ITransformer transformer;
switch (webhookRequest.TransformerType) switch (webhookRequest.TransformerType)
{ {
case TransformerType.Handlebars: case TransformerType.Handlebars:
var factoryHandlebars = new HandlebarsContextFactory(_settings.FileSystemHandler, _settings.HandlebarsRegistrationCallback); var factoryHandlebars = new HandlebarsContextFactory(_settings.FileSystemHandler, _settings.HandlebarsRegistrationCallback);
responseMessageTransformer = new Transformer(factoryHandlebars); transformer = new Transformer(factoryHandlebars);
break; break;
case TransformerType.Scriban: case TransformerType.Scriban:
case TransformerType.ScribanDotLiquid: case TransformerType.ScribanDotLiquid:
var factoryDotLiquid = new ScribanContextFactory(_settings.FileSystemHandler, webhookRequest.TransformerType); var factoryDotLiquid = new ScribanContextFactory(_settings.FileSystemHandler, webhookRequest.TransformerType);
responseMessageTransformer = new Transformer(factoryDotLiquid); transformer = new Transformer(factoryDotLiquid);
break; break;
default: default:
throw new NotImplementedException($"TransformerType '{webhookRequest.TransformerType}' is not supported."); throw new NotImplementedException($"TransformerType '{webhookRequest.TransformerType}' is not supported.");
} }
(bodyData, headers) = responseMessageTransformer.Transform(mapping, originalRequestMessage, originalResponseMessage, webhookRequest.BodyData, webhookRequest.Headers, webhookRequest.TransformerReplaceNodeOptions); bodyData = transformer.TransformBody(mapping, originalRequestMessage, originalResponseMessage, webhookRequest.BodyData, webhookRequest.TransformerReplaceNodeOptions);
headers = transformer.TransformHeaders(mapping, originalRequestMessage, originalResponseMessage, webhookRequest.Headers);
webhookRequestUrl = transformer.TransformString(mapping, originalRequestMessage, originalResponseMessage, webhookRequest.Url);
} }
else else
{ {
bodyData = webhookRequest.BodyData; bodyData = webhookRequest.BodyData;
headers = webhookRequest.Headers; headers = webhookRequest.Headers;
webhookRequestUrl = webhookRequest.Url;
} }
// Create RequestMessage // Create RequestMessage
var requestMessage = new RequestMessage( var requestMessage = new RequestMessage(
new UrlDetails(webhookRequest.Url), new UrlDetails(webhookRequestUrl),
webhookRequest.Method, webhookRequest.Method,
ClientIp, ClientIp,
bodyData, bodyData,
@@ -8,5 +8,9 @@ interface ITransformer
{ {
ResponseMessage Transform(IMapping mapping, IRequestMessage requestMessage, IResponseMessage original, bool useTransformerForBodyAsFile, ReplaceNodeOptions options); ResponseMessage Transform(IMapping mapping, IRequestMessage requestMessage, IResponseMessage original, bool useTransformerForBodyAsFile, ReplaceNodeOptions options);
(IBodyData? BodyData, IDictionary<string, WireMockList<string>>? Headers) Transform(IMapping mapping, IRequestMessage originalRequestMessage, IResponseMessage originalResponseMessage, IBodyData? bodyData, IDictionary<string, WireMockList<string>>? headers, ReplaceNodeOptions options); IBodyData? TransformBody(IMapping mapping, IRequestMessage originalRequestMessage, IResponseMessage originalResponseMessage, IBodyData? bodyData, ReplaceNodeOptions options);
IDictionary<string, WireMockList<string>>? TransformHeaders(IMapping mapping, IRequestMessage originalRequestMessage, IResponseMessage originalResponseMessage, IDictionary<string, WireMockList<string>>? headers);
string TransformString(IMapping mapping, IRequestMessage originalRequestMessage, IResponseMessage originalResponseMessage, string? value);
} }
@@ -0,0 +1,13 @@
using System.Diagnostics.CodeAnalysis;
namespace WireMock.Transformers;
[SuppressMessage("ReSharper", "InconsistentNaming")]
internal struct TransformModel
{
public IMapping mapping { get; set; }
public IRequestMessage request { get; set; }
public IResponseMessage? response { get; set; }
}
+47 -23
View File
@@ -1,9 +1,9 @@
using System;
using System.Collections.Generic;
using System.Linq;
using Newtonsoft.Json; using Newtonsoft.Json;
using Newtonsoft.Json.Linq; using Newtonsoft.Json.Linq;
using Stef.Validation; using Stef.Validation;
using System;
using System.Collections.Generic;
using System.Linq;
using WireMock.Types; using WireMock.Types;
using WireMock.Util; using WireMock.Util;
@@ -18,22 +18,14 @@ internal class Transformer : ITransformer
_factory = Guard.NotNull(factory); _factory = Guard.NotNull(factory);
} }
public (IBodyData? BodyData, IDictionary<string, WireMockList<string>>? Headers) Transform( public IBodyData? TransformBody(
IMapping mapping, IMapping mapping,
IRequestMessage originalRequestMessage, IRequestMessage originalRequestMessage,
IResponseMessage originalResponseMessage, IResponseMessage originalResponseMessage,
IBodyData? bodyData, IBodyData? bodyData,
IDictionary<string, WireMockList<string>>? headers,
ReplaceNodeOptions options) ReplaceNodeOptions options)
{ {
var transformerContext = _factory.Create(); var (transformerContext, model) = Create(mapping, originalRequestMessage, originalResponseMessage);
var model = new
{
mapping,
request = originalRequestMessage,
response = originalResponseMessage
};
IBodyData? newBodyData = null; IBodyData? newBodyData = null;
if (bodyData?.DetectedBodyType != null) if (bodyData?.DetectedBodyType != null)
@@ -41,20 +33,42 @@ internal class Transformer : ITransformer
newBodyData = TransformBodyData(transformerContext, options, model, bodyData, false); newBodyData = TransformBodyData(transformerContext, options, model, bodyData, false);
} }
return (newBodyData, TransformHeaders(transformerContext, model, headers)); return newBodyData;
}
public IDictionary<string, WireMockList<string>>? TransformHeaders(
IMapping mapping,
IRequestMessage originalRequestMessage,
IResponseMessage originalResponseMessage,
IDictionary<string, WireMockList<string>>? headers
)
{
var (transformerContext, model) = Create(mapping, originalRequestMessage, originalResponseMessage);
return TransformHeaders(transformerContext, model, headers);
}
public string TransformString(
IMapping mapping,
IRequestMessage originalRequestMessage,
IResponseMessage originalResponseMessage,
string? value
)
{
if (value is null)
{
return string.Empty;
}
var (transformerContext, model) = Create(mapping, originalRequestMessage, originalResponseMessage);
return transformerContext.ParseAndRender(value, model);
} }
public ResponseMessage Transform(IMapping mapping, IRequestMessage requestMessage, IResponseMessage original, bool useTransformerForBodyAsFile, ReplaceNodeOptions options) public ResponseMessage Transform(IMapping mapping, IRequestMessage requestMessage, IResponseMessage original, bool useTransformerForBodyAsFile, ReplaceNodeOptions options)
{ {
var transformerContext = _factory.Create();
var responseMessage = new ResponseMessage(); var responseMessage = new ResponseMessage();
var model = new var (transformerContext, model) = Create(mapping, requestMessage, null);
{
mapping,
request = requestMessage
};
if (original.BodyData?.DetectedBodyType != null) if (original.BodyData?.DetectedBodyType != null)
{ {
@@ -85,7 +99,17 @@ internal class Transformer : ITransformer
return responseMessage; return responseMessage;
} }
private static IBodyData? TransformBodyData(ITransformerContext transformerContext, ReplaceNodeOptions options, object model, IBodyData original, bool useTransformerForBodyAsFile) private (ITransformerContext TransformerContext, TransformModel Model) Create(IMapping mapping, IRequestMessage request, IResponseMessage? response)
{
return (_factory.Create(), new TransformModel
{
mapping = mapping,
request = request,
response = response
});
}
private static IBodyData? TransformBodyData(ITransformerContext transformerContext, ReplaceNodeOptions options, TransformModel model, IBodyData original, bool useTransformerForBodyAsFile)
{ {
return original.DetectedBodyType switch return original.DetectedBodyType switch
{ {
@@ -96,7 +120,7 @@ internal class Transformer : ITransformer
}; };
} }
private static IDictionary<string, WireMockList<string>> TransformHeaders(ITransformerContext transformerContext, object model, IDictionary<string, WireMockList<string>>? original) private static IDictionary<string, WireMockList<string>> TransformHeaders(ITransformerContext transformerContext, TransformModel model, IDictionary<string, WireMockList<string>>? original)
{ {
if (original == null) if (original == null)
{ {
@@ -12,10 +12,10 @@ using WireMock.Types;
using WireMock.Util; using WireMock.Util;
using Xunit; using Xunit;
namespace WireMock.Net.Tests namespace WireMock.Net.Tests;
public class WireMockServerWebhookTests
{ {
public class WireMockServerWebhookTests
{
[Fact] [Fact]
public async Task WireMockServer_WithWebhooks_Should_Send_Message_To_Webhooks() public async Task WireMockServer_WithWebhooks_Should_Send_Message_To_Webhooks()
{ {
@@ -89,7 +89,7 @@ namespace WireMock.Net.Tests
{ {
// Assign // Assign
var serverReceivingTheWebhook = WireMockServer.Start(); var serverReceivingTheWebhook = WireMockServer.Start();
serverReceivingTheWebhook.Given(Request.Create().UsingPost()).RespondWith(Response.Create().WithStatusCode(200)); serverReceivingTheWebhook.Given(Request.Create().WithPath("x").UsingPost()).RespondWith(Response.Create().WithStatusCode(200));
// Act // Act
var server = WireMockServer.Start(); var server = WireMockServer.Start();
@@ -98,14 +98,15 @@ namespace WireMock.Net.Tests
{ {
Request = new WebhookRequest Request = new WebhookRequest
{ {
Url = serverReceivingTheWebhook.Urls[0], Url = serverReceivingTheWebhook.Url! + "/{{request.Query.q}}",
Method = "post", Method = "post",
BodyData = new BodyData BodyData = new BodyData
{ {
BodyAsString = "abc", BodyAsString = "abc",
DetectedBodyType = BodyType.String, DetectedBodyType = BodyType.String,
DetectedBodyTypeFromContentType = BodyType.String DetectedBodyTypeFromContentType = BodyType.String
} },
UseTransformer = true
} }
}) })
.RespondWith(Response.Create().WithBody("a-response")); .RespondWith(Response.Create().WithBody("a-response"));
@@ -113,7 +114,7 @@ namespace WireMock.Net.Tests
var request = new HttpRequestMessage var request = new HttpRequestMessage
{ {
Method = HttpMethod.Post, Method = HttpMethod.Post,
RequestUri = new Uri($"{server.Urls[0]}/TST"), RequestUri = new Uri($"{server.Urls[0]}/TST?q=x"),
Content = new StringContent("test") Content = new StringContent("test")
}; };
@@ -197,5 +198,4 @@ namespace WireMock.Net.Tests
server.Dispose(); server.Dispose();
serverReceivingTheWebhook.Dispose(); serverReceivingTheWebhook.Dispose();
} }
}
} }