Function readRecentNetworkTrafficFromText

src/daemon/network-log.ts:107–153

(
  content: string,
  options?: {
    path?: string;
    backend?: LogBackend;
    maxEntries?: number;
    include?: NetworkIncludeMode;
    maxPayloadChars?: number;
    maxScanLines?: number;
  },
)

}

export function readRecentNetworkTrafficFromText(
  content: string,
  options?: {
    path?: string;
    backend?: LogBackend;
    maxEntries?: number;
    include?: NetworkIncludeMode;
    maxPayloadChars?: number;
    maxScanLines?: number;
  },
): NetworkDump {
  const maxEntries = clampInt(options?.maxEntries, 25, 1, 200);
  const backend = options?.backend;
  const include = options?.include ?? 'summary';
  const maxPayloadChars = clampInt(options?.maxPayloadChars, 2048, 64, 16_384);
  const maxScanLines = clampInt(options?.maxScanLines, 4000, 100, 20_000);
  const allLines = content.split('\n');
  const startIndex = Math.max(0, allLines.length - maxScanLines);
  const lines = allLines.slice(startIndex);
  const entries: NetworkEntry[] = [];

  for (let i = lines.length - 1; i >= 0 && entries.length < maxEntries; i -= 1) {
    const rawLine = lines[i];
    const trimmedLine = rawLine?.trim();
    if (!trimmedLine) continue;
    const parsed = parseNetworkLine(
      lines,
      i,
      startIndex + i + 1,
      backend,
      include,
      maxPayloadChars,
    );
    if (!parsed) continue;
    entries.push(parsed);
  }

  return {
    path: options?.path ?? NETWORK_LOG_MEMORY_PATH,
    exists: true,
    scannedLines: lines.length,
    matchedLines: entries.length,
    entries,
    include,
    limits: { maxEntries, maxPayloadChars, maxScanLines },
  };
}

function parseNetworkLine(
  lines: string[],