[SLOP(claude-opus-4-8-high)] feat(workflow-engine): add getVersion primitive for workflow versioning

Author: abcxff

frontend/src/components/actors/workflow/transform-workflow-history.ts

@@ -521,6 +521,28 @@ export function writeWorkflowRemovedEntry(
 	write1(bc, x.originalName);
 }
 
+export type WorkflowVersionCheckEntry = {
+	readonly resolved: u32;
+	readonly latest: u32;
+};
+
+export function readWorkflowVersionCheckEntry(
+	bc: bare.ByteCursor,
+): WorkflowVersionCheckEntry {
+	return {
+		resolved: bare.readU32(bc),
+		latest: bare.readU32(bc),
+	};
+}
+
+export function writeWorkflowVersionCheckEntry(
+	bc: bare.ByteCursor,
+	x: WorkflowVersionCheckEntry,
+): void {
+	bare.writeU32(bc, x.resolved);
+	bare.writeU32(bc, x.latest);
+}
+
 export type WorkflowEntryKind =
 	| { readonly tag: "WorkflowStepEntry"; readonly val: WorkflowStepEntry }
 	| { readonly tag: "WorkflowLoopEntry"; readonly val: WorkflowLoopEntry }
@@ -538,6 +560,10 @@ export type WorkflowEntryKind =
 	| {
 			readonly tag: "WorkflowRemovedEntry";
 			readonly val: WorkflowRemovedEntry;
+	  }
+	| {
+			readonly tag: "WorkflowVersionCheckEntry";
+			readonly val: WorkflowVersionCheckEntry;
 	  };
 
 export function readWorkflowEntryKind(bc: bare.ByteCursor): WorkflowEntryKind {
@@ -572,6 +598,11 @@ export function readWorkflowEntryKind(bc: bare.ByteCursor): WorkflowEntryKind {
 				tag: "WorkflowRemovedEntry",
 				val: readWorkflowRemovedEntry(bc),
 			};
+		case 8:
+			return {
+				tag: "WorkflowVersionCheckEntry",
+				val: readWorkflowVersionCheckEntry(bc),
+			};
 		default: {
 			bc.offset = offset;
 			throw new bare.BareError(offset, "invalid tag");
@@ -624,6 +655,11 @@ export function writeWorkflowEntryKind(
 			writeWorkflowRemovedEntry(bc, x.val);
 			break;
 		}
+		case "WorkflowVersionCheckEntry": {
+			bare.writeU8(bc, 8);
+			writeWorkflowVersionCheckEntry(bc, x.val);
+			break;
+		}
 	}
 }
 

frontend/src/components/actors/workflow/workflow-types.ts

@@ -907,6 +907,10 @@ function serializeWorkflowEntryKind(
 	| {
 			tag: "WorkflowRemovedEntry";
 			val: { originalType: string; originalName: string | null };
+	  }
+	| {
+			tag: "WorkflowVersionCheckEntry";
+			val: { resolved: number; latest: number };
 	  } {
 	switch (kind.tag) {
 		case "WorkflowStepEntry":
@@ -972,6 +976,14 @@ function serializeWorkflowEntryKind(
 					originalName: kind.val.originalName,
 				},
 			};
+		case "WorkflowVersionCheckEntry":
+			return {
+				tag: kind.tag,
+				val: {
+					resolved: kind.val.resolved,
+					latest: kind.val.latest,
+				},
+			};
 	}
 }
 

frontend/src/components/actors/workflow/xyflow-nodes.tsx

@@ -960,6 +960,10 @@ export class WorkflowContext<
 		await this.#wrapActive(() => this.#inner.removed(name, originalType));
 	}
 
+	getVersion(name: string, latest: number): Promise<number> {
+		return this.#wrapActive(() => this.#inner.getVersion(name, latest));
+	}
+
 	isEvicted(): boolean {
 		return this.#inner.isEvicted();
 	}

rivetkit-typescript/packages/rivetkit/src/common/bare/transport/v1.ts

@@ -184,6 +184,14 @@ function toWorkflowEntryKind(kind: EntryKind): transport.WorkflowEntryKind {
 					originalName: kind.data.originalName ?? null,
 				},
 			};
+		case "version_check":
+			return {
+				tag: "WorkflowVersionCheckEntry",
+				val: {
+					resolved: kind.data.resolved,
+					latest: kind.data.latest,
+				},
+			};
 		default:
 			assertUnreachable(kind as never);
 	}

rivetkit-typescript/packages/rivetkit/src/registry/native.ts

@@ -188,6 +188,17 @@ describe("inspector workflow transport", () => {
 						},
 					},
 				},
+				{
+					id: "entry-2",
+					location: [{ tag: "WorkflowNameIndex", val: 1 }],
+					kind: {
+						tag: "WorkflowVersionCheckEntry",
+						val: {
+							resolved: 1,
+							latest: 2,
+						},
+					},
+				},
 			],
 			entryMetadata: new Map([
 				[

rivetkit-typescript/packages/rivetkit/src/workflow/context.ts

@@ -307,6 +307,14 @@ function entryKindToBare(kind: InternalEntryKind): v1.EntryKind {
 					originalName: kind.data.originalName ?? null,
 				},
 			};
+		case "version_check":
+			return {
+				tag: "VersionCheckEntry",
+				val: {
+					resolved: kind.data.resolved,
+					latest: kind.data.latest,
+				},
+			};
 	}
 }
 
@@ -396,6 +404,14 @@ function entryKindFromBare(kind: v1.EntryKind): InternalEntryKind {
 					originalName: kind.val.originalName ?? undefined,
 				},
 			};
+		case "VersionCheckEntry":
+			return {
+				type: "version_check",
+				data: {
+					resolved: kind.val.resolved,
+					latest: kind.val.latest,
+				},
+			};
 		default:
 			throw new Error(
 				`Unknown entry kind: ${(kind as { tag: string }).tag}`,

rivetkit-typescript/packages/rivetkit/src/workflow/inspector.ts

@@ -122,6 +122,14 @@ type RemovedEntry struct {
 	originalName: optional<str>
 }
 
+# MARK: Version Check Entry
+type VersionCheckEntry struct {
+	# The version this instance resolved to at this location
+	resolved: u32
+	# The `latest` value seen when first resolved (diagnostics)
+	latest: u32
+}
+
 # MARK: Entry Kind
 # Type-specific entry data
 type EntryKind union {
@@ -132,7 +140,8 @@ type EntryKind union {
 	RollbackCheckpointEntry |
 	JoinEntry |
 	RaceEntry |
-	RemovedEntry
+	RemovedEntry |
+	VersionCheckEntry
 }
 
 # MARK: Entry