jax-daemon 0.1.14

End-to-end encrypted storage buckets with peer-to-peer synchronization
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

//! Blob storage module for the daemon.
//!
//! This module provides the blob store setup following the same pattern as the database module.

mod setup;

use std::path::Path;

use common::peer::BlobsStore;

use crate::state::BlobStoreConfig;

/// Wrapper around the legacy BlobsStore.
///
/// This provides a consistent interface for blob storage setup,
/// following the same pattern as the Database module.
#[derive(Clone)]
pub struct Blobs(BlobsStore);

impl Blobs {
    /// Setup blob storage based on configuration.
    ///
    /// # Arguments
    /// * `config` - Blob store configuration (Legacy, Filesystem, or S3)
    /// * `jax_dir` - Path to the jax directory (used for legacy blobs and cache)
    /// * `max_import_size` - Maximum blob size allowed for BAO imports
    pub async fn setup(
        config: &BlobStoreConfig,
        jax_dir: &Path,
        max_import_size: u64,
    ) -> Result<Self, BlobsSetupError> {
        let store = setup::setup_blobs_store(config, jax_dir, max_import_size).await?;
        Ok(Self(store))
    }

    /// Consume self and return the underlying BlobsStore.
    pub fn into_inner(self) -> BlobsStore {
        self.0
    }
}

/// Error type for blob store setup.
#[derive(Debug, thiserror::Error)]
pub enum BlobsSetupError {
    #[error("blob store error: {0}")]
    StoreError(String),
}