Method new

nodedb/src/storage/cold.rs:116–178

Create a cold storage client. Connects to the configured S3-compatible endpoint, or uses local filesystem if no endpoint is configured.

(config: ColdStorageConfig)

    /// Connects to the configured S3-compatible endpoint, or uses
    /// local filesystem if no endpoint is configured.
    pub fn new(config: ColdStorageConfig) -> crate::Result<Self> {
        let store: Arc<dyn ObjectStore> = if config.endpoint.is_empty() {
            // Local filesystem (dev/testing).
            let dir = config
                .local_dir
                .clone()
                .unwrap_or_else(|| PathBuf::from("/tmp/nodedb/cold"));
            std::fs::create_dir_all(&dir)?;
            Arc::new(LocalFileSystem::new_with_prefix(&dir).map_err(|e| {
                crate::Error::ColdStorage {
                    detail: format!("local cold storage: {e}"),
                }
            })?)
        } else {
            // S3-compatible object store.
            let mut builder = AmazonS3Builder::new()
                .with_endpoint(&config.endpoint)
                .with_bucket_name(&config.bucket)
                .with_region(&config.region)
                .with_allow_http(config.endpoint.starts_with("http://"));

            if !config.access_key.is_empty() {
                builder = builder
                    .with_access_key_id(&config.access_key)
                    .with_secret_access_key(&config.secret_key);
            }

            match &config.sse_mode {
                Some(SseMode::Aes256) => {
                    // AES256 = SSE-S3 (S3-managed keys).
                    // object_store 0.13 configures SSE-S3 via the "server_side_encryption"
                    // config key with value "AES256". This maps to
                    // `S3EncryptionType::S3` → `x-amz-server-side-encryption: AES256`.
                    use object_store::aws::AmazonS3ConfigKey;
                    let sse_key = "server_side_encryption"
                        .parse::<AmazonS3ConfigKey>()
                        .map_err(|e| crate::Error::ColdStorage {
                            detail: format!(
                                "SSE-S3 config key parse error (object_store version mismatch?): {e}"
                            ),
                        })?;
                    builder = builder.with_config(sse_key, "AES256");
                }
                Some(SseMode::Kms { key_id }) => {
                    let id = key_id.as_deref().unwrap_or("");
                    builder = builder.with_sse_kms_encryption(id);
                }
                None => {}
            }

            let s3 = builder.build().map_err(|e| crate::Error::ColdStorage {
                detail: format!("S3 client init: {e}"),
            })?;
            Arc::new(s3)
        };

        Ok(Self {
            config,