Class WebhookSource

packages/trigger-sdk/src/triggers/webhook.ts:153–247

};

export class WebhookSource<
  TIntegration extends TriggerIntegration,
  TParams extends any = any,
  TConfig extends Record<string, string[]> = Record<string, string[]>,
> {
  constructor(private options: WebhookOptions<TIntegration, TParams, TConfig>) {}

  async generateEvents(request: Request, client: TriggerClient, ctx: WebhookDeliveryContext) {
    return this.options.generateEvents({
      request,
      client,
      ctx,
    });
  }

  filter(params: TParams, config?: TConfig): EventFilter {
    return this.options.filter?.(params, config) ?? {};
  }

  properties(params: TParams): DisplayProperty[] {
    return this.options.properties?.(params) ?? [];
  }

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

  async register(
    params: TParams,
    registerEvent: WebhookRegisterEvent<TConfig>,
    io: IO,
    ctx: TriggerContext
  ) {
    if (!this.options.register) {
      return;
    }

    const updates = await this.options.register(
      {
        ...registerEvent,
        params,
      },
      io as IOWithIntegrations<{ integration: TIntegration }>,
      ctx
    );

    return updates;
  }

  async verify(
    request: Request,
    client: TriggerClient,
    ctx: WebhookDeliveryContext
  ): Promise<VerifyResult> {
    if (this.options.verify) {
      const clonedRequest = request.clone();
      return this.options.verify({ request: clonedRequest, client, ctx });
    }