Function mockSendEvent

packages/testing/src/index.ts:128–159

(client: TriggerClient)

    } & Record<string, any>
  > => {
    const mockSendEvent = (client: TriggerClient) =>
      vi
        .spyOn(client, "sendEvent")
        .mockImplementation(
          async (unparsedEvent: SendEvent, unparsedOptions: SendEventOptions = {}) => {
            const body = SendEventBodySchema.parse({
              event: unparsedEvent,
              options: unparsedOptions,
            });
            const { event, options } = body;

            const timestamp = new Date();
            const deliverAt =
              options?.deliverAt ||
              (options?.deliverAfter
                ? new Date(Date.now() + options.deliverAfter * 1000)
                : undefined);

            const eventLog = {
              id: event.id,
              name: event.name,
              payload: event.payload ?? {},
              context: event.context,
              timestamp,
              deliverAt,
              deliveredAt: !deliverAt ? timestamp : undefined,
              cancelledAt: undefined,
            };

            return eventLog;
          }
        );

    const { client, trigger } = job;