RievoGitAdmin/discordBots
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

remove sentry and move to slog

Browse source
This commit is contained in:
Seraphim Strub 2023-11-05 16:03:52 +00:00
parent a20bc22ab1
commit 5d2b8f39d9
18 changed files with 134 additions and 232 deletions
Download patch file Download diff file Expand all files Collapse all files

57
cmd/dealsbot/main.go
View file

@ -10,10 +10,9 @@ import (
"github.com/disgoorg/disgo/rest"
"github.com/disgoorg/disgo/webhook"
"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"
"log/slog"
"os"
"os/signal"
"reflect"
@ -26,7 +25,8 @@ var (
webhookToken = os.Getenv("webhook_token")
)
// sentry
var logger = slog.New(slog.NewJSONHandler(os.Stdout, nil))
var release string
func main() {
@ -40,28 +40,12 @@ func main() {
// - origin
// - check ubisoft works
err := sentry.Init(sentry.ClientOptions{
// Either set your DSN here or set the SENTRY_DSN environment variable.
//Dsn: "",
// Set TracesSampleRate to 1.0 to capture 100%
// of transactions for performance monitoring.
// We recommend adjusting this value in production,
TracesSampleRate: 1.0,
Release: release,
})
if err != nil {
log.Fatalf("sentry.Init: %s", err)
}
// Flush buffered events before the program terminates.
defer sentry.Flush(2 * time.Second)
log.Printf("INFO: starting dealsbot...")
log.Printf("INFO: disgo version: %v", disgo.Version)
logger.Info("starting dealsbot...", slog.String("disgo version", disgo.Version))
client := webhook.New(webhookID, webhookToken)
defer client.Close(context.TODO())
repo := repository.InitDb()
repo := repository.InitDb(logger)
defer repo.Close()
ticker := time.NewTicker(10 * time.Minute)
@ -73,12 +57,17 @@ func main() {
select {
case <-ticker.C:
var apis []api.Api
apis = append(apis, api.NewUbsioftApi(), api.NewEpicApi(), api.NewSteamApi(), api.NewGogFrontApi(), api.NewGogApi(), api.NewHumbleBundleApi())
apis = append(apis,
api.NewUbsioftApi(logger),
api.NewEpicApi(logger),
api.NewSteamApi(logger),
api.NewGogFrontApi(logger),
api.NewGogApi(logger),
api.NewHumbleBundleApi(logger))
for _, a := range apis {
err := a.Load()
if err != nil {
sentry.CaptureException(fmt.Errorf("ERROR: loading from api: %w", err))
log.Printf("ERROR: %v", err)
logger.Error("failed loading api", slog.Any("error", err))
}
}
var deals []api.Deal
@ -91,15 +80,15 @@ func main() {
retrievedDeal, _ := repo.GetValue(deal.Id)
if deal.Id == retrievedDeal.Id {
log.Printf("DEBUG: %v is already published", deal.Id)
logger.Debug("deal is already published", slog.String("deal", deal.Id))
} else if reflect.DeepEqual(deal, retrievedDeal) {
log.Printf("ERROR: %v is published but not equal", deal.Id)
logger.Error("deal is published but not equal", slog.String("deal", deal.Id))
} else {
log.Printf("INFO: %v is new and will be published", deal.Id)
logger.Info("deal is new and will be published", slog.String("deal", deal.Id))
go sendWebhook(client, deal)
err := repo.SetValue(deal)
if err != nil {
log.Printf("ERROR: %v", err)
logger.Error("failed saving deal", slog.Any("error", err))
}
}
}
@ -107,9 +96,9 @@ func main() {
case <-tickerGC.C:
err := repo.RunGC()
if err != nil && !errors.Is(err, badger.ErrNoRewrite) {
log.Printf("ERROR: GC: %v", err)
logger.Error("GC failed", slog.Any("error", err))
} else {
log.Printf("DEBUG: GC successful")
logger.Debug("GC successful")
}
case <-quit:
ticker.Stop()
@ -119,11 +108,7 @@ func main() {
}
}()
log.Printf("INFO: dealsbot (%v) is now running. Press CTRL-C to exit.", release)
sentry.ConfigureScope(func(scope *sentry.Scope) {
scope.SetLevel(sentry.LevelDebug)
sentry.CaptureMessage("DEBUG: dealsbot started")
})
logger.Info("dealsbot is now running. Press CTRL-C to exit.", slog.String("version", release))
s := make(chan os.Signal, 1)
signal.Notify(s, syscall.SIGINT, syscall.SIGTERM, os.Interrupt)
@ -139,6 +124,6 @@ func sendWebhook(client webhook.Client, deal api.Deal) {
SetContent(status).Build(),
rest.WithDelay(2*time.Second),
); err != nil {
log.Printf("ERROR: sending message %v", err.Error())
logger.Error("sending message failed", slog.Any("error", err))
}
}