Class EventTrigger

packages/trigger-sdk/src/triggers/eventTrigger.ts:23–64

};

export class EventTrigger<TEventSpecification extends EventSpecification<any>>
  implements Trigger<TEventSpecification>
{
  #options: EventTriggerOptions<TEventSpecification>;

  constructor(options: EventTriggerOptions<TEventSpecification>) {
    this.#options = options;
  }

  toJSON(): TriggerMetadata {
    return {
      type: "static",
      title: this.#options.name ?? this.#options.event.title,
      rule: {
        event: this.#options.name ?? this.#options.event.name,
        source: this.#options.source ?? "trigger.dev",
        payload: deepMergeFilters(this.#options.filter ?? {}, this.#options.event.filter ?? {}),
      },
    };
  }

  get event() {
    return this.#options.event;
  }

  attachToJob(triggerClient: TriggerClient, job: Job<Trigger<TEventSpecification>, any>): void {}

  get preprocessRuns() {
    return false;
  }

  async verifyPayload(payload: ReturnType<TEventSpecification["parsePayload"]>) {
    if (this.#options.verify) {
      if ((payload as any) instanceof Request) {
        const clonedRequest = (payload as Request).clone();
        return this.#options.verify(clonedRequest);
      }
    }

    return { success: true as const };
  }
}

/** Configuration options for an EventTrigger */
type TriggerOptions<TEvent> = {