Merge pull request #39 from ilikepi63/fix/error-logging-for-consume

fix: Error Logging for Consume.

Author: ilikepi63

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "riskless"
-version = "0.6.2"
+version = "0.6.3"
 edition = "2024"
 description = "A pure Rust implementation of Diskless Topics"
 license = "MIT / Apache-2.0"

Cargo.toml

@@ -163,18 +163,29 @@ pub async fn consume(
                                     .filter(|batch| batch.object_key == *object_name)
                                     .map(|batch| (res.clone(), batch))
                             })
+                            .inspect(|val| {
+                                tracing::trace!("Result returned for query: {:#?}", val);
+                            })
                             .filter_map(|(res, batch)| {
                                 ConsumeBatch::try_from((res, batch, &b)).ok()
                             })
                             .collect::<Vec<_>>();
 
                         batch_responses_for_object
                     } else {
+                        tracing::trace!(
+                            "Could not retrieve bytes for given GetObject query: {}",
+                            object_name
+                        );
                         vec![]
                     }
                 }
-                Err(_err) => {
-                    // TODO: How are we going to handle errors here?
+                Err(err) => {
+                    tracing::error!(
+                        "An error occurred trying to retrieve the object with key {}. Error: {:#?}",
+                        object_name,
+                        err
+                    );
                     vec![]
                 }
             };
@@ -186,6 +197,8 @@ pub async fn consume(
                 {
                     tracing::error!("Failed to send consume response: {:#?}", e);
                 };
+            } else {
+                tracing::trace!("No ConsumeBatches found for query.");
             };
         });
     }