Class WebhookEventCatalog

integrations/shopify/src/triggers.ts:180–205

};

export class WebhookEventCatalog<
  TEvents extends Record<string, EventSpecification<any, any>>,
  TSource extends WebhookSource<any>,
> {
  constructor(private options: WebhookCatalogOptions<TEvents, TSource>) {}

  get events() {
    return this.options.events;
  }

  get source() {
    return this.options.source;
  }

  on<TName extends keyof TEvents, TParams extends GetWebhookParams<TSource>>(
    name: TName,
    params: TParams
  ): WebhookTrigger<TEvents[TName], TSource> {
    return new WebhookTrigger({
      event: this.events[name],
      params,
      source: this.source,
      config: {},
    });
  }
}

export function createWebhookEventCatalog(source: ReturnType<typeof createWebhookEventSource>) {
  return new WebhookEventCatalog({