Struct SnapshotManager 

pub struct SnapshotManager<Db>
where
    Db: HoprDbGeneralModelOperations + Clone + Send + Sync + 'static,
{ /* private fields */ }

Coordinates snapshot download, extraction, validation, and database integration.

The main interface for snapshot operations in production environments. Manages the complete workflow from download to database installation.

Architecture

• SnapshotDownloader - HTTP/HTTPS and file:// URL handling with retry logic
• SnapshotExtractor - Secure tar.xz extraction with path validation
• SnapshotValidator - SQLite integrity and content verification
• Database integration via HoprDbGeneralModelOperations::import_logs_db

Implementations

impl<Db> SnapshotManager<Db>

where Db: HoprDbGeneralModelOperations + Clone + Send + Sync + 'static,

pub fn with_db(db: Db) -> Result<Self, SnapshotError>

Creates a snapshot manager with database integration.

Arguments

• db - Database instance implementing HoprDbGeneralModelOperations

Example

let manager = SnapshotManager::with_db(db)?;

pub async fn download_and_setup_snapshot( &self, url: &str, data_dir: &Path, ) -> SnapshotResult<SnapshotInfo>

Downloads, extracts, validates, and installs a snapshot.

Performs the complete snapshot setup workflow:

1. Downloads archive from URL (HTTP/HTTPS/file://)
2. Extracts tar.xz archive safely
3. Validates database integrity
4. Installs via HoprDbGeneralModelOperations::import_logs_db
5. Cleans up temporary files

Arguments

• url - Snapshot URL (https://, http://, or file:// scheme)
• data_dir - Target directory for temporary files during installation

Returns

SnapshotInfo containing log count, block count, and metadata on success

Errors

Returns SnapshotError for network failures, validation errors, or installation issues

Examples

// Download from HTTPS
let info = manager
    .download_and_setup_snapshot("https://snapshots.hoprnet.org/logs.tar.xz", Path::new("/data"))
    .await?;

// Use local file
let info = manager
    .download_and_setup_snapshot("file:///backups/snapshot.tar.xz", Path::new("/data"))
    .await?;