chore(rivetkit): fmt

biome.json

@@ -1,12 +1,11 @@
 {
 	"$schema": "https://biomejs.dev/schemas/2.1.1/schema.json",
 	"files": {
 		"includes": [
 			"**/*.js",
 			"**/*.json",
 			"**/*.ts",
 			"!engine/artifacts",
-			"!engine/sdks",
 			"!engine/sdks/typescript/api-full",
 			"!engine/sdks/typescript/runner-protocol",
 			"!frontend",

engine/sdks/typescript/runner/src/websocket-tunnel-adapter.ts

@@ -4,7 +4,7 @@
 import { logger } from "./log";
 
 export class WebSocketTunnelAdapter {
 	#webSocketId: string;
 	#readyState: number = 0; // CONNECTING
 	#eventListeners: Map<string, Set<(event: any) => void>> = new Map();
 	#onopen: ((this: any, ev: any) => any) | null = null;
@@ -28,7 +28,11 @@
 	constructor(
 		webSocketId: string,
 		sendCallback: (data: ArrayBuffer | string, isBinary: boolean) => void,
-		closeCallback: (code?: number, reason?: string, retry?: boolean) => void,
+		closeCallback: (
+			code?: number,
+			reason?: string,
+			retry?: boolean,
+		) => void,
 	) {
 		this.#webSocketId = webSocketId;
 		this.#sendCallback = sendCallback;
@@ -223,7 +227,7 @@
 	addEventListener(
 		type: string,
 		listener: (event: any) => void,
 		options?: boolean | any,
 	): void {
 		if (typeof listener === "function") {
 			let listeners = this.#eventListeners.get(type);
@@ -436,7 +440,12 @@
 	}
 
 	/// Returns false if the message was sent off.
-	_handleMessage(requestId: ArrayBuffer, data: string | Uint8Array, index: number, isBinary: boolean): boolean {
+	_handleMessage(
+		requestId: ArrayBuffer,
+		data: string | Uint8Array,
+		index: number,
+		isBinary: boolean,
+	): boolean {
 		if (this.#readyState !== 1) {
 			// OPEN
 			return true;
@@ -525,12 +534,12 @@
 	readonly CLOSED = 3;
 
 	// Additional methods for compatibility
 	ping(data?: any, mask?: boolean, cb?: (err: Error) => void): void {
 		// Not implemented for tunnel - could be added if needed
 		if (cb) cb(new Error("Ping not supported in tunnel adapter"));
 	}
 
 	pong(data?: any, mask?: boolean, cb?: (err: Error) => void): void {
 		// Not implemented for tunnel - could be added if needed
 		if (cb) cb(new Error("Pong not supported in tunnel adapter"));
 	}

engine/sdks/typescript/test-runner/src/index.ts

@@ -12,8 +12,7 @@ const INTERNAL_SERVER_PORT = process.env.INTERNAL_SERVER_PORT
 	: 5051;
 const RIVET_NAMESPACE = process.env.RIVET_NAMESPACE ?? "default";
 const RIVET_RUNNER_NAME = process.env.RIVET_RUNNER_NAME ?? "test-runner";
-const RIVET_RUNNER_KEY =
-	process.env.RIVET_RUNNER_KEY;
+const RIVET_RUNNER_KEY = process.env.RIVET_RUNNER_KEY;
 const RIVET_RUNNER_VERSION = process.env.RIVET_RUNNER_VERSION
 	? Number(process.env.RIVET_RUNNER_VERSION)
 	: 1;
@@ -106,8 +105,7 @@ if (AUTOSTART_SERVER) {
 
 if (AUTOSTART_RUNNER) {
 	[runner, runnerStarted, runnerStopped] = await startRunner();
-}
-else await autoConfigureServerless();
+} else await autoConfigureServerless();
 
 async function autoConfigureServerless() {
 	const res = await fetch(
@@ -155,13 +153,14 @@ async function startRunner(): Promise<
 		token: RIVET_TOKEN,
 		namespace: RIVET_NAMESPACE,
 		runnerName: RIVET_RUNNER_NAME,
-		runnerKey: RIVET_RUNNER_KEY ?? `key-${Math.floor(Math.random() * 10000)}`,
+		runnerKey:
+			RIVET_RUNNER_KEY ?? `key-${Math.floor(Math.random() * 10000)}`,
 		totalSlots: RIVET_RUNNER_TOTAL_SLOTS,
 		prepopulateActorNames: {},
 		onConnected: () => {
 			runnerStarted.resolve(undefined);
 		},
-		onDisconnected: () => { },
+		onDisconnected: () => {},
 		onShutdown: () => {
 			runnerStopped.resolve(undefined);
 		},
@@ -227,9 +226,17 @@ async function startRunner(): Promise<
 				ws.send(`Echo: ${data}`);
 
 				// Ack
-				const websocketId = Buffer.from((event as any).rivetRequestId).toString("base64");
-				websocketLastMsgIndexes.set(websocketId, (event as any).rivetMessageIndex);
-				runner.sendWebsocketMessageAck((event as any).rivetRequestId, (event as any).rivetMessageIndex);
+				const websocketId = Buffer.from(
+					(event as any).rivetRequestId,
+				).toString("base64");
+				websocketLastMsgIndexes.set(
+					websocketId,
+					(event as any).rivetMessageIndex,
+				);
+				runner.sendWebsocketMessageAck(
+					(event as any).rivetRequestId,
+					(event as any).rivetMessageIndex,
+				);
 			});
 
 			ws.addEventListener("close", () => {

engine/sdks/typescript/test-runner/src/log.ts

@@ -1,11 +1,11 @@
+import { inspect } from "node:util";
 import {
 	type Level,
 	type LevelWithSilent,
 	type Logger,
 	pino,
 	stdTimeFunctions,
 } from "pino";
-import { inspect } from "util";
 
 export type { Logger } from "pino";
 
@@ -25,13 +25,13 @@
 		return configuredLogLevel;
 	}
 
 	return (process.env["LOG_LEVEL"] || "warn")
 		.toString()
 		.toLowerCase() as LevelWithSilent;
 }
 
 export function getIncludeTarget(): boolean {
 	return process.env["LOG_TARGET"] === "1";
 }
 
 /**
@@ -47,7 +47,7 @@
 	const entries: any = {};
 
 	// Add timestamp if enabled
 	if (process.env["LOG_TIMESTAMP"] === "1" && o.time) {
 		const date = typeof o.time === "number" ? new Date(o.time) : new Date();
 		entries.ts = date;
 	}
@@ -108,7 +108,7 @@
 			},
 		},
 		timestamp:
 			process.env["LOG_TIMESTAMP"] === "1"
 				? stdTimeFunctions.epochTime
 				: false,
 		browser: {
@@ -135,7 +135,7 @@
 				};
 				const levelName = levelMap[level] || "info";
 				const time =
 					process.env["LOG_TIMESTAMP"] === "1"
 						? Date.now()
 						: undefined;
 				// TODO: This can be simplified in logfmt.ts