console

type AppConsoleDeviceService interface {
	GetDevice(ctx context.Context, orgId uuid.UUID, name string) (*domain.Device, domain.Status)
	UpdateDevice(ctx context.Context, orgId uuid.UUID, name string, device domain.Device, fieldsToUnset []string) (*domain.Device, error)
}

type AppConsoleSession struct {
	UUID       string
	OrgId      uuid.UUID
	DeviceName string
	AppName    string
	SendCh     chan []byte
	RecvCh     chan []byte
	ProtocolCh chan string
	// ErrCh carries a session-level failure reported by the agent (e.g. the requested
	// application does not exist). The WebSocket handler must close the client
	// connection with a distinguishable close code/reason instead of relaying this as
	// console payload data.
	ErrCh chan string
}

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

type AppConsoleSessionRegistration interface {
	StartSession(session *AppConsoleSession) error
	CloseSession(session *AppConsoleSession) error
}

type ConsoleEventNotifier interface {
	NotifyConsole(ctx context.Context, orgId uuid.UUID, name string) error
	ClearConsoleNotification(ctx context.Context, orgId uuid.UUID, name string) error
}

type ConsoleSession struct {
	UUID       string
	OrgId      uuid.UUID
	DeviceName string
	SendCh     chan []byte
	RecvCh     chan []byte
	ProtocolCh chan string
}

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

type InternalSessionRegistration interface {
	// Register a session with a given UUID and channels
	// Those channels will be used to read from and write to the session
	// in a way that this interface down to the gRPC session is abstracted
	StartSession(*ConsoleSession) error
	CloseSession(*ConsoleSession) error
}