package all import ( log "github.com/sirupsen/logrus" "dev.sum7.eu/genofire/logmania/bot" "dev.sum7.eu/genofire/logmania/database" "dev.sum7.eu/genofire/logmania/lib" "dev.sum7.eu/genofire/logmania/notify" ) type Notifier struct { notify.Notifier list []notify.Notifier channelNotify chan *log.Entry } func Init(config *lib.NotifyConfig, db *database.DB, bot *bot.Bot) notify.Notifier { var list []notify.Notifier for _, init := range notify.NotifyRegister { notify := init(config, db, bot) if notify == nil { continue } list = append(list, notify) } n := &Notifier{ list: list, channelNotify: make(chan *log.Entry), } go n.sender() return n } func (n *Notifier) sender() { for c := range n.channelNotify { for _, item := range n.list { item.Send(c) } } } func (n *Notifier) Send(e *log.Entry) error { n.channelNotify <- e return nil } func (n *Notifier) Close() { for _, item := range n.list { item.Close() } }