feat(grpc-gateway-v2): Add environment variable HTTP_GO_LOG_HTTP_HEADER to set http header logging for the default logger

Author: searKing

third_party/github.com/grpc-ecosystem/grpc-gateway-v2/go.mod

@@ -4,9 +4,9 @@ go 1.24.0
 
 require (
 	github.com/gin-gonic/gin v1.11.0
-	github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.3.2
+	github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.3.3
 	github.com/grpc-ecosystem/grpc-gateway/v2 v2.27.3
-	github.com/searKing/golang/go v1.2.124
+	github.com/searKing/golang/go v1.2.136
 	github.com/searKing/golang/third_party/google.golang.org/grpc v1.2.120
 	google.golang.org/grpc v1.76.0
 	google.golang.org/protobuf v1.36.10

third_party/github.com/grpc-ecosystem/grpc-gateway-v2/go.sum

@@ -35,8 +35,8 @@ github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX
 github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
-github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.3.2 h1:sGm2vDRFUrQJO/Veii4h4zG2vvqG6uWNkBHSTqXOZk0=
-github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.3.2/go.mod h1:wd1YpapPLivG6nQgbf7ZkG1hhSOXDhhn4MLTknx2aAc=
+github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.3.3 h1:B+8ClL/kCQkRiU82d9xajRPKYMrB7E0MbtzWVi1K4ns=
+github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.3.3/go.mod h1:NbCUVmiS4foBGBHOYlCT25+YmGpJ32dZPi75pGEUpj4=
 github.com/grpc-ecosystem/grpc-gateway/v2 v2.27.3 h1:NmZ1PKzSTQbuGHw9DGPFomqkkLWMC+vZCkfs+FHv1Vg=
 github.com/grpc-ecosystem/grpc-gateway/v2 v2.27.3/go.mod h1:zQrxl1YP88HQlA6i9c63DSVPFklWpGX4OWAc9bFuaH4=
 github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM=

third_party/github.com/grpc-ecosystem/grpc-gateway-v2/grpc/logging.http.go

@@ -8,6 +8,7 @@ import (
 	"fmt"
 	"log/slog"
 	"net/http"
+	"os"
 	"strconv"
 	"strings"
 	"time"
@@ -27,6 +28,14 @@ var (
 // Logger will read existing and write new logging.Fields available in current context.
 // See `ExtractFields` and `InjectFields` for details.
 func HttpInterceptor(l logging.Logger) func(handler http.Handler) http.Handler {
+	var logHttpHeader bool
+	{
+		vHeader := os.Getenv("HTTP_GO_LOG_HTTP_HEADER")
+		if vh, err := strconv.ParseBool(vHeader); err == nil {
+			logHttpHeader = vh
+		}
+	}
+
 	return func(handler http.Handler) http.Handler {
 		return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
 			var cost time_.Cost
@@ -35,16 +44,28 @@ func HttpInterceptor(l logging.Logger) func(handler http.Handler) http.Handler {
 			attrs = append(attrs, slog.String(SystemTag[0], SystemTag[1]))
 			attrs = append(attrs, slog.Time("http.start_time", time.Now()))
 			attrs = append(attrs, extractLoggingFieldsFromHttpRequest(r)...)
-			l.Log(r.Context(), logging.LevelInfo, fmt.Sprintf("http request received"), attrs...)
+
+			var reqAttrs = attrs
+			if logHttpHeader {
+				reqAttrs = append(reqAttrs, httpHeaderToAttr(r.Header, "http.request.header"))
+			}
+			l.Log(r.Context(), logging.LevelInfo, fmt.Sprintf("http request received"), reqAttrs...)
 
 			rw := http_.NewResponseWriterDelegator(w)
 			handler.ServeHTTP(rw, r)
 
-			attrs = append(attrs, slog.String("http.status_code", slices_.FirstOrZero(http.StatusText(rw.Status()), "CODE("+strconv.FormatInt(int64(rw.Status()), 10)+")")),
+			attrs = append(attrs,
+				slog.String("http.status_code", slices_.FirstOrZero(http.StatusText(rw.Status()), "CODE("+strconv.FormatInt(int64(rw.Status()), 10)+")")),
 				slog.Duration("cost", cost.Elapse()),
 				slog.Int64("http.request_body_size", r.ContentLength),
 				slog.Int64("http.response_body_size", rw.Written()))
-			l.Log(r.Context(), logging.LevelInfo, fmt.Sprintf("finished http call with code %d", rw.Status()), attrs...)
+
+			var respAttrs = attrs
+			if logHttpHeader {
+				respAttrs = append(respAttrs, httpHeaderToAttr(r.Header, "http.response.header"))
+			}
+			l.Log(r.Context(), logging.LevelInfo, fmt.Sprintf("finished http call with status code %d", rw.Status()),
+				respAttrs...)
 		})
 	}
 }
@@ -76,3 +97,11 @@ func extractLoggingFieldsFromHttpRequest(r *http.Request) []any {
 	}
 	return attrs
 }
+
+func httpHeaderToAttr(h http.Header, k string) slog.Attr {
+	var attrs []slog.Attr
+	for k, v := range h {
+		attrs = append(attrs, slog.Any(k, v))
+	}
+	return slog.GroupAttrs(k, attrs...)
+}