notifications

Documentation

Index

• type Config
• type Dependencies
• type GameService
• type Notifier
• type Service
  • func NewService(cfg Config, deps Dependencies) *Service
  • func (s *Service) NotifyUser(ctx context.Context, userId string) error
  • func (s *Service) Run(ctx context.Context) error
• type Storage

Types

type Config

type Config struct {
	ActivityBuffer time.Duration
	ScanInterval   time.Duration
	WorkersCount   int
}

type Dependencies

type Dependencies struct {
	Storage         Storage
	Game            GameService
	SandboxNotifier Notifier
	ProdNotifier    Notifier
}

type GameService

type GameService interface {
	GetUserGames(ctx context.Context, userId string) ([]*game.UserGame, error)
}

type Notifier

type Notifier interface {
	SendNotification(ctx context.Context, device []byte, n apn.Notification) error
}

type Service

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

func NewService

func NewService(cfg Config, deps Dependencies) *Service

func (*Service) NotifyUser

func (s *Service) NotifyUser(ctx context.Context, userId string) error

func (*Service) Run

func (s *Service) Run(ctx context.Context) error

type Storage

type Storage interface {
	GetActiveUsers(ctx context.Context, activityBuffer time.Duration) ([]string, error)
	GetUserById(ctx context.Context, userId string) (*storage.User, error)
	UpdateSentNotification(ctx context.Context, userId string, updater storage.SentNotificationUpdater) error
}