summaryrefslogtreecommitdiff
path: root/internal/server/api/helpers.go
diff options
context:
space:
mode:
authorKyren223 <Kyren223@proton.me>2025-07-09 16:20:59 +0300
committerKyren223 <Kyren223@proton.me>2025-07-19 18:32:12 +0300
commitba47118e5171a602e90d22951997bf220fd8deb1 (patch)
treedd270b5fe4c8242b5c8411ddc87f829f679066b1 /internal/server/api/helpers.go
parent402e2b41084fd6558a73121734a1bae66e4ae5ad (diff)
Replaced most log statements with slog on the server
Diffstat (limited to 'internal/server/api/helpers.go')
-rw-r--r--internal/server/api/helpers.go15
1 files changed, 8 insertions, 7 deletions
diff --git a/internal/server/api/helpers.go b/internal/server/api/helpers.go
index 7895a59..ea192df 100644
--- a/internal/server/api/helpers.go
+++ b/internal/server/api/helpers.go
@@ -2,12 +2,13 @@ package api
import (
"context"
- "log"
+ "log/slog"
"strings"
"time"
"github.com/kyren223/eko/internal/data"
"github.com/kyren223/eko/internal/packet"
+ "github.com/kyren223/eko/internal/server/ctxkeys"
"github.com/kyren223/eko/internal/server/session"
"github.com/kyren223/eko/pkg/snowflake"
)
@@ -66,7 +67,7 @@ func NetworkPropagateWithFilter(
Users: sessions,
})
if err != nil {
- log.Println("database error in propagate:", err)
+ slog.ErrorContext(ctx, "database error", "error", err)
return &ErrInternalError
}
@@ -80,7 +81,7 @@ func NetworkPropagateWithFilter(
go func() {
defer cancel()
if ok := session.Write(context, payload); !ok {
- log.Println(sess.Addr(), "propagation to", session.Addr(), "failed")
+ slog.ErrorContext(ctx, "propagation failed", "session", session.LogValue(), "reason", "write failed")
}
}()
}
@@ -110,11 +111,11 @@ func SplitMembersAndUsers(membersAndUsers []data.GetNetworkMembersRow) ([]data.M
func UserPropagate(
ctx context.Context, sess *session.Session,
- user snowflake.ID, payload packet.Payload,
+ userId snowflake.ID, payload packet.Payload,
) packet.Payload {
- session := sess.Manager().Session(user)
+ session := sess.Manager().Session(userId)
if session == nil {
- log.Println(sess.Addr(), "propagation to user", user, "failed due to session being nil")
+ slog.ErrorContext(ctx, "propagation failed", ctxkeys.UserID.String(), userId, "reason", "session is nil")
return payload
}
timeout := 1 * time.Second
@@ -122,7 +123,7 @@ func UserPropagate(
go func() {
defer cancel()
if ok := session.Write(context, payload); !ok {
- log.Println(sess.Addr(), "propagation to", session.Addr(), "failed")
+ slog.ErrorContext(ctx, "propagation failed", "session", session.LogValue(), "reason", "write failed")
}
}()