fix(rivetkit): revert remove client-side connection request size check

Author: abcxff

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

@@ -1280,34 +1280,8 @@ export class ActorConnRaw {
 							}
 						},
 					);
-					const serializedLength = messageLength(messageSerialized);
-					if (
-						serializedLength > DEFAULT_MAX_INCOMING_MESSAGE_SIZE &&
-						message.body.tag === "ActionRequest"
-					) {
-						const actionId = Number(message.body.val.id);
-						const inFlight = this.#takeActionInFlight(actionId);
-						const error = new errors.ActorError(
-							"message",
-							"incoming_too_long",
-							"Incoming message too long",
-							{
-								maxSize: DEFAULT_MAX_INCOMING_MESSAGE_SIZE,
-								actualSize: serializedLength,
-							},
-						);
-						logger().warn({
-							msg: "rejecting oversized connection action request",
-							actionId,
-							actionName: inFlight.name,
-							actualSize: serializedLength,
-							maxSize: DEFAULT_MAX_INCOMING_MESSAGE_SIZE,
-						});
-						inFlight.reject(error);
-						this.#dispatchActorError(error);
-						return;
-					}
 					this.#websocket.send(messageSerialized);
+					const serializedLength = messageLength(messageSerialized);
 					logger().trace({
 						msg: "sent websocket message",
 						len: serializedLength,

rivetkit-typescript/packages/rivetkit/tests/driver/actor-conn.test.ts

@@ -707,16 +707,18 @@ describeDriverMatrix("Actor Conn", (driverTestConfig) => {
 				await connection.dispose();
 			});
 
-			test("should reject request exceeding maxIncomingMessageSize", async (c) => {
+			test("should reject request exceeding maxIncomingMessageSize via server", async (c) => {
 				const { client } = await setupDriverTest(c, driverTestConfig);
 
 				const handle = client.largePayloadConnActor.getOrCreate([
 					"test-large-request-exceed",
 				]);
 				const connection = handle.connect();
 
-				// Create a payload that exceeds the default 64KB limit
-				// Each item is roughly 60 bytes, so 1500 items ≈ 90KB
+				// Create a payload that exceeds the default 64KB limit.
+				// Each item is roughly 60 bytes, so 1500 items ~ 90KB.
+				// The server enforces the limit and closes the WebSocket
+				// with reason "message.incoming_too_long".
 				const items: string[] = [];
 				for (let i = 0; i < 1500; i++) {
 					items.push(