// Copyright (c) 2019 The Jaeger Authors. // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. import { TraceResponse } from '../types/trace'; import transformTraceData, { orderTags, deduplicateTags } from './transform-trace-data'; describe('orderTags()', () => { it('correctly orders tags', () => { const orderedTags = orderTags( [ { key: 'b.ip', value: '8.8.4.4' }, { key: 'http.Status_code', value: '200' }, { key: 'z.ip', value: '8.8.8.16' }, { key: 'a.ip', value: '8.8.8.8' }, { key: 'http.message', value: 'ok' }, ], ['z.', 'a.', 'HTTP.'] ); expect(orderedTags).toEqual([ { key: 'z.ip', value: '8.8.8.16' }, { key: 'a.ip', value: '8.8.8.8' }, { key: 'http.message', value: 'ok' }, { key: 'http.Status_code', value: '200' }, { key: 'b.ip', value: '8.8.4.4' }, ]); }); }); describe('deduplicateTags()', () => { it('deduplicates tags', () => { const tagsInfo = deduplicateTags([ { key: 'b.ip', value: '8.8.4.4' }, { key: 'b.ip', value: '8.8.8.8' }, { key: 'b.ip', value: '8.8.4.4' }, { key: 'a.ip', value: '8.8.8.8' }, ]); expect(tagsInfo.dedupedTags).toEqual([ { key: 'b.ip', value: '8.8.4.4' }, { key: 'b.ip', value: '8.8.8.8' }, { key: 'a.ip', value: '8.8.8.8' }, ]); expect(tagsInfo.warnings).toEqual(['Duplicate tag "b.ip:8.8.4.4"']); }); }); describe('transformTraceData()', () => { const startTime = 1586160015434000; const duration = 34000; const traceID = 'f77950feed55c1ce91dd8e87896623a6'; const rootSpanID = 'd4dcb46e95b781f5'; const rootOperationName = 'rootOperation'; const serviceName = 'serviceName'; const spans = [ { traceID, spanID: '41f71485ed2593e4', operationName: 'someOperationName', references: [ { refType: 'CHILD_OF', traceID, spanID: rootSpanID, }, ], startTime, duration, tags: [], processID: 'p1', }, { traceID, spanID: '4f623fd33c213cba', operationName: 'anotherOperationName', references: [ { refType: 'CHILD_OF', traceID, spanID: rootSpanID, }, ], startTime: startTime + 100, duration, tags: [], processID: 'p1', }, ]; const rootSpanWithMissingRef = { traceID, spanID: rootSpanID, operationName: rootOperationName, references: [ { refType: 'CHILD_OF', traceID, spanID: 'missingSpanId', }, ], startTime: startTime + 50, duration, tags: [], processID: 'p1', }; const rootSpanWithoutRefs = { traceID, spanID: rootSpanID, operationName: rootOperationName, startTime: startTime + 50, duration, tags: [], processID: 'p1', }; const processes = { p1: { serviceName, tags: [], }, }; it('should return null for trace without traceID', () => { const traceData = { traceID: undefined, processes, spans, } as unknown as TraceResponse; expect(transformTraceData(traceData)).toEqual(null); }); it('should return trace data with correct traceName based on root span with missing ref', () => { const traceData = { traceID, processes, spans: [...spans, rootSpanWithMissingRef], } as unknown as TraceResponse; expect(transformTraceData(traceData)!.traceName).toEqual(`${serviceName}: ${rootOperationName}`); }); it('should return trace data with correct traceName based on root span without any refs', () => { const traceData = { traceID, processes, spans: [...spans, rootSpanWithoutRefs], } as unknown as TraceResponse; expect(transformTraceData(traceData)!.traceName).toEqual(`${serviceName}: ${rootOperationName}`); }); });