wingsession

type Authority struct {
	Principal            string
	UserID, Email, Role  string
	DisplayName          string
	Browser              bool
	PublicKey, AuthToken string
	AllowedPaths         []string
	EnforcePaths         bool
	LegacyLocalDefault   bool
	Unsandboxed          bool
	SealedFS             bool
}

type Launch struct {
	Config   *egg.EggConfig
	CWD      string
	Identity eggclient.EggIdentity
	// contains filtered or unexported fields
}

type MCPTaskRecord struct {
	RetentionMillis *int64             `json:"retention_millis"`
	CancelledAt     time.Time          `json:"cancelled_at,omitempty"`
	CancelledResult *egg.RunTurnResult `json:"cancelled_result,omitempty"`
}

type Policy struct {
	Wing  *config.WingConfig
	Egg   *egg.EggConfig
	Keys  []config.AllowKey
	Audit bool
}

type Run struct {
	ID             string            `json:"run_id"`
	SessionID      string            `json:"session_id"`
	RequestKey     string            `json:"idempotency_key,omitempty"`
	SpecHash       string            `json:"spec_hash"`
	Prompt         string            `json:"prompt"`
	OriginalPrompt string            `json:"original_prompt"`
	Agent          string            `json:"agent"`
	Model          string            `json:"model"`
	CWD            string            `json:"cwd"`
	Label          string            `json:"label,omitempty"`
	TimeoutSeconds int               `json:"timeout_seconds"`
	Isolation      string            `json:"isolation"`
	CreatedAt      time.Time         `json:"created_at"`
	ParentID       string            `json:"parent_id,omitempty"`
	Direction      string            `json:"direction,omitempty"`
	QueueExpiresAt time.Time         `json:"queue_expires_at,omitempty"`
	Launch         RunLaunch         `json:"launch"`
	Phase          string            `json:"phase"`
	Cancelled      bool              `json:"cancelled,omitempty"`
	Result         egg.RunTurnResult `json:"result"`
	MCPTask        *MCPTaskRecord    `json:"mcp_task,omitempty"`
	// contains filtered or unexported fields
}

type RunBackend struct {
	Reserve func(context.Context, *config.Config, eggclient.LocalSession, egg.RunTurnRequest) (egg.RunTurnResult, error)
	Ready   func(context.Context, *config.Config, eggclient.LocalSession) error
	Submit  func(context.Context, *config.Config, eggclient.LocalSession, egg.RunTurnRequest) (egg.RunTurnResult, error)
	Status  func(context.Context, *config.Config, eggclient.LocalSession, string) (egg.RunTurnResult, error)
	Wait    func(context.Context, *config.Config, eggclient.LocalSession, string) (egg.RunTurnResult, error)
	Result  func(context.Context, *config.Config, eggclient.LocalSession, string) (egg.RunTurnResult, error)
	Stop    func(context.Context, *config.Config, eggclient.LocalSession, string) (egg.RunTurnResult, error)
}

type RunEvent struct {
	Cursor                   int64
	Timestamp, Event, Detail string
}

type RunInventory struct {
	WingID           string                   `json:"wing_id"`
	Runs             []store.RunInventoryItem `json:"runs"`
	Count            int                      `json:"count"`
	NextCursor       string                   `json:"next_cursor,omitempty"`
	SnapshotRevision string                   `json:"snapshot_revision"`
	ObservedAt       string                   `json:"observed_at"`
	TerminalSince    string                   `json:"terminal_since"`
}

type RunInventoryRequest struct {
	Limit                 int    `json:"limit,omitempty"`
	Cursor                string `json:"cursor,omitempty"`
	RequestKey            string `json:"idempotency_key,omitempty"`
	TerminalWindowSeconds int    `json:"terminal_window_seconds,omitempty"`
}

type RunLaunch struct {
	Authority  Authority
	Identity   eggclient.EggIdentity
	ConfigYAML string
	Options    StartOptions
	Actor      string
}

type RunRequest struct {
	Prompt, Agent, Model, CWD, Label, RequestKey, ParentID, Direction string
	TimeoutSeconds                                                    int
	MCPTask                                                           *control.MCPTaskParams `json:"mcp_task,omitempty"`
}

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

type Service struct {
	Config     *config.Config
	Home       string
	SharedHost bool
	Policy     func() Policy
	AuthCache  *auth.AuthCache
	Inventory  func(*config.Config) []ws.SessionInfo
	// Spawn is replaceable by isolated protocol fixtures; production uses SpawnEgg.
	Spawn func(*Launch, StartOptions) (*egg.Client, error)
	// Register installs wing input routing before Start acknowledges the egg.
	Register func(string) error

	RunManager *Runs
	RunBackend *RunBackend
	// contains filtered or unexported fields
}

type StartOptions struct {
	SessionID, Agent  string
	Rows, Cols        uint32
	Debug, VTE, Trace bool
	IdleTimeout       time.Duration
	Egg               eggclient.SpawnEggOpts
	Tools             []*config.ToolConfig
}