runner

type Adapter interface {
	Run(context.Context, Request, Callbacks) (Response, error)
	ListModels(context.Context, ModelListRequest) (ModelPage, error)
	Version(context.Context) (string, error)
	Auth(context.Context) (AuthStatus, error)
}

type Antigravity struct {
	Path               string
	Process            ProcessFunc
	InteractiveProcess InteractiveProcessFunc
	Env                []string
}

type AuthStatus struct {
	Authenticated bool   `json:"authenticated"`
	Version       string `json:"version,omitempty"`
	Message       string `json:"message,omitempty"`
	// Account is used only as an in-memory cache discriminator. Catalog cache
	// files persist its hash, never the raw account identifier.
	Account string `json:"-"`
}

type Authenticator interface {
	Login(context.Context, LoginRequest) error
}

type Callbacks struct {
	// SessionStarted must durably record an ID before a fresh call is
	// considered successful. Adapters invoke it as soon as the provider emits
	// its durable session/thread event.
	SessionStarted func(string) error
	Event          func(Event) error
	// Diagnostic receives concise, non-secret launch diagnostics. Adapters do
	// not persist these messages and callers may leave it nil.
	Diagnostic func(string)
}

type CapabilityProber interface {
	Probe(context.Context) error
}

type Claude struct {
	Path               string
	Process            ProcessFunc
	InteractiveProcess InteractiveProcessFunc
	Env                []string
	Custom             []ModelInfo
	PXPipePath         string
	TaskLauncher       PXPipeLauncher
}

type Codex struct {
	Path               string
	Process            ProcessFunc
	InteractiveProcess InteractiveProcessFunc
	Env                []string
	// PXPipePath is discovered once for the adapter, then checked again at
	// launch time so installing/removing the optional helper between turns is
	// safe. TaskLauncher is an injectable lifecycle boundary for tests.
	PXPipePath   string
	TaskLauncher CodexTaskLauncher
	AuthProbe    CodexAuthProbe
	// ModelPages is a deterministic seam for discovery tests. Production uses
	// the app-server model/list protocol when it is nil.
	ModelPages func(context.Context, task.RuntimeSnapshot) ([]ModelInfo, string, string, error)
}

type CodexAuthEvidence struct {
	Mode   CodexAuthMode
	Reason string
}

type CodexAuthMode string

type CodexAuthProbe func(context.Context, string, []string) (CodexAuthEvidence, error)

type CodexTaskLauncher = PXPipeLauncher

type Copilot struct {
	Path               string
	BaseDirectory      string
	InteractiveProcess InteractiveProcessFunc
	Env                []string
	// Discover is a deterministic seam for catalog tests. Production uses the
	// pinned SDK's ListModels method.
	Discover func(context.Context) ([]copilot.ModelInfo, error)
}

type Envelope struct {
	Role      string          `json:"role"`
	Status    string          `json:"status,omitempty"`
	Verdict   string          `json:"verdict,omitempty"`
	Plan      string          `json:"plan,omitempty"`
	Question  string          `json:"question,omitempty"`
	WorkUnits []task.WorkUnit `json:"work_units,omitempty"`
	Findings  []task.Finding  `json:"findings,omitempty"`
}

type Event struct {
	Type      string          `json:"type"`
	SessionID string          `json:"session_id,omitempty"`
	Model     string          `json:"model,omitempty"`
	Effort    string          `json:"effort,omitempty"`
	Raw       json.RawMessage `json:"raw,omitempty"`
}

type Factory func(cliPath, repoRoot string) (Adapter, string, error)

type InteractiveProcessFunc func(context.Context, string, []string, string, []string, io.Reader, io.Writer, io.Writer) error

type LocalAuthHinter interface {
	LocalAuthHint() AuthStatus
}

type LoginRequest struct {
	RepoRoot string
	Stdin    io.Reader
	Stdout   io.Writer
	Stderr   io.Writer
}

type ModelInfo struct {
	ID                     string        `json:"id"`
	Label                  string        `json:"label,omitempty"`
	Description            string        `json:"description,omitempty"`
	Provider               string        `json:"provider"`
	Origin                 string        `json:"origin"`
	Availability           string        `json:"availability"`
	AgeSeconds             int64         `json:"age_seconds,omitempty"`
	ContextWindowTokens    int           `json:"context_window_tokens,omitempty"`
	MaxContextWindowTokens int           `json:"max_context_window_tokens,omitempty"`
	MaxPromptTokens        int           `json:"max_prompt_tokens,omitempty"`
	MaxOutputTokens        int           `json:"max_output_tokens,omitempty"`
	IsDefault              bool          `json:"is_default,omitempty"`
	Efforts                []string      `json:"efforts,omitempty"`
	EffortOptions          []ModelOption `json:"effort_options,omitempty"`
	DefaultEffort          string        `json:"default_effort,omitempty"`
	SpeedOptions           []ModelOption `json:"speed_options,omitempty"`
	DefaultSpeed           string        `json:"default_speed,omitempty"`
	Aliases                []string      `json:"aliases,omitempty"`
	Custom                 bool          `json:"custom"`
	Account                string        `json:"-"`
}

