sessionrun

type ListDependencies struct {
	Directory func(string) (string, error)
	Records   func(string) ([]session.View, error)
	Worktrees func(context.Context, worktrees.ListOptions) ([]worktrees.ListResult, error)
	Home      func(string) (string, error)
	Waits     func(string, waitregistry.Options) ([]waitregistry.Record, error)
}

type ListRequest struct {
	ProjectsRoot string
	OnlyLive     bool
}

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

type MessageDependencies struct {
	ResolveSource func(string) (session.Record, bool, error)
	Store         func(string) (sessionmove.Store, error)
	NewMessageID  func() (string, error)
	Send          func(context.Context, sessionmessenger.Options) (sessionmessenger.Result, error)
	Now           func() time.Time
}

type MessageRequest struct {
	ProjectsRoot, Target, Body, ResumeID, RetryVerb string
	Kind                                            sessionmove.MessageKind
}

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

type MoveDependencies struct {
	LoadScanner       func() (*secretscan.Scanner, []string, error)
	DefaultConfigPath func() string
	LoadConfig        func(string) (sessionmove.Config, error)
	LocalMachine      func() (string, error)
	ResolveSource     func(string) (session.Record, bool, error)
	Checkpoint        func(context.Context, worktrees.SessionCheckpointOptions) (worktrees.SessionCheckpointResult, error)
	Store             func(string) (sessionmove.Store, error)
	NewDeliverer      func(sessionmove.TargetConfig, sessionmove.Courier, sessioncourier.SynchestraOptions) (sessioncourier.Deliverer, error)
	LoopbackDeliverer func(sessionmove.Store) sessioncourier.Deliverer
	Acknowledge       func(context.Context, sessioncustody.Options) (sessioncustody.Result, error)
}

type MoveRequest struct {
	ProjectsRoot    string
	Worktree        string
	Target          string
	Via             string
	ConfigPath      string
	Harness         string
	Model           string
	Summary         string
	Validation      string
	Remaining       string
	HandoverFile    string
	Input           io.Reader
	OverrideSecrets []string
	ResumeID        string
}

type MoveResult struct {
	Phase        string                        `json:"phase"`
	Courier      sessionmove.Courier           `json:"courier"`
	SourceActive bool                          `json:"source_active"`
	Request      sessionmove.Request           `json:"request"`
	Digest       sessionmove.Digest            `json:"request_digest"`
	Successor    *sessionlaunch.Result         `json:"successor,omitempty"`
	Receipt      *sessionmove.Receipt          `json:"receipt,omitempty"`
	Address      *sessionmove.SuccessorAddress `json:"successor_address,omitempty"`
	Resume       bool                          `json:"-"`
}

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

type ParkDependencies struct {
	Directory     func(string) (string, error)
	Home          func(string) (string, error)
	PID           func() int
	ResolveSource func(string, int, session.AutoRegisterHints) (session.Record, bool, error)
	List          func(context.Context, worktrees.ListOptions) ([]worktrees.ListResult, error)
	Store         func(string) sessionpark.Store
	Capture       func(context.Context, string, []worktrees.ListResult, session.Record, func([]sessionpark.Worktree) error) error
	NewID         func() (string, error)
	Now           func() time.Time
	MarkParked    func(string, int, string) (session.Record, error)
	LoadScanner   func() (*secretscan.Scanner, []string, error)
}

type ParkOutput struct {
	ParkedSessionID string `json:"parked_session_id"`
	Status          string `json:"status"`
	MemberCount     int    `json:"member_count"`
	// WBSessionID names the parked source session, and RegisteredAtPark says
	// whether park had to register it first. A caller that never ran
	// `wb session register` learns its own identity from exactly here.
	WBSessionID      string `json:"wb_session_id"`
	RegisteredAtPark bool   `json:"registered_at_park"`
}

type ParkRegistration struct {
	PID            int
	Runtime, Model string
}

type ParkRequest struct {
	ProjectsRoot, Runtime, Model, WBSessionID string
	PID                                       int
	Continuation                              []byte
	OverrideSecrets                           []string
}

type ParkResult struct {
	Output       ParkOutput
	Warnings     []secretscan.Finding
	Registration ParkRegistration
}

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

type PruneDependencies struct {
	Directory func(string) (string, error)
	Prune     func(string) (int, error)
}

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

type ReceiveDependencies struct {
	LocalMachine func() (string, error)
	Store        func(string) (sessionmove.Store, error)
	Receive      func(context.Context, sessionreceive.Options) (sessionreceive.Result, error)
}

type ReceiveMessageDependencies struct {
	LocalMachine func() (string, error)
	Store        func(string) (sessionmove.Store, error)
	Receive      func(context.Context, sessionmessage.Options) (sessionmessage.Result, error)
	Directory    func(string) (string, error)
}

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

type ReceiveParkDependencies struct {
	LocalMachine func() (string, error)
	Store        func(string) (sessionpark.TargetStore, error)
	Receive      func(context.Context, sessionparkreceive.Options) (sessionparkreceive.Result, error)
}

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

type ReceiveRequest struct {
	ProjectsRoot string
	Raw          []byte
}

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

type RegisterDependencies struct {
	CurrentPID     func() int
	ParentPID      func() int
	RuntimeProcess func(int, string) bool
	Directory      func(string) (string, error)
	Register       func(string, session.Record) (session.Record, error)
}

type RegisterRequest struct {
	ProjectsRoot string
	Record       session.Record
}

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

type ResumeDependencies struct {
	Home func(string) (string, error)

	Now               func() time.Time
	DeliverSSH        func(context.Context, sessionmove.SSHConfig, []byte, sessionparkcourier.Options) (sessionparkcourier.Result, error)
	WithRemoteCustody func(context.Context, string, sessionpark.Bundle, func() error) error
	WithLocalCustody  func(context.Context, string, sessionpark.Bundle, string, func(*worktrees.ParkedLocalCustody) error) error
	AttachLocal       func(context.Context, *worktrees.ParkedLocalCustody, session.Record, string, uint64) error
	StartLocal        func(context.Context, sessionlaunch.Options) (sessionlaunch.Result, error)
	InspectLocal      func(context.Context, sessionlaunch.Options) (sessionlaunch.Result, error)
	InspectPrepared   func(context.Context, sessionlaunch.Options) (string, error)
	AfterLocalLaunch  func(sessionlaunch.Result) error
	MarkResumed       func(string, int, string, string) (session.Record, error)
	PreflightLocal    func(session.Record) error
}

type ResumeRequest struct {
	ProjectsRoot, ParkedSessionID, Target, Via, ConfigPath string
	Stderr                                                 io.Writer
}

type ResumeResult struct {
	ParkedSessionID      string             `json:"parked_session_id"`
	Status               string             `json:"status"`
	TargetMachine        string             `json:"target_machine"`
	SuccessorWBSessionID string             `json:"successor_wb_session_id"`
	MemberCount          int                `json:"member_count"`
	ReceiptDigest        sessionmove.Digest `json:"receipt_digest,omitempty"`
	Replay               bool               `json:"replay"`
}

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

type Row struct {
	session.View
	Efforts   []string `json:"efforts"`
	Worktrees []string `json:"worktrees"`
	Branches  []string `json:"branches"`
	// Waiting is what this session has delegated to WB and is still blocked
	// on. Without it a session that correctly delegated its waiting is
	// indistinguishable from one that stopped.
	Waiting []string `json:"waiting,omitempty"`
}