Compare commits

...

13 Commits

Author SHA1 Message Date
khwezi 5c7ef3525f Merge pull request 'Refactored ledger handing' (#27) from payments into master
Reviewed-on: #27
2026-06-13 18:08:59 +02:00
Khwezi Mngoma 86da0d843e Refactored ledger handing
continuous-integration/drone/pr Build is passing
2026-06-13 18:08:34 +02:00
khwezi 59710e32a6 Merge pull request 'Updated nuget packages' (#26) from payments into master
Reviewed-on: #26
2026-06-13 17:22:56 +02:00
Khwezi Mngoma 5190fcaa17 Updated nuget packages
continuous-integration/drone/pr Build is passing
2026-06-13 17:22:26 +02:00
khwezi d0afc4f748 Merge pull request 'Updated niget packages' (#25) from payments into master
Reviewed-on: #25
2026-06-13 16:38:48 +02:00
Khwezi Mngoma 9a96c0ad0c Updated niget packages
continuous-integration/drone/pr Build is passing
2026-06-13 16:38:18 +02:00
khwezi 8cdfba58fd Merge pull request 'Refactored endpoint to handle incoming form using IFormCollection' (#24) from payments into master
Reviewed-on: #24
2026-06-13 16:10:33 +02:00
Khwezi Mngoma 41e1c9da4c Refactored endpoint to handle incoming form using IFormCollection
continuous-integration/drone/pr Build is passing
2026-06-13 16:10:05 +02:00
khwezi 01d3aa90ea Merge pull request 'Added inline logging for critical bugs' (#23) from payments into master
Reviewed-on: #23
2026-06-13 15:30:28 +02:00
Khwezi Mngoma c3981fd859 Added inline logging for critical bugs
continuous-integration/drone/pr Build is passing
2026-06-13 15:29:55 +02:00
khwezi 8cc4425dfb Merge pull request 'payments' (#22) from payments into master
Reviewed-on: #22
2026-06-13 13:14:50 +02:00
Khwezi Mngoma 60579c6230 Slowed down health check stream
continuous-integration/drone/pr Build is passing
2026-06-13 13:14:27 +02:00
Khwezi Mngoma f3478270fb Added logging to endpoint 2026-06-13 13:13:01 +02:00
3 changed files with 20 additions and 16 deletions
+2 -2
View File
@@ -54,13 +54,13 @@
</ItemGroup> </ItemGroup>
<ItemGroup> <ItemGroup>
<PackageReference Include="LiteCharms.Features" Version="1.115.0" /> <PackageReference Include="LiteCharms.Features" Version="1.122.0" />
</ItemGroup> </ItemGroup>
<!-- UI --> <!-- UI -->
<ItemGroup> <ItemGroup>
<PackageReference Include="ANM.Blazored.Toast" Version="0.1.1" /> <PackageReference Include="ANM.Blazored.Toast" Version="0.1.1" />
<PackageReference Include="LiteCharms.Features.MidrandBooks" Version="1.115.0" /> <PackageReference Include="LiteCharms.Features.MidrandBooks" Version="1.122.0" />
<!-- Global Usings --> <!-- Global Usings -->
<Using Include="Blazored.Toast.Services" /> <Using Include="Blazored.Toast.Services" />
@@ -16,15 +16,14 @@ public sealed class PayfastConfirmationEndpoint : IEndpoint
public void Map(IEndpointRouteBuilder builder) public void Map(IEndpointRouteBuilder builder)
{ {
builder.MapPost("payments/payfast/confirm", async (HttpRequest request, PayfastService payfastService, builder.MapPost("payments/payfast/confirm", async (HttpRequest request, PayfastService payfastService,
IJobOrchestrator jobOrchestrator, IConfiguration configuration, IHostEnvironment hostEnvironment, CancellationToken cancellationToken) => IJobOrchestrator jobOrchestrator, IConfiguration configuration, IHostEnvironment hostEnvironment,
ILogger<PayfastConfirmationEndpoint> logger, CancellationToken cancellationToken) =>
{ {
using Activity? activity = PaymentActivitySource.StartActivity("ReceivePayfastWebhook", ActivityKind.Server); using Activity? activity = PaymentActivitySource.StartActivity("ReceivePayfastWebhook", ActivityKind.Server);
activity?.SetTag("messaging.system", "payfast"); activity?.SetTag("messaging.system", "payfast");
activity?.SetTag("messaging.destination.name", "payments/payfast/confirm"); activity?.SetTag("messaging.destination.name", "payments/payfast/confirm");
string? remoteIp = request.HttpContext.Connection.RemoteIpAddress?.ToString();
var formCollection = await request.ReadFormAsync(cancellationToken); var formCollection = await request.ReadFormAsync(cancellationToken);
if (!formCollection.TryGetValue("signature", out var signatureValues) || string.IsNullOrWhiteSpace(signatureValues.ToString())) if (!formCollection.TryGetValue("signature", out var signatureValues) || string.IsNullOrWhiteSpace(signatureValues.ToString()))
@@ -33,24 +32,30 @@ public sealed class PayfastConfirmationEndpoint : IEndpoint
string incomingSignature = signatureValues.ToString().Trim(); string incomingSignature = signatureValues.ToString().Trim();
var payload = ParseForm(formCollection, incomingSignature); var payload = ParseForm(formCollection, incomingSignature);
var paramDictionary = payload.ToParamDictionary(); string? passphrase = configuration["PayfastSettings:Passphrase"];
string? passphrase = configuration["HasherSettings:PayfastPassphrase"];
var signatureCheck = PayfastService.GenerateSignature(paramDictionary, passphrase); if (!PayfastService.VerifyIncomingSignatureFromForm(formCollection, passphrase!))
{
if (signatureCheck.IsFailed || !string.Equals(signatureCheck.Value, incomingSignature, StringComparison.OrdinalIgnoreCase)) logger.LogCritical($"Incoming signature failed validation: {incomingSignature}");
return Results.Unauthorized(); return Results.Unauthorized();
}
var formPairs = formCollection.Select(kvp => $"{kvp.Key}={HttpUtility.UrlEncode(kvp.Value.ToString())}"); var sortedPairs = formCollection
.Where(kvp => !kvp.Key.Equals("signature", StringComparison.OrdinalIgnoreCase))
.OrderBy(kvp => kvp.Key, StringComparer.Ordinal)
.Select(kvp => $"{kvp.Key}={HttpUtility.UrlEncode(kvp.Value.ToString().Trim())}");
string rawQueryParamString = string.Join("&", formPairs); string rawQueryParamString = string.Join("&", sortedPairs);
bool isSandbox = !hostEnvironment.IsProduction(); bool isSandbox = !hostEnvironment.IsProduction();
var serverConfirmation = await payfastService.ValidateServerConfirmationAsync(rawQueryParamString, isSandbox, cancellationToken); var serverConfirmation = await payfastService.ValidateServerConfirmationAsync(rawQueryParamString, isSandbox, cancellationToken);
if (serverConfirmation.IsFailed || !serverConfirmation.Value) if (serverConfirmation.IsFailed || !serverConfirmation.Value)
{
logger.LogCritical($"Payfast server validation ping rejected the request data: {rawQueryParamString}");
return Results.Unauthorized(); return Results.Unauthorized();
}
var notification = PayfastPaymentConfirmationReceivedEvent.Create(payload, payload.MerchantPaymentId!, var notification = PayfastPaymentConfirmationReceivedEvent.Create(payload, payload.MerchantPaymentId!,
allowLoopback: !hostEnvironment.IsProduction(), performBackgroundChecks: false); allowLoopback: !hostEnvironment.IsProduction(), performBackgroundChecks: false);
@@ -58,7 +63,6 @@ public sealed class PayfastConfirmationEndpoint : IEndpoint
await jobOrchestrator.SendAsync(notification, cancellationToken); await jobOrchestrator.SendAsync(notification, cancellationToken);
activity?.SetStatus(ActivityStatusCode.Ok); activity?.SetStatus(ActivityStatusCode.Ok);
return Results.Ok(); return Results.Ok();
}) })
.WithDescription("Securely confirm and process an incoming Payfast merchant payment callback.") .WithDescription("Securely confirm and process an incoming Payfast merchant payment callback.")
+2 -2
View File
@@ -161,8 +161,8 @@ spec:
httpGet: httpGet:
path: /health path: /health
port: 8080 port: 8080
initialDelaySeconds: 5 initialDelaySeconds: 10
periodSeconds: 10 periodSeconds: 15
readinessProbe: readinessProbe:
httpGet: httpGet:
path: /health path: /health