eventTrigger()

eventTrigger() is set as a Job’s trigger to subscribe to an event a Job from a sent event.

There are two way to send an event that will trigger eventTrigger():

1. Use client.sendEvent() from anywhere in your codebase.
2. Use io.sendEvent() from inside a Job's run() function.

You can have multiple Jobs that subscribe to the same event, they will all trigger when the event gets delivered.

Parameters

options · object · required

Hide options

name · string · required

The name of the event you are subscribing to. Must be an exact match (case sensitive).

schema · object

A Zod schema that defines the shape of the event payload. The default is z.any() which is any.

source · string

You can use this to filter events based on the source.

filter · object

Used to filter which events trigger the Job.

An example:

{
  name: ["John", "Jane"],
  age: [18, 21]
}

This filter would match against an event with the following data:

{
  "name": "Jane",
  "age": 18,
  "location": "San Francisco"
}

examples · array

Used to provide example payloads that are accepted by the job.

This will be available in the dashboard and can be used to trigger test runs.

Hide example object properties

id · string · required

The example’s ID.

name · string · required

The name that’s displayed in the dashboard.

payload · object · required

The payload that’s accepted by the job.

icon · string

The icon to use for this example in the dashboard.

eventTrigger()

//this Job subscribes to an event called new.user
client.defineJob({
  id: "job-2",
  name: "Second job",
  version: "0.0.1",
  //subscribes to the "new.user" event
  trigger: eventTrigger({
    //sent events with this name will trigger this Job
    name: "new.user",
    //the expected payload shape
    schema: z.object({
      userId: z.string(),
      tier: z.union([z.literal("free"), z.literal("pro")]),
    }),
    //only events with the tier: "pro" will trigger this Job
    filter: {
      tier: ["pro"],
    },
    //(optional) example event object
    examples: [
      {
        id: "issue.opened",
        name: "Issue opened",
        payload: {
          userId: "1234",
          tier: "free",
        },
        //optional
        icon: "github",
      },
    ],
  }),
  run: async (payload, io, ctx) => {
    await io.logger.log("New pro user created", { userId: payload.userId });
    //do stuff
  },
});