Build Paystack Subscriptions in ASP.NET Core

// Controllers/SubscriptionController.cs
[ApiController]
[Route("api/[controller]")]
public class SubscriptionController : ControllerBase
{
    private readonly HttpClient _paystackClient;

    public SubscriptionController(IHttpClientFactory factory)
    {
        _paystackClient = factory.CreateClient("Paystack");
    }

    [HttpPost("plans")]
    public async Task<IActionResult> CreatePlan([FromBody] CreatePlanRequest req)
    {
        var payload = new
        {
            name = req.Name,
            amount = req.AmountInKobo,
            interval = req.Interval,  // "monthly", "weekly", "annually", "daily"
            currency = req.Currency ?? "NGN"
        };

        var response = await _paystackClient.PostAsJsonAsync("plan", payload);
        var result = await response.Content.ReadFromJsonAsync<JsonElement>();

        if (!result.GetProperty("status").GetBoolean())
            return BadRequest(result.GetProperty("message").GetString());

        var data = result.GetProperty("data");
        return Ok(new
        {
            plan_code = data.GetProperty("plan_code").GetString(),
            name = data.GetProperty("name").GetString(),
            amount = data.GetProperty("amount").GetInt64()
        });
    }
}

public record CreatePlanRequest(string Name, long AmountInKobo, string Interval, string? Currency = null);

[HttpPost("subscribe")]
public async Task<IActionResult> Subscribe([FromBody] SubscribeRequest req)
{
    // Your plan code stored in config
    var planCode = "PLN_xxxxxxxxxxxx";

    var reference = $"sub_{DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()}_{Guid.NewGuid():N}"[..30];

    var payload = new
    {
        email = req.Email,
        plan = planCode,
        reference = reference,
        callback_url = "https://yourapp.com/subscription/callback"
    };

    var response = await _paystackClient.PostAsJsonAsync("transaction/initialize", payload);
    var result = await response.Content.ReadFromJsonAsync<JsonElement>();

    if (!result.GetProperty("status").GetBoolean())
        return BadRequest(result.GetProperty("message").GetString());

    var data = result.GetProperty("data");
    return Ok(new
    {
        authorization_url = data.GetProperty("authorization_url").GetString(),
        access_code = data.GetProperty("access_code").GetString(),
        reference = data.GetProperty("reference").GetString()
    });
}

public record SubscribeRequest(string Email);

// In WebhookController.cs ProcessEventAsync
case "subscription.create":
{
    var subCode = data.GetProperty("subscription_code").GetString();
    var emailToken = data.GetProperty("email_token").GetString();
    var customerEmail = data.GetProperty("customer").GetProperty("email").GetString();

    _logger.LogInformation("New subscription: {SubCode} for {Email}", subCode, customerEmail);
    // Activate the customer's plan in database
    // Store subCode and emailToken for future cancellation
    break;
}
case "charge.success":
{
    // Check if this is a subscription renewal
    if (data.TryGetProperty("plan", out var plan) &&
        plan.ValueKind != JsonValueKind.Null)
    {
        var subRef = data.GetProperty("reference").GetString();
        var amount = data.GetProperty("amount").GetInt64();
        _logger.LogInformation("Subscription renewal: {Ref}, {Amount}", subRef, amount / 100m);
        // Extend subscription period in database
    }
    break;
}
case "invoice.payment_failed":
{
    var subInfo = data.GetProperty("subscription");
    var subCode = subInfo.GetProperty("subscription_code").GetString();
    _logger.LogWarning("Renewal failed for subscription: {SubCode}", subCode);
    // Pause access, send payment failure email
    break;
}
case "subscription.disable":
{
    var subCode = data.GetProperty("subscription_code").GetString();
    _logger.LogInformation("Subscription cancelled: {SubCode}", subCode);
    // Deactivate plan, do not delete — keep for audit
    break;
}

[HttpPost("cancel")]
public async Task<IActionResult> Cancel([FromBody] CancelRequest req)
{
    var payload = new { code = req.SubscriptionCode, token = req.EmailToken };
    var response = await _paystackClient.PostAsJsonAsync("subscription/disable", payload);
    var result = await response.Content.ReadFromJsonAsync<JsonElement>();

    if (!result.GetProperty("status").GetBoolean())
        return BadRequest(result.GetProperty("message").GetString());

    return Ok(new { cancelled = true });
}

public record CancelRequest(string SubscriptionCode, string EmailToken);

This guide is part of the Paystack integration guides by language and framework series.

Sign up for the McTaba newsletter