store the eventId on the step

Author: ianmacartney

example/convex/_generated/api.d.ts

@@ -109,6 +109,7 @@ export declare const components: {
                   args: { eventId?: string };
                   argsSize: number;
                   completedAt?: number;
+                  eventId?: string;
                   inProgress: boolean;
                   kind: "event";
                   name: string;
@@ -173,6 +174,7 @@ export declare const components: {
                   args: { eventId?: string };
                   argsSize: number;
                   completedAt?: number;
+                  eventId?: string;
                   inProgress: boolean;
                   kind: "event";
                   name: string;
@@ -220,6 +222,7 @@ export declare const components: {
                 args: { eventId?: string };
                 argsSize: number;
                 completedAt?: number;
+                eventId?: string;
                 inProgress: boolean;
                 kind: "event";
                 name: string;
@@ -303,6 +306,7 @@ export declare const components: {
                   args: { eventId?: string };
                   argsSize: number;
                   completedAt?: number;
+                  eventId?: string;
                   inProgress: boolean;
                   kind: "event";
                   name: string;

src/component/_generated/api.d.ts

@@ -103,6 +103,7 @@ export type Mounts = {
                 args: { eventId?: string };
                 argsSize: number;
                 completedAt?: number;
+                eventId?: string;
                 inProgress: boolean;
                 kind: "event";
                 name: string;
@@ -167,6 +168,7 @@ export type Mounts = {
                 args: { eventId?: string };
                 argsSize: number;
                 completedAt?: number;
+                eventId?: string;
                 inProgress: boolean;
                 kind: "event";
                 name: string;
@@ -214,6 +216,7 @@ export type Mounts = {
               args: { eventId?: string };
               argsSize: number;
               completedAt?: number;
+              eventId?: string;
               inProgress: boolean;
               kind: "event";
               name: string;
@@ -297,6 +300,7 @@ export type Mounts = {
                 args: { eventId?: string };
                 argsSize: number;
                 completedAt?: number;
+                eventId?: string;
                 inProgress: boolean;
                 kind: "event";
                 name: string;

src/component/event.ts

@@ -56,7 +56,8 @@ export async function awaitEvent(
       break;
     }
   }
-  entry.step.args = { eventId: event._id };
+  assert(entry.step.kind === "event", "Step is not an event");
+  entry.step.eventId = event._id;
   await ctx.db.replace(entry._id, entry);
   // if there's a name, see if there's one to consume.
   // if it's there, mark it consumed and swap in the result.
@@ -142,7 +143,8 @@ export const send = mutation({
           step,
           `Entry ${event.state.stepId} not found when sending event ${event._id} (${name}) in workflow ${args.workflowId}`,
         );
-        step.step.args = { eventId: event._id };
+        assert(step.step.kind === "event", "Step is not an event");
+        step.step.eventId = event._id;
         step.step.runResult = args.result;
         step.step.inProgress = false;
         step.step.completedAt = Date.now();

src/component/schema.ts

@@ -80,6 +80,7 @@ export const step = v.union(
   v.object({
     kind: v.literal("event"),
     ...stepCommonFields,
+    eventId: v.optional(v.id("events")),
     args: v.object({ eventId: v.optional(v.id("events")) }),
   }),
 );