diff options
| author | Kyren223 <Kyren223@proton.me> | 2025-07-06 18:20:46 +0300 |
|---|---|---|
| committer | Kyren223 <Kyren223@proton.me> | 2025-07-06 18:20:46 +0300 |
| commit | bbd4eae95fe7dec5b85e2124eb016c7a10a390fe (patch) | |
| tree | f6fc7870a97b28b87fa16e112e93d8be28cc397a /internal/server/api/api.go | |
| parent | d4475050721738f26652c914b0668f887aac97b8 (diff) | |
Added better logging for packets and payloads and now the writer is
responsible for packaging into a packet the payload (instead of everyone
who sends to the writer)
Diffstat (limited to 'internal/server/api/api.go')
| -rw-r--r-- | internal/server/api/api.go | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/internal/server/api/api.go b/internal/server/api/api.go index 2640433..e507997 100644 --- a/internal/server/api/api.go +++ b/internal/server/api/api.go @@ -14,7 +14,6 @@ import ( "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/assert" "github.com/kyren223/eko/pkg/snowflake" @@ -1626,7 +1625,7 @@ func Authenticate(ctx context.Context, sess *session.Session, request *packet.Au // NOTE: as per the protocol, this must be the first message after auth payload := &packet.UsersInfo{Users: []data.User{user}} - ok := sess.Write(ctx, WrapPayload(payload)) + ok := sess.Write(ctx, payload) if !ok { // Timeout, send at least this payload, client can request the rest return payload @@ -1657,8 +1656,8 @@ func sendInitialAuthPackets(ctx context.Context, sess *session.Session) bool { success = false continue } - slog.InfoContext(ctx, "sending initial auth payload", ctxkeys.Payload.String(), payload, ctxkeys.PayloadType.String(), payload.Type()) - ok := sess.Write(ctx, WrapPayload(payload)) + slog.InfoContext(ctx, "sending initial auth payload", "payload", payload, "payload_type", payload.Type()) + ok := sess.Write(ctx, payload) if !ok { success = false continue |