Function dispatchEngineSpan

packages/instrumentation/src/ActiveTracingHelper.ts:108–151

(
  tracer: Tracer,
  engineSpan: EngineSpan,
  allSpans: EngineSpan[],
  linkIds: Map<string, string>,
  ignoreSpanTypes: (string | RegExp)[],
)

}

function dispatchEngineSpan(
  tracer: Tracer,
  engineSpan: EngineSpan,
  allSpans: EngineSpan[],
  linkIds: Map<string, string>,
  ignoreSpanTypes: (string | RegExp)[],
) {
  if (shouldIgnoreSpan(engineSpan.name, ignoreSpanTypes)) return

  const spanOptions = {
    attributes: engineSpan.attributes as Attributes,
    kind: engineSpanKindToOtelSpanKind(engineSpan.kind),
    startTime: engineSpan.startTime,
  } satisfies SpanOptions

  tracer.startActiveSpan(engineSpan.name, spanOptions, (span) => {
    linkIds.set(engineSpan.id, span.spanContext().spanId)

    if (engineSpan.links) {
      span.addLinks(
        engineSpan.links.flatMap((link) => {
          const linkedId = linkIds.get(link)
          if (!linkedId) {
            return []
          }
          return {
            context: {
              spanId: linkedId,
              traceId: span.spanContext().traceId,
              traceFlags: span.spanContext().traceFlags,
            },
          }
        }),
      )
    }

    const children = allSpans.filter((s) => s.parentId === engineSpan.id)
    for (const child of children) {
      dispatchEngineSpan(tracer, child, allSpans, linkIds, ignoreSpanTypes)
    }

    span.end(engineSpan.endTime)
  })
}

function endSpan<T>(span: Span, result: T): T {
  if (isPromiseLike(result)) {