postgres

Jan 10, 2025

Changes in this version

+ type AdmimRepository struct

+ func (a *AdmimRepository) Create(ctx context.Context, project string, data *api.Key) (*api.Key, error)

+ func (a *AdmimRepository) DeleteLogs(ctx context.Context, project string, to time.Time) (int, error)

+ func (a *AdmimRepository) List(ctx context.Context, project string) ([]*api.Key, error)

+ func (a *AdmimRepository) ListLogs(ctx context.Context, project string, to time.Time) ([]*api.Log, error)

+ func (a *AdmimRepository) Update(ctx context.Context, project string, id string, data map[string]interface{}) (*api.Key, error)

+ func (r *AdmimRepository) AddAdmin(ctx context.Context, key string, user *model.User) error

+ func (r *AdmimRepository) Get(ctx context.Context, user *model.User, id string) (*api.Key, error)

+ func (r *AdmimRepository) GetLogs(ctx context.Context, user *model.User, keyID string) ([]*api.Log, error)

+ func (r *AdmimRepository) Reset(ctx context.Context, project string, since time.Time, limit float64) error

+ func (r *AdmimRepository) RestoreUsage(ctx context.Context, project string, manual bool, request string, ...) error

+ func (r *AdmimRepository) ValidateToken(ctx context.Context, token string) (*model.User, error)

type CMSRepository

+ func (r *CMSRepository) Changes(ctx context.Context, user *model.User, from *time.Time, projects []string) (*api.Changes, error)

Jun 12, 2025

Changes in this version

+ func NewDB(ctx context.Context, dsn string) (*sqlx.DB, error)

+ type AdminRepository struct

+ func NewAdmimRepository(ctx context.Context, db *sqlx.DB, hasher Hasher) (*AdminRepository, error)

+ func (a *AdminRepository) DeleteLogs(ctx context.Context, project string, to time.Time) (int, error)

+ func (a *AdminRepository) List(ctx context.Context, project string) ([]*api.Key, error)

+ func (a *AdminRepository) ListLogs(ctx context.Context, project string, to time.Time) ([]*api.Log, error)

+ func (r *AdminRepository) AddAdmin(ctx context.Context, key string, user *model.User) error

+ func (r *AdminRepository) Get(ctx context.Context, user *model.User, id string) (*api.Key, error)

+ func (r *AdminRepository) GetLogs(ctx context.Context, user *model.User, keyID string) ([]*api.Log, error)

+ func (r *AdminRepository) Reset(ctx context.Context, project string, since time.Time, limit float64) error

+ func (r *AdminRepository) RestoreUsage(ctx context.Context, project string, manual bool, request string, ...) error

+ func (r *AdminRepository) ValidateToken(ctx context.Context, token string, ip string) (*model.User, error)

+ type CMSRepository struct

+ func NewCMSRepository(ctx context.Context, db *sqlx.DB, keySize int, hasher Hasher) (*CMSRepository, error)

+ func (r *CMSRepository) AddCredits(ctx context.Context, user *model.User, id string, in *api.CreditsInput) (*api.Key, error)

+ func (r *CMSRepository) Change(ctx context.Context, user *model.User, id string) (*api.Key, error)

+ func (r *CMSRepository) Create(ctx context.Context, user *model.User, in *api.CreateInput) (*api.Key, bool, error)

+ func (r *CMSRepository) CreatePlain(ctx context.Context, user *model.User, in []*mapi.Key, project string, ...) error

+ func (r *CMSRepository) GetKey(ctx context.Context, user *model.User, id string) (*api.Key, error)

+ func (r *CMSRepository) GetKeyID(ctx context.Context, user *model.User, id string) (*api.KeyID, error)

+ func (r *CMSRepository) Stats(ctx context.Context, user *model.User, in *api.StatParams) ([]*api.Bucket, error)

+ func (r *CMSRepository) Update(ctx context.Context, user *model.User, id string, in *api.UpdateInput) (*api.Key, error)

+ func (r *CMSRepository) Usage(ctx context.Context, user *model.User, id string, from *time.Time, ...) (*api.Usage, error)

+ type Hasher interface

+ HashKey func(key string) string

+ type ProjectSettings struct

+ NextReset time.Time

+ Project string

+ ResetStarted time.Time

+ Updated time.Time

+ type Repository struct

+ func NewRepository(ctx context.Context, db *sqlx.DB, project string, hasher Hasher) (*Repository, error)

+ func (r *Repository) CheckCreateIPKey(ctx context.Context, ip string, limit float64) (string, error)

+ func (r *Repository) IsValid(ctx context.Context, key string, IP string, manual bool) (bool, string, []string, error)

+ func (r *Repository) Restore(ctx context.Context, key string, manual bool, qv float64) (float64, float64, error)

+ func (r *Repository) SaveLog(ctx context.Context, data *api.Log) error

+ func (r *Repository) SaveValidate(ctx context.Context, key string, ip string, manual bool, qv float64) (bool, float64, float64, error)