Function eventTrigger

packages/trigger-sdk/src/triggers/eventTrigger.ts:103–131

(
  options: TriggerOptions<TEvent>
)

 * @param options options for the EventTrigger
 */
export function eventTrigger<TEvent extends any = any>(
  options: TriggerOptions<TEvent>
): Trigger<EventSpecification<TEvent>> {
  return new EventTrigger({
    name: options.name,
    filter: options.filter,
    source: options.source,
    event: {
      name: options.name,
      title: "Event",
      source: options.source ?? "trigger.dev",
      icon: "custom-event",
      examples: options.examples,
      parsePayload: (rawPayload: any) => {
        if (options.schema) {
          const results = options.schema.safeParse(rawPayload);

          if (!results.success) {
            throw new ParsedPayloadSchemaError(formatSchemaErrors(results.error.issues));
          }

          return results.data;
        }

        return rawPayload as any;
      },
    },
  });
}