bug fix message queue oveflow

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "tvserver"
-version = "0.7.0"
+version = "0.7.1"
 edition = "2021"
 authors = ["Chris Morgan <cmorgan@abamaxa.com>"]
 repository = "https://github.com/abamaxa/tvserver"

src/domain/messagebus/message_exchange.rs

@@ -26,7 +26,6 @@ pub struct MessageExchange {
     sender: mpsc::Sender<ReceivedRemoteMessage>,
     receiver: broadcast::Sender<ReceivedRemoteMessage>,
     local_sender: LocalMessageSender,
-    _local_receiver: Arc<LocalMessageReceiver>,
 }
 
 impl MessageExchange {
@@ -55,7 +54,7 @@ impl MessageExchange {
             })(client_map.clone(), in_tx.clone()),
         );
 
-        let (local_sender, local_receiver) = broadcast::channel::<LocalMessage>(100);
+        let (local_sender, _) = broadcast::channel::<LocalMessage>(100);
 
         let _ = tokio::spawn((|client_map: ClientMap| async move {
             loop {
@@ -66,7 +65,6 @@ impl MessageExchange {
         let exchanger = Self {
             client_map: client_map.clone(),
             receiver: in_tx,
-            _local_receiver: Arc::new(local_receiver),
             sender,
             local_sender,
         };

src/services/media_store.rs

@@ -64,6 +64,10 @@ impl MediaStore {
     }
 
     fn store_video_info(&self, path: &Path) {
+        if self.sender.len() >= 100 {
+            tracing::info!("local queue has more than 100 entries, will process {:?} later", path);
+            return;
+        }
         let event = MediaEvent::new_media(path, None);
 
         if let Err(e) = self.sender.send(LocalMessage::Media(event)) {

src/services/monitor.rs

@@ -38,7 +38,7 @@ impl Monitor {
                     tracing::error!("error checking video info: {}", err);
                 }
 
-                sleep(Duration::from_secs(3)).await;
+                sleep(Duration::from_secs(10)).await;
             }
         })
     }