monitor

package

v0.0.0-...-47bbb21 Latest Latest Go to latest Published: Jun 5, 2025 License: GPL-3.0 Imports: 14 Imported by: 0

Details

View Source

const MsgReqDelay = 30 * time.Second

View Source

const RecoveringDelay = 5 * time.Minute

This section is empty.

This section is empty.

type Chats struct {
	Sources      []tg.InputPeerChannel
	Destinations []tg.InputPeerClass
}

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

func New(options Options, db *sql.DB, bot *bot.Bot, parentLogger *zap.SugaredLogger) *Monitor

func (m Monitor) RecoverSync() error

func (m Monitor) ReplyMessageRating(
	e tg.Entities,
	u *tg.UpdateNewChannelMessage,
	replyID int,
	chat *tg.Channel,
) error

func (m Monitor) UpdateMessage(chat tg.InputChannel, msg db.Message) (db.Message, error)

func (m Monitor) WatchSync(ctx context.Context, delay time.Duration, ageLimit time.Duration)

WatchSync runs reactions & replies monitor delay - duration between each check ageLimit - duration in which messages will be monitored

type Options struct {
	Thresholds       Thresholds
	Chats            Chats
	NoQuoteWhitelist []int64
}

type Thresholds struct {
	Text    int
	Photo   int
	Forward int
}