Extract source IP address into context for OTLP/HTTP (#4257)

receiver/otlpreceiver/otlphttp.go

@@ -22,6 +22,7 @@ import (
  "google.golang.org/grpc/codes"
  "google.golang.org/grpc/status"
 
+ "go.opentelemetry.io/collector/client"
  "go.opentelemetry.io/collector/receiver/otlpreceiver/internal/logs"
  "go.opentelemetry.io/collector/receiver/otlpreceiver/internal/metrics"
  "go.opentelemetry.io/collector/receiver/otlpreceiver/internal/trace"
@@ -44,7 +45,12 @@ func handleTraces(resp http.ResponseWriter, req *http.Request, tracesReceiver *t
  return
  }
 
- otlpResp, err := tracesReceiver.Export(req.Context(), otlpReq)
+ ctx := req.Context()
+ if c, ok := client.FromHTTP(req); ok {
+ ctx = client.NewContext(ctx, c)
+ }
+
+ otlpResp, err := tracesReceiver.Export(ctx, otlpReq)
  if err != nil {
  writeError(resp, encoder, err, http.StatusInternalServerError)
  return
@@ -70,7 +76,12 @@ func handleMetrics(resp http.ResponseWriter, req *http.Request, metricsReceiver
  return
  }
 
- otlpResp, err := metricsReceiver.Export(req.Context(), otlpReq)
+ ctx := req.Context()
+ if c, ok := client.FromHTTP(req); ok {
+ ctx = client.NewContext(ctx, c)
+ }
+
+ otlpResp, err := metricsReceiver.Export(ctx, otlpReq)
  if err != nil {
  writeError(resp, encoder, err, http.StatusInternalServerError)
  return
@@ -96,7 +107,12 @@ func handleLogs(resp http.ResponseWriter, req *http.Request, logsReceiver *logs.
  return
  }
 
- otlpResp, err := logsReceiver.Export(req.Context(), otlpReq)
+ ctx := req.Context()
+ if c, ok := client.FromHTTP(req); ok {
+ ctx = client.NewContext(ctx, c)
+ }
+
+ otlpResp, err := logsReceiver.Export(ctx, otlpReq)
  if err != nil {
  writeError(resp, encoder, err, http.StatusInternalServerError)
  return