✨ Enables user restart by entering rs in stdin (#12) (#17)

* ✨ Enables user restart by entering rs in stdin

Users can restart their program by typing rs and pressing enter in the terminal.

* 🐛 Kill child process before restarting.

* 🚨 Removed Clippy warnings

Author: alayshahh

src/exec.rs

@@ -1,13 +1,16 @@
-use std::io::{self, Write};
-use std::process::{Command, Stdio};
+use std::io::{self};
+use std::process::Command;
+use std::sync::mpsc::Sender;
 use std::sync::Arc;
 use std::thread;
-use termcolor::{Color, ColorChoice, ColorSpec, StandardStream, WriteColor};
 
 pub use crate::cli::Cli;
 pub use crate::LightmonEvent;
 
-pub fn start(cli_args: Arc<Cli>) -> std::thread::JoinHandle<()> {
+pub fn start(
+    cli_args: Arc<Cli>,
+    lightmon_event_sender: Sender<LightmonEvent>,
+) -> std::thread::JoinHandle<()> {
     thread::spawn(move || {
         debug!("thread started");
 
@@ -20,23 +23,32 @@ pub fn start(cli_args: Arc<Cli>) -> std::thread::JoinHandle<()> {
                 cmd.arg(argument);
             }
             debug!("final cmd = {:?}", cmd);
-            let output = cmd.output().unwrap();
-            cmd.stdout(Stdio::inherit());
-            cmd.stdout(Stdio::inherit());
-            //write stdout to stdout
-            io::stdout().write_all(&output.stdout).unwrap();
-            if !output.stderr.is_empty() {
-                //if stderr
-                //change color to red
-                let mut error = StandardStream::stderr(ColorChoice::Always);
-                error
-                    .set_color(ColorSpec::new().set_fg(Some(Color::Red)))
-                    .unwrap();
-                //write to stderr
-                io::stderr().write_all(&output.stderr).unwrap();
-                //reset terminal output color
-                let color_reset = WriteColor::reset(&mut error).unwrap();
-                debug!("reset color? {:?}", color_reset);
+            let mut child = cmd.spawn().unwrap();
+            loop {
+                let mut input = String::new();
+                if let Ok(n) = io::stdin().read_line(&mut input) {
+                    if input.eq("rs\n") {
+                        debug!("rs RECEIEVED");
+                        match lightmon_event_sender.send(LightmonEvent::KillAndRestartChild) {
+                            Ok(()) => {
+                                let child_killed = child.kill();
+                                match child_killed {
+                                    Ok(()) => {}
+                                    Err(e) => {
+                                        error!("program cannot be quit and restarted: {:?}", e);
+                                        std::process::exit(1);
+                                    }
+                                }
+                            }
+                            Err(_) => {
+                                panic!("failed to send initial lightmon event. Something went seriously wrong!");
+                            }
+                        };
+                    } else {
+                        debug!("unknown input, bits read from input {:?}", n);
+                        debug!("input = {:?}", input);
+                    }
+                }
             }
         }
     })

src/main.rs

@@ -31,7 +31,7 @@ fn main() {
         }
     };
 
-    watcher::start(cli_args.clone(), lightmon_event_sender);
+    watcher::start(cli_args.clone(), lightmon_event_sender.clone());
 
     println!("lightmon started ({} mode)", cli_args.project_language);
 
@@ -41,14 +41,14 @@ fn main() {
             match lightmon_event {
                 LightmonEvent::KillAndRestartChild => {
                     debug!("KILL AND RESTART RECEIEVED");
-                    exec::start(cli_args.clone());
+                    exec::start(cli_args.clone(), lightmon_event_sender.clone());
                 }
                 LightmonEvent::KillChild => {
                     debug!("KILL RECEIEVED");
                 }
                 LightmonEvent::InitExec => {
                     debug!("INIT EXEC RECEIVED");
-                    exec::start(cli_args.clone());
+                    exec::start(cli_args.clone(), lightmon_event_sender.clone());
                 }
             }
         }