fix(rivetkit): bind methods through createWriteThroughProxy (#4987)

Fixes an error that occurs when inspector state attempts to serialize non trivial values (ie `Date`).

Author: abcxff

pnpm-lock.yaml

@@ -123,6 +123,33 @@
                               "type": "null"
                             }
                           ]
+                        },
+                        "actor": {
+                          "type": "object",
+                          "properties": {
+                            "actorId": {
+                              "type": "string"
+                            },
+                            "generation": {
+                              "anyOf": [
+                                {
+                                  "type": "number"
+                                },
+                                {
+                                  "type": "integer",
+                                  "format": "int64"
+                                }
+                              ]
+                            },
+                            "key": {
+                              "type": "string"
+                            }
+                          },
+                          "required": [
+                            "actorId",
+                            "generation"
+                          ],
+                          "additionalProperties": false
                         }
                       },
                       "required": [
@@ -421,6 +448,33 @@
                 "type": "null"
               }
             ]
+          },
+          "actor": {
+            "type": "object",
+            "properties": {
+              "actorId": {
+                "type": "string"
+              },
+              "generation": {
+                "anyOf": [
+                  {
+                    "type": "number"
+                  },
+                  {
+                    "type": "integer",
+                    "format": "int64"
+                  }
+                ]
+              },
+              "key": {
+                "type": "string"
+              }
+            },
+            "required": [
+              "actorId",
+              "generation"
+            ],
+            "additionalProperties": false
           }
         },
         "required": [

rivetkit-asyncapi/asyncapi.json

@@ -168,13 +168,14 @@
 		"actor-config-schema-gen": "tsx scripts/actor-config-schema-gen.ts"
 	},
 	"dependencies": {
-		"@rivet-dev/agent-os-core": "^0.1.1",
 		"@hono/node-server": "^1.18.2",
 		"@hono/node-ws": "^1.1.1",
 		"@hono/zod-openapi": "^1.1.5",
+		"@rivet-dev/agent-os-core": "^0.1.1",
 		"@rivetkit/bare-ts": "^0.6.2",
 		"@rivetkit/engine-cli": "workspace:*",
 		"@rivetkit/engine-envoy-protocol": "workspace:*",
+		"@rivetkit/on-change": "6.0.1",
 		"@rivetkit/rivetkit-napi": "workspace:*",
 		"@rivetkit/rivetkit-wasm": "workspace:*",
 		"@rivetkit/traces": "workspace:*",
@@ -192,10 +193,10 @@
 		"zod": "^4.1.0"
 	},
 	"devDependencies": {
+		"@biomejs/biome": "^2.3",
 		"@copilotkit/llmock": "^1.6.0",
 		"@rivet-dev/agent-os-common": "*",
 		"@rivet-dev/agent-os-pi": "^0.1.1",
-		"@biomejs/biome": "^2.3",
 		"@standard-schema/spec": "^1.0.0",
 		"@types/invariant": "^2",
 		"@types/node": "^22.13.1",

rivetkit-typescript/packages/rivetkit/package.json

@@ -22,6 +22,7 @@ import {
 import { assertUnreachable, stringifyError } from "@/common/utils";
 import type { UniversalWebSocket } from "@/common/websocket-interface";
 import type { EngineControlClient } from "@/engine-client/driver";
+import type { JsonCompatValue } from "@/common/encoding";
 import {
 	decodeCborCompat,
 	deserializeWithEncoding,
@@ -1267,7 +1268,7 @@ export class ActorConnRaw {
 											name: msg.body.val.name,
 											args: bufferToArrayBuffer(
 												encodeCborCompat(
-													msg.body.val.args,
+													msg.body.val.args as JsonCompatValue,
 												),
 											),
 										},

rivetkit-typescript/packages/rivetkit/src/client/actor-conn.ts

@@ -23,6 +23,7 @@ import {
 } from "@/common/client-protocol-zod";
 import { deconstructError } from "@/common/utils";
 import type { EngineControlClient } from "@/engine-client/driver";
+import type { JsonCompatValue } from "@/common/encoding";
 import { decodeCborCompat, deserializeWithEncoding, encodeCborCompat } from "@/serde";
 import { bufferToArrayBuffer } from "@/utils";
 import type {
@@ -332,7 +333,7 @@ export class ActorHandleRaw {
 						args,
 					}),
 					requestToBare: (args): protocol.HttpActionRequest => ({
-						args: bufferToArrayBuffer(encodeCborCompat(args)),
+						args: bufferToArrayBuffer(encodeCborCompat(args as JsonCompatValue)),
 					}),
 					responseFromJson: (json): Response => json.output as Response,
 					responseFromBare: (bare): Response =>

rivetkit-typescript/packages/rivetkit/src/client/actor-handle.ts

@@ -12,6 +12,7 @@ import {
 	type HttpQueueSendResponse as HttpQueueSendResponseJson,
 	HttpQueueSendResponseSchema,
 } from "@/common/client-protocol-zod";
+import type { JsonCompatValue } from "@/common/encoding";
 import { decodeCborCompat, encodeCborCompat } from "@/serde";
 import { bufferToArrayBuffer } from "@/utils";
 import { sendHttpRequest } from "./utils";
@@ -111,7 +112,7 @@ export function createQueueSender(
 			}),
 			requestToBare: (value): protocol.HttpQueueSendRequest => ({
 				name: value.name ?? name,
-				body: bufferToArrayBuffer(encodeCborCompat(value.body)),
+				body: bufferToArrayBuffer(encodeCborCompat(value.body as JsonCompatValue)),
 				wait: value.wait ?? false,
 				timeout:
 					value.timeout !== undefined ? BigInt(value.timeout) : null,