bots

Documentation

Index

• type Chat
  • func (c *Chat) Id() uint32
  • func (c *Chat) SetId(u uint32)
  • func (c Chat) SetState(new, updated bool)
  • func (c *Chat) SetUUID(s string)
  • func (c *Chat) UUID() string
• type ChatBotRunner
• type ChatMessage
• type TelegramProvider
• type TelegramRunner
  • func NewTelegram(token string, cfg config.Config, provider TelegramProvider) (*TelegramRunner, error)
  • func (t *TelegramRunner) Broadcast(message *ChatMessage)
  • func (t *TelegramRunner) FeedBroadcast(messageChannel <-chan ChatMessage) error
  • func (t *TelegramRunner) ForEachChat(callback func(chat interface{}))
  • func (t *TelegramRunner) Run() error

Types

type Chat

type Chat struct {
	Username    string
	InitialText string
	ChatId      int64
	UUIDValue   string
	RecordId    uint32
	// contains filtered or unexported fields
}

func (*Chat) Id

func (c *Chat) Id() uint32

func (*Chat) SetId

func (c *Chat) SetId(u uint32)

func (Chat) SetState

func (c Chat) SetState(new, updated bool)

func (*Chat) SetUUID

func (c *Chat) SetUUID(s string)

func (*Chat) UUID

func (c *Chat) UUID() string

type ChatBotRunner

type ChatBotRunner interface {
	//Run Starts listening for messages from clients.
	Run()
	//FeedBroadcasts Broadcast anything that comes from a channel.
	FeedBroadcast(messageChannel <-chan ChatMessage)
}

type ChatMessage

type ChatMessage struct {
	Text   string
	ChatId 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) Broadcast

func (t *TelegramRunner) Broadcast(message *ChatMessage)

Broadcast a message to all active 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