From 81fd3bc2ceb4b38c9eb0e115a47549c86adbd6e9 Mon Sep 17 00:00:00 2001
From: Nickiel12 <35903114+Nickiel12@users.noreply.github.com>
Date: Fri, 24 Jun 2022 19:19:03 -0700
Subject: [PATCH] added pause_timer

---
 src/modules/message_handler.rs            | 52 ++++++++++++++++++++++-
 src/modules/stream_states/state_update.rs |  3 ++
 2 files changed, 53 insertions(+), 2 deletions(-)

diff --git a/src/modules/message_handler.rs b/src/modules/message_handler.rs
index 51313e8..23d810a 100644
--- a/src/modules/message_handler.rs
+++ b/src/modules/message_handler.rs
@@ -6,6 +6,7 @@ pub trait MessageHandler {                              //the first one goes to
     fn handle_update(&mut self, update: StateUpdate, hotkey_handler: &Hotkeys)
      -> (Option<StateUpdate>, Option<Vec<StateUpdate>>);
     fn get_states(&self) -> StreamState;
+    fn pause_timer(&mut self, do_pause: bool) -> (Option<StateUpdate>, Option<Vec<StateUpdate>>);
     fn tick(&mut self) -> Vec<StateUpdate>;
 }
 
@@ -79,6 +80,7 @@ impl MessageHandler for StreamState {
                     return (Some(update), None);
                 }
             }
+            StateUpdate::PauseTimer(value) => {return self.pause_timer(value)},
             StateUpdate::TimerLength(value) => {self.timer_length = value; return (Some(update), None)},
             StateUpdate::TimerText(value) => {self.timer_text = value.clone(); return (Some(StateUpdate::TimerText(value)), None)},
             StateUpdate::SubScene(value) => {
@@ -135,11 +137,57 @@ impl MessageHandler for StreamState {
         (None, None)
     }
 
+    fn pause_timer(&mut self, do_pause: bool) -> (Option<StateUpdate>, Option<Vec<StateUpdate>>) {
+        let instruction: StateUpdate;
+        
+        // if do pause, 
+        if do_pause {
+            // stop tick from running,
+            self.timer_can_run = false;
+            
+            // get the amount of time left on the clock
+            let time_left: u16;
+            match self.timer_start.elapsed() {
+                Err(_) => {time_left = 0},
+                Ok(change) => {
+                    // take the duration, multiply it by 10 to save the last decimal,
+                    // then drop the rest of the digits with .round()
+                    time_left = (self.timer_length - (change.as_secs_f32() * 10.0).round()) as u16;
+                }
+            }
+            self.timer_paused_length = Some(time_left);
+            
+            // (Send to socket, process another instruction)
+            // send the pause singal to the socket, and update the timer text (dividing by 10 to return the last digit)
+            return (Some(StateUpdate::PauseTimer(true)), Some(vec![StateUpdate::TimerText(format!("{:.1}", time_left as f32/10.0))]));
+        } else {
+            // if start timer from pause
+            // enable tick()
+            self.timer_can_run = true;
+
+            // Some fancy check to not have to use a match statement. The 'expect' should never be called, worry if it does
+            let timer_paused_length: u16 = self.timer_paused_length.or(Some(0)).expect("timer_paused 'Some' unwrap somehow failed");
+            
+            // update timer_start, taking into account the amount of time already run
+            self.timer_start = SystemTime::now() - 
+                    std::time::Duration::from_millis(
+                        // first get the decimal back from timer_paused_length, get the amount of time already run
+                        // then convert that to milliseconds, then from f32 to u64 
+                        ((self.timer_length - (timer_paused_length as f32 / 10.0)) * 1000.0) as u64);
+                        
+                
+            // Clear the paused time
+            self.timer_paused_length = None;
+
+            instruction = StateUpdate::PauseTimer(false);
+        }
+        return (Some(instruction), None)
+    }
+
     fn tick(&mut self) -> Vec<StateUpdate> {
         let mut instructions = Vec::new();
         if self.timer_finished == false && self.timer_can_run == true {
-            let change = self.timer_start.elapsed();
-            match change {
+            match self.timer_start.elapsed() {
                 Err(_) => {},
                 Ok(change) => {
                     if change.as_secs_f32() >= self.timer_length {
diff --git a/src/modules/stream_states/state_update.rs b/src/modules/stream_states/state_update.rs
index 3d68b33..4526996 100644
--- a/src/modules/stream_states/state_update.rs
+++ b/src/modules/stream_states/state_update.rs
@@ -12,6 +12,7 @@ pub enum StateUpdate {
     ChangeSceneOnChangeSlide(bool),
     SceneIsAugmented(bool),
     TimerCanRun(bool),
+    PauseTimer(bool),
     TimerLength(f32),
     TimerText(String),
     SubScene(SubScenes),
@@ -120,6 +121,8 @@ impl StateUpdate {
                      SlideChange::PreviousHotkey => {("Prev_Slide", "hotkey".to_string())},
                 }
             },
+            StateUpdate::PauseTimer(value) => {
+                ("Pause_Timer", value.to_string())}
             StateUpdate::UpdateClient => {
                 ("all", "".to_string())
             },