Add more trace output

Signed-off-by: Matthias Beyer <mail@beyermatthias.de>

1 files changed, 6 insertions, 0 deletions

diff --git a/src/filestore/staging.rs b/src/filestore/staging.rs
index d471d44..880b274 100644
--- a/src/filestore/staging.rs
+++ b/src/filestore/staging.rs
@@ -10,6 +10,7 @@ use futures::stream::Stream;
 use indicatif::ProgressBar;
 use resiter::Filter;
 use resiter::Map;
+use result_inspect::ResultInspect;
 use tar;
 
 use crate::filestore::Artifact;
@@ -52,10 +53,13 @@ impl StagingStore {
                         Ok(p)
                     })
                     .map_ok(|path| dest.join(path))
+                    .inspect(|p| trace!("Path in tar archive: {:?}", p))
                     .filter_ok(|p| p.is_file())
+                    .inspect(|p| trace!("Taking from archive: {:?}", p))
                     .collect::<Result<Vec<_>>>()
                     .context("Collecting outputs of TAR archive")?;
 
+                trace!("Unpacking archive to {}", dest.display());
                 tar::Archive::new(&bytes[..])
                     .unpack(dest)
                     .context("Unpacking TAR")
@@ -64,8 +68,10 @@ impl StagingStore {
             })
             .context("Concatenating the output bytestream")?
             .into_iter()
+            .inspect(|p| trace!("Trying to load into staging store: {}", p.display()))
             .map(|path| {
                 self.0.load_from_path(&path)
+                    .inspect(|r| trace!("Loading from path = {:?}", r))
                     .with_context(|| anyhow!("Loading from path: {}", path.display()))
                     .map_err(Error::from)
                     .map(|art| art.path().clone())