Function executeFunctionTools

go/llmproxy/agent/runner.go:195–228

executeFunctionTools runs the given function tool calls using the tools available to the current agent.

(ctx context.Context, requests []llmproxy.ToolCallRequest, currentAgent *Agent, turn int, emit func(Event))

// executeFunctionTools runs the given function tool calls using the tools available to the current agent.
func executeFunctionTools(ctx context.Context, requests []llmproxy.ToolCallRequest, currentAgent *Agent, turn int, emit func(Event)) (*Handoff, llmproxy.InputItems, error) {
	newInputItems := llmproxy.InputItems{}
	for _, req := range requests {
		tool, ok := FindExternalTool(currentAgent, req.Name)
		if !ok {
			return nil, nil, fmt.Errorf("tool %s not found for agent %s", req.Name, currentAgent.Name)
		}
		switch ft := tool.(type) {
		case llmproxy.FunctionTool:
			// Add tool call itself to conversation input, so model knows what was called
			newInputItems = append(newInputItems, req)
			emit(Event{Type: EventToolCall, Turn: turn, ToolCall: &req})
			// Call the tool function and get the result
			toolResult, err := ft.ToolCall(ctx, req.Arguments)
			if err != nil {
				return nil, nil, fmt.Errorf("error invoking tool %s: %w", req.Name, err)
			}
			// Add tool result to conversation input
			ftr := llmproxy.ToolResult{
				CallID: req.CallID,
				Name:   ft.ToolName(),
				Output: toolResult,
			}
			newInputItems = append(newInputItems, ftr)
			emit(Event{Type: EventToolResult, Turn: turn, ToolResult: &ftr})
		case Handoff:
			// Handoffs are control flow changes. No tool requests, results or turns.
			return &ft, nil, nil
		default:
			return nil, nil, fmt.Errorf("unsupported function tool type %T for tool %s", ft, req.Name)
		}
	}
	return nil, newInputItems, nil
}