From 9e67f3b4a59f6310f1a7df452e6659b148915848 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=96=E7=95=8C?= Date: Sun, 18 Dec 2022 15:50:22 +0800 Subject: [PATCH] Fix user from stream packet conn --- inbound/http.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/inbound/http.go b/inbound/http.go index e2963db0..14a614b1 100644 --- a/inbound/http.go +++ b/inbound/http.go @@ -102,6 +102,12 @@ func (a *myInboundAdapter) newUserConnection(ctx context.Context, conn net.Conn, } func (a *myInboundAdapter) streamUserPacketConnection(ctx context.Context, conn N.PacketConn, metadata adapter.InboundContext) error { - a.logger.InfoContext(ctx, "inbound packet connection to ", metadata.Destination) + user, loaded := auth.UserFromContext[string](ctx) + if !loaded { + a.logger.InfoContext(ctx, "inbound packet connection to ", metadata.Destination) + return a.router.RoutePacketConnection(ctx, conn, metadata) + } + metadata.User = user + a.logger.InfoContext(ctx, "[", user, "] inbound packet connection to ", metadata.Destination) return a.router.RoutePacketConnection(ctx, conn, metadata) }