🐛 Fix key exchange to original client

2025-03-04 20:56:07 +08:00
parent 8ca5573b86
commit 1ed9816b12
1 changed files with 1 additions and 1 deletions
--- a/pkg/internal/grpc/stream.go
+++ b/pkg/internal/grpc/stream.go
@@ -113,7 +113,7 @@ func (v *App) PushStream(_ context.Context, request *proto.PushStreamRequest) (*

 		// Forward ack request
 		sc.PushStream(context.Background(), &proto.PushStreamRequest{
-			ClientId: request.ClientId,
+			ClientId: &data.ClientID,
 			Body: nex.WebSocketPackage{
 				Action:  "kex.ack",
 				Payload: data,