Surge_by_SukkaW/Build/trace/index.ts

import { isCI } from 'ci-info';
import { noop } from 'foxts/noop';
import { basename, extname } from 'node:path';
import { performance } from 'node:perf_hooks';
import process from 'node:process';
import { threadId } from 'node:worker_threads';
import { mergeExternalDownloadStats, takeExternalDownloadStats } from '../lib/download-stats';
import type { ExternalDownloadStatsSnapshot } from '../lib/download-stats';
import { SPAN_STATUS_END, SPAN_STATUS_START, SpanCategory } from './types';
import type { RawSpan, TraceResult } from './types';
import { adjustTraceTimestamps, printBuildReport } from './report';

export { SPAN_STATUS_START, SPAN_STATUS_END, SpanCategory, UNCATEGORIZED } from './types';
export type { RawSpan, TraceResult, ReportedSpanCategory, SpanEventLoopUtilization } from './types';
export { printTraceResult, printStats, printBuildReport, analyzeTraces } from './report';
export type { BuildResourceUsage, TraceAnalysis } from './report';

const spanTag = Symbol('span');

export interface Span {
  [spanTag]: true,
  readonly rawSpan: RawSpan,
  readonly stop: (time?: number) => void,
  /** Tag (or re-tag) what this span's self time is spent on */
  readonly setCategory: (category: SpanCategory) => Span,
  readonly traceChild: (name: string, category?: SpanCategory) => Span,
  readonly traceSyncFn: <T>(fn: (span: Span) => T) => T,
  readonly traceAsyncFn: <T>(fn: (span: Span) => T | Promise<T>) => Promise<T>,
  readonly tracePromise: <T>(promise: Promise<T>) => Promise<T>,
  readonly traceChildSync: <T>(name: string, fn: (span: Span) => T, category?: SpanCategory) => T,
  readonly traceChildAsync: <T>(name: string, fn: (span: Span) => T | Promise<T>, category?: SpanCategory) => Promise<T>,
  readonly traceChildPromise: <T>(name: string, promise: Promise<T>, category?: SpanCategory) => Promise<T>,
  /** Always tagged {@link SpanCategory.Worker}: the self time is the IPC + waiting on the worker */
  readonly traceWorkerChild: <T>(name: string, factory: (rawSpan: RawSpan) => Promise<WorkerJobResult<T>>) => Promise<T>,
  readonly traceResult: TraceResult
}

/**
 * Wraps a serializable {@link RawSpan} with all span methods.
 * Use this on a worker thread after receiving a {@link RawSpan} (or {@link TraceResult})
 * transferred from another thread.
 */
export function makeSpan(rawSpan: RawSpan): Span {
  const { traceResult } = rawSpan;

  const stop = (time?: number) => {
    if (rawSpan.status === SPAN_STATUS_END) {
      throw new Error(`span already stopped: ${traceResult.name}`);
    }
    traceResult.end = time ?? performance.now();
    if (rawSpan.eluStart) {
      const elu = performance.eventLoopUtilization(rawSpan.eluStart);
      traceResult.elu = { idle: elu.idle, active: elu.active };
    }
    rawSpan.status = SPAN_STATUS_END;
  };

  const traceChild = (name: string, category?: SpanCategory) => createSpan(name, traceResult, category);

  const span: Span = {
    [spanTag]: true,
    rawSpan,
    stop,
    setCategory(category) {
      traceResult.category = category;
      return span;
    },
    traceChild,
    traceSyncFn<T>(fn: (span: Span) => T) {
      traceResult.sync = true;
      const res = fn(span);
      span.stop();
      return res;
    },
    async traceAsyncFn<T>(fn: (span: Span) => T | Promise<T>): Promise<T> {
      const res = await fn(span);
      span.stop();
      return res;
    },
    traceResult,
    async tracePromise<T>(promise: Promise<T>): Promise<T> {
      const res = await promise;
      span.stop();
      return res;
    },
    traceChildSync: <T>(name: string, fn: (span: Span) => T, category?: SpanCategory): T => traceChild(name, category).traceSyncFn(fn),
    traceChildAsync: <T>(name: string, fn: (span: Span) => T | Promise<T>, category?: SpanCategory): Promise<T> => traceChild(name, category).traceAsyncFn(fn),
    traceChildPromise: <T>(name: string, promise: Promise<T>, category?: SpanCategory): Promise<T> => traceChild(name, category).tracePromise(promise),

    async traceWorkerChild<T>(name: string, factory: (rawSpan: RawSpan) => Promise<WorkerJobResult<T>>): Promise<T> {
      const childSpan = traceChild(name, SpanCategory.Worker);
      const { result, traceResult, workerTimeOrigin, externalDownloadStats } = await factory(childSpan.rawSpan);
      mergeWorkerTrace(childSpan, traceResult, workerTimeOrigin);
      mergeExternalDownloadStats(externalDownloadStats);
      childSpan.stop();
      return result;
    }
  };

  // eslint-disable-next-line sukka/no-redundant-variable -- self reference
  return span;
}

