probe

func ACPAgentEnvKey ¶

func ACPAgentEnvKey(commandOrKey string) string

ACPAgentEnvKey returns the stable AgentID used by current settings. Legacy EnvKey/Bin/command aliases remain lookup-only migration identifiers.

func ACPAgentEnvKeyPriority ¶

func ACPAgentEnvKeyPriority(savedKey string) (string, int)

ACPAgentEnvKeyPriority reports the stable env key and precedence for a saved settings key. Higher priority wins when normalizing duplicates.

func ACPAgentEnvLookupKeys ¶

func ACPAgentEnvLookupKeys(commandOrKey string) []string

ACPAgentEnvLookupKeys returns the current and historical settings keys that may hold env vars for this agent. New writes should use ACPAgentEnvKey; reads use this list to migrate older command-keyed settings.

func CacheACPConfigState ¶

func CacheACPConfigState(
	command string,
	target model.ACPConfigTarget,
	modelID string,
	modeID string,
	thoughtLevelID string,
	state *model.ACPConfigState,
)

CacheACPConfigState mirrors a successful live-session selector change into the probe cache so later /agent/list requests return the most recently used values. Model/thought updates are scoped to their model key; mode updates do not touch either model-linked field.

func CachedAgentValidation ¶

func CachedAgentValidation(agentID, revision string, envVersion int64) (model.ACPProbeCacheEntry, bool)

func HeadlessBin ¶

func HeadlessBin(command string) (string, bool)

HeadlessBin maps an ACP agent's *serve* command (the string stored in AgentInfo.Type, e.g. "qoderclicn --acp" or "claude-agent-acp") to the binary used to run that same tool in *headless one-shot* mode (e.g. "qoderclicn", "claude").

This distinction matters: an ACP serve command speaks JSON-RPC over stdio and cannot be invoked as `<cmd> -p <prompt>`; doing so just boots the ACP server and exits non-zero. One-shot text flows (title / IM reply) must instead run the agent's plain CLI in print mode, which is exactly what KnownACPAgents already records as Bin. The second return value reports whether command was a recognised ACP agent.

func InitAllowedAgentCommands ¶

func InitAllowedAgentCommands()

InitAllowedAgentCommands registers only the current runtime revision of each installed, active built-in Agent. Historical revisions are retained in the catalog and registered on demand when a session or GraphRun uses them.

Made explicit (rather than an init()) so startup ordering is visible in the entrypoint and tests do not depend on import ordering.

func PickDefaultModeID ¶

func PickDefaultModeID(modes []model.ACPSessionMode) string

PickDefaultModeID selects a default mode from the available modes list, preferring modes with "all", "full", or "bypass" in their ID.

func PreviewSetConfig ¶

func PreviewSetConfig(
	ctx context.Context,
	command string,
	sel PreviewSelection,
	asyncDone func(),
) (*model.ACPConfigState, error)

PreviewSetConfig applies a session-less selector change against the probe cache. Cached state is returned immediately and refreshed asynchronously; only an uncached agent/model pair performs a synchronous ACP probe. Because each target updates only its own cached selection, refreshing a model-linked thought-level list can never reset the cached mode.

func StoreValidation ¶

func StoreValidation(entry model.ACPProbeCacheEntry)

func ValidateAgent ¶

func ValidateAgent(ctx context.Context, binding model.AgentRuntimeBinding, envVersion int64) error

ValidateAgent forces a live ACP validation for the given agent command and updates the in-memory selector cache on success. Unlike the background refresh fan-out it never consults the failure backoff — explicit validation always probes. The probe itself is bounded by acpProbeTimeout.

func ValidateBinding ¶

func ValidateBinding(
	ctx context.Context,
	binding model.AgentRuntimeBinding,
	envVersion int64,
	env []pkgacp.EnvVar,
) (model.ACPProbeCacheEntry, error)

func ValidateBindingCandidate ¶

func ValidateBindingCandidate(
	ctx context.Context,
	binding model.AgentRuntimeBinding,
	envVersion int64,
	env []pkgacp.EnvVar,
) (model.ACPProbeCacheEntry, error)