| 286 | } |
| 287 | |
| 288 | func (vs *ValidationService) validateTraceRetrieval( |
| 289 | ctx context.Context, |
| 290 | trace *util.TraceInfo, |
| 291 | httpClient httpclient.TempoHTTPClient, |
| 292 | ) error { |
| 293 | start := trace.Timestamp().Add(-10 * time.Minute).Unix() |
| 294 | end := trace.Timestamp().Add(10 * time.Minute).Unix() |
| 295 | |
| 296 | retrievedTrace, err := httpClient.QueryTraceWithRange(ctx, trace.HexID(), start, end) |
| 297 | if err != nil { |
| 298 | return fmt.Errorf("failed to read trace: %w", err) |
| 299 | } |
| 300 | |
| 301 | if len(retrievedTrace.ResourceSpans) == 0 { |
| 302 | return fmt.Errorf("retrieved trace has no spans") |
| 303 | } |
| 304 | |
| 305 | retrievedTraceID := extractTraceID(retrievedTrace) |
| 306 | |
| 307 | equal, err := util.EqualHexStringTraceIDs(trace.HexID(), retrievedTraceID) |
| 308 | if err != nil { |
| 309 | return fmt.Errorf("error comparing trace IDs: %w", err) |
| 310 | } |
| 311 | |
| 312 | if !equal { |
| 313 | return fmt.Errorf("trace IDs do not match") |
| 314 | } |
| 315 | |
| 316 | vs.logger.Info("Retrieved trace", zap.String("traceID", retrievedTraceID)) |
| 317 | |
| 318 | return nil |
| 319 | } |
| 320 | |
| 321 | func (vs *ValidationService) validateTraceSearch( |
| 322 | _ context.Context, |