Method put_edge_versioned

nodedb/src/engine/graph/edge_store/temporal/write.rs:22–69

Write a new version of an edge at `system_from`. Maintains the reverse index with the same suffix so inbound traversal can version-scan symmetrically. Does NOT close prior versions' `system_until` — Ceiling infers the closed-open interval at read time from the next-newer version's `system_from`.

(
        &self,
        edge: EdgeRef<'_>,
        properties: &[u8],
        system_from: i64,
        valid_from_ms: i64,
        valid_until_ms: i64,
    )

    /// closed-open interval at read time from the next-newer version's
    /// `system_from`.
    pub fn put_edge_versioned(
        &self,
        edge: EdgeRef<'_>,
        properties: &[u8],
        system_from: i64,
        valid_from_ms: i64,
        valid_until_ms: i64,
    ) -> crate::Result<()> {
        let fwd = versioned_edge_key(edge.collection, edge.src, edge.label, edge.dst, system_from)?;
        let rev = versioned_edge_key(edge.collection, edge.dst, edge.label, edge.src, system_from)?;
        let payload =
            EdgeValuePayload::new(valid_from_ms, valid_until_ms, properties.to_vec()).encode()?;
        let t = edge.tid.as_u64();

        let write_txn = self
            .db
            .begin_write()
            .map_err(|e| redb_err("begin_write", e))?;
        {
            let mut edges = write_txn
                .open_table(EDGES)
                .map_err(|e| redb_err("open edges", e))?;
            edges
                .insert((t, fwd.as_str()), payload.as_slice())
                .map_err(|e| redb_err("insert versioned edge", e))?;
            drop(edges);

            let mut rev_t = write_txn
                .open_table(REVERSE_EDGES)
                .map_err(|e| redb_err("open reverse", e))?;
            rev_t
                .insert((t, rev.as_str()), &[] as &[u8])
                .map_err(|e| redb_err("insert reverse", e))?;
            drop(rev_t);

            increment_for_insert(
                &write_txn,
                t,
                edge.collection,
                edge.label,
                edge.src,
                edge.dst,
                system_from,
            )?;
        }
        write_txn.commit().map_err(|e| redb_err("commit", e))?;
        Ok(())
    }

    /// BiTemporalFK enforcement: close a referrer edge by appending a new
    /// version that copies the latest live version's properties and