Function writeSpan

src/compiled/cognition/traces.js:146–183

* Persist a cognition span. Never throws — failures are logged and counted. * The span_id is generated here so callers don't have to reach for randomUUID.

(init)

 * The span_id is generated here so callers don't have to reach for randomUUID.
 */
async function writeSpan(init) {
    const now = Date.now();
    const span = {
        span_id: (0, crypto_1.randomUUID)(),
        trace_id: init.trace_id,
        parent_span_id: init.parent_span_id ?? null,
        workflow: init.workflow,
        step: init.step,
        kind: init.kind,
        prompt: init.prompt ?? null,
        model: init.model ?? null,
        provider: init.provider ?? null,
        input_redacted: init.input === undefined ? null : redactValue(init.input, init.input_entity_hint),
        output_redacted: init.output === undefined ? null : redactValue(init.output, init.output_entity_hint),
        validate_result: init.validate_result ?? null,
        confidence: init.confidence ?? null,
        prompt_tokens: init.prompt_tokens ?? null,
        completion_tokens: init.completion_tokens ?? null,
        cost_usd: init.cost_usd ?? null,
        latency_ms: init.latency_ms,
        cache_hit: init.cache_hit ?? false,
        status: init.status,
        error_code: init.error_code ?? null,
        metadata: init.metadata ?? {},
        started_at: now - init.latency_ms,
        finished_at: now,
    };
    try {
        await __backend.write(span);
        (0, metrics_1.counter)("cognition.span_written", { kind: init.kind, status: init.status });
    }
    catch (e) {
        (0, metrics_1.counter)("cognition.span_write_failed");
        const msg = e instanceof Error ? e.message : String(e);
        logger_1.logger.warn("cognition_span_write_failed", { event: "traces", status: "rejected", trace_id: span.trace_id, metadata: { error: msg.slice(0, 256) } });
    }
    return span.span_id;
}
/** Load all spans for a trace, sorted by start time. */
async function loadTrace(trace_id) {
    return __backend.loadTrace(trace_id);