telegram

Documentation

Index

• Constants
• type ChatState
  • func ChatStateFromJSON(data []byte) (ChatState, error)
  • func (s ChatState) ToJSON() ([]byte, error)
• type DB
• type Telegram
  • func NewTelegram(db DB, token string, wgManager *manager.Manager, logger *zap.Logger) *Telegram
  • func (t *Telegram) Close()
  • func (t *Telegram) Init() error
  • func (t *Telegram) Run() error
• type Tx

Constants

const (
	ChatStateInitial = iota
	ChatStateSubnetExpectCIDR
)

Types

type ChatState

type ChatState int

func ChatStateFromJSON

func ChatStateFromJSON(data []byte) (ChatState, error)

func (ChatState) ToJSON

func (s ChatState) ToJSON() ([]byte, error)

type DB

type DB interface {
	db.DB
	Begin(mode db.TxMode) (Tx, error)
}

type Telegram

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

func NewTelegram

func NewTelegram(db DB, token string, wgManager *manager.Manager, logger *zap.Logger) *Telegram

func (*Telegram) Close

func (t *Telegram) Close()

Close stops accepting new messages and waits handlers to finish.

func (*Telegram) Init

func (t *Telegram) Init() error

func (*Telegram) Run

func (t *Telegram) Run() error

type Tx

type Tx interface {
	db.Tx
	CreateChatState(chatID int64, chatState ChatState) (ChatState, error)
	GetChatState(chatID int64) (ChatState, error)
	UpdateChatState(chatID int64, chatState ChatState) (ChatState, error)
	DeleteChatState(chatID int64) error
	CreateChatLongRunningCommand(chatID int64, command string) (string, error)
	GetChatLongRunningCommand(chatID int64) (string, error)
	UpdateChatLongRunningCommand(chatID int64, command string) (string, error)
	DeleteChatLongRunningCommand(chatID int64) error
}