core

type AuthContext struct {
	UserID int64

	// SessionID is the session id for authorizations via session tokens.
	SessionID *int64

	// ForwardAuth is true if the request was forwarded from a reverse proxy.
	ForwardAuth bool
}

type Channel struct {
	ID      string `json:"id"`
	Enabled bool   `json:"enabled"`
	Name    string `json:"name"`
	Number  int    `json:"number"`
	PiconID int    `json:"piconId"`
}

type ChannelService interface {
	// GetAll returns a list of channels.
	GetAll(ctx context.Context, params PaginationSortQueryParams) ([]*Channel, error)
	// Get returns a channel by id.
	Get(ctx context.Context, id string) (*Channel, error)
}

type Clock interface {
	Now() time.Time
}

type CreateRecording struct {
	// Title title of the recording.
	Title string `json:"title"`
	// ExtraText optional extraText of the recording.
	ExtraText string `json:"extraText"`
	// ChannelID the channel id for the recording.
	ChannelID string `json:"channelId"`
	// StartAt start date of the recording as unix timestamp.
	StartsAt int64 `json:"startsAt"`
	// EndsAt end date of the recording as unix timestamp.
	EndsAt int64 `json:"endsAt"`
	// Comment optional comment of the recording.
	Comment string `json:"comment"`
	// StartPadding optional padding in minutes to record
	// before the recording starts.
	StartPadding int `json:"startPadding"`
	// EndPadding optional padding in minutes to record
	// after the recording ends.
	EndPadding int `json:"endPadding"`
	// Priority priority of the recording.
	Priority int `json:"priority"`
	// ConfigID configuration id of the dvr config.
	ConfigID string `json:"configId"`
}

type CreateRecordingByEvent struct {
	EventID  int64  `json:"eventId"`
	ConfigID string `json:"configId"`
}

type EpgChannel struct {
	ChannelID     string      `json:"channelId"`
	ChannelName   string      `json:"channelName"`
	ChannelNumber int64       `json:"channelNumber"`
	PiconID       int         `json:"piconId"`
	Events        []*EpgEvent `json:"events"`
}

type EpgContentType struct {
	ID   int    `json:"id"`
	Name string `json:"string"`
}

type EpgEvent struct {
	ID            int64  `json:"id"`
	AudioDesc     bool   `json:"audioDesc"`
	ChannelID     string `json:"channelId"`
	ChannelName   string `json:"channelName"`
	ChannelNumber int64  `json:"channelNumber"`
	PiconID       int    `json:"piconId"`
	Description   string `json:"description"`
	EndsAt        int64  `json:"endsAt"`
	HD            bool   `json:"hd"`
	NextEventID   int    `json:"nextEventId"`
	StartsAt      int64  `json:"startsAt"`
	Subtitle      string `json:"subtitle"`
	Subtitled     bool   `json:"subtitled"`
	Title         string `json:"title"`
	Widescreen    bool   `json:"widescreen"`
	DvrUUID       string `json:"dvrUuid,omitempty"`
	DvrState      string `json:"dvrState,omitempty"`
}

type EpgEventsResult = ListResult[*EpgEvent]

type EpgService interface {
	// GetEpg returns the epg (events for each channel).
	GetEpg(ctx context.Context, params GetEpgQueryParams) ([]*EpgChannel, error)

	// GetEvents returns a list of epg events.
	GetEvents(ctx context.Context, params GetEpgEventsQueryParams) (*EpgEventsResult, error)

	// GetEvent returns a epg event.
	GetEvent(ctx context.Context, id int64) (*EpgEvent, error)

	// GetRelatedEvents returns a list of epg related events for a given event.
	GetRelatedEvents(
		ctx context.Context,
		eventId int64,
		params PaginationSortQueryParams,
	) (*EpgEventsResult, error)

	// GetContentTypes returns a list of epg content types.
	GetContentTypes(ctx context.Context) ([]*EpgContentType, error)
}

