summaryrefslogtreecommitdiff
path: root/internal/db/bundb/hook.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/db/bundb/hook.go')
-rw-r--r--internal/db/bundb/hook.go26
1 files changed, 12 insertions, 14 deletions
diff --git a/internal/db/bundb/hook.go b/internal/db/bundb/hook.go
index 6f9935272..23f334048 100644
--- a/internal/db/bundb/hook.go
+++ b/internal/db/bundb/hook.go
@@ -22,7 +22,9 @@ import (
"context"
"time"
- "github.com/sirupsen/logrus"
+ "codeberg.org/gruf/go-kv"
+ "codeberg.org/gruf/go-logger/v2/level"
+ "github.com/superseriousbusiness/gotosocial/internal/log"
"github.com/uptrace/bun"
)
@@ -38,21 +40,17 @@ func (queryHook) AfterQuery(_ context.Context, event *bun.QueryEvent) {
// Get the DB query duration
dur := time.Since(event.StartTime)
- log := func(lvl logrus.Level, msg string) {
- logrus.WithFields(logrus.Fields{
- "duration": dur,
- "operation": event.Operation(),
- "query": event.Query,
- }).Log(lvl, msg)
- }
-
switch {
// Warn on slow database queries
case dur > time.Second:
- log(logrus.WarnLevel, "SLOW DATABASE QUERY")
-
- // On trace, we log query information
- case logrus.GetLevel() == logrus.TraceLevel:
- log(logrus.TraceLevel, "database query")
+ log.WithFields(kv.Fields{
+ {"duration", dur},
+ {"query", event.Query},
+ }...).Warn("SLOW DATABASE QUERY")
+
+ // On trace, we log query information,
+ // manually crafting so DB query not escaped.
+ case log.Level() >= level.TRACE:
+ log.Printf("level=TRACE duration=%s query=%s", dur, event.Query)
}
}