2021-08-19 15:33:56 +02:00
|
|
|
package delay
|
2021-05-12 18:26:17 +02:00
|
|
|
|
|
|
|
import (
|
|
|
|
"math/rand"
|
|
|
|
"time"
|
|
|
|
|
2021-08-19 15:33:56 +02:00
|
|
|
"github.com/Luzifer/twitch-bot/plugins"
|
2021-05-12 18:26:17 +02:00
|
|
|
"github.com/go-irc/irc"
|
|
|
|
)
|
|
|
|
|
2021-08-19 15:33:56 +02:00
|
|
|
func Register(args plugins.RegistrationArguments) error {
|
|
|
|
args.RegisterActor(func() plugins.Actor { return &actor{} })
|
|
|
|
|
|
|
|
return nil
|
2021-06-11 13:52:42 +02:00
|
|
|
}
|
2021-05-12 18:26:17 +02:00
|
|
|
|
2021-08-19 15:33:56 +02:00
|
|
|
type actor struct {
|
2021-06-11 13:52:42 +02:00
|
|
|
Delay time.Duration `json:"delay" yaml:"delay"`
|
|
|
|
DelayJitter time.Duration `json:"delay_jitter" yaml:"delay_jitter"`
|
|
|
|
}
|
2021-05-12 18:26:17 +02:00
|
|
|
|
2021-09-02 17:09:30 +02:00
|
|
|
func (a actor) Execute(c *irc.Client, m *irc.Message, r *plugins.Rule, eventData map[string]interface{}) (preventCooldown bool, err error) {
|
2021-06-11 13:52:42 +02:00
|
|
|
if a.Delay == 0 && a.DelayJitter == 0 {
|
2021-08-12 00:12:10 +02:00
|
|
|
return false, nil
|
2021-06-11 13:52:42 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
totalDelay := a.Delay
|
|
|
|
if a.DelayJitter > 0 {
|
|
|
|
totalDelay += time.Duration(rand.Int63n(int64(a.DelayJitter))) // #nosec: G404 // It's just time, no need for crypto/rand
|
|
|
|
}
|
|
|
|
|
|
|
|
time.Sleep(totalDelay)
|
2021-08-12 00:12:10 +02:00
|
|
|
return false, nil
|
2021-05-12 18:26:17 +02:00
|
|
|
}
|
2021-06-11 13:52:42 +02:00
|
|
|
|
2021-08-19 15:33:56 +02:00
|
|
|
func (a actor) IsAsync() bool { return false }
|
|
|
|
func (a actor) Name() string { return "delay" }
|