bpm_core 0.1.0

Cross-platform software helping to verify, prove and secure package compilation, building, fetching, and deployment. Core package.
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

use std::{path::PathBuf, sync::Arc};

use polodb_core::{Collection, Database};
use tokio::sync::Mutex;

use super::documents::{
    blockchain_document::BlockchainDocument, package_document::PackageDocument,
};

pub struct DbClient {
    instance: Arc<Mutex<Database>>,
}

impl DbClient {
    /**
     * Get packages collection
     */
    pub async fn get_packages_collection(&self) -> Collection<PackageDocument> {
        let packages_collection_name: &str = "packages";

        let packages_collection = self
            .instance
            .lock()
            .await
            .collection(packages_collection_name);

        packages_collection
    }

    /**
     * Get blockchains collection
     */
    pub async fn get_blockchains_collection(&self) -> Collection<BlockchainDocument> {
        let blockchains_collection_name: &str = "blockchains";

        let blockchains_collection = self
            .instance
            .lock()
            .await
            .collection(blockchains_collection_name);

        blockchains_collection
    }
}

impl From<&PathBuf> for DbClient {
    /**
     * New instance from DB path
     */
    fn from(db_path: &PathBuf) -> Self {
        let db = Arc::new(Mutex::new(Database::open_path(db_path).unwrap()));

        let instance = Self { instance: db };

        instance
    }
}