From a594313b5f47531138b79795fdf72ae74776f1cf Mon Sep 17 00:00:00 2001
From: Scott Lawrence <scott+git@ineffectivetheory.com>
Date: Sat, 29 Jun 2024 10:35:42 -0700
Subject: Sending json-serialized state over socket.

---
 src/main.rs | 25 +++++++++++++++++++++----
 1 file changed, 21 insertions(+), 4 deletions(-)

(limited to 'src')

diff --git a/src/main.rs b/src/main.rs
index fb1165d..0282ec7 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -1,5 +1,6 @@
+use std::io::Write;
 use std::os::unix::net::{UnixStream,UnixListener};
-use std::sync::Mutex;
+use std::sync::{Arc,Mutex};
 use std::thread::{sleep,spawn};
 use std::time::{Duration,Instant,SystemTime};
 
@@ -59,9 +60,25 @@ fn main() {
         let start = Instant::now();
         let delay_ms: u64 = args.delay * 1000;
         let mut cycle: u64 = 0;
-        let state_mutex = Mutex::new(init_state());
-        let listener = spawn(move || {
-        });
+        let state_mutex = Arc::new(Mutex::new(init_state()));
+        let listen_thread = {
+            let state_mutex = Arc::clone(&state_mutex);
+            spawn(move || {
+                let listener = UnixListener::bind(args.socket).unwrap();
+                loop {
+                    match listener.accept() {
+                        Ok((mut socket,accept)) => {
+                            let json = {
+                                let state = state_mutex.lock().unwrap();
+                                serde_json::to_string(&*state).unwrap()
+                            };
+                            socket.write_all(json.as_bytes()).unwrap();
+                        },
+                        Err(e) => println!("error: {:?}", e)
+                    }
+                }
+            });
+        };
         loop {
             cycle += 1;
             sleep(Duration::from_millis(cycle*delay_ms) - start.elapsed());
-- 
cgit v1.2.3-54-g00ecf