fix(rust/cardano-chain-follower): Mithril downloader log error (#361)

* fix(cardano-chain-follower): mithril downloader log error

Signed-off-by: bkioshn <[email protected]>

* fix(cardano-chain-follower): enhance err logging

Signed-off-by: bkioshn <[email protected]>

* fix(cardano-chain-follower): enhance err logging

Signed-off-by: bkioshn <[email protected]>

* fix(cardano-chain-follower): fix err logging

Signed-off-by: bkioshn <[email protected]>

* fix(cardano-chain-follower): fix comment

Signed-off-by: bkioshn <[email protected]>

---------

Signed-off-by: bkioshn <[email protected]>
Co-authored-by: Alex Pozhylenkov <[email protected]>

Author: bkioshn

rust/cardano-chain-follower/src/mithril_turbo_downloader.rs

@@ -3,7 +3,7 @@
 use std::{
     cmp,
     ffi::OsStr,
-    io::{BufReader, Read},
+    io::{BufReader, ErrorKind, Read},
     path::{Path, PathBuf},
     // process::Stdio,
     sync::{
@@ -169,7 +169,22 @@ impl Inner {
                 }
             } else {
                 // No dedup, just extract it into the tmp directory as-is.
-                entry.unpack_in(&tmp_dir)?;
+                entry.unpack_in(&tmp_dir).inspect_err(|e| {
+                    // Handle known I/O error kinds explicitly - `StorageFull`
+                    // All other error kinds are logged as unhandled.
+                    if e.kind() == ErrorKind::StorageFull {
+                        error!(
+                            chain = %self.cfg.chain,
+                            error = %e,
+                            "Storage full while extracting file {rel_file:?} with size {entry_size}"
+                        );
+                    } else {
+                        error!(
+                            chain = %self.cfg.chain,
+                            error = %e,
+                            "Unhandled I/O error kind: {}", e.kind());
+                    }
+                })?;
                 debug!(chain = %self.cfg.chain, "DeDup: Extracted file {rel_file:?}:{entry_size}");
             }
             new_file!(self, rel_file, abs_file, entry_size);