copy request body in fasthttp handler

andot · andot · commit b2401a7b7ebe · 2024-01-26T00:07:18.000+08:00
diff --git a/rpc/http/handler.go b/rpc/http/handler.go
@@ -276,7 +276,10 @@ func (h *Handler) ServeFastHTTP(ctx *fasthttp.RequestCtx) {
 		}
 	}
 	serviceContext := h.getFastHTTPServiceContext(ctx)
-	result, err := h.Service.Handle(core.WithContext(context.Background(), serviceContext), ctx.Request.Body())
+	body := ctx.Request.Body()
+	request := make([]byte, len(body))
+	copy(request, body)
+	result, err := h.Service.Handle(core.WithContext(context.Background(), serviceContext), request)
 	if err != nil {
 		h.onFastHTTPError(ctx, err)
 	}

Original file line number	Diff line number	Diff line change
`@@ -276,7 +276,10 @@ func (h Handler) ServeFastHTTP(ctx fasthttp.RequestCtx) {`
`276`	`276`	`}`
`277`	`277`	`}`
`278`	`278`	`serviceContext := h.getFastHTTPServiceContext(ctx)`
`279`		`- result, err := h.Service.Handle(core.WithContext(context.Background(), serviceContext), ctx.Request.Body())`
	`279`	`+ body := ctx.Request.Body()`
	`280`	`+ request := make([]byte, len(body))`
	`281`	`+ copy(request, body)`
	`282`	`+ result, err := h.Service.Handle(core.WithContext(context.Background(), serviceContext), request)`
`280`	`283`	`if err != nil {`
`281`	`284`	`h.onFastHTTPError(ctx, err)`
`282`	`285`	`}`