Getting rid of Responder::{trackers,tx_tracker_map}

This commit introduced the minimal changes to get rid of trackers
and tx_tracker_map hashmaps.

`trackersq usage was replaced with DB calls when needed.
while `tx_tracker_map` wasn't actually needed after all.

The memory usage didn't change much (any) on our testing 2M appointments DB since there weren't any trackers/breaches there.

teos/src/dbm.rs

@@ -228,6 +228,15 @@ impl DBM {
         stmt.query_row([], |row| row.get(0)).unwrap()
     }
 
+    /// Get the number of stored trackers.
+    pub(crate) fn get_trackers_count(&self) -> usize {
+        let mut stmt = self
+            .connection
+            .prepare("SELECT COUNT(*) FROM trackers")
+            .unwrap();
+        stmt.query_row([], |row| row.get(0)).unwrap()
+    }
+
     /// Stores an [Appointment] into the database.
     pub(crate) fn store_appointment(
         &self,
@@ -276,8 +285,8 @@ impl DBM {
             Ok(_) => {
                 log::debug!("Appointment successfully updated: {uuid}");
             }
-            Err(_) => {
-                log::error!("Appointment not found, data cannot be updated: {uuid}");
+            Err(e) => {
+                log::error!("Appointment not found, data cannot be updated: {uuid}. Error: {e:?}");
             }
         }
     }
@@ -471,7 +480,7 @@ impl DBM {
         .collect()
     }
 
-    pub(crate) fn batch_check_locator_exists(&self, locators: Vec<Locator>) -> Vec<Locator> {
+    pub(crate) fn batch_check_locators_exist(&self, locators: Vec<Locator>) -> Vec<Locator> {
         let mut registered_locators = Vec::new();
         let locators: Vec<Vec<u8>> = locators.iter().map(|l| l.to_vec()).collect();
         let limit = self.connection.limit(Limit::SQLITE_LIMIT_VARIABLE_NUMBER) as usize;
@@ -529,6 +538,31 @@ impl DBM {
         }
     }
 
+    /// Updates the tracker information in the database.
+    ///
+    /// The only updatable fields are `height` and `confirmed`. Such an update will be issued when:
+    /// 1- A tracker was confirmed in a block.
+    /// 2- A tracker was reorged out of the main chain and is back in the mempool.
+    pub(crate) fn update_tracker_status(
+        &self,
+        uuid: UUID,
+        status: &ConfirmationStatus,
+    ) -> Result<(), Error> {
+        let (height, confirmed) = status.to_db_data().ok_or(Error::MissingField)?;
+
+        let query = "UPDATE trackers SET height=(?1), confirmed=(?2) WHERE UUID=(?3)";
+        match self.update_data(query, params![height, confirmed, uuid.to_vec(),]) {
+            Ok(x) => {
+                log::debug!("Tracker successfully updated: {uuid}");
+                Ok(x)
+            }
+            Err(e) => {
+                log::error!("Couldn't update tracker: {uuid}. Error: {e:?}");
+                Err(e)
+            }
+        }
+    }
+
     /// Loads a [TransactionTracker] from the database.
     pub(crate) fn load_tracker(&self, uuid: UUID) -> Result<TransactionTracker, Error> {
         let key = uuid.to_vec();
@@ -931,7 +965,7 @@ mod tests {
     }
 
     #[test]
-    fn test_batch_check_locator_exists() {
+    fn test_batch_check_locators_exist() {
         let dbm = DBM::in_memory().unwrap();
         // Generate `count` appointments which we will store in the DB.
         let count = 100;
@@ -972,7 +1006,7 @@ mod tests {
             .cloned()
             .collect();
 
-        assert_eq!(known_locators, dbm.batch_check_locator_exists(all_locators));
+        assert_eq!(known_locators, dbm.batch_check_locators_exist(all_locators));
     }
 
     #[test]

teos/src/main.rs

@@ -258,8 +258,8 @@ async fn main() {
     let shutdown_signal_tor = shutdown_signal_rpc_api.clone();
 
     // The ordering here actually matters. Listeners are called by order, and we want the gatekeeper to be called
-    // last, so both the Watcher and the Responder can query the necessary data from it during data deletion.
-    let listener = &(watcher.clone(), &(responder, gatekeeper));
+    // first so it updates the users' states and both the Watcher and the Responder operate only on registered users.
+    let listener = &(gatekeeper, &(watcher.clone(), responder));
     let cache = &mut UnboundedCache::new();
     let spv_client = SpvClient::new(tip, poller, cache, listener);
     let mut chain_monitor = ChainMonitor::new(