From bdef101bc004451d320cbf575a25bf016772a8bf Mon Sep 17 00:00:00 2001 From: LittleSheep Date: Tue, 4 Mar 2025 00:44:30 +0800 Subject: [PATCH] :bug: Fix key exchange missing client id --- pkg/internal/grpc/stream.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/pkg/internal/grpc/stream.go b/pkg/internal/grpc/stream.go index 449b8fd..6b15088 100644 --- a/pkg/internal/grpc/stream.go +++ b/pkg/internal/grpc/stream.go @@ -69,10 +69,12 @@ func (v *App) PushStream(_ context.Context, request *proto.PushStreamRequest) (* break } + raw, _ := jsoniter.Marshal(data) + // Forward ask request sc.PushStream(context.Background(), &proto.PushStreamRequest{ UserId: lo.ToPtr(uint64(data.UserID)), - Body: request.GetBody(), + Body: raw, }) case "kex.ack": var data struct { @@ -111,10 +113,12 @@ func (v *App) PushStream(_ context.Context, request *proto.PushStreamRequest) (* break } + raw, _ := jsoniter.Marshal(data) + // Forward ack request sc.PushStream(context.Background(), &proto.PushStreamRequest{ ClientId: request.ClientId, - Body: request.GetBody(), + Body: raw, }) }