CMDCGateway.EventTranslator (cmdc_gateway v0.6.0)

内部 CMDC.Event.t() → 对外 JSON schema 翻译层。

字段命名统一 camelCase。SDK 和前端消费此格式。

对外事件列表

事件类型	说明
`rag_retrieved`	RAG/GraphRAG 检索摘要
`rag_answered`	RAG/Pipeline answer 摘要
`rag_citation_used`	citation provenance
`rag_pipeline_step`	pipeline step timeline
`rag_ingestion_progress`	ingestion 进度
`rag_reembed_progress`	reembed 进度
`rag_graph_progress`	GraphRAG maintenance/search 进度
`rag_graph_audit`	GraphRAG 只读查询审计
`rag_eval_progress`	RAG Eval / release gate 进度

事件类型	说明
`error`	运行时错误

heartbeat()

心跳 SSE 注释行，保持连接。

将翻译后的事件编码为 SSE 格式字符串（含 event: 和 data: 行）。

translate(arg1)

将内部事件翻译为对外 JSON map。

带模式选项的事件翻译。

将 EventBus 事件投影为 AuditEvent JSON 事件。

@spec heartbeat() :: iodata()

心跳 SSE 注释行，保持连接。

@spec to_sse(String.t(), map()) :: iodata()

将翻译后的事件编码为 SSE 格式字符串（含 event: 和 data: 行）。

@spec translate(CMDC.Event.t()) :: {:ok, String.t(), map()} | :skip

将内部事件翻译为对外 JSON map。

返回 {:ok, event_type, json_map} 或 :skip（不对外暴露的事件）。

@spec translate(
  CMDC.Event.t(),
  keyword()
) :: {:ok, String.t(), map()} | :skip

带模式选项的事件翻译。

支持 mode: :audit 输出 canonical audit 投影；默认与 translate/1 完全一致。

@spec translate_audit(
  CMDC.Event.t(),
  keyword()
) :: {:ok, String.t(), map()} | :skip

将 EventBus 事件投影为 AuditEvent JSON 事件。

未被 core CMDC.AuditEvent.from_event/3 覆盖的低价值事件返回 :skip。