httpsrichardy.comanda/Boundaries/Comanda.Orchestrator/Source/Comanda.Orchestrator.WebApi/Controllers/SubscriptionsController.cs at 0e96d045fc74721d76aaf1d9897228e9c558e865 · https-richardy/httpsrichardy.comanda · GitHub

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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
namespace Comanda.Orchestrator.WebApi.Controllers;

[ApiController]
[Route("api/v1/subscriptions")]
public sealed class SubscriptionsController(IDispatcher dispatcher) : ControllerBase
{
    [HttpPost]
    [Authorize(Roles = Permissions.Subscribe)]
    [Idempotent] // https://developer.mozilla.org/en-US/docs/Glossary/Idempotent
    public async Task<IActionResult> CreateCheckoutSessionAsync(
        [FromBody] SubscriptionCheckoutSessionCreationScheme request, CancellationToken cancellation)
    {
        var result = await dispatcher.DispatchAsync(request, cancellation);

        return result switch
        {
            { IsSuccess: true } when result.Data is not null =>
                StatusCode(StatusCodes.Status200OK, result.Data),

            { IsFailure: true } when result.Error == SubscriptionErrors.PlanNotSupported =>
                StatusCode(StatusCodes.Status422UnprocessableEntity, result.Error),

            { IsFailure: true } when result.Error == CommonErrors.RateLimitExceeded =>
                StatusCode(StatusCodes.Status429TooManyRequests, result.Error),

            { IsFailure: true } when result.Error == CommonErrors.OperationFailed =>
                StatusCode(StatusCodes.Status500InternalServerError, result.Error),
        };
    }

    [HttpDelete("{id}")]
    [Authorize(Roles = Permissions.CancelSubscription)]
    [Idempotent] // https://developer.mozilla.org/en-US/docs/Glossary/Idempotent
    public async Task<IActionResult> CancelSubscriptionAsync(
        [FromQuery] SubscriptionCancelationScheme request, [FromRoute] string id, CancellationToken cancellation)
    {
        // we’re not actually receiving the subscription id as a query parameter, it’s taken from the route.
        // this is just an elegant way to instantiate the request record without explicitly using new()

        var result = await dispatcher.DispatchAsync(request with { SubscriptionId = id }, cancellation);

        return result switch
        {
            { IsSuccess: true } when result.Data is not null =>
                StatusCode(StatusCodes.Status200OK, result.Data),

            { IsFailure: true } when result.Error == SubscriptionErrors.SubscriptionDoesNotExist =>
                StatusCode(StatusCodes.Status404NotFound, result.Error),

            { IsFailure: true } when result.Error == CommonErrors.RateLimitExceeded =>
                StatusCode(StatusCodes.Status429TooManyRequests, result.Error),

            { IsFailure: true } when result.Error == CommonErrors.OperationFailed =>
                StatusCode(StatusCodes.Status500InternalServerError, result.Error),
        };
    }

    [HttpGet("callback/success")]
    [AllowAnonymous]
    public async Task<IActionResult> OnSuccessCallbackAsync(
        [FromQuery] CallbackSuccessfulCheckoutParameters request, CancellationToken cancellation)
    {
        var result = await dispatcher.DispatchAsync(request, cancellation);

        return result switch
        {
            { IsSuccess: true } when result.Data is not null =>
                StatusCode(StatusCodes.Status200OK, result.Data),

            { IsFailure: true } when result.Error == CommonErrors.RateLimitExceeded =>
                StatusCode(StatusCodes.Status429TooManyRequests, result.Error),

            { IsFailure: true } when result.Error == CommonErrors.OperationFailed =>
                StatusCode(StatusCodes.Status500InternalServerError, result.Error),
        };
    }

    [HttpGet("callback/fail")]
    [AllowAnonymous]
    public async Task<IActionResult> OnCancelCallbackAsync(
        [FromQuery] CallbackFailedCheckoutParameters request, CancellationToken cancellation)
    {
        var result = await dispatcher.DispatchAsync(request, cancellation);

        return result switch
        {
            { IsSuccess: true } when result.Data is not null =>
                StatusCode(StatusCodes.Status200OK, result.Data),

            { IsFailure: true } when result.Error == CommonErrors.RateLimitExceeded =>
                StatusCode(StatusCodes.Status429TooManyRequests, result.Error),

            { IsFailure: true } when result.Error == CommonErrors.OperationFailed =>
                StatusCode(StatusCodes.Status500InternalServerError, result.Error),
        };
    }
}