go_notifier_core

type DbConfig struct {
	Username string
	Password string
	Driver   int
	Host     string
	Port     string
	Name     string
	DB       string
}

type EmailCampaignCreateData struct {
	EmailServiceId uint64
	ScheduledAt    *time.Time
	TemplateId     uint64
	StatusId       uint64
	FromEmail      string
	FromName       string
	Subject        string
	Name           string
	Tags           []uint64
}

type EmailCampaignUpdateData struct {
	EmailServiceId uint64
	ScheduledAt    *time.Time
	TemplateId     uint64
	StatusId       uint64
	FromEmail      string
	FromName       string
	Subject        string
	Name           string
	Tags           []uint64
}

type EmailWorker struct {
}

type IEmailCampaignRepository interface {
	IRepository[NotifierEmailCampaign]
	AssignTagsToCampaign(cmpId uint64, tagsId []uint64) error
	DeleteAllTagsForCampaign(cmpId uint64) error
	GetLatestCampaign() (*NotifierEmailCampaign, error)
	GetCampaignTags(cmpId uint64) []NotifierTag
}

type IEmailMessageRepository interface {
	IRepository[NotifierEmailMessage]
	CheckMessageExists(message *NotifierEmailMessage) error
}

type IEmailServiceRepository interface {
	IRepository[NotifierEmailService]
}

type IEmailStatusRepository interface {
	IRepository[NotifierEmailCampaignStatus]
	FirstOrCreate(status *NotifierEmailCampaignStatus) error
}

type IEmailSubTagRepository interface {
	IRepository[NotifierEmailSubTag]
}

type IEmailSubscriberRepository interface {
	IRepository[NotifierEmailSubscriber]
	GetByEmail(email string) (*NotifierEmailSubscriber, error)
	AssignTagToUser(userId uint64, tagsId []uint64) error
	RemoveTagsFromUser(id uint64, entity []uint64) error
	GetSubscribersForTag(tagId uint64, data *[]NotifierEmailSubscriber)
	GetUnSubscribed(data *[]NotifierEmailSubscriber)
	GetUsersByTagId(tags []NotifierTag, data *[]NotifierEmailSubscriber)
	GetByEmailWithTags(email string) (*NotifierEmailSubscriber, error)
}

type IEmailTemplateRepository interface {
	IRepository[NotifierEmailCampaignTemplate]
}

type IEmailUnSubEventRepository interface {
	IRepository[NotifierEmailUnsubscribeEvent]
	FirstOrCreate(status *NotifierEmailUnsubscribeEvent) error
}

type IMobileSubTagRepository interface {
	IRepository[NotifierMobileSubTag]
}

type IMobileSubscriberRepository interface {
	IRepository[NotifierMobileSubscriber]
	GetByMobile(mobile string) (*NotifierMobileSubscriber, error)
	AssignTagToUser(userId uint64, tagsId []uint64) error
	RemoveTagsFromUser(id uint64, entity []uint64) error
	GetSubscribersForTag(tagId uint64, data []NotifierMobileSubscriber)
	GetUnSubscribed(data []NotifierMobileSubscriber)
}

type IMobileUnSubEventRepository interface {
	IRepository[NotifierMobileUnsubscribeEvent]
}

type INotificationSubTagRepository interface {
	IRepository[NotifierNotificationSubTag]
}

type INotificationSubscriberRepository interface {
	IRepository[NotifierNotificationSubscriber]
	GetByNotification(token string) (*NotifierNotificationSubscriber, error)
	AssignTagToUser(userId uint64, tagsId []uint64) error
	RemoveTagsFromUser(id uint64, entity []uint64) error
	GetSubscribersForTag(tagId uint64, data []NotifierNotificationSubscriber)
	GetSubscribersForTagAndDriver(tagId, driverId uint64, data []NotifierNotificationSubscriber)
}

type INotifierNotificationDriverRepository interface {
	IRepository[NotifierNotificationService]
}

