Implement input handling

1 files changed, 43 insertions, 2 deletions

diff --git a/src/app.rs b/src/app.rs
index 87caf62..f0ffff0 100644
--- a/src/app.rs
+++ b/src/app.rs
@@ -1,15 +1,23 @@
-use std::io::{stdout, Stdout};
+use std::{
+    error::Error,
+    io::{stdout, Stdout},
+    time::Duration,
+};
 
+use crossterm::event::{poll, read, KeyCode, KeyModifiers};
 use rand::Rng;
 use tokio::sync::mpsc::{channel, Receiver, Sender};
 
 use crate::event::Event;
 
+const TICK_RATE: u64 = 1000 / 20;
+
 pub struct App {
     stdout: Stdout,
     quote: Vec<String>,
     event_tx: Sender<Event>,
     event_rx: Receiver<Event>,
+    running: bool,
 }
 
 impl App {
@@ -22,10 +30,43 @@ impl App {
             quote: quotes[chosen].clone(),
             event_rx,
             event_tx,
+            running: false,
         }
     }
 
-    pub fn run() {
+    pub async fn run(&mut self) {
         todo!()
     }
+
+    // TODO
+    // - [ ] Pause on focus lost
+    // - [ ] Invalidate on paste
+    async fn handle_input(&mut self) -> Result<(), Box<dyn Error>> {
+        while self.running {
+            if poll(Duration::from_millis(TICK_RATE))? {
+                match read()? {
+                    //crossterm::event::Event::FocusGained => todo!(),
+                    //crossterm::event::Event::FocusLost => todo!(),
+                    //crossterm::event::Event::Paste(_) => todo!(),
+                    crossterm::event::Event::Key(key_event) => {
+                        if key_event.code == KeyCode::Char('c')
+                            && key_event.modifiers == KeyModifiers::CONTROL
+                        {
+                            self.event_tx.send(Event::Terminate).await?;
+                            continue;
+                        }
+                        if key_event.code == KeyCode::Backspace {
+                            self.event_tx.send(Event::Backspace).await?;
+                            continue;
+                        }
+                        if let KeyCode::Char(c) = key_event.code {
+                            self.event_tx.send(Event::KeyPress(c)).await?;
+                        }
+                    }
+                    _ => (),
+                }
+            }
+        }
+        return Ok(());
+    }
 }