From 6ab657f0e6211aed4452ba7b0e06e803b25c8ccc Mon Sep 17 00:00:00 2001
From: Yuval Adam <_@yuv.al>
Date: Thu, 12 Jul 2018 18:47:57 +0300
Subject: Test HTTP file serving

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

(limited to 'src/main.rs')

diff --git a/src/main.rs b/src/main.rs
index 42208dc..398e76d 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -14,6 +14,7 @@ use std::sync::mpsc;
 
 mod cli;
 mod upnp;
+mod serve;
 
 fn main() {
     let app = App::new(env!("CARGO_PKG_NAME"))
@@ -47,29 +48,31 @@ fn main() {
         process::exit(1);
     }
 
-    let _udp = thread::spawn(move || {
-        upnp::discover();
-    });
+    serve::run();
 
-    let (tx, rx) = mpsc::channel();
-    let child = thread::spawn(move || {
-        let mut controller = cli::Controller::init();
-        loop {
-            let c = controller.read();
-            tx.send(c).unwrap();
-            if c == 113 {
-                break;
-            }
-        }
-        controller.destroy();
-    });
+    // let _udp = thread::spawn(move || {
+    //     upnp::discover();
+    // });
 
-    for received in rx {
-        println!("Got char: {}", received);
-    }
+    // let (tx, rx) = mpsc::channel();
+    // let child = thread::spawn(move || {
+    //     let mut controller = cli::Controller::init();
+    //     loop {
+    //         let c = controller.read();
+    //         tx.send(c).unwrap();
+    //         if c == 113 {
+    //             break;
+    //         }
+    //     }
+    //     controller.destroy();
+    // });
+
+    // for received in rx {
+    //     println!("Got char: {}", received);
+    // }
 
-    println!("Waiting for all thread");
-    let _res = child.join();
-    println!("Done!");
+    // println!("Waiting for all thread");
+    // let _res = child.join();
+    // println!("Done!");
 
 }
-- 
cgit v1.3.1