AshHooks.InboundDelivery

Turns the consumer's resource into the inbound webhook ledger — the durable, fenced dedup substrate of the inbound pipeline (ADR-0003).

Attach next to the consumer's own data layer:

use Ash.Resource,
  data_layer: AshSqlite.DataLayer,
  extensions: [AshHooks, AshHooks.InboundDelivery]

inbound_delivery do
  scope_identity([:account_id])
end

The extension injects the ledger fields (provider, external ids, payload + digest, the fenced state machine's status/token/lease/attempts), the unique_ingest identity spanning provider + external event id + the declared scope slots, and the fenced action primitives (:ingest, :claim, :mark_processed, :mark_failed, :renew).

The uniqueness identity must be backed by a REAL unique index on the consumer's data layer — storage-level uniqueness is the idempotency primitive, and the fenced machine's crash-safety rests on it. Scope slots must be non-nullable attributes: a nullable slot would make nil scope values distinct on SQL unique indexes and silently break dedup for scope-less redeliveries.

The injected actions are PRIMITIVES, not fences: the conditional gates (claim only from :received or an expired lease; mark/renew only by the current token under an unexpired lease) live in the query filters that AshHooks.Ingress builds — the WHERE clause is the portable fence (probe 2026-08-21: error()-in-expression atomics are inexpressible on sqlite, and action-level change filter(...) is silently dropped on the atomic path).

inbound_delivery

Configuration of this resource as the inbound webhook ledger.

Options