Method put

nodedb/src/control/array_sync/snapshot_store.rs:117–151

Persist a snapshot.

(&self, snapshot: &TileSnapshot)

    /// Persist a snapshot.
    pub fn put(&self, snapshot: &TileSnapshot) -> crate::Result<()> {
        let key = snapshot_key(&snapshot.array, snapshot.snapshot_hlc).ok_or_else(|| {
            crate::Error::Storage {
                engine: "array_sync".into(),
                detail: format!("snapshot_store: array name too long: '{}'", snapshot.array),
            }
        })?;
        let encoded = encode_snapshot(snapshot).map_err(|e| crate::Error::Storage {
            engine: "array_sync".into(),
            detail: format!("snapshot_store encode: {e}"),
        })?;

        let txn = self.db.begin_write().map_err(|e| crate::Error::Storage {
            engine: "array_sync".into(),
            detail: format!("snapshot_store put begin_write: {e}"),
        })?;
        {
            let mut table = txn
                .open_table(SNAPSHOT_TABLE)
                .map_err(|e| crate::Error::Storage {
                    engine: "array_sync".into(),
                    detail: format!("snapshot_store put open_table: {e}"),
                })?;
            table
                .insert(key.as_slice(), encoded.as_slice())
                .map_err(|e| crate::Error::Storage {
                    engine: "array_sync".into(),
                    detail: format!("snapshot_store put insert: {e}"),
                })?;
        }
        txn.commit().map_err(|e| crate::Error::Storage {
            engine: "array_sync".into(),
            detail: format!("snapshot_store put commit: {e}"),
        })
    }

    /// Retrieve a snapshot by exact `(array, hlc)`.
    pub fn get(&self, array: &str, hlc: Hlc) -> Option<TileSnapshot> {