12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973 |
- import type {Theme} from '@emotion/react';
- import type {Client} from 'sentry/api';
- import type {RawSpanType} from 'sentry/components/events/interfaces/spans/types';
- import {pickBarColor} from 'sentry/components/performance/waterfall/utils';
- import type {Organization} from 'sentry/types';
- import type {Event, EventTransaction, Measurement} from 'sentry/types/event';
- import {MobileVital, WebVital} from 'sentry/utils/fields';
- import type {
- TraceError as TraceErrorType,
- TraceFullDetailed,
- TracePerformanceIssue,
- TraceSplitResults,
- } from 'sentry/utils/performance/quickTrace/types';
- import {
- isTraceError,
- isTraceTransaction,
- } from 'sentry/utils/performance/quickTrace/utils';
- import {
- MOBILE_VITAL_DETAILS,
- WEB_VITAL_DETAILS,
- } from 'sentry/utils/performance/vitals/constants';
- import type {Vital} from 'sentry/utils/performance/vitals/types';
- import {TraceType} from '../traceDetails/newTraceDetailsContent';
- import {isRootTransaction} from '../traceDetails/utils';
- import {
- isAutogroupedNode,
- isMissingInstrumentationNode,
- isNoDataNode,
- isParentAutogroupedNode,
- isRootNode,
- isSiblingAutogroupedNode,
- isSpanNode,
- isTraceErrorNode,
- isTraceNode,
- isTransactionNode,
- shouldAddMissingInstrumentationSpan,
- } from './guards';
- /**
- *
- * This file implements the tree data structure that is used to represent a trace. We do
- * this both for performance reasons as well as flexibility. The requirement for a tree
- * is to support incremental patching and updates. This is important because we want to
- * be able to fetch more data as the user interacts with the tree, and we want to be able
- * efficiently update the tree as we receive more data.
- *
- * The trace is represented as a tree with different node value types (transaction or span)
- * Each tree node contains a reference to its parent and a list of references to its children,
- * as well as a reference to the value that the node holds. Each node also contains
- * some meta data and state about the node, such as if it is expanded or zoomed in. The benefit
- * of abstracting parts of the UI state is that the tree will persist user actions such as expanding
- * or collapsing nodes which would have otherwise been lost when individual nodes are remounted in the tree.
- *
- * Each tree holds a list reference, which is a live reference to a flattened representation
- * of the tree (used to render the tree in the UI). Since the list is mutable (and we want to keep it that way for performance
- * reasons as we want to support mutations on traces with ~100k+ nodes), callers need to manage reactivity themselves.
- *
- * An alternative, but not recommended approach is to call build() on the tree after each mutation,
- * which will iterate over all of the children and build a fresh list reference.
- *
- * In most cases, the initial tree is a list of transactions containing other transactions. Each transaction can
- * then be expanded into a list of spans which can also in some cases be expanded.
- *
- * - trace - trace
- * |- parent transaction --> when expanding |- parent transaction
- * |- child transaction |- span
- * |- span this used to be a transaction,
- * |- child transaction span <- but is now be a list of spans
- * |- span belonging to the transaction
- * this results in child txns to be lost,
- * which is a confusing user experience
- *
- * The tree supports autogrouping of spans vertically or as siblings. When that happens, a autogrouped node of either a vertical or
- * sibling type is inserted as an intermediary node. In the vertical case, the autogrouped node
- * holds the reference to the head and tail of the autogrouped sequence. In the sibling case, the autogrouped node
- * holds a reference to the children that are part of the autogrouped sequence. When expanding and collapsing these nodes,
- * the tree perform a reference swap to either point to the head (when expanded) or tail (when collapsed) of the autogrouped sequence.
- *
- * In vertical grouping case, the following happens:
- *
- * - root - root
- * - trace - trace
- * |- transaction |- transaction
- * |- span 1 <-| these become autogrouped |- autogrouped (head=span1, tail=span3, children points to children of tail)
- * |- span 2 |- as they are inserted into |- other span (parent points to autogrouped node)
- * |- span 3 <-| the tree.
- * |- other span
- *
- * When the autogrouped node is expanded the UI needs to show the entire collapsed chain, so we swap the tail children to point
- * back to the tail, and have autogrouped node point to it's head as the children.
- *
- * - root - root
- * - trace - trace
- * |- transaction |- transaction
- * |- autogrouped (head=span1, tail=span3) <- when expanding |- autogrouped (head=span1, tail=span3, children points to head)
- * | other span (paren points to autogrouped) |- span 1 (head)
- * |- span 2
- * |- span 3 (tail)
- * |- other span (children of tail, parent points to tail)
- *
- * Notes and improvements:
- * - the notion of expanded and zoomed is confusing, they stand for the same idea from a UI pov
- * - there is an annoying thing wrt span and transaction nodes where we either store data on _children or _spanChildren
- * this is because we want to be able to store both transaction and span nodes in the same tree, but it makes for an
- * annoying API. A better design would have been to create an invisible meta node that just points to the correct children
- * - instead of storing span children separately, we should have meta tree nodes that handle pointing to the correct children
- */
- export declare namespace TraceTree {
- type Transaction = TraceFullDetailed;
- interface Span extends RawSpanType {
- childTransaction: Transaction | undefined;
- event: EventTransaction;
- }
- type Trace = TraceSplitResults<Transaction>;
- type TraceError = TraceErrorType;
- type Profile = {profile_id: string; space: [number, number]};
- interface MissingInstrumentationSpan {
- start_timestamp: number;
- timestamp: number;
- type: 'missing_instrumentation';
- }
- interface SiblingAutogroup extends RawSpanType {
- autogrouped_by: {
- description: string;
- op: string;
- };
- }
- interface ChildrenAutogroup extends RawSpanType {
- autogrouped_by: {
- op: string;
- };
- }
- type NodeValue =
- | Trace
- | Transaction
- | TraceError
- | Span
- | MissingInstrumentationSpan
- | SiblingAutogroup
- | ChildrenAutogroup
- | null;
- type NodePath =
- `${'txn' | 'span' | 'ag' | 'trace' | 'ms' | 'error' | 'empty'}:${string}`;
- type Metadata = {
- event_id: string | undefined;
- project_slug: string | undefined;
- };
- type Indicator = {
- duration: number;
- label: string;
- measurement: Measurement;
- poor: boolean;
- start: number;
- type: 'cls' | 'fcp' | 'fp' | 'lcp' | 'ttfb';
- };
- type CollectedVital = {key: string; measurement: Measurement};
- }
- function cacheKey(organization: Organization, project_slug: string, event_id: string) {
- return organization.slug + ':' + project_slug + ':' + event_id;
- }
- function fetchTransactionSpans(
- api: Client,
- organization: Organization,
- project_slug: string,
- event_id: string
- ): Promise<EventTransaction> {
- return api.requestPromise(
- `/organizations/${organization.slug}/events/${project_slug}:${event_id}/?averageColumn=span.self_time`
- );
- }
- function measurementToTimestamp(
- start_timestamp: number,
- measurement: number,
- unit: string
- ) {
- if (unit === 'second') {
- return start_timestamp + measurement;
- }
- if (unit === 'millisecond') {
- return start_timestamp + measurement / 1e3;
- }
- if (unit === 'nanosecond') {
- return start_timestamp + measurement / 1e9;
- }
- throw new TypeError(`Unsupported measurement unit', ${unit}`);
- }
- function maybeInsertMissingInstrumentationSpan(
- parent: TraceTreeNode<TraceTree.NodeValue>,
- node: TraceTreeNode<TraceTree.Span>
- ) {
- const previousSpan = parent.spanChildren[parent.spanChildren.length - 1];
- if (!previousSpan || !isSpanNode(previousSpan)) {
- return;
- }
- if (node.value.start_timestamp - previousSpan.value.timestamp < 0.1) {
- return;
- }
- const missingInstrumentationSpan = new MissingInstrumentationNode(
- parent,
- {
- type: 'missing_instrumentation',
- start_timestamp: previousSpan.value.timestamp,
- timestamp: node.value.start_timestamp,
- },
- {
- event_id: undefined,
- project_slug: undefined,
- },
- previousSpan,
- node
- );
- parent.spanChildren.push(missingInstrumentationSpan);
- }
- export function makeTraceNodeBarColor(
- theme: Theme,
- node: TraceTreeNode<TraceTree.NodeValue>
- ): string {
- if (isTransactionNode(node)) {
- return pickBarColor(node.value['transaction.op']);
- }
- if (isSpanNode(node)) {
- return pickBarColor(node.value.op);
- }
- if (isAutogroupedNode(node)) {
- return theme.blue300;
- }
- if (isMissingInstrumentationNode(node)) {
- return theme.gray300;
- }
- if (isTraceErrorNode(node)) {
- return theme.red300;
- }
- if (isNoDataNode(node)) {
- return theme.yellow300;
- }
- return pickBarColor('default');
- }
- function shouldCollapseNodeByDefault(node: TraceTreeNode<TraceTree.NodeValue>) {
- if (isSpanNode(node)) {
- // Android creates TCP connection spans which are noisy and not useful in most cases
- if (node.value.op === 'http.client' && node.value.origin === 'auto.http.okhttp') {
- return true;
- }
- }
- return false;
- }
- // cls is not included as it is a cumulative layout shift and not a single point in time
- const RENDERABLE_MEASUREMENTS = [
- WebVital.TTFB,
- WebVital.FP,
- WebVital.FCP,
- WebVital.LCP,
- MobileVital.TIME_TO_FULL_DISPLAY,
- MobileVital.TIME_TO_INITIAL_DISPLAY,
- ]
- .map(n => n.replace('measurements.', ''))
- .reduce((acc, curr) => {
- acc[curr] = true;
- return acc;
- }, {});
- const WEB_VITALS = [
- WebVital.TTFB,
- WebVital.FP,
- WebVital.FCP,
- WebVital.LCP,
- WebVital.CLS,
- WebVital.FID,
- WebVital.INP,
- WebVital.REQUEST_TIME,
- ].map(n => n.replace('measurements.', ''));
- const MOBILE_VITALS = [
- MobileVital.TIME_TO_FULL_DISPLAY,
- MobileVital.TIME_TO_INITIAL_DISPLAY,
- ].map(n => n.replace('measurements.', ''));
- const WEB_VITALS_LOOKUP = new Set<string>(WEB_VITALS);
- const MOBILE_VITALS_LOOKUP = new Set<string>(MOBILE_VITALS);
- const COLLECTABLE_MEASUREMENTS = [...WEB_VITALS, ...MOBILE_VITALS].map(n =>
- n.replace('measurements.', '')
- );
- const MEASUREMENT_ACRONYM_MAPPING = {
- [MobileVital.TIME_TO_FULL_DISPLAY.replace('measurements.', '')]: 'TTFD',
- [MobileVital.TIME_TO_INITIAL_DISPLAY.replace('measurements.', '')]: 'TTID',
- };
- const MEASUREMENT_THRESHOLDS = {
- [WebVital.TTFB.replace('measurements.', '')]: 600,
- [WebVital.FP.replace('measurements.', '')]: 3000,
- [WebVital.FCP.replace('measurements.', '')]: 3000,
- [WebVital.LCP.replace('measurements.', '')]: 4000,
- [MobileVital.TIME_TO_INITIAL_DISPLAY.replace('measurements.', '')]: 2000,
- };
- export const TRACE_MEASUREMENT_LOOKUP: Record<string, Vital> = {};
- for (const key in {...MOBILE_VITAL_DETAILS, ...WEB_VITAL_DETAILS}) {
- TRACE_MEASUREMENT_LOOKUP[key.replace('measurements.', '')] = {
- ...MOBILE_VITAL_DETAILS[key],
- ...WEB_VITAL_DETAILS[key],
- };
- }
- export class TraceTree {
- type: 'loading' | 'empty' | 'error' | 'trace' = 'trace';
- root: TraceTreeNode<null> = TraceTreeNode.Root();
- indicators: TraceTree.Indicator[] = [];
- vitals: Map<TraceTreeNode<TraceTree.NodeValue>, TraceTree.CollectedVital[]> = new Map();
- vital_types: Set<'web' | 'mobile'> = new Set();
- eventsCount: number = 0;
- private _spanPromises: Map<string, Promise<Event>> = new Map();
- private _list: TraceTreeNode<TraceTree.NodeValue>[] = [];
- static Empty() {
- const tree = new TraceTree().build();
- tree.type = 'empty';
- return tree;
- }
- static Loading(metadata: TraceTree.Metadata, tree?: TraceTree | null): TraceTree {
- const t = tree ? TraceTree.FromTree(tree) : makeExampleTrace(metadata);
- t.type = 'loading';
- return t;
- }
- static Error(metadata: TraceTree.Metadata, tree?: TraceTree | null): TraceTree {
- const t = tree ? TraceTree.FromTree(tree) : makeExampleTrace(metadata);
- t.type = 'error';
- return t;
- }
- static FromTree(tree: TraceTree): TraceTree {
- const newTree = new TraceTree();
- newTree.root = tree.root.cloneDeep() as TraceTreeNode<null>;
- newTree.indicators = tree.indicators;
- newTree._list = tree._list;
- return newTree;
- }
- static FromTrace(trace: TraceTree.Trace): TraceTree {
- const tree = new TraceTree();
- let traceStart = Number.POSITIVE_INFINITY;
- let traceEnd = Number.NEGATIVE_INFINITY;
- const traceNode = new TraceTreeNode(tree.root, trace, {
- event_id: undefined,
- project_slug: undefined,
- });
- // Trace is always expanded by default
- tree.root.children.push(traceNode);
- function visit(
- parent: TraceTreeNode<TraceTree.NodeValue | null>,
- value: TraceFullDetailed | TraceTree.TraceError
- ) {
- const node = new TraceTreeNode(parent, value, {
- project_slug: value && 'project_slug' in value ? value.project_slug : undefined,
- event_id: value && 'event_id' in value ? value.event_id : undefined,
- });
- node.canFetch = true;
- tree.eventsCount += 1;
- if (isTraceTransaction(value)) {
- for (const error of value.errors) {
- traceNode.errors.add(error);
- }
- for (const performanceIssue of value.performance_issues) {
- traceNode.performance_issues.add(performanceIssue);
- }
- } else {
- traceNode.errors.add(value);
- }
- if (parent) {
- parent.children.push(node as TraceTreeNode<TraceTree.NodeValue>);
- }
- if ('start_timestamp' in value && value.start_timestamp < traceStart) {
- traceStart = value.start_timestamp;
- }
- if ('timestamp' in value && typeof value.timestamp === 'number') {
- // Errors don't have 'start_timestamp', so we adjust traceStart
- // with an errors 'timestamp'
- if (isTraceError(value)) {
- traceStart = Math.min(value.timestamp, traceStart);
- }
- traceEnd = Math.max(value.timestamp, traceEnd);
- }
- if (value && 'measurements' in value) {
- tree.collectMeasurements(
- node,
- traceStart,
- value.measurements as Record<string, Measurement>,
- tree.vitals,
- tree.vital_types,
- tree.indicators
- );
- }
- if (value && 'children' in value) {
- for (const child of value.children) {
- visit(node, child);
- }
- }
- return node;
- }
- const transactionQueue = trace.transactions ?? [];
- const orphanErrorsQueue = trace.orphan_errors ?? [];
- let tIdx = 0;
- let oIdx = 0;
- const tLen = transactionQueue.length;
- const oLen = orphanErrorsQueue.length;
- while (tIdx < tLen || oIdx < oLen) {
- const transaction = transactionQueue[tIdx];
- const orphan = orphanErrorsQueue[oIdx];
- if (transaction && orphan) {
- if (
- typeof orphan.timestamp === 'number' &&
- transaction.start_timestamp <= orphan.timestamp
- ) {
- visit(traceNode, transaction);
- tIdx++;
- } else {
- visit(traceNode, orphan);
- oIdx++;
- }
- } else if (transaction) {
- visit(traceNode, transaction);
- tIdx++;
- } else if (orphan) {
- visit(traceNode, orphan);
- oIdx++;
- }
- }
- if (tree.indicators.length > 0) {
- tree.indicators.sort((a, b) => a.start - b.start);
- for (const indicator of tree.indicators) {
- if (indicator.start > traceEnd) {
- traceEnd = indicator.start;
- }
- indicator.start *= traceNode.multiplier;
- }
- }
- traceNode.space = [
- traceStart * traceNode.multiplier,
- (traceEnd - traceStart) * traceNode.multiplier,
- ];
- tree.root.space = [
- traceStart * traceNode.multiplier,
- (traceEnd - traceStart) * traceNode.multiplier,
- ];
- return tree.build();
- }
- get shape(): TraceType {
- const trace = this.root.children[0];
- if (!trace) {
- return TraceType.EMPTY_TRACE;
- }
- if (!isTraceNode(trace)) {
- throw new TypeError('Not trace node');
- }
- const {transactions, orphan_errors} = trace.value;
- const {roots, orphans} = (transactions ?? []).reduce(
- (counts, transaction) => {
- if (isRootTransaction(transaction)) {
- counts.roots++;
- } else {
- counts.orphans++;
- }
- return counts;
- },
- {roots: 0, orphans: 0}
- );
- if (roots === 0) {
- if (orphans > 0) {
- return TraceType.NO_ROOT;
- }
- if (orphan_errors && orphan_errors.length > 0) {
- return TraceType.ONLY_ERRORS;
- }
- return TraceType.EMPTY_TRACE;
- }
- if (roots === 1) {
- if (orphans > 0) {
- return TraceType.BROKEN_SUBTRACES;
- }
- return TraceType.ONE_ROOT;
- }
- if (roots > 1) {
- return TraceType.MULTIPLE_ROOTS;
- }
- throw new Error('Unknown trace type');
- }
- static FromSpans(
- parent: TraceTreeNode<TraceTree.NodeValue>,
- data: Event,
- spans: RawSpanType[],
- options: {sdk: string | undefined} | undefined
- ): TraceTreeNode<TraceTree.NodeValue> {
- parent.invalidate(parent);
- const platformHasMissingSpans = shouldAddMissingInstrumentationSpan(options?.sdk);
- const parentIsSpan = isSpanNode(parent);
- const lookuptable: Record<
- RawSpanType['span_id'],
- TraceTreeNode<TraceTree.Span | TraceTree.Transaction>
- > = {};
- // If we've already fetched children, the tree is already assembled
- if (parent.spanChildren.length > 0) {
- parent.zoomedIn = true;
- return parent;
- }
- // If we have no spans, insert an empty node to indicate that there is no data
- if (!spans.length && !parent.children.length) {
- parent.zoomedIn = true;
- parent.spanChildren.push(new NoDataNode(parent));
- return parent;
- }
- if (parentIsSpan) {
- if (parent.value && 'span_id' in parent.value) {
- lookuptable[parent.value.span_id] = parent as TraceTreeNode<TraceTree.Span>;
- }
- }
- const transactionsToSpanMap = new Map<string, TraceTreeNode<TraceTree.Transaction>>();
- for (const child of parent.children) {
- if (
- isTransactionNode(child) &&
- 'parent_span_id' in child.value &&
- typeof child.value.parent_span_id === 'string'
- ) {
- transactionsToSpanMap.set(child.value.parent_span_id, child);
- }
- continue;
- }
- for (const span of spans) {
- const childTransaction = transactionsToSpanMap.get(span.span_id);
- const spanNodeValue: TraceTree.Span = {
- ...span,
- event: data as EventTransaction,
- childTransaction: childTransaction?.value,
- };
- const node: TraceTreeNode<TraceTree.Span> = new TraceTreeNode(null, spanNodeValue, {
- event_id: undefined,
- project_slug: undefined,
- });
- for (const error of getRelatedSpanErrorsFromTransaction(span, parent)) {
- node.errors.add(error);
- }
- for (const performanceIssue of getRelatedPerformanceIssuesFromTransaction(
- span,
- parent
- )) {
- node.performance_issues.add(performanceIssue);
- }
- // This is the case where the current span is the parent of a txn at the
- // trace level. When zooming into the parent of the txn, we want to place a copy
- // of the txn as a child of the parenting span.
- if (childTransaction) {
- const clonedChildTxn =
- childTransaction.cloneDeep() as unknown as TraceTreeNode<TraceTree.Span>;
- node.spanChildren.push(clonedChildTxn);
- clonedChildTxn.parent = node;
- }
- lookuptable[span.span_id] = node;
- if (span.parent_span_id) {
- const spanParentNode = lookuptable[span.parent_span_id];
- if (spanParentNode) {
- node.parent = spanParentNode;
- if (platformHasMissingSpans) {
- maybeInsertMissingInstrumentationSpan(spanParentNode, node);
- }
- spanParentNode.spanChildren.push(node);
- continue;
- }
- }
- if (platformHasMissingSpans) {
- maybeInsertMissingInstrumentationSpan(parent, node);
- }
- parent.spanChildren.push(node);
- node.parent = parent;
- }
- parent.zoomedIn = true;
- TraceTree.AutogroupSiblingSpanNodes(parent);
- TraceTree.AutogroupDirectChildrenSpanNodes(parent);
- return parent;
- }
- static AutogroupDirectChildrenSpanNodes(
- root: TraceTreeNode<TraceTree.NodeValue>
- ): void {
- const queue = [root];
- while (queue.length > 0) {
- const node = queue.pop()!;
- if (node.children.length > 1 || !isSpanNode(node)) {
- for (const child of node.children) {
- queue.push(child);
- }
- continue;
- }
- const head = node;
- let tail = node;
- let groupMatchCount = 0;
- const errors: TraceErrorType[] = [];
- const performance_issues: TracePerformanceIssue[] = [];
- let start = head.value.start_timestamp;
- let end = head.value.timestamp;
- while (
- tail &&
- tail.children.length === 1 &&
- isSpanNode(tail.children[0]) &&
- tail.children[0].value.op === head.value.op
- ) {
- if ((tail?.errors?.size ?? 0) > 0) {
- errors.push(...tail?.errors);
- }
- if ((tail?.performance_issues?.size ?? 0) > 0) {
- performance_issues.push(...tail.performance_issues);
- }
- // Collect start/end of all nodes in the list
- // so that we can properly render a autogrouped bar that
- // encapsulates all the nodes in the list
- if (tail.value.start_timestamp < start) {
- start = tail.value.start_timestamp;
- }
- if (tail.value.timestamp > end) {
- end = tail.value.timestamp;
- }
- groupMatchCount++;
- tail = tail.children[0];
- }
- // Checking the tail node for errors as it is not included in the grouping
- // while loop, but is hidden when the autogrouped node is collapsed
- if ((tail?.errors?.size ?? 0) > 0) {
- errors.push(...tail?.errors);
- }
- if ((tail?.performance_issues?.size ?? 0) > 0) {
- performance_issues.push(...tail.performance_issues);
- }
- if (groupMatchCount < 1) {
- for (const child of head.children) {
- queue.push(child);
- }
- continue;
- }
- const autoGroupedNode = new ParentAutogroupNode(
- node.parent,
- {
- ...head.value,
- start_timestamp: start,
- timestamp: end,
- autogrouped_by: {
- op: head.value && 'op' in head.value ? head.value.op ?? '' : '',
- },
- },
- {
- event_id: undefined,
- project_slug: undefined,
- },
- head,
- tail
- );
- if (!node.parent) {
- throw new Error('Parent node is missing, this should be unreachable code');
- }
- autoGroupedNode.groupCount = groupMatchCount + 1;
- for (const error of errors) {
- autoGroupedNode.errors.add(error);
- }
- for (const performanceIssue of performance_issues) {
- autoGroupedNode.performance_issues.add(performanceIssue);
- }
- autoGroupedNode.space = [
- start * autoGroupedNode.multiplier,
- (end - start) * autoGroupedNode.multiplier,
- ];
- for (const c of tail.children) {
- c.parent = autoGroupedNode;
- queue.push(c);
- }
- const index = node.parent.children.indexOf(node);
- node.parent.children[index] = autoGroupedNode;
- }
- }
- static AutogroupSiblingSpanNodes(root: TraceTreeNode<TraceTree.NodeValue>): void {
- const queue = [root];
- while (queue.length > 0) {
- const node = queue.pop()!;
- for (const child of node.children) {
- queue.push(child);
- }
- if (isAutogroupedNode(node)) {
- continue;
- }
- if (node.children.length < 5) {
- continue;
- }
- let index = 0;
- let matchCount = 0;
- while (index < node.children.length) {
- const current = node.children[index] as TraceTreeNode<TraceTree.Span>;
- const next = node.children[index + 1] as TraceTreeNode<TraceTree.Span>;
- if (
- next &&
- next.children.length === 0 &&
- current.children.length === 0 &&
- next.value.op === current.value.op &&
- next.value.description === current.value.description
- ) {
- matchCount++;
- // If the next node is the last node in the list, we keep iterating
- if (index + 1 < node.children.length) {
- index++;
- continue;
- }
- }
- if (matchCount >= 4) {
- const autoGroupedNode = new SiblingAutogroupNode(
- node,
- {
- ...current.value,
- autogrouped_by: {
- op: current.value.op ?? '',
- description: current.value.description ?? '',
- },
- },
- {
- event_id: undefined,
- project_slug: undefined,
- }
- );
- autoGroupedNode.groupCount = matchCount + 1;
- const start = index - matchCount;
- let start_timestamp = Number.MAX_SAFE_INTEGER;
- let timestamp = Number.MIN_SAFE_INTEGER;
- for (let j = start; j < start + matchCount + 1; j++) {
- const child = node.children[j];
- if (
- child.value &&
- 'timestamp' in child.value &&
- typeof child.value.timestamp === 'number' &&
- child.value.timestamp > timestamp
- ) {
- timestamp = child.value.timestamp;
- }
- if (
- child.value &&
- 'start_timestamp' in child.value &&
- typeof child.value.start_timestamp === 'number' &&
- child.value.start_timestamp < start_timestamp
- ) {
- start_timestamp = child.value.start_timestamp;
- }
- if (!isSpanNode(child)) {
- throw new TypeError(
- 'Expected child of autogrouped node to be a span node.'
- );
- }
- if (child.has_errors) {
- for (const error of child.errors) {
- autoGroupedNode.errors.add(error);
- }
- for (const performanceIssue of child.performance_issues) {
- autoGroupedNode.performance_issues.add(performanceIssue);
- }
- }
- autoGroupedNode.children.push(node.children[j]);
- autoGroupedNode.children[autoGroupedNode.children.length - 1].parent =
- autoGroupedNode;
- }
- autoGroupedNode.space = [
- start_timestamp * autoGroupedNode.multiplier,
- (timestamp - start_timestamp) * autoGroupedNode.multiplier,
- ];
- node.children.splice(start, matchCount + 1, autoGroupedNode);
- index = start + 1;
- matchCount = 0;
- } else {
- index++;
- matchCount = 0;
- }
- }
- }
- }
- collectMeasurements(
- node: TraceTreeNode<TraceTree.NodeValue>,
- start_timestamp: number,
- measurements: Record<string, Measurement>,
- vitals: Map<TraceTreeNode<TraceTree.NodeValue>, TraceTree.CollectedVital[]>,
- vital_types: Set<'web' | 'mobile'>,
- indicators: TraceTree.Indicator[]
- ): void {
- for (const measurement of COLLECTABLE_MEASUREMENTS) {
- const value = measurements[measurement];
- if (!value || typeof value.value !== 'number') {
- continue;
- }
- if (!vitals.has(node)) {
- vitals.set(node, []);
- }
- WEB_VITALS_LOOKUP.has(measurement) && vital_types.add('web');
- MOBILE_VITALS_LOOKUP.has(measurement) && vital_types.add('mobile');
- const vital = vitals.get(node)!;
- vital.push({
- key: measurement,
- measurement: value,
- });
- if (!RENDERABLE_MEASUREMENTS[measurement]) {
- continue;
- }
- const timestamp = measurementToTimestamp(
- start_timestamp,
- value.value,
- value.unit ?? 'millisecond'
- );
- indicators.push({
- start: timestamp,
- duration: 0,
- measurement: value,
- poor: MEASUREMENT_THRESHOLDS[measurement]
- ? value.value > MEASUREMENT_THRESHOLDS[measurement]
- : false,
- type: measurement as TraceTree.Indicator['type'],
- label: (MEASUREMENT_ACRONYM_MAPPING[measurement] ?? measurement).toUpperCase(),
- });
- }
- }
- // Returns boolean to indicate if node was updated
- expand(node: TraceTreeNode<TraceTree.NodeValue>, expanded: boolean): boolean {
- if (expanded === node.expanded) {
- return false;
- }
- // Expanding is not allowed for zoomed in nodes
- if (node.zoomedIn) {
- return false;
- }
- if (node instanceof ParentAutogroupNode) {
- // In parent autogrouping, we perform a node swap and either point the
- // head or tails of the autogrouped sequence to the autogrouped node
- if (node.expanded) {
- const index = this._list.indexOf(node);
- const autogroupedChildren = node.getVisibleChildren();
- this._list.splice(index + 1, autogroupedChildren.length);
- const newChildren = node.tail.getVisibleChildren();
- for (const c of node.tail.children) {
- c.parent = node;
- }
- this._list.splice(index + 1, 0, ...newChildren);
- } else {
- node.head.parent = node;
- const index = this._list.indexOf(node);
- const childrenCount = node.getVisibleChildrenCount();
- this._list.splice(index + 1, childrenCount);
- node.getVisibleChildrenCount();
- const newChildren = [node.head].concat(
- node.head.getVisibleChildren() as TraceTreeNode<TraceTree.Span>[]
- );
- for (const c of node.children) {
- c.parent = node.tail;
- }
- this._list.splice(index + 1, 0, ...newChildren);
- }
- node.invalidate(node);
- node.expanded = expanded;
- return true;
- }
- if (node.expanded) {
- const index = this._list.indexOf(node);
- this._list.splice(index + 1, node.getVisibleChildrenCount());
- // Flip expanded after collecting visible children
- node.expanded = expanded;
- } else {
- const index = this._list.indexOf(node);
- // Flip expanded so that we can collect visible children
- node.expanded = expanded;
- this._list.splice(index + 1, 0, ...node.getVisibleChildren());
- }
- node.expanded = expanded;
- return true;
- }
- zoomIn(
- node: TraceTreeNode<TraceTree.NodeValue>,
- zoomedIn: boolean,
- options: {
- api: Client;
- organization: Organization;
- }
- ): Promise<Event | null> {
- if (zoomedIn === node.zoomedIn) {
- return Promise.resolve(null);
- }
- if (!zoomedIn) {
- const index = this._list.indexOf(node);
- const childrenCount = node.getVisibleChildrenCount();
- this._list.splice(index + 1, childrenCount);
- node.zoomedIn = zoomedIn;
- node.invalidate(node);
- if (node.expanded) {
- this._list.splice(index + 1, 0, ...node.getVisibleChildren());
- }
- return Promise.resolve(null);
- }
- const key = cacheKey(
- options.organization,
- node.metadata.project_slug!,
- node.metadata.event_id!
- );
- const promise =
- this._spanPromises.get(key) ??
- fetchTransactionSpans(
- options.api,
- options.organization,
- node.metadata.project_slug!,
- node.metadata.event_id!
- );
- node.fetchStatus = 'loading';
- promise
- .then(data => {
- // The user may have collapsed the node before the promise resolved. When that
- // happens, dont update the tree with the resolved data. Alternatively, we could implement
- // a cancellable promise and avoid this cumbersome heuristic.
- node.fetchStatus = 'resolved';
- if (!node.expanded) {
- return data;
- }
- const spans = data.entries.find(s => s.type === 'spans') ?? {data: []};
- // Remove existing entries from the list
- const index = this._list.indexOf(node);
- if (node.expanded) {
- const childrenCount = node.getVisibleChildrenCount();
- if (childrenCount > 0) {
- this._list.splice(index + 1, childrenCount);
- }
- }
- // Api response is not sorted
- spans.data.sort((a, b) => a.start_timestamp - b.start_timestamp);
- TraceTree.FromSpans(node, data, spans.data, {sdk: data.sdk?.name});
- const spanChildren = node.getVisibleChildren();
- this._list.splice(index + 1, 0, ...spanChildren);
- return data;
- })
- .catch(_e => {
- node.fetchStatus = 'error';
- });
- this._spanPromises.set(key, promise);
- return promise;
- }
- toList(): TraceTreeNode<TraceTree.NodeValue>[] {
- const list: TraceTreeNode<TraceTree.NodeValue>[] = [];
- function visit(node: TraceTreeNode<TraceTree.NodeValue>) {
- list.push(node);
- if (!node.expanded) {
- return;
- }
- for (const child of node.children) {
- visit(child);
- }
- }
- for (const child of this.root.children) {
- visit(child);
- }
- return list;
- }
- get list(): ReadonlyArray<TraceTreeNode<TraceTree.NodeValue>> {
- return this._list;
- }
- /**
- * Prints the tree in a human readable format, useful for debugging and testing
- */
- print() {
- // root nodes are -1 indexed, so we add 1 to the depth so .repeat doesnt throw
- const print = this.list
- .map(t => printNode(t, 0))
- .filter(Boolean)
- .join('\n');
- // eslint-disable-next-line no-console
- console.log(print);
- }
- build() {
- this._list = this.toList();
- return this;
- }
- }
- export class TraceTreeNode<T extends TraceTree.NodeValue> {
- canFetch: boolean = false;
- fetchStatus: 'resolved' | 'error' | 'idle' | 'loading' = 'idle';
- parent: TraceTreeNode<TraceTree.NodeValue> | null = null;
- value: T;
- expanded: boolean = false;
- zoomedIn: boolean = false;
- metadata: TraceTree.Metadata = {
- project_slug: undefined,
- event_id: undefined,
- };
- errors: Set<TraceErrorType> = new Set<TraceErrorType>();
- performance_issues: Set<TracePerformanceIssue> = new Set<TracePerformanceIssue>();
- multiplier: number;
- space: [number, number] | null = null;
- profiles: TraceTree.Profile[] = [];
- private unit: 'milliseconds' = 'milliseconds';
- private _depth: number | undefined;
- private _children: TraceTreeNode<TraceTree.NodeValue>[] = [];
- private _spanChildren: TraceTreeNode<
- TraceTree.Span | TraceTree.MissingInstrumentationSpan
- >[] = [];
- private _connectors: number[] | undefined = undefined;
- constructor(
- parent: TraceTreeNode<TraceTree.NodeValue> | null,
- value: T,
- metadata: TraceTree.Metadata
- ) {
- this.parent = parent ?? null;
- this.value = value;
- this.metadata = metadata;
- this.multiplier = this.unit === 'milliseconds' ? 1e3 : 1;
- if (value && 'timestamp' in value && 'start_timestamp' in value) {
- this.space = [
- value.start_timestamp * this.multiplier,
- (value.timestamp - value.start_timestamp) * this.multiplier,
- ];
- } else if (value && 'timestamp' in value && typeof value.timestamp === 'number') {
- this.space = [value.timestamp * this.multiplier, 0];
- }
- if (
- isTraceErrorNode(this) &&
- 'timestamp' in this.value &&
- typeof this.value.timestamp === 'number'
- ) {
- this.space = [this.value.timestamp * this.multiplier, 0];
- }
- if (value && 'profile_id' in value && typeof value.profile_id === 'string') {
- this.profiles.push({profile_id: value.profile_id, space: this.space ?? [0, 0]});
- }
- if (isTransactionNode(this)) {
- this.canFetch = true;
- }
- if (isTransactionNode(this) || isTraceNode(this) || isSpanNode(this)) {
- this.expanded = true;
- }
- if (shouldCollapseNodeByDefault(this)) {
- this.expanded = false;
- }
- if (isTransactionNode(this)) {
- this.errors = new Set(this.value.errors);
- this.performance_issues = new Set(this.value.performance_issues);
- }
- // For error nodes, its value is the only associated issue.
- if (isTraceErrorNode(this)) {
- this.errors = new Set([this.value]);
- }
- }
- cloneDeep():
- | TraceTreeNode<T>
- | ParentAutogroupNode
- | SiblingAutogroupNode
- | NoDataNode {
- let clone: TraceTreeNode<T> | ParentAutogroupNode | SiblingAutogroupNode | NoDataNode;
- if (isParentAutogroupedNode(this)) {
- clone = new ParentAutogroupNode(
- this.parent,
- this.value,
- this.metadata,
- this.head,
- this.tail
- );
- clone.groupCount = this.groupCount;
- } else if (isSiblingAutogroupedNode(this)) {
- clone = new SiblingAutogroupNode(this.parent, this.value, this.metadata);
- clone.groupCount = this.groupCount;
- } else if (isNoDataNode(this)) {
- clone = new NoDataNode(this.parent);
- } else {
- clone = new TraceTreeNode(this.parent, this.value, this.metadata);
- }
- if (!clone) {
- throw new Error('CloneDeep is not implemented');
- }
- clone.expanded = this.expanded;
- clone.zoomedIn = this.zoomedIn;
- clone.canFetch = this.canFetch;
- clone.space = this.space;
- clone.metadata = this.metadata;
- if (isParentAutogroupedNode(clone)) {
- clone.head = clone.head.cloneDeep() as TraceTreeNode<TraceTree.Span>;
- clone.tail = clone.tail.cloneDeep() as TraceTreeNode<TraceTree.Span>;
- clone.head.parent = clone;
- // If the node is not expanded, the parent of the tail points to the
- // autogrouped clone. If the node is expanded, the parent of the children
- // of the tail points to the autogrouped clone.
- if (!clone.expanded) {
- for (const c of clone.tail.children) {
- c.parent = clone;
- }
- } else {
- for (const c of clone.children) {
- c.parent = clone.tail;
- }
- }
- clone.head.parent = clone;
- clone.tail.parent = clone;
- } else if (isSiblingAutogroupedNode(clone)) {
- for (const child of this.children) {
- const childClone = child.cloneDeep() as TraceTreeNode<TraceTree.Span>;
- clone.children.push(childClone);
- childClone.parent = clone;
- }
- } else {
- for (const child of this.children) {
- const childClone = child.cloneDeep() as TraceTreeNode<TraceTree.Span>;
- clone.children.push(childClone);
- childClone.parent = clone;
- }
- }
- return clone;
- }
- get isOrphaned() {
- return this.parent?.value && 'orphan_errors' in this.parent.value;
- }
- get isLastChild() {
- if (!this.parent || this.parent.children.length === 0) {
- return true;
- }
- return this.parent.children[this.parent.children.length - 1] === this;
- }
- /**
- * Return a lazily calculated depth of the node in the tree.
- * Root node has a value of -1 as it is abstract.
- */
- get depth(): number {
- if (typeof this._depth === 'number') {
- return this._depth;
- }
- let depth = -2;
- let node: TraceTreeNode<any> | null = this;
- while (node) {
- if (typeof node.parent?.depth === 'number') {
- this._depth = node.parent.depth + 1;
- return this._depth;
- }
- depth++;
- node = node.parent;
- }
- this._depth = depth;
- return this._depth;
- }
- get has_errors(): boolean {
- return this.errors.size > 0 || this.performance_issues.size > 0;
- }
- get parent_transaction(): TraceTreeNode<TraceTree.Transaction> | null {
- let node: TraceTreeNode<TraceTree.NodeValue> | null = this.parent;
- while (node) {
- if (isTransactionNode(node)) {
- return node;
- }
- node = node.parent;
- }
- return null;
- }
- /**
- * Returns the depth levels at which the row should draw vertical connectors
- * negative values mean connector points to an orphaned node
- */
- get connectors(): number[] {
- if (this._connectors !== undefined) {
- return this._connectors!;
- }
- this._connectors = [];
- if (!this.parent) {
- return this._connectors;
- }
- if (this.parent?.connectors !== undefined) {
- this._connectors = [...this.parent.connectors];
- if (this.isLastChild || this.value === null) {
- return this._connectors;
- }
- this.connectors.push(this.isOrphaned ? -this.depth : this.depth);
- return this._connectors;
- }
- let node: TraceTreeNode<T> | TraceTreeNode<TraceTree.NodeValue> | null = this.parent;
- while (node) {
- if (node.value === null) {
- break;
- }
- if (node.isLastChild) {
- node = node.parent;
- continue;
- }
- this._connectors.push(node.isOrphaned ? -node.depth : node.depth);
- node = node.parent;
- }
- return this._connectors;
- }
- /**
- * Returns the children that the node currently points to.
- * The logic here is a consequence of the tree design, where we want to be able to store
- * both transaction and span nodes in the same tree. This results in an annoying API where
- * we either store span children separately or transaction children separately. A better design
- * would have been to create an invisible meta node that always points to the correct children.
- */
- get children(): TraceTreeNode<TraceTree.NodeValue>[] {
- if (isAutogroupedNode(this)) {
- return this._children;
- }
- if (isSpanNode(this)) {
- return this.canFetch && !this.zoomedIn ? [] : this.spanChildren;
- }
- if (isTransactionNode(this)) {
- return this.zoomedIn ? this._spanChildren : this._children;
- }
- return this._children;
- }
- set children(children: TraceTreeNode<TraceTree.NodeValue>[]) {
- this._children = children;
- }
- get spanChildren(): (
- | TraceTreeNode<TraceTree.Span | TraceTree.MissingInstrumentationSpan>
- | NoDataNode
- )[] {
- return this._spanChildren;
- }
- /**
- * Invalidate the visual data used to render the tree, forcing it
- * to be recalculated on the next render. This is useful when for example
- * the tree is expanded or collapsed, or when the tree is mutated and
- * the visual data is no longer valid as the indentation changes
- */
- invalidate(root?: TraceTreeNode<TraceTree.NodeValue>) {
- this._connectors = undefined;
- this._depth = undefined;
- if (root) {
- const queue = [...this.children];
- if (isParentAutogroupedNode(this)) {
- queue.push(this.head);
- }
- while (queue.length > 0) {
- const next = queue.pop()!;
- next.invalidate();
- if (isParentAutogroupedNode(next)) {
- queue.push(next.head);
- }
- for (let i = 0; i < next.children.length; i++) {
- queue.push(next.children[i]);
- }
- }
- }
- }
- getVisibleChildrenCount(): number {
- const stack: TraceTreeNode<TraceTree.NodeValue>[] = [];
- let count = 0;
- if (
- this.expanded ||
- isParentAutogroupedNode(this) ||
- isMissingInstrumentationNode(this)
- ) {
- for (let i = this.children.length - 1; i >= 0; i--) {
- stack.push(this.children[i]);
- }
- }
- while (stack.length > 0) {
- const node = stack.pop()!;
- count++;
- // Since we're using a stack and it's LIFO, reverse the children before pushing them
- // to ensure they are processed in the original left-to-right order.
- if (node.expanded || isParentAutogroupedNode(node)) {
- for (let i = node.children.length - 1; i >= 0; i--) {
- stack.push(node.children[i]);
- }
- }
- }
- return count;
- }
- getVisibleChildren(): TraceTreeNode<TraceTree.NodeValue>[] {
- const stack: TraceTreeNode<TraceTree.NodeValue>[] = [];
- const children: TraceTreeNode<TraceTree.NodeValue>[] = [];
- if (
- this.expanded ||
- isParentAutogroupedNode(this) ||
- isMissingInstrumentationNode(this)
- ) {
- for (let i = this.children.length - 1; i >= 0; i--) {
- stack.push(this.children[i]);
- }
- }
- while (stack.length > 0) {
- const node = stack.pop()!;
- children.push(node);
- // Since we're using a stack and it's LIFO, reverse the children before pushing them
- // to ensure they are processed in the original left-to-right order.
- if (node.expanded || isParentAutogroupedNode(node)) {
- for (let i = node.children.length - 1; i >= 0; i--) {
- stack.push(node.children[i]);
- }
- }
- }
- return children;
- }
- // Returns the min path required to reach the node from the root.
- // @TODO: skip nodes that do not require fetching
- get path(): TraceTree.NodePath[] {
- const nodes: TraceTreeNode<TraceTree.NodeValue>[] = [this];
- let current: TraceTreeNode<TraceTree.NodeValue> | null = this.parent;
- if (isSpanNode(this) || isAutogroupedNode(this)) {
- while (
- current &&
- (isSpanNode(current) || (isAutogroupedNode(current) && !current.expanded))
- ) {
- current = current.parent;
- }
- }
- while (current) {
- if (isTransactionNode(current)) {
- nodes.push(current);
- }
- if (isSpanNode(current)) {
- nodes.push(current);
- while (current.parent) {
- if (isTransactionNode(current.parent)) {
- break;
- }
- if (isAutogroupedNode(current.parent) && current.parent.expanded) {
- break;
- }
- current = current.parent;
- }
- }
- if (isAutogroupedNode(current)) {
- nodes.push(current);
- }
- current = current.parent;
- }
- return nodes.map(nodeToId);
- }
- print() {
- // root nodes are -1 indexed, so we add 1 to the depth so .repeat doesnt throw
- const offset = this.depth === -1 ? 1 : 0;
- const nodes = [this, ...this.getVisibleChildren()];
- const print = nodes
- .map(t => printNode(t, offset))
- .filter(Boolean)
- .join('\n');
- // eslint-disable-next-line no-console
- console.log(print);
- }
- static Find(
- root: TraceTreeNode<TraceTree.NodeValue>,
- predicate: (node: TraceTreeNode<TraceTree.NodeValue>) => boolean
- ): TraceTreeNode<TraceTree.NodeValue> | null {
- const queue = [root];
- while (queue.length > 0) {
- const next = queue.pop()!;
- if (predicate(next)) return next;
- for (const child of next.children) {
- queue.push(child);
- }
- }
- return null;
- }
- static Root() {
- return new TraceTreeNode(null, null, {
- event_id: undefined,
- project_slug: undefined,
- });
- }
- }
- export class MissingInstrumentationNode extends TraceTreeNode<TraceTree.MissingInstrumentationSpan> {
- next: TraceTreeNode<TraceTree.Span>;
- previous: TraceTreeNode<TraceTree.Span>;
- constructor(
- parent: TraceTreeNode<TraceTree.NodeValue>,
- node: TraceTree.MissingInstrumentationSpan,
- metadata: TraceTree.Metadata,
- previous: TraceTreeNode<TraceTree.Span>,
- next: TraceTreeNode<TraceTree.Span>
- ) {
- super(parent, node, metadata);
- this.next = next;
- this.previous = previous;
- }
- }
- export class ParentAutogroupNode extends TraceTreeNode<TraceTree.ChildrenAutogroup> {
- head: TraceTreeNode<TraceTree.Span>;
- tail: TraceTreeNode<TraceTree.Span>;
- groupCount: number = 0;
- profiles: TraceTree.Profile[] = [];
- private _autogroupedSegments: [number, number][] | undefined;
- constructor(
- parent: TraceTreeNode<TraceTree.NodeValue> | null,
- node: TraceTree.ChildrenAutogroup,
- metadata: TraceTree.Metadata,
- head: TraceTreeNode<TraceTree.Span>,
- tail: TraceTreeNode<TraceTree.Span>
- ) {
- super(parent, node, metadata);
- this.expanded = false;
- this.head = head;
- this.tail = tail;
- }
- get children() {
- if (this.expanded) {
- return [this.head];
- }
- return this.tail.children;
- }
- get has_errors(): boolean {
- return this.errors.size > 0 || this.performance_issues.size > 0;
- }
- get autogroupedSegments(): [number, number][] {
- if (this._autogroupedSegments) {
- return this._autogroupedSegments;
- }
- const children: TraceTreeNode<TraceTree.NodeValue>[] = [];
- let start: TraceTreeNode<TraceTree.NodeValue> | undefined = this.head;
- while (start && start !== this.tail) {
- children.push(start);
- start = start.children[0];
- }
- children.push(this.tail);
- this._autogroupedSegments = computeAutogroupedBarSegments(children);
- return this._autogroupedSegments;
- }
- }
- export class SiblingAutogroupNode extends TraceTreeNode<TraceTree.SiblingAutogroup> {
- groupCount: number = 0;
- profiles: TraceTree.Profile[] = [];
- private _autogroupedSegments: [number, number][] | undefined;
- constructor(
- parent: TraceTreeNode<TraceTree.NodeValue> | null,
- node: TraceTree.SiblingAutogroup,
- metadata: TraceTree.Metadata
- ) {
- super(parent, node, metadata);
- this.expanded = false;
- }
- get has_errors(): boolean {
- return this.errors.size > 0 || this.performance_issues.size > 0;
- }
- get autogroupedSegments(): [number, number][] {
- if (this._autogroupedSegments) {
- return this._autogroupedSegments;
- }
- this._autogroupedSegments = computeAutogroupedBarSegments(this.children);
- return this._autogroupedSegments;
- }
- }
- export class NoDataNode extends TraceTreeNode<null> {
- constructor(parent: TraceTreeNode<TraceTree.NodeValue> | null) {
- super(parent, null, {
- event_id: undefined,
- project_slug: undefined,
- });
- }
- }
- function partialTransaction(
- partial: Partial<TraceTree.Transaction>
- ): TraceTree.Transaction {
- return {
- start_timestamp: 0,
- timestamp: 0,
- errors: [],
- performance_issues: [],
- parent_span_id: '',
- span_id: '',
- parent_event_id: '',
- project_id: 0,
- 'transaction.duration': 0,
- 'transaction.op': 'db',
- 'transaction.status': 'ok',
- generation: 0,
- project_slug: '',
- event_id: `event_id`,
- transaction: `transaction`,
- children: [],
- ...partial,
- };
- }
- export function makeExampleTrace(metadata: TraceTree.Metadata): TraceTree {
- const trace: TraceTree.Trace = {
- transactions: [],
- orphan_errors: [],
- };
- function randomBetween(min: number, max: number) {
- return Math.floor(Math.random() * (max - min + 1) + min);
- }
- let start = new Date().getTime();
- const root = partialTransaction({
- ...metadata,
- generation: 0,
- start_timestamp: start,
- transaction: 'root transaction',
- timestamp: start + randomBetween(100, 200),
- });
- trace.transactions.push(root);
- for (let i = 0; i < 50; i++) {
- const end = start + randomBetween(100, 200);
- const nest = i > 0 && Math.random() > 0.33;
- if (nest) {
- const parent = root.children[root.children.length - 1];
- parent.children.push(
- partialTransaction({
- ...metadata,
- generation: 0,
- start_timestamp: start,
- transaction: `parent transaction ${i}`,
- timestamp: end,
- })
- );
- parent.timestamp = end;
- } else {
- root.children.push(
- partialTransaction({
- ...metadata,
- generation: 0,
- start_timestamp: start,
- transaction: 'loading...',
- ['transaction.op']: 'loading',
- timestamp: end,
- })
- );
- }
- start = end;
- }
- const tree = TraceTree.FromTrace(trace);
- return tree;
- }
- function nodeToId(n: TraceTreeNode<TraceTree.NodeValue>): TraceTree.NodePath {
- if (isTransactionNode(n)) {
- return `txn:${n.value.event_id}`;
- }
- if (isSpanNode(n)) {
- return `span:${n.value.span_id}`;
- }
- if (isAutogroupedNode(n)) {
- if (isParentAutogroupedNode(n)) {
- return `ag:${n.head.value.span_id}`;
- }
- if (isSiblingAutogroupedNode(n)) {
- const child = n.children[0];
- if (isSpanNode(child)) {
- return `ag:${child.value.span_id}`;
- }
- }
- }
- if (isTraceNode(n)) {
- return `trace:root`;
- }
- if (isTraceErrorNode(n)) {
- return `error:${n.value.event_id}`;
- }
- if (isNoDataNode(n)) {
- return `empty:node`;
- }
- if (isRootNode(n)) {
- throw new Error('A path to root node does not exist as the node is virtual');
- }
- if (isMissingInstrumentationNode(n)) {
- if (n.previous) {
- return `ms:${n.previous.value.span_id}`;
- }
- if (n.next) {
- return `ms:${n.next.value.span_id}`;
- }
- throw new Error('Missing instrumentation node must have a previous or next node');
- }
- throw new Error('Not implemented');
- }
- export function computeAutogroupedBarSegments(
- nodes: TraceTreeNode<TraceTree.NodeValue>[]
- ): [number, number][] {
- if (nodes.length === 0) {
- return [];
- }
- if (nodes.length === 1) {
- const space = nodes[0].space;
- if (!space) {
- throw new Error(
- 'Autogrouped node child has no defined space. This should not happen.'
- );
- }
- return [space];
- }
- const first = nodes[0];
- const multiplier = first.multiplier;
- if (!isSpanNode(first)) {
- throw new Error('Autogrouped node must have span children');
- }
- const segments: [number, number][] = [];
- let start = first.value.start_timestamp;
- let end = first.value.timestamp;
- let i = 1;
- while (i < nodes.length) {
- const next = nodes[i];
- if (!isSpanNode(next)) {
- throw new Error('Autogrouped node must have span children');
- }
- if (next.value.start_timestamp > end) {
- segments.push([start * multiplier, (end - start) * multiplier]);
- start = next.value.start_timestamp;
- end = next.value.timestamp;
- i++;
- } else {
- end = next.value.timestamp;
- i++;
- }
- }
- segments.push([start * multiplier, (end - start) * multiplier]);
- return segments;
- }
- // Returns a list of errors related to the txn with ids matching the span id
- function getRelatedSpanErrorsFromTransaction(
- span: RawSpanType,
- node?: TraceTreeNode<TraceTree.NodeValue>
- ): TraceErrorType[] {
- if (!node || !node.value || !isTransactionNode(node)) {
- return [];
- }
- if (!node?.value?.errors?.length) {
- return [];
- }
- const errors: TraceErrorType[] = [];
- for (const error of node.value.errors) {
- if (error.span === span.span_id) {
- errors.push(error);
- }
- }
- return errors;
- }
- // Returns a list of performance errors related to the txn with ids matching the span id
- function getRelatedPerformanceIssuesFromTransaction(
- span: RawSpanType,
- node?: TraceTreeNode<TraceTree.NodeValue>
- ): TracePerformanceIssue[] {
- if (!node || !node.value || !isTransactionNode(node)) {
- return [];
- }
- if (!node?.value?.performance_issues?.length && !node?.value?.errors?.length) {
- return [];
- }
- const performanceIssues: TracePerformanceIssue[] = [];
- for (const perfIssue of node.value.performance_issues) {
- for (const s of perfIssue.span) {
- if (s === span.span_id) {
- performanceIssues.push(perfIssue);
- }
- }
- for (const suspect of perfIssue.suspect_spans) {
- if (suspect === span.span_id) {
- performanceIssues.push(perfIssue);
- }
- }
- }
- return performanceIssues;
- }
- function printNode(t: TraceTreeNode<TraceTree.NodeValue>, offset: number): string {
- // +1 because we may be printing from the root which is -1 indexed
- const padding = ' '.repeat(t.depth + offset);
- if (isAutogroupedNode(t)) {
- if (isParentAutogroupedNode(t)) {
- return padding + `parent autogroup (${t.groupCount})`;
- }
- if (isSiblingAutogroupedNode(t)) {
- return padding + `sibling autogroup (${t.groupCount})`;
- }
- return padding + 'autogroup';
- }
- if (isSpanNode(t)) {
- return padding + (t.value.op || t.value.span_id || 'unknown span');
- }
- if (isTransactionNode(t)) {
- return padding + (t.value.transaction || 'unknown transaction');
- }
- if (isMissingInstrumentationNode(t)) {
- return padding + 'missing_instrumentation';
- }
- if (isRootNode(t)) {
- return padding + 'Root';
- }
- if (isTraceNode(t)) {
- return padding + 'Trace';
- }
- if (isNoDataNode(t)) {
- return padding + 'No Data';
- }
- if (isTraceErrorNode(t)) {
- return padding + (t.value.event_id || t.value.level) || 'unknown trace error';
- }
- return 'unknown node';
- }
|