Webhooks

export declare function emailWebhook(config: EmailWebhookConfig): WebhookDestination;

export interface EmailWebhookConfig {
    transport: "sendgrid";
    apiKey: string;
    to: string[];
    from: string;
    subject?: string | ((event: string) => string);
}

export declare function httpWebhook(config: HttpWebhookConfig): WebhookDestination;

export interface HttpWebhookConfig {
    url: string;
    headers?: Record<string, string>;
    method?: "POST" | "PUT";
    secret?: string;
}

export declare function slackWebhook(config: SlackWebhookConfig): WebhookDestination;

export interface SlackWebhookConfig {
    webhookUrl: string;
    channel?: string;
    formatMessage?: (event: string, payload: unknown) => string;
}

export interface WebhookConfig {
    destinations: WebhookDestination[];
    events?: string[];
    batchInterval?: number;
    retries?: number;
    onError?: "log" | "throw";
}

export interface WebhookDestination {
    name: string;
    send(event: string, payload: unknown): Promise<void>;
}

export declare class WebhookManager {
    constructor(config: WebhookConfig);
    attach(eventBus: EventBus): void;
    detach(eventBus: EventBus): void;
    flush(): Promise<void>;
}