refactor: studio -> inspector (#1185)

### TL;DR

Renamed all references from `studio` to `inspector` in the codebase to maintain consistent terminology.

### What changed?

- Renamed the `studio` property to `inspector` in the `RunConfig` schema
- Updated all references to this property throughout the codebase
- Changed environment variable names from `RIVETKIT_STUDIO_TOKEN` to `RIVETKIT_INSPECTOR_TOKEN` and `RIVETKIT_STUDIO_DISABLE` to `RIVETKIT_INSPECTOR_DISABLE`
- Renamed `getStudioUrl` function to `getInspectorUrl`
- Updated log messages and comments to use "inspector" instead of "studio"
- Renamed `defaultStudioOrigins` to `defaultInspectorOrigins`

### How to test?

1. Ensure the inspector functionality works correctly after the rename
2. Verify that environment variables using the new `RIVETKIT_INSPECTOR_*` naming pattern work as expected
3. Check that the inspector URL is correctly generated and displayed in logs
4. Confirm that CORS settings are properly applied for inspector endpoints

### Why make this change?

This change standardizes terminology across the codebase by consistently using "inspector" instead of "studio". This improves code clarity, reduces confusion, and ensures that all references to this feature use the same naming convention. The rename aligns the code with the actual functionality being provided, which is an inspection tool rather than a studio.

Author: jog1t

examples/next-js/src/app/api/registry/[...all]/route.ts

@@ -6,8 +6,8 @@ const server = registry.createServer({
 	// It should match the path in your Next.js API route
 	// For example, if your API route is at /api/registry/[...all], this should be "/api/registry"
 	basePath: "/api/registry",
-	studio: {
-		// Tell RivetKit Studio where to find RivetKit Registry
+	inspector: {
+		// Tell RivetKit Inspector where to find RivetKit Registry
 		defaultEndpoint: "http://localhost:3000/api/registry",
 	},
 });

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@4b0f765"
+    "@rivetkit/engine-runner": "https://pkg.pr.new/rivet-gg/engine/@rivetkit/engine-runner@21dd4b4"
   },
   "devDependencies": {
     "@hono/node-server": "^1.18.2",

packages/core/src/actor/router.ts

@@ -235,7 +235,7 @@ export function createActorRouter(
 		}
 	});
 
