introduced new command

Author: sidit77

Cargo.lock

@@ -102,7 +102,10 @@ fn client() -> Result<()> {
                     dialog = Some(thread::spawn(|| run_key_tester()));
                 },
                 Some(GuiEvent::ShutdownServer) => {
-                    log::info!("Shutdown");
+                    log::info!("Sending shutdown signal to server");
+                    if let Some(ref mut transmitter) = input_transmitter {
+                        transmitter.sender.deref().borrow_mut().shutdown_remote();
+                    }
                 }
                 None => { }
             }

inputshare-client/src/main.rs

@@ -41,6 +41,10 @@ impl InputSender {
 
     }
 
+    pub fn shutdown_remote(&mut self) {
+        self.message_queue.push_back([MessageType::Shutdown.into(), 0])
+    }
+
     pub fn reset(&mut self) {
         self.message_queue.push_back([MessageType::Reset.into(), 0])
     }

inputshare-client/src/sender.rs

@@ -1,6 +1,6 @@
 [package]
 name = "inputshare-server"
-version = "2.2.1"
+version = "2.3.1"
 authors = ["sidit77 <sidit77@gmail.com>"]
 edition = "2018"
 

inputshare-server/Cargo.toml

@@ -154,7 +154,8 @@ fn server(args: Args) -> Result<()> {
                                         keyboard.reset()?;
                                         mouse.reset()?;
                                         consumer_device.reset()?;
-                                    }
+                                    },
+                                    InputEvent::Shutdown => log::info!("Shutdown")
                                 }
                                 last_input = Instant::now();
                                 // println!("{:?}", event);

inputshare-server/src/main.rs

@@ -16,6 +16,7 @@ pub enum InputEvent {
     HorizontalScrolling(i8),
     VerticalScrolling(i8),
     Reset,
+    Shutdown
 }
 
 #[derive(Debug)]
@@ -70,6 +71,7 @@ impl InputReceiver {
                 Ok(MessageType::HorizontalScrolling) => self.events.push_back(InputEvent::HorizontalScrolling(msg_arg as i8)),
                 Ok(MessageType::VerticalScrolling) => self.events.push_back(InputEvent::VerticalScrolling(msg_arg as i8)),
                 Ok(MessageType::Reset) => self.events.push_back(InputEvent::Reset),
+                Ok(MessageType::Shutdown) => self.events.push_back(InputEvent::Shutdown),
                 Err(e) => log::warn!("Invalid message: {}", e)
             }
             self.last_message = start_message + i + 1;

inputshare-server/src/receiver.rs

@@ -28,7 +28,8 @@ pub enum MessageType {
     ConsumerDeviceRelease,
     HorizontalScrolling,
     VerticalScrolling,
-    Reset
+    Reset,
+    Shutdown
 }
 
 #[derive(Debug, Copy, Clone, Hash, PartialEq, Eq, IntoPrimitive, FromPrimitive)]