domain

type AccessToken struct {
	Id             uuid.UUID `json:"id"`
	UserId         uuid.UUID `json:"user_id"`
	RefreshTokenId uuid.UUID `json:"refresh_token_id"`
	CreateTime     time.Time `json:"create_time"`
	UpdateTime     time.Time `json:"update_time"`
}

type AccessTokenCacheDs interface {
	GetAccessTokenById(ctx context.Context, id uuid.UUID) (*AccessToken, error)
	CreateAccessToken(ctx context.Context, accessToken *AccessToken) error
	DeleteAccessToken(ctx context.Context, id uuid.UUID) error
}

type AccessTokenDatabaseDs interface {
	GetAccessTokenById(ctx context.Context, id uuid.UUID) (*AccessToken, error)
	CreateAccessToken(ctx context.Context, tx *sql.Tx, accessToken *AccessToken) (*AccessToken, error)
	DeleteAccessTokenByUserId(ctx context.Context, tx *sql.Tx, userId uuid.UUID) (*uuid.UUID, error)
}

type AccessTokenRepository interface {
	GetAccessToken(ctx context.Context, id uuid.UUID) (*AccessToken, error)
	CreateAccessToken(ctx context.Context, tx *sql.Tx, userId uuid.UUID, refreshTokenId uuid.UUID) (*AccessToken, error)
	DeleteAccessTokenByUserId(ctx context.Context, tx *sql.Tx, userId uuid.UUID) error
}

type CustomClaims struct {
	UserID string `json:"user_id"`
	jwt.StandardClaims
}

type File struct {
	Id            uuid.UUID `json:"id"`
	NoteId        uuid.UUID `json:"note_id"`
	OriginalFile  string    `json:"original_file"`
	ProcessedFile string    `json:"processed_file"`
	Url           string    `json:"url"`
	CreateTime    time.Time `json:"create_time"`
	UpdateTime    time.Time `json:"update_time"`
	DeleteTime    time.Time `json:"delete_time"`
}

type FileDatabaseDs interface {
	ListFilesByNotesIds(ctx context.Context, noteId []uuid.UUID) (*[]File, error)
	ListFilesByNoteId(ctx context.Context, noteId uuid.UUID) (*[]File, error)
	CreateFile(ctx context.Context, tx *sql.Tx, file *File) (*File, error)
	UpdateFileByOriginalId(ctx context.Context, tx *sql.Tx, originalFileId, processFileId string) (*File, error)
	HardDeleteFilesByNoteId(ctx context.Context, tx *sql.Tx, noteId uuid.UUID) (*[]File, error)
}

type FileRepository interface {
	Create(ctx context.Context, tx *sql.Tx, ossFileId, path string, noteID uuid.UUID) (*File, error)
	Update() error
	HardDeleteFiles(ctx context.Context, tx *sql.Tx, files *[]File) error
	ListFilesByNoteId(ctx context.Context, noteId uuid.UUID) (*[]File, error)
	ListFilesByNotesIds(ctx context.Context, noteId []uuid.UUID) (*[]File, error)
	Move() error
	Process(ctx context.Context, tx *sql.Tx, ossFileId string) error
}

type HashDatasource interface {
	// Hash takes a string value and returns its hash representation.
	// It returns an error if the hashing operation fails.
	Hash(value string) (string, error)
	// CheckHash verifies if the given hash matches the hash of the provided value.
	// It returns true if the hash matches, false otherwise.
	CheckHash(value, hash string) (bool, error)
}

type JWTMetadata struct {
	TokenId uuid.UUID
	UserId  uuid.UUID
	Token   string
}

type JwtDatasource interface {
	CreateJWT(tokenMetadata *JWTMetadata, expirationTime time.Time) (*string, error)
	ParseJWT(tokenMetadata *JWTMetadata) error
}

type Note struct {
	Id         uuid.UUID `json:"id"`
	UserId     uuid.UUID `json:"user_id"`
	Title      string    `json:"title"`
	Content    string    `json:"content"`
	Files      []*File   `json:"files"`
	CreateTime time.Time `json:"create_time"`
	UpdateTime time.Time `json:"update_time"`
	DeleteTime time.Time `json:"delete_time"`
}

