messages

Documentation

Index

• Variables
• func MonitorMessages(ctx context.Context, client *telegram.Client, dispatcher tg.UpdateDispatcher, ...)
• type Monitoring
  • func NewMonitoring(dispatcher tg.UpdateDispatcher, id int64, strip bool) *Monitoring
  • func (m *Monitoring) Handle(re *regexp.Regexp, handler func(ctx MonitoringContext) error)
  • func (m *Monitoring) Listen(ctx context.Context, client *telegram.Client) error
  • func (a *Monitoring) SetupMessageMonitoring(messagesChan chan *tg.Message)
• type MonitoringContext
  • func (m *MonitoringContext) GetClient() *telegram.Client
  • func (m *MonitoringContext) GetMessage() *tg.Message
• type RouteEntry

Variables

var (
	EndConversation = errors.New("end")
)

Functions

func MonitorMessages

func MonitorMessages(ctx context.Context, client *telegram.Client, dispatcher tg.UpdateDispatcher, work func(chatID int64, m *tg.Message) error, done chan bool)

MonitorMessages accepts a function to process the message along with the chatID of the channel from which it was received. This function is deprecated please use the `Monitoring` class for simplicity.

Types

type Monitoring

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

func NewMonitoring

func NewMonitoring(dispatcher tg.UpdateDispatcher, id int64, strip bool) *Monitoring

func (*Monitoring) Handle

func (m *Monitoring) Handle(re *regexp.Regexp, handler func(ctx MonitoringContext) error)

func (*Monitoring) Listen

func (m *Monitoring) Listen(ctx context.Context, client *telegram.Client) error

func (*Monitoring) SetupMessageMonitoring

func (a *Monitoring) SetupMessageMonitoring(messagesChan chan *tg.Message)

type MonitoringContext

type MonitoringContext struct {
	Ctx context.Context
	// contains filtered or unexported fields
}

func (*MonitoringContext) GetClient

func (m *MonitoringContext) GetClient() *telegram.Client

func (*MonitoringContext) GetMessage

func (m *MonitoringContext) GetMessage() *tg.Message

type RouteEntry

type RouteEntry struct {
	Regex   *regexp.Regexp
	Handler func(ctx MonitoringContext) error
}