fix: Log & continue on mapper errors (#53)

src/mapper/cip25.rs

@@ -91,15 +91,15 @@ impl EventWriter {
     }
 
     pub(crate) fn crawl_metadata_label_721(&self, content: &Metadatum) -> Result<(), Error> {
-        let version = self
-            .search_cip25_version(content)
-            .unwrap_or_else(|| "1.0".to_string());
-
         let entries = match content {
             Metadatum::Map(map) => map,
             _ => return Err("expected 721 content to be a map".into()),
         };
 
+        let version = self
+            .search_cip25_version(content)
+            .unwrap_or_else(|| "1.0".to_string());
+
         for (key, sub_content) in entries.iter() {
             if let Some(policy) = is_policy_key(key) {
                 self.crawl_721_policy(&version, &policy, sub_content)?;

src/sources/n2c/mod.rs

@@ -19,6 +19,7 @@ use pallas::{
 use crate::{
     framework::{Error, EventData},
     mapper::EventWriter,
+    utils::SwallowResult,
 };
 
 #[derive(Debug)]
@@ -64,7 +65,9 @@ impl Observer<Content> for ChainObserver {
         let Self(writer) = self;
         let Content(block) = content;
 
-        writer.crawl(block)?;
+        writer
+            .crawl(block)
+            .ok_or_warn("error crawling block for events");
 
         Ok(())
     }

src/sources/n2n/mod.rs

@@ -23,6 +23,7 @@ use std::sync::mpsc::{Receiver, SyncSender};
 use crate::{
     framework::{Error, EventData},
     mapper::EventWriter,
+    utils::SwallowResult,
 };
 
 #[derive(Debug)]
@@ -67,7 +68,10 @@ impl BlockObserver for Block2EventMapper {
         match maybe_block {
             Ok(alonzo::BlockWrapper(_, block)) => {
                 let Self(writer) = self;
-                writer.crawl(&block)?;
+
+                writer
+                    .crawl(&block)
+                    .ok_or_warn("error crawling block for events");
             }
             Err(err) => {
                 log::error!("{:?}", err);

src/utils/mod.rs

@@ -1 +1,16 @@
+use crate::framework::Error;
+
 pub mod throttle;
+
+pub(crate) trait SwallowResult {
+    fn ok_or_warn(self, context: &'static str);
+}
+
+impl SwallowResult for Result<(), Error> {
+    fn ok_or_warn(self, context: &'static str) {
+        match self {
+            Ok(_) => (),
+            Err(e) => log::warn!("{}: {:?}", context, e),
+        }
+    }
+}