Function orchestrate

server/modules/ai/orchestrator/orchestrator.js:1658–2007

(
  teamId, question, conversationHistory = [], conversation = null, context = null, options = {}
)

}

async function orchestrate(
  teamId, question, conversationHistory = [], conversation = null, context = null, options = {}
) {
  // Extract optional tool progress callback
  const { toolProgressCallback, userId } = options;
  if (!openaiClient) {
    throw new Error("OpenAI client is not initialized. Please check your environment variables.");
  }

  // Sanitize conversation history to ensure OpenAI API compliance
  // This removes any assistant messages with tool_calls that don't have complete tool responses
  const sanitizedHistory = sanitizeConversationHistory(conversationHistory);

  // Emit initial processing event
  if (conversation?.id) {
    emitProgressEvent(socketManager, conversation.id, "PROCESSING_START", { question });
  }

  const semanticLayer = await buildSemanticLayer(teamId);

  // Check if this is a capability question
  if (isCapabilityQuestion(question)) {
    // Generate capability response without AI calls
    const capabilityResponse = generateCapabilityResponse(semanticLayer);

    // Prepare messages for database recording
    const messages = [
      { role: "system", content: "System prompt for capability response" }, // Simplified for recording
      ...sanitizedHistory,
      { role: "user", content: question },
      { role: "assistant", content: capabilityResponse }
    ];

    // Emit completion event
    if (conversation?.id) {
      emitProgressEvent(socketManager, conversation.id, "PROCESSING_COMPLETE");
    }

    // Return with 0 token usage
    return {
      message: capabilityResponse,
      conversationHistory: messages,
      usage: {
        prompt_tokens: 0,
        completion_tokens: 0,
        total_tokens: 0
      },
      usageRecords: [{
        model: openAiModel || "gpt-5.4-nano",
        prompt_tokens: 0,
        completion_tokens: 0,
        total_tokens: 0,
        elapsed_ms: 0,
      }],
      iterations: 0,
    };
  }