From fb492c6b91bc7c2c456961997d2c25e585cb4710 Mon Sep 17 00:00:00 2001
From: Lucas Colombo <lucasncolombo@gmail.com>
Date: Wed, 5 Jun 2024 08:17:51 -0300
Subject: [PATCH] =?UTF-8?q?fix:=20=F0=9F=9A=91=20make=20rustlers=20start?=
 =?UTF-8?q?=20blocking?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lib/rustlers/svc.rs | 25 ++++++++++---------------
 1 file changed, 10 insertions(+), 15 deletions(-)

diff --git a/lib/rustlers/svc.rs b/lib/rustlers/svc.rs
index f4958c4..ff127b1 100644
--- a/lib/rustlers/svc.rs
+++ b/lib/rustlers/svc.rs
@@ -11,6 +11,7 @@ use {
     },
     eyre::Result,
     lool::{
+        fail,
         logger::{info, warn},
         sched::{
             recur, ruleset, scheduler::tokio::Scheduler, utils::parse_time, RecurrenceRuleSet,
@@ -18,10 +19,7 @@ use {
         },
     },
     std::sync::Arc,
-    tokio::{
-        spawn,
-        sync::{mpsc::Sender, Mutex},
-    },
+    tokio::sync::{mpsc::Sender, Mutex},
 };
 
 /// **🐎 » Rustler Message**
@@ -103,22 +101,19 @@ where
                 self.schedule_rustler_for((market, tickers), sender.clone()).await?;
             }
 
+            // NOTE: if we wanted to stop all the rustlers for good for some reason, we should
+            // use a select! instead and listen for a stop signal coming from somewhere
             let mut publisher = self.publisher.clone();
-            spawn(async move {
-                while let Some(msg) = receiver.recv().await {
-                    match msg {
-                        RustlerMsg::QuoteMsg(quote) => publisher.publish(quote).await?,
-                    }
+            while let Some(msg) = receiver.recv().await {
+                match msg {
+                    RustlerMsg::QuoteMsg(quote) => publisher.publish(quote).await?,
                 }
+            }
 
-                info!("Rustler message receiver stopped");
-                Ok::<(), eyre::Report>(())
-            });
+            fail!("Rustlers stopped")
         } else {
-            warn!("No markets found with tickers");
+            fail!("No markets found")
         }
-
-        Ok(())
     }
 
     /// **🐎 » restart rustlers**