export function createSpan(name: string, parentTraceResult?: TraceResult, category?: SpanCategory): Span {
  const traceResult: TraceResult = {
    name,
    start: performance.now(),
    end: 0,
    thread: threadId,
    children: []
  };
  if (category !== undefined) {
    traceResult.category = category;
  }

  const rawSpan: RawSpan = {
    traceResult,
    status: SPAN_STATUS_START,
    eluStart: performance.eventLoopUtilization()
  };

  parentTraceResult?.children.push(traceResult);

  return makeSpan(rawSpan);
}

export const dummySpan = createSpan('dummy');

export function task(importMetaMain: boolean, importMetaPath: string) {
  return (fn: (span: Span, onCleanup: (cb: () => Promise<void> | void) => void) => Promise<unknown>, customName?: string) => {
    const taskName = customName ?? basename(importMetaPath, extname(importMetaPath));
    let cleanup: () => Promise<void> | void = noop;
    const onCleanup = (cb: () => void) => {
      cleanup = cb;
    };

    if (importMetaMain) {
      const eluAtStart = performance.eventLoopUtilization();
      const cpuAtStart = process.cpuUsage();
      const innerSpan = createSpan(taskName);

      process.on('uncaughtException', (error) => {
        console.error('Uncaught exception:', error);
        process.exit(1);
      });
      process.on('unhandledRejection', (reason) => {
        console.error('Unhandled rejection:', reason);
        process.exit(1);
      });

      innerSpan.traceChildAsync('dummy', (childSpan) => fn(childSpan, onCleanup)).finally(() => {
        innerSpan.stop();
        innerSpan.traceResult.timeOrigin = performance.timeOrigin;
        printBuildReport([innerSpan.traceResult], {
          elu: performance.eventLoopUtilization(eluAtStart),
          cpu: process.cpuUsage(cpuAtStart)
        });
        process.nextTick(whyIsNodeRunning);
        process.nextTick(() => process.exit(0));
      });
    }

    let runSpan: Span;
    async function run(parentSpan?: Span | null): Promise<TraceResult> {
      if (parentSpan) {
        runSpan = parentSpan.traceChild(taskName);
      } else {
        runSpan = createSpan(taskName);
      }

      try {
        await fn(runSpan, onCleanup);
      } finally {
        runSpan.stop();
        cleanup();
      }

      // A task may run on a worker thread (via jest-worker) and hand its trace
      // back to the main thread, which then needs this to re-align the clock.
      runSpan.traceResult.timeOrigin = performance.timeOrigin;
      return runSpan.traceResult;
    }

    return Object.assign(run, {
      getInternalTraceResult: () => runSpan.traceResult
    });
  };
}

export async function whyIsNodeRunning() {
  if (isCI && process.env.RUNNER_DEBUG === '1') {
    const mod = await import('why-is-node-running');
    return mod.default();
  }
}

// const isSpan = (obj: any): obj is Span => {
//   return typeof obj === 'object' && obj && spanTag in obj;
// };
// export const universalify = <A extends any[], R>(taskname: string, fn: (this: void, ...args: A) => R) => {
//   return (...args: A) => {
//     const lastArg = args[args.length - 1];
//     if (isSpan(lastArg)) {
//       return lastArg.traceChild(taskname).traceSyncFn(() => fn(...args));
//     }
//     return fn(...args);
//   };
// };

function mergeWorkerTrace(
  parentSpan: Span,
  workerTraceResult: TraceResult,
  workerTimeOrigin: number
): void {
  const offset = workerTimeOrigin - performance.timeOrigin;
  for (let i = 0, len = workerTraceResult.children.length; i < len; i++) {
    const child = workerTraceResult.children[i];
    parentSpan.traceResult.children.push(adjustTraceTimestamps(child, offset));
  }
}

/** The envelope that a worker function returns so the main thread can recover both the result and the trace. */
export interface WorkerJobResult<T> {
  result: T,
  traceResult: TraceResult,
  workerTimeOrigin: number,
  externalDownloadStats: ExternalDownloadStatsSnapshot
}

/**
 * Worker-side wrapper.  Call this instead of manually constructing spans.
 *
 * - When `rawSpan` is provided (normal worker invocation from the main thread),
 *   it is wrapped with {@link makeSpan} so all child spans are attached to the
 *   caller's trace tree and can be recovered after the job finishes.
 * - When `rawSpan` is `undefined` (standalone / CLI invocation), a fresh
 *   child span of {@link dummySpan} is used instead.
 *
 * The impl function receives a full {@link Span} and returns its result
 * normally; the wrapper packages everything into a {@link WorkerJobResult}.
 */
export async function workerJob<T>(
  rawSpan: RawSpan | undefined,
  impl: (span: Span) => Promise<T>
): Promise<WorkerJobResult<T>> {
  const span = rawSpan == null ? dummySpan.traceChild('worker-standalone') : makeSpan(rawSpan);
  const result = await impl(span);
  return {
    result,
    traceResult: span.traceResult,
    workerTimeOrigin: performance.timeOrigin,
    externalDownloadStats: takeExternalDownloadStats()
  };
}