Fix: Disconnected Spans exported for Remote-log-url

pkg/gofr/exporter.go

@@ -25,6 +25,8 @@ type Exporter struct {
 	logger   logging.Logger // Logger for logging errors and other messages.
 }
 
+const SQLConnectTrace = "sql.connector.connect"
+
 // NewExporter creates a new Exporter instance with a custom endpoint and logger.
 func NewExporter(endpoint string, logger logging.Logger) *Exporter {
 	return &Exporter{
@@ -96,6 +98,10 @@ func convertSpans(spans []sdktrace.ReadOnlySpan) []Span {
 	convertedSpans := make([]Span, 0, len(spans))
 
 	for i, s := range spans {
+		if s.Name() == SQLConnectTrace {
+			continue
+		}
+
 		convertedSpan := Span{
 			TraceID:   s.SpanContext().TraceID().String(),
 			ID:        s.SpanContext().SpanID().String(),

pkg/gofr/service/new.go

@@ -137,12 +137,14 @@ func (h *httpService) createAndSendRequest(ctx context.Context, method string, p
 	uri := h.url + "/" + path
 	uri = strings.TrimRight(uri, "/")
 
-	spanContext, span := h.Tracer.Start(ctx, uri)
+	ctx, span := h.Tracer.Start(ctx, uri)
 	defer span.End()
 
-	spanContext = httptrace.WithClientTrace(spanContext, otelhttptrace.NewClientTrace(ctx))
+	// Attach client-side trace handling for HTTP request.
+	clientTraceCtx := httptrace.WithClientTrace(ctx, otelhttptrace.NewClientTrace(ctx))
 
-	req, err := http.NewRequestWithContext(spanContext, method, uri, bytes.NewBuffer(body))
+	// Create the HTTP request with the tracing context.
+	req, err := http.NewRequestWithContext(clientTraceCtx, method, uri, bytes.NewBuffer(body))
 	if err != nil {
 		return nil, err
 	}
@@ -161,25 +163,15 @@ func (h *httpService) createAndSendRequest(ctx context.Context, method string, p
 		req.Header.Set("Content-Type", "application/json")
 	}
 
-	// encode the query parameters on the request
-	encodeQueryParameters(req, queryParams)
-
-	if !trace.SpanFromContext(ctx).SpanContext().HasTraceID() {
-		// Start context and Tracing
-		ctx = req.Context()
+	// Inject tracing information into the request headers.
+	otel.GetTextMapPropagator().Inject(clientTraceCtx, propagation.HeaderCarrier(req.Header))
 
-		// extract the traceID and spanID from the headers and create a new context for the same
-		// this context will make a new span using the traceID and link the incoming SpanID as
-		// its parentID, thus connecting two spans
-		ctx = otel.GetTextMapPropagator().Extract(ctx, propagation.HeaderCarrier(req.Header))
-	}
-
-	// inject the TraceParent header manually in the request headers
-	otel.GetTextMapPropagator().Inject(spanContext, propagation.HeaderCarrier(req.Header))
+	// encode the query parameters on the request.
+	encodeQueryParameters(req, queryParams)
 
 	log := &Log{
 		Timestamp:     time.Now(),
-		CorrelationID: trace.SpanFromContext(ctx).SpanContext().TraceID().String(),
+		CorrelationID: trace.SpanFromContext(clientTraceCtx).SpanContext().TraceID().String(),
 		HTTPMethod:    method,
 		URI:           uri,
 	}
@@ -196,12 +188,12 @@ func (h *httpService) createAndSendRequest(ctx context.Context, method string, p
 		log.ResponseCode = http.StatusInternalServerError
 		h.Log(&ErrorLog{Log: log, ErrorMessage: err.Error()})
 
-		h.updateMetrics(ctx, method, respTime.Seconds(), http.StatusInternalServerError)
+		h.updateMetrics(clientTraceCtx, method, respTime.Seconds(), http.StatusInternalServerError)
 
 		return resp, err
 	}
 
-	h.updateMetrics(ctx, method, respTime.Seconds(), resp.StatusCode)
+	h.updateMetrics(clientTraceCtx, method, respTime.Seconds(), resp.StatusCode)
 	log.ResponseCode = resp.StatusCode
 
 	h.Log(log)