notifications

Documentation

Index

• type Notification
• type NotificationHandlers
  • func NewNotificationHandlers(service *NotificationService, log *zap.Logger) *NotificationHandlers
  • func (h *NotificationHandlers) Reader(c *gin.Context)
• type NotificationRepository
  • func NewNotificationRepository(client *mongo.Client, conf *passport.Config) *NotificationRepository
  • func (r *NotificationRepository) GetAllNotRead(ctx context.Context) ([]*Notification, error)
  • func (r *NotificationRepository) GetAllNotSent(ctx context.Context) ([]*Notification, error)
• type NotificationService
  • func NewNotificationService(repository *NotificationRepository, conf *passport.Config, log *zap.Logger, ...) *NotificationService
  • func (s *NotificationService) Listener()

Types

type Notification

type Notification struct {
	ID        primitive.ObjectID `bson:"_id"`
	CreatedOn time.Time          `bson:"createdOn"`
	Flow      string             `bson:"type"`
	UserID    string             `bson:"userId"`
	Topic     string             `bson:"topic"`
	Header    string             `bson:"header"`
	Body      string             `bson:"body"`
	Params    map[string]string  `bson:"params,omitempty"`
	Meta      []string           `bson:"meta,omitempty"`
	IsSent    bool               `bson:"isSent"`
	SentOn    *time.Time         `bson:"sentOn,omitempty"`
	IsRead    bool               `bson:"isRead"`
	ReadOn    *time.Time         `bson:"readOn,omitempty"`
}

type NotificationHandlers

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

func NewNotificationHandlers

func NewNotificationHandlers(service *NotificationService, log *zap.Logger) *NotificationHandlers

func (*NotificationHandlers) Reader

func (h *NotificationHandlers) Reader(c *gin.Context)

type NotificationRepository

type NotificationRepository struct {
	*passport.MongoRepository
}

func NewNotificationRepository

func NewNotificationRepository(client *mongo.Client, conf *passport.Config) *NotificationRepository

func (*NotificationRepository) GetAllNotRead

func (r *NotificationRepository) GetAllNotRead(ctx context.Context) ([]*Notification, error)

func (*NotificationRepository) GetAllNotSent

func (r *NotificationRepository) GetAllNotSent(ctx context.Context) ([]*Notification, error)

type NotificationService

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

func NewNotificationService

func NewNotificationService(repository *NotificationRepository, conf *passport.Config, log *zap.Logger, mc *passport.MailClient) *NotificationService

func (*NotificationService) Listener

func (s *NotificationService) Listener()