notifications

Documentation

Index

• type NoopNotifier
  • func (n *NoopNotifier) OnFinish(item media.SearchItem) error
  • func (n *NoopNotifier) OnQueued(item media.SearchItem) error
• type Notifier
• type Telegram
  • func NewTelegramClient(bot *tgbotapi.BotAPI, db *sql.DB) *Telegram
  • func (t *Telegram) GetSubscribedChats() (ids []int64)
  • func (t *Telegram) OnFinish(item media.SearchItem) error
  • func (t *Telegram) OnQueued(item media.SearchItem) error
  • func (t *Telegram) RegisterChat(id int64) error
  • func (t *Telegram) StartListener() error
  • func (t *Telegram) UnregisterChat(id int64) error
  • func (t *Telegram) UpdateSubscribers(text string) error

Types

type NoopNotifier

type NoopNotifier struct {
}

func (*NoopNotifier) OnFinish

func (n *NoopNotifier) OnFinish(item media.SearchItem) error

func (*NoopNotifier) OnQueued

func (n *NoopNotifier) OnQueued(item media.SearchItem) error

type Notifier

type Notifier interface {
	OnQueued(item media.SearchItem) error
	OnFinish(item media.SearchItem) error
}

type Telegram

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

func NewTelegramClient

func NewTelegramClient(bot *tgbotapi.BotAPI, db *sql.DB) *Telegram

func (*Telegram) GetSubscribedChats

func (t *Telegram) GetSubscribedChats() (ids []int64)

func (*Telegram) OnFinish

func (t *Telegram) OnFinish(item media.SearchItem) error

func (*Telegram) OnQueued

func (t *Telegram) OnQueued(item media.SearchItem) error

func (*Telegram) RegisterChat

func (t *Telegram) RegisterChat(id int64) error

func (*Telegram) StartListener

func (t *Telegram) StartListener() error

func (*Telegram) UnregisterChat

func (t *Telegram) UnregisterChat(id int64) error

func (*Telegram) UpdateSubscribers

func (t *Telegram) UpdateSubscribers(text string) error