db

type APIKey struct {
	Id        Id
	UserId    Id
	Name      string
	Key       string
	ExpiresAt *time.Time
	CreatedAt time.Time
	UpdatedAt time.Time
}

type APIKeyRepository interface {
	Create(apiKey *APIKey) error
	GetById(id Id) (*APIKey, error)
	GetByKey(key string) (*APIKey, error)
	ListByUserId(userId Id, limit, offset int) ([]*APIKey, error)
	Delete(id Id) error
	DeleteExpired() (int64, error)
	Count() (int64, error)
	CountByUserId(userId Id) (int64, error)
}

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

type AsyncTask struct {
	Id          Id
	Type        string
	Status      string
	Payload     *string
	Result      *string
	Error       *string
	Attempts    int
	Priority    int
	RunAt       *time.Time
	LockedAt    *time.Time
	CompletedAt *time.Time
	CreatedAt   time.Time
	UpdatedAt   time.Time
}

type AsyncTaskMeta struct {
	Id          Id
	AsyncTaskId Id
	Key         string
	Value       string
	CreatedAt   time.Time
	UpdatedAt   time.Time
}

type AsyncTaskMetaRepository interface {
	Create(id Id, key, value string) error
	Get(id Id, key string) (*AsyncTaskMeta, error)
	Update(id Id, key, value string) error
	Delete(id Id, key string) error
	ListByAsyncTaskId(id Id) ([]*AsyncTaskMeta, error)
	Upsert(id Id, key, value string) error
}

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

type AsyncTaskRepository interface {
	Create(task *AsyncTask) error
	MarkRunning(id Id) error
	Complete(id Id, result string) error
	Fail(id Id, message string) error
	CountByStatus(status string) (int64, error)
	ListByStatus(status string) ([]*AsyncTask, error)
}

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

type Config struct {
	Id        Id
	Key       string
	Value     string
	CreatedAt time.Time
	UpdatedAt time.Time
}

type ConfigRepository interface {
	Create(key, value string) error
	Get(key string) (*Config, error)
	Update(key, value string) error
	Delete(key string) error
	List() ([]*Config, error)
}

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

type Connection struct {
	DB     *sql.DB
	Driver string
}

type DatabaseConfig struct {
	Driver          string
	Host            string
	Port            int
	Username        string
	Password        string
	Database        string
	MaxOpenConns    int
	MaxIdleConns    int
	ConnMaxLifetime int
}

type Id string

type Session struct {
	Id        Id
	Token     string
	UserId    Id
	IPAddress *string
	UserAgent *string
	ExpiresAt time.Time
	CreatedAt time.Time
	UpdatedAt time.Time
}

type SessionRepository interface {
	Create(session *Session) error
	GetByToken(token string) (*Session, error)
	GetById(id Id) (*Session, error)
	GetByUserId(userId Id) ([]*Session, error)
	Delete(id Id) error
	DeleteByToken(token string) error
	DeleteByUserId(userId Id) error
	DeleteExpired() (int64, error)
	IsValid(token string) (bool, error)
	UpdateExpiration(id Id, expiresAt time.Time) error
	Count() (int64, error)
	CountByUserId(userId Id) (int64, error)
}

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

type User struct {
	Id          Id
	Name        string
	Email       string
	Password    string
	Role        string
	IsActive    bool
	LastLoginAt time.Time
	Language    string
	Theme       string
	CreatedAt   time.Time
	UpdatedAt   time.Time
}

type UserMeta struct {
	Id        Id
	Key       string
	Value     string
	UserId    Id
	CreatedAt time.Time
	UpdatedAt time.Time
}

type UserMetaRepository interface {
	Create(id Id, key, value string) error
	Get(id Id, key string) (*UserMeta, error)
	Update(id Id, key, value string) error
	Delete(id Id, key string) error
	ListByUser(id Id) ([]*UserMeta, error)
	Upsert(id Id, key, value string) error
}

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

type UserRepository interface {
	Create(user *User) error
	GetById(id Id) (*User, error)
	GetByAPIKey(apiKey string) (*User, error)
	GetByEmail(email string) (*User, error)
	Update(user *User) error
	UpdateLastLogin(id Id) error
	Delete(id Id) error
	List(limit, offset int) ([]*User, error)
	Count() (int64, error)
}

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