63 lines
1.3 KiB
Go
63 lines
1.3 KiB
Go
|
package middleware
|
||
|
|
|
||
|
|
import (
|
||
|
|
"errors"
|
||
|
|
|
||
|
|
tele "git.belvedersky.ru/common/telebot"
|
||
|
|
)
|
||
|
|
|
||
|
|
// AutoRespond returns a middleware that automatically responds
|
||
|
|
// to every callback.
|
||
|
|
func AutoRespond() tele.MiddlewareFunc {
|
||
|
|
return func(next tele.HandlerFunc) tele.HandlerFunc {
|
||
|
|
return func(c tele.Context) error {
|
||
|
|
if c.Callback() != nil {
|
||
|
|
defer c.Respond()
|
||
|
|
}
|
||
|
|
return next(c)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// IgnoreVia returns a middleware that ignores all the
|
||
|
|
// "sent via" messages.
|
||
|
|
func IgnoreVia() tele.MiddlewareFunc {
|
||
|
|
return func(next tele.HandlerFunc) tele.HandlerFunc {
|
||
|
|
return func(c tele.Context) error {
|
||
|
|
if msg := c.Message(); msg != nil && msg.Via != nil {
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
return next(c)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// Recover returns a middleware that recovers a panic happened in
|
||
|
|
// the handler.
|
||
|
|
func Recover(onError ...func(error)) tele.MiddlewareFunc {
|
||
|
|
return func(next tele.HandlerFunc) tele.HandlerFunc {
|
||
|
|
return func(c tele.Context) error {
|
||
|
|
var f func(error)
|
||
|
|
if len(onError) > 0 {
|
||
|
|
f = onError[0]
|
||
|
|
} else {
|
||
|
|
f = func(err error) {
|
||
|
|
c.Bot().OnError(err, nil)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
defer func() {
|
||
|
|
if r := recover(); r != nil {
|
||
|
|
if err, ok := r.(error); ok {
|
||
|
|
f(err)
|
||
|
|
} else if s, ok := r.(string); ok {
|
||
|
|
f(errors.New(s))
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
|
||
|
|
return next(c)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|