From 809b252df7cdc276620dea38f6d64ae7216ea473 Mon Sep 17 00:00:00 2001
From: Paul Lecuq <paul@paulbsd.com>
Date: Tue, 12 Dec 2023 22:41:21 +0100
Subject: [PATCH] added error handling for monitoring

---
 src/ipblc.rs      | 3 +--
 src/monitoring.rs | 8 +++++++-
 2 files changed, 8 insertions(+), 3 deletions(-)

diff --git a/src/ipblc.rs b/src/ipblc.rs
index 9c56704..fd83e91 100644
--- a/src/ipblc.rs
+++ b/src/ipblc.rs
@@ -205,8 +205,7 @@ async fn compare_files_changes(
         match modfiles.inevent.name {
             Some(name) => {
                 let filename = name.to_str().unwrap();
-                for sak in sas.clone().keys() {
-                    let sa = sas.get(sak).unwrap();
+                for (sak, sa) in sas.clone().iter_mut() {
                     if modfiles.inevent.wd == sa.wd {
                         let handle: String;
                         if sa.filename.as_str() == "" {
diff --git a/src/monitoring.rs b/src/monitoring.rs
index 4204793..27f7364 100644
--- a/src/monitoring.rs
+++ b/src/monitoring.rs
@@ -10,7 +10,13 @@ use tokio::sync::RwLock;
 pub async fn apiserver(ctxarc: &Arc<RwLock<Context>>) -> io::Result<()> {
     let ctxarc = ctxarc.clone();
     let addr: String = { ctxarc.read().await.cfg.api.parse().unwrap() };
-    let listener = TcpListener::bind(addr).await.unwrap();
+    let listener = match TcpListener::bind(addr).await {
+        Ok(l) => l,
+        Err(err) => {
+            println!("Error: {err}");
+            std::process::exit(1);
+        }
+    };
 
     tokio::spawn(async move {
         loop {