diff --git a/references/job-catalog/src/events.ts b/references/job-catalog/src/events.ts index 1b05383a6..fda96b446 100644 --- a/references/job-catalog/src/events.ts +++ b/references/job-catalog/src/events.ts @@ -153,4 +153,35 @@ client.defineJob({ }, }); +client.defineJob({ + id: "batch-trigger-receive", + name: "Batch Trigger Receive", + version: "1.0.0", + trigger: eventTrigger({ + name: "batch.trigger", + batch: { + maxPayloads: 5, + }, + }), + run: async (payload) => { + return Array.isArray(payload) ? payload.length : "Not an array"; + }, +}); + +client.defineJob({ + id: "batch-trigger-send", + name: "Batch Trigger Send", + version: "1.0.0", + trigger: eventTrigger({ + name: "batch.trigger.send", + }), + run: async (payload, io) => { + for (let i = 0; i < 10; i++) { + await io.sendEvent(`send-${i}`, { + name: "batch.trigger", + }); + } + }, +}); + createExpressServer(client);