repositories

Documentation

Index

• Constants
• Variables
• type DevicesRepository
  • func NewDevicesRepository(db *gorm.DB) *DevicesRepository
  • func (r *DevicesRepository) Get(id string) (models.Device, error)
  • func (r *DevicesRepository) GetByToken(token string) (models.Device, error)
  • func (r *DevicesRepository) Insert(device *models.Device) error
  • func (r *DevicesRepository) Select(filter SelectDevicesFilter) ([]models.Device, error)
  • func (r *DevicesRepository) UpdateLastSeen(id string) error
  • func (r *DevicesRepository) UpdateToken(id, token string) error
• type MessagesRepository
  • func NewMessagesRepository(db *gorm.DB) *MessagesRepository
  • func (r *MessagesRepository) Get(ID string, filter MessagesSelectFilter, options ...MessagesSelectOptions) (message models.Message, err error)
  • func (r *MessagesRepository) HashProcessed(ids []uint64) error
  • func (r *MessagesRepository) Insert(message *models.Message) error
  • func (r *MessagesRepository) SelectPending(deviceID string) (messages []models.Message, err error)
  • func (r *MessagesRepository) UpdateState(message *models.Message) error
• type MessagesSelectFilter
• type MessagesSelectOptions
• type SelectDevicesFilter
• type UsersRepository
  • func NewUsersRepository(db *gorm.DB) *UsersRepository
  • func (r *UsersRepository) GetByLogin(login string) (models.User, error)
  • func (r *UsersRepository) Insert(user *models.User) error

Constants

const HashingLockName = "36444143-1ace-4dbf-891c-cc505911497e"

Variables

var (
	ErrDeviceNotFound = gorm.ErrRecordNotFound
)

var ErrMessageNotFound = gorm.ErrRecordNotFound

var (
	ErrUserNotFound = gorm.ErrRecordNotFound
)

var Module = fx.Module(
	"repositories",
	fx.Decorate(func(log *zap.Logger) *zap.Logger {
		return log.Named("repositories")
	}),
	fx.Provide(
		NewDevicesRepository,
		NewMessagesRepository,
		NewUsersRepository,
	),
)

Types

type DevicesRepository

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

func NewDevicesRepository

func NewDevicesRepository(db *gorm.DB) *DevicesRepository

func (*DevicesRepository) Get

func (r *DevicesRepository) Get(id string) (models.Device, error)

func (*DevicesRepository) GetByToken

func (r *DevicesRepository) GetByToken(token string) (models.Device, error)

func (*DevicesRepository) Insert

func (r *DevicesRepository) Insert(device *models.Device) error

func (*DevicesRepository) Select

func (r *DevicesRepository) Select(filter SelectDevicesFilter) ([]models.Device, error)

func (*DevicesRepository) UpdateLastSeen

func (r *DevicesRepository) UpdateLastSeen(id string) error

func (*DevicesRepository) UpdateToken

func (r *DevicesRepository) UpdateToken(id, token string) error

type MessagesRepository

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

func NewMessagesRepository

func NewMessagesRepository(db *gorm.DB) *MessagesRepository

func (*MessagesRepository) Get

func (r *MessagesRepository) Get(ID string, filter MessagesSelectFilter, options ...MessagesSelectOptions) (message models.Message, err error)

func (*MessagesRepository) HashProcessed

func (r *MessagesRepository) HashProcessed(ids []uint64) error

func (*MessagesRepository) Insert

func (r *MessagesRepository) Insert(message *models.Message) error

func (*MessagesRepository) SelectPending

func (r *MessagesRepository) SelectPending(deviceID string) (messages []models.Message, err error)

func (*MessagesRepository) UpdateState

func (r *MessagesRepository) UpdateState(message *models.Message) error

type MessagesSelectFilter

type MessagesSelectFilter struct {
	DeviceID string
}

/////////////////////////////////////////////////////////////////////////////

type MessagesSelectOptions

type MessagesSelectOptions struct {
	WithRecipients bool
	WithDevice     bool
}

type SelectDevicesFilter

type SelectDevicesFilter struct {
	UserId *string
}

type UsersRepository

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

func NewUsersRepository

func NewUsersRepository(db *gorm.DB) *UsersRepository

func (*UsersRepository) GetByLogin

func (r *UsersRepository) GetByLogin(login string) (models.User, error)

func (*UsersRepository) Insert

func (r *UsersRepository) Insert(user *models.User) error