Method onServerHello

apps/kimi-web/src/api/daemon/ws.ts:390–423

()

  }

  private onServerHello(): void {
    this.connected = true;
    this.reconnectAttempts = 0;
    this.handlers.onConnectionState(true);

    // Build the initial subscription list from current subscriptions + pending
    const allSessionIds = Array.from(this.subscriptions.keys());
    // Drain pending: merge into subscriptions map (pending overrides if seq differs)
    for (const p of this.pendingSubscriptions) {
      this.subscriptions.set(p.sessionId, p.cursor);
      if (!allSessionIds.includes(p.sessionId)) allSessionIds.push(p.sessionId);
    }
    this.pendingSubscriptions.length = 0;

    // Build cursors from subscriptions
    const cursors: Record<string, SessionCursor> = {};
    for (const [sid, cursor] of this.subscriptions.entries()) {
      cursors[sid] = cursor;
    }

    this.send({
      type: 'client_hello',
      id: this.nextId(),
      payload: {
        client_id: this.clientId,
        subscriptions: allSessionIds,
        cursors,
      },
    });

    for (const attachment of this.terminalAttachments.values()) {
      this.sendTerminalAttach(attachment.sessionId, attachment.terminalId, attachment.lastSeq);
    }
  }

  private sendSubscribe(sessionIds: string[], cursors: Record<string, SessionCursor>): void {
    this.send({