Method processToolCalls

pkg/runtime/tool_dispatch.go:32–52

processToolCalls builds a per-stream [toolexec.Dispatcher] and delegates the per-call orchestration to it. The dispatcher owns the approval flow, hook dispatch, tracing, telemetry, and event emission; this file only supplies the runtime-side adapters that bridge them to the runtime's chan Event. Th

(ctx context.Context, sess *session.Session, calls []tools.ToolCall, agentTools []tools.Tool, events EventSink)

// halts the *batch* but keeps the loop alive so the synthesised tool
// error responses can be sent back to the model on the next turn.
func (r *LocalRuntime) processToolCalls(ctx context.Context, sess *session.Session, calls []tools.ToolCall, agentTools []tools.Tool, events EventSink) (stopRun bool, stopMessage string) {
	// Bind runtime-managed handlers (transfer_task, handoff, change_model, ...)
	// to the current events channel: r.toolMap entries take chan Event,
	// toolexec.ToolHandler doesn't.
	handlers := make(map[string]toolexec.ToolHandler, len(r.toolMap))
	for name, h := range r.toolMap {
		handlers[name] = func(ctx context.Context, sess *session.Session, tc tools.ToolCall) (*tools.ToolCallResult, error) {
			return h(ctx, sess, tc, events)
		}
	}

	d := &toolexec.Dispatcher{
		Tracer:      r.tracer,
		Hooks:       &hookDispatcher{r: r, events: events},
		Resume:      r.resumeChan,
		AgentFor:    r.resolveSessionAgent,
		Permissions: r.permissionCheckers,
		Handlers:    handlers,
	}
	return d.Process(ctx, sess, calls, agentTools, &sinkEmitter{events: events})
}

// permissionCheckers returns the ordered list of permission checkers to
// evaluate (session-level first, then team-level).