mirror of
https://github.com/Luzifer/twitch-bot.git
synced 2024-12-30 08:31:16 +00:00
83 lines
2.5 KiB
Go
83 lines
2.5 KiB
Go
package raffle
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/Luzifer/go_helpers/v2/fieldcollection"
|
|
"github.com/Luzifer/twitch-bot/v3/plugins"
|
|
"github.com/pkg/errors"
|
|
"github.com/sirupsen/logrus"
|
|
"gopkg.in/irc.v4"
|
|
)
|
|
|
|
type (
|
|
enterRaffleActor struct{}
|
|
)
|
|
|
|
var ptrStrEmpty = ptrStr("")
|
|
|
|
func ptrStr(v string) *string { return &v }
|
|
|
|
func (enterRaffleActor) Execute(_ *irc.Client, m *irc.Message, _ *plugins.Rule, evtData *fieldcollection.FieldCollection, attrs *fieldcollection.FieldCollection) (preventCooldown bool, err error) {
|
|
if m != nil || evtData.MustString("reward_id", ptrStrEmpty) == "" {
|
|
return false, errors.New("enter-raffle actor is only supposed to act on channelpoint redeems")
|
|
}
|
|
|
|
r, err := dbc.GetByChannelAndKeyword(
|
|
evtData.MustString("channel", ptrStrEmpty),
|
|
attrs.MustString("keyword", ptrStrEmpty),
|
|
)
|
|
if err != nil {
|
|
if errors.Is(err, errRaffleNotFound) {
|
|
// We don't need to care, that was no raffle input
|
|
return false, errors.Errorf("specified keyword %q does not belong to active raffle", attrs.MustString("keyword", ptrStrEmpty))
|
|
}
|
|
return false, errors.Wrap(err, "fetching raffle")
|
|
}
|
|
|
|
re := raffleEntry{
|
|
EnteredAs: "reward",
|
|
RaffleID: r.ID,
|
|
UserID: evtData.MustString("user_id", ptrStrEmpty),
|
|
UserLogin: evtData.MustString("user", ptrStrEmpty),
|
|
UserDisplayName: evtData.MustString("user", ptrStrEmpty),
|
|
EnteredAt: time.Now().UTC(),
|
|
}
|
|
|
|
raffleEventFields := fieldcollection.FieldCollectionFromData(map[string]any{
|
|
"user_id": re.UserID,
|
|
"user": re.UserLogin,
|
|
})
|
|
|
|
// We have everything we need to create an entry
|
|
if err = dbc.Enter(re); err != nil {
|
|
logrus.WithFields(logrus.Fields{
|
|
"raffle": r.ID,
|
|
"user_id": re.UserID,
|
|
"user": re.UserLogin,
|
|
}).WithError(err).Error("creating raffle entry")
|
|
return false, errors.Wrap(
|
|
r.SendEvent(raffleMessageEventEntryFailed, raffleEventFields),
|
|
"sending entry-failed chat message",
|
|
)
|
|
}
|
|
|
|
return false, errors.Wrap(
|
|
r.SendEvent(raffleMessageEventEntry, raffleEventFields),
|
|
"sending entry chat message",
|
|
)
|
|
}
|
|
|
|
func (enterRaffleActor) IsAsync() bool { return false }
|
|
func (enterRaffleActor) Name() string { return "enter-raffle" }
|
|
|
|
func (enterRaffleActor) Validate(_ plugins.TemplateValidatorFunc, attrs *fieldcollection.FieldCollection) (err error) {
|
|
if err = attrs.ValidateSchema(
|
|
fieldcollection.MustHaveField(fieldcollection.SchemaField{Name: "keyword", NonEmpty: true, Type: fieldcollection.SchemaFieldTypeString}),
|
|
); err != nil {
|
|
return fmt.Errorf("validating attributes: %w", err)
|
|
}
|
|
|
|
return nil
|
|
}
|