-
Notifications
You must be signed in to change notification settings - Fork 34
/
EventRegistrationActivity.cs
79 lines (60 loc) · 2.57 KB
/
EventRegistrationActivity.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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
namespace Registration.Components.Activities;
using System;
using System.Threading.Tasks;
using MassTransit;
using Microsoft.Extensions.Logging;
public class EventRegistrationActivity :
IActivity<EventRegistrationArguments, EventRegistrationLog>
{
readonly ILogger<EventRegistrationActivity> _logger;
readonly IEndpointAddressProvider _provider;
public EventRegistrationActivity(ILogger<EventRegistrationActivity> logger, IEndpointAddressProvider provider)
{
_logger = logger;
_provider = provider;
}
public async Task<ExecutionResult> Execute(ExecuteContext<EventRegistrationArguments> context)
{
var arguments = context.Arguments;
_logger.LogInformation("Registering for event: {EventId} ({Email})", arguments.EventId, arguments.ParticipantEmailAddress);
var registrationTotal = 25.00m;
if (!string.IsNullOrWhiteSpace(arguments.ParticipantLicenseNumber))
{
_logger.LogInformation("Participant Detail: {LicenseNumber} ({LicenseExpiration}) {Category}",
arguments.ParticipantLicenseNumber, arguments.ParticipantLicenseExpirationDate, arguments.ParticipantCategory);
registrationTotal = 15.0m;
}
await Task.Delay(10);
Guid? registrationId = NewId.NextGuid();
_logger.LogInformation("Registered for event: {RegistrationId} ({Email})", registrationId, arguments.ParticipantEmailAddress);
var log = new EventRegistrationLog
{
RegistrationId = registrationId.Value,
ParticipantEmailAddress = arguments.ParticipantEmailAddress
};
var variables = new
{
registrationId,
Amount = registrationTotal
};
if (arguments.EventId?.StartsWith("DANGER") ?? false)
{
return context.ReviseItinerary(log, variables, x =>
{
x.AddActivitiesFromSourceItinerary();
x.AddActivity("Assign Waiver", _provider.GetExecuteEndpoint<AssignWaiverActivity, AssignWaiverArguments>());
});
}
return context.CompletedWithVariables(new
{
registrationId,
arguments.ParticipantEmailAddress
}, variables);
}
public async Task<CompensationResult> Compensate(CompensateContext<EventRegistrationLog> context)
{
_logger.LogInformation("Removing registration for event: {RegistrationId} ({Email})", context.Log.RegistrationId, context.Log.ParticipantEmailAddress);
await Task.Delay(10);
return context.Compensated();
}
}