DDG: Remove kind.server filter and handle service calling itself

Signed-off-by: Ruben Vargas <[email protected]>
jaegertracing · Apr 4, 2020 · c9bb9ea · c9bb9ea
1 parent 4589298
commit c9bb9ea
Showing 1 changed file with 14 additions and 10 deletions.
diff --git a/packages/jaeger-ui/src/model/ddg/transformTracesToPaths.tsx b/packages/jaeger-ui/src/model/ddg/transformTracesToPaths.tsx
@@ -36,20 +36,24 @@ function transformTracesToPaths(
           return !span.hasChildren;
         })
         .forEach(leaf => {
-          const spans = spanAncestorIds(leaf).map(id => {
+          const spans = spanAncestorIds(leaf).reduce((acumulator: Span[], id: string): Span[] => {
             const span = spanMap.get(id);
             if (!span) throw new Error(`Ancestor spanID ${id} not found in trace ${traceID}`);
-            return span;
-          });
+            if (acumulator.length > 0) {
+              const headSpan = acumulator[acumulator.length - 1];
+              if (headSpan.processID === span.processID) {
+                return acumulator;
+              }
+            }
+            acumulator.push(span);
+            return acumulator;
+          }, []);
           spans.reverse();
           spans.push(leaf);
-
-          const path: TDdgPayloadEntry[] = spans
-            .filter(span => span.tags.find(({ key, value }) => key === 'span.kind' && value === 'server'))
-            .map(({ processID, operationName: operation }) => ({
-              service: data.processes[processID].serviceName,
-              operation,
-            }));
+          const path: TDdgPayloadEntry[] = spans.map(({ processID, operationName: operation }) => ({
+            service: data.processes[processID].serviceName,
+            operation,
+          }));
 
           if (
             path.some(