type GetEpgEventsQueryParams struct {
	PaginationSortQueryParams
	Title      string `schema:"title"`
	FullText   bool   `schema:"fullText"`
	Language   string `schema:"lang"`
	NowPlaying bool   `schema:"nowPlaying"`
	// Channel name or id of the channel.
	Channel     string `schema:"channel"`
	ContentType string `schema:"contentType"`
	DurationMin int64  `schema:"durationMin"`
	DurationMax int64  `schema:"durationMax"`
	StartsAt    int64  `schema:"startsAt"`
	EndsAt      int64  `schema:"endsAt"`
}

type GetEpgQueryParams struct {
	SortQueryParams
	StartsAt int64 `schema:"startsAt"`
	EndsAt   int64 `schema:"endsAt"`
}

type GetRecordingsParams struct {
	PaginationSortQueryParams
	// upcoming, finished, failed, removed
	Status string `schema:"status"`
}

type InvalidOrExpiredTokenError struct {
	// Reason is the reason why the token is invalid or expired.
	Reason error
}

type ListResult[T any] struct {
	Entries []T   `json:"entries"`
	Total   int64 `json:"total"`
	Offset  int64 `json:"offset"`
}

type PaginationQueryParams struct {
	// (Optional) Limit the result.
	Limit int64 `schema:"limit"`
	// (Optional) Offset the result.
	Offset int64 `schema:"offset"`
}

type PaginationSortQueryParams struct {
	PaginationQueryParams
	SortQueryParams
}

type PasswordAuthenticator interface {
	// Login logs in a user via login, password and optional totp code.
	Login(ctx context.Context, login string, username string, totp *string) (*User, error)

	// ConfirmPassword confirms the password of a user.
	ConfirmPassword(ctx context.Context, userID int64, password string) error
}

type PiconService interface {
	// GetPicon returns the picon of a channel.
	Get(ctx context.Context, id int) (io.Reader, error)
}

type Recording struct {
	ChannelID string `json:"channelId"`
	// ID of the event when the recordings was created by event.
	EventID     int64             `json:"eventId,omitempty"`
	ChannelName string            `json:"channelName"`
	PiconID     int               `json:"piconId"`
	CreatedAt   int64             `json:"createdAt"`
	Duration    int64             `json:"duration"`
	Enabled     bool              `json:"enabled"`
	Filename    string            `json:"filename"`
	ID          string            `json:"id"`
	LangTitle   map[string]string `json:"langTitle"`
	Title       string            `json:"title"`
	Subtitle    string            `json:"subtitle"`
	Description string            `json:"description"`
	ExtraText   string            `json:"extraText"`
	// OriginalStartsAt time stamp of the original start date
	// without StartPadding.
	OriginalStartsAt int64 `json:"originalStartsAt"`
	// OriginalEndsAt time stamp of the original end date
	// without theEndPadding.
	OriginalEndsAt int64 `json:"originalEndsAt"`
	// StartAt start date of the recording as unix timestamp.
	StartsAt int64 `json:"startsAt"`
	// EndsAt end date of the recording as unix timestamp.
	EndsAt int64 `json:"endsAt"`
	// StartPadding optional padding in minutes to record
	// before the recording starts.
	StartPadding int `json:"startPadding"`
	// EndPadding optional padding in minutes to record
	// after the recording ends.
	EndPadding int    `json:"endPadding"`
	Status     string `json:"status"`
}

type RecordingListResult = ListResult[*Recording]

