feat(drivers/engine): pass inspector to metadata

Author: jog1t

packages/core/package.json

@@ -167,7 +167,7 @@
     "on-change": "^5.0.1",
     "p-retry": "^6.2.1",
     "zod": "^3.25.76",
-    "@rivetkit/engine-runner": "https://pkg.pr.new/rivet-gg/engine/@rivetkit/engine-runner@f8860f3"
+    "@rivetkit/engine-runner": "https://pkg.pr.new/rivet-gg/engine/@rivetkit/engine-runner@4b0f765"
   },
   "devDependencies": {
     "@hono/node-server": "^1.18.2",

packages/core/src/drivers/engine/actor-driver.ts

@@ -31,7 +31,6 @@ import {
 	handleRawWebSocketHandler,
 	handleWebSocketConnect,
 	lookupInRegistry,
-	noopNext,
 	PATH_CONNECT_WEBSOCKET,
 	PATH_RAW_WEBSOCKET_PREFIX,
 } from "@/mod";
@@ -85,7 +84,15 @@ export class EngineActorDriver implements ActorDriver {
 			totalSlots: config.totalSlots,
 			runnerName: config.runnerName,
 			runnerKey: config.runnerKey,
-			prepopulateActorNames: Object.keys(this.#registryConfig.use),
+			metadata: {
+				inspectorToken: this.#runConfig.studio.token(),
+			},
+			prepopulateActorNames: Object.fromEntries(
+				Object.keys(this.#registryConfig.use).map((name) => [
+					name,
+					{ metadata: {} },
+				]),
+			),
 			onConnected: () => {
 				if (hasDisconnected) {
 					logger().info("runner reconnected", {

packages/core/src/drivers/engine/manager-driver.ts

@@ -1,14 +1,14 @@
 import * as cbor from "cbor-x";
 import type { Context as HonoContext } from "hono";
-import type { WSContext } from "hono/ws";
 import invariant from "invariant";
-import { ActorAlreadyExists, InternalError } from "@/actor/errors";
+import { ActorAlreadyExists } from "@/actor/errors";
 import {
 	HEADER_AUTH_DATA,
 	HEADER_CONN_PARAMS,
 	HEADER_ENCODING,
 	HEADER_EXPOSE_INTERNAL_ERROR,
 } from "@/actor/router-endpoints";
+import { generateRandomString } from "@/actor/utils";
 import { importWebSocket } from "@/common/websocket";
 import type {
 	ActorOutput,
@@ -40,6 +40,10 @@ export class EngineManagerDriver implements ManagerDriver {
 	constructor(config: Config, runConfig: RunConfig) {
 		this.#config = config;
 		this.#runConfig = runConfig;
+		if (!this.#runConfig.studio.token()) {
+			const token = generateRandomString();
+			this.#runConfig.studio.token = () => token;
+		}
 		this.#importWebSocketPromise = importWebSocket();
 	}