Compare commits

...

5 Commits

Author SHA1 Message Date
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
2 changed files with 12 additions and 3 deletions
@@ -16,7 +16,8 @@ public sealed class PayfastConfirmationEndpoint : IEndpoint
public void Map(IEndpointRouteBuilder builder)
{
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);
@@ -39,7 +40,11 @@ public sealed class PayfastConfirmationEndpoint : IEndpoint
var signatureCheck = PayfastService.GenerateSignature(paramDictionary, passphrase);
if (signatureCheck.IsFailed || !string.Equals(signatureCheck.Value, incomingSignature, StringComparison.OrdinalIgnoreCase))
{
logger.LogCritical($"Incoming sugnature failed validation: {incomingSignature}, {signatureCheck.Errors.Select(e => e.Message).ToList()}");
return Results.Unauthorized();
}
var formPairs = formCollection.Select(kvp => $"{kvp.Key}={HttpUtility.UrlEncode(kvp.Value.ToString())}");
@@ -50,7 +55,11 @@ public sealed class PayfastConfirmationEndpoint : IEndpoint
var serverConfirmation = await payfastService.ValidateServerConfirmationAsync(rawQueryParamString, isSandbox, cancellationToken);
if (serverConfirmation.IsFailed || !serverConfirmation.Value)
{
logger.LogCritical($"Server confirmation failed: {rawQueryParamString}, {serverConfirmation.Errors.Select(e => e.Message).ToList()}");
return Results.Unauthorized();
}
var notification = PayfastPaymentConfirmationReceivedEvent.Create(payload, payload.MerchantPaymentId!,
allowLoopback: !hostEnvironment.IsProduction(), performBackgroundChecks: false);
+2 -2
View File
@@ -161,8 +161,8 @@ spec:
httpGet:
path: /health
port: 8080
initialDelaySeconds: 5
periodSeconds: 10
initialDelaySeconds: 10
periodSeconds: 15
readinessProbe:
httpGet:
path: /health