type RecordingService interface {
	// CreateByEvent creates a new recording by an epg event.
	CreateByEvent(ctx context.Context, opts CreateRecordingByEvent) error

	// CreateByEvent creates a new recording by an epg event.
	Create(ctx context.Context, opts CreateRecording) error

	// GetAll returns a list of recordings.
	GetAll(ctx context.Context, params GetRecordingsParams) (*RecordingListResult, error)

	// Get returns a recording by its id.
	Get(ctx context.Context, id string) (*Recording, error)

	// Stop gracefully stops a running recording.
	Stop(ctx context.Context, id string) error

	// BatchStop gracefully stops running recordings.
	BatchStop(ctx context.Context, ids []string) error

	// Cancel deletes a upcoming recording or aborts a running recording.
	Cancel(ctx context.Context, id string) error

	// BatchCancel deletes multiple upcoming recordings or aborts running recordings.
	BatchCancel(ctx context.Context, ids []string) error

	// Remove removes a finished recording from disk.
	Remove(ctx context.Context, id string) error

	// BatchRemove removes multiple recordings from disk.
	BatchRemove(ctx context.Context, ids []string) error

	// MoveFinished moves a recording to finished status.
	MoveFinished(ctx context.Context, id string) error

	// MoveFailed moves a recording to failed status.
	MoveFailed(ctx context.Context, id string) error

	// UpdateRecording updates a recording.
	UpdateRecording(ctx context.Context, id string, opts UpdateRecording) error
}

type Session struct {
	ID          int64  `json:"id"`
	UserId      int64  `json:"userId"`
	HashedToken string `json:"-"`
	ClientIP    string `json:"clientIp"`
	UserAgent   string `json:"userAgent"`
	CreatedAt   int64  `json:"createdAt"`
	LastUsedAt  int64  `json:"lastUsedAt"`
	RotatedAt   int64  `json:"-"`
}

type SessionManager interface {
	// Validate validates a session and updates the last usage and rotates the token if needed.
	// The rotated token is returned as second return value when the token was rotated.
	Validate(ctx context.Context, token string) (*AuthContext, *string, error)
	// Create creates a new session for a user with a client ip and a user agent.
	Create(ctx context.Context, userId int64, clientIp string, userAgent string) (string, error)
	// Revoke revokes a specific session.
	Revoke(ctx context.Context, sessionID int64, userID int64) error
}

type SessionRepository interface {
	// Find returns a sessions.
	Find(ctx context.Context, hashedToken string) (*Session, error)

	// FindByUser returns a list of sessions for a user.
	FindByUser(ctx context.Context, userID int64) ([]*Session, error)

	// Create persists a new session.
	Create(ctx context.Context, session *Session) error

	// Create persists a updated session.
	Update(ctx context.Context, session *Session) error

	// Delete deletes a session.
	Delete(ctx context.Context, sessionID int64, userID int64) error

	// DeleteExpired deletes all expired sessions.
	DeleteExpired(
		ctx context.Context,
		expirationDate int64,
		inactiveExpirationDate int64,
	) (int64, error)
}

type SortQueryParams struct {
	// (Optional) Sort key.
	SortKey string `schema:"sort_key"`
	// (Optional) Sort direction.
	SortDirection string `schema:"sort_dir"`
}

type StreamingService interface {
	// GetChannelStream returns a raw http response of the channel stream.
	GetChannelStream(
		ctx context.Context,
		channelNumber int64,
		profile string,
	) (*http.Response, error)

	// GetRecordingStream returns a raw http response of the recording stream.
	GetRecordingStream(ctx context.Context, recordingId string) (*http.Response, error)
}

type Token struct {
	ID          int64  `json:"id"`
	UserID      int64  `json:"-"`
	Name        string `json:"name"`
	HashedToken string `json:"-"`
	CreatedAt   int64  `json:"createdAt"`
	UpdatedAt   int64  `json:"updatedAt"`
}

type TokenRepository interface {
	// FindByToken returns a Token by a the hashed token.
	FindByToken(ctx context.Context, token string) (*Token, error)

	// FindByUser returns all token for a user.
	FindByUser(ctx context.Context, userID int64) ([]*Token, error)

	// Create persists a new Token.
	Create(ctx context.Context, token *Token) error

	// Delete deletes a Token.
	Delete(ctx context.Context, token *Token) error
}

