fix: should not auto reconnect when kicked

Author: zxch3n

packages/loro-websocket/README.md

@@ -112,6 +112,7 @@ type ClientStatusValue = typeof ClientStatus[keyof typeof ClientStatus];
   - Retry cadence: attempts start ~500 ms after the first unexpected close and double on each failure (1 s, 2 s, 4 s, …) up to a 15 s ceiling. A successful connection resets the backoff to the 500 ms starting point.
   - The timer is canceled when the environment reports `offline`; the client stays in `Disconnected` until an `online` event arrives, at which point the next retry fires immediately.
   - Calling `close()` or `destroy()` turns off auto‑retry. Invoke `connect()` later to restart the process with a fresh backoff window.
+  - Server‑initiated kicks: if the socket closes with a code in the `4400–4499` range or a reason of `permission_changed` / `room_closed`, the client assumes the server intentionally removed the connection and **does not** schedule reconnect attempts. This mirrors the Durable Object kick semantics used in `@loro-protocol/do`.
 
 ## Latency & Ping/Pong
 

packages/loro-websocket/src/client/index.ts

@@ -49,7 +49,7 @@ interface ActiveRoom {
 interface SocketListeners {
   open: () => void;
   error: (event: Event) => void;
-  close: () => void;
+  close: (event: CloseEvent) => void;
   message: (event: MessageEvent<string | ArrayBuffer>) => void;
 }
 
@@ -309,8 +309,8 @@ export class LoroWebsocketClient {
     const error = (event: Event) => {
       this.onSocketError(ws, event);
     };
-    const close = () => {
-      this.onSocketClose(ws);
+    const close = (event: CloseEvent) => {
+      this.onSocketClose(ws, event);
     };
     const message = (event: MessageEvent<string | ArrayBuffer>) => {
       void this.onSocketMessage(ws, event);
@@ -354,13 +354,23 @@ export class LoroWebsocketClient {
     // Leave further handling to the close event for the active socket
   }
 
-  private onSocketClose(ws: WebSocket): void {
+  private onSocketClose(ws: WebSocket, event?: CloseEvent): void {
     const isCurrent = ws === this.ws;
     this.detachSocketListeners(ws);
     if (!isCurrent) {
       return;
     }
 
+    const closeCode = event?.code;
+    if (closeCode != null && closeCode >= 4400 && closeCode < 4500) {
+      this.shouldReconnect = false;
+    }
+
+    const closeReason = event?.reason;
+    if (closeReason === "permission_changed" || closeReason === "room_closed") {
+      this.shouldReconnect = false;
+    }
+
     this.clearPingTimer();
     // Clear any pending fragment reassembly timers to avoid late callbacks
     if (this.fragmentBatches.size) {