Initial commit

Author: joostlek

stacktrace_processor.go

@@ -16,9 +16,40 @@ import (
 
 type stackTraceProcessor struct {
 	nextConsumer consumer.Traces
+	sourceMaps   map[string][]byte
 }
 
 func (s *stackTraceProcessor) Start(ctx context.Context, host component.Host) error {
+	s.sourceMaps = make(map[string][]byte)
+	files, err := os.ReadDir("testdata")
+	if err != nil {
+		return err
+	}
+	for _, file := range files {
+		if strings.HasSuffix(file.Name(), ".map") {
+			err := s.ReadSourceMap("testdata", file.Name())
+			if err != nil {
+				return err
+			}
+		}
+	}
+	return nil
+}
+
+func (s *stackTraceProcessor) ReadSourceMap(path string, name string) error {
+	fullPath := fmt.Sprintf("%s/%s", path, name)
+	if path == "" {
+		fullPath = name
+	}
+	file, err := os.Open(fullPath)
+	if err != nil {
+		return err
+	}
+	b, err := io.ReadAll(file)
+	if err != nil {
+		return err
+	}
+	s.sourceMaps[name] = b
 	return nil
 }
 
@@ -35,36 +66,36 @@ func (s *stackTraceProcessor) ConsumeTraces(ctx context.Context, td ptrace.Trace
 		resourceSpan := td.ResourceSpans().At(resourceSpanId)
 		sdkLanguage, valid := resourceSpan.Resource().Attributes().Get("telemetry.sdk.language")
 		if valid && sdkLanguage.Str() == "webjs" {
-			ConsumeScopeSpans(resourceSpan.ScopeSpans())
+			s.ConsumeScopeSpans(resourceSpan.ScopeSpans())
 		}
 	}
 	return s.nextConsumer.ConsumeTraces(ctx, td)
 }
 
