services

Documentation

Index

• Constants
• Variables
• type AuthService
  • 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 ErrValidation
  • func (e ErrValidation) Error() string
• type MessagesService
  • 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) HashProcessed() error
  • func (s *MessagesService) SelectPending(deviceID string) ([]smsgateway.Message, error)
  • func (s *MessagesService) UpdateState(deviceID string, message smsgateway.MessageState) error
• type PushService
  • func NewPushService(config PushServiceConfig) *PushService
  • func (s *PushService) Send(ctx context.Context, token string, data map[string]string) error
• type PushServiceConfig

Constants

const (
	ErrorTTLExpired = "TTL expired"
)

Variables

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

Types

type AuthService

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

func NewAuthService

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

func (*AuthService) AuthorizeDevice

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

func (*AuthService) AuthorizeUser

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

func (*AuthService) RegisterDevice

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

func (*AuthService) RegisterUser

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

func (*AuthService) UpdateDevice

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

type ErrValidation

type ErrValidation string

func (ErrValidation) Error

func (e ErrValidation) Error() string

type MessagesService

type MessagesService struct {
	Messages *repositories.MessagesRepository
	PushSvc  *PushService
	// contains filtered or unexported fields
}

func NewMessagesService

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

func (*MessagesService) Enqeue

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

func (*MessagesService) GetState

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

func (*MessagesService) HashProcessed

func (s *MessagesService) HashProcessed() error

func (*MessagesService) SelectPending

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

func (*MessagesService) UpdateState

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

type PushService

type PushService struct {
	CredentialsJSON string
	// contains filtered or unexported fields
}

func NewPushService

func NewPushService(config PushServiceConfig) *PushService

func (*PushService) Send

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

send

type PushServiceConfig

type PushServiceConfig struct {
	CredentialsJSON string
}