Method onMessage

packages/server/src/ws/connection.ts:196–268

(data: RawData)

  }

  private onMessage(data: RawData): void {
    if (this.closed) return;
    let parsed: unknown;
    try {
      parsed = JSON.parse(rawDataToString(data));
    } catch {
      this.logger.warn('non-json ws frame; ignoring');
      return;
    }
    const type = frameType(parsed);
    if (type === undefined) {
      this.logger.warn('invalid control message type');
      return;
    }
    const operation = getClientControlOperation(type);
    if (operation === undefined) {
      this.logger.warn({ type }, 'unknown control message type');
      return;
    }
    const result = operation.messageSchema.safeParse(parsed);
    if (!result.success) {
      this.logger.warn({ issues: result.error.issues.length }, 'invalid control message');
      return;
    }
    const msg = result.data as ClientControlMessage;
    switch (msg.type) {
      case 'client_hello':
        void this.onClientHello(msg).catch((err: unknown) => {
          this.logger.warn({ err: String(err) }, 'client_hello handler failed');
        });
        break;
      case 'pong':
        this.onPong();
        break;
      case 'subscribe':
        void this.onSubscribe(msg).catch((err: unknown) => {
          this.logger.warn({ err: String(err) }, 'subscribe handler failed');
        });
        break;
      case 'unsubscribe':
        this.onUnsubscribe(msg);
        break;
      case 'abort':
        this.onAbort(msg);
        break;
      case 'watch_fs_add':
        this.onWatchFsAdd(msg);
        break;
      case 'watch_fs_remove':
        this.onWatchFsRemove(msg);
        break;
      case 'terminal_attach':
        this.onTerminalAttach(msg);
        break;
      case 'terminal_detach':
        this.onTerminalDetach(msg);
        break;
      case 'terminal_input':