import type { KafkaProducer } from "./kafka.js"; /** * The event schema for webhook events. * See more: https://github.com/thirdweb-dev/api-server/blob/dev/docs/webhooks.md */ interface WebhookEvent extends Record { id?: `evt_${string}`; teamId: string; projectId?: string; /** * The timestamp your event was triggered at. */ createdAt?: Date; /** * Your model defined in api-server. */ data: Record; } /** * Creates a producer for webhook events. * * Example: * ```ts * const kafkaProducer = new KafkaProducer({...}); * const webhookProducer = new WebhookEventProducer({ kafkaProducer }); * await webhookProducer.sendEvents("your.topic.name", events); * ``` */ export declare class WebhookEventProducer { private kafkaProducer; constructor(config: { kafkaProducer: KafkaProducer; }); /** * Emit a webhook event. * This method may throw. To call this non-blocking: * ```ts * void webhookProducer.sendEvents(events).catch((e) => console.error(e)) * ``` */ sendEvents(topic: string, events: WebhookEvent[]): Promise; } export {}; //# sourceMappingURL=webhookProducer.d.ts.map