repository

Documentation

Index

• Constants
• type Config
• type Repository
  • func New(logger *zap.Logger, cfg *Config, rdbms rdbms.RDBMS) Repository

Constants

const QueryCreateContact = `
INSERT INTO contacts(name, phones, description, user_id) VALUES($1, $2, $3, $4) 
RETURNING id;`

const QueryCreateUser = `
INSERT INTO users(email, password) VALUES($1, $2) 
RETURNING id;`

const QueryDeleteContact = `
DELETE FROM contacts 
WHERE user_id=$1 AND id=$2;`

const QueryGetContactById = `
SELECT name, phones, description
FROM contacts
WHERE user_id=$1 AND id=$2;`

const QueryGetContacts = `` /* 154-byte string literal not displayed */

const QueryGetUserByEmail = `
SELECT id, password, created_at
FROM users
WHERE email=$1;`

const QueryGetUserByEmailAndPassword = `
SELECT id, created_at 
FROM users 
WHERE email=$1 AND password=$2;`

const QueryGetUserDetailsById = `` /* 291-byte string literal not displayed */

const QueryUpdateContact = `
UPDATE contacts 
SET name=$1, phones=$2, description=$3 
WHERE user_id=$4 AND id=$5;`

Types

type Config

type Config struct {
	CursorSecret string `koanf:"cursor_secret"`
	Limit        struct {
		Min int `koanf:"min"`
		Max int `koanf:"max"`
	} `koanf:"limit"`
}

type Repository

type Repository interface {
	Migrate(models.Migrate) error

	CreateUser(user *models.User) error
	GetUserByEmail(email string) (*models.User, error)
	GetUserByEmailAndPassword(email, password string) (*models.User, error)

	CreateContact(userId uint64, contect *models.Contact) error
	GetContactById(userId, contactId uint64) (*models.Contact, error)
	UpdateContact(userId uint64, contact *models.Contact) error
	DeleteContact(userId, contactId uint64) error
	GetContacts(userId uint64, encryptedCursor, search string, limit int) ([]models.Contact, string, error)
}

func New

func New(logger *zap.Logger, cfg *Config, rdbms rdbms.RDBMS) Repository