/
OrderProcessor.cs
60 lines (49 loc) · 2.05 KB
/
OrderProcessor.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
using Cleipnir.ResilientFunctions;
using Cleipnir.ResilientFunctions.AspNetCore.Core;
using Cleipnir.ResilientFunctions.Domain;
using Serilog;
namespace Sample.WebApi.Ordering;
public class OrderProcessor : IRegisterRFuncOnInstantiation
{
private RAction.Invoke<Order, Scrapbook> RAction { get; }
public OrderProcessor(RFunctions rFunctions)
{
var registration = rFunctions
.RegisterMethod<Inner>()
.RegisterAction<Order, Scrapbook>(
nameof(OrderProcessor),
inner => inner.ProcessOrder
);
RAction = registration.Invoke;
}
public Task ProcessOrder(Order order)
=> RAction.Invoke(
functionInstanceId: order.OrderId,
param: order
);
public class Inner
{
private readonly IPaymentProviderClient _paymentProviderClient;
private readonly IEmailClient _emailClient;
private readonly ILogisticsClient _logisticsClient;
public Inner(IPaymentProviderClient paymentProviderClient, IEmailClient emailClient, ILogisticsClient logisticsClient)
{
_paymentProviderClient = paymentProviderClient;
_emailClient = emailClient;
_logisticsClient = logisticsClient;
}
public async Task ProcessOrder(Order order, Scrapbook scrapbook)
{
Log.Logger.Information($"ORDER_PROCESSOR: Processing of order '{order.OrderId}' started");
await _paymentProviderClient.Reserve(scrapbook.TransactionId, order.CustomerId, order.TotalPrice);
await _logisticsClient.ShipProducts(order.CustomerId, order.ProductIds);
await _paymentProviderClient.Capture(scrapbook.TransactionId);
await _emailClient.SendOrderConfirmation(order.CustomerId, order.ProductIds);
Log.Logger.ForContext<OrderProcessor>().Information($"Processing of order '{order.OrderId}' completed");
}
}
public class Scrapbook : RScrapbook
{
public Guid TransactionId { get; set; } = Guid.NewGuid();
}
}