aboutsummaryrefslogtreecommitdiffstats
path: root/filamento/examples/example.rs
diff options
context:
space:
mode:
Diffstat (limited to 'filamento/examples/example.rs')
-rw-r--r--filamento/examples/example.rs23
1 files changed, 16 insertions, 7 deletions
diff --git a/filamento/examples/example.rs b/filamento/examples/example.rs
index 8ebfde0..d7c03e4 100644
--- a/filamento/examples/example.rs
+++ b/filamento/examples/example.rs
@@ -12,21 +12,30 @@ impl FileStore for Files {
type Err = Arc<io::Error>;
async fn is_stored(&self, name: &str) -> Result<bool, Self::Err> {
- Ok(tokio::fs::try_exists(format!("files/{}", name))
+ tracing::debug!("checking if {} is stored", name);
+ let res = tokio::fs::try_exists(format!("files/{}", name))
.await
- .map_err(|err| Arc::new(err))?)
+ .map_err(|err| Arc::new(err));
+ tracing::debug!("file check res: {:?}", res);
+ res
}
async fn store(&self, name: &str, data: &[u8]) -> Result<(), Self::Err> {
- Ok(tokio::fs::write(format!("files/{}", name), data)
+ tracing::debug!("storing {} is stored", name);
+ let res = tokio::fs::write(format!("files/{}", name), data)
.await
- .map_err(|err| Arc::new(err))?)
+ .map_err(|err| Arc::new(err));
+ tracing::debug!("file store res: {:?}", res);
+ res
}
async fn delete(&self, name: &str) -> Result<(), Self::Err> {
- Ok(tokio::fs::remove_file(format!("files/{}", name))
+ tracing::debug!("deleting {}", name);
+ let res = tokio::fs::remove_file(format!("files/{}", name))
.await
- .map_err(|err| Arc::new(err))?)
+ .map_err(|err| Arc::new(err));
+ tracing::debug!("file delete res: {:?}", res);
+ res
}
}
@@ -37,7 +46,7 @@ async fn main() {
.await
.unwrap();
let (client, mut recv) = Client::new(
- "test@blos.sm".try_into().unwrap(),
+ "test@blos.sm/testing2".try_into().unwrap(),
"slayed".to_string(),
db,
Files,