Function ensureConnection

apps/kimi-web/src/composables/useTerminal.ts:17–44

()

  let conn: KimiEventConnection | null = null;

  function ensureConnection(): KimiEventConnection | null {
    if (conn !== null) return conn;
    if (typeof WebSocket === 'undefined') return null;
    conn = getKimiWebApi().connectEvents({
      onEvent: () => {},
      onResync: () => {},
      onError: (_code, msg) => {
        error.value = msg;
      },
      onConnectionChange: (state) => {
        connected.value = state;
      },
      onTerminalOutput: (sid, terminalId, data, seq) => {
        if (sid !== sessionId.value || terminal.value?.id !== terminalId) return;
        lastSeq.value = Math.max(lastSeq.value, seq);
        for (const handler of outputHandlers) handler(data);
      },
      onTerminalExit: (sid, terminalId, exitCode) => {
        if (sid !== sessionId.value || terminal.value?.id !== terminalId) return;
        readOnly.value = true;
        terminal.value = terminal.value
          ? { ...terminal.value, status: 'exited', exitCode }
          : terminal.value;
        for (const handler of exitHandlers) handler(exitCode);
      },
    });
    return conn;
  }

  async function start(size?: { cols?: number; rows?: number }): Promise<void> {
    const sid = sessionId.value;