basalt / subscriptions-prisma/src / PrismaWebhookStore
Class: PrismaWebhookStore
Defined in: subscriptions-prisma/src/index.ts:210
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 PrismaWebhookStore(client, options?): PrismaWebhookStore
Defined in: subscriptions-prisma/src/index.ts:213
Parameters
client
options?
PrismaSubscriptionsStoreOptions = {}
Returns
PrismaWebhookStore
Methods
markProcessed()
> markProcessed(id): Promise<boolean>
Defined in: subscriptions-prisma/src/index.ts:220
Parameters
id
string
Returns
Promise<boolean>
Implementation of
release()
> release(id): Promise<void>
Defined in: subscriptions-prisma/src/index.ts:230
Parameters
id
string
Returns
Promise<void>