Commit 431c7de

committed

store the eventId on the step

1 parent 126f1ac commit 431c7deCopy full SHA for 431c7de

File tree

+13

-2

lines changed

+13

-2

lines changed

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -109,6 +109,7 @@ export declare const components: {`
`109`	`109`	`args: { eventId?: string };`
`110`	`110`	`argsSize: number;`
`111`	`111`	`completedAt?: number;`
	`112`	`+ eventId?: string;`
`112`	`113`	`inProgress: boolean;`
`113`	`114`	`kind: "event";`
`114`	`115`	`name: string;`
`@@ -173,6 +174,7 @@ export declare const components: {`
`173`	`174`	`args: { eventId?: string };`
`174`	`175`	`argsSize: number;`
`175`	`176`	`completedAt?: number;`
	`177`	`+ eventId?: string;`
`176`	`178`	`inProgress: boolean;`
`177`	`179`	`kind: "event";`
`178`	`180`	`name: string;`
`@@ -220,6 +222,7 @@ export declare const components: {`
`220`	`222`	`args: { eventId?: string };`
`221`	`223`	`argsSize: number;`
`222`	`224`	`completedAt?: number;`
	`225`	`+ eventId?: string;`
`223`	`226`	`inProgress: boolean;`
`224`	`227`	`kind: "event";`
`225`	`228`	`name: string;`
`@@ -303,6 +306,7 @@ export declare const components: {`
`303`	`306`	`args: { eventId?: string };`
`304`	`307`	`argsSize: number;`
`305`	`308`	`completedAt?: number;`
	`309`	`+ eventId?: string;`
`306`	`310`	`inProgress: boolean;`
`307`	`311`	`kind: "event";`
`308`	`312`	`name: string;`

Lines changed: 4 additions & 0 deletions

Lines changed: 4 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -56,7 +56,8 @@ export async function awaitEvent(`
`56`	`56`	`break;`
`57`	`57`	`}`
`58`	`58`	`}`
`59`		`- entry.step.args = { eventId: event._id };`
	`59`	`+ assert(entry.step.kind === "event", "Step is not an event");`
	`60`	`+ entry.step.eventId = event._id;`
`60`	`61`	`await ctx.db.replace(entry._id, entry);`
`61`	`62`	`// if there's a name, see if there's one to consume.`
`62`	`63`	`// if it's there, mark it consumed and swap in the result.`
`@@ -142,7 +143,8 @@ export const send = mutation({`
`142`	`143`	`step,`
`143`	`144`	`Entry ${event.state.stepId} not found when sending event ${event._id} (${name}) in workflow ${args.workflowId}`,
`144`	`145`	`);`
`145`		`- step.step.args = { eventId: event._id };`
	`146`	`+ assert(step.step.kind === "event", "Step is not an event");`
	`147`	`+ step.step.eventId = event._id;`
`146`	`148`	`step.step.runResult = args.result;`
`147`	`149`	`step.step.inProgress = false;`
`148`	`150`	`step.step.completedAt = Date.now();`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -80,6 +80,7 @@ export const step = v.union(`
`80`	`80`	`v.object({`
`81`	`81`	`kind: v.literal("event"),`
`82`	`82`	`...stepCommonFields,`
	`83`	`+ eventId: v.optional(v.id("events")),`
`83`	`84`	`args: v.object({ eventId: v.optional(v.id("events")) }),`
`84`	`85`	`}),`
`85`	`86`	`);`

Comments

(0)