nodedb-lite 0.1.0

Embedded edge client for NodeDB — offline vector search, graph traversal, and CRDT sync
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

// SPDX-License-Identifier: Apache-2.0

//! Publish PageDB snapshot files and required Lite encryption metadata.

use std::io::Write;
use std::path::Path;

use crate::error::LiteError;
use crate::storage::pagedb_storage::PagedbStorageDefault;

use super::metadata::METADATA_FILE;
use super::ownership::{OwnedDirectory, io_error, sync_parent};

impl PagedbStorageDefault {
    pub(crate) async fn export_snapshot(&self, destination: &Path) -> Result<(), LiteError> {
        let descriptor = self
            .snapshot_descriptor
            .as_ref()
            .ok_or_else(|| LiteError::Storage {
                detail: "native storage lacks snapshot encryption metadata".into(),
            })?;
        let mut ownership = OwnedDirectory::claim(destination, false)?;
        let result = async {
            self.db
                .snapshot_to(destination)
                .await
                .map_err(LiteError::from)?;
            let bytes = descriptor.encode()?;
            let metadata = destination.join(METADATA_FILE);
            let mut file = std::fs::OpenOptions::new()
                .write(true)
                .create_new(true)
                .open(&metadata)
                .map_err(|error| io_error(&metadata, error))?;
            file.write_all(&bytes)
                .and_then(|()| file.sync_all())
                .map_err(|error| io_error(&metadata, error))?;
            sync_parent(&metadata)?;
            sync_parent(destination)?;
            Ok(())
        }
        .await;
        if let Err(primary) = result {
            return Err(ownership.cleanup_error(primary));
        }
        ownership.preserve();
        Ok(())
    }
}