diff options
Diffstat (limited to 'filamento/examples/example.rs')
-rw-r--r-- | filamento/examples/example.rs | 23 |
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, |