bots

Documentation

Index

• type ChatBotRunner
• type ChatMessage
• type TelegramProvider
• type TelegramRunner
  • func NewTelegram(token string, cfg config.Config, provider TelegramProvider) (*TelegramRunner, error)
  • func (t *TelegramRunner) FeedBroadcast(messageChannel <-chan ChatMessage) error
  • func (t *TelegramRunner) ForEachChat(callback func(chat interface{}))
  • func (t *TelegramRunner) Run() error

Types

type ChatBotRunner

type ChatBotRunner interface {
	Run()
	FeedBroadcast(messageChannel <-chan ChatMessage)
}

type ChatMessage

type ChatMessage struct {
	Text   string
	Banner string
}

type TelegramProvider

type TelegramProvider func(token string) (*tgbotapi.BotAPI, error)

type TelegramRunner

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

func NewTelegram

func NewTelegram(token string, cfg config.Config, provider TelegramProvider) (*TelegramRunner, error)

NewTelegram creates a new telegram bot runner. This function uses the `chat_db` environment variable for storing the chats.

func (*TelegramRunner) FeedBroadcast

func (t *TelegramRunner) FeedBroadcast(messageChannel <-chan ChatMessage) error

FeedBroadcast the messages that are passed to each one of the chats.

func (*TelegramRunner) ForEachChat

func (t *TelegramRunner) ForEachChat(callback func(chat interface{}))

ForEachChat goes over all the persisted chats and invokes the callback on them.

func (*TelegramRunner) Run

func (t *TelegramRunner) Run() error

Run the bot, listening for updates from users