Method onWsMessage

src/workspaces/persistent-session.ts:497–529

(ws: WebSocket, raw: unknown, isBinary: boolean)

  }

  private onWsMessage(ws: WebSocket, raw: unknown, isBinary: boolean): void {
    if (this.disposed) return;
    if (this.ws !== ws) return; // stale (this ws was kicked)

    if (isBinary) {
      const buf = toBuffer(raw);
      if (!buf) return;
      try {
        // Browser stdin arrives as UTF-8 bytes. Keep this edge byte-faithful:
        // converting through string corrupts arbitrary terminal sequences and
        // makes CJK/IME behavior depend on JS decoding instead of the PTY.
        this.term.write(buf as unknown as string);
      } catch (err) {
        this.log.warn('session.write_error', { err });
      }
      return;
    }

    const buf = toBuffer(raw);
    if (!buf) return;
    let parsed: unknown;
    try {
      parsed = JSON.parse(buf.toString('utf8'));
    } catch {
      return;
    }
    if (!isClientControlMessage(parsed)) return;

    if (parsed.type === 'resize') {
      this.resize(parsed.cols, parsed.rows);
    }
    // `attach` mid-stream is ignored — the initial attach already happened.
  }

  private wireWs(ws: WebSocket): void {
    const messageHandler = (raw: unknown, isBinary: boolean): void =>