Method sendQuery

src/clients/codex.ts:48–153

* Send a query to Codex and stream responses * @param prompt - User message or prompt * @param cwd - Working directory for Codex * @param resumeSessionId - Optional thread ID to resume

(
    prompt: string,
    cwd: string,
    resumeSessionId?: string
  )

   * @param resumeSessionId - Optional thread ID to resume
   */
  async *sendQuery(
    prompt: string,
    cwd: string,
    resumeSessionId?: string
  ): AsyncGenerator<MessageChunk> {
    const codex = await getCodex();

    // Get or create thread (synchronous operations!)
    let thread;
    if (resumeSessionId) {
      console.log(`[Codex] Resuming thread: ${resumeSessionId}`);
      try {
        // NOTE: resumeThread is synchronous, not async
        // IMPORTANT: Must pass options when resuming!
        thread = codex.resumeThread(resumeSessionId, {
          workingDirectory: cwd,
          skipGitRepoCheck: true,
        });
      } catch (error) {
        console.error(`[Codex] Failed to resume thread ${resumeSessionId}, creating new one:`, error);
        // Fall back to creating new thread
        thread = codex.startThread({
          workingDirectory: cwd,
          skipGitRepoCheck: true,
        });
      }
    } else {
      console.log(`[Codex] Starting new thread in ${cwd}`);
      // NOTE: startThread is synchronous, not async
      thread = codex.startThread({
        workingDirectory: cwd,
        skipGitRepoCheck: true,
      });
    }

    try {
      // Run streamed query (this IS async)
      const result = await thread.runStreamed(prompt);

      // Process streaming events
      for await (const event of result.events) {
        // Handle error events
        if (event.type === 'error') {
          console.error('[Codex] Stream error:', event.message);
          // Don't send MCP timeout errors (they're optional)
          if (!event.message.includes('MCP client')) {
            yield { type: 'system', content: `⚠️ ${event.message}` };
          }
          continue;
        }

        // Handle turn failed events
        if (event.type === 'turn.failed') {
          console.error('[Codex] Turn failed:', event.error?.message);
          yield {
            type: 'system',
            content: `❌ Turn failed: ${event.error?.message || 'Unknown error'}`,
          };