Stop polling for events when in external editor

Adds a global atomic counter to indicate whether the background thread looking for input events should be polling or not.

Even though this methods stops gitui snatching input events from the editor, it seems that _one_ key input event is still captured. It looks like it happens after approximately 2 seconds (the `MAX_POLL_DURATION` used by the event poller).

Author: jonstodle

Diff for: src/components/commit.rs

@@ -130,7 +130,11 @@ impl CommitComponent {
             anyhow!("unable to read editor command")
         })?;
 
+        crate::poll::SHOULD_DO_POLL
+            .fetch_add(1, std::sync::atomic::Ordering::SeqCst);
         Command::new(command).args(editor).status()?;
+        crate::poll::SHOULD_DO_POLL
+            .fetch_add(1, std::sync::atomic::Ordering::SeqCst);
 
         let mut message = String::new();
 

Diff for: src/poll.rs

@@ -1,8 +1,11 @@
 use asyncgit::AsyncNotification;
 use crossbeam_channel::{unbounded, Receiver};
 use crossterm::event::{self, Event};
+use std::sync::atomic::{AtomicUsize, Ordering};
 use std::time::{Duration, Instant};
 
+// TODO: Do this properly!!!
+pub static SHOULD_DO_POLL: AtomicUsize = AtomicUsize::new(0);
 ///
 #[derive(Clone, Copy)]
 pub enum QueueEvent {
@@ -25,23 +28,27 @@ pub fn start_polling_thread() -> Receiver<Vec<QueueEvent>> {
         let mut batch = Vec::new();
 
         loop {
-            let timeout = if batch.is_empty() {
-                MAX_POLL_DURATION
-            } else {
-                MIN_POLL_DURATION
-            };
-            if let Some(e) =
-                poll(timeout).expect("failed to pull events.")
-            {
-                batch.push(QueueEvent::InputEvent(e));
-            }
+            // TODO: This doesn't start working immediately if it's currently
+            // polling with a 2 seconds timeout duration
+            if SHOULD_DO_POLL.load(Ordering::SeqCst) % 2 == 0 {
+                let timeout = if batch.is_empty() {
+                    MAX_POLL_DURATION
+                } else {
+                    MIN_POLL_DURATION
+                };
+                if let Some(e) =
+                    poll(timeout).expect("failed to pull events.")
+                {
+                    batch.push(QueueEvent::InputEvent(e));
+                }
 
-            if !batch.is_empty()
-                && last_send.elapsed() > MAX_BATCHING_DURATION
-            {
-                tx.send(batch).expect("send input event failed");
-                batch = Vec::new();
-                last_send = Instant::now();
+                if !batch.is_empty()
+                    && last_send.elapsed() > MAX_BATCHING_DURATION
+                {
+                    tx.send(batch).expect("send input event failed");
+                    batch = Vec::new();
+                    last_send = Instant::now();
+                }
             }
         }
     });