source/teaql-ts/src/core/sql-diagnostic-event.ts

import type { RuntimeDiagnosticEvent, RuntimeExecutionCorrelation } from './telemetry';
import type { SQLExecutionMetadata } from '../sql/core';

/** Does not spread metadata, parameters, rows, audit payloads or entity IDs. */
export function sqlDiagnosticEvent(metadata: SQLExecutionMetadata,
  correlation?: RuntimeExecutionCorrelation): RuntimeDiagnosticEvent {
  if (metadata.logMode !== 'masked') throw new Error('Telemetry requires safe SQL projection');
  const nodes = (frames: readonly { kind: string; name: string; detail?: string }[] = []) =>
    JSON.stringify(frames.map(frame => ({ kind: frame.kind, name: frame.name, detail: frame.detail ?? '' })));
  return Object.freeze({ body: 'TeaQL SQL execution', correlation,
    attributes: Object.freeze({
      'teaql.trace_chain': nodes(metadata.traceChain),
      'teaql.trace_path': nodes(metadata.tracePath),
      'teaql.mutation_lineage': nodes(metadata.mutationLineage),
      'teaql.intent.comment': metadata.comment ?? metadata.auditReason ?? '',
      'teaql.intent.purpose': metadata.purpose ?? '',
      'teaql.sql.debug': metadata.debugSQL,
      'teaql.sql.log_mode': metadata.logMode,
      'teaql.sql.operation': metadata.operation,
      'teaql.sql.outcome': metadata.executionOutcome ?? 'unknown',
      'teaql.sql.elapsed_us': metadata.elapsedMicros,
      ...(metadata.resultCount === undefined ? {} : { 'teaql.sql.result_count': metadata.resultCount }),
      ...(metadata.affectedRows === undefined ? {} : { 'teaql.sql.affected_rows': metadata.affectedRows }),
    }) });
}