Function getOrchestration

server/controllers/AiController.js:17–185

(
  teamId,
  question,
  conversationHistory,
  aiConversationId,
  userId,
  context = null,
)

}

async function getOrchestration(
  teamId,
  question,
  conversationHistory,
  aiConversationId,
  userId,
  context = null,
) {
  let conversation;

  // Load existing conversation or create new one
  if (aiConversationId) {
    conversation = await db.AiConversation.findByPk(aiConversationId);
    if (!conversation) {
      throw new Error("Conversation not found");
    }
    if (`${conversation.team_id}` !== `${teamId}`) {
      throw new Error("Conversation does not belong to this team");
    }
    assertConversationOwnership(conversation, userId);
  } else {
    // Create new conversation
    conversation = await db.AiConversation.create({
      team_id: teamId,
      user_id: userId,
      title: "New Conversation", // Will be updated by orchestrator
      status: "active",
    });

    // Emit conversation ID to user's room immediately so they can join before orchestration
    socketManager.emitToUser(userId, "conversation-created", {
      conversationId: conversation.id
    });
  }

  // Load conversation history from database if not provided
  let fullHistory = conversationHistory;
  if (!conversationHistory || conversationHistory.length === 0) {
    // Rebuild history from AiMessage table
    const messages = await db.AiMessage.findAll({
      where: { conversation_id: conversation.id },
      order: [["sequence", "ASC"]],
    });

    fullHistory = messages.map((msg) => {
      const messageObj = {
        role: msg.role,
        content: msg.content,
      };

      // Add tool-specific fields
      if (msg.tool_calls) {
        messageObj.tool_calls = msg.tool_calls;
      }
      if (msg.tool_name) {
        messageObj.name = msg.tool_name;
      }
      if (msg.tool_call_id) {