Method emit_session_node

atomic-core/src/pristine/txn/write/session_kg.rs:300–327

Upsert the session node with its current lifecycle metadata.

(&mut self, record: &SessionRecord)

    /// Upsert the session node with its current lifecycle metadata.
    pub(crate) fn emit_session_node(&mut self, record: &SessionRecord) -> PristineResult<()> {
        let node = KgNode::new(
            session_node_id(&record.session_id),
            "session",
            &record.session_id,
            "session_ledger",
        )
        .with_metadata(serde_json::json!({
            "rdf_type": entity_type::SESSION,
            "view": record.view_name,
            "parent_view": record.parent_view,
            "status": if record.ended_at.is_some() { "ended" } else { "active" },
            "turn_count": record.turn_count,
            "json_path": record.json_path,
        }));
        self.upsert_kg_node(&node)?;

        // session ON_VIEW view — shares the enrichment's view vocabulary so
        // `neighbors view:X` surfaces sessions alongside changes and files.
        if let Some(view) = &record.view_name {
            self.upsert_kg_edge(&KgEdge::new(
                session_node_id(&record.session_id),
                format!("view:{}", view),
                edge_kind::ON_VIEW,
            ))?;
        }
        Ok(())
    }

    /// Emit one turn row's nodes and edges.
    ///