type NoteCacheDs interface {
	// ListNote(ctx context.Context) (*[]Note, error)
	// GetNote(ctx context.Context, id uuid.UUID) (*Note, error)
	CreateNote(ctx context.Context, note *Note) error
}

type NoteDatabaseDs interface {
	ListNotesByUser(ctx context.Context, user_id uuid.UUID, cursor time.Time) (*[]Note, error)
	ListTrashNotesByUser(ctx context.Context, user_id uuid.UUID, cursor time.Time) (*[]Note, error)
	GetNote(ctx context.Context, id uuid.UUID) (*Note, error)
	CreateNote(ctx context.Context, tx *sql.Tx, note *Note) (*Note, error)
	UpdateNote(ctx context.Context, tx *sql.Tx, note *Note) (*Note, error)
	RestoreNote(ctx context.Context, tx *sql.Tx, id uuid.UUID) (*Note, error)
	HardDeleteNote(ctx context.Context, tx *sql.Tx, id uuid.UUID) error
	SoftDeleteNote(ctx context.Context, tx *sql.Tx, id uuid.UUID) error
}

type NoteRepository interface {
	ListNotesByUser(ctx context.Context, user_id uuid.UUID, cursor time.Time) (*[]Note, error)
	ListTrashNotesByUser(ctx context.Context, user_id uuid.UUID, cursor time.Time) (*[]Note, error)
	// GetNote(ctx context.Context, id uuid.UUID) (*Note, error)
	CreateNote(ctx context.Context, tx *sql.Tx, note *Note) (*Note, error)
	RestoreNote(ctx context.Context, tx *sql.Tx, id uuid.UUID) (*Note, error)
	UpdateNote(ctx context.Context, tx *sql.Tx, note *Note) (*Note, error)
	DeleteNote(ctx context.Context, tx *sql.Tx, id uuid.UUID, isHard bool) error
}

type RefreshToken struct {
	Id         uuid.UUID `json:"id"`
	UserId     uuid.UUID `json:"user_id"`
	CreateTime time.Time `json:"create_time"`
	UpdateTime time.Time `json:"update_time"`
}

type RefreshTokenCacheDs interface {
	GetRefreshToken(ctx context.Context, id uuid.UUID) (*RefreshToken, error)
	CreateRefreshToken(ctx context.Context, refreshToken *RefreshToken) error
	DeleteRefreshToken(ctx context.Context, id uuid.UUID) error
}

type RefreshTokenDatabaseDs interface {
	GetRefreshTokenById(ctx context.Context, id uuid.UUID) (*RefreshToken, error)
	CreateRefreshToken(ctx context.Context, tx *sql.Tx, refreshToken *RefreshToken) (*RefreshToken, error)
	DeleteRefreshTokenByUserId(ctx context.Context, tx *sql.Tx, userId uuid.UUID) (*uuid.UUID, error)
}

type RefreshTokenRepository interface {
	GetRefreshToken(ctx context.Context, id uuid.UUID) (*RefreshToken, error)
	CreateRefreshToken(ctx context.Context, tx *sql.Tx, refreshToken *RefreshToken) (*RefreshToken, error)
	DeleteRefreshTokenByUserId(ctx context.Context, tx *sql.Tx, userId uuid.UUID) error
}

type User struct {
	Id         uuid.UUID `json:"id"`
	Name       string    `json:"name"`
	Email      string    `json:"email"`
	Password   string    `json:"-"`
	CreateTime time.Time `json:"create_time"`
	UpdateTime time.Time `json:"update_time"`
}

type UserCacheDs interface {
	GetUserByEmail(ctx context.Context, email string) (*User, error)
	GetUserById(ctx context.Context, id uuid.UUID) (*User, error)
	CreateUser(ctx context.Context, user *User) error
	UpdateUser(ctx context.Context, user *User) error
	DeleteUser(ctx context.Context, id uuid.UUID) error
}

type UserDatabaseDs interface {
	CreateUser(ctx context.Context, user *User) (*User, error)
	GetUserById(ctx context.Context, id uuid.UUID) (*User, error)
	GetUserByEmail(ctx context.Context, email string) (*User, error)
}

type UserRepository interface {
	CreateUser(ctx context.Context, user *User) (*User, error)
	GetUserById(ctx context.Context, id uuid.UUID) (*User, error)
	GetUserByEmail(ctx context.Context, email string) (*User, error)
}