solar-s3 0.1.1

Solar-s3 this is the first version of the package that allows you to work with the file system as with S3 storage.
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98

#[cfg(test)]
mod tests_store {
    use std::io::Result;
    use std::path::{Path, PathBuf};

    use mocktopus::mocking::*;
    use tokio::fs;
    use uuid::Uuid;

    use crate::storage::space::Space;
    use crate::storage::store::{Storage, Store};

    async fn prepare_test() -> Result<PathBuf> {
        let path = Path::new("../storages");
        fs::create_dir(&path).await.is_err();
        let path = Path::new(&path).join(Uuid::new_v4().to_string());
        fs::remove_dir_all(&path).await.is_err();
        return Ok(path);
    }

    #[tokio::test]
    async fn test_create_success() {
        let path = prepare_test().await.unwrap();

		Store::create(&path, 1000, None).await.unwrap();
		assert!(path.exists());

        fs::remove_dir_all(&path).await.is_err();
	}

    #[tokio::test]
	async fn test_create_check_json() {
		let path = prepare_test().await.unwrap();

        Store::create(&path, 1000, None).await.unwrap();
		assert!(path.join("storage.json").exists());

        fs::remove_dir_all(path).await.is_err();
	}

    #[tokio::test]
	async fn test_create_failed() {
		Space::get_disc.mock_safe(|| MockResult::Return(0));
		let path = prepare_test().await.unwrap();

        let res = Store::create(&path, 10, None).await.is_err();
		assert!(res);

        fs::remove_dir_all(path).await.is_err();
	}

    #[tokio::test]
	async fn test_open() {
		Space::get_disc.mock_safe(|| MockResult::Return(10000));
		let path = prepare_test().await.unwrap();

        Store::create(&path, 1000, None).await.unwrap();
		assert!(path.exists());

        let res = Store::open(&path).await.unwrap();
        let is_uuid = Uuid::parse_str(res.uuid.as_str()).is_err();

        assert_eq!(res.store_path, path.to_str().unwrap().to_string());
        assert_eq!(is_uuid, false);
        assert_eq!(res.logging, false);
        assert_eq!(res.available_space, 1000);
        assert_eq!(res.usage_space, 0);
        fs::remove_dir_all(&path).await.is_err();
    }

    #[tokio::test]
    async fn test_update_size() {
        let path = prepare_test().await.unwrap();

        Store::create(&path, 1000, None).await.unwrap();
        assert!(path.exists());

        let mut res = Store::open(&path).await.unwrap();
        let size = res.update_space(999).await.unwrap();
        assert_eq!(size, 999);

        fs::remove_dir_all(&path).await.is_err();
    }

    #[tokio::test]
    async fn test_update_size_failed() {
        let path = prepare_test().await.unwrap();

        Store::create(&path, 1000, None).await.unwrap();
        assert!(path.exists());

        let mut res = Store::open(&path).await.unwrap();
        let err = res.update_space(1001).await.is_err();
        assert!(err);

        fs::remove_dir_all(&path).await.is_err();
    }
}