Method reprobe

pkg/runtime/loop.go:1302–1343

reprobe re-runs ensureToolSetsAreStarted after a batch of tool calls. If new tools became available (by name-set diff), it emits a ToolsetInfo event to update the TUI immediately. The new tools will be picked up by the next iteration's getTools() call at the top of the loop. reprobe deliberately do

(
	ctx context.Context,
	sess *session.Session,
	a *agent.Agent,
	currentTools []tools.Tool,
	sessionSpan trace.Span,
	events EventSink,
)

// reprobe deliberately does NOT return the new tool list: the top-of-loop
// getTools() is the single authoritative source for agentTools each iteration.
func (r *LocalRuntime) reprobe(
	ctx context.Context,
	sess *session.Session,
	a *agent.Agent,
	currentTools []tools.Tool,
	sessionSpan trace.Span,
	events EventSink,
) {
	updated, err := r.getTools(ctx, a, sessionSpan, events, false)
	if err != nil {
		slog.WarnContext(ctx, "reprobe: getTools failed", "agent", a.Name(), "error", err)
		return
	}
	updated = filterExcludedTools(updated, sess.ExcludedTools)
	updated = r.skillSubSessionTools(ctx, sess, a, updated, events)

	// Emit any pending warnings that getTools just generated.
	r.emitAgentWarnings(a, events)

	// Compute added tools by comparing name-sets (not just counts), so we
	// correctly handle a toolset that replaced one tool with another.
	prev := make(map[string]struct{}, len(currentTools))
	for _, t := range currentTools {
		prev[t.Name] = struct{}{}
	}
	var added []string
	for _, t := range updated {
		if _, exists := prev[t.Name]; !exists {
			added = append(added, t.Name)
		}
	}

	if len(added) == 0 {
		return
	}

	slog.InfoContext(ctx, "New tools available after toolset re-probe",
		"agent", a.Name(), "added", added)

	// Emit updated tool count to the TUI immediately.
	events.Emit(ToolsetInfo(len(updated), false, a.Name()))
}