Router helpers for mounting Accrue webhook endpoints.

Usage (Phoenix router)

import Accrue.Router

pipeline :accrue_webhook_raw_body do
  plug Plug.Parsers,
    parsers: [:json],
    pass: ["*/*"],
    json_decoder: Jason,
    body_reader: {Accrue.Webhook.CachingBodyReader, :read_body, []},
    length: 1_000_000
end

scope "/webhooks" do
  pipe_through :accrue_webhook_raw_body
  accrue_webhook "/stripe", :stripe
end

Apple App Store Server Notifications V2 use a dedicated route-scoped body reader whose parser limit matches the notification plug's 256 KiB default:

pipeline :accrue_apple_notifications_raw_body do
  plug Plug.Parsers,
    parsers: [:json],
    pass: ["*/*"],
    json_decoder: Jason,
    body_reader: {Accrue.Webhook.CachingBodyReader, :read_body, []},
    length: 262_144
end

scope "/webhooks" do
  pipe_through :accrue_apple_notifications_raw_body
  accrue_apple_notifications "/apple", verifier_config: apple_verifier_config,
    rate_limiter: &MyApp.AppleRateLimiter.check/1
end

Multi-endpoint (Phase 4 Connect ready, D2-18)

The macro accepts a processor atom. Calling accrue_webhook/2 multiple times with different processors works natively:

scope "/webhooks" do
  pipe_through :accrue_webhook_raw_body
  accrue_webhook "/stripe", :stripe
  accrue_webhook "/connect", :stripe_connect
end

Each resolves to its own signing secret via Accrue.Config.

Entitlement guards (controller pipeline)

require_feature/1 and require_plan/1 are single-arg sugar over Accrue.Plug.RequireEntitlement for the common "gate one feature / plan" case in a controller's plug pipeline:

import Accrue.Router

defmodule MyAppWeb.ReportsController do
  use MyAppWeb, :controller

  require_feature :reports      # plug Accrue.Plug.RequireEntitlement, feature: :reports
  require_plan :pro             # plug Accrue.Plug.RequireEntitlement, plan: :pro
  # ... actions
end

For advanced overrides (status:, on_deny:, billable:) use the explicit plug form directly:

plug Accrue.Plug.RequireEntitlement, feature: :reports, on_deny: {:redirect, "/pricing"}