# agent-transit Adopt this skill: https://proskills.md/skills/other/israelvicars-transit-skills-agent-transit Page: https://proskills.md/skills/other/israelvicars-transit-skills-agent-transit This document is the public skill bundle for that page. It contains SKILL.md and every helper file the catalog carries. No login is required. ## File: skills/agent-transit/SKILL.md size: 4142 sha: 2d2af1ec928bed7114ea18ea15a9f1ba8db7bbd2 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/SKILL.md ```text --- name: agent-transit description: A transit map for your coding-agent sessions. Use when the user wants to visualize one Claude Code, Codex CLI, or Cursor coding-agent session as a subway map of tool calls. --- # Agent Transit A local subway map for one AI coding-agent session: tool families are lines and tool calls are stations. 🔒 Session logs can contain prompts, source code, command output, credentials, and other secrets. This skill is default-deny: it keeps only tool name, family, target basename, timing, status, and `agent.source`. Prompt text, assistant text, tool output, file contents, full commands, and arguments are dropped. `--show-args` is an explicit opt-in and includes only a truncated, redacted argument preview. ## Where things are `` means the folder containing this file. Run scripts from it by absolute path, e.g. `node /src/agent-transit/scripts/find-session.mjs --source codex`. The shared engine is at `/core/`. ## Steps 1. Find the newest local session path without reading its contents: `node /src/agent-transit/scripts/find-session.mjs --source claude-code|codex|cursor`. 2. Build one page to share: `node /core/build.mjs --format claude-code --share --title "Agent: one coding session, tool by tool"`. Without `--out` the file is named after the title and the first failed tool call, in `./transit-out/`, e.g. `transit-out/agent-shell-git-service-alert.html`. `--share` scrubs at the strict level, refuses `--no-scrub`, and opens the page paused on the first failed call with a one-line verdict above the map. Idle stretches with nothing running (e.g. model thinking time between tool calls) longer than 3 s are shortened to 3 s so the animation isn't dead air; the header says how many were shortened and the root span keeps the wall time as `transit.wall_ms`. Pass `--max-gap-ms N` to change the cap, or `--max-gap-ms 0` for true wall-clock timing. 3. Share the HTML file: give the user its path and the verdict line the build printed, ready to paste with the file in Slack (desktop and iOS open it as the interactive page). Use the printed verdict as is. For example: > shell · git failed after 12.0 s: denied · SERVICE ALERT · 18 calls > `agent-shell-git-service-alert.html` opens on the denied call. Only tool names and timing are in it. 4. Optional teaser (GIF + MP4) with the bundled renderer: `node /core/render.mjs --format claude-code --name agent`. 5. Check it with the bundled verifier: `node /core/verify.mjs --format claude-code --name agent`. Use `--format codex` or `--format cursor` for those sources. Cursor: most Cursor installs keep chats only in `state.vscdb`, not as transcripts. Export one composer to a metadata-only JSONL (tool name, status, file basename or command word, timestamps; never message text, params or results), opened read-only: `node /src/agent-transit/scripts/export-cursor.mjs --list` (sessions for the current workspace; `--workspace DIR` or `--all-workspaces`), then `node /src/agent-transit/scripts/export-cursor.mjs --composer --out ./transit-out/agent/cursor.cursor.jsonl`, and build that with `--format cursor`. Cursor builds since about Sep 2025 stamp each message bubble with `createdAt`, so calls start at real times; Cursor stores no tool end time, so each call ends at the next message (an upper bound). Older bubbles and `agent-transcripts` files have no timestamps: order only, with uniform synthetic durations. Keep session files local and never upload them. Synthetic fixtures are provided in `samples/`; no real home-directory logs belong in this repository. ## Rules - Never expose or copy prompts, code, command lines, outputs, or arguments by default. - Only use the bundled build/render/verify scripts; never hand-write a substitute renderer. - Do not upload a session or render unless the user explicitly asks. - Review errors, denials, slow calls, and subagent branches in the map without revealing their payloads. ``` ## File: skills/agent-transit/README.md size: 1167 sha: 62680a7335f68e35eb728eadd43dd6766e710429 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/README.md ````text # agent-transit A transit map for your coding-agent sessions. ![Animated Transit map of a coding-agent session: tool families are lines, tool calls are stations, with DELAY and SERVICE ALERT markers on slow and failed calls](https://raw.githubusercontent.com/israelvicars/transit/main/docs/agent.gif) ## Example prompts - “Make an MP4 of my last Claude Code session.” - “Draw my latest Codex session as a transit map. Which tool calls were slow?” - “Render my newest Cursor session as a GIF.” - “Map this saved session log and show me where the tool errors were.” ## What it maps Tool families become lines and tool calls become stations. Long calls receive DELAY markers, while errors or denials receive SERVICE ALERT markers. Supported sources are Claude Code, Codex CLI, and Cursor (experimental). Session files and renders remain local. ## Install ```sh npx skills add israelvicars/transit --skill agent-transit ``` ## Privacy Runs locally only, with no telemetry. By default it keeps only tool names, timing, status, target basenames, and the agent source. [Back to the Transit README](https://github.com/israelvicars/transit#readme) ```` ## File: skills/agent-transit/src/agent-transit/samples/README.md size: 525 sha: 7b371db3cfa55e7bc9433c8e553a59a88e6e564f upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/agent-transit/samples/README.md ```text # Synthetic agent sessions These JSONL files are hand-built fixtures, not copied from any real `~/.claude`, `~/.codex`, or `~/.cursor` directory. Claude Code and Codex fixtures carry a synthetic marker; the Cursor fixture follows the native transcript shape and is synthetic by this README/test context. The payloads intentionally contain prompt, output, file-content, and command-argument canaries so tests prove they never reach HTML by default. Cursor timing is synthetic because the format has no timestamps or results. ``` ## File: skills/agent-transit/core/adapters.mjs size: 1106 sha: 9f1cdf5644e61ee97d5d20ceeeadd19cee8cb70c upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/adapters.mjs ```text import { normalize as normalizeRequest, detectFormat as detectRequestFormat } from '../src/request-transit/adapters/normalize.mjs'; import { isGitHubActionsRun, normalizeGh } from '../src/ci-transit/adapters/normalize-gh.mjs'; import { isAgentLog, normalizeAgent } from '../src/agent-transit/adapters/normalize-agent.mjs'; const adapters = new Map([['gh-actions', normalizeGh], ['claude-code', normalizeAgent], ['codex', normalizeAgent], ['cursor', normalizeAgent]]); export function registerAdapter(format, adapter) { adapters.set(format, adapter); } export function pickAdapter(doc, format) { if (format === 'gh-actions' || isGitHubActionsRun(doc)) return { format: 'gh-actions', normalize: adapters.get('gh-actions') }; if (format === 'claude-code' || format === 'codex' || format === 'cursor' || isAgentLog(doc)) { const selected = format || (doc && doc[0] && doc[0]._agentFormat) || 'claude-code'; return { format: selected, normalize: adapters.get(selected) }; } return { format: format || detectRequestFormat(doc), normalize: format && adapters.get(format) || normalizeRequest }; } ``` ## File: skills/agent-transit/core/build.mjs size: 10835 sha: faa8e4ddd9a178ca750598b744f110ec0ce2b52a upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/build.mjs ```text // core/build.mjs: trace file (OTLP JSON, Datadog span JSON, Datadog Spans API v2, or normalized) // -> one self-contained transit.html (trace, fonts and code inlined; no network at view time). // // usage: node core/build.mjs [--share] [--out transit-out/transit.html] [--format otlp|datadog|datadog-v2|internal] // [--trace-id ID] [--title "..."] [--subtitle "..."] [--slow-ms N] [--ms-per-sec N] // [--target-seconds 9] [--redact key1,key2] [--no-default-redact] // [--strict | --share] [--keep-uuids] [--keep-ci-titles] [--no-scrub] (value scrubbing, see core/scrub.mjs) // --share: strict scrubbing, refuses --no-scrub, opens paused on the first SERVICE ALERT with a verdict headline. // Without --out the file is ./transit-out/-<alert>-service-alert.html (see core/verdict.mjs), else // ./transit-out/transit.html; an existing file is never overwritten (-2, -3, ... is added). --out is used as given. import { readFileSync, writeFileSync, mkdirSync } from 'node:fs'; import { dirname, resolve, join } from 'node:path'; import { fileURLToPath } from 'node:url'; import { parseJsonSafe } from '../src/request-transit/adapters/normalize.mjs'; import { pickAdapter } from './adapters.mjs'; import { existsSync } from 'node:fs'; import { matchTrace } from '../src/request-transit/contracts/match.mjs'; import { resolveVocab } from './vocab.mjs'; import { compressGaps, DEFAULT_MAX_GAP_MS } from './gaps.mjs'; import { scrubTrace, scrubLevel } from './scrub.mjs'; import { parseArgs, runCli, UserError } from './cli.mjs'; import { verdict, defaultName } from './verdict.mjs'; const DEFAULT_DIR = 'transit-out'; export const DEFAULT_INDEX = '.transit-cache/contracts/index.json'; const HERE = dirname(fileURLToPath(import.meta.url)); // attribute keys dropped before anything is rendered (span attributes can carry PII) export const DEFAULT_REDACT = /(^|[._-])(user|email|phone|token|auth|authorization|password|passwd|secret|cookie|set-cookie|session|card|ssn|credentials?|jwt|bearer|api[_-]?key|apikey|private[_-]?key|access[_-]?key)([._-]|$)|^(client|user)\.(address|ip)$|^enduser\./i; export function redact(trace, keys = [], useDefault = true) { const set = new Set(keys); let n = 0; for (const s of trace.spans) { if (!s.attrs) continue; for (const k of Object.keys(s.attrs)) if (set.has(k) || (useDefault && DEFAULT_REDACT.test(k))) { delete s.attrs[k]; n++; } } trace.meta.redacted = n; return trace; } // A request trace from one service (e.g. telemetrygen, a monolith) would draw one station and no hops. // Then stations become operations: each non-root span's service is its span name, with a trailing // counter or id dropped ("okey-dokey-7" -> "okey-dokey") so N numbered children share one station. export function splitSingleService(trace) { const services = new Set(trace.spans.map((s) => s.service)); if (services.size !== 1 || trace.spans.length < 2) return false; // calls to an uninstrumented peer (DB, AWS service, broker) already give the map a second station if (trace.spans.some((s) => s.peer && s.peer !== s.service)) return false; const svc = [...services][0]; const op = (name) => String(name || 'span').replace(/[\s._:#/-]*(\d+|[0-9a-f]{8,})$/i, '').slice(0, 40) || String(name); const ops = new Set(); for (const s of trace.spans) if (s.parentId) { s.attrs = Object.assign({}, s.attrs, { 'service.name': svc }); s.service = op(s.name); ops.add(s.service); } trace.meta.warnings.push(`single-service trace (${svc}): stations are operations (${ops.size} span name${ops.size === 1 ? '' : 's'})`); return true; } // JSON, or JSON Lines (agent sessions); anything else is a UserError with the reason, never a stack trace export function readInput(file) { let input; try { input = readFileSync(file, 'utf8'); } catch (e) { throw new UserError(e.code === 'ENOENT' ? `no such file: ${file}` : e.code === 'EISDIR' ? `${file} is a directory, expected a trace file` : `cannot read ${file}: ${e.code || e.message}`); } if (!input.trim()) throw new UserError(`${file} is empty; expected a trace export (JSON) or an agent session (JSON Lines)`); try { return parseJsonSafe(input); } catch (jsonErr) { const lines = input.split(/\r?\n/).map((l, i) => [l, i + 1]).filter(([l]) => l.trim()); if (lines.length < 2) throw new UserError(`${file} is not valid JSON (${jsonErr.message.replace(/\s+/g, ' ').slice(0, 160)})`); return lines.map(([l, n]) => { try { return parseJsonSafe(l); } catch (e) { throw new UserError(`${file} is neither JSON nor JSON Lines: line ${n} does not parse (${e.message.replace(/\s+/g, ' ').slice(0, 160)})`); } }); } } export function build(file, opt = {}) { const doc = readInput(file); if (doc === null || typeof doc !== 'object') throw new UserError(`${file} holds a JSON ${doc === null ? 'null' : typeof doc}, not a trace; see the supported formats in src/request-transit/SKILL.md`); let adapter, trace; try { adapter = pickAdapter(doc, opt.format); trace = adapter.normalize(doc, { format: adapter.format, traceId: opt['trace-id'], showArgs: !!opt['show-args'], maxSteps: opt['max-steps'] != null ? Number(opt['max-steps']) : undefined }); } catch (e) { if (e instanceof UserError) throw e; throw new UserError(`could not read ${file} as a trace: ${e.message}`); } if (opt.share && (opt['no-scrub'] || opt.scrub === 'off')) throw new UserError('--share pages are meant to be dropped into Slack, so value scrubbing cannot be turned off: remove --no-scrub (or build without --share for local debugging)'); redact(trace, opt.redact ? String(opt.redact).split(',') : [], !opt['no-default-redact']); scrubTrace(trace, scrubLevel(opt), adapter.format); const vizOpts = {}; if (!['gh-actions', 'claude-code', 'codex', 'cursor'].includes(adapter.format)) splitSingleService(trace); // the verdict's "after N" is wall time, so keep the start/end times from before gap shortening const wallSpans = new Map(trace.spans.map((s) => [s.spanId, { start: s.start, duration: s.duration }])); // agent sessions and CI runs: shorten idle gaps (--max-gap-ms N, 0 or --no-compress-gaps to keep wall time) const family = adapter.format === 'gh-actions' ? 'ci' : ['claude-code', 'codex', 'cursor'].includes(adapter.format) ? 'agent' : null; if (family && !opt['no-compress-gaps']) { const gaps = compressGaps(trace, opt['max-gap-ms'] != null ? Number(opt['max-gap-ms']) : DEFAULT_MAX_GAP_MS[family]); if (gaps) { trace.meta.gaps = gaps; trace.meta.warnings.push(`shortened ${gaps.count} idle gap(s) longer than ${gaps.maxGapMs / 1000} s (${Math.round(gaps.removedMs / 1000)} s of wall time cut); pass --max-gap-ms 0 for wall time`); vizOpts.gapNote = `${gaps.count} idle gap${gaps.count === 1 ? '' : 's'} shortened, not wall-clock`; } } // a large CI run keeps only failed/cancelled steps as stations: say so on the map, not just in the console if (adapter.format === 'gh-actions' && trace.meta.warnings.some((w) => w.startsWith('large run:'))) vizOpts.gapNote = [vizOpts.gapNote, 'failed steps only'].filter(Boolean).join(' · '); if (opt.title) vizOpts.title = opt.title; if (opt.subtitle) vizOpts.subtitle = opt.subtitle; if (opt['slow-ms']) vizOpts.slowMs = Number(opt['slow-ms']); if (opt['ms-per-sec']) vizOpts.msPerSec = Number(opt['ms-per-sec']); if (opt['target-seconds']) vizOpts.targetSeconds = Number(opt['target-seconds']); if (adapter.format === 'gh-actions') vizOpts.ciStepsAsStations = true; vizOpts.vocab = resolveVocab(opt.vocab || (adapter.format === 'gh-actions' ? 'ci' : adapter.format && ['claude-code', 'codex', 'cursor'].includes(adapter.format) ? 'agent' : undefined)); const v = verdict(trace, vizOpts.vocab, wallSpans); if (opt.share) vizOpts.share = { verdict: v.text, origin: v.origin, message: v.message }; // contracts are opt-in: only an explicit --contracts [index.json] reads an index, and it never builds one let contracts = null; if (opt.contracts) { const ix = opt.contracts === true ? DEFAULT_INDEX : opt.contracts; if (!existsSync(ix)) throw new Error(`--contracts: no index at ${ix}. Build one first (ask the user): node src/request-transit/scripts/transit.mjs index --config transit.config.json`); contracts = matchTrace(trace, JSON.parse(readFileSync(ix, 'utf8'))); } const js = `window.TRACE = ${JSON.stringify(trace)};\nwindow.VIZ_OPTS = ${JSON.stringify(vizOpts)};\nwindow.CONTRACTS = ${JSON.stringify(contracts)};`.replace(/<\//g, '<\\/'); const face = (w) => `@font-face { font-family: "Transit Sans"; font-weight: ${w}; font-style: normal; src: url(data:font/woff;base64,${readFileSync(join(HERE, `fonts/arimo-${w}.woff`)).toString('base64')}) format("woff"); }`; const tpl = readFileSync(join(HERE, 'transit.template.html'), 'utf8'); if (!tpl.includes('/*__TRACE_DATA__*/') || !tpl.includes('/*__FONTS__*/')) throw new Error('template placeholder missing'); const html = tpl.replace('/*__FONTS__*/', () => face(400) + '\n ' + face(700)).replace('/*__TRACE_DATA__*/', () => js); // default: ./transit-out/ (the same folder the render teaser uses); never overwrite an earlier default file let out = resolve(opt.out || join(DEFAULT_DIR, defaultName(opt.title, v))); if (!opt.out) for (let i = 2; existsSync(out); i++) out = resolve(DEFAULT_DIR, defaultName(opt.title, v).replace(/\.html$/, `-${i}.html`)); mkdirSync(dirname(out), { recursive: true }); writeFileSync(out, html); return { out, trace, contracts, verdict: v.text }; } if (process.argv[1] && process.argv[1].endsWith('/build.mjs')) await runCli(async () => { await (await import('./setup.mjs')).ensureSetup({ need: [] }); // node version only; the HTML needs no deps const { opt, pos } = parseArgs(process.argv.slice(2)); if (!pos[0]) throw new UserError('usage: node core/build.mjs <trace.json> [--share] [--out transit-out/transit.html] [--title ...] [--strict]'); const { out, trace, contracts, verdict: vt } = build(pos[0], opt); for (const w of trace.meta.warnings) console.error('warning:', w); const sc = trace.meta.scrub; console.log(`wrote ${out} (${trace.spans.length} spans, ${trace.meta.format}${trace.meta.synthetic ? ', synthetic' : ''}, ${trace.meta.redacted} attrs redacted, ${sc.level === 'off' ? 'value scrubbing OFF' : `${sc.values} values scrubbed (${sc.level})`}${contracts ? `, contracts: ${Object.values(contracts.bySpan).filter((m) => m.state === 'matched' || m.state === 'fallback').length} matched / ${Object.values(contracts.bySpan).filter((m) => m.state === 'unmatched').length} unmatched / ${Object.values(contracts.bySpan).filter((m) => m.state === 'infra').length} infra` : ''})`); if (opt.share) console.log(`share: drop ${out} into Slack. Suggested message: "${vt}"`); }); ``` ## File: skills/agent-transit/core/cli.mjs size: 1827 sha: 8ac47871be21006c9a7a72cf5f1d2ae5aec1be9d upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/cli.mjs ```text // core/cli.mjs: argument parsing and error reporting shared by the entry scripts. // Flags that never take a value; every other --flag takes the next argument. export const BOOL_FLAGS = new Set(['strict', 'share', 'keep-uuids', 'keep-ci-titles']); // flags that take a value only when one follows (--contracts [index.json], --show-args) const OPTIONAL_VALUE = new Set(['contracts', 'show-args']); export function parseArgs(argv) { const opt = {}, pos = []; for (let i = 0; i < argv.length; i++) { const a = argv[i]; if (!a.startsWith('--')) { pos.push(a); continue; } const eq = a.indexOf('='); if (eq > 2) { opt[a.slice(2, eq)] = a.slice(eq + 1); continue; } const k = a.slice(2), next = argv[i + 1]; if (k.startsWith('no-') || BOOL_FLAGS.has(k)) opt[k] = true; else if (OPTIONAL_VALUE.has(k) && (next == null || next.startsWith('--'))) opt[k] = true; else if (next == null) throw new UserError(`--${k} needs a value`); else opt[k] = argv[++i]; } return { opt, pos }; } // back to argv form (for passing build options on to a child script) export const toArgs = (opt, skip = []) => Object.entries(opt).flatMap(([k, v]) => skip.includes(k) ? [] : v === true ? ['--' + k] : ['--' + k, String(v)]); // An error whose message is the whole story for the user: printed without a stack trace. export class UserError extends Error {} // Runs an async CLI body; any error prints as one "transit: ..." line (stack only with TRANSIT_DEBUG=1). export async function runCli(fn) { try { await fn(); } catch (e) { console.error(`transit: ${e && e.message ? e.message : e}`); if (process.env.TRANSIT_DEBUG === '1' && e && e.stack) console.error(e.stack); else if (!(e instanceof UserError)) console.error(' (set TRANSIT_DEBUG=1 for a stack trace)'); process.exit(1); } } ``` ## File: skills/agent-transit/core/export.mjs size: 5400 sha: 3f25f9e69ae80fa44584f4ae84b723d5c7183db6 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/export.mjs ```text // scripts/export.mjs: turn out/frames/*.png into an MP4, a single-palette GIF, a contact sheet, // and a loop check. Works on macOS, Linux and Windows (needs only node + ffmpeg, see core/setup.mjs). // // usage: node core/export.mjs [all|mp4|gif|sheet|loop] [--fps 24] [--frames out/frames] [--out out] // // Runs the article's ffmpeg commands with these fixes: // - GIF is scaled to fit inside 1200x1080 (X's GIF limit is 1280x1080; the article's // scale=1200:-1 made a 1200x1200 GIF for square input and also upscaled 1080 px sources) // - contact sheet always shows 12 frames spread across the whole clip (the article's // "every 12th frame" left 4 black cells on a 4 s / 24 fps loop) and adds -update 1, // which ffmpeg 7 asks for when writing a single image // - loop check also measures the seam: SSIM(frame N-1, frame 0) vs the median // SSIM of neighbouring frames, so you get a number, not just a video to eyeball import { execFileSync } from 'node:child_process'; import { readdirSync, mkdirSync, existsSync } from 'node:fs'; import { join } from 'node:path'; import { ffmpegBin, countFrames } from './tools.mjs'; const argv = process.argv.slice(2); const what = argv[0] && !argv[0].startsWith('--') ? argv[0] : 'all'; const opt = {}; for (let i = 0; i < argv.length; i++) if (argv[i].startsWith('--')) opt[argv[i].slice(2)] = argv[++i]; const FPS = Number(opt.fps) || 24; const FR = opt.frames || 'out/frames'; const OUT = opt.out || 'out'; mkdirSync(OUT, { recursive: true }); if (!existsSync(FR)) { console.error(`no ${FR}: run render.mjs first`); process.exit(1); } const files = readdirSync(FR).filter((f) => /^\d{4}\.png$/.test(f)).sort(); const N = files.length; if (!N) { console.error(`no frames in ${FR}`); process.exit(1); } const pattern = join(FR, '%04d.png'); const ff = (args) => execFileSync(ffmpegBin(), ['-hide_banner', '-loglevel', 'error', '-y', ...args], { stdio: ['ignore', 'pipe', 'pipe'] }); const probeFrames = countFrames; // ffmpeg's own frame count; no ffprobe console.log(`${N} frames in ${FR} at ${FPS} fps = ${(N / FPS).toFixed(3)} s`); if (what === 'all' || what === 'mp4') { const f = join(OUT, 'anim.mp4'); ff(['-framerate', String(FPS), '-i', pattern, '-c:v', 'libx264', '-profile:v', 'high', '-pix_fmt', 'yuv420p', '-crf', '18', '-movflags', '+faststart', f]); console.log(`mp4 ${f} (${probeFrames(f)} frames)`); } if (what === 'all' || what === 'gif') { const f = join(OUT, 'anim.gif'); const vf = "scale='min(1200,iw)':'min(1080,ih)':force_original_aspect_ratio=decrease:flags=lanczos," + 'split[a][b];[a]palettegen=stats_mode=diff[p];[b][p]paletteuse=dither=bayer:bayer_scale=5:diff_mode=rectangle'; ff(['-framerate', String(FPS), '-i', pattern, '-vf', vf, '-loop', '0', f]); console.log(`gif ${f} (${probeFrames(f)} frames${N > 350 ? ', WARNING: X caps GIFs at 350 frames' : ''})`); } if (what === 'all' || what === 'sheet') { const f = join(OUT, 'contact.png'); const step = Math.max(1, Math.floor(N / 12)); const vf = `select='not(mod(n\\,${step}))*lt(n\\,${step * 12})',scale=400:-1,tile=4x3:padding=4:color=white`; ff(['-framerate', String(FPS), '-i', pattern, '-vf', vf, '-frames:v', '1', '-update', '1', f]); console.log(`sheet ${f} (frames ${Array.from({ length: Math.min(12, N) }, (_, i) => i * step).join(', ')}; left to right, top to bottom)`); } if (what === 'all' || what === 'loop') { const mp4 = join(OUT, 'anim.mp4'); if (existsSync(mp4)) { const f = join(OUT, 'loop_check.mp4'); ff(['-stream_loop', '2', '-i', mp4, '-c', 'copy', f]); console.log(`loop ${f} (3 plays back to back, watch the seam)`); } // SSIM between each frame and the next (N-1 values), then the seam: frame N-1 vs frame 0. const ssim = (args) => execFileSync(ffmpegBin(), ['-hide_banner', '-loglevel', 'error', ...args, '-lavfi', 'ssim=stats_file=-', '-f', 'null', '-'], { maxBuffer: 1 << 26 }).toString() .trim().split('\n').map((l) => Number((l.match(/All:([\d.]+)/) || [])[1])).filter((x) => !Number.isNaN(x)); const inner0 = N > 1 ? ssim(['-framerate', String(FPS), '-i', pattern, '-framerate', String(FPS), '-start_number', '1', '-i', pattern]) : []; const seam0 = ssim(['-i', join(FR, files[N - 1]), '-i', join(FR, files[0])]); const s = [...inner0.slice(0, N - 1), ...seam0]; if (s.length === N) { const seam = s[N - 1], before = s[N - 2], after = s[0]; const inner = s.slice(0, N - 1).sort((x, y) => x - y), median = inner[Math.floor(inner.length / 2)]; console.log(`seam SSIM(frame ${N - 1} -> 0) = ${seam.toFixed(4)}; steps around it: ${N - 2}->${N - 1} ${before.toFixed(4)}, 0->1 ${after.toFixed(4)}; clip median ${median.toFixed(4)}`); // Heuristic: a pop at the seam shows up as a much bigger change than the steps on either side. const jump = 1 - seam, local = Math.max(1 - before, 1 - after); if (seam > 0.99999) console.log('seam WARNING: frame N-1 is identical to frame 0, you probably rendered frame N (first frame shown twice)'); else if (jump > 3 * local + 0.002) console.log(`seam CHECK: the cut from frame ${N - 1} to 0 is a bigger change than its neighbours, look at frames ${N - 2}, ${N - 1}, 0, 1`); else console.log('seam OK: the last frame flows into frame 0 like any other step'); } else { console.log(`seam could not parse SSIM output (${s.length} values for ${N} frames)`); } } ``` ## File: skills/agent-transit/core/fonts/arimo-400.woff size: 12292 sha: bfb191123ba405c410d95243cc267259b8169c56 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/fonts/arimo-400.woff Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/fonts/arimo-400.woff ## File: skills/agent-transit/core/fonts/arimo-700.woff size: 12428 sha: 71453f0419055351e078b992efa176b9a6875dc9 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/fonts/arimo-700.woff Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/fonts/arimo-700.woff ## File: skills/agent-transit/core/fonts/OFL-Arimo.txt size: 4384 sha: d610cd5937b2dad697afc36c3853626b034dc62d upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/fonts/OFL-Arimo.txt ```text Copyright 2026 The Arimo Project Authors (https://github.com/googlefonts/arimo) This Font Software is licensed under the SIL Open Font License, Version 1.1. This license is copied below, and is also available with a FAQ at: https://openfontlicense.org ----------------------------------------------------------- SIL OPEN FONT LICENSE Version 1.1 - 26 February 2007 ----------------------------------------------------------- PREAMBLE The goals of the Open Font License (OFL) are to stimulate worldwide development of collaborative font projects, to support the font creation efforts of academic and linguistic communities, and to provide a free and open framework in which fonts may be shared and improved in partnership with others. The OFL allows the licensed fonts to be used, studied, modified and redistributed freely as long as they are not sold by themselves. The fonts, including any derivative works, can be bundled, embedded, redistributed and/or sold with any software provided that any reserved names are not used by derivative works. The fonts and derivatives, however, cannot be released under any other type of license. The requirement for fonts to remain under this license does not apply to any document created using the fonts or their derivatives. DEFINITIONS "Font Software" refers to the set of files released by the Copyright Holder(s) under this license and clearly marked as such. This may include source files, build scripts and documentation. "Reserved Font Name" refers to any names specified as such after the copyright statement(s). "Original Version" refers to the collection of Font Software components as distributed by the Copyright Holder(s). "Modified Version" refers to any derivative made by adding to, deleting, or substituting -- in part or in whole -- any of the components of the Original Version, by changing formats or by porting the Font Software to a new environment. "Author" refers to any designer, engineer, programmer, technical writer or other person who contributed to the Font Software. PERMISSION & CONDITIONS Permission is hereby granted, free of charge, to any person obtaining a copy of the Font Software, to use, study, copy, merge, embed, modify, redistribute, and sell modified and unmodified copies of the Font Software, subject to the following conditions: 1) Neither the Font Software nor any of its individual components, in Original or Modified Versions, may be sold by itself. 2) Original or Modified Versions of the Font Software may be bundled, redistributed and/or sold with any software, provided that each copy contains the above copyright notice and this license. These can be included either as stand-alone text files, human-readable headers or in the appropriate machine-readable metadata fields within text or binary files as long as those fields can be easily viewed by the user. 3) No Modified Version of the Font Software may use the Reserved Font Name(s) unless explicit written permission is granted by the corresponding Copyright Holder. This restriction only applies to the primary font name as presented to the users. 4) The name(s) of the Copyright Holder(s) or the Author(s) of the Font Software shall not be used to promote, endorse or advertise any Modified Version, except to acknowledge the contribution(s) of the Copyright Holder(s) and the Author(s) or with their explicit written permission. 5) The Font Software, modified or unmodified, in part or in whole, must be distributed entirely under this license, and must not be distributed under any other license. The requirement for fonts to remain under this license does not apply to any document created using the Font Software. TERMINATION This license becomes null and void if any of the above conditions are not met. DISCLAIMER THE FONT SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO ANY WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT OF COPYRIGHT, PATENT, TRADEMARK, OR OTHER RIGHT. IN NO EVENT SHALL THE COPYRIGHT HOLDER BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, INCLUDING ANY GENERAL, SPECIAL, INDIRECT, INCIDENTAL, OR CONSEQUENTIAL DAMAGES, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF THE USE OR INABILITY TO USE THE FONT SOFTWARE OR FROM OTHER DEALINGS IN THE FONT SOFTWARE. ``` ## File: skills/agent-transit/core/fsguard.mjs size: 2991 sha: 7111fc2d2e91eb523ad3845a9f50d0c65cd1f37c upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/fsguard.mjs ```text // core/fsguard.mjs: the only way Transit clears output. No recursive deletes: a frames folder is emptied // by removing just the files Transit writes there (NNNN.png and the .transit-frames marker), then the folder // itself if that left it empty. Filesystem roots, the home directory, the repo root, the working directory // and any of their ancestors are refused outright, whatever --frames / --out / --out-dir say. import { existsSync, lstatSync, readdirSync, rmdirSync, unlinkSync, writeFileSync, mkdirSync, realpathSync } from 'node:fs'; import { homedir } from 'node:os'; import { join, parse, resolve, relative, isAbsolute, sep } from 'node:path'; import { ROOT } from './tools.mjs'; import { UserError } from './cli.mjs'; export const FRAME_FILE = /^\d{4}\.png$/; export const FRAMES_MARKER = '.transit-frames'; const real = (p) => { try { return realpathSync(p); } catch { return resolve(p); } }; const isInside = (child, parent) => { const r = relative(parent, child); return r === '' || (!r.startsWith('..') && !isAbsolute(r)); }; // throws when `dir` is a place no Transit output folder may be export function assertSafeOutputDir(dir, what = 'output folder') { const d = real(resolve(dir)); const protectedDirs = [parse(d).root, homedir(), ROOT, process.cwd()].map(real); for (const p of protectedDirs) if (isInside(p, d)) throw new UserError(`refusing to use ${dir} as the ${what}: it is ${p === d ? '' : 'an ancestor of '}${p === parse(d).root ? 'the filesystem root' : p === real(homedir()) ? 'your home directory' : p === real(ROOT) ? 'the Transit repo root' : 'the current directory'}. Pick a dedicated folder, e.g. out/frames.`); return d; } // empties a frames folder of Transit's own files only; returns the number of files removed export function clearFrames(dir) { const d = assertSafeOutputDir(dir, 'frames folder'); if (!existsSync(d)) return 0; if (!lstatSync(d).isDirectory()) throw new UserError(`${dir} exists and is not a folder`); let n = 0; for (const f of readdirSync(d)) if (FRAME_FILE.test(f) || f === FRAMES_MARKER) { const p = join(d, f); if (lstatSync(p).isFile()) { unlinkSync(p); n++; } } return n; } // clears, then removes the folder only if nothing else is left in it export function removeFramesDir(dir) { const n = clearFrames(dir); const d = resolve(dir); if (existsSync(d) && readdirSync(d).length === 0) rmdirSync(d); return n; } export function prepareFramesDir(dir) { const d = assertSafeOutputDir(dir, 'frames folder'); mkdirSync(d, { recursive: true }); writeFileSync(join(d, FRAMES_MARKER), 'frames written by Transit; safe to delete\n'); return d; } // a --name becomes a folder under out/: one path segment, no separators or dot-dot export function safeName(name) { if (!/^[A-Za-z0-9][A-Za-z0-9._-]{0,63}$/.test(name) || name.includes('..') || name.includes(sep)) throw new UserError(`--name must be a simple folder name (letters, digits, . _ -), got ${JSON.stringify(name)}`); return name; } ``` ## File: skills/agent-transit/core/gaps.mjs size: 1860 sha: 46312ada9c48b2bbdd3cfcfbae269e5f5349bf9a upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/gaps.mjs ```text // core/gaps.mjs: shorten idle stretches (no non-root span running) so long agent sessions and CI runs // don't animate as dead air. The time map is monotone, so order and overlaps are kept; only idle time // between activity is squeezed down to maxGapMs. Not applied to request traces. export const DEFAULT_MAX_GAP_MS = { agent: 3000, ci: 20000 }; const r3 = (x) => Math.round(x * 1000) / 1000; export function compressGaps(trace, maxGapMs) { if (!(maxGapMs > 0)) return null; const spans = trace.spans; const root = spans.find((s) => !s.parentId); const iv = spans.filter((s) => s !== root).map((s) => [s.start, s.start + s.duration]).sort((a, b) => a[0] - b[0]); if (!iv.length) return null; const merged = []; for (const [a, b] of iv) { const m = merged[merged.length - 1]; if (m && a <= m[1]) m[1] = Math.max(m[1], b); else merged.push([a, b]); } const end = Math.max(...spans.map((s) => s.start + s.duration)); const idle = []; let prev = Math.min(0, ...spans.map((s) => s.start)); for (const [a, b] of merged) { if (a - prev > maxGapMs) idle.push([prev, a]); prev = Math.max(prev, b); } if (end - prev > maxGapMs) idle.push([prev, end]); if (!idle.length) return null; const map = (t) => { let cut = 0; for (const [a, b] of idle) { if (t >= b) { cut += (b - a) - maxGapMs; continue; } if (t > a) return r3(a - cut + (t - a) * maxGapMs / (b - a)); break; } return r3(t - cut); }; const wall = end; for (const s of spans) { const a = map(s.start), b = map(s.start + s.duration); s.start = a; s.duration = r3(b - a); } const removedMs = r3(idle.reduce((n, [a, b]) => n + (b - a) - maxGapMs, 0)); if (root) root.attrs = Object.assign({}, root.attrs, { 'transit.wall_ms': r3(wall), 'transit.idle_gaps_shortened': idle.length }); return { count: idle.length, maxGapMs, removedMs }; } ``` ## File: skills/agent-transit/core/render-frames.mjs size: 4623 sha: 5b393d27249566da8f8666efd663957b8c2d729a upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/render-frames.mjs ```text // render.mjs: freeze an HTML animation at t = i / fps and save every frame as a PNG. // Based on the renderer in Florence's "Opus 5.5 Motion Lab" article, with fixes: // - viewport comes from --width/--height, else window.STAGE, else the page's first <canvas> // (the article hardcoded 1200x675 and silently cropped anything else) // - the page's requestAnimationFrame loop is frozen during capture, so a preview loop // cannot overwrite the frame between renderAt(t) and the screenshot (the article's version // produced different PNGs on repeat runs when the page had a rAF loop) // - old NNNN.png frames are removed first (only those files, never the folder's other contents), // so stale frames from a longer earlier render never end up in the MP4/GIF // - --frames renders only named stills (for the review loop), --scale renders at 2x // // usage: // node render.mjs <file.html> [seconds=6] [fps=24] [options] // node render.mjs anim.html 4 24 // node render.mjs anim.html 4 24 --width 1080 --height 1350 // node render.mjs anim.html 4 24 --frames 0,24,48,72 --out out/stills // options: // --width N --height N viewport in CSS px (default: window.STAGE, then <canvas>, then 1200x675) // --scale N deviceScaleFactor, e.g. 2 for crisp text (PNG is W*N x H*N) // --frames a,b,c only these frame numbers (no folder wipe, existing files are overwritten) // --out DIR output folder (default out/frames) import { launchBrowser } from './tools.mjs'; import { pathToFileURL } from 'node:url'; import { clearFrames, prepareFramesDir } from './fsguard.mjs'; import { resolve, join } from 'node:path'; const pos = [], opt = {}; const argv = process.argv.slice(2); for (let i = 0; i < argv.length; i++) { if (argv[i].startsWith('--')) opt[argv[i].slice(2)] = argv[++i]; else pos.push(argv[i]); } const [file = 'anim.html', secs = '6', fps = '24'] = pos; const FPS = Number(fps), N = Math.round(Number(secs) * FPS); // frames 0 to N-1, never N const OUT = opt.out || 'out/frames'; const SCALE = Number(opt.scale) || 1; const only = opt.frames ? opt.frames.split(',').map(Number) : null; if (!(FPS > 0) || !(N > 0)) { console.error('seconds and fps must be positive numbers'); process.exit(1); } // only Transit's own frame files are removed (core/fsguard.mjs); unsafe folders are refused try { if (!only) clearFrames(OUT); prepareFramesDir(OUT); } catch (e) { console.error(`transit: ${e.message}`); process.exit(1); } const browser = await launchBrowser(); const context = await browser.newContext({ viewport: { width: 1200, height: 675 }, deviceScaleFactor: SCALE }); // Runs before any page script: tell the page it is being rendered, and wrap rAF so it can be frozen. await context.addInitScript(() => { window.__RENDER_MODE = true; const raf = window.requestAnimationFrame.bind(window); window.__origRAF = raf; window.requestAnimationFrame = (cb) => (window.__RENDER_FREEZE ? 0 : raf(cb)); }); const page = await context.newPage(); await page.goto(pathToFileURL(resolve(file)).href, { waitUntil: 'networkidle' }); await page.evaluate(async () => { await document.fonts.ready; }); // Size: CLI args win, then window.STAGE {width,height}, then the first canvas. let width = Number(opt.width), height = Number(opt.height); if (!width || !height) { const detected = await page.evaluate(() => { if (window.STAGE && window.STAGE.width) return { width: window.STAGE.width, height: window.STAGE.height }; const c = document.querySelector('canvas'); if (!c) return null; const r = c.getBoundingClientRect(); return { width: Math.round(r.width) || c.width, height: Math.round(r.height) || c.height }; }); width = width || detected?.width || 1200; height = height || detected?.height || 675; } await page.setViewportSize({ width, height }); // Freeze the page's own animation loop, then let any in-flight frame finish. await page.evaluate(() => new Promise((done) => { window.__RENDER_FREEZE = true; window.__origRAF(() => window.__origRAF(done)); })); const list = only || Array.from({ length: N }, (_, i) => i); for (const i of list) { await page.evaluate((t) => { if (window.renderAt) window.renderAt(t); document.getAnimations().forEach((a) => { a.pause(); a.currentTime = t * 1000; }); }, i / FPS); await page.screenshot({ path: join(OUT, `${String(i).padStart(4, '0')}.png`) }); } await browser.close(); console.log(`rendered ${list.length} frame(s) at ${width}x${height}${SCALE !== 1 ? ` @${SCALE}x` : ''} to ${OUT}` + (only ? '' : ` (frames 0..${N - 1} = ${secs} s x ${FPS} fps)`)); ``` ## File: skills/agent-transit/core/render.mjs size: 2388 sha: d71bccf606b9bdbbb5fe2c28d8083b1337510070 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/render.mjs ```text // core/render.mjs: trace file -> out/<name>/{transit.html, frames/, anim.mp4, anim.gif, contact.png} // Frame-exact: the page's rAF loop is frozen and every frame is renderAt(i / fps). // usage: node core/render.mjs <trace.json> [--name NAME | --out-dir DIR] [--frames DIR] [build options...] // build options include --strict / --share, --keep-uuids, --keep-ci-titles, --no-scrub (see core/scrub.mjs) import { execFileSync } from 'node:child_process'; import { ensureSetup } from './setup.mjs'; import { pathToFileURL, fileURLToPath } from 'node:url'; import { dirname, join, resolve } from 'node:path'; import { build } from './build.mjs'; import { parseArgs, runCli, UserError } from './cli.mjs'; import { assertSafeOutputDir, safeName } from './fsguard.mjs'; await runCli(async () => { const { opt, pos } = parseArgs(process.argv.slice(2)); if (!pos[0]) throw new UserError('usage: node core/render.mjs <trace.json> [--name NAME | --out-dir DIR] [--strict]'); const ROOT = resolve(dirname(fileURLToPath(import.meta.url)), '..'); const name = opt['out-dir'] ? String(opt.name || 'trace') : safeName(String(opt.name || 'trace')); const dir = assertSafeOutputDir(resolve(opt['out-dir'] || join(ROOT, 'out', name)), 'output folder'); const frames = resolve(opt.frames || join(dir, 'frames')); assertSafeOutputDir(frames, 'frames folder'); // build first: a bad input file fails here with a one-line reason, before any setup or download const { out: html } = build(resolve(pos[0]), { ...opt, out: join(dir, 'transit.html') }); await ensureSetup({ need: ['deps', 'browser', 'ffmpeg'] }); const { launchBrowser } = await import('./tools.mjs'); const browser = await launchBrowser(); const page = await browser.newPage(); await page.goto(pathToFileURL(html).href + '?paused=1'); const { seconds, fps, msPerSec } = await page.evaluate(() => window.VIZ); await browser.close(); console.log(`${name}: ${seconds.toFixed(3)} s at ${fps} fps, 1 s of video = ${msPerSec} ms of trace`); const run = (args) => execFileSync(process.execPath, args, { cwd: ROOT, stdio: 'inherit' }); // arg arrays, no shell run(['core/render-frames.mjs', html, String(seconds), String(fps), '--out', frames]); if (opt['frames-only']) return; for (const k of ['mp4', 'gif', 'sheet']) run(['core/export.mjs', k, '--fps', String(fps), '--frames', frames, '--out', dir]); }); ``` ## File: skills/agent-transit/core/scrub.mjs size: 8901 sha: 5d851fa1230fcfd7d640df998805fc38a25072b1 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/scrub.mjs ```text // core/scrub.mjs: value-based scrubbing, run on every trace before anything is rendered. // Key-based redaction (build.mjs DEFAULT_REDACT) drops whole attributes by name; this pass rewrites the // strings that are always drawn or inlined: service and span names, peers, operations, status messages, // attribute values, the source note and warnings. The default level is meant to be safe to share. // // levels (build/render flags): // default emails, bearer/basic credentials, JWTs, known token prefixes (GitHub, Slack, AWS keys, // Stripe, OpenAI, GitLab, npm, PostHog...), key=value secrets (password=, token:, api_key=...), // URL userinfo and query strings, long hex (>= 32) and long base64-like runs, UUIDs, // home directories (/Users/<name>, /home/<name>, C:\Users\<name>), AWS account ids in ARNs; // CI runs lose the PR/commit title and the branch name // --strict (alias --share) also IPv4/IPv6 addresses, internal host names (.internal .local .lan .corp // .intranet .svc .cluster.local and hosts inside URLs), long numeric ids (>= 6 digits), and keeps // only a minimal attribute allowlist // --keep-uuids keep UUIDs (default level only) --keep-ci-titles keep CI run titles and branch names // --no-scrub off (local debugging only; the page is NOT safe to share) // Placeholders are bracketed, e.g. [email], so a reader can see something was removed. const KEYS = 'password|passwd|pwd|pass|secret|client[_-]?secret|token|access[_-]?token|refresh[_-]?token|id[_-]?token|api[_-]?key|apikey|x-api-key|access[_-]?key|private[_-]?key|auth|authorization|credentials?|session(?:[_-]?id)?|sid|sig|signature|key|cookie'; // base64/base64url secrets vs kebab-case names and paths: a secret has one long unbroken run (>= 24) that mixes // upper, lower and digits with high character entropy; "feature/jira-1234-big-customer" has only short words const entropy = (x) => { const f = {}; for (const ch of x) f[ch] = (f[ch] || 0) + 1; return Object.values(f).reduce((h, c) => h - (c / x.length) * Math.log2(c / x.length), 0); }; function looksSecret(m) { const run = m.split(/[-_/+.=]/).reduce((a, b) => (b.length > a.length ? b : a), ''); return run.length >= 24 && /[a-z]/.test(run) && /[A-Z]/.test(run) && /\d/.test(run) && entropy(run) >= 4; } // key=value always counts; with a colon ("session: tool calls" is prose) only a strong secret key or a value that looks // like a secret (has a digit or symbol, or is a long unbroken run) is redacted const STRONG = /^(password|passwd|pwd|secret|client[_-]?secret|api[_-]?key|apikey|x-api-key|access[_-]?key|private[_-]?key|access[_-]?token|refresh[_-]?token|id[_-]?token|authorization|credentials?)$/i; function kvReplace(m, k, sep, v) { if (/^\[[a-z-]+\]$/.test(v) || /^(bearer|basic|token)$/i.test(v)) return m; const bare = v.replace(/^["']|["']$/g, ''); if (sep.includes(':') && !STRONG.test(k) && !/[\d!@#$%^&*+/=_~-]/.test(bare) && bare.length < 16) return m; return `${k}${sep}[redacted]`; } const RULES = [ // URL userinfo first, then query strings, so the URL rules see whole URLs ['userinfo', /\b([a-z][a-z0-9+.-]*:\/\/)[^\s/@:]+(?::[^\s/@]*)?@/gi, '$1[credentials]@'], ['query', /((?:\b[a-z][a-z0-9+.-]*:\/\/[^\s?#"'<>]+|(?:^|(?<=[\s"'(=]))\/[^\s?#"'<>]*))\?[^\s#"'<>]+/gi, '$1?[query]'], ['jwt', /\beyJ[A-Za-z0-9_-]{5,}\.[A-Za-z0-9_-]{5,}\.[A-Za-z0-9_-]{5,}/g, '[jwt]'], ['bearer', /\b(bearer|basic|token)\s+[A-Za-z0-9._~+/=-]{8,}/gi, '$1 [token]'], ['token', /\b(?:gh[pousr]_[A-Za-z0-9]{20,}|github_pat_[A-Za-z0-9_]{20,}|xox[abprs]-[A-Za-z0-9-]{10,}|(?:sk|pk|rk)_(?:live|test)_[A-Za-z0-9]{10,}|sk-[A-Za-z0-9_-]{20,}|glpat-[A-Za-z0-9_-]{20,}|npm_[A-Za-z0-9]{30,}|ph[cxs]_[A-Za-z0-9]{20,}|(?:AKIA|ASIA)[A-Z0-9]{16}|AIza[A-Za-z0-9_-]{30,})\b/g, '[token]'], ['kv', new RegExp(`\\b(${KEYS})(\\s*[=:]\\s*)("[^"]*"|'[^']*'|[^\\s&,;)"'\\]}]+)`, 'gi'), kvReplace], ['email', /\b[A-Za-z0-9._%+-]+@[A-Za-z0-9.-]+\.[A-Za-z]{2,}\b/g, '[email]'], ['arn', /(\barn:aws[a-z-]*:[a-z0-9-]*:[a-z0-9-]*:)\d{12}(?=:)/g, '$1[account]'], ['home', /(\/Users\/|\/home\/|[A-Za-z]:\\Users\\)[^\s/\\:"']+/g, (m, p) => (p.includes('\\') ? 'C:\\Users\\[user]' : `${p}[user]`)], ['uuid', /\b[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}\b/gi, '[uuid]', 'uuids'], ['hex', /\b[0-9a-f]{32,}\b/gi, '[hex]'], ['b64', /(?<![A-Za-z0-9+/_-])[A-Za-z0-9+/_-]{32,}={0,2}(?![A-Za-z0-9+/_-])/g, (m) => (looksSecret(m) ? '[secret]' : m)], ]; const STRICT_RULES = [ ['ipv4', /\b(?:25[0-5]|2[0-4]\d|1?\d?\d)(?:\.(?:25[0-5]|2[0-4]\d|1?\d?\d)){3}\b/g, '[ip]'], // full 8-group form, or a compressed form with "::" and at least one group (clock times like 10:30:00 never match) ['ipv6', /(?<![\w:])(?:(?:[0-9a-f]{1,4}:){7}[0-9a-f]{1,4}|(?:[0-9a-f]{1,4}(?::[0-9a-f]{1,4})*)?::(?:[0-9a-f]{1,4}(?::[0-9a-f]{1,4})*)?)(?![\w:])/gi, (m) => (/[0-9a-f]/i.test(m) ? '[ip]' : m)], ['url-host', /\b([a-z][a-z0-9+.-]*:\/\/)(?!\[)[^\s/?#"'<>]+/gi, '$1[host]'], ['internal-host', /\b[a-z0-9-]+(?:\.[a-z0-9-]+)*\.(?:internal|local|lan|corp|intranet|svc|cluster\.local|home\.arpa)\b/gi, '[internal-host]'], ['long-id', /(?<![\w.])\d{6,}(?![\w.])/g, '[id]'], ]; // attributes kept in --strict (values are still scrubbed); ci.step.* and ci.needs.from are structural: CI steps are stations only with them const STRICT_ATTRS = /^(http\.(request\.method|method|response\.status_code|status_code|route)|rpc\.(system|service|method|grpc\.status_code)|db\.system|messaging\.(system|operation)|ci\.(job|conclusion|needs|needs\.from|attempt|event|step\.number|step\.name)|agent\.source|component)$/; export function scrubLevel(opt = {}) { if (opt['no-scrub'] || opt.scrub === 'off') return { level: 'off' }; const strict = !!(opt.strict || opt.share || opt.scrub === 'strict'); return { level: strict ? 'strict' : 'default', uuids: strict || !opt['keep-uuids'], ciTitles: !opt['keep-ci-titles'] }; } export function scrubString(value, cfg = { level: 'default', uuids: true }, counts = {}) { if (typeof value !== 'string' || !value || cfg.level === 'off') return value; let s = value; for (const [name, re, rep, flag] of cfg.level === 'strict' ? [...RULES, ...STRICT_RULES] : RULES) { if (flag && !cfg[flag]) continue; s = s.replace(re, (...m) => { const out = typeof rep === 'function' ? rep(...m) : rep.replace(/\$(\d)/g, (_, i) => (typeof m[i] === 'string' ? m[i] : '')); if (out !== m[0]) counts[name] = (counts[name] || 0) + 1; return out; }); } return s; } const scrubValue = (v, cfg, counts) => typeof v === 'string' ? scrubString(v, cfg, counts) : Array.isArray(v) ? v.map((x) => scrubValue(x, cfg, counts)) : v; // rewrites the trace in place; returns {level, values} (values = number of replacements) export function scrubTrace(trace, cfg = scrubLevel(), format) { if (cfg.level === 'off') { trace.meta.scrub = { level: 'off', values: 0 }; trace.meta.warnings.push('value scrubbing is off (--no-scrub): names, messages and URLs are unredacted; do not share this page'); return trace.meta.scrub; } const counts = {}; const str = (v) => scrubString(v, cfg, counts); if (format === 'gh-actions' && cfg.ciTitles) { const root = trace.spans.find((s) => !s.parentId); // the run title is the PR or commit title; the branch name can carry ticket ids or customer names if (root && root.name !== root.service) { root.name = root.service; counts['ci-title'] = 1; } for (const s of trace.spans) if (s.attrs) for (const k of ['ci.branch', 'ci.title', 'ci.head_sha', 'ci.actor']) if (k in s.attrs) { delete s.attrs[k]; counts['ci-meta'] = (counts['ci-meta'] || 0) + 1; } } for (const s of trace.spans) { // CI step stations are named by their own span id (job-<id>-step-<n>), which the page keeps anyway; // scrubbing the id out of the name alone would merge every job's steps into one station const stepStation = format === 'gh-actions' && s.service === s.spanId && /^job-\d+-step-\d+$/.test(s.service); for (const k of ['service', 'name', 'peer', 'operation', 'statusMessage']) if (typeof s[k] === 'string' && !(k === 'service' && stepStation)) s[k] = str(s[k]); if (s.attrs) { for (const k of Object.keys(s.attrs)) { if (cfg.level === 'strict' && !STRICT_ATTRS.test(k)) { delete s.attrs[k]; counts['strict-attr'] = (counts['strict-attr'] || 0) + 1; continue; } s.attrs[k] = scrubValue(s.attrs[k], cfg, counts); } } if (s.events) s.events = scrubValue(s.events, cfg, counts); } if (trace.meta.source) trace.meta.source = str(String(trace.meta.source)); trace.meta.warnings = trace.meta.warnings.map(str); const values = Object.values(counts).reduce((a, b) => a + b, 0); trace.meta.scrub = { level: cfg.level, values, kinds: counts }; return trace.meta.scrub; } ``` ## File: skills/agent-transit/core/setup.mjs size: 15637 sha: fce36fddc3418c84b8e7f1ae8c616928b73ecd4d upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/setup.mjs ```text // core/setup.mjs: first-run check, shared by every entry script. Reuses what the machine already has and // downloads only what is missing, always with a one-line size notice first. It never installs system // packages (no brew/apt/winget): when something system-level is missing it explains and prints the command. // node >= 20 required (playwright-core 1.64 needs 20), never installed // npm deps `npm install` (playwright-core + ffmpeg-static, project-local, into node_modules) only // when node_modules is missing // browser, first that launches: // 1. TRANSIT_BROWSER (path, or channel chrome/msedge) // 2. Playwright's own build for this playwright-core version, if already downloaded // 3. any other Chromium / headless shell already in the Playwright cache (other projects' downloads) // 4. system Google Chrome or Microsoft Edge (Playwright channels), or chromium on PATH (Linux) // 5. download chromium-headless-shell only (~100 MB download / ~200 MB on disk; full Chromium is ~170 MB / ~370 MB) // ffmpeg 1. TRANSIT_FFMPEG=/path/to/ffmpeg 2. the pinned ffmpeg-static dependency (package.json + // lockfile; its install script fetches the binary, approved in package.json allowScripts) // 3. ffmpeg on PATH or in /opt/homebrew/bin, /usr/local/bin, /usr/bin // else: explain, print the install command, exit. ffprobe is not used. // The marker .transit-cache/setup.json records what was reused vs installed; scripts read it via core/tools.mjs. // usage: node core/setup.mjs [--force] [--check] [--no-download] // --check dry run: report what would be used or downloaded, change nothing (exit 1 if something is missing) // --no-download never download (also TRANSIT_NO_DOWNLOAD=1); fail with instructions instead // env: TRANSIT_SKIP_SETUP=1 skips everything (prepared CI images); TRANSIT_NO_SYSTEM_BROWSER=1 ignores system // Chrome/Edge (pin renders to Playwright's build); TRANSIT_BROWSER=... forces one import { spawnSync } from 'node:child_process'; import { existsSync, readFileSync, writeFileSync, mkdirSync, rmSync, readdirSync, statSync } from 'node:fs'; import { dirname, join } from 'node:path'; import { homedir } from 'node:os'; import { lookup } from 'node:dns/promises'; import { fileURLToPath, pathToFileURL } from 'node:url'; import { ROOT, MARKER, launchOptions } from './tools.mjs'; const MIN_NODE = 20; const log = (m) => process.stderr.write(`transit setup: ${m}\n`); const sleep = (ms) => new Promise((r) => setTimeout(r, ms)); const runs = (cmd, args) => spawnSync(cmd, args, { stdio: 'ignore' }).status === 0; const PW = join(ROOT, 'node_modules/playwright-core'); const pwVersion = () => { try { return JSON.parse(readFileSync(join(PW, 'package.json'), 'utf8')).version; } catch { return null; } }; const argv = process.argv.slice(2); const isMain = process.argv[1] && fileURLToPath(import.meta.url) === process.argv[1]; class SetupError extends Error {} const fail = (msg) => { throw new SetupError(msg); }; async function online(host) { try { await lookup(host); return true; } catch { return false; } } // Retries with backoff (2 s, 8 s) for network steps; returns true on success. async function runRetry(label, cmd, args, { attempts = 3 } = {}) { for (let i = 1; i <= attempts; i++) { log(`${label}${attempts > 1 ? ` (attempt ${i}/${attempts})` : ''}: ${cmd} ${args.join(' ')}`); const r = spawnSync(cmd, args, { cwd: ROOT, stdio: ['ignore', 'inherit', 'inherit'] }); // arg arrays, never a shell if (r.status === 0) return true; if (i < attempts) await sleep(i === 1 ? 2000 : 8000); } return false; } // npm without a shell: on Windows npm is a .cmd shim, so run its JS entry with this node instead function npmCommand(args) { if (process.platform !== 'win32') return ['npm', args]; const cli = [process.env.npm_execpath, join(dirname(process.execPath), 'node_modules/npm/bin/npm-cli.js')].find((p) => p && /npm-cli\.js$/.test(p) && existsSync(p)); if (!cli) fail('cannot locate npm-cli.js next to node; run `npm install` in ' + ROOT + ' yourself'); return [process.execPath, [cli, ...args]]; } // ---------------------------------------------------------------- browser const pwCacheDir = () => process.env.PLAYWRIGHT_BROWSERS_PATH && process.env.PLAYWRIGHT_BROWSERS_PATH !== '0' ? process.env.PLAYWRIGHT_BROWSERS_PATH : process.platform === 'darwin' ? join(homedir(), 'Library/Caches/ms-playwright') : process.platform === 'win32' ? join(process.env.LOCALAPPDATA || join(homedir(), 'AppData/Local'), 'ms-playwright') : join(homedir(), '.cache/ms-playwright'); const EXE = new Set(['chrome-headless-shell', 'chrome-headless-shell.exe', 'Chromium', 'chrome', 'chrome.exe', 'Google Chrome for Testing']); function findExecutables(dir, depth = 5, out = []) { let names; try { names = readdirSync(dir); } catch { return out; } for (const n of names) { const p = join(dir, n); let st; try { st = statSync(p); } catch { continue; } if (st.isFile() && EXE.has(n) && (process.platform === 'win32' || st.mode & 0o111)) out.push(p); else if (st.isDirectory() && depth > 0 && !n.endsWith('.framework') && n !== 'Resources' && n !== 'locales') findExecutables(p, depth - 1, out); } return out; } // Other Playwright downloads on this machine, newest revision first, headless shells before full Chromium. function cachedBrowsers() { const base = pwCacheDir(); let dirs = []; try { dirs = readdirSync(base).filter((d) => /^chromium(_headless_shell)?-\d+$/.test(d)); } catch {} dirs.sort((a, b) => Number(b.split('-').pop()) - Number(a.split('-').pop()) || (b.includes('headless') ? 1 : -1)); return dirs.flatMap((d) => findExecutables(join(base, d)).map((p) => ({ kind: 'executable', value: p, source: 'playwright-cache', label: d }))); } function systemBrowsers() { const c = [{ kind: 'channel', value: 'chrome', source: 'system', label: 'Google Chrome' }, { kind: 'channel', value: 'msedge', source: 'system', label: 'Microsoft Edge' }]; if (process.platform === 'linux') for (const p of ['/usr/bin/chromium', '/usr/bin/chromium-browser', '/snap/bin/chromium']) if (existsSync(p)) c.push({ kind: 'executable', value: p, source: 'system', label: p }); return c; } async function tryLaunch(choice) { try { const { chromium } = await import(pathToFileURL(join(PW, 'index.mjs')).href); const b = await chromium.launch({ ...launchOptions(choice), timeout: 30000 }); const version = b.version(); await b.close(); return version; } catch { return null; } } async function pickBrowser({ check, noDownload }) { const candidates = []; if (process.env.TRANSIT_BROWSER) { const v = process.env.TRANSIT_BROWSER; candidates.push(v === 'bundled' ? { kind: 'bundled', source: 'env' } : /^(chrome|chrome-beta|msedge|msedge-beta|chromium)$/.test(v) ? { kind: 'channel', value: v, source: 'env' } : { kind: 'executable', value: v, source: 'env' }); } else { candidates.push({ kind: 'bundled', source: 'playwright-cache', label: `playwright-core ${pwVersion()} build` }, ...cachedBrowsers(), ...(process.env.TRANSIT_NO_SYSTEM_BROWSER === '1' ? [] : systemBrowsers())); } for (const c of candidates) { const version = await tryLaunch(c); if (version) return { ...c, version }; } if (process.env.TRANSIT_BROWSER) fail(`TRANSIT_BROWSER=${process.env.TRANSIT_BROWSER} did not launch. Point it at a Chrome/Chromium/Edge executable or a channel (chrome, msedge), or unset it.`); const notice = 'no usable Chrome/Chromium found; Transit needs chromium-headless-shell (~100 MB download, ~200 MB on disk, into ' + pwCacheDir() + ')'; if (check) return { kind: 'bundled', source: 'would-download', note: notice }; if (noDownload) fail(`${notice}, but downloads are disabled (--no-download / TRANSIT_NO_DOWNLOAD).\n Install Google Chrome, or set TRANSIT_BROWSER=/path/to/chrome, or allow the download.`); if (!(await online('cdn.playwright.dev')) && !(await online('playwright.download.prss.microsoft.com'))) fail(`${notice}, but this machine looks offline (DNS lookup failed).\n Connect and rerun, install Google Chrome, or set TRANSIT_BROWSER=/path/to/chrome.`); log(`${notice}. Downloading once…`); if (!(await runRetry('browser download', process.execPath, [join(PW, 'cli.js'), 'install', '--only-shell', 'chromium']))) fail('chromium-headless-shell download failed 3 times. Check your network/proxy (HTTPS_PROXY), or install Google Chrome and rerun.'); const version = await tryLaunch({ kind: 'bundled' }); if (!version) fail('the downloaded headless shell does not start.' + (process.platform === 'linux' ? ' On Linux install its system libraries: npx playwright-core install-deps chromium' : '')); return { kind: 'bundled', source: 'downloaded', label: 'chromium-headless-shell', version }; } // ---------------------------------------------------------------- ffmpeg // ffmpeg only (MP4/GIF/contact sheet and the verify gates); frame counts come from ffmpeg itself, so no ffprobe. function staticFfmpeg() { try { const pkg = join(ROOT, 'node_modules/ffmpeg-static'); const version = JSON.parse(readFileSync(join(pkg, 'package.json'), 'utf8')).version; const bin = join(pkg, process.platform === 'win32' ? 'ffmpeg.exe' : 'ffmpeg'); return { bin, version, present: existsSync(bin) }; } catch { return null; } } function findFfmpeg() { if (process.env.TRANSIT_FFMPEG) return runs(process.env.TRANSIT_FFMPEG, ['-version']) ? { ffmpeg: process.env.TRANSIT_FFMPEG, source: 'env' } : null; const st = staticFfmpeg(); if (st && st.present && runs(st.bin, ['-version'])) return { ffmpeg: st.bin, source: `ffmpeg-static ${st.version}` }; for (const d of ['', '/opt/homebrew/bin/', '/usr/local/bin/', '/usr/bin/']) if (runs(d + 'ffmpeg', ['-version'])) return { ffmpeg: d + 'ffmpeg', source: 'system' }; return null; } function pickFfmpeg({ check }) { const found = findFfmpeg(); if (found) return found; if (process.env.TRANSIT_FFMPEG) fail(`TRANSIT_FFMPEG=${process.env.TRANSIT_FFMPEG} does not run (\`-version\` failed). Point it at an ffmpeg binary or unset it.`); const st = staticFfmpeg(); const fix = st && !st.present ? `The ffmpeg-static dependency is installed but its binary was not downloaded (its install script did not run; npm 11 asks for approval).\n Fetch it: npm rebuild ffmpeg-static (from ${ROOT}; downloads ~45 MB into node_modules)` : `Run \`npm install\` in ${ROOT} (installs the pinned ffmpeg-static, ~45 MB, into node_modules).`; const sys = process.platform === 'darwin' ? 'brew install ffmpeg' : process.platform === 'linux' ? 'sudo apt-get install -y ffmpeg (Fedora: sudo dnf install ffmpeg)' : 'winget install Gyan.FFmpeg'; const help = `ffmpeg is needed for MP4/GIF output and was not found.\n ${fix}\n Or install a system ffmpeg yourself: ${sys}\n Or set TRANSIT_FFMPEG=/path/to/ffmpeg.\n Transit never installs system packages for you. The interactive HTML (core/build.mjs) works without ffmpeg.`; if (check) return { source: 'missing', note: help.replace(/\n\s*/g, ' | ') }; fail(help); } // ---------------------------------------------------------------- main entry export async function ensureSetup({ need = ['deps', 'browser', 'ffmpeg'], force = false, check = false } = {}) { if (process.env.TRANSIT_SKIP_SETUP === '1') return null; const noDownload = argv.includes('--no-download') || process.env.TRANSIT_NO_DOWNLOAD === '1'; try { const major = Number(process.versions.node.split('.')[0]); if (major < MIN_NODE) fail(`Node ${process.versions.node} is too old; Transit needs Node ${MIN_NODE}+ (playwright-core 1.64 requires it). Install a current Node from https://nodejs.org or your version manager.`); let mark = null; try { mark = JSON.parse(readFileSync(MARKER, 'utf8')); } catch {} const browserGone = mark?.browser?.kind === 'executable' && !existsSync(mark.browser.value); const fresh = !force && !check && mark && mark.version === 3 && mark.node === process.versions.node && mark.playwrightCore === pwVersion() && existsSync(PW) && !browserGone; const todo = need.filter((n) => !(fresh && mark.ok?.includes(n))); if (!todo.length) return mark; if (!check) log(`first run (or changed setup): checking ${todo.join(', ')}`); const rec = fresh ? { ...mark } : { version: 3, ok: [] }; const ok = new Set(rec.ok); if (todo.includes('deps') || todo.includes('browser')) { if (existsSync(PW)) rec.deps = { source: 'present' }; else if (check) rec.deps = { source: 'missing', note: 'would run npm install (playwright-core ~13 MB + pinned ffmpeg-static ~45 MB, into node_modules)' }; else { if (noDownload) fail('node_modules is missing and downloads are disabled. Run `npm install` in ' + ROOT); if (!(await online('registry.npmjs.org'))) fail('node_modules is missing and this machine looks offline (cannot resolve registry.npmjs.org). Connect and rerun, or copy node_modules from another machine.'); log('installing project dependencies into node_modules (playwright-core ~13 MB, pinned ffmpeg-static ~45 MB); nothing system-wide…'); if (!(await runRetry('npm install', ...npmCommand(['install', '--no-audit', '--no-fund', '--omit=dev'])))) fail('npm install failed 3 times. Check your network/proxy and run `npm install` in ' + ROOT + ' to see the error.'); rec.deps = { source: 'installed' }; } ok.add('deps'); } if (todo.includes('browser')) { rec.browser = existsSync(PW) ? await pickBrowser({ check, noDownload }) : { source: 'unknown', note: 'needs npm deps first' }; ok.add('browser'); } if (todo.includes('ffmpeg')) { rec.ffmpeg = pickFfmpeg({ check }); ok.add('ffmpeg'); } Object.assign(rec, { node: process.versions.node, playwrightCore: pwVersion(), platform: `${process.platform}-${process.arch}`, ok: [...ok].sort() }); if (check) return rec; mkdirSync(dirname(MARKER), { recursive: true }); writeFileSync(MARKER, JSON.stringify(rec, null, 1) + '\n'); const b = rec.browser, f = rec.ffmpeg; log(`ok: browser = ${b ? `${b.label || b.value || b.kind} (${b.source}${b.version ? ', ' + b.version : ''})` : 'not needed'}; ffmpeg = ${f ? `${f.ffmpeg} (${f.source})` : 'not needed'}. Recorded in .transit-cache/setup.json`); return rec; } catch (e) { if (!(e instanceof SetupError)) throw e; log(e.message); if (isMain || !check) process.exit(1); throw e; } } if (isMain) { const check = argv.includes('--check'); if (argv.includes('--force')) rmSync(MARKER, { force: true }); const rec = await ensureSetup({ force: argv.includes('--force'), check }); if (check) { const line = (k, v) => console.log(`${k.padEnd(8)} ${v}`); line('node', `${process.versions.node} (needs ${MIN_NODE}+)`); line('deps', `${rec.deps?.source}${rec.deps?.note ? ' - ' + rec.deps.note : ''}`); const b = rec.browser || {}; line('browser', b.source === 'would-download' ? `missing - ${b.note}` : `${b.label || b.value || b.kind} [${b.source}]${b.version ? ' ' + b.version : ''}`); const f = rec.ffmpeg || {}; line('ffmpeg', f.ffmpeg ? `${f.ffmpeg} [${f.source}]` : `missing - ${f.note}`); const missing = rec.deps?.source === 'missing' || b.source === 'would-download' || !f.ffmpeg; console.log(missing ? 'check: something would be installed (nothing was changed)' : 'check: everything present, nothing to download'); process.exit(missing ? 1 : 0); } log('all set'); } ``` ## File: skills/agent-transit/core/still.mjs size: 923 sha: bcc6ed3d3086f0444b472bbba7af0e99d9770d3b upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/still.mjs ```text import { ensureSetup } from './setup.mjs'; import { pathToFileURL } from 'node:url'; import { resolve } from 'node:path'; await ensureSetup({ need: ['deps', 'browser'] }); const { launchBrowser } = await import('./tools.mjs'); const [file, ...ts] = process.argv.slice(2); const b = await launchBrowser(); const p = await b.newPage({ viewport: { width: 1200, height: 900 } }); const errs = []; p.on('pageerror', (e) => errs.push(e.message)); p.on('console', (m) => m.type() === 'error' && errs.push(m.text())); await p.goto(pathToFileURL(resolve(file)).href + '?paused=1'); await p.evaluate(() => document.fonts.ready); console.log(JSON.stringify(await p.evaluate(() => ({ s: window.VIZ && window.VIZ.seconds, f: document.fonts.check('700 14px "Transit Sans"') }))), errs); for (const t of ts) { await p.evaluate((t) => window.renderAt(t), Number(t)); await p.screenshot({ path: `/tmp/still-${t}.png` }); } await b.close(); ``` ## File: skills/agent-transit/core/tools.mjs size: 2749 sha: 663f743d7dfe5380fcdca75cf8ed4b20fbeabc61 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/tools.mjs ```text // core/tools.mjs: the browser and ffmpeg that core/setup.mjs chose, recorded in .transit-cache/setup.json. // Every script launches Chromium and runs ffmpeg through here, so a reused system Chrome or a reused // Playwright cache from another project is used the same way everywhere. // TRANSIT_BROWSER=/path/to/chrome | chrome | msedge | bundled overrides the recorded choice // Determinism: two renders on the same machine with the same browser build are byte-identical. Different // browsers or builds (system Chrome vs Playwright's headless shell, or another version) can rasterize text // slightly differently, so hashes are only comparable per machine+browser. import { readFileSync } from 'node:fs'; import { spawnSync } from 'node:child_process'; import { dirname, join, resolve } from 'node:path'; import { fileURLToPath } from 'node:url'; export const ROOT = resolve(dirname(fileURLToPath(import.meta.url)), '..'); export const MARKER = join(ROOT, '.transit-cache', 'setup.json'); const marker = () => { try { return JSON.parse(readFileSync(MARKER, 'utf8')); } catch { return {}; } }; // {kind:'bundled'} | {kind:'channel', value:'chrome'} | {kind:'executable', value:'/path'} export function browserChoice() { const env = process.env.TRANSIT_BROWSER; if (env) return env === 'bundled' ? { kind: 'bundled' } : /^(chrome|chrome-beta|msedge|msedge-beta|chromium)$/.test(env) ? { kind: 'channel', value: env } : { kind: 'executable', value: env }; return marker().browser || { kind: 'bundled' }; } export const launchOptions = (c = browserChoice()) => c.kind === 'channel' ? { channel: c.value } : c.kind === 'executable' ? { executablePath: c.value } : {}; export async function launchBrowser(opts = {}) { const { chromium } = await import('playwright-core'); return chromium.launch({ ...launchOptions(), ...opts }); } export const ffmpegBin = () => process.env.TRANSIT_FFMPEG || marker().ffmpeg?.ffmpeg || 'ffmpeg'; // Runs ffmpeg with an argument array (never a shell) and returns stdout + stderr as text, even when it exits non-zero. export function ffmpegText(args) { const r = spawnSync(ffmpegBin(), ['-hide_banner', ...args], { encoding: 'utf8', maxBuffer: 1 << 26 }); if (r.error) throw new Error(`cannot run ffmpeg (${ffmpegBin()}): ${r.error.code || r.error.message}`); return (r.stdout || '') + (r.stderr || ''); } // Decoded video frame count from ffmpeg's own progress line (replaces ffprobe -count_frames). export function countFrames(file) { const out = ffmpegText(['-nostdin', '-i', file, '-map', '0:v:0', '-f', 'null', '-']); const all = [...out.matchAll(/frame=\s*(\d+)/g)]; if (!all.length) throw new Error(`ffmpeg reported no frames for ${file}`); return Number(all[all.length - 1][1]); } ``` ## File: skills/agent-transit/core/transit.template.html size: 85599 sha: 785dbfbc105ef28e4b91be9df4a504fd7bc6b5c4 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/transit.template.html Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/transit.template.html ## File: skills/agent-transit/core/verdict.mjs size: 6128 sha: 9fa093244ea064c8a9a2fc1ac6f954125e28e59c upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/verdict.mjs ```text // core/verdict.mjs: a one-line, data-derived summary of a normalized trace, used for the default file // name, the --share console tip and the --share page headline. Nothing here is invented: the subject, // message, time and count all come from the trace. The hop count mirrors the page's call building // (uninstrumented peers + cross-service parent/child edges), without CI needs connectors. const CI = 'gh-actions', AGENT = ['claude-code', 'codex', 'cursor']; export function countHops(trace) { const spans = trace.spans, byId = new Map(spans.map((s) => [s.spanId, s])); const kids = new Map(spans.map((s) => [s.spanId, []])); for (const s of spans) if (s.parentId && kids.has(s.parentId)) kids.get(s.parentId).push(s); const crossKids = (s) => kids.get(s.spanId).filter((c) => c.service !== s.service); const via = new Map(); let n = 0; for (const s of spans) { if ((s.kind === 'client' || s.kind === 'producer') && s.peer && (s.kind === 'producer' || crossKids(s).length === 0) && s.peer !== s.service) { via.set(s.spanId, s.peer); n++; } } for (const s of spans) { const p = s.parentId && byId.get(s.parentId); if (!p || p.service === s.service) continue; const from = p.kind === 'producer' && via.has(p.spanId) ? via.get(p.spanId) : p.service; if (from !== s.service) n++; } return n; } // the first error that starts here (an error span with no error below it), earliest end first export function errorOrigin(trace) { const kids = new Map(trace.spans.map((s) => [s.spanId, []])); for (const s of trace.spans) if (s.parentId && kids.has(s.parentId)) kids.get(s.parentId).push(s); const errBelow = (s) => kids.get(s.spanId).some((k) => k.status === 'error' || errBelow(k)); const origins = trace.spans.filter((s) => s.status === 'error' && !errBelow(s)); // CI: only steps carry alerts on the map const pool = trace.meta && trace.meta.format === CI ? origins.filter((s) => s.attrs && s.attrs['ci.step.number'] != null) : origins; return pool.sort((a, b) => (a.start + a.duration) - (b.start + b.duration) || a.start - b.start || String(a.spanId).localeCompare(String(b.spanId)))[0] || null; } export const fmtMs = (ms) => { if (ms < 1000) return `${Math.round(ms)} ms`; if (ms < 60000) return `${(ms / 1000).toFixed(ms < 10000 ? 2 : 1)} s`; const sec = Math.round(ms / 1000), m = Math.floor(sec / 60), r = sec % 60; return m < 60 ? `${m} min${r ? ` ${r} s` : ''}` : `${Math.floor(m / 60)} h ${m % 60} min`; }; const clean = (s) => String(s || '').replace(/\s+/g, ' ').trim(); // cut at a word boundary, never mid-word const cut = (t, max) => { if (t.length <= max) return t; const w = t.slice(0, max).replace(/\s+\S*$/, ''); return (w || t.slice(0, max)).replace(/[\s,;:.-]+$/, '') + '…'; }; // the short cause for the verdict line; the full message stays in the panel and the line's tooltip. // "Internal Server Error: failed to send order confirmation (SMTP timeout)" -> "SMTP timeout" // "error: connect ECONNREFUSED 10.0.0.1:5432" -> "connect ECONNREFUSED 10.0.0.1:5432" // returns '' when the message only repeats the station's own name ("step failed: Run unit tests") export function shortReason(message, names = [], max = 40) { let t = clean(message); if (!t) return ''; const paren = t.match(/\(([^()]{2,48})\)\s*\.?$/); if (paren) t = paren[1].trim(); else if (t.length > max) { const parts = t.split(/:\s+/).filter(Boolean); if (parts.length > 1) t = parts[parts.length - 1]; } const low = t.toLowerCase().replace(/^(step|job|tool|call)?\s*failed:?\s*/, ''); if (!low || names.some((n) => n && clean(n).toLowerCase() === low)) return ''; return cut(t, max); } function subjectOf(s, format) { // a step without ci.job (hand-made or partial run JSON) falls back to its station, never 'undefined' if (format === CI) { const job = (s.attrs && s.attrs['ci.job']) || s.service; return job && job !== s.name ? { label: `${job} / ${s.name}`, short: job } : { label: s.name, short: s.name }; } if (AGENT.includes(format)) return { label: s.name, short: s.name }; return { label: s.service, short: s.service }; } // wall (optional): spanId -> {start, duration} from before idle gaps were shortened, so times read as wall time export function verdict(trace, vocab = {}, wall = null) { const format = trace.meta && trace.meta.format; const W = (s) => (wall && wall.get(s.spanId)) || s; const hops = countHops(trace), noun = vocab.hopNounPlural || 'hops', alert = vocab.serviceAlert || 'SERVICE ALERT'; const t0 = Math.min(...trace.spans.map((s) => W(s).start)), t1 = Math.max(...trace.spans.map((s) => W(s).start + W(s).duration)); const o = errorOrigin(trace); if (!o) return { text: `no ${alert} · ${hops} ${noun} in ${fmtMs(t1 - t0)}`, origin: null, subject: null, message: null }; const sub = subjectOf(o, format); const reason = shortReason(o.statusMessage, [o.name, o.service, sub.label]); return { text: `${sub.label} failed after ${fmtMs(W(o).start - t0)}${reason ? `: ${reason}` : ''} · ${alert} · ${hops} ${noun}`, origin: o.spanId, subject: sub.short, message: clean(o.statusMessage) || null, }; } export const slug = (s, max = 40) => String(s || '').normalize('NFKD').replace(/[̀-ͯ]/g, '').toLowerCase() .replace(/[^a-z0-9]+/g, '-').replace(/^-+|-+$/g, '').slice(0, max).replace(/-+$/, ''); // "Checkout: one order through..." + email alert -> "checkout-email-service-alert" // Empty slug parts (e.g. CJK-only text) are dropped, so a name never starts with '-' (shells read that as a flag): // an alert with nothing nameable is "transit-service-alert". export function defaultName(title, v) { const t = String(title || ''); const head = /[:–—|]/.test(t) ? t.split(/[:–—|]/)[0] : t.split(/\s+/).slice(0, 4).join(' '); const parts = [slug(head, 32), v && v.subject ? slug(v.subject, 24) : ''].filter(Boolean); if (v && v.subject) parts.push(parts.length ? 'service-alert' : 'transit-service-alert'); const name = parts.join('-').replace(/-+/g, '-').replace(/^-+/, '').slice(0, 80).replace(/-+$/, ''); return (name || 'transit') + '.html'; } ``` ## File: skills/agent-transit/core/verify.mjs size: 4549 sha: d81fc1c55547602b03062c0b2e3246babfe99865 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/verify.mjs ```text // core/verify.mjs: done-check for story 4 (share a flow). // 1. determinism: render every frame twice into separate folders, sha256 each PNG, compare // 2. timing: each train leaves on frame ceil((intro + span.start / msPerSec) * fps) // 3. ffmpeg gates on anim.mp4: freezedetect (no static stretch longer than intro/outro allow), // blackdetect (no black gaps) and blackdetect on the negated film (no blank white gaps) // usage: node core/verify.mjs <trace.json> --name otel [build options] import { execFileSync } from 'node:child_process'; import { readdirSync, readFileSync } from 'node:fs'; import { createHash } from 'node:crypto'; import { join, resolve, dirname } from 'node:path'; import { fileURLToPath, pathToFileURL } from 'node:url'; import { ensureSetup } from './setup.mjs'; import { ffmpegText } from './tools.mjs'; import { removeFramesDir, safeName } from './fsguard.mjs'; import { parseArgs, toArgs, runCli, UserError } from './cli.mjs'; await ensureSetup({ need: ['deps', 'browser', 'ffmpeg'] }); const { launchBrowser } = await import('./tools.mjs'); const ROOT = resolve(dirname(fileURLToPath(import.meta.url)), '..'); await runCli(async () => { const { opt, pos } = parseArgs(process.argv.slice(2)); if (!pos[0]) throw new UserError('usage: node core/verify.mjs <trace.json> --name NAME [build options]'); const name = safeName(opt.name || 'otel'); const dir = join(ROOT, 'out', name); let fail = 0; const ok = (c, m) => { console.log(`${c ? 'PASS' : 'FAIL'} ${m}`); if (!c) fail++; }; const pass = (args) => [...args, ...toArgs(opt, ['name'])]; // child renders: argument arrays (no shell); their stderr shows, so a failure says why const node = (args) => execFileSync(process.execPath, args, { cwd: ROOT, stdio: ['ignore', 'ignore', 'inherit'] }); // 1. two independent full renders const runA = join(dir, 'frames'), runB = join(dir, 'frames-rerun'); node(pass(['core/render.mjs', pos[0], '--name', name])); node(pass(['core/render.mjs', pos[0], '--name', name, '--frames', runB, '--frames-only', '1'])); const sha = (f) => createHash('sha256').update(readFileSync(f)).digest('hex'); const A = readdirSync(runA).filter((f) => f.endsWith('.png')).sort(), B = readdirSync(runB).filter((f) => f.endsWith('.png')).sort(); const diff = A.filter((f, i) => B[i] !== f || sha(join(runA, f)) !== sha(join(runB, f))); const all = createHash('sha256'); for (const f of A) all.update(sha(join(runA, f))); ok(A.length === B.length && diff.length === 0, `determinism: ${A.length} frames x 2 renders, sha256 identical (${diff.length} differ); film hash ${all.digest('hex').slice(0, 16)}`); removeFramesDir(runB); // only the NNNN.png files this script rendered, then the folder if empty // 2. timing from the page model const browser = await launchBrowser(); const page = await browser.newPage(); await page.goto(pathToFileURL(join(dir, 'transit.html')).href + '?paused=1'); const V = await page.evaluate(() => ({ ...window.VIZ, trainsAt: undefined, frameOfTraceMs: undefined })); let bad = 0; const zero = V.calls.filter((c) => !(c.end > c.start)).length; // zero-duration calls (e.g. skipped CI jobs) have no train for (const c of V.calls.filter((c) => c.end > c.start)) { const f = await page.evaluate((ms) => window.VIZ.frameOfTraceMs(ms), c.start); const on = async (fr) => (await page.evaluate((t) => window.VIZ.trainsAt(t), fr / V.fps)).some((x) => x.spanId === c.spanId && !x.back); if (!(await on(f)) || (f > 0 && await on(f - 1))) bad++; } ok(bad === 0, `timing: ${V.calls.length - zero} trains each leave on the frame of their span start (${bad} off${zero ? `, ${zero} zero-duration skipped` : ''})`); await browser.close(); // 3. ffmpeg gates const mp4 = join(dir, 'anim.mp4'); const ffe = (vf) => ffmpegText(['-nostdin', '-i', mp4, '-vf', vf, '-an', '-f', 'null', '-']); // arg array, the recorded ffmpeg const maxStill = V.intro + 1.75 + 0.6; const fz = ffe('freezedetect=n=0.0005:d=' + maxStill.toFixed(2)); const freezes = [...fz.matchAll(/freeze_duration: ([\d.]+)/g)].map((m) => Number(m[1])); ok(freezes.length === 0, `freezedetect: no static stretch >= ${maxStill.toFixed(2)} s (${freezes.length ? freezes.join(', ') + ' s' : 'none'})`); const bl = ffe('blackdetect=d=0.1:pix_th=0.10'); ok(!/black_start/.test(bl), 'blackdetect: no black gaps'); const wh = ffe('negate,blackdetect=d=0.1:pix_th=0.10:pic_th=0.97'); ok(!/black_start/.test(wh), 'blackdetect (negated): no blank white gaps'); console.log(fail ? `${fail} check(s) failed` : 'all checks passed'); process.exit(fail ? 1 : 0); }); ``` ## File: skills/agent-transit/core/vocab.mjs size: 5170 sha: a9dfd797b25d1c35786f45f971c4bedfa150a17a upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/core/vocab.mjs ```text // User-visible vocabulary for each Transit skill. Packs may be partial: the // request pack is the compatibility fallback for every missing string. export const vocab = { request: { lineNoun: 'service', stationNoun: 'hop', hopNoun: 'hop', hopNounPlural: 'hops', play: 'Play', pause: 'Pause', helpTitle: 'Keyboard shortcuts', space: 'play / pause', nextHop: 'next hop', previousHop: 'previous hop', seek: 'seek 0.5 s', frame: 'step one frame', startEnd: 'start / end', speed: 'speed 0.5x / 1x / 2x', click: 'click', clickHelp: 'station, train or line: select that hop', inspectClick: 'click a station, train or line', pauseHelp: 'selects the hop in progress', escape: 'deselect / close', help: 'this help', of: 'of', video: '1 s of video', trace: 'trace', infrastructure: 'infrastructure', delay: 'DELAY', serviceAlert: 'SERVICE ALERT', request: 'request', response: 'response', legendDelay: 'delay: self time ≥', legendAlert: 'service alert: error starts here', legendInfra: 'dotted: infrastructure (no spans of its own)', synthetic: 'SYNTHETIC sample data', renderedLocally: 'rendered locally by Transit', unmatched: 'unmatched', matched: 'matched', contracts: 'contracts', noContractIndex: 'no contract index', contractFooter: true, // footer counts hops without a contract; only request traces have contracts scrubbedValues: 'value(s) scrubbed from names, messages and URLs', scrubOff: 'Value scrubbing was OFF for this page: do not share it.', error: 'error', slow: 'slow', ok: 'ok', tableTitle: 'Hops', tableStart: 'start', tableFrom: 'from', tableTo: 'to', tableSpan: 'span', tableStatus: 'status', tableContract: 'contract', infrastructureHop: 'infrastructure hop', infrastructureHopTitle: 'Infrastructure hop', unmatchedContracts: 'unmatched (contracts not indexed)', unmatchedShort: 'unmatched', noHopSelected: 'no hop selected', inspectHop: 'Pause, press', or: 'or', inspectTail: 'to inspect a hop.', shortcuts: 'Shortcuts', transit: 'Transit', hop: 'HOP', span: 'SPAN', from: 'from', client: 'client', server: 'server', noServerSpan: 'no server span', notInstrumented: 'is not instrumented', status: 'status', unset: 'unset', resource: 'resource', attributes: 'Attributes', serverSpan: 'server span', children: 'Children', none: 'none', sensitiveRedacted: 'Sensitive-looking keys are redacted at build time.', redactedAcross: 'attribute(s) redacted across this trace before rendering.', expectedRequestResponse: 'Expected request / response', contractsNotIndexed: 'Contracts not indexed. The contract layer is optional: build an index with', thenBuildWith: 'then build the page with', noHopContract: 'No hop contract for this span', internalWorkInside: 'internal work inside', noContractExpected: 'No contract expected', fallback: 'FALLBACK', matchedTag: 'MATCHED', message: 'Message', noRequestSchema: 'No request schema found', noResponseType: 'No response type found', responseBody: 'no body (void)', unknown: 'unknown', unresolved: 'unresolved', deeperFields: '… deeper fields not shown', optional: 'optional', required: 'required', sharedPackage: 'shared package', declared: 'declared', clientCallFrom: 'client call from', in: 'in', wholeTrace: 'of the whole trace', spanInsideClient: 'server span inside the client call', spanInsideParent: 'span inside its parent', deselect: 'Deselect (Esc)', more: 'more', confidenceHigh: 'high confidence', confidenceMedium: 'medium confidence', confidenceLow: 'low confidence', validator: 'validator', type: 'type', spec: 'spec', schema: 'schema', kind: 'kind', start: 'start', duration: 'duration', self: 'self', groups: { http: 'HTTP', db: 'DB', messaging: 'Messaging', rpc: 'RPC', other: 'Other' }, }, ci: { lineNoun: 'job', stationNoun: 'step', hopNoun: 'dependency', hopNounPlural: 'dependencies', request: 'workflow run', response: 'completion', delay: 'DELAY', serviceAlert: 'SERVICE ALERT', legendDelay: 'delay: self time ≥', legendAlert: 'service alert: error starts here', tableTitle: 'Steps', tableSpan: 'step', infrastructure: 'workflow infrastructure', hop: 'STEP', span: 'JOB', trace: 'run', error: 'failed', slow: 'slow step', skipped: 'skipped', contractFooter: false, }, agent: { lineNoun: 'tool family', stationNoun: 'call', hopNoun: 'call', hopNounPlural: 'calls', trace: 'session', request: 'session', response: 'completion', tableTitle: 'Tool calls', tableSpan: 'call', delay: 'DELAY', serviceAlert: 'SERVICE ALERT', legendDelay: 'delay: self time ≥', legendAlert: 'service alert: error starts here', infrastructure: 'agent infrastructure', hop: 'CALL', span: 'TOOL', error: 'error', slow: 'slow call', contractFooter: false, }, }; export const VOCAB_PACKS = vocab; export const DEFAULT_VOCAB = 'request'; export function resolveVocab(value = DEFAULT_VOCAB) { const pack = typeof value === 'string' ? vocab[value] : value; if (typeof value === 'string' && !pack) throw new Error(`unknown vocab pack: ${value}`); return { ...vocab.request, ...(pack || {}) }; } ``` ## File: skills/agent-transit/LICENSE size: 1070 sha: 0cedbc256085f2d0a7175150e6d648ebb6661e0c upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/LICENSE ```text MIT License Copyright (c) 2026 Israel Vicars Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software. THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. ``` ## File: skills/agent-transit/package.json size: 252 sha: 28926b5b37e7f280a7b2292ade8177fd5484e33d upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/package.json ```text { "name": "agent-transit", "private": true, "type": "module", "engines": { "node": ">=20" }, "dependencies": { "ffmpeg-static": "5.3.0", "playwright-core": "1.64.0" }, "allowScripts": { "ffmpeg-static@5.3.0": true } } ``` ## File: skills/agent-transit/src/agent-transit/adapters/normalize-agent.mjs size: 15134 sha: f467bc74ae28a1dd6f559a7cd1208b5fc29ce291 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/agent-transit/adapters/normalize-agent.mjs ```text // Tolerant, privacy-first adapters for local coding-agent session JSONL. // Deliberately extracts timing and tool identity only; payloads are never copied. import { basename } from 'node:path'; import { readFileSync } from 'node:fs'; import { fileURLToPath } from 'node:url'; import { validate, parseJsonSafe } from '../../request-transit/adapters/normalize.mjs'; const FAMILIES = new Map([ ['read', 'read'], ['readfile', 'read'], ['glob', 'read'], ['grep', 'read'], ['ls', 'read'], ['view', 'read'], ['view_image', 'read'], ['edit', 'edit'], ['write', 'edit'], ['multiedit', 'edit'], ['apply_patch', 'edit'], ['bash', 'shell'], ['shell', 'shell'], ['exec_command', 'shell'], ['local_shell', 'shell'], ['write_stdin', 'shell'], ['wait', 'shell'], ['webfetch', 'web'], ['websearch', 'web'], ['web_fetch', 'web'], ['web_search', 'web'], ['web__run', 'web'], ['web.run', 'web'], ['task', 'subagent'], ['agent', 'subagent'], ['skill', 'skill'], ['todowrite', 'plan'], ['update_plan', 'plan'], ['notebookedit', 'edit'], ['strreplace', 'edit'], ['delete', 'edit'], ['editnotebook', 'edit'], ['semanticsearch', 'read'], ['readlints', 'read'], // Cursor IDE composer tool names (toolFormerData.name in state.vscdb) ['read_file', 'read'], ['list_dir', 'read'], ['grep_search', 'read'], ['ripgrep', 'read'], ['file_search', 'read'], ['glob_file_search', 'read'], ['codebase_search', 'read'], ['read_lints', 'read'], ['search_replace', 'edit'], ['edit_file', 'edit'], ['edit_file_v2_apply_patch', 'edit'], ['delete_file', 'edit'], ['run_terminal_cmd', 'shell'], ['todo_write', 'plan'], ['update_memory', 'plan'], ['fetch_pull_request', 'web'], ]); const isoMs = (x) => { if (x == null) return null; if (typeof x === 'number') return x < 1e12 ? x * 1000 : x; const n = Number(x); if (Number.isFinite(n)) return n < 1e12 ? n * 1000 : n; const t = Date.parse(String(x)); return Number.isFinite(t) ? t : null; }; const key = (name) => String(name || '').toLowerCase(); const family = (name) => { const n = key(name); if (FAMILIES.has(n)) return FAMILIES.get(n); return n.startsWith('mcp__') || n.startsWith('mcp_') || n.includes('.') ? 'mcp' : 'other'; }; const contentText = (x) => Array.isArray(x) ? x.map((b) => typeof b === 'string' ? b : b && (b.text || b.content || '')).join(' ') : String(x ?? ''); const denied = (x) => /\b(denied|permission denied|not allowed|rejected|approval required)\b/i.test(contentText(x)); const errorText = (x) => /\b(error|failed|failure|exception)\b/i.test(contentText(x)); const basenameTarget = (name, args) => { const a = args && typeof args === 'object' ? args : {}; const path = a.file_path || a.filePath || a.path || a.filename || a.target_file || a.relativeWorkspacePath || a.relative_workspace_path || a.targetFile || a.directoryPath || a.targetDirectory || a.target_directory || a.globPattern || a.glob_pattern; if (path) return basename(String(path)); const command = typeof args === 'string' ? args : a.command || a.cmd || a.script; if (command) return String(command).trim().split(/\s+/)[0].slice(0, 40); const query = a.pattern || a.query || a.url || a.searchTerm || a.search_term; return query ? String(query).trim().split(/\s+/)[0].slice(0, 40) : ''; }; const shortName = (name, args) => `${String(name || 'tool')}${basenameTarget(name, args) ? ` · ${basenameTarget(name, args)}` : ''}`.slice(0, 40); const safeArgs = (args) => { let s = typeof args === 'string' ? args : JSON.stringify(args ?? '', (k, v) => /^(content|output|result|prompt|text)$/i.test(k) ? '[REDACTED]' : v); s = s.replace(/("?(?:password|passwd|token|secret|authorization|cookie)"?\s*[:=]\s*")([^"\\]{0,200})(")/ig, '$1[REDACTED]$3'); return s.slice(0, 120); }; const isMarker = (x) => x && typeof x === 'object' && (x._agentFormat || x.meta && x.meta.agentFormat); const linesOf = (doc) => Array.isArray(doc) ? doc : String(doc).split(/\r?\n/).filter(Boolean).map((x) => JSON.parse(x)); export function isAgentLog(doc) { const lines = Array.isArray(doc) ? doc : []; return !!lines.length && (isMarker(lines[0]) || lines.some((x) => x && (x.type === 'session_meta' || x.type === 'response_item' || x.role === 'assistant' || x.role === 'user')) || lines.slice(0, 5).some(isBubble)); } function claudeEvents(lines, format, warnings) { const calls = new Map(), results = new Map(), times = []; for (const line of lines) { if (isMarker(line)) continue; if (['queue-operation', 'attachment', 'ai-title', 'last-prompt', 'summary', 'system', 'file-history-snapshot'].includes(line.type)) continue; const t = isoMs(line.timestamp); if (t != null) times.push(t); const blocks = line.message && Array.isArray(line.message.content) ? line.message.content : []; for (const b of blocks) { if (line.type === 'assistant' && b && b.type === 'tool_use' && b.id) calls.set(String(b.id), { id: String(b.id), name: b.name, args: b.input, start: t, sidechain: !!line.isSidechain }); if (line.type === 'user' && b && b.type === 'tool_result' && b.tool_use_id) results.set(String(b.tool_use_id), { end: t, error: !!b.is_error, denied: !!b.is_error && denied(contentText(b.content).slice(0, 200)) }); } } return [...calls.values()].map((c) => ({ ...c, result: results.get(c.id) })).filter((c) => c.start != null); } // Codex outputs: judge only the head of the output (first line / exit metadata). Scanning the whole body for // words like "error" or "denied" flags any call whose output merely mentions them (seen on real sessions). function codexStatus(p) { const text = contentText(p.output); const head = text.trimStart().split(/\r?\n/)[0].slice(0, 120); let exit = null; if (typeof p.output === 'string' && p.output.trim().startsWith('{')) { try { const o = JSON.parse(p.output); exit = o && o.metadata && o.metadata.exit_code; } catch {} } const isDenied = /^(permission denied|denied|rejected|not allowed|aborted by user)/i.test(head); return { error: !!p.is_error || isDenied || /^script failed\b/i.test(head) || (exit != null && Number(exit) !== 0), denied: isDenied }; } function codexEvents(lines, warnings) { const calls = new Map(), results = new Map(), times = [], unknown = new Map(); const warnUnknown = (type) => unknown.set(type, (unknown.get(type) || 0) + 1); for (const line of lines) { if (isMarker(line)) continue; const t = isoMs(line.timestamp); if (t != null) times.push(t); if (['session_meta', 'turn_context', 'event_msg', 'world_state', 'token_usage_record', 'compacted'].includes(line.type)) continue; if (line.type !== 'response_item') { warnUnknown(line.type || 'missing type'); continue; } const p = line.payload || {}; const kind = p.type || line.type; if (kind === 'message' || kind === 'reasoning' || kind === 'agent_message' || String(kind).startsWith('compaction') || kind === 'ghost_snapshot') continue; if (kind === 'web_search_call') { const id = String(p.call_id || p.id || `web-${calls.size + 1}`); calls.set(id, { id, name: 'web_search', args: {}, start: t }); } else if (kind === 'function_call' || kind === 'custom_tool_call' || kind === 'local_shell_call') { const id = String(p.call_id || p.id || `${kind}-${calls.size + 1}`); let args = p.arguments ?? p.input ?? p.command ?? p; let name = p.namespace && p.name ? `${p.namespace}.${p.name}` : p.name || (kind === 'local_shell_call' ? 'local_shell' : kind); let wrapper; if (kind === 'custom_tool_call' && name === 'exec') { const match = typeof p.input === 'string' && [...p.input.matchAll(/\btools\.(\w+)\s*\(/g)].find((m) => !/^(forEach|map|filter|find|some|every|reduce|includes|keys|values|entries)$/.test(m[1])); name = match ? match[1] : 'exec'; args = {}; wrapper = 'exec'; } if (typeof args === 'string' && p.arguments && (args.trim().startsWith('{') || args.trim().startsWith('['))) { try { args = JSON.parse(args); } catch {} } calls.set(id, { id, name, args, start: t, wrapper }); } else if (kind === 'function_call_output' || kind === 'custom_tool_call_output' || kind === 'local_shell_call_output') { const id = String(p.call_id || p.id || ''); if (id) { const st = codexStatus(p); results.set(id, { end: t, error: st.error, denied: st.denied }); } } else warnUnknown(kind || 'missing payload type'); } for (const [type, count] of unknown) warnings.push(`ignored ${count} Codex line(s) of type ${type}`); return [...calls.values()].map((c) => ({ ...c, result: results.get(c.id) })).filter((c) => c.start != null); } // Cursor IDE composer bubbles (exported by scripts/export-cursor.mjs, or any dump of state.vscdb bubble records): // {bubbleId, type: 1 user | 2 assistant, createdAt ISO, timingInfo {clientRpcSendTime, clientEndTime}, toolFormerData {name, status, params}}. // A tool call starts at its bubble's createdAt. Cursor stores no tool end time, so it ends at the next bubble's // createdAt, capped by the turn's clientEndTime: an upper bound that includes the model's next step. // Bubbles from Cursor builds before ~Sep 2025 have no createdAt: order only, uniform durations. const isBubble = (l) => l && typeof l === 'object' && typeof l.bubbleId === 'string' && typeof l.type === 'number'; const parseObj = (x) => { if (x && typeof x === 'object') return x; try { const o = JSON.parse(x); return o && typeof o === 'object' ? o : {}; } catch { return {}; } }; function cursorBubbleEvents(lines, warnings) { const bubbles = lines.filter(isBubble); const t = bubbles.map((b) => isoMs(b.createdAt)); const tools = bubbles.map((b, i) => [b, i]).filter(([b]) => b.toolFormerData && b.toolFormerData.name); const timed = tools.length > 0 && tools.every(([, i]) => t[i] != null); const events = []; let turnEnd = null; // Bubbles created within a few ms of each other belong to one model step: parallel tool calls, and the empty // assistant placeholder Cursor creates right after each call (seen on every call in real sessions). A call ends at // the first bubble after that burst. const BURST_MS = 300; const endOf = (i) => { // next later timestamp after the burst, capped by the turn end let j = i + 1; while (j < bubbles.length && bubbles[j].type !== 1 && t[j] != null && t[j - 1] != null && t[j] - t[j - 1] < BURST_MS) j++; for (; j < bubbles.length; j++) if (t[j] != null && t[j] >= t[i]) return turnEnd != null && turnEnd >= t[i] ? Math.min(t[j], turnEnd) : t[j]; return turnEnd != null && turnEnd >= t[i] ? turnEnd : t[i]; }; bubbles.forEach((b, i) => { if (b.type === 1) turnEnd = null; const te = b.timingInfo && isoMs(b.timingInfo.clientEndTime); if (te != null && te > 1e12) turnEnd = te; const tf = b.toolFormerData; if (!tf || !tf.name) return; const n = events.length, start = timed ? t[i] : n * 1250, end = timed ? endOf(i) : start + 1000; const st = String(tf.status || '').toLowerCase(); events.push({ id: `cursor-${n + 1}`, name: tf.name, args: { ...parseObj(tf.rawArgs), ...parseObj(tf.params) }, start, cursor: true, result: { end, error: st === 'error', denied: st === 'cancelled' || st === 'rejected', cancelled: st === 'cancelled' } }); }); warnings.push(timed ? 'Cursor session: tool calls start at their bubble createdAt; Cursor stores no tool end time, so each ends at the next message (an upper bound)' : 'Cursor session without bubble timestamps (Cursor builds before ~Sep 2025): order only, durations are uniform'); return events; } function cursorEvents(lines, warnings) { if (lines.some(isBubble)) return cursorBubbleEvents(lines, warnings); const calls = [], turnCalls = []; for (const line of lines) { if (line.type === 'turn_ended') { if (line.status === 'error' && turnCalls.length) turnCalls[turnCalls.length - 1].turnError = true; turnCalls.length = 0; continue; } const blocks = line.message && Array.isArray(line.message.content) ? line.message.content : []; for (const b of blocks) if (line.role === 'assistant' && b && b.type === 'tool_use') { const e = { id: `cursor-${calls.length + 1}`, name: b.name, args: b.input, start: calls.length * 1250, cursor: true }; calls.push(e); turnCalls.push(e); } } warnings.push('Cursor transcripts have no timestamps or results: order only, durations are uniform'); return calls.map((e) => ({ ...e, result: e.turnError ? { end: e.start + 1000, error: true, denied: false } : { end: e.start + 1000, error: false, denied: false } })); } export function normalizeAgent(doc, options = {}) { const lines = linesOf(doc), format = options.format || (lines[0] && lines[0]._agentFormat) || 'claude-code'; const warnings = [], events = format === 'codex' ? codexEvents(lines, warnings) : format === 'cursor' ? cursorEvents(lines, warnings) : claudeEvents(lines, format, warnings); const allTimes = format === 'cursor' ? events.flatMap((e) => [e.start, e.result.end]) : lines.map((l) => isoMs(l.timestamp)).filter((x) => x != null); for (const e of events) if (e.result && e.result.end != null) allTimes.push(e.result.end); const startMs = allTimes.length ? Math.min(...allTimes) : 0, endMs = Math.max(...allTimes, startMs); const rootId = `session-${format}`; const raw = [{ spanId: rootId, parentId: null, service: 'agent', name: `${format} session`, start: 0, duration: endMs - startMs, status: 'ok', kind: 'server', attrs: { 'agent.source': format } }]; for (const e of events) { const end = e.result && e.result.end != null ? e.result.end : e.start; const result = e.result; const status = result && (result.error || result.denied) ? 'error' : 'ok'; const attrs = { 'agent.source': format }; if (e.wrapper) attrs['agent.wrapper'] = e.wrapper; if (e.sidechain) attrs['agent.sidechain'] = true; const s = { spanId: `tool-${e.id}`, parentId: rootId, service: e.wrapper === 'exec' ? family(e.name) : family(e.name), name: shortName(e.name, e.args), start: Math.max(0, e.start - startMs), duration: Math.max(0, end - e.start), status, kind: 'internal', attrs }; if (status === 'error') s.statusMessage = result.cancelled ? 'cancelled' : result.denied ? 'denied' : 'tool error'; if (options.showArgs) s.attrs['agent.args'] = safeArgs(e.args); raw.push(s); } const synthetic = options.synthetic === true || lines.some((l) => /synthetic/i.test(String(l._comment || l.meta?.synthetic || ''))); return validate({ traceId: `agent-${format}`, meta: { format, source: `agent.${format}`, synthetic, startUnixNs: String(Math.round(startMs * 1e6)), warnings }, spans: raw }); } export function normalize(doc, options = {}) { return normalizeAgent(doc, options); } if (process.argv[1] && fileURLToPath(import.meta.url) === process.argv[1]) { const file = process.argv[2], format = process.argv.find((x) => ['claude-code', 'codex', 'cursor'].includes(x)); if (!file) throw new Error('usage: node normalize-agent.mjs <session.jsonl> [claude-code|codex|cursor]'); const t = normalizeAgent(readFileSync(file, 'utf8'), { format }); console.log(JSON.stringify(t, null, 2)); } ``` ## File: skills/agent-transit/src/agent-transit/samples/claude-code-synthetic.jsonl size: 9011 sha: 413b4b6bbfe8ff04603070f5deb637e73d3cf472 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/agent-transit/samples/claude-code-synthetic.jsonl ```text {"_agentFormat":"claude-code","_comment":"SYNTHETIC hand-built Claude Code JSONL; prompts, outputs, and file contents contain SECRET_CANARY_PROMPT_7731 / SECRET_CANARY_OUTPUT_7731 / SECRET_CANARY_COMMAND_7731."} {"type":"assistant","timestamp":"2026-10-16T12:00:01.000Z","uuid":"u-0","parentUuid":null,"message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-1","name":"Read","input":{"file_path":"src/module-0.mjs"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:02.000Z","uuid":"r-0","parentUuid":"u-0","message":{"content":[{"type":"tool_result","tool_use_id":"cc-1","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:02.000Z","uuid":"u-1","parentUuid":"u-0","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-2","name":"Glob","input":{"pattern":"src/**/*.mjs"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:03.000Z","uuid":"r-1","parentUuid":"u-1","message":{"content":[{"type":"tool_result","tool_use_id":"cc-2","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:03.000Z","uuid":"u-2","parentUuid":"u-1","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-3","name":"Grep","input":{"pattern":"normalize","path":"src"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:04.000Z","uuid":"r-2","parentUuid":"u-2","message":{"content":[{"type":"tool_result","tool_use_id":"cc-3","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:04.000Z","uuid":"u-3","parentUuid":"u-2","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-4","name":"Edit","input":{"file_path":"src/module-3.mjs","content":"SECRET_CANARY_FILE_CONTENT_7731"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:05.000Z","uuid":"r-3","parentUuid":"u-3","message":{"content":[{"type":"tool_result","tool_use_id":"cc-4","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:05.000Z","uuid":"u-4","parentUuid":"u-3","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-5","name":"Write","input":{"file_path":"src/module-4.mjs","content":"SECRET_CANARY_FILE_CONTENT_7731"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:06.000Z","uuid":"r-4","parentUuid":"u-4","message":{"content":[{"type":"tool_result","tool_use_id":"cc-5","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:06.000Z","uuid":"u-5","parentUuid":"u-4","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-6","name":"Bash","input":{"command":"git diff --stat SECRET_CANARY_COMMAND_7731"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:07.000Z","uuid":"r-5","parentUuid":"u-5","message":{"content":[{"type":"tool_result","tool_use_id":"cc-6","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:07.000Z","uuid":"u-6","parentUuid":"u-5","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-7","name":"Read","input":{"file_path":"src/module-6.mjs"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:08.000Z","uuid":"r-6","parentUuid":"u-6","message":{"content":[{"type":"tool_result","tool_use_id":"cc-7","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:08.000Z","uuid":"u-7","parentUuid":"u-6","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-8","name":"Task","input":{"description":"inspect tests"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:09.000Z","uuid":"r-7","parentUuid":"u-7","message":{"content":[{"type":"tool_result","tool_use_id":"cc-8","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:09.000Z","uuid":"u-8","parentUuid":"u-7","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-9","name":"WebSearch","input":{"query":"public API docs"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:10.000Z","uuid":"r-8","parentUuid":"u-8","message":{"content":[{"type":"tool_result","tool_use_id":"cc-9","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:10.000Z","uuid":"u-9","parentUuid":"u-8","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-10","name":"WebFetch","input":{}}]}} {"type":"user","timestamp":"2026-10-16T12:00:11.000Z","uuid":"r-9","parentUuid":"u-9","message":{"content":[{"type":"tool_result","tool_use_id":"cc-10","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:11.000Z","uuid":"u-10","parentUuid":"u-9","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-11","name":"mcp__docs__lookup","input":{}}]}} {"type":"user","timestamp":"2026-10-16T12:00:12.000Z","uuid":"r-10","parentUuid":"u-10","message":{"content":[{"type":"tool_result","tool_use_id":"cc-11","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:12.000Z","uuid":"u-11","parentUuid":"u-10","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-12","name":"MultiEdit","input":{"file_path":"src/module-11.mjs","content":"SECRET_CANARY_FILE_CONTENT_7731"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:13.000Z","uuid":"r-11","parentUuid":"u-11","message":{"content":[{"type":"tool_result","tool_use_id":"cc-12","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:13.000Z","uuid":"u-12","parentUuid":"u-11","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-13","name":"shell","input":{"command":"git diff --stat SECRET_CANARY_COMMAND_7731"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:14.000Z","uuid":"r-12","parentUuid":"u-12","message":{"content":[{"type":"tool_result","tool_use_id":"cc-13","is_error":true,"content":"permission denied SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:14.000Z","uuid":"u-13","parentUuid":"u-12","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-14","name":"Read","input":{"file_path":"src/module-13.mjs"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:15.000Z","uuid":"r-13","parentUuid":"u-13","message":{"content":[{"type":"tool_result","tool_use_id":"cc-14","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:15.000Z","uuid":"u-14","parentUuid":"u-13","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-15","name":"apply_patch","input":{"file_path":"src/module-14.mjs","content":"SECRET_CANARY_FILE_CONTENT_7731"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:16.000Z","uuid":"r-14","parentUuid":"u-14","message":{"content":[{"type":"tool_result","tool_use_id":"cc-15","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:01:01.000Z","uuid":"u-15","parentUuid":"u-14","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-16","name":"Bash","input":{"command":"npm run build SECRET_CANARY_COMMAND_7731"}}]}} {"type":"user","timestamp":"2026-10-16T12:01:05.000Z","uuid":"r-15","parentUuid":"u-15","message":{"content":[{"type":"tool_result","tool_use_id":"cc-16","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:17.000Z","uuid":"u-16","parentUuid":"u-15","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-17","name":"Agent","input":{"description":"inspect tests"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:18.000Z","uuid":"r-16","parentUuid":"u-16","message":{"content":[{"type":"tool_result","tool_use_id":"cc-17","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} {"type":"assistant","timestamp":"2026-10-16T12:00:18.000Z","uuid":"u-17","parentUuid":"u-16","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","id":"cc-18","name":"Write","input":{"file_path":"src/module-17.mjs","content":"SECRET_CANARY_FILE_CONTENT_7731"}}]}} {"type":"user","timestamp":"2026-10-16T12:00:19.000Z","uuid":"r-17","parentUuid":"u-17","message":{"content":[{"type":"tool_result","tool_use_id":"cc-18","is_error":false,"content":"result SECRET_CANARY_OUTPUT_7731"}]}} ``` ## File: skills/agent-transit/src/agent-transit/samples/codex-synthetic.jsonl size: 7313 sha: dfb99279a4392a3f0b1106befcc38f0e67b75ef9 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/agent-transit/samples/codex-synthetic.jsonl ```text {"_agentFormat":"codex","_comment":"SYNTHETIC hand-built Codex rollout JSONL; SECRET_CANARY_PROMPT_7731 SECRET_CANARY_OUTPUT_7731 SECRET_CANARY_COMMAND_7731"} {"timestamp":"2026-10-16T12:00:00.000Z","type":"session_meta","payload":{"id":"synthetic-session"}} {"timestamp":"2026-10-16T12:00:01.000Z","type":"response_item","payload":{"type":"custom_tool_call","call_id":"cx-1","name":"exec","input":"const x = tools.exec_command({ command: 'SECRET_CANARY_COMMAND_7731' });"}} {"timestamp":"2026-10-16T12:00:02.000Z","type":"response_item","payload":{"type":"custom_tool_call_output","call_id":"cx-1","output":[{"type":"input_text","text":"SECRET_CANARY_OUTPUT_7731"}]}} {"timestamp":"2026-10-16T12:00:02.000Z","type":"response_item","payload":{"type":"custom_tool_call","call_id":"cx-2","name":"exec","input":"tools.apply_patch({ patch: 'SECRET_CANARY_FILE_CONTENT_7731' });"}} {"timestamp":"2026-10-16T12:00:03.000Z","type":"response_item","payload":{"type":"custom_tool_call_output","call_id":"cx-2","output":[{"type":"input_text","text":"SECRET_CANARY_OUTPUT_7731"}]}} {"timestamp":"2026-10-16T12:00:03.000Z","type":"response_item","payload":{"type":"custom_tool_call","call_id":"cx-3","name":"exec","input":"tools.update_plan({ plan: 'SECRET_CANARY_PROMPT_7731' });"}} {"timestamp":"2026-10-16T12:00:04.000Z","type":"response_item","payload":{"type":"custom_tool_call_output","call_id":"cx-3","output":[{"type":"input_text","text":"SECRET_CANARY_OUTPUT_7731"}]}} {"timestamp":"2026-10-16T12:00:04.000Z","type":"response_item","payload":{"type":"function_call","call_id":"cx-4","name":"Edit","arguments":"{\"file_path\":\"src/module-3.mjs\",\"content\":\"SECRET_CANARY_FILE_CONTENT_7731\"}"}} {"timestamp":"2026-10-16T12:00:05.000Z","type":"response_item","payload":{"type":"function_call_output","call_id":"cx-4","output":"output SECRET_CANARY_OUTPUT_7731","is_error":false}} {"timestamp":"2026-10-16T12:00:05.000Z","type":"response_item","payload":{"type":"function_call","call_id":"cx-5","name":"Write","arguments":"{\"file_path\":\"src/module-4.mjs\",\"content\":\"SECRET_CANARY_FILE_CONTENT_7731\"}"}} {"timestamp":"2026-10-16T12:00:06.000Z","type":"response_item","payload":{"type":"function_call_output","call_id":"cx-5","output":"output SECRET_CANARY_OUTPUT_7731","is_error":false}} {"timestamp":"2026-10-16T12:00:06.000Z","type":"response_item","payload":{"type":"local_shell_call","call_id":"cx-6","command":"git diff SECRET_CANARY_COMMAND_7731"}} {"timestamp":"2026-10-16T12:00:07.000Z","type":"response_item","payload":{"type":"local_shell_call_output","call_id":"cx-6","output":"output SECRET_CANARY_OUTPUT_7731","is_error":false}} {"timestamp":"2026-10-16T12:00:07.000Z","type":"response_item","payload":{"type":"function_call","call_id":"cx-7","name":"Read","arguments":"{\"file_path\":\"src/module-6.mjs\"}"}} {"timestamp":"2026-10-16T12:00:08.000Z","type":"response_item","payload":{"type":"function_call_output","call_id":"cx-7","output":"output SECRET_CANARY_OUTPUT_7731","is_error":false}} {"timestamp":"2026-10-16T12:00:08.000Z","type":"response_item","payload":{"type":"function_call","call_id":"cx-8","name":"Task","arguments":"{\"description\":\"inspect tests\"}"}} {"timestamp":"2026-10-16T12:00:09.000Z","type":"response_item","payload":{"type":"function_call_output","call_id":"cx-8","output":"output SECRET_CANARY_OUTPUT_7731","is_error":false}} {"timestamp":"2026-10-16T12:00:09.000Z","type":"response_item","payload":{"type":"function_call","call_id":"cx-9","name":"WebSearch","arguments":"{\"query\":\"public API docs\"}"}} {"timestamp":"2026-10-16T12:00:10.000Z","type":"response_item","payload":{"type":"function_call_output","call_id":"cx-9","output":"output SECRET_CANARY_OUTPUT_7731","is_error":false}} {"timestamp":"2026-10-16T12:00:10.000Z","type":"response_item","payload":{"type":"function_call","call_id":"cx-10","name":"WebFetch","arguments":"{}"}} {"timestamp":"2026-10-16T12:00:11.000Z","type":"response_item","payload":{"type":"function_call_output","call_id":"cx-10","output":"output SECRET_CANARY_OUTPUT_7731","is_error":false}} {"timestamp":"2026-10-16T12:00:11.000Z","type":"response_item","payload":{"type":"function_call","call_id":"cx-11","name":"mcp__docs__lookup","arguments":"{}"}} {"timestamp":"2026-10-16T12:00:12.000Z","type":"response_item","payload":{"type":"function_call_output","call_id":"cx-11","output":"output SECRET_CANARY_OUTPUT_7731","is_error":false}} {"timestamp":"2026-10-16T12:00:12.000Z","type":"response_item","payload":{"type":"function_call","call_id":"cx-12","name":"MultiEdit","arguments":"{\"file_path\":\"src/module-11.mjs\",\"content\":\"SECRET_CANARY_FILE_CONTENT_7731\"}"}} {"timestamp":"2026-10-16T12:00:13.000Z","type":"response_item","payload":{"type":"function_call_output","call_id":"cx-12","output":"output SECRET_CANARY_OUTPUT_7731","is_error":false}} {"timestamp":"2026-10-16T12:00:13.000Z","type":"response_item","payload":{"type":"local_shell_call","call_id":"cx-13","command":"git diff SECRET_CANARY_COMMAND_7731"}} {"timestamp":"2026-10-16T12:00:14.000Z","type":"response_item","payload":{"type":"local_shell_call_output","call_id":"cx-13","output":"Permission denied SECRET_CANARY_OUTPUT_7731","is_error":true}} {"timestamp":"2026-10-16T12:00:14.000Z","type":"response_item","payload":{"type":"function_call","call_id":"cx-14","name":"Read","arguments":"{\"file_path\":\"src/module-13.mjs\"}"}} {"timestamp":"2026-10-16T12:00:15.000Z","type":"response_item","payload":{"type":"function_call_output","call_id":"cx-14","output":"output SECRET_CANARY_OUTPUT_7731","is_error":false}} {"timestamp":"2026-10-16T12:00:15.000Z","type":"response_item","payload":{"type":"function_call","call_id":"cx-15","name":"apply_patch","arguments":"{\"file_path\":\"src/module-14.mjs\",\"content\":\"SECRET_CANARY_FILE_CONTENT_7731\"}"}} {"timestamp":"2026-10-16T12:00:16.000Z","type":"response_item","payload":{"type":"function_call_output","call_id":"cx-15","output":"output SECRET_CANARY_OUTPUT_7731","is_error":false}} {"timestamp":"2026-10-16T12:01:01.000Z","type":"response_item","payload":{"type":"local_shell_call","call_id":"cx-16","command":"npm run build SECRET_CANARY_COMMAND_7731"}} {"timestamp":"2026-10-16T12:01:05.000Z","type":"response_item","payload":{"type":"local_shell_call_output","call_id":"cx-16","output":"output SECRET_CANARY_OUTPUT_7731","is_error":false}} {"timestamp":"2026-10-16T12:00:17.000Z","type":"response_item","payload":{"type":"function_call","call_id":"cx-17","name":"Agent","arguments":"{\"description\":\"inspect tests\"}"}} {"timestamp":"2026-10-16T12:00:18.000Z","type":"response_item","payload":{"type":"function_call_output","call_id":"cx-17","output":"output SECRET_CANARY_OUTPUT_7731","is_error":false}} {"timestamp":"2026-10-16T12:00:18.000Z","type":"response_item","payload":{"type":"function_call","call_id":"cx-18","name":"Write","arguments":"{\"file_path\":\"src/module-17.mjs\",\"content\":\"SECRET_CANARY_FILE_CONTENT_7731\"}"}} {"timestamp":"2026-10-16T12:00:19.000Z","type":"response_item","payload":{"type":"function_call_output","call_id":"cx-18","output":"output SECRET_CANARY_OUTPUT_7731","is_error":false}} {"timestamp":"2026-10-16T12:00:25.000Z","type":"mystery_future_line","payload":{}} {"timestamp":"2026-10-16T12:00:26.000Z","type":"mystery_future_line","payload":{}} ``` ## File: skills/agent-transit/src/agent-transit/samples/cursor-bubbles-synthetic.jsonl size: 14276 sha: fc7e0bf77106cabff5dc4f21a9903513bed3fc60 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/agent-transit/samples/cursor-bubbles-synthetic.jsonl Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/agent-transit/samples/cursor-bubbles-synthetic.jsonl ## File: skills/agent-transit/src/agent-transit/samples/cursor-synthetic.jsonl size: 4159 sha: 3d1ec9817daea8ca002f833eb3502e2535a33d8b upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/agent-transit/samples/cursor-synthetic.jsonl ```text {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"Read","input":{"file_path":"src/module-0.mjs","content":"SECRET_CANARY_FILE_CONTENT_7731"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"StrReplace","input":{"file_path":"src/module-1.mjs","content":"SECRET_CANARY_FILE_CONTENT_7731"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"Shell","input":{"command":"git diff SECRET_CANARY_COMMAND_7731"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"TodoWrite","input":{"content":"SECRET_CANARY_FILE_CONTENT_7731"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"Task","input":{"description":"inspect tests"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"WebSearch","input":{"query":"public API docs"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"Glob","input":{"pattern":"src/**/*.mjs"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"Grep","input":{"pattern":"normalize","path":"src"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"Write","input":{"file_path":"src/module-8.mjs","content":"SECRET_CANARY_FILE_CONTENT_7731"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"Delete","input":{"file_path":"src/module-9.mjs"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"SemanticSearch","input":{"query":"normalize"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"ReadLints","input":{"file_path":"src/module-11.mjs"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"EditNotebook","input":{"file_path":"src/notebook.ipynb","content":"SECRET_CANARY_FILE_CONTENT_7731"}}]}} {"type":"turn_ended","status":"error","error":"SECRET_CANARY_OUTPUT_7731"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"WebFetch","input":{"url":"https://example.test"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"Shell","input":{"command":"npm run build SECRET_CANARY_COMMAND_7731"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"Read","input":{"file_path":"src/module-15.mjs"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"StrReplace","input":{"file_path":"src/module-16.mjs","content":"SECRET_CANARY_FILE_CONTENT_7731"}}]}} {"type":"turn_ended","status":"success"} {"role":"assistant","message":{"content":[{"type":"text","text":"SECRET_CANARY_PROMPT_7731"},{"type":"tool_use","name":"Task","input":{"description":"inspect tests"}}]}} {"type":"turn_ended","status":"success"} ``` ## File: skills/agent-transit/src/agent-transit/samples/make-agent-samples.mjs size: 4449 sha: a4896d579b5365c610fbc7de4fcadd8f5c164b6e upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/agent-transit/samples/make-agent-samples.mjs ```text import { mkdirSync, writeFileSync } from 'node:fs'; import { dirname, join } from 'node:path'; import { fileURLToPath } from 'node:url'; const here = dirname(fileURLToPath(import.meta.url)); const iso = (n) => new Date(Date.UTC(2026, 9, 16, 12, 0, n)).toISOString(); const tools = ['Read', 'Glob', 'Grep', 'Edit', 'Write', 'Bash', 'Read', 'Task', 'WebSearch', 'WebFetch', 'mcp__docs__lookup', 'MultiEdit', 'shell', 'Read', 'apply_patch', 'Bash', 'Agent', 'Write']; const args = (name, i) => name === 'Bash' || name === 'shell' ? { command: `${i === 15 ? 'npm run build' : 'git diff --stat'} SECRET_CANARY_COMMAND_7731` } : name === 'Task' || name === 'Agent' ? { description: 'inspect tests' } : name === 'WebSearch' ? { query: 'public API docs' } : name === 'Glob' ? { pattern: 'src/**/*.mjs' } : name === 'Grep' ? { pattern: 'normalize', path: 'src' } : name === 'Read' ? { file_path: `src/module-${i}.mjs` } : name === 'Write' || name === 'Edit' || name === 'MultiEdit' || name === 'apply_patch' ? { file_path: `src/module-${i}.mjs`, content: 'SECRET_CANARY_FILE_CONTENT_7731' } : {}; function claude() { const out = [{ _agentFormat: 'claude-code', _comment: 'SYNTHETIC hand-built Claude Code JSONL; prompts, outputs, and file contents contain SECRET_CANARY_PROMPT_7731 / SECRET_CANARY_OUTPUT_7731 / SECRET_CANARY_COMMAND_7731.' }]; tools.forEach((name, i) => { const id = `cc-${i + 1}`; const t = 1 + i * (i === 15 ? 4 : 1); out.push({ type: 'assistant', timestamp: iso(t), uuid: `u-${i}`, parentUuid: i ? `u-${i - 1}` : null, message: { content: [{ type: 'text', text: 'SECRET_CANARY_PROMPT_7731' }, { type: 'tool_use', id, name, input: args(name, i) }] } }); out.push({ type: 'user', timestamp: iso(t + (i === 15 ? 4 : 1)), uuid: `r-${i}`, parentUuid: `u-${i}`, message: { content: [{ type: 'tool_result', tool_use_id: id, is_error: i === 12, content: i === 12 ? 'permission denied SECRET_CANARY_OUTPUT_7731' : 'result SECRET_CANARY_OUTPUT_7731' }] } }); }); return out; } function cursor() { const names = ['Read', 'StrReplace', 'Shell', 'TodoWrite', 'Task', 'WebSearch', 'Glob', 'Grep', 'Write', 'Delete', 'SemanticSearch', 'ReadLints', 'EditNotebook', 'WebFetch', 'Shell', 'Read', 'StrReplace', 'Task']; const out = []; names.forEach((name, i) => { out.push({ role: 'assistant', message: { content: [{ type: 'text', text: 'SECRET_CANARY_PROMPT_7731' }, { type: 'tool_use', name, input: { file_path: `src/module-${i}.mjs`, command: `${i === 14 ? 'npm run build' : 'git diff'} SECRET_CANARY_COMMAND_7731`, content: 'SECRET_CANARY_FILE_CONTENT_7731' } }] } }); out.push({ type: 'turn_ended', status: i === 12 ? 'error' : 'success', ...(i === 12 ? { error: 'SECRET_CANARY_OUTPUT_7731' } : {}) }); }); return out; } function codex() { const out = [{ _agentFormat: 'codex', _comment: 'SYNTHETIC hand-built Codex rollout JSONL; SECRET_CANARY_PROMPT_7731 SECRET_CANARY_OUTPUT_7731 SECRET_CANARY_COMMAND_7731' }, { timestamp: iso(0), type: 'session_meta', payload: { id: 'synthetic-session' } }]; tools.forEach((name, i) => { const id = `cx-${i + 1}`; const t = 1 + i * (i === 15 ? 4 : 1); const wrapped = i < 3; const inner = ['exec_command', 'apply_patch', 'update_plan'][i]; const payload = wrapped ? { type: 'custom_tool_call', call_id: id, name: 'exec', input: `tools.${inner}({ value: 'SECRET_CANARY_COMMAND_7731' });` } : name === 'Bash' || name === 'shell' ? { type: 'local_shell_call', call_id: id, command: `${i === 15 ? 'npm run build' : 'git diff'} SECRET_CANARY_COMMAND_7731` } : { type: 'function_call', call_id: id, name, arguments: JSON.stringify(args(name, i)) }; out.push({ timestamp: iso(t), type: 'response_item', payload }); out.push({ timestamp: iso(t + (i === 15 ? 4 : 1)), type: 'response_item', payload: { type: wrapped ? 'custom_tool_call_output' : name === 'Bash' || name === 'shell' ? 'local_shell_call_output' : 'function_call_output', call_id: id, output: wrapped ? [{ type: 'input_text', text: 'SECRET_CANARY_OUTPUT_7731' }] : i === 12 ? 'Permission denied SECRET_CANARY_OUTPUT_7731' : 'output SECRET_CANARY_OUTPUT_7731', is_error: i === 12 } }); }); out.push({ timestamp: iso(25), type: 'mystery_future_line', payload: {} }); return out; } mkdirSync(here, { recursive: true }); for (const [name, data] of [['claude-code', claude()], ['codex', codex()], ['cursor', cursor()]]) writeFileSync(join(here, `${name}-synthetic.jsonl`), data.map((x) => JSON.stringify(x)).join('\n') + '\n'); ``` ## File: skills/agent-transit/src/agent-transit/scripts/export-cursor.mjs size: 9355 sha: bbffe73bc6b47fa95411bf05ec4c04a6bba6831a upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/agent-transit/scripts/export-cursor.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/agent-transit/scripts/export-cursor.mjs ## File: skills/agent-transit/src/agent-transit/scripts/find-session.mjs size: 2646 sha: e1d3fac2435e87106e88044ce9c7c06baecb622d upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/agent-transit/scripts/find-session.mjs ```text import { readdirSync, readFileSync, statSync } from 'node:fs'; import { homedir } from 'node:os'; import { join, resolve } from 'node:path'; const source = process.argv[process.argv.indexOf('--source') + 1]; if (!['claude-code', 'codex', 'cursor'].includes(source)) throw new Error('usage: node find-session.mjs --source claude-code|codex|cursor'); const cwd = resolve(process.cwd()), home = homedir(); const newest = (items) => items.sort((a, b) => b.mtime - a.mtime)[0]; const mtime = (path) => { try { return statSync(path).mtimeMs; } catch { return 0; } }; const entries = (dir) => { try { return readdirSync(dir, { withFileTypes: true }); } catch { return []; } }; if (source === 'cursor') { const root = join(home, '.cursor', 'projects'), matches = []; for (const project of entries(root)) { if (!project.isDirectory()) continue; const transcripts = join(root, project.name, 'agent-transcripts'); for (const session of entries(transcripts)) { if (!session.isDirectory()) continue; const path = join(transcripts, session.name, `${session.name}.jsonl`); try { if (statSync(path).isFile()) matches.push({ path, mtime: mtime(path) }); } catch {} } } const match = newest(matches); if (match) console.log(match.path); else console.error('no Cursor agent-transcripts found; Cursor keeps chats in its state.vscdb instead. Export one (metadata only): node <skill>/scripts/export-cursor.mjs --list, then --composer ID'); } else if (source === 'codex') { const root = join(home, '.codex', 'sessions'), matches = []; const walk = (dir) => { for (const entry of entries(dir)) { const path = join(dir, entry.name); if (entry.isDirectory()) walk(path); else if (entry.isFile() && entry.name.endsWith('.jsonl')) { try { const first = readFileSync(path, 'utf8').split(/\r?\n/, 1)[0]; const line = JSON.parse(first); if (line.type === 'session_meta' && (line.payload?.cwd || line.cwd) === cwd) matches.push({ path, mtime: mtime(path) }); } catch {} } } }; walk(root); const match = newest(matches); if (match) console.log(match.path); } else { const root = join(home, '.claude', 'projects'), encoded = cwd.replaceAll('/', '-'), matches = []; const walk = (dir) => { for (const entry of entries(dir)) { const path = join(dir, entry.name); if (entry.isDirectory()) walk(path); else if (entry.isFile() && entry.name.endsWith('.jsonl') && path.includes(encoded)) matches.push({ path, mtime: mtime(path) }); } }; walk(root); const match = newest(matches); if (match) console.log(match.path); } ``` ## File: skills/agent-transit/src/ci-transit/adapters/normalize-gh.mjs size: 7073 sha: 4c87b1a441ff458d6efcc5a66e491a23c38d15bf upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/ci-transit/adapters/normalize-gh.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/ci-transit/adapters/normalize-gh.mjs ## File: skills/agent-transit/src/request-transit/adapters/fetch-datadog-api.mjs size: 2699 sha: ea5b1f6533bf3b73adc0e0fc39e459fb41b09858 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/adapters/fetch-datadog-api.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/adapters/fetch-datadog-api.mjs ## File: skills/agent-transit/src/request-transit/adapters/fetch-posthog-api.mjs size: 4001 sha: 76c8ca090c4e395cf13636eaf9591204bd1cf629 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/adapters/fetch-posthog-api.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/adapters/fetch-posthog-api.mjs ## File: skills/agent-transit/src/request-transit/adapters/fetch-tempo.mjs size: 4826 sha: 7a0bef04c864e51eb1b5617db0132efc7c433e7d upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/adapters/fetch-tempo.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/adapters/fetch-tempo.mjs ## File: skills/agent-transit/src/request-transit/adapters/fetch-xray.mjs size: 3287 sha: dfcac55469d95075162034e15a1b871413fbbc2f upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/adapters/fetch-xray.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/adapters/fetch-xray.mjs ## File: skills/agent-transit/src/request-transit/adapters/normalize.mjs size: 30455 sha: b78a5ad116e1afe9fb530a3161c4359e4b6e3d8a upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/adapters/normalize.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/adapters/normalize.mjs ## File: skills/agent-transit/src/request-transit/contracts/extractors/class-validator.mjs size: 2768 sha: ce2e7e4df98f5a3dee5a3dfaaafeb1a9ee41fbcc upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/class-validator.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/class-validator.mjs ## File: skills/agent-transit/src/request-transit/contracts/extractors/express.mjs size: 2370 sha: 02bdefe5cab50458302c49e7fdc910b4a91c1680 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/express.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/express.mjs ## File: skills/agent-transit/src/request-transit/contracts/extractors/index.mjs size: 729 sha: 9e72323e29d5f13033059bdff710398b31666b00 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/index.mjs ```text // Extractor registry. Add one by exporting {name, kind, test(src, file), symbols?(src), routes?(src)} and // listing it here. symbols() returns named shapes; routes() returns http/rpc/topic entries that point at them. import zod from './zod.mjs'; import joi from './joi.mjs'; import classValidator from './class-validator.mjs'; import tsTypes from './ts-types.mjs'; import express from './express.mjs'; import nest from './nest.mjs'; import topicProducer from './topic-producer.mjs'; import openapi from './openapi.mjs'; import protobuf from './protobuf.mjs'; export const EXTRACTORS = [zod, joi, classValidator, tsTypes, express, nest, topicProducer, openapi, protobuf]; export const EXTRACTOR_VERSION = 'transit-contracts-2'; ``` ## File: skills/agent-transit/src/request-transit/contracts/extractors/joi.mjs size: 2539 sha: 837b52093cf8c36959ffa381447eb6c8f1322dd3 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/joi.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/joi.mjs ## File: skills/agent-transit/src/request-transit/contracts/extractors/nest.mjs size: 3615 sha: c261bf4d5f635b77f7f299ac48c42953dbfe2ed3 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/nest.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/nest.mjs ## File: skills/agent-transit/src/request-transit/contracts/extractors/openapi.mjs size: 2806 sha: 31b21363b8fa8f41e1448ecfc3bb92227790285b upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/openapi.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/openapi.mjs ## File: skills/agent-transit/src/request-transit/contracts/extractors/protobuf.mjs size: 4523 sha: 6bf35f6ea60c881e11aa02cf54c279e7c7412cb8 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/protobuf.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/protobuf.mjs ## File: skills/agent-transit/src/request-transit/contracts/extractors/topic-producer.mjs size: 998 sha: c8c7b3acfe39512e5477259abfb6efcd496f423e upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/topic-producer.mjs ```text // Message producers: <client>.emit('topic', payload satisfies T) or publish<T>('topic', ...). // Gives the topic's shape so consumers without their own schema can fall back to it. import { closeOf, lineOf } from '../text.mjs'; export default { name: 'topic-producer', kind: 'route', test: (src) => /\.(emit|publish|send)\s*(<[^>]*>)?\(\s*['"`]/.test(src), routes(src) { const out = []; for (const m of src.matchAll(/\.(?:emit|publish|send)\s*(?:<\s*([\w$]+)\s*>)?\(\s*['"`]([\w.-]+)['"`]/g)) { const open = m.index + m[0].indexOf('('), args = src.slice(open, closeOf(src, open) + 1); const sat = args.match(/\bsatisfies\s+([\w$]+)/) || args.match(/\bas\s+([\w$]+)\s*\)/); const symbol = m[1] || (sat && sat[1]); if (!symbol) continue; out.push({ kind: 'topic', topic: m[2], role: 'producer', line: lineOf(src, m.index), request: { symbol, via: m[1] ? 'publish<T>' : 'satisfies' }, response: null, framework: 'producer' }); } return out; }, }; ``` ## File: skills/agent-transit/src/request-transit/contracts/extractors/ts-types.mjs size: 1278 sha: e71fe1fe6c183c2a539bb7f454686cf7da4d7839 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/ts-types.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/ts-types.mjs ## File: skills/agent-transit/src/request-transit/contracts/extractors/zod.mjs size: 3301 sha: c7d0ba285d09f2d3e2491b6e330911747bb9991f upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/zod.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/extractors/zod.mjs ## File: skills/agent-transit/src/request-transit/contracts/indexer.mjs size: 13769 sha: 11e06885f806a3aa7ce5f3a4dfffed9379082599 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/indexer.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/indexer.mjs ## File: skills/agent-transit/src/request-transit/contracts/match.mjs size: 4933 sha: 5af244c670fd5b19184f862c30be002f5afb2b7e upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/match.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/match.mjs ## File: skills/agent-transit/src/request-transit/contracts/schema.mjs size: 3395 sha: 3a93c6e1fc8064c617e99b37922b3ba8c7bbe00c upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/schema.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/schema.mjs ## File: skills/agent-transit/src/request-transit/contracts/text.mjs size: 3579 sha: 2934e7f69dafe70f7f2ab4533c2ac937a7bf1292 upstream: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/text.mjs Content is not inlined in the catalog. Read the upstream file: https://github.com/israelvicars/transit/blob/main/skills/agent-transit/src/request-transit/contracts/text.mjs