Method processAgentResult

packages/core/src/core/run-handler.ts:410–482

* Process agent result and execute tools

({
    runAgentResult,
    agent,
  }: {
    runAgentResult: RunAgentResult;
    agent: AbstractAgent;
  })

   * Process agent result and execute tools
   */
  private async processAgentResult({
    runAgentResult,
    agent,
  }: {
    runAgentResult: RunAgentResult;
    agent: AbstractAgent;
  }): Promise<RunAgentResult> {
    const { newMessages } = runAgentResult;
    // Agent ID is guaranteed to be set by validateAndAssignAgentId
    const agentId = agent.agentId!;

    let needsFollowUp = false;

    for (const message of newMessages) {
      if (message.role === "assistant") {
        for (const toolCall of message.toolCalls || []) {
          if (
            newMessages.findIndex(
              (m) => m.role === "tool" && m.toolCallId === toolCall.id,
            ) === -1
          ) {
            const tool = this.getTool({
              toolName: toolCall.function.name,
              agentId: agent.agentId,
            });
            if (tool) {
              const followUp = await this.executeSpecificTool(
                tool,
                toolCall,
                message,
                agent,
                agentId,
              );
              if (followUp) {
                needsFollowUp = true;
              }
            } else {
              // Wildcard fallback for undefined tools
              const wildcardTool = this.getTool({
                toolName: "*",
                agentId: agent.agentId,
              });
              if (wildcardTool) {
                const followUp = await this.executeWildcardTool(
                  wildcardTool,
                  toolCall,
                  message,
                  agent,
                  agentId,
                );
                if (followUp) {
                  needsFollowUp = true;
                }
              }
            }
          }
        }
      }