Add interrupt to workflow proxy and server

.changeset/chubby-keys-decide.md

@@ -0,0 +1,5 @@
+---
+"@effect/workflow": minor
+---
+
+Expose interrupt method to proxy

packages/workflow/src/WorkflowProxy.ts

@@ -64,7 +64,10 @@ export const toRpcGroup = <
         payload: workflow.payloadSchema
       }).annotateContext(workflow.annotations),
       Rpc.make(`${prefix}${workflow.name}Resume`, { payload: ResumePayload })
-        .annotateContext(workflow.annotations)
+        .annotateContext(workflow.annotations),
+      Rpc.make(`${prefix}${workflow.name}Interrupt`, {
+        payload: InterruptPayload
+      }).annotateContext(workflow.annotations)
     )
   }
   return RpcGroup.make(...rpcs) as any
@@ -82,6 +85,7 @@ export type ConvertRpcs<Workflows extends Workflow.Any, Prefix extends string> =
     | Rpc.Rpc<`${Prefix}${_Name}`, _Payload, _Success, _Error>
     | Rpc.Rpc<`${Prefix}${_Name}Discard`, _Payload>
     | Rpc.Rpc<`${Prefix}${_Name}Resume`, typeof ResumePayload>
+    | Rpc.Rpc<`${Prefix}${_Name}Interrupt`, typeof InterruptPayload>
   : never
 
 /**
@@ -140,6 +144,10 @@ export const toHttpApiGroup = <const Name extends string, const Workflows extend
       HttpApiEndpoint.post(workflow.name + "Resume", `${path}/resume`)
         .setPayload(ResumePayload)
         .annotateContext(workflow.annotations)
+    ).add(
+      HttpApiEndpoint.post(workflow.name + "Interrupt", `${path}/interrupt`)
+        .setPayload(InterruptPayload)
+        .annotateContext(workflow.annotations)
     ) as any
   }
   return group as any
@@ -193,7 +201,20 @@ export type ConvertHttpApi<Workflows extends Workflow.Any> = Workflows extends W
       void,
       never,
       typeof ResumePayload.Context
+    >
+    | HttpApiEndpoint.HttpApiEndpoint<
+      `${_Name}Interrupt`,
+      "POST",
+      never,
+      never,
+      typeof InterruptPayload.Type,
+      never,
+      void,
+      never,
+      typeof InterruptPayload.Context
     > :
   never
 
 const ResumePayload = Schema.Struct({ executionId: Schema.String })
+
+const InterruptPayload = Schema.Struct({ executionId: Schema.String })

packages/workflow/src/WorkflowProxyServer.ts

@@ -73,6 +73,17 @@ export const layerHttpApi = <
                 })
               )
           )
+          .handle(
+            workflow.name + "Interrupt" as any,
+            ({ payload }: { payload: any }) =>
+              workflow.interrupt(payload.executionId).pipe(
+                Effect.tapDefect(Effect.logError),
+                Effect.annotateLogs({
+                  module: "WorkflowProxyServer",
+                  method: workflow.name + "Interrupt"
+                })
+              )
+          )
       }
       return handlers as HttpApiBuilder.Handlers<never, never, never>
     })
@@ -101,9 +112,11 @@ export const layerRpcHandlers = <
       const tag = `${prefix}${workflow.name}`
       const tagDiscard = `${tag}Discard`
       const tagResume = `${tag}Resume`
+      const tagInterrupt = `${tag}Interrupt`
       const key = `@effect/rpc/Rpc/${tag}`
       const keyDiscard = `${key}Discard`
       const keyResume = `${key}Resume`
+      const keyInterrupt = `${key}Interrupt`
       handlers.set(key, {
         context,
         tag,
@@ -119,6 +132,11 @@ export const layerRpcHandlers = <
         tag: tagResume,
         handler: (payload: any) => workflow.resume(payload.executionId) as any
       } as any)
+      handlers.set(keyInterrupt, {
+        context,
+        tag: tagInterrupt,
+        handler: (payload: any) => workflow.interrupt(payload.executionId) as any
+      } as any)
     }
     return Context.unsafeMake(handlers)
   }))
@@ -131,5 +149,9 @@ export type RpcHandlers<Workflows extends Workflow.Any, Prefix extends string> =
   infer _Payload,
   infer _Success,
   infer _Error
-> ? Rpc.Handler<`${Prefix}${_Name}`> | Rpc.Handler<`${Prefix}${_Name}Discard`> | Rpc.Handler<`${Prefix}${_Name}Resume`>
+> ?
+    | Rpc.Handler<`${Prefix}${_Name}`>
+    | Rpc.Handler<`${Prefix}${_Name}Discard`>
+    | Rpc.Handler<`${Prefix}${_Name}Resume`>
+    | Rpc.Handler<`${Prefix}${_Name}Interrupt`>
   : never