converge-storage 3.2.1

Object storage abstraction for Converge — local, S3, GCS
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

// Copyright 2024-2026 Reflective Labs
// SPDX-License-Identifier: MIT

use std::path::Path;
use std::sync::Arc;

use object_store::ObjectStore;
use object_store::local::LocalFileSystem;

use crate::StorageError;

pub fn build(path: &Path) -> Result<Arc<dyn ObjectStore>, StorageError> {
    if !path.exists() {
        std::fs::create_dir_all(path).map_err(|e| {
            StorageError::Config(format!("failed to create local storage dir: {e}"))
        })?;
        tracing::info!(path = %path.display(), "created local storage directory");
    }

    let store = LocalFileSystem::new_with_prefix(path)
        .map_err(|e| StorageError::Config(format!("local filesystem setup failed: {e}")))?;

    Ok(Arc::new(store))
}