Struct TranscriptWriter 

pub struct TranscriptWriter { /* private fields */ }

Implementations

impl TranscriptWriter

pub fn new(root: impl Into<PathBuf>, agent_id: impl Into<String>) -> Self

pub fn with_tenant_id(self, tenant_id: Option<String>) -> Self

Tag the writer with its owning tenant so every emitted TranscriptAppended event carries tenant_id. Boot wire reads agent.tenant_id and threads it through. None is the legacy / single-tenant case (default).

pub fn with_extras( root: impl Into<PathBuf>, agent_id: impl Into<String>, redactor: Arc<Redactor>, index: Option<Arc<TranscriptsIndex>>, ) -> Self

Wrap the writer with a redactor and/or FTS index. Both are optional — Redactor::disabled() and None reproduce the behavior of Self::new.

pub fn with_emitter(self, emitter: Arc<dyn AgentEventEmitter>) -> Self

Install a firehose emitter. Replaces the default NoopAgentEventEmitter. Call AFTER with_extras (or use the standalone factory from boot wiring).

pub fn root(&self) -> &Path

pub fn agent_id(&self) -> &str

Owning agent id this writer was pinned to at construction. The TranscriptWriterAppender adapter (in nexo-setup) uses it for a defense-in-depth check that operator stamps cannot cross into a different agent’s transcript via the shared writer instance.

pub async fn append_entry( &self, session_id: Uuid, entry: TranscriptEntry, ) -> Result<()>

Append one entry to the session transcript. Writes a header first if the file doesn’t exist yet. When a redactor is active, the entry’s content is rewritten before any persistence path sees it. When an FTS index is wired, the (possibly redacted) content is also inserted best-effort — JSONL stays the source of truth.

pub async fn read_session( &self, session_id: Uuid, ) -> Result<Vec<TranscriptLine>>

Read every line of a session transcript back into memory. Unknown lines are skipped so the reader is forward-compatible with future line variants.