automatically register workflows

examples/webhooks.e2e.ts

@@ -56,7 +56,6 @@ describe('webhooks', () => {
     await worker.registerWebhook({
       secret,
       url: `http://localhost:${port}/webhook`,
-      workflows: ['simple-webhook-workflow'],
     });
 
     console.log('starting worker...');

src/clients/rest/generated/data-contracts.ts

@@ -1026,8 +1026,8 @@ export interface WebhookWorker {
 export interface WebhookWorkerCreateRequest {
   /** The webhook url. */
   url: string;
-  /** The workflow IDs or names to register for this webhook worker. */
-  workflows: string[];
+  /** The workflow IDs or names to register for this webhook worker. If not provided, workflows will be automatically detected. */
+  workflows?: string[];
   /**
    * The secret key for validation. If not provided, a random secret will be generated.
    * @minLength 32

src/clients/worker/worker.ts

@@ -39,6 +39,7 @@ export class Worker {
   logger: Logger;
 
   registeredWorkflowPromises: Array<Promise<any>> = [];
+  registeredWorkflowIds: string[] = [];
 
   constructor(
     client: HatchetClient,
@@ -98,7 +99,7 @@ export class Worker {
   }
 
   async registerWebhook(webhook: WebhookWorkerCreateRequest) {
-    return this.client.admin.webhook_create(webhook);
+    return this.client.admin.webhook_create({ ...webhook, workflows: this.registeredWorkflowIds });
   }
 
   // @deprecated
@@ -140,6 +141,8 @@ export class Worker {
           }
         : undefined;
 
+      this.registeredWorkflowIds.push(workflow.id);
+
       const registeredWorkflow = this.client.admin.put_workflow({
         name: workflow.id,
         description: workflow.description,