feat(webhooks): add webhook workflows

examples/simple-worker.e2e.ts

@@ -16,7 +16,7 @@ describe('e2e', () => {
     await sleep(2000);
   });
 
-  it('should pass a simple workflow', async () => {
+  xit('should pass a simple workflow', async () => {
     let invoked = 0;
     const start = new Date();
 

examples/webhooks.e2e.ts

@@ -0,0 +1,86 @@
+import { createServer } from 'node:http';
+import { Workflow, Worker } from '../src';
+import sleep from '../src/util/sleep';
+import Hatchet from '../src/sdk';
+
+const port = 8369;
+
+describe('e2e', () => {
+  let hatchet: Hatchet;
+  let worker: Worker;
+
+  beforeEach(async () => {
+    hatchet = Hatchet.init();
+    worker = await hatchet.worker('simple-webhook-workflow');
+  });
+
+  afterEach(async () => {
+    await worker.stop();
+    await sleep(2000);
+  });
+
+  it('should pass a simple workflow', async () => {
+    let invoked = 0;
+
+    const workflow: Workflow = {
+      id: 'simple-webhook-workflow',
+      webhook: `http://localhost:${port}/webhook`,
+      description: 'test',
+      on: {
+        event: 'user:create-webhook',
+      },
+      steps: [
+        {
+          name: 'step1',
+          run: async (ctx) => {
+            console.log('invoked!! ✅✅✅✅✅✅✅');
+            console.log('invoked!! ✅✅✅✅✅✅✅');
+            console.log('invoked!! ✅✅✅✅✅✅✅');
+            console.log('invoked!! ✅✅✅✅✅✅✅');
+            console.log('invoked!! ✅✅✅✅✅✅✅');
+            invoked += 1;
+            return { message: `${ctx.workflowName()} results!` };
+          },
+        },
+        {
+          name: 'step2',
+          parents: ['step1'],
+          run: (ctx) => {
+            invoked += 1;
+            return { message: `${ctx.workflowName()} results!` };
+          },
+        },
+      ],
+    };
+
+    console.log('registering workflow...');
+    await worker.registerWorkflow(workflow);
+
+    const secret = 'secret';
+    const server = createServer(await worker.handler(secret));
+
+    await new Promise((resolve) => {
+      server.listen(port, () => {
+        resolve('');
+      });
+    });
+
+    console.log('worker started.');
+
+    await sleep(5000);
+
+    console.log('pushing event...');
+
+    await hatchet.event.push('user:create-webhook', {
+      test: 'test',
+    });
+
+    await sleep(10000);
+
+    console.log('invoked', invoked);
+
+    expect(invoked).toEqual(2);
+
+    await worker.stop();
+  }, 60000);
+});

src/clients/dispatcher/action-listener.ts

@@ -6,6 +6,7 @@ import sleep from '@util/sleep';
 import HatchetError from '@util/errors/hatchet-error';
 import { Logger } from '@hatchet/util/logger';
 
+import { z } from 'zod';
 import { DispatcherClient } from './dispatcher-client';
 import { Heartbeat } from './heartbeat/heartbeat-controller';
 
@@ -18,20 +19,22 @@ enum ListenStrategy {
   LISTEN_STRATEGY_V2 = 2,
 }
 
-export interface Action {
-  tenantId: string;
-  jobId: string;
-  jobName: string;
-  jobRunId: string;
-  stepId: string;
-  stepRunId: string;
-  actionId: string;
-  actionType: number;
-  actionPayload: string;
-  workflowRunId: string;
-  getGroupKeyRunId: string;
-  stepName: string;
-}
+export const ActionObject = z.object({
+  tenantId: z.string(),
+  jobId: z.string(),
+  jobName: z.string(),
+  jobRunId: z.string(),
+  stepId: z.string(),
+  stepRunId: z.string(),
+  actionId: z.string(),
+  actionType: z.number().optional(),
+  actionPayload: z.string(),
+  workflowRunId: z.string(),
+  getGroupKeyRunId: z.string().optional(),
+  stepName: z.string(),
+});
+
+export type Action = z.infer<typeof ActionObject>;
 
 export class ActionListener {
   config: ClientConfig;