services

Feb 29, 2024

Changes in this version

+ type AuthServiceParams struct

+ Devices *repositories.DevicesRepository

+ Logger *zap.Logger

+ Users *repositories.UsersRepository

+ type DevicesService struct

+ Devices *repositories.DevicesRepository

+ Logger *zap.Logger

+ func NewDevicesService(params DevicesServiceParams) *DevicesService

+ func (s *DevicesService) Select(user models.User) ([]models.Device, error)

+ type DevicesServiceParams struct

+ Devices *repositories.DevicesRepository

+ Logger *zap.Logger

Feb 16, 2024

Changes in this version

+ type MessagesEnqueueOptions struct

+ SkipPhoneValidation bool

Feb 6, 2024

Changes in this version

type MessagesService

+ Logger *zap.Logger

+ type MessagesServiceParams struct

+ Logger *zap.Logger

+ Messages *repositories.MessagesRepository

+ PushSvc *PushService

type PushService

+ Config PushServiceConfig

+ Logger *zap.Logger

+ func (s *PushService) Enqueue(ctx context.Context, token string, data map[string]string) error

+ func (s *PushService) Run(ctx context.Context)

type PushServiceConfig

+ Debounce time.Duration

+ Timeout time.Duration

+ type PushServiceParams struct

+ Config PushServiceConfig

+ Logger *zap.Logger

Dec 22, 2023

Changes in this version

type ErrValidation

+ func (e ErrValidation) Error() string

type MessagesService

+ func (s *MessagesService) HashProcessed() error

Nov 29, 2023

Changes in this version

+ const ErrorTTLExpired

Nov 13, 2023

Changes in this version

+ var ErrValidation error = errors.New("validation error")

+ var Module = fx.Module("services", fx.Provide(NewAuthService, NewMessagesService, NewPushService))

+ type AuthService struct

+ func NewAuthService(users *repositories.UsersRepository, devices *repositories.DevicesRepository) *AuthService

+ func (s *AuthService) AuthorizeDevice(token string) (models.Device, error)

+ func (s *AuthService) AuthorizeUser(username, password string) (models.User, error)

+ func (s *AuthService) RegisterDevice(userID string, name, pushToken *string) (models.Device, error)

+ func (s *AuthService) RegisterUser(login, password string) (models.User, error)

+ func (s *AuthService) UpdateDevice(id, pushToken string) error

+ type MessagesService struct

+ Messages *repositories.MessagesRepository

+ PushSvc *PushService

+ func NewMessagesService(pushSvc *PushService, messages *repositories.MessagesRepository) *MessagesService

+ func (s *MessagesService) Enqeue(device models.Device, message smsgateway.Message) (smsgateway.MessageState, error)

+ func (s *MessagesService) GetState(user models.User, ID string) (smsgateway.MessageState, error)

+ func (s *MessagesService) SelectPending(deviceID string) ([]smsgateway.Message, error)

+ func (s *MessagesService) UpdateState(deviceID string, message smsgateway.MessageState) error

+ type PushService struct

+ CredentialsJSON string

+ func NewPushService(config PushServiceConfig) *PushService

+ func (s *PushService) Send(ctx context.Context, token string, data map[string]string) error

+ type PushServiceConfig struct

+ CredentialsJSON string