From ed3518d0755cb5cae25d9d8f1690ab2e60702588 Mon Sep 17 00:00:00 2001 From: Kujtim Hoxha Date: Mon, 21 Apr 2025 16:24:38 +0200 Subject: [PATCH] small things --- cmd/root.go | 8 ++++---- internal/db/connect.go | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/cmd/root.go b/cmd/root.go index 545652a7a9e938e2b7a2598e253287146b98f543..8777acb823229ad82eed591fa1206fcab9ccc27c 100644 --- a/cmd/root.go +++ b/cmd/root.go @@ -182,7 +182,7 @@ func setupSubscriber[T any]( select { case event, ok := <-subCh: if !ok { - logging.Info("%s subscription channel closed", name) + logging.Info("subscription channel closed", "name", name) return } @@ -191,13 +191,13 @@ func setupSubscriber[T any]( select { case outputCh <- msg: case <-time.After(2 * time.Second): - logging.Warn("%s message dropped due to slow consumer", name) + logging.Warn("message dropped due to slow consumer", "name", name) case <-ctx.Done(): - logging.Info("%s subscription cancelled", name) + logging.Info("subscription cancelled", "name", name) return } case <-ctx.Done(): - logging.Info("%s subscription cancelled", name) + logging.Info("subscription cancelled", "name", name) return } } diff --git a/internal/db/connect.go b/internal/db/connect.go index e850bc8d02a4e9c685e1e5dc71260eacb44a0563..9335bfc263c288f4ca95cffb3bb212a99b0bcec5 100644 --- a/internal/db/connect.go +++ b/internal/db/connect.go @@ -48,9 +48,9 @@ func Connect() (*sql.DB, error) { for _, pragma := range pragmas { if _, err = db.Exec(pragma); err != nil { - logging.Warn("Failed to set pragma", pragma, err) + logging.Error("Failed to set pragma", pragma, err) } else { - logging.Warn("Set pragma", "pragma", pragma) + logging.Debug("Set pragma", "pragma", pragma) } }