feat(workflow): add workflow history inspector integration

Author: NathanFlurry

pnpm-lock.yaml

@@ -173,7 +173,7 @@
 	],
 	"scripts": {
 		"build": "tsup src/mod.ts src/client/mod.ts src/common/log.ts src/common/websocket.ts src/actor/errors.ts src/topologies/coordinate/mod.ts src/topologies/partition/mod.ts src/utils.ts src/driver-helpers/mod.ts src/driver-test-suite/mod.ts src/serve-test-suite/mod.ts src/test/mod.ts src/inspector/mod.ts src/workflow/mod.ts",
-		"build:schema": "./scripts/compile-bare.ts compile schemas/client-protocol/v1.bare -o dist/schemas/client-protocol/v1.ts && ./scripts/compile-bare.ts compile schemas/client-protocol/v2.bare -o dist/schemas/client-protocol/v2.ts && ./scripts/compile-bare.ts compile schemas/client-protocol/v3.bare -o dist/schemas/client-protocol/v3.ts && ./scripts/compile-bare.ts compile schemas/file-system-driver/v1.bare -o dist/schemas/file-system-driver/v1.ts && ./scripts/compile-bare.ts compile schemas/file-system-driver/v2.bare -o dist/schemas/file-system-driver/v2.ts && ./scripts/compile-bare.ts compile schemas/file-system-driver/v3.bare -o dist/schemas/file-system-driver/v3.ts && ./scripts/compile-bare.ts compile schemas/actor-persist/v1.bare -o dist/schemas/actor-persist/v1.ts && ./scripts/compile-bare.ts compile schemas/actor-persist/v2.bare -o dist/schemas/actor-persist/v2.ts && ./scripts/compile-bare.ts compile schemas/actor-persist/v3.bare -o dist/schemas/actor-persist/v3.ts && ./scripts/compile-bare.ts compile schemas/actor-persist/v4.bare -o dist/schemas/actor-persist/v4.ts && ./scripts/compile-bare.ts compile schemas/actor-inspector/v1.bare -o dist/schemas/actor-inspector/v1.ts && ./scripts/compile-bare.ts compile schemas/actor-inspector/v2.bare -o dist/schemas/actor-inspector/v2.ts && ./scripts/compile-bare.ts compile schemas/actor-inspector/v3.bare -o dist/schemas/actor-inspector/v3.ts && ./scripts/compile-bare.ts compile schemas/actor-inspector/v4.bare -o dist/schemas/actor-inspector/v4.ts"
+		"build:schema": "./scripts/compile-bare.ts compile schemas/client-protocol/v1.bare -o dist/schemas/client-protocol/v1.ts && ./scripts/compile-bare.ts compile schemas/client-protocol/v2.bare -o dist/schemas/client-protocol/v2.ts && ./scripts/compile-bare.ts compile schemas/client-protocol/v3.bare -o dist/schemas/client-protocol/v3.ts && ./scripts/compile-bare.ts compile schemas/file-system-driver/v1.bare -o dist/schemas/file-system-driver/v1.ts && ./scripts/compile-bare.ts compile schemas/file-system-driver/v2.bare -o dist/schemas/file-system-driver/v2.ts && ./scripts/compile-bare.ts compile schemas/file-system-driver/v3.bare -o dist/schemas/file-system-driver/v3.ts && ./scripts/compile-bare.ts compile schemas/actor-persist/v1.bare -o dist/schemas/actor-persist/v1.ts && ./scripts/compile-bare.ts compile schemas/actor-persist/v2.bare -o dist/schemas/actor-persist/v2.ts && ./scripts/compile-bare.ts compile schemas/actor-persist/v3.bare -o dist/schemas/actor-persist/v3.ts && ./scripts/compile-bare.ts compile schemas/actor-persist/v4.bare -o dist/schemas/actor-persist/v4.ts && ./scripts/compile-bare.ts compile schemas/persist/v1.bare -o dist/schemas/persist/v1.ts && ./scripts/compile-bare.ts compile schemas/transport/v1.bare -o dist/schemas/transport/v1.ts && ./scripts/compile-bare.ts compile schemas/actor-inspector/v1.bare -o dist/schemas/actor-inspector/v1.ts && ./scripts/compile-bare.ts compile schemas/actor-inspector/v2.bare -o dist/schemas/actor-inspector/v2.ts",
 		"check-types": "tsc --noEmit",
 		"lint": "biome check .",
 		"lint:fix": "biome check --write .",

rivetkit-typescript/packages/rivetkit/package.json

@@ -1,7 +1,7 @@
 # MARK: Message To Server
 
 type PatchStateRequest struct {
- 	state: data
+	state: data
 }
 
 type ActionRequest struct {
@@ -18,15 +18,23 @@ type ConnectionsRequest struct {
 	id: uint
 }
 
-type EventsRequest struct {
+type RpcsListRequest struct {
 	id: uint
 }
 
-type ClearEventsRequest struct {
+type TraceQueryRequest struct {
 	id: uint
+	startMs: uint
+	endMs: uint
+	limit: uint
 }
 
-type RpcsListRequest struct {
+type QueueRequest struct {
+	id: uint
+	limit: uint
+}
+
+type WorkflowHistoryRequest struct {
 	id: uint
 }
 
@@ -35,9 +43,10 @@ type ToServerBody union {
 	StateRequest |
 	ConnectionsRequest |
 	ActionRequest |
-	EventsRequest |
-	ClearEventsRequest |
-	RpcsListRequest
+	RpcsListRequest |
+	TraceQueryRequest |
+	QueueRequest |
+	WorkflowHistoryRequest
 }
 
 type ToServer struct {
@@ -53,55 +62,18 @@ type Connection struct {
 	details: data
 }
 
-type ActionEvent struct {
-	name: str
-	args: data
-	connId: str
-}
-
-type BroadcastEvent struct {
-	eventName: str
-	args: data
-}
-
-type SubscribeEvent struct {
-	eventName: str
-	connId: str
-}
-
-type UnSubscribeEvent struct {
-	eventName: str
-	connId: str
-}
-
-type FiredEvent struct {
-	eventName: str
-	args: data
-	connId: str
-}
-
-type EventBody union {
-	ActionEvent |
-	BroadcastEvent |
-	SubscribeEvent |
-	UnSubscribeEvent |
-	FiredEvent
-}
-
-type Event struct {
-	id: str
-	timestamp: uint
-	body: EventBody
-}
+# Workflow history is encoded using schemas/transport.
+type WorkflowHistory data
 
 type Init struct {
 	connections: list<Connection>
-	events: list<Event>
 	state: optional<State>
 	isStateEnabled: bool
 	rpcs: list<str>
 	isDatabaseEnabled: bool
 	queueSize: uint
+	workflowHistory: optional<WorkflowHistory>
+	isWorkflowEnabled: bool
 }
 
 type ConnectionsResponse struct {
@@ -115,28 +87,52 @@ type StateResponse struct {
 	isStateEnabled: bool
 }
 
-type EventsResponse struct {
+type ActionResponse struct {
 	rid: uint
-	events: list<Event>
+	output: data
 }
 
-type ActionResponse struct {
+type TraceQueryResponse struct {
 	rid: uint
-	output: data
+	payload: data
 }
 
-type StateUpdated struct {
-	state: State
+type QueueMessageSummary struct {
+	id: uint
+	name: str
+	createdAtMs: uint
+}
+
+type QueueStatus struct {
+	size: uint
+	maxSize: uint
+	messages: list<QueueMessageSummary>
+	truncated: bool
 }
 
-type EventsUpdated struct {
-	events: list<Event>
+type QueueResponse struct {
+	rid: uint
+	status: QueueStatus
+}
+
+type WorkflowHistoryResponse struct {
+	rid: uint
+	history: optional<WorkflowHistory>
+	isWorkflowEnabled: bool
+}
+
+type StateUpdated struct {
+	state: State
 }
 
 type QueueUpdated struct {
 	queueSize: uint
 }
 
+type WorkflowHistoryUpdated struct {
+	history: WorkflowHistory
+}
+
 type RpcsListResponse struct {
 	rid: uint
 	rpcs: list<str>
@@ -145,20 +141,23 @@ type RpcsListResponse struct {
 type ConnectionsUpdated struct {
 	connections: list<Connection>
 }
+
 type Error struct {
 	message: str
 }
 
 type ToClientBody union {
 	StateResponse |
 	ConnectionsResponse |
-	EventsResponse |
 	ActionResponse |
 	ConnectionsUpdated |
-	EventsUpdated |
 	QueueUpdated |
 	StateUpdated |
+	WorkflowHistoryUpdated |
 	RpcsListResponse |
+	TraceQueryResponse |
+	QueueResponse |
+	WorkflowHistoryResponse |
 	Error |
 	Init
 }