Function streamAssistantDraft

lib/services/cli/codex.ts:603–635

(force = false)

  };

  const streamAssistantDraft = (force = false) => {
    const combined = buildAssistantPayload();
    if (!combined) {
      return;
    }
    if (!force && combined === lastStreamedAssistantPayload) {
      return;
    }
    const id = assistantMessageId ?? (assistantMessageId = randomUUID());

    // Enhanced duplicate prevention
    if (streamedMessageIds.has(id) && !force) {
      console.debug(`[CodexService] Assistant message ${id} already streamed, skipping`);
      return;
    }

    const realtime = createRealtimeMessage({
      id,
      projectId,
      role: 'assistant',
      messageType: 'chat',
      content: combined,
      metadata: { cli_type: 'codex' },
      cliSource: 'codex',
      requestId,
      isStreaming: true,
      isFinal: false,
    });
    streamManager.publish(projectId, { type: 'message', data: realtime });
    streamedMessageIds.add(id);
    lastStreamedAssistantPayload = combined;
    console.debug(`[CodexService] Streamed assistant message: ${id} (length: ${combined.length})`);
  };

  const resetAssistantBuffers = () => {
    agentBuffer = '';