Method processToolCalls

cmd/wasm/runtime_wasm.go:534–653

processToolCalls executes tool calls and returns the tool result messages. Returns (messages, handoffAgentName, error).

(ctx context.Context, calls []tools.ToolCall, agentTools []tools.Tool, _ []chat.Message)

// processToolCalls executes tool calls and returns the tool result messages.
// Returns (messages, handoffAgentName, error).
func (rt *wasmRuntime) processToolCalls(ctx context.Context, calls []tools.ToolCall, agentTools []tools.Tool, _ []chat.Message) ([]chat.Message, string, error) {
	toolByName := make(map[string]tools.Tool, len(agentTools))
	for _, t := range agentTools {
		toolByName[t.Name] = t
	}

	var resultMessages []chat.Message
	var handoffAgent string

	for _, tc := range calls {
		if ctx.Err() != nil {
			return nil, "", ctx.Err()
		}

		// Emit tool_call event.
		rt.emitEvent(map[string]any{
			"type": "tool_call",
			"id":   tc.ID,
			"name": tc.Function.Name,
			"args": tc.Function.Arguments,
		})

		// Fire pre_tool_use hook.
		preResult := rt.fireHook(ctx, rt.currentAgent, hooks.EventPreToolUse, &hooks.Input{
			ToolName:  tc.Function.Name,
			ToolUseID: tc.ID,
			ToolInput: parseToolArgs(tc.Function.Arguments),
		})
		if preResult != nil && !preResult.Allowed {
			// Hook denied the tool call.
			rt.emitEvent(map[string]any{
				"type":   "tool_blocked",
				"id":     tc.ID,
				"name":   tc.Function.Name,
				"reason": preResult.Message,
			})
			resultMessages = append(resultMessages, chat.Message{
				Role:       chat.MessageRoleTool,
				ToolCallID: tc.ID,
				Content:    fmt.Sprintf("Tool call denied by hook: %s", preResult.Message),
			})
			continue
		}

		// Handle built-in delegation tools.
		switch tc.Function.Name {
		case "transfer_task":
			result, target := rt.handleTransferTask(tc)
			resultMessages = append(resultMessages, chat.Message{
				Role:       chat.MessageRoleTool,
				ToolCallID: tc.ID,
				Content:    result,
			})
			if target != "" {
				handoffAgent = target
			}
			continue
		case "handoff":