Moved episode indexing into a transaction.

hammond-data/src/feed.rs

@@ -1,4 +1,6 @@
 use rayon::prelude::*;
+use diesel::prelude::*;
+
 use diesel::Identifiable;
 use rss;
 
@@ -46,12 +48,15 @@ impl Feed {
         let db = connection();
         let con = db.get().unwrap();
 
-        episodes.into_iter().for_each(|x| {
+        let _ = con.transaction::<(), Error, _>(|| {
-            let e = x.index(&con);
+            episodes.into_iter().for_each(|x| {
-            if let Err(err) = e {
+                let e = x.index(&con);
-                error!("Failed to index episode: {:?}.", x);
+                if let Err(err) = e {
-                error!("Error msg: {}", err);
+                    error!("Failed to index episode: {:?}.", x);
-            };
+                    error!("Error msg: {}", err);
+                };
+            });
+            Ok(())
         });
         Ok(())
     }