diff options
| author | Kyren223 <Kyren223@proton.me> | 2025-07-09 16:20:59 +0300 |
|---|---|---|
| committer | Kyren223 <Kyren223@proton.me> | 2025-07-19 18:32:12 +0300 |
| commit | ba47118e5171a602e90d22951997bf220fd8deb1 (patch) | |
| tree | dd270b5fe4c8242b5c8411ddc87f829f679066b1 /internal/server/api/helpers.go | |
| parent | 402e2b41084fd6558a73121734a1bae66e4ae5ad (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.go | 15 |
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") } }() |
