services

Documentation

Index

• Constants
• Variables
• type DevicesService
  • func NewDevicesService(params DevicesServiceParams) *DevicesService
  • func (s *DevicesService) Select(user models.User) ([]models.Device, error)
• type DevicesServiceParams
• type ErrValidation
  • func (e ErrValidation) Error() string
• type MessagesEnqueueOptions
• type MessagesService
  • func NewMessagesService(params MessagesServiceParams) *MessagesService
  • func (s *MessagesService) Enqeue(device models.Device, message smsgateway.Message, opts MessagesEnqueueOptions) (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 MessagesServiceParams

Constants

const (
	ErrorTTLExpired = "TTL expired"
)

Variables

var Module = fx.Module(
	"services",
	fx.Decorate(func(log *zap.Logger) *zap.Logger {
		return log.Named("services")
	}),
	fx.Provide(
		NewMessagesService,
		NewDevicesService,
	),
)

Types

type DevicesService

type DevicesService struct {
	Devices *repositories.DevicesRepository

	Logger *zap.Logger
}

func NewDevicesService

func NewDevicesService(params DevicesServiceParams) *DevicesService

func (*DevicesService) Select

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

type DevicesServiceParams

type DevicesServiceParams struct {
	fx.In

	Devices *repositories.DevicesRepository
	Logger  *zap.Logger
}

type ErrValidation

type ErrValidation string

func (ErrValidation) Error

func (e ErrValidation) Error() string

type MessagesEnqueueOptions

type MessagesEnqueueOptions struct {
	SkipPhoneValidation bool
}

type MessagesService

type MessagesService struct {
	Messages *repositories.MessagesRepository
	PushSvc  *push.Service
	Logger   *zap.Logger
	// contains filtered or unexported fields
}

func NewMessagesService

func NewMessagesService(params MessagesServiceParams) *MessagesService

func (*MessagesService) Enqeue

func (s *MessagesService) Enqeue(device models.Device, message smsgateway.Message, opts MessagesEnqueueOptions) (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 MessagesServiceParams

type MessagesServiceParams struct {
	fx.In

	Messages *repositories.MessagesRepository
	PushSvc  *push.Service
	Logger   *zap.Logger
}