Method cascadeChat

src/client.js:593–1378

* Chat via Cascade flow (for premium models with string UIDs). * * 1. StartCascade → cascade_id * 2. SendUserCascadeMessage (with model config) * 3. Poll GetCascadeTrajectorySteps until IDLE * * @param {Array} messages * @param {number} modelEnum * @param {string} modelUid

(messages, modelEnum, modelUid, opts = {})

   * @param {object} opts - { onChunk, onEnd, onError }
   */
  async cascadeChat(messages, modelEnum, modelUid, opts = {}) {
    let onChunk, onEnd, onError, signal, reuseEntry, toolPreamble, displayModel, nativeEnvironment;
    let nativeMode, nativeAllowlist, additionalSteps;
    acquireLsUseOrThrow(this.port);
    try {
    ({
      onChunk, onEnd, onError, signal, reuseEntry, toolPreamble, displayModel, nativeEnvironment,
      // v2.0.65 native tool bridge handles. When nativeMode=true the
      // upstream cascade_config switches the planner to DEFAULT mode + a
      // restricted CascadeToolConfig.tool_allowlist; additionalSteps[9]
      // carries fake "completed" trajectory steps for the caller's prior
      // tool turns so the planner reasons from post-tool state.
      nativeMode, nativeAllowlist, additionalSteps,
    } = opts);
    const aborted = () => signal?.aborted;
    const inputChars = messages.reduce((n, m) => n + contentToString(m?.content).length, 0);

    log.debug(`CascadeChat: uid=${modelUid} enum=${modelEnum} msgs=${messages.length} reuse=${!!reuseEntry}`);

    // One-shot per-LS workspace init (idempotent; typically pre-warmed at
    // LS startup). Falls back to a local session id if the LS entry is gone.
    const lsEntry = getLsEntryByPort(this.port);
    await this.warmupCascade();
    let sessionId = reuseEntry?.sessionId || lsEntry?.sessionId || randomUUID();

    // "panel state not found" means the LS forgot the panel for our sessionId
    // (LS restarted, TTL expired, etc.). Re-run warmupCascade with a fresh
    // sessionId and retry the handshake once.
    const isPanelMissing = (e) => /panel state not found|not_found.*panel/i.test(e?.message || '');
    // v2.0.25 HIGH-2: a cascade we tried to resume is gone upstream (TTL
    // expired, server flushed, replay window passed). Same recovery as
    // panel-missing — discard the reuse entry and fresh-start with full
    // history replay.
    const isExpiredCascade = (e) => /not_found.*(cascade|trajectory)|(?:cascade|trajectory).*not[ _-]?found|expired.*cascade|unknown.*cascade/i.test(e?.message || '');
    // #107 follow-up (zhangzhang-bit): SendUserCascadeMessage occasionally
    // returns "untrusted workspace" on a freshly-spun LS — UpdateWorkspaceTrust
    // either silently failed during warmup (handleWarmupError swallows
    // non-transport errors) or the trust state was reset between warmup
    // and the first message. Same recovery: force re-warm (which retries
    // UpdateWorkspaceTrust) and reopen the cascade.
    const isUntrustedWorkspace = (e) => /untrusted workspace|workspace.*not.*trusted/i.test(e?.message || '');

      // Step 1: Start cascade — with retry on panel-state-not-found
      let cascadeId;
      const openCascade = async () => {
        if (reuseEntry?.cascadeId) {
          log.debug(`Cascade resumed: ${reuseEntry.cascadeId}`);
          return reuseEntry.cascadeId;
        }
        const startProto = buildStartCascadeRequest(this.apiKey, sessionId);
        const startResp = await grpcUnary(
          this.port, this.csrfToken, `${LS_SERVICE}/StartCascade`, grpcFrame(startProto)
        );
        const id = parseStartCascadeResponse(startResp);
        if (!id) throw new Error('StartCascade returned empty cascade_id');
        log.debug(`Cascade started: ${id}`);
        return id;
      };