Method rawGetChatMessage

src/client.js:434–501

* Stream chat via RawGetChatMessage. * Used for models without a string UID (enum < 280 generally). * * @param {Array} messages - OpenAI-format messages * @param {number} modelEnum - Model enum value * @param {string} [modelName] - Optional model name * @param {object} opts - { onC

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

   * @param {object} opts - { onChunk, onEnd, onError }
   */
  rawGetChatMessage(messages, modelEnum, modelName, opts = {}) {
    acquireLsUseOrThrow(this.port);
    try {
      const { onChunk, onEnd, onError } = opts;
      // Reuse the LS-scoped session_id instead of letting buildMetadata
      // mint a fresh UUID on every call. A stable session per LS matches
      // what a real Windsurf IDE instance sends (one session for the whole
      // window's lifetime) and gives upstream fingerprinting less to latch
      // onto. Cascade path already does this via lsEntry.sessionId; this
      // closes the same gap for the legacy channel.
      const lsEntry = getLsEntryByPort(this.port);
      if (lsEntry && !lsEntry.sessionId) lsEntry.sessionId = randomUUID();
      const sessionId = lsEntry?.sessionId;
      const proto = buildRawGetChatMessageRequest(this.apiKey, messages, modelEnum, modelName, sessionId);
      const body = grpcFrame(proto);

      log.debug(`RawGetChatMessage: enum=${modelEnum} msgs=${messages.length}`);

      return new Promise((resolve, reject) => {
        const chunks = [];
        // Once the promise has settled, ignore any further stream events. The
        // LS occasionally emits an error frame followed by a trailing onEnd;
        // without this guard the second callback re-resolves/re-rejects.
        let done = false;

        grpcStream(this.port, this.csrfToken, `${LS_SERVICE}/RawGetChatMessage`, body, {
          onData: (payload) => {
            if (done) return;
            try {
              const parsed = parseRawResponse(payload);
              if (parsed.text) {
                // Detect server-side errors returned as text
                const errMatch = /^(permission_denied|failed_precondition|not_found|unauthenticated):/.test(parsed.text.trim());
                if (parsed.isError || errMatch) {
                  const err = new Error(parsed.text.trim());
                  // Mark model-level errors so they don't count against the account
                  err.isModelError = /permission_denied|failed_precondition/.test(parsed.text);
                  if (err.isModelError) err.kind = 'model_error';
                  done = true;
                  reject(err);
                  return;
                }
                chunks.push(parsed);
                onChunk?.(parsed);
              }
            } catch (e) {
              log.error('RawGetChatMessage parse error:', e.message);
            }
          },
          onEnd: () => {
            if (done) return;
            done = true;
            onEnd?.(chunks);
            resolve(chunks);
          },
          onError: (err) => {
            if (done) return;
            done = true;