updated monitoring socket

src/monitoring.rs

@@ -24,34 +24,26 @@ pub async fn apiserver(ctxarc: &Arc<RwLock<Context>>) -> io::Result<()> {
         loop {
             //apitx.send(String::from("")).await.unwrap();
             match listener.accept().await {
-                Ok((stream, _addr)) => {
+                Ok((mut stream, _addr)) => {
                     //let mut buf = [0; 1024];
                     let data;
                     {
                         let ctx = ctxarc.read().await;
-                        data = serde_json::to_string(&ctx.blocklist);
+                        data = serde_json::to_string(&ctx.blocklist).unwrap();
                     }
 
-                    match data {
+                    stream
-                        Ok(dt) => {
+                        .write_all(format!("{data}\n").as_bytes())
-                            let (_reader, mut writer) = stream.into_split();
+                        .await
-                            match writer.write_all(format!("{dt}").as_bytes()).await {
+                        .unwrap();
-                                Ok(_) => {}
+                    stream.flush().await.unwrap();
-                                Err(err) => {
+                    stream.shutdown().await.unwrap();
-                                    println!("{err}");
-                                }
-                            }
                 }
                 Err(err) => {
                     println!("unable to serialize data: {err}");
                 }
             }
         }
-                Err(err) => {
-                    println!("couldn't get client: {}", err)
-                }
-            }
-        }
     });
     Ok(())
 }