type ModelListRequest struct {
	Refresh bool
	Runtime task.RuntimeSnapshot
}

type ModelOption struct {
	ID          string `json:"id"`
	Label       string `json:"label,omitempty"`
	Description string `json:"description,omitempty"`
}

type ModelPage struct {
	Models     []ModelInfo
	NextCursor string
	Account    string
	Endpoint   string
}

type PXPipeCapabilityCheck func(context.Context, ProcessSpec) error

type PXPipeLaunchError struct {
	BeforeTask bool
	Cause      error
}

type PXPipeLaunchSpec struct {
	PXPipePath         string
	Provider           ProcessSpec
	ProviderName       string
	ServerEnv          []string
	EventsFile         string
	RoutePrefix        string
	TaskStartsOnLaunch bool
	Diagnostic         func(string)
}

type PXPipeLauncher interface {
	Launch(context.Context, PXPipeLaunchSpec) (ProcessResult, error)
}

type PXPipePortChooser func(context.Context) ([]int, error)

type PXPipeServer interface {
	WaitReady(context.Context) error
	Done() <-chan struct{}
	Err() error
	Stop(context.Context) error
}

type PXPipeServerFactory func(context.Context, PXPipeServerSpec) (PXPipeServer, error)

type PXPipeServerSpec struct {
	Path           string
	Env            []string
	Dir            string
	Port           int
	StartupTimeout time.Duration
	Readiness      func(context.Context, string) error
}

type PXPipeTaskLauncher struct {
	Path            string
	Process         ProcessFunc
	ServerFactory   PXPipeServerFactory
	PortChooser     PXPipePortChooser
	CapabilityCheck PXPipeCapabilityCheck
	MaxAttempts     int
	StartupTimeout  time.Duration
	ShutdownTimeout time.Duration
}

type ProcessFunc func(context.Context, ProcessSpec) (ProcessResult, error)

type ProcessResult struct {
	Stdout   []byte
	Stderr   []byte
	ExitCode int
	// ProcessStarted is true only after the OS accepted the child. A false
	// value is reliable evidence that no provider/helper process could run.
	// Injectable ProcessFunc implementations should set it when they start a
	// child before returning a setup error.
	ProcessStarted bool
}

type ProcessSpec struct {
	Path           string
	Args           []string
	Dir            string
	Env            []string
	Stdin          string
	MaxOutputBytes int64
	// StdoutLine is invoked as each complete stdout line arrives. It is used
	// for durable provider session events that must be saved before the child
	// exits. The complete stdout stream is still returned in ProcessResult.
	StdoutLine func([]byte) error
}

type ProviderError struct {
	Code         string `json:"code"`
	Message      string `json:"message"`
	Retryable    bool   `json:"retryable"`
	KnownSession bool   `json:"known_session"`
	SessionID    string `json:"session_id,omitempty"`
	Cause        error  `json:"-"`
}

type Registry struct {
	// contains filtered or unexported fields
}

type Request struct {
	Role      Role
	Operation string
	Prompt    string
	Model     string
	Effort    string
	Speed     string
	RepoRoot  string
	Scope     string
	// SkillDirectories are provider-native roots selected by RoleMux. Adapters
	// that expose an explicit skill-loading API may use them; others rely on
	// their native discovery while receiving the same bounded metadata note.
	SkillDirectories []string
	SessionID        string
	Resume           bool
	Sandbox          string
	Runtime          task.RuntimeSnapshot

	// MaxOutputBytes is a hard process-output bound. Zero uses a safe default.
	MaxOutputBytes int64
}

type Response struct {
	Text           string          `json:"text,omitempty"`
	SessionID      string          `json:"session_id"`
	ReportedModel  string          `json:"reported_model,omitempty"`
	ReportedEffort string          `json:"reported_effort,omitempty"`
	Envelope       *Envelope       `json:"envelope,omitempty"`
	Raw            json.RawMessage `json:"raw,omitempty"`
	Usage          task.TokenUsage `json:"usage,omitempty"`
	// UsageCumulative means token counters cover the whole resumed provider
	// conversation rather than only this invocation.
	UsageCumulative bool `json:"usage_cumulative,omitempty"`
}

type Role string

type RoleSupporter interface {
	SupportsRole(Role) error
}

type TokenUsage = task.TokenUsage