bridge

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

type Command struct {
	Name        string `json:"name"`
	Description string `json:"description,omitempty"`
}

type Completion struct {
	Text   string `json:"text"`
	Label  string `json:"label"`
	Detail string `json:"detail,omitempty"`
}

type Descriptor struct {
	Status     string                `json:"status,omitempty"`
	Model      string                `json:"model,omitempty"`
	Provider   string                `json:"provider,omitempty"` // the model's: two providers may offer one name
	Thinking   string                `json:"thinking,omitempty"`
	Stats      *runtime.SessionStats `json:"stats,omitempty"`
	Usage      *usage.Snapshot       `json:"usage,omitempty"`
	Commands   []Command             `json:"commands,omitempty"`
	Catalog    string                `json:"catalog,omitempty"` // digest of models and commands, which a describe sending it omits
	Waits      bool                  `json:"waits"`             // events.subscribe takes wait: a follower long-polls
	State      string                `json:"state,omitempty"`   // the pulse this describes, read first: a follower waits for a change since
	Models     []bridge.Model        `json:"models,omitempty"`
	Name       string                `json:"name,omitempty"`
	CWD        string                `json:"cwd,omitempty"`
	InstanceID string                `json:"instance_id"`
	Service    string                `json:"service"`
	Generation string                `json:"registration_generation"`
	Target     runtime.ControlTarget `json:"target"`
	Methods    []string              `json:"methods"`
	Input      *runtime.InputRequest `json:"input,omitempty"`
}

type Host interface {
	Session() *runtime.AgentSession
	EnableControl() (*runtime.SessionControl, error)
	ObserveSessions(func(*runtime.AgentSession)) func()
	NewSession(context.Context, *extensions.NewSessionOptions) (extensions.SessionReplacementResult, error)
	SwitchSession(context.Context, string, *runtime.AgentSessionRuntimeSwitchOptions) (extensions.SessionReplacementResult, error)
	Fork(context.Context, string, *extensions.ForkOptions) (runtime.AgentSessionRuntimeForkResult, error)
}

type Options struct {
	Status func(*runtime.AgentSession) string
	// Usage is the plan limits of the session's provider account; nil when it reports none. A new
	// reading moves the pulse, so followers describe again. It is called often and must not block.
	Usage func(*runtime.AgentSession) *usage.Snapshot
	// Complete is what `@query` completes to in a message, as the TUI offers it.
	Complete    func(context.Context, *runtime.AgentSession, string) []Completion
	InstanceID  string
	Store       document.Document
	Authorize   func(bridge.Request) bool
	LedgerQuota int
}