update versions and change to std logger

This commit is contained in:
Seraphim Strub 2023-04-23 00:33:20 +02:00
parent aa20d59a0f
commit df441014ed
17 changed files with 212 additions and 147 deletions

View file

@ -9,10 +9,11 @@ import (
"github.com/disgoorg/disgo/discord"
"github.com/disgoorg/disgo/rest"
"github.com/disgoorg/disgo/webhook"
"github.com/disgoorg/log"
"github.com/disgoorg/snowflake/v2"
"github.com/getsentry/sentry-go"
"grow.rievo.dev/discordBots/cmd/dealsbot/api"
"grow.rievo.dev/discordBots/cmd/dealsbot/repository"
"log"
"os"
"os/signal"
"reflect"
@ -36,9 +37,23 @@ func main() {
// - origin
// - check ubisoft works
log.SetLevel(log.LevelInfo)
log.Info("starting dealsbot...")
log.Info("disgo version: ", disgo.Version)
err := sentry.Init(sentry.ClientOptions{
Dsn: "https://0282823b5ee14546a4c154c129109a31@sentry.rvo.one/2",
// Set TracesSampleRate to 1.0 to capture 100%
// of transactions for performance monitoring.
// We recommend adjusting this value in production,
TracesSampleRate: 1.0,
})
if err != nil {
log.Fatalf("sentry.Init: %s", err)
}
// Flush buffered events before the program terminates.
defer sentry.Flush(2 * time.Second)
sentry.CaptureMessage("DEBUG: dealsbot started")
log.Printf("INFO: starting dealsbot...")
log.Printf("INFO: disgo version: %v", disgo.Version)
client := webhook.New(webhookID, webhookToken)
defer client.Close(context.TODO())
@ -59,7 +74,7 @@ func main() {
for _, api := range apis {
err := api.Load()
if err != nil {
log.Error(err)
log.Printf("ERROR: %v", err)
}
}
var deals []api.Deal
@ -72,15 +87,15 @@ func main() {
retrievedDeal, _ := repo.GetValue(deal.Id)
if deal.Id == retrievedDeal.Id {
log.Debugf("%v is already published", deal.Id)
log.Printf("DEBUG: %v is already published", deal.Id)
} else if reflect.DeepEqual(deal, retrievedDeal) {
log.Errorf("%v is published but not equal", deal.Id)
log.Printf("ERROR: %v is published but not equal", deal.Id)
} else {
log.Infof("%v is new and will be published", deal.Id)
log.Printf("INFO: %v is new and will be published", deal.Id)
go sendWebhook(client, deal)
err := repo.SetValue(deal)
if err != nil {
log.Error(err)
log.Printf("ERROR: %v", err)
}
}
}
@ -88,9 +103,9 @@ func main() {
case <-tickerGC.C:
err := repo.RunGC()
if err != nil && !errors.Is(err, badger.ErrNoRewrite) {
log.Errorf("error with GC: %v", err)
log.Printf("ERROR: GC: %v", err)
} else {
log.Debug("GC successful")
log.Printf("DEBUG: GC successful")
}
case <-quit:
ticker.Stop()
@ -100,7 +115,7 @@ func main() {
}
}()
log.Infof("dealsbot is now running. Press CTRL-C to exit.")
log.Printf("INFO: dealsbot is now running. Press CTRL-C to exit.")
s := make(chan os.Signal, 1)
signal.Notify(s, syscall.SIGINT, syscall.SIGTERM, os.Interrupt)
<-s
@ -115,6 +130,6 @@ func sendWebhook(client webhook.Client, deal api.Deal) {
SetContent(status).Build(),
rest.WithDelay(2*time.Second),
); err != nil {
log.Errorf("error sending message %v", err.Error())
log.Printf("ERROR: sending message %v", err.Error())
}
}