telegramnotifier

Documentation

Index

• type Interaction
  • func NewInteraction(bot *telebot.Bot, store service.Store) *Interaction
  • func (it *Interaction) Broadcast(message string)
  • func (it *Interaction) Command(command string, h func(m *telebot.Message))
  • func (it *Interaction) EmitAuth(user *telebot.User)
  • func (it *Interaction) HandleAuth(m *telebot.Message)
  • func (it *Interaction) HandleHelp(m *telebot.Message)
  • func (it *Interaction) HandleInfo(m *telebot.Message)
  • func (it *Interaction) HandleStart(m *telebot.Message)
  • func (it *Interaction) HandleSubscribe(m *telebot.Message)
  • func (it *Interaction) OnAuth(cb func(user *telebot.User))
  • func (it *Interaction) SendToOwner(message string)
  • func (it *Interaction) Session() *Session
  • func (it *Interaction) SetAuthToken(token string)
  • func (it *Interaction) Start(session Session)
• type Notifier
  • func New(interaction *Interaction, options ...Option) *Notifier
  • func (n *Notifier) Notify(obj interface{}, args ...interface{})
  • func (n *Notifier) NotifyTo(channel string, obj interface{}, args ...interface{})
• type Option
  • func UseBroadcast() Option
• type Session
  • func NewSession(key *otp.Key) Session

Types

type Interaction

type Interaction struct {
	AuthToken string

	StartCallbacks []func()
	AuthCallbacks  []func(user *telebot.User)
	// contains filtered or unexported fields
}

func NewInteraction

func NewInteraction(bot *telebot.Bot, store service.Store) *Interaction

func (*Interaction) Broadcast

func (it *Interaction) Broadcast(message string)

func (*Interaction) Command

func (it *Interaction) Command(command string, h func(m *telebot.Message))

TODO: wrapper the handler function parameter to a global struct

func (*Interaction) EmitAuth

func (it *Interaction) EmitAuth(user *telebot.User)

func (*Interaction) HandleAuth

func (it *Interaction) HandleAuth(m *telebot.Message)

func (*Interaction) HandleHelp

func (it *Interaction) HandleHelp(m *telebot.Message)

func (*Interaction) HandleInfo

func (it *Interaction) HandleInfo(m *telebot.Message)

func (*Interaction) HandleStart

func (it *Interaction) HandleStart(m *telebot.Message)

func (*Interaction) HandleSubscribe

func (it *Interaction) HandleSubscribe(m *telebot.Message)

func (*Interaction) OnAuth

func (it *Interaction) OnAuth(cb func(user *telebot.User))

func (*Interaction) SendToOwner

func (it *Interaction) SendToOwner(message string)

func (*Interaction) Session

func (it *Interaction) Session() *Session

func (*Interaction) SetAuthToken

func (it *Interaction) SetAuthToken(token string)

func (*Interaction) Start

func (it *Interaction) Start(session Session)

type Notifier

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

func New

func New(interaction *Interaction, options ...Option) *Notifier

New TODO: register interaction with channel, so that we can route message to the specific telegram bot

func (*Notifier) Notify

func (n *Notifier) Notify(obj interface{}, args ...interface{})

func (*Notifier) NotifyTo

func (n *Notifier) NotifyTo(channel string, obj interface{}, args ...interface{})

type Option

type Option func(notifier *Notifier)

func UseBroadcast

func UseBroadcast() Option

type Session

type Session struct {
	Owner              *telebot.User `json:"owner"`
	OwnerChat          *telebot.Chat `json:"chat"`
	OneTimePasswordKey *otp.Key      `json:"otpKey"`

	// Chat objects
	Chats map[int64]bool `json:"chats"`
}

func NewSession

func NewSession(key *otp.Key) Session