events

Documentation

Overview

Package events provide event handlers for telegram bot and all the high-level event handlers. It parses messages, sends them to the spam detector and handles the results. It can also ban users and send messages to the admin.

In addition to that, it provides support for admin chat handling allowing to unban users via the web service and update the list of spam samples.

Index

• type Bot
• type Locator
• type SpamLogger
• type SpamLoggerFunc
  • func (f SpamLoggerFunc) Save(msg *bot.Message, response *bot.Response)
• type SuperUsers
  • func (s SuperUsers) IsSuper(userName string) bool
• type TbAPI
• type TelegramListener
  • func (l *TelegramListener) Do(ctx context.Context) error

Types

type Bot

type Bot interface {
	OnMessage(msg bot.Message) (response bot.Response)
	UpdateSpam(msg string) error
	UpdateHam(msg string) error
	AddApprovedUsers(id int64, ids ...int64)
	RemoveApprovedUsers(id int64, ids ...int64)
}

Bot is an interface for bot events.

type Locator

type Locator interface {
	AddMessage(msg string, chatID, userID int64, userName string, msgID int) error
	AddSpam(userID int64, checks []lib.CheckResult) error
	Message(msg string) (storage.MsgMeta, bool)
	Spam(userID int64) (storage.SpamData, bool)
	MsgHash(msg string) string
}

Locator is an interface for message locator

type SpamLogger

type SpamLogger interface {
	Save(msg *bot.Message, response *bot.Response)
}

SpamLogger is an interface for spam logger

type SpamLoggerFunc

type SpamLoggerFunc func(msg *bot.Message, response *bot.Response)

SpamLoggerFunc is a function that implements SpamLogger interface

func (SpamLoggerFunc) Save

func (f SpamLoggerFunc) Save(msg *bot.Message, response *bot.Response)

Save is a function that implements SpamLogger interface

type SuperUsers

type SuperUsers []string

SuperUsers for moderators

func (SuperUsers) IsSuper

func (s SuperUsers) IsSuper(userName string) bool

IsSuper checks if username in the list of super users

type TbAPI

type TbAPI interface {
	GetUpdatesChan(config tbapi.UpdateConfig) tbapi.UpdatesChannel
	Send(c tbapi.Chattable) (tbapi.Message, error)
	Request(c tbapi.Chattable) (*tbapi.APIResponse, error)
	GetChat(config tbapi.ChatInfoConfig) (tbapi.Chat, error)
	GetChatAdministrators(config tbapi.ChatAdministratorsConfig) ([]tbapi.ChatMember, error)
}

TbAPI is an interface for telegram bot API, only subset of methods used

type TelegramListener

type TelegramListener struct {
	TbAPI        TbAPI
	SpamLogger   SpamLogger
	Bot          Bot
	Group        string // can be int64 or public group username (without "@" prefix)
	AdminGroup   string // can be int64 or public group username (without "@" prefix)
	IdleDuration time.Duration
	SuperUsers   SuperUsers
	TestingIDs   []int64
	StartupMsg   string
	NoSpamReply  bool
	TrainingMode bool
	Dry          bool
	KeepUser     bool
	Locator      Locator
	// contains filtered or unexported fields
}

TelegramListener listens to tg update, forward to bots and send back responses Not thread safe

func (*TelegramListener) Do

func (l *TelegramListener) Do(ctx context.Context) error

Do process all events, blocked call