basalt / subscriptions-sqlite/src / SqliteWebhookStore
Class: SqliteWebhookStore
Defined in: subscriptions-sqlite/src/index.ts:201
Deduplicates webhook processing across restarts and instances. markProcessed claims an event id (true = new, process it; false = already seen, skip); release frees the claim so a failed apply can be retried by the gateway.
Implements
Constructors
Constructor
> new SqliteWebhookStore(db): SqliteWebhookStore
Defined in: subscriptions-sqlite/src/index.ts:202
Parameters
db
DatabaseSync
Returns
SqliteWebhookStore
Methods
markProcessed()
> markProcessed(id): Promise<boolean>
Defined in: subscriptions-sqlite/src/index.ts:204
Parameters
id
string
Returns
Promise<boolean>
Implementation of
release()
> release(id): Promise<void>
Defined in: subscriptions-sqlite/src/index.ts:212
Parameters
id
string
Returns
Promise<void>