sqlstore

package

v0.0.1 Latest Latest Go to latest Published: Dec 4, 2024 License: GPL-3.0 Imports: 13 Imported by: 0

Details

This section is empty.

View Source

var (
	InvalidLinkError = errors.New("The passed link is not valid")
	ExistLinkError   = errors.New("The desired link already exists")
)

func SetupTestDB(t *testing.T, tokenForAdmin string) (*sql.DB, func(...string))

func TestDB(t *testing.T, databasePath string) (*sql.DB, func(...string))

type LinkRepository struct {
	ExpDuration time.Duration
	DelDuration time.Duration
	// contains filtered or unexported fields
}

func (l *LinkRepository) Create(ctx context.Context, UID int, originLink string, preferredLink string) (*models.Link, error)

Заменить вызов двух функций на транзакцию

func (l *LinkRepository) Delete(ctx context.Context, originLink string) error

func (l *LinkRepository) GetByOriginLink(ctx context.Context, originLink string) (*models.Link, error)

func (l *LinkRepository) GetByShortLink(ctx context.Context, shortLink string) (*models.Link, error)

func (l *LinkRepository) GetByUID(ctx context.Context, uid int) ([]*models.Link, error)

func (l *LinkRepository) ReActivate(ctx context.Context, originLink string) error

func (l *LinkRepository) ShortLinkExist(ctx context.Context, shortLink string) (bool, error)

type Store struct {
	QueryTimeout time.Duration
	// contains filtered or unexported fields
}

func New(db *sql.DB, QueryTimeout time.Duration) *Store

func (s *Store) Link() store.LinkRepository

func (s *Store) User() store.UserRepository

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

func (u *UserRepository) CheckByToken(ctx context.Context, token string) (bool, error)

func (u *UserRepository) Create(ctx context.Context) (*models.User, error)

func (u *UserRepository) Delete(ctx context.Context, unique interface{}) error

func (u *UserRepository) GetByRole(ctx context.Context, role string, limit int, offset int) ([]models.User, error)

func (u *UserRepository) GetByToken(ctx context.Context, token string) (*models.User, error)

func (u *UserRepository) GetByUID(ctx context.Context, uid int) (*models.User, error)