machinechannel

type ConnectedSessionRecord struct {
	MachineID        uuid.UUID
	SessionID        string
	ConnectedAt      time.Time
	SystemInfo       domain.SystemInfo
	ToolInventory    []domain.ToolInfo
	ResourceSnapshot *domain.ResourceSnapshot
	WebsocketHealth  *domain.WebsocketHealth
}

type CreateTokenRecord struct {
	MachineID uuid.UUID
	TokenHash string
	ExpiresAt time.Time
}

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

type DisconnectedSessionRecord struct {
	MachineID      uuid.UUID
	SessionID      string
	DisconnectedAt time.Time
	Reason         string
}

type ExpiredSession struct {
	MachineID      uuid.UUID
	SessionID      string
	DisconnectedAt time.Time
}

type HeartbeatRecord struct {
	MachineID        uuid.UUID
	SessionID        string
	HeartbeatAt      time.Time
	SystemInfo       *domain.SystemInfo
	ToolInventory    []domain.ToolInfo
	ResourceSnapshot *domain.ResourceSnapshot
	WebsocketHealth  *domain.WebsocketHealth
}

type MachineRecord struct {
	ID                    uuid.UUID
	OrganizationID        uuid.UUID
	Name                  string
	ConnectionMode        string
	ReachabilityMode      string
	ExecutionMode         string
	Status                string
	ChannelCredentialKind string
	ChannelTokenID        *string
}

type RegisteredSession struct {
	MachineID       uuid.UUID
	SessionID       string
	ConnectedAt     time.Time
	LastHeartbeatAt time.Time
	Replaced        bool
	// contains filtered or unexported fields
}

type Repository interface {
	GetMachine(ctx context.Context, machineID uuid.UUID) (MachineRecord, error)
	IssueToken(ctx context.Context, input CreateTokenRecord) (TokenRecord, error)
	TokenByHash(ctx context.Context, tokenHash string) (TokenRecord, error)
	TouchTokenLastUsed(ctx context.Context, tokenID uuid.UUID, usedAt time.Time) error
	RevokeToken(ctx context.Context, machineID uuid.UUID, tokenID uuid.UUID, revokedAt time.Time) error
	RecordConnectedSession(ctx context.Context, input ConnectedSessionRecord) (MachineRecord, error)
	RecordHeartbeat(ctx context.Context, input HeartbeatRecord) (MachineRecord, error)
	RecordDisconnectedSession(ctx context.Context, input DisconnectedSessionRecord) (MachineRecord, error)
}

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

type SessionCloser interface {
	Close(reason string) error
}

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

type TokenRecord struct {
	TokenID   uuid.UUID
	MachineID uuid.UUID
	TokenHash string
	Status    string
	ExpiresAt time.Time
	RevokedAt *time.Time
}