Don't forget to commit after R/W operations

quickpeep_raker/src/bin/qp-seedrake.rs

@@ -283,5 +283,6 @@ async fn import_and_flush_batch(
             }
         }
     }
+    txn.commit()?;
     Ok(())
 }

quickpeep_raker/src/raking/task.rs

@@ -144,7 +144,9 @@ impl TaskContext {
                         }
 
                         // TODO delete the domain from the store
+                        todo!();
 
+                        txn.commit()?;
                         Ok(true)
                     })
                     .await?;
@@ -227,6 +229,7 @@ impl TaskContext {
                     self.store
                         .async_rw_txn(move |txn| {
                             txn.mark_url_as_visited(&domain, &url_str, record)?;
+                            txn.commit()?;
                             Ok(())
                         })
                         .await?;
@@ -266,6 +269,7 @@ impl TaskContext {
                                 backoff_sec: 0,
                             },
                         )?;
+                        txn.commit()?;
                         Ok(())
                     })
                     .await?;
@@ -374,7 +378,7 @@ impl TaskContext {
                 self.store
                     .async_rw_txn(move |txn| {
                         txn.start_backing_off(&domain, new_backoff, url.to_string(), failure)?;
-
+                        txn.commit()?;
                         Ok(())
                     })
                     .await?;
@@ -425,7 +429,9 @@ impl EventProcessor<'_> {
                     UrlVisitedRecord {
                         last_visited_days: datestamp,
                     },
-                )
+                )?;
+                txn.commit()?;
+                Ok(())
             })
             .await
     }
@@ -453,6 +459,7 @@ impl EventProcessor<'_> {
                     txn.enqueue_url(&reference.target, reference.last_mod, reference.kind.into())?;
                 }
 
+                txn.commit()?;
                 Ok(())
             })
             .await
@@ -469,7 +476,9 @@ impl EventProcessor<'_> {
                     UrlVisitedRecord {
                         last_visited_days: datestamp,
                     },
-                )
+                )?;
+                txn.commit()?;
+                Ok(())
             })
             .await
     }

quickpeep_raker/src/storage.rs

@@ -220,6 +220,11 @@ pub struct RakerTxn<'a, K: TransactionKind> {
 }
 
 impl<'a> RakerTxn<'a, RW> {
+    pub fn commit(self) -> anyhow::Result<()> {
+        self.mdbx_txn.commit()?;
+        Ok(())
+    }
+
     /// Inserts a domain into the active domain table,
     /// generating a raffle ticket (and inserting it too).
     ///