Documentation
¶
Index ¶
- func AppendEventBusFlags(args []string, url, token string) []string
- func ClearProcessHostDriver()
- func Handle(args []string) error
- func NotifyOnOpenPath(kind string, opts EventBusOpts, sessionID, runner, workspace string)
- func NotifyTTYRestarted(opts EventBusOpts, sessionID, runner, workspace, reason string)
- func NotifyTTYStarted(opts EventBusOpts, sessionID, runner, workspace string)
- func NotifyTTYStartedReason(opts EventBusOpts, sessionID, runner, workspace, reason string)
- func RunFocus(args []string, stdout, stderr io.Writer) error
- func RunHelpText() string
- func SetProcessHostDriver(d agentdriver.Driver)
- func WireOnTTYRestarted(opts EventBusOpts) func(agentrunapi.TTYStartedInfo)
- func WireOnTTYStarted(opts EventBusOpts) func(agentrunapi.TTYStartedInfo)
- type EventBusOpts
- type FrontendSource
- type ResolvedFrontend
- type TakeoverDeps
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AppendEventBusFlags ¶ added in v0.0.112
AppendEventBusFlags appends --event-bus-url / --event-bus-token to args when URL is non-empty. Empty URL returns a copy of args unchanged (no flags added). Token is appended only when non-empty.
func ClearProcessHostDriver ¶ added in v0.0.72
func ClearProcessHostDriver()
ClearProcessHostDriver clears the process default (tests).
func Handle ¶
Handle is the full agent-run CLI entrypoint for args after the program name (os.Args[1:]). Same command surface as today's cmd/agent-run: web, run, resume, attach, send, msg, snapshot, watch, sessions, status, kill, tty, pty, top-level help, --agent-runner, and internal serve/stub paths. Success (including help) returns nil; failures return an error for the thin main to print and exit 1.
func NotifyOnOpenPath ¶ added in v0.0.112
func NotifyOnOpenPath(kind string, opts EventBusOpts, sessionID, runner, workspace string)
NotifyOnOpenPath dispatches open-path publish policy:
- "new-terminal" — after successful ForceNew / open-profile → NotifyTTYStarted once
- "send" — live send path → no-op here (library OnTTYRestarted handles follow-up)
func NotifyTTYRestarted ¶ added in v0.0.113
func NotifyTTYRestarted(opts EventBusOpts, sessionID, runner, workspace, reason string)
NotifyTTYRestarted publishes type=agent.tty.restarted source=agent-run with payload {session_id, runner, workspace, reason}. reason should be followup|resume. No AlreadyNotified guard — each restart may re-open local attach.
func NotifyTTYStarted ¶ added in v0.0.112
func NotifyTTYStarted(opts EventBusOpts, sessionID, runner, workspace string)
NotifyTTYStarted publishes type=agent.tty.started source=agent-run with payload {session_id, runner, workspace, reason}. reason defaults to "new". Best-effort: empty URL is a no-op; publish errors write a "warning:" line. When AlreadyNotified is non-nil and *true, skips; after a non-empty-URL publish attempt, sets *true (empty URL does not set).
func NotifyTTYStartedReason ¶ added in v0.0.113
func NotifyTTYStartedReason(opts EventBusOpts, sessionID, runner, workspace, reason string)
NotifyTTYStartedReason is NotifyTTYStarted with an explicit reason field.
func RunFocus ¶ added in v0.0.89
RunFocus implements `agent-run focus` with injectable writers for L2 tests. CLI surface: focus <session-id> [--index N] [--dry-run] [--session-id ID] [-h]
func RunHelpText ¶ added in v0.0.112
func RunHelpText() string
RunHelpText returns the `agent-run run -h` help body (same text flags.Help uses). Always ends with a trailing newline.
func SetProcessHostDriver ¶ added in v0.0.72
func SetProcessHostDriver(d agentdriver.Driver)
SetProcessHostDriver sets the default host Driver for this process when Opts leave Driver zero. Used by embedding hosts (spl agent-run); bare agent-run leaves this unset so serve falls back to agentdriver.DefaultSelf.
func WireOnTTYRestarted ¶ added in v0.0.113
func WireOnTTYRestarted(opts EventBusOpts) func(agentrunapi.TTYStartedInfo)
WireOnTTYRestarted returns a callback for agentrunapi.Opts.OnTTYRestarted. Empty URL → nil. Does not share AlreadyNotified with started.
func WireOnTTYStarted ¶ added in v0.0.113
func WireOnTTYStarted(opts EventBusOpts) func(agentrunapi.TTYStartedInfo)
WireOnTTYStarted returns a callback for agentrunapi.Opts.OnTTYStarted. Empty URL → nil. Uses info.Reason when set, else "new".
Types ¶
type EventBusOpts ¶ added in v0.0.112
type EventBusOpts struct {
URL string
Token string
// PublishHook, when set, replaces the production HTTP publisher (tests).
// Signature matches wire type/source + payload only (no eventbus import in harness).
PublishHook func(ctx context.Context, eventType, source string, payload json.RawMessage) error
// WarnWriter receives best-effort failure lines (prefix "warning:"). Nil → os.Stderr.
WarnWriter io.Writer
// AlreadyNotified, when non-nil, is an at-most-once guard for agent.tty.started only
// (ForceNew NotifyOnOpenPath + library WireOnTTYStarted). Never used for restarted.
// If *true, NotifyTTYStarted skips. After publishing with a non-empty URL, sets *true.
// Empty URL does not set the flag.
AlreadyNotified *bool
}
EventBusOpts configures best-effort publish of agent.tty.* events. Empty URL disables publish (no HTTP, no warning). PublishHook is the L2 inject seam; when nil, production uses eventbus.NewPublisher.
type FrontendSource ¶ added in v0.0.71
type FrontendSource string
FrontendSource names where the SPA tree came from.
const ( FrontendSourceEmbed FrontendSource = "embed" FrontendSourceCache FrontendSource = "cache" FrontendSourceDownload FrontendSource = "download" FrontendSourceA1 FrontendSource = "a1" )
type ResolvedFrontend ¶ added in v0.0.71
type ResolvedFrontend struct {
FS fs.FS
Source FrontendSource
CacheDir string
// EnsureErr is set when download was attempted and failed (A1 fallback).
EnsureErr error
}
ResolvedFrontend is the result of resolveAgentRunFrontend. When Source is FrontendSourceA1, FS is nil and callers should serve the A1 shell.
type TakeoverDeps ¶ added in v0.0.112
type TakeoverDeps struct {
ListProcs func() []procresolve.Proc
Lsof func(pid int) []string
Kill func(pid int, sig syscall.Signal) error
WaitDead func(pid int, timeout time.Duration) bool
OpenIterm func(dir string, followUp string) error
// HooksActive is true when AGENT_RUN_TAKEOVER_TEST_HOOKS was loaded (synthetic PIDs).
HooksActive bool
// ProcsSnapshot is the full ListProcs result used for ancestry walks.
ProcsSnapshot []procresolve.Proc
// KillLog path from hooks file (may be empty).
KillLog string
}
TakeoverDeps injects process/kill/iTerm behavior for tests. When nil fields are present, production defaults are used unless hooks env is set.
Source Files
¶
- assets_cmd.go
- attach_cmd.go
- event_bus.go
- focus_cmd.go
- frontend_resolve.go
- handle.go
- host_driver.go
- kill_cmd.go
- msg_cmd.go
- pty_cmd.go
- resume_cmd.go
- run_cmd.go
- runner_validate.go
- send_cmd.go
- serve_cmd.go
- session_env.go
- session_id.go
- sessions.go
- sessions_list.go
- sessions_print.go
- snapshot_cmd.go
- status.go
- store.go
- takeover_cmd.go
- tty_cmd.go
- watch_cmd.go
- web.go
- web_fixture.go
- web_handlers.go
- web_run_config.go
- web_static.go
- web_terminal.go