#!/usr/bin/env node import { randomUUID } from "node:crypto"; import { hostname } from "node:os"; const INGEST_URL = process.env.AGENTMON_INGEST_URL || "http://localhost:8080"; const FRAMEWORK = process.env.AGENTMON_FRAMEWORK || "codex"; const HOST = process.env.AGENTMON_HOST || hostname(); const BATCH_SIZE = 10; const FLUSH_MS = 2e3; const FETCH_TIMEOUT_MS = 500; let buffer = []; let flushTimer = null; let isFlushing = false; const activeRuns = /* @__PURE__ */ new Map(); function isRecord(value) { return value !== null && typeof value === "object" && !Array.isArray(value); } function pickString(...values) { for (const value of values) { if (typeof value === "string" && value.trim() !== "") { return value; } } return void 0; } function pickNumber(...values) { for (const value of values) { if (typeof value === "number" && Number.isFinite(value)) { return value; } } return void 0; } function truncate(value, limit) { if (value === void 0 || value === null) { return void 0; } const text = typeof value === "string" ? value : safeJSONStringify(value); if (!text) { return void 0; } if (text.length <= limit) { return text; } return text.slice(0, limit) + "..."; } function safeJSONStringify(value) { try { return JSON.stringify(value); } catch { return String(value); } } function getSessionKey(input) { return pickString( input.id, input.session, input.sessionId, input.session_id, input.threadId, input.thread_id, input.chatId, input.chat_id, input.conversationId, input.conversation_id ); } function getUsage(input) { const usage = isRecord(input.usage) ? input.usage : isRecord(input.llm) ? input.llm : isRecord(input.tokens) ? input.tokens : isRecord(input.llm_usage) ? input.llm_usage : void 0; if (!usage) return void 0; const result = {}; if (usage.input_tokens !== void 0) result.input_tokens = usage.input_tokens; if (usage.prompt_tokens !== void 0) result.input_tokens = usage.prompt_tokens; if (usage.input !== void 0) result.input_tokens = usage.input; if (usage.output_tokens !== void 0) result.output_tokens = usage.output_tokens; if (usage.completion_tokens !== void 0) result.output_tokens = usage.completion_tokens; if (usage.output !== void 0) result.output_tokens = usage.output; if (usage.total_tokens !== void 0) result.total_tokens = usage.total_tokens; if (usage.total !== void 0) result.total_tokens = usage.total; if (usage.cost !== void 0) result.total_cost = usage.cost; if (usage.total_cost !== void 0) result.total_cost = usage.total_cost; return Object.keys(result).length > 0 ? result : void 0; } function getModel(input) { return pickString( input.model, isRecord(input.llm) ? input.llm.model : void 0, isRecord(input.usage) ? input.usage.model : void 0 ); } function buildEnvelope(type, sessionKey, opts = {}) { const correlation = {}; if (sessionKey) { correlation.session_id = sessionKey; } if (opts.runId) { correlation.run_id = opts.runId; } if (opts.spanId) { correlation.span_id = opts.spanId; } if (opts.parentSpanId) { correlation.parent_span_id = opts.parentSpanId; } const envelope = { schema: { name: "agentmon.event", version: 1 }, event: { id: randomUUID(), type, ts: (/* @__PURE__ */ new Date()).toISOString(), source: { framework: FRAMEWORK, client_id: HOST, host: HOST } } }; if (Object.keys(correlation).length > 0) { envelope.correlation = correlation; } if (opts.attributes && Object.keys(opts.attributes).length > 0) { envelope.attributes = opts.attributes; } if (opts.payload && Object.keys(opts.payload).length > 0) { envelope.payload = opts.payload; } return envelope; } function scheduleFlush() { if (!flushTimer) { flushTimer = setTimeout(() => { void flush(); }, FLUSH_MS); } } function enqueue(event) { buffer.push(event); if (buffer.length >= BATCH_SIZE) { void flush(); } else { scheduleFlush(); } } function enqueueMetricSnapshot(sessionKey, runId, usage, input) { if (!usage) { return; } const metrics = { usage }; const model = getModel(input); if (model) { metrics.model = model; } enqueue(buildEnvelope("metric.snapshot", sessionKey, { runId, payload: { metrics } })); } function startRun(sessionKey, input) { const runId = randomUUID(); if (sessionKey) { activeRuns.set(sessionKey, runId); } enqueue(buildEnvelope("run.start", sessionKey, { runId, attributes: { trigger: pickString(input.trigger_type, input.trigger, input.event, input.event_type) }, payload: { prompt_preview: truncate(pickString(input.prompt, input.message, input.text), 200) } })); return runId; } function endRun(sessionKey, runId, input, duration) { if (!runId) { return; } const usage = getUsage(input); enqueue(buildEnvelope("run.end", sessionKey, { runId, payload: { status: "success", duration_ms: duration, model: getModel(input), ...usage && { usage } } })); enqueueMetricSnapshot(sessionKey, runId, usage, input); } async function postBatch(batch) { const controller = new AbortController(); const timeout = setTimeout(() => controller.abort(), FETCH_TIMEOUT_MS); try { await fetch(`${INGEST_URL}/v1/events`, { method: "POST", headers: { "Content-Type": "application/json" }, body: JSON.stringify(batch), signal: controller.signal }); } finally { clearTimeout(timeout); } } async function flush() { if (flushTimer) { clearTimeout(flushTimer); flushTimer = null; } if (isFlushing || buffer.length === 0) { return; } isFlushing = true; const batch = buffer.splice(0, BATCH_SIZE); try { await postBatch(batch); } catch { console.debug(`[agentmon] failed to flush ${batch.length} events`); } finally { isFlushing = false; if (buffer.length > 0) { if (buffer.length >= BATCH_SIZE) { void flush(); } else { scheduleFlush(); } } } } async function handleSessionStart(input) { const sessionKey = getSessionKey(input) || randomUUID(); enqueue(buildEnvelope("session.start", sessionKey)); startRun(sessionKey, input); await flush(); } async function handleSessionEnd(input) { const sessionKey = getSessionKey(input); const runId = sessionKey ? activeRuns.get(sessionKey) : void 0; const usage = getUsage(input); const duration = pickNumber(input.duration_ms, input.elapsed_ms, input.duration); endRun(sessionKey, runId, input, duration); enqueue(buildEnvelope("session.end", sessionKey, { payload: { model: getModel(input), ...usage && { usage } } })); enqueueMetricSnapshot(sessionKey, runId, usage, input); activeRuns.delete(sessionKey || ""); await flush(); } async function handlePromptSubmit(input) { const sessionKey = getSessionKey(input); const runId = sessionKey ? activeRuns.get(sessionKey) : void 0; const duration = pickNumber(input.elapsed_ms, input.duration_ms, input.duration); const prompt = pickString(input.prompt, input.text, input.message); if (runId && prompt) { endRun(sessionKey, runId, input, duration); } startRun(sessionKey, input); await flush(); } async function handleNotification(input) { const sessionKey = getSessionKey(input); const notificationType = pickString(input.type, input.notification_type, input.event, input.event_type); const usage = getUsage(input); const duration = pickNumber(input.duration_ms, input.elapsed_ms); if (notificationType === "agent-turn-complete" || notificationType === "Done" || notificationType === "turn.complete") { const runId = sessionKey ? activeRuns.get(sessionKey) : void 0; endRun(sessionKey, runId, input, duration); if (pickString(input.prompt, input.message, input.text)) { startRun(sessionKey, input); } } else if (usage) { enqueueMetricSnapshot(sessionKey, sessionKey ? activeRuns.get(sessionKey) : void 0, usage, input); } await flush(); } const handler = async () => { const args = process.argv.slice(2); const hookType = args[0] || "unknown"; let input = {}; try { const stdin = await readStdin(); if (stdin) { input = JSON.parse(stdin); } } catch { input = {}; } try { switch (hookType) { case "start": await handleSessionStart(input); break; case "stop": await handleSessionEnd(input); break; case "prompt": case "prompt-submit": await handlePromptSubmit(input); break; case "notification": await handleNotification(input); break; default: console.debug(`[agentmon] unknown hook type: ${hookType}`); } } catch (err) { console.debug("[agentmon] handler error:", err); } }; async function readStdin() { return new Promise((resolve) => { let data = ""; process.stdin.on("data", (chunk) => data += chunk); process.stdin.on("end", () => resolve(data)); process.stdin.on("error", () => resolve("")); setTimeout(() => resolve(data), 100); }); } handler();