api

type API struct {
	Sessions  *Sessions
	Config    *Config
	Scans     *Scans
	SCO       *SCO
	Agents    AgentReader
	Status    StatusReader
	ServerURL string
}

type AgentReader interface {
	List() []*types.AgentView
	Count() int
}

type ApplicationBackends struct {
	Sessions *Sessions
	Scans    *Scans
	Commands CommandExecutor
	Files    FileUploader
	PTY      PTYRouter
	NewID    func() string
}

type ApplicationConnection interface {
	Context() context.Context
	Send(*aop.Envelope) error
	Run(*aop.Envelope, func(context.Context, *aop.Envelope, aop.SendFunc) error) error
}

type ArtifactNormalizer interface {
	NormalizeArtifact(context.Context, string, string, []byte) (uint64, uint64, error)
	SupportedArtifacts() []string
}

type Code string

type CommandExecutor interface {
	ExecuteSessionCommand(sessionID, line string) (string, error)
}

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

type ConfigOptions struct {
	Store     ConfigStore
	Build     func(context.Context, *PreparedConfig) (*runner.App, error)
	Apply     func(*runner.App)
	Broadcast func(*types.DistributeConfig)
}

type ConfigStore interface {
	GetDistributeConfig(context.Context) (string, bool, *types.DistributeConfig, error)
	PrepareDistributeConfig(context.Context, *types.DistributeConfig) (*PreparedConfig, error)
	CommitDistributeConfig(context.Context, *PreparedConfig) error
	DiscardDistributeConfig(*PreparedConfig)
}

type Error struct {
	Code Code
	Err  error
}

type FileUploader interface {
	Upload(ctx context.Context, sessionID, filename string, data []byte) (*filepb.Result, error)
}

type PTYRouter interface {
	SubscribePTY(nodeID, streamID string) (<-chan *ptypb.ProtocolMessage, bool, func())
	ForwardPTY(nodeID string, message *ptypb.ProtocolMessage) error
	ClosePTY(nodeID, streamID string)
}

type PreparedConfig struct {
	Config      *types.DistributeConfig
	RuntimePath string
	TargetPath  string
}

type RequestJournal interface {
	LoadAOPRequest(context.Context, string, string, []byte, proto.Message) (bool, bool, error)
	SaveAOPRequest(context.Context, string, string, []byte, proto.Message) error
}

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

type SCOStore interface {
	ListSCONodesByScanID(context.Context, string, string, int) ([]json.RawMessage, error)
	GetSCONode(context.Context, string) (json.RawMessage, error)
	SCONodeStats(context.Context) (map[string]int, error)
	DeleteSCONodesByScan(context.Context, string) error
	UpsertSCONodes(context.Context, string, []json.RawMessage) error
}

type ScanBackend interface {
	SubmitScan(context.Context, string, string, bool, bool, bool) (*types.Scan, error)
	GetScan(context.Context, string) (*types.Scan, error)
	ListScans(context.Context) ([]*types.Scan, error)
	CancelScan(string) error
	GetReport(context.Context, string, string) (string, error)
}

type ScanEvents interface {
	SubscribeScan(string) (<-chan *types.ScanEvent, uint64, func())
}

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

type SessionRuntime interface {
	AgentInfo(string) (string, bool)
	GetScan(context.Context, string) (*types.Scan, error)
	OpenAgentSession(context.Context, string, *aop.OpenSessionRequest) error
	CloseAgentSession(context.Context, string, string, *aop.CloseSessionRequest) (bool, error)
	StartAgentTurn(string, *aop.RunTurnRequest)
	CancelTurn(context.Context, string, string) error
	PublishUserMessage(string, string, *aop.Message)
	BroadcastAOPEvent(string, *aop.Event)
	SubscribeSessionEvents(string) (<-chan *aop.EventDelivery, func())
	DeleteSession(context.Context, string) error
	SessionMenu(string) []*types.CommandSpec
}

type SessionStore interface {
	RequestJournal
	ListSessionPage(context.Context, int, int, bool) ([]*types.SessionRecord, bool, error)
	GetSession(context.Context, string) (*types.SessionRecord, error)
	CreateSession(context.Context, *types.SessionRecord) error
	UpdateSession(context.Context, *types.SessionRecord) error
	DeleteSession(context.Context, string) error
	LinkScanToSession(context.Context, string, string) error
	ListAOPEventsAfter(context.Context, string, int64, int) ([]*aop.EventDelivery, error)
}

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

type StatusReader interface {
	Status() *types.SystemStatus
}