-func ConsumeScopeSpans(scopeSpans ptrace.ScopeSpansSlice) {
+func (s *stackTraceProcessor) ConsumeScopeSpans(scopeSpans ptrace.ScopeSpansSlice) {
 	for scopeSpanId := 0; scopeSpanId < scopeSpans.Len(); scopeSpanId++ {
 		spans := scopeSpans.At(scopeSpanId).Spans()
-		ConsumeSpans(spans)
+		s.ConsumeSpans(spans)
 	}
 }
 
-func ConsumeSpans(spans ptrace.SpanSlice) {
+func (s *stackTraceProcessor) ConsumeSpans(spans ptrace.SpanSlice) {
 	for spanId := 0; spanId < spans.Len(); spanId++ {
 		span := spans.At(spanId)
-		ConsumeSpan(span)
+		s.ConsumeSpan(span)
 	}
 }
 
-func ConsumeSpan(span ptrace.Span) {
+func (s *stackTraceProcessor) ConsumeSpan(span ptrace.Span) {
 	for eventId := 0; eventId < span.Events().Len(); eventId++ {
 		event := span.Events().At(eventId)
 		if event.Name() == "exception" {
-			ConsumeException(event)
+			s.ConsumeException(event)
 		}
 	}
 }
 
-func ConsumeException(event ptrace.SpanEvent) {
+func (s *stackTraceProcessor) ConsumeException(event ptrace.SpanEvent) {
 	stacktrace, valid := event.Attributes().Get("exception.stacktrace")
 	if valid != true {
 		return
@@ -93,27 +124,21 @@ func ConsumeException(event ptrace.SpanEvent) {
 			res = append(res, line)
 			continue
 		}
-		file, err := os.Open(fmt.Sprintf("%s.map", sourceFile))
+		mapFileName := fmt.Sprintf("%s.map", sourceFile)
+
+		smap, err := sourcemap.Parse(sourceFile, s.sourceMaps[mapFileName])
 		if err != nil {
 			res = append(res, line)
 			continue
 		}
-		b, err := io.ReadAll(file)
-		if err != nil {
+
+		finalFile, _, sourceLine, sourceColumn, ok := smap.Source(mapLine, mapColumn)
+		if ok != true {
 			res = append(res, line)
 			continue
 		}
-
-		smap, err := sourcemap.Parse(sourceFile, b)
-		if err != nil {
-			panic(err)
-		}
-
-		finalFile, fn, sourceLine, sourceColumn, ok := smap.Source(mapLine, mapColumn)
-		fmt.Println(finalFile, fn, sourceLine, sourceColumn, ok)
 		res = append(res, fmt.Sprintf("%s@%s:%d:%d", trace, finalFile, sourceLine, sourceColumn))
 	}
-	fmt.Println(res)
 	event.Attributes().PutStr("exception.stacktrace", strings.Join(res, "\n"))
 }
 

stacktrace_processor_test.go

@@ -24,6 +24,16 @@ func TestBatchProcessorSpansDeliveredEnforceBatchSize(t *testing.T) {
 
 	td := GenerateTraces()
 	assert.NoError(t, processor.ConsumeTraces(context.Background(), td))
+	for {
+		if sink.SpanCount() == 1 {
+			break
+		}
+	}
+	traces := sink.AllTraces()
+	event := traces[0].ResourceSpans().At(0).ScopeSpans().At(0).Spans().At(0).Events().At(0)
+	stackTrace, valid := event.Attributes().Get("exception.stacktrace")
+	assert.True(t, valid)
+	assert.Equal(t, "padStart@lib/lineSlicer.js:11:53\npadStart@http://localhost:4203/lineSlicers.min.js:1:228\n", stackTrace.Str())
 
 	require.NoError(t, processor.Shutdown(context.Background()))
 }
@@ -56,6 +66,6 @@ func fillExceptionSpan(span ptrace.Span) {
 	ev0.SetName("exception")
 	ev0.Attributes().PutStr("exception.type", "TypeError")
 	ev0.Attributes().PutStr("exception.message", "symbol.viewBox.baseVal is null")
-	ev0.Attributes().PutStr("exception.stacktrace", "loadSvg@http://localhost:4203/main.js:1514:21\nngOnInit/this.svgDefinition$<@http://localhost:4203/main.js:1397:23\nmap/</<@http://localhost:4203/vendor.js:47989:31\nOperatorSubscriber/this._next<@http://localhost:4203/vendor.js:47268:15\nnext@http://localhost:4203/vendor.js:46165:12\n_next@http://localhost:4203/vendor.js:46192:22\nnext@http://localhost:4203/vendor.js:46165:12\nmap/</<@http://localhost:4203/vendor.js:47989:18\nOperatorSubscriber/this._next<@http://localhost:4203/vendor.js:47268:15\nnext@http://localhost:4203/vendor.js:46165:12\nfilter/</<@http://localhost:4203/vendor.js:47771:175\nOperatorSubscriber/this._next<@http://localhost:4203/vendor.js:47268:15\nnext@http://localhost:4203/vendor.js:46165:12\ndoInnerSub/<@http://localhost:4203/vendor.js:48106:20\nOperatorSubscriber/this._next<@http://localhost:4203/vendor.js:47268:15\nnext@http://localhost:4203/vendor.js:46165:12\nswitchMap/</</innerSubscriber<@http://localhost:4203/vendor.js:48637:243\nOperatorSubscriber/this._next<@http://localhost:4203/vendor.js:47268:15\nnext@http://localhost:4203/vendor.js:46165:12\nonLoad@http://localhost:4203/vendor.js:83794:22\ninvokeTask@http://localhost:4203/polyfills.js:8205:171\nonInvokeTask@http://localhost:4203/vendor.js:110067:22\ninvokeTask@http://localhost:4203/polyfills.js:8205:54\nonInvokeTask@http://localhost:4203/vendor.js:110367:25\ninvokeTask@http://localhost:4203/polyfills.js:8205:54\nrunTask@http://localhost:4203/polyfills.js:8007:37\npatchRunTask@http://localhost:4203/vendor.js:3777:27\ninvokeTask@http://localhost:4203/polyfills.js:8282:26\ninvokeTask@http://localhost:4203/polyfills.js:9406:12\nglobalCallback@http://localhost:4203/polyfills.js:9447:33\nglobalZoneAwareCallback@http://localhost:4203/polyfills.js:9467:12\nEventListener.handleEvent*customScheduleGlobal@http://localhost:4203/polyfills.js:9555:37\nscheduleTask@http://localhost:4203/polyfills.js:8195:16\nonScheduleTask@http://localhost:4203/vendor.js:110060:21\nscheduleTask@http://localhost:4203/polyfills.js:8190:43\nonScheduleTask@http://localhost:4203/polyfills.js:8107:61\nscheduleTask@http://localhost:4203/polyfills.js:8190:43\nscheduleTask@http://localhost:4203/polyfills.js:8046:35\npatchScheduleTask@http://localhost:4203/vendor.js:3740:25\nscheduleEventTask@http://localhost:4203/polyfills.js:8071:19\nmakeAddListener/<@http://localhost:4203/polyfills.js:9706:27\nhandle/</<@http://localhost:4203/vendor.js:83881:13\n_trySubscribe@http://localhost:4203/vendor.js:45790:19\nsubscribe/<@http://localhost:4203/vendor.js:45784:113\nerrorContext@http://localhost:4203/vendor.js:50241:5\nsubscribe@http://localhost:4203/vendor.js:45779:69\nswitchMap/</<@http://localhost:4203/vendor.js:48637:100\nOperatorSubscriber/this._next<@http://localhost:4203/vendor.js:47268:15\nnext@http://localhost:4203/vendor.js:46165:12\nfromArrayLike/<@http://localhost:4203/vendor.js:46991:18\n_trySubscribe@http://localhost:4203/vendor.js:45790:19\nsubscribe/<@http://localhost:4203/vendor.js:45784:113\nerrorContext@http://localhost:4203/vendor.js:50241:5\nsubscribe@http://localhost:4203/vendor.js:45779:69\nswitchMap/<@http://localhost:4203/vendor.js:48633:12\noperate/</<@http://localhost:4203/vendor.js:50530:18\nsubscribe/<@http://localhost:4203/vendor.js:45784:42\nerrorContext@http://localhost:4203/vendor.js:50241:5\nsubscribe@http://localhost:4203/vendor.js:45779:69\ndoInnerSub@http://localhost:4203/vendor.js:48101:95\nouterNext@http://localhost:4203/vendor.js:48096:52\nOperatorSubscriber/this._next<@http://localhost:4203/vendor.js:47268:15\nnext@http://localhost:4203/vendor.js:46165:12\nfromArrayLike/<@http://localhost:4203/vendor.js:46991:18\n_trySubscribe@http://localhost:4203/vendor.js:45790:19\nsubscribe/<@http://localhost:4203/vendor.js:45784:113\nerrorContext@http://localhost:4203/vendor.js:50241:5\nsubscribe@http://localhost:4203/vendor.js:45779:69\nmergeInternals@http://localhost:4203/vendor.js:48129:10\nmergeMap/<@http://localhost:4203/vendor.js:48167:149\noperate/</<@http://localhost:4203/vendor.js:50530:18\nsubscribe/<@http://localhost:4203/vendor.js:45784:42\nerrorContext@http://localhost:4203/vendor.js:50241:5\nsubscribe@http://localhost:4203/vendor.js:45779:69\nfilter/<@http://localhost:4203/vendor.js:47771:12\noperate/</<@http://localhost:4203/vendor.js:50530:18\nsubscribe/<@http://localhost:4203/vendor.js:45784:42\nerrorContext@http://localhost:4203/vendor.js:50241:5\nsubscribe@http://localhost:4203/vendor.js:45779:69\nmap/<@http://localhost:4203/vendor.js:47988:12\noperate/</<@http://localhost:4203/vendor.js:50530:18\nsubscribe/<@http://localhost:4203/vendor.js:45784:42\nerrorContext@http://localhost:4203/vendor.js:50241:5\nsubscribe@http://localhost:4203/vendor.js:45779:69\ncatchError/<@http://localhost:4203/vendor.js:47404:23\noperate/</<@http://localhost:4203/vendor.js:50530:18\nsubscribe/<@http://localhost:4203/vendor.js:45784:42\nerrorContext@http://localhost:4203/vendor.js:50241:5\nsubscribe@http://localhost:4203/vendor.js:45779:69\ncatchError/</innerSub<@http://localhost:4203/vendor.js:47409:23\nOperatorSubscriber/this._error<@http://localhost:4203/vendor.js:47275:16\nerror@http://localhost:4203/vendor.js:46173:12\n_error@http://localhost:4203/vendor.js:46196:24\nerror@http://localhost:4203/vendor.js:46173:12\n_error@http://localhost:4203/vendor.js:46196:24\nerror@http://localhost:4203/vendor.js:46173:12\n_error@http://localhost:4203/vendor.js:46196:24\nerror@http://localhost:4203/vendor.js:46173:12\n_error@http://localhost:4203/vendor.js:46196:24\nerror@http://localhost:4203/vendor.js:46173:12\ninit@http://localhost:4203/vendor.js:47189:41\n_trySubscribe@http://localhost:4203/vendor.js:45790:19\nsubscribe/<@http://localhost:4203/vendor.js:45784:113\nerrorContext@http://localhost:4203/vendor.js:50241:5\nsubscribe@http://localhost:4203/vendor.js:45779:69\ncatchError/</innerSub<@http://localhost:4203/vendor.js:47409:23\nOperatorSubscriber/this._error<@http://localhost:4203/vendor.js:47275:16\nerror@http://localhost:4203/vendor.js:46173:12\ninit@http://localhost:4203/vendor.js:47189:41\n_trySubscribe@http://localhost:4203/vendor.js:45790:19\nsubscribe/<@http://localhost:4203/vendor.js:45784:113\nerrorContext@http://localhost:4203/vendor.js:50241:5\nsubscribe@http://localhost:4203/vendor.js:45779:69\ncatchError/</innerSub<@http://localhost:4203/vendor.js:47409:23\nOperatorSubscriber/this._error<@http://localhost:4203/vendor.js:47275:16\nerror@http://localhost:4203/vendor.js:46173:12\n_error@http://localhost:4203/vendor.js:46196:24\nerror@http://localhost:4203/vendor.js:46173:12\nonLoad@http://localhost:4203/vendor.js:83806:22\ninvokeTask@http://localhost:4203/polyfills.js:8205:171\nonInvokeTask@http://localhost:4203/vendor.js:110067:22\ninvokeTask@http://localhost:4203/polyfills.js:8205:54\nonInvokeTask@http://localhost:4203/vendor.js:110367:25\ninvokeTask@http://localhost:4203/polyfills.js:8205:54\nrunTask@http://localhost:4203/polyfills.js:8007:37\npatchRunTask@http://localhost:4203/vendor.js:3777:27\ninvokeTask@http://localhost:4203/polyfills.js:8282:26\ninvokeTask@http://localhost:4203/polyfills.js:9406:12\nglobalCallback@http://localhost:4203/polyfills.js:9447:33\n")
+	ev0.Attributes().PutStr("exception.stacktrace", "padStart@http://localhost:4203/lineSlicer.min.js:1:228\npadStart@http://localhost:4203/lineSlicers.min.js:1:228\n")
 	span.Status().SetCode(2)
 }