lb_rs/service/
path.rs

1use crate::model::errors::{LbErrKind, LbResult};
2use crate::model::file::File;
3use crate::model::path_ops::Filter;
4use crate::model::tree_like::TreeLike;
5use crate::Lb;
6use uuid::Uuid;
7
8impl Lb {
9    #[instrument(level = "debug", skip(self), err(Debug))]
10    pub async fn create_link_at_path(&self, path: &str, target_id: Uuid) -> LbResult<File> {
11        let mut tx = self.begin_tx().await;
12        let db = tx.db();
13
14        let mut tree = (&db.base_metadata)
15            .to_staged(&mut db.local_metadata)
16            .to_lazy();
17
18        let root = db.root.get().ok_or(LbErrKind::RootNonexistent)?;
19
20        let id = tree.create_link_at_path(path, target_id, root, &self.keychain)?;
21
22        let ui_file = tree.decrypt(&self.keychain, &id, &db.pub_key_lookup)?;
23
24        self.events.meta_changed(*root);
25
26        Ok(ui_file)
27    }
28
29    #[instrument(level = "debug", skip(self), err(Debug))]
30    pub async fn create_at_path(&self, path: &str) -> LbResult<File> {
31        let mut tx = self.begin_tx().await;
32        let db = tx.db();
33
34        let mut tree = (&db.base_metadata)
35            .to_staged(&mut db.local_metadata)
36            .to_lazy();
37
38        let root = db.root.get().ok_or(LbErrKind::RootNonexistent)?;
39
40        let id = tree.create_at_path(path, root, &self.keychain)?;
41
42        let ui_file = tree.decrypt(&self.keychain, &id, &db.pub_key_lookup)?;
43
44        self.events.meta_changed(*root);
45
46        Ok(ui_file)
47    }
48
49    #[instrument(level = "debug", skip(self), err(Debug))]
50    pub async fn get_by_path(&self, path: &str) -> LbResult<File> {
51        let tx = self.ro_tx().await;
52        let db = tx.db();
53
54        let mut tree = (&db.base_metadata).to_staged(&db.local_metadata).to_lazy();
55
56        let root = db.root.get().ok_or(LbErrKind::RootNonexistent)?;
57
58        let id = tree.path_to_id(path, root, &self.keychain)?;
59
60        let ui_file = tree.decrypt(&self.keychain, &id, &db.pub_key_lookup)?;
61
62        Ok(ui_file)
63    }
64
65    #[instrument(level = "debug", skip(self), err(Debug))]
66    pub async fn get_path_by_id(&self, id: Uuid) -> LbResult<String> {
67        let tx = self.ro_tx().await;
68        let db = tx.db();
69
70        let mut tree = (&db.base_metadata).to_staged(&db.local_metadata).to_lazy();
71        let path = tree.id_to_path(&id, &self.keychain)?;
72
73        Ok(path)
74    }
75
76    #[instrument(level = "debug", skip(self), err(Debug))]
77    pub async fn list_paths(&self, filter: Option<Filter>) -> LbResult<Vec<String>> {
78        let tx = self.ro_tx().await;
79        let db = tx.db();
80
81        let mut tree = (&db.base_metadata).to_staged(&db.local_metadata).to_lazy();
82        let paths = tree.list_paths(filter, &self.keychain)?;
83
84        Ok(paths)
85    }
86}
lb_rs/service/path.rs

lb_rs/service/
path.rs