-	if (runConfig.studio.enabled) {
+	if (runConfig.inspector.enabled) {
 		router.route(
 			"/inspect",
 			new Hono<ActorInspectorRouterEnv & { Bindings: ActorRouterBindings }>()

packages/core/src/driver-test-suite/mod.ts

@@ -157,7 +157,7 @@ export async function createTestRuntime(
 	const config: RunConfig = RunConfigSchema.parse({
 		driver,
 		getUpgradeWebSocket: () => upgradeWebSocket!,
-		studio: {
+		inspector: {
 			enabled: true,
 			token: () => "token",
 		},

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

@@ -80,12 +80,11 @@ export class EngineActorDriver implements ActorDriver {
 			endpoint: config.endpoint,
 			pegboardEndpoint: config.pegboardEndpoint,
 			namespace: config.namespace,
-			addresses: config.addresses,
 			totalSlots: config.totalSlots,
 			runnerName: config.runnerName,
 			runnerKey: config.runnerKey,
 			metadata: {
-				inspectorToken: this.#runConfig.studio.token(),
+				inspectorToken: this.#runConfig.inspector.token(),
 			},
 			prepopulateActorNames: Object.fromEntries(
 				Object.keys(this.#registryConfig.use).map((name) => [

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

@@ -40,9 +40,9 @@ export class EngineManagerDriver implements ManagerDriver {
 	constructor(config: Config, runConfig: RunConfig) {
 		this.#config = config;
 		this.#runConfig = runConfig;
-		if (!this.#runConfig.studio.token()) {
+		if (!this.#runConfig.inspector.token()) {
 			const token = generateRandomString();
-			this.#runConfig.studio.token = () => token;
+			this.#runConfig.inspector.token = () => token;
 		}
 		this.#importWebSocketPromise = importWebSocket();
 	}
@@ -365,7 +365,7 @@ function buildGuardHeadersForHttp(
 	// Add guard-specific headers
 	headers.set("x-rivet-target", "actor");
 	headers.set("x-rivet-actor", actorId);
-	headers.set("x-rivet-addr", "main");
+	headers.set("x-rivet-port", "main");
 	return headers;
 }
 
@@ -378,7 +378,7 @@ function buildGuardHeadersForWebSocket(
 	const headers: Record<string, string> = {};
 	headers["x-rivet-target"] = "actor";
 	headers["x-rivet-actor"] = actorId;
-	headers["x-rivet-addr"] = "main";
+	headers["x-rivet-port"] = "main";
 	headers[HEADER_EXPOSE_INTERNAL_ERROR] = "true";
 	headers[HEADER_ENCODING] = encoding;
 	if (params) {

packages/core/src/drivers/file-system/manager.ts

@@ -54,9 +54,9 @@ export class FileSystemManagerDriver implements ManagerDriver {
 		this.#state = state;
 		this.#driverConfig = driverConfig;
 
-		if (runConfig.studio.enabled) {
-			if (!this.#runConfig.studio.token()) {
-				this.#runConfig.studio.token = () =>
+		if (runConfig.inspector.enabled) {
+			if (!this.#runConfig.inspector.token()) {
+				this.#runConfig.inspector.token = () =>
 					this.#state.getOrCreateInspectorAccessToken();
 			}
 			const startedAt = new Date().toISOString();

packages/core/src/inspector/config.ts

@@ -6,7 +6,7 @@ import { getEnvUniversal } from "@/utils";
 type CorsOptions = NonNullable<Parameters<typeof cors>[0]>;
 
 const defaultTokenFn = () => {
-	const envToken = getEnvUniversal("RIVETKIT_STUDIO_TOKEN");
+	const envToken = getEnvUniversal("RIVETKIT_INSPECTOR_TOKEN");
 
 	if (envToken) {
 		return envToken;
@@ -18,19 +18,19 @@ const defaultTokenFn = () => {
 const defaultEnabled = () => {
 	return (
 		getEnvUniversal("NODE_ENV") !== "production" ||
-		!getEnvUniversal("RIVETKIT_STUDIO_DISABLE")
+		!getEnvUniversal("RIVETKIT_INSPECTOR_DISABLE")
 	);
 };
 
-const defaultStudioOrigins = [
+const defaultInspectorOrigins = [
 	"http://localhost:43708",
 	"https://studio.rivet.gg",
 ];
 
 const defaultCors: CorsOptions = {
 	origin: (origin) => {
 		if (
-			defaultStudioOrigins.includes(origin) ||
+			defaultInspectorOrigins.includes(origin) ||
 			(origin.startsWith("https://") && origin.endsWith("rivet-gg.vercel.app"))
 		) {
 			return origin;
@@ -59,7 +59,7 @@ export const InspectorConfigSchema = z
 			.default(() => defaultCors),
 
 		/**
-		 * Token used to access the Studio.
+		 * Token used to access the Inspector.
 		 */
 		token: z
 			.function()
@@ -68,9 +68,9 @@ export const InspectorConfigSchema = z
 			.default(() => defaultTokenFn),
 
 		/**
-		 * Default RivetKit server endpoint for Rivet Studio to connect to. This should be the same endpoint as what you use for your Rivet client to connect to RivetKit.
+		 * Default RivetKit server endpoint for Rivet Inspector to connect to. This should be the same endpoint as what you use for your Rivet client to connect to RivetKit.
 		 *
-		 * This is a convenience property just for printing out the studio URL.
+		 * This is a convenience property just for printing out the inspector URL.
 		 */
 		defaultEndpoint: z.string().optional(),
 	})

packages/core/src/inspector/utils.ts

@@ -28,7 +28,7 @@ export function compareSecrets(providedSecret: string, validSecret: string) {
 
 export const secureInspector = (runConfig: RunConfig) =>
 	createMiddleware(async (c, next) => {
-		if (!runConfig.studio.enabled) {
+		if (!runConfig.inspector.enabled) {
 			return c.text("Inspector is not enabled", 503);
 		}
 
@@ -37,7 +37,7 @@ export const secureInspector = (runConfig: RunConfig) =>
 			return c.text("Unauthorized", 401);
 		}
 
-		const inspectorToken = runConfig.studio.token?.();
+		const inspectorToken = runConfig.inspector.token?.();
 		if (!inspectorToken) {
 			return c.text("Unauthorized", 401);
 		}
@@ -50,16 +50,16 @@ export const secureInspector = (runConfig: RunConfig) =>
 		await next();
 	});
 
-export function getStudioUrl(runConfig: RunConfigInput | undefined) {
-	if (!runConfig?.studio?.enabled) {
+export function getInspectorUrl(runConfig: RunConfigInput | undefined) {
+	if (!runConfig?.inspector?.enabled) {
 		return "disabled";
 	}
 
-	const accessToken = runConfig?.studio?.token?.();
+	const accessToken = runConfig?.inspector?.token?.();
 
 	if (!accessToken) {
 		inspectorLogger().warn(
-			"Studio Token is not set, but Studio is enabled. Please set it in the run configuration `inspector.token` or via `RIVETKIT_STUDIO_TOKEN` environment variable. Studio will not be accessible.",
+			"Inspector Token is not set, but Inspector is enabled. Please set it in the run configuration `inspector.token` or via `RIVETKIT_INSPECTOR_TOKEN` environment variable. Inspector will not be accessible.",
 		);
 		return "disabled";
 	}
@@ -68,8 +68,8 @@ export function getStudioUrl(runConfig: RunConfigInput | undefined) {
 
 	url.searchParams.set("t", accessToken);
 
-	if (runConfig?.studio?.defaultEndpoint) {
-		url.searchParams.set("u", runConfig.studio.defaultEndpoint);
+	if (runConfig?.inspector?.defaultEndpoint) {
+		url.searchParams.set("u", runConfig.inspector.defaultEndpoint);
 	}
 
 	return url.href;

packages/core/src/manager/router.ts

@@ -160,7 +160,7 @@ export function createManagerRouter(
 
 	router.use("*", loggerMiddleware(logger()));
 
-	if (runConfig.cors || runConfig.studio?.cors) {
+	if (runConfig.cors || runConfig.inspector?.cors) {
 		router.use("*", async (c, next) => {
 			// Don't apply to WebSocket routes
 			// HACK: This could be insecure if we had a varargs path. We have to check the path suffix for WS since we don't know the path that this router was mounted.
@@ -179,19 +179,19 @@ export function createManagerRouter(
 
 			return cors({
 				...(runConfig.cors ?? {}),
-				...(runConfig.studio?.cors ?? {}),
+				...(runConfig.inspector?.cors ?? {}),
 				origin: (origin, c) => {
-					const studioOrigin = runConfig.studio?.cors?.origin;
+					const inspectorOrigin = runConfig.inspector?.cors?.origin;
 
-					if (studioOrigin !== undefined) {
-						if (typeof studioOrigin === "function") {
-							const allowed = studioOrigin(origin, c);
+					if (inspectorOrigin !== undefined) {
+						if (typeof inspectorOrigin === "function") {
+							const allowed = inspectorOrigin(origin, c);
 							if (allowed) return allowed;
 							// Proceed to next CORS config if none provided
-						} else if (Array.isArray(studioOrigin)) {
-							return studioOrigin.includes(origin) ? origin : undefined;
+						} else if (Array.isArray(inspectorOrigin)) {
+							return inspectorOrigin.includes(origin) ? origin : undefined;
 						} else {
-							return studioOrigin;
+							return inspectorOrigin;
 						}
 					}
 
@@ -207,12 +207,12 @@ export function createManagerRouter(
 					return null;
 				},
 				allowMethods: (origin, c) => {
-					const studioMethods = runConfig.studio?.cors?.allowMethods;
-					if (studioMethods) {
-						if (typeof studioMethods === "function") {
-							return studioMethods(origin, c);
+					const inspectorMethods = runConfig.inspector?.cors?.allowMethods;
+					if (inspectorMethods) {
+						if (typeof inspectorMethods === "function") {
+							return inspectorMethods(origin, c);
 						}
-						return studioMethods;
+						return inspectorMethods;
 					}
 
 					if (runConfig.cors?.allowMethods) {
@@ -226,14 +226,14 @@ export function createManagerRouter(
 				},
 				allowHeaders: [
 					...(runConfig.cors?.allowHeaders ?? []),
-					...(runConfig.studio?.cors?.allowHeaders ?? []),
+					...(runConfig.inspector?.cors?.allowHeaders ?? []),
 					...ALLOWED_PUBLIC_HEADERS,
 					"Content-Type",
 					"User-Agent",
 				],
 				credentials:
 					runConfig.cors?.credentials ??
-					runConfig.studio?.cors?.credentials ??
+					runConfig.inspector?.cors?.credentials ??
 					true,
 			})(c, next);
 		});
@@ -562,12 +562,12 @@ export function createManagerRouter(
 		});
 	}
 
-	if (runConfig.studio?.enabled) {
+	if (runConfig.inspector?.enabled) {
 		router.route(
 			"/actors/inspect",
 			new Hono()
 				.use(
-					cors(runConfig.studio.cors),
+					cors(runConfig.inspector.cors),
 					secureInspector(runConfig),
 					universalActorProxy({
 						registryConfig,
@@ -584,7 +584,7 @@ export function createManagerRouter(
 			"/inspect",
 			new Hono()
 				.use(
-					cors(runConfig.studio.cors),
+					cors(runConfig.inspector.cors),
 					secureInspector(runConfig),
 					async (c, next) => {
 						const inspector = managerDriver.inspector;