Function flushAssistantMessage

lib/services/cli/codex.ts:642–672

(force = false)

  };

  const flushAssistantMessage = async (force = false) => {
    const combined = buildAssistantPayload();

    if (!combined) {
      if (force) {
        assistantMessageId = null;
        lastStreamedAssistantPayload = null;
        resetAssistantBuffers();
      }
      return;
    }

    const id = assistantMessageId ?? (assistantMessageId = randomUUID());
    lastStreamedAssistantPayload = null;

    await persistMessage(
      projectId,
      {
        id,
        role: 'assistant',
        messageType: 'chat',
        content: combined,
        metadata: { cli_type: 'codex' },
      },
      requestId,
      { isStreaming: false, isFinal: true },
    );

    assistantMessageId = null;
    resetAssistantBuffers();
  };

  const emitCommandStart = async (item: Record<string, unknown>) => {
    const id = pickFirstString(item.id) ?? randomUUID();