type IRepository[Model interface{}] interface {
	Create(*Model) error
	Update(*Model) error
	Delete(*Model) error
	Get(id uint64) (*Model, error)
	All(data *[]Model)
}

type ITagRepository interface {
	IRepository[NotifierTag]
	GetByName(name string) (*NotifierTag, error)
}

type IWorker interface {
	Run()
}

type Mailer interface {
	Send(fromName, fromMail, to, subject, message string) error
	SetConfig(config []byte)
}

type MobileWorker struct {
}

type NotFoundError struct {
}

type NotificationWorker struct {
}

type NotifierEmailCampaign struct {
	EmailServiceId uint64
	ScheduledAt    *time.Time
	TemplateId     uint64
	UpdatedAt      time.Time
	CreatedAt      time.Time
	StatusId       uint64
	FromEmail      string
	FromName       string
	Subject        string
	Content        string `gorm:"type=longtext"`
	Name           string
	ID             uint64
}

type NotifierEmailCampaignStatus struct {
	Name string
	ID   uint64
}

type NotifierEmailCampaignTag struct {
	CampaignId uint64
	TagId      uint64
}

type NotifierEmailCampaignTemplate struct {
	UpdatedAt time.Time
	CreatedAt time.Time
	Content   string `gorm:"type=longtext"`
	Name      string
	ID        uint64
}

type NotifierEmailMessage struct {
	RecipientEmail string
	EmailServiceId uint64
	SubscriberId   uint64
	SourceType     string
	Message        string
	CreatedAt      time.Time
	UpdatedAt      time.Time
	FromEmail      string
	SourceId       uint64
	FromName       string
	QueuedAt       *time.Time
	FailedAt       *time.Time
	Subject        string
	SentAt         *time.Time
	ID             uint64
}

type NotifierEmailService struct {
	Payload string `gorm:"type=longtext"`
	Type    string
	Name    string
	ID      uint64
}

type NotifierEmailSubTag struct {
	EmailSubscriberId uint64
	TagId             uint64
}

type NotifierEmailSubscriber struct {
	UnsubscribedEventId *uint64
	Tags                []NotifierTag `gorm:"many2many:notifier_email_sub_tags;ForeignKey:id;References:id;JoinForeignKey:EmailSubscriberId;joinReferences:TagId"`
	UnsubscribedAt      *time.Time
	CreatedAt           time.Time
	UpdatedAt           time.Time
	FirstName           string
	LastName            string
	Email               string
	ID                  uint64
}

type NotifierEmailUnsubscribeEvent struct {
	ID     uint64
	Reason string
}

type NotifierMobileDriver struct {
	Payload string `gorm:"type=longtext"`
	Type    string
	Name    string
	ID      uint64
}

type NotifierMobileSubTag struct {
	MobileSubscriberId uint64
	TagId              uint64
}

type NotifierMobileSubscriber struct {
	UnsubscribedEventId *uint64
	UnsubscribedAt      *time.Time
	CountryCode         string
	CreatedAt           time.Time
	UpdatedAt           time.Time
	FirstName           string
	LastName            string
	Mobile              string
	ID                  uint64
}

type NotifierMobileUnsubscribeEvent struct {
	ID     uint64
	Reason string
}

type NotifierNotificationService struct {
	Payload string `gorm:"type=longtext"`
	Type    string
	Name    string
	ID      uint64
}

type NotifierNotificationSubTag struct {
	NotificationSubscriberId uint64
	TagId                    uint64
}

type NotifierNotificationSubscriber struct {
	CreatedAt time.Time
	UpdatedAt time.Time
	FirstName string
	LastName  string
	DriverId  uint64
	Token     string
	ID        uint64
}

type NotifierTag struct {
	CreatedAt time.Time
	UpdatedAt time.Time
	Name      string
	ID        uint64
}

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

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

type SmtpConfig struct {
	Host       string
	Port       string
	Username   string
	Password   string
	Encryption string
}

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

type WorkerConfig struct {
	Duration time.Duration
	Worker   IWorker
	Name     string
}

type WorkersList []WorkerConfig