type TokenService interface {
	// Create creates a new token for a user.
	Create(ctx context.Context, userID int64, name string) (string, error)

	// Validate validates a token.
	Validate(ctx context.Context, token string) (*AuthContext, error)

	// Revoke revokes a token.
	Revoke(ctx context.Context, id int64) error
}

type TwoFactorAuthService interface {
	// GetSettings returns the current two factor settings for a user.
	GetSettings(ctx context.Context, userId int64) (*TwoFactorSettings, error)

	// Setup starts the setup process for two factor auth for a user.
	Setup(ctx context.Context, userId int64) (string, error)

	// Deactivate deactivates two factor auth for a user.
	Deactivate(ctx context.Context, userId int64, code string) error

	// Activate activates two factor auth for a user.
	Activate(ctx context.Context, userID int64, code string) error

	// Verify verifies a two factor code for a user.
	Verify(ctx context.Context, userId int64, code *string) error
}

type TwoFactorSettings struct {
	UserID    int64  `json:"-"`
	Secret    string `json:"-"`
	Enabled   bool   `json:"enabled"`
	CreatedAt int64  `json:"-"`
	UpdatedAt int64  `json:"-"`
}

type TwoFactorSettingsRepository interface {
	// Find returns two factor settings by a user id.
	Find(ctx context.Context, userID int64) (*TwoFactorSettings, error)

	// Create persists new two factor settings.
	Create(ctx context.Context, settings *TwoFactorSettings) error

	// Delete deletes two factor settings.
	Delete(ctx context.Context, settings *TwoFactorSettings) error

	Update(ctx context.Context, settings *TwoFactorSettings) error

	Save(ctx context.Context, settings *TwoFactorSettings) error
}

type UpdateRecording struct {
	// Title title of the recording.
	Title *string `json:"title"`
	// ExtraText optional extraText of the recording.
	ExtraText *string `json:"extraText"`
	// StartAt start date of the recording as unix timestamp.
	StartsAt *int64 `json:"startsAt"`
	// EndsAt end date of the recording as unix timestamp.
	EndsAt *int64 `json:"endsAt"`
	// Comment optional comment of the recording.
	Comment *string `json:"comment"`
	// StartPadding optional padding in minutes to record
	// before the recording starts.
	StartPadding *int `json:"startPadding"`
	// EndPadding optional padding in minutes to record
	// after the recording ends.
	EndPadding *int `json:"endPadding"`
	// Priority priority of the recording.
	Priority *int `json:"priority"`
	// Enabled enabled status of the recording.
	Enabled *bool `json:"enabled"`
	// Episode episode of the recording.
	Episode *string `json:"episode"`
}

type User struct {
	ID       int64  `json:"id"`
	Username string `json:"username"`
	// PasswordHash hash of the users password
	PasswordHash string `json:"-"`
	Email        string `json:"email"`
	DisplayName  string `json:"displayName"`
	CreatedAt    int64  `json:"createdAt"`
	UpdatedAt    int64  `json:"updatedAt"`
}

type UserQueryParams struct {
	// (Optional) Limit the result.
	Limit int64
	// (Optional) Offset the result.
	// Can only be used together with Limit.
	Offset int64
}

type UserRepository interface {
	// FindById returns a user by id.
	FindById(ctx context.Context, id int64) (*User, error)

	// FindByUsername returns a user by username.
	FindByUsername(ctx context.Context, user string) (*User, error)

	// Find returns a list of users paginated by UserQueryParams.
	Find(ctx context.Context, params UserQueryParams) ([]*User, error)

	// Create persists a new user.
	Create(ctx context.Context, user *User) error

	// Update persists an updated user.
	Update(ctx context.Context, user *User) error

	// Delete deletes a user.
	Delete(ctx context.Context, user *User) error
}