Method waitForEvent

packages/trigger-sdk/src/io.ts:373–437

(
    cacheKey: string | any[],
    event: {
      name: string;
      schema?: T;
      filter?: EventFilter;
      source?: string;
      contextFilter?: EventFilter;
      accountId?: string;
    },
    options?: { timeoutInSeconds?: number }
  )

  }

  async waitForEvent<T extends z.ZodTypeAny = z.ZodTypeAny>(
    cacheKey: string | any[],
    event: {
      name: string;
      schema?: T;
      filter?: EventFilter;
      source?: string;
      contextFilter?: EventFilter;
      accountId?: string;
    },
    options?: { timeoutInSeconds?: number }
  ): Promise<WaitForEventResult<z.output<T>>> {
    const timeoutInSeconds = options?.timeoutInSeconds ?? 60 * 60;

    return (await this.runTask(
      cacheKey,
      async (task, io) => {
        if (!task.callbackUrl) {
          throw new Error("No callbackUrl found on task");
        }

        await this.triggerClient.createEphemeralEventDispatcher({
          url: task.callbackUrl,
          name: event.name,
          filter: event.filter,
          contextFilter: event.contextFilter,
          source: event.source,
          accountId: event.accountId,
          timeoutInSeconds,
        });

        return {} as Promise<{}>;
      },
      {
        name: "Wait for Event",
        icon: "custom-event",
        params: {
          name: event.name,
          source: event.source,
          filter: event.filter,
          contextFilter: event.contextFilter,
          accountId: event.accountId,
        },
        callback: {
          enabled: true,
          timeoutInSeconds,
        },
        properties: [
          {
            label: "Event",
            text: event.name,
          },
          {
            label: "Timeout",
            text: `${timeoutInSeconds}s`,
          },
          ...(event.source ? [{ label: "Source", text: event.source }] : []),
          ...(event.accountId ? [{ label: "Account ID", text: event.accountId }] : []),