fix: fix connection dead

Author: MasterPtato

clients/openapi/openapi.json

@@ -24,7 +24,15 @@
             "schema": {
               "type": "string"
             },
-            "required": true,
+            "required": false,
+            "name": "actor_ids",
+            "in": "query"
+          },
+          {
+            "schema": {
+              "type": "string"
+            },
+            "required": false,
             "name": "key",
             "in": "query"
           }

packages/rivetkit/src/actor/instance.ts

@@ -84,8 +84,8 @@ export type ExtractActorState<A extends AnyActorInstance> =
 		// biome-ignore lint/suspicious/noExplicitAny: Must be used for `extends`
 		any
 	>
-		? State
-		: never;
+	? State
+	: never;
 
 export type ExtractActorConnParams<A extends AnyActorInstance> =
 	A extends ActorInstance<
@@ -101,8 +101,8 @@ export type ExtractActorConnParams<A extends AnyActorInstance> =
 		// biome-ignore lint/suspicious/noExplicitAny: Must be used for `extends`
 		any
 	>
-		? ConnParams
-		: never;
+	? ConnParams
+	: never;
 
 export type ExtractActorConnState<A extends AnyActorInstance> =
 	A extends ActorInstance<
@@ -118,8 +118,8 @@ export type ExtractActorConnState<A extends AnyActorInstance> =
 		// biome-ignore lint/suspicious/noExplicitAny: Must be used for `extends`
 		any
 	>
-		? ConnState
-		: never;
+	? ConnState
+	: never;
 
 export class ActorInstance<S, CP, CS, V, I, DB extends AnyDatabaseProvider> {
 	// Shared actor context for this instance
@@ -1145,15 +1145,15 @@ export class ActorInstance<S, CP, CS, V, I, DB extends AnyDatabaseProvider> {
 				}
 
 				// Connection is dead, remove it
-				this.#rLog.warn({
-					msg: "connection is dead, removing",
-					connId: conn.id,
-					lastSeen,
-				});
+				// this.#rLog.warn({
+				// 	msg: "connection is dead, removing",
+				// 	connId: conn.id,
+				// 	lastSeen,
+				// });
 
 				// TODO: Do we need to force disconnect the connection here?
 
-				this.__removeConn(conn);
+				// this.__removeConn(conn);
 			}
 		}
 	}
@@ -1367,14 +1367,14 @@ export class ActorInstance<S, CP, CS, V, I, DB extends AnyDatabaseProvider> {
 				try {
 					websocket.removeEventListener("close", onSocketClosed);
 					websocket.removeEventListener("error", onSocketClosed);
-				} catch {}
+				} catch { }
 				this.#activeRawWebSockets.delete(websocket);
 				this.#resetSleepTimer();
 			};
 			try {
 				websocket.addEventListener("close", onSocketClosed);
 				websocket.addEventListener("error", onSocketClosed);
-			} catch {}
+			} catch { }
 
 			// Handle WebSocket
 			await this.#config.onWebSocket(this.actorContext, websocket, opts);
@@ -1672,7 +1672,7 @@ export class ActorInstance<S, CP, CS, V, I, DB extends AnyDatabaseProvider> {
 		// Abort any listeners waiting for shutdown
 		try {
 			this.#abortController.abort();
-		} catch {}
+		} catch { }
 
 		// Call onStop lifecycle hook if defined
 		if (this.#config.onStop) {