Merge pull request 'copy incoming content-type' (#169) from ct into v3

Reviewed-on: #169

go.mod

@@ -1,11 +1,17 @@
 module go.unistack.org/micro-server-grpc/v3
 
-go 1.16
+go 1.20
 
 require (
-	github.com/golang/protobuf v1.5.2
-	go.unistack.org/micro/v3 v3.10.14
-	golang.org/x/net v0.5.0
-	google.golang.org/grpc v1.52.3
-	google.golang.org/protobuf v1.28.1
+	github.com/golang/protobuf v1.5.3
+	go.unistack.org/micro/v3 v3.10.31
+	golang.org/x/net v0.17.0
+	google.golang.org/grpc v1.59.0
+	google.golang.org/protobuf v1.31.0
+)
+
+require (
+	golang.org/x/sys v0.13.0 // indirect
+	golang.org/x/text v0.13.0 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20231030173426-d783a09b4405 // indirect
 )

grpc.go

@@ -234,6 +234,10 @@ func (g *Server) handler(srv interface{}, stream grpc.ServerStream) (err error)
 	for k, v := range gmd {
 		md.Set(k, strings.Join(v, ", "))
 	}
+	md.Set("Path", fullMethod)
+	md.Set("Micro-Server", "grpc")
+	md.Set(metadata.HeaderEndpoint, methodName)
+	md.Set(metadata.HeaderService, serviceName)
 
 	var td string
 	// timeout for server deadline

subscriber.go

@@ -132,9 +132,6 @@ func (g *Server) createSubHandler(sb *subscriber, opts server.Options) broker.Ha
 
 		hdr := make(map[string]string, len(msg.Header))
 		for k, v := range msg.Header {
-			if k == "Content-Type" {
-				continue
-			}
 			hdr[k] = v
 		}