Struct LiveTranscriptIdentity 

pub struct LiveTranscriptIdentity<'a> {
    pub provider_item_id: Option<&'a str>,
    pub previous_item_id: Option<&'a str>,
    pub content_index: Option<u32>,
    pub response_id: Option<&'a str>,
    pub delta_id: Option<&'a str>,
}

Runtime-side projection sink consumed by LiveAdapterHost.

This is the seam through which adapter observations become canonical Meerkat semantic facts. Surfaces (RPC/REST/WASM) provide an implementation that bridges into meerkat_core::SessionService / EventInjector / observer streams. Tests use [RecordingProjectionSink] (in this module’s #[cfg(test)] block) to assert routing decisions deterministically. Provider-side identity carried alongside a transcript fragment.

All fields are Option<&str> / Option<u32> because the underlying LiveAdapterObservation variants emit them as #[serde(default, skip_serializing_if = "Option::is_none")] per A11. Bundling them in one struct keeps sink trait signatures readable and lets sink implementations pattern-match the fields they care about without the call sites passing six separate arguments.

Variants:

• UserTranscriptFinal carries provider_item_id, previous_item_id, content_index (no response_id / delta_id — those are assistant-only).
• AssistantTextDelta carries the full set including response_id and delta_id.
• AssistantTranscriptFinal carries provider_item_id (always present), previous_item_id, content_index, response_id (no delta_id — a final is not a delta).

Fields

provider_item_id: Option<&'a str>

previous_item_id: Option<&'a str>

content_index: Option<u32>

response_id: Option<&'a str>

delta_id: Option<&'a str>

Implementations

impl<'a> LiveTranscriptIdentity<'a>

pub fn user( provider_item_id: Option<&'a str>, previous_item_id: Option<&'a str>, content_index: Option<u32>, ) -> Self

Build identity for a user-side observation (response/delta IDs are always None on the user side).

pub fn assistant_delta( provider_item_id: Option<&'a str>, previous_item_id: Option<&'a str>, content_index: Option<u32>, response_id: Option<&'a str>, delta_id: Option<&'a str>, ) -> Self

Build identity for a streaming assistant delta (full set carried).

pub fn assistant_final( provider_item_id: &'a str, previous_item_id: Option<&'a str>, content_index: Option<u32>, response_id: Option<&'a str>, ) -> Self

Build identity for an assistant final (no delta_id, but everything else is meaningful and provider_item_id is required upstream).

pub fn require_delta_identity( &self, ) -> Result<DeltaIdentity<'a>, LiveTranscriptIdentityError>

Resolve the required identity triple for an assistant delta event (D199): response_id, delta_id, and item_id (provider item id).

The sink previously coalesced each missing id to an empty string via unwrap_or_default(), emitting an RealtimeTranscriptEvent whose identity was empty-string truth — a delta that cannot be bound back to any response/item. This accessor fails closed: a missing required id yields a typed LiveTranscriptIdentityError naming the absent field, so the projection rejects the malformed delta rather than fabricating empty identity.

Trait Implementations

impl<'a> Clone for LiveTranscriptIdentity<'a>

fn clone(&self) -> LiveTranscriptIdentity<'a>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a> Copy for LiveTranscriptIdentity<'a>

impl<'a> Debug for LiveTranscriptIdentity<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a> Default for LiveTranscriptIdentity<'a>

fn default() -> LiveTranscriptIdentity<'a>

Returns the “default value” for a type.

impl<'a> Eq for LiveTranscriptIdentity<'a>

impl<'a> PartialEq for LiveTranscriptIdentity<'a>

fn eq(&self, other: &LiveTranscriptIdentity<'a>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<'a> StructuralPartialEq for LiveTranscriptIdentity<'a>