converge-storage 3.7.6

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
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

// 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))
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn build_creates_missing_directory() {
        let dir = tempfile::tempdir().unwrap();
        let nested = dir.path().join("a/b/c");
        assert!(!nested.exists());

        let store = build(&nested).unwrap();
        assert!(nested.exists());
        assert!(Arc::strong_count(&store) == 1);
    }

    #[test]
    fn build_succeeds_on_existing_directory() {
        let dir = tempfile::tempdir().unwrap();
        let store = build(dir.path()).unwrap();
        assert!(Arc::strong_count(&store) == 1);
    }
}