adds mvp for new ui layer

Author: dingfeli

Cargo.lock

@@ -20,6 +20,10 @@ serde_json.workspace = true
 chrono.workspace = true
 crossterm.workspace = true
 tokio.workspace = true
+eyre.workspace = true
+tokio-util.workspace = true
+futures.workspace = true
+ratatui = "0.29.0"
 
 [target.'cfg(unix)'.dependencies]
 nix.workspace = true

crates/chat-cli-ui/Cargo.toml

@@ -1,6 +1,10 @@
-use std::{io::Write as _, marker::PhantomData};
+use std::io::Write as _;
+use std::marker::PhantomData;
 
-use crate::protocol::{Event, LegacyPassThroughOutput};
+use crate::protocol::{
+    Event,
+    LegacyPassThroughOutput,
+};
 
 #[derive(thiserror::Error, Debug)]
 pub enum ConduitError {

crates/chat-cli-ui/src/conduit.rs

@@ -0,0 +1 @@
+

crates/chat-cli-ui/src/input_bar.rs

@@ -1,7 +1,10 @@
 //! This is largely based on https://docs.ag-ui.com/concepts/events
 //! They do not have a rust SDK so for now we are handrolling these types
 
-use serde::{Deserialize, Serialize};
+use serde::{
+    Deserialize,
+    Serialize,
+};
 use serde_json::Value;
 
 /// Role of a message sender

crates/chat-cli-ui/src/protocol.rs

@@ -0,0 +1,7 @@
+#![allow(dead_code)]
+#[derive(Debug, Clone, Copy, PartialEq, Eq)]
+pub enum Action {
+    Quit,
+    Tick,
+    Noop,
+}

crates/chat-cli-ui/src/ui/action.rs

@@ -0,0 +1,46 @@
+use eyre::Result;
+use tokio::sync::mpsc::unbounded_channel;
+use tracing::error;
+
+use crate::ui::action::Action;
+use crate::ui::tui::Tui;
+
+pub struct App {
+    pub should_quit: bool,
+}
+
+impl App {
+    pub async fn run(&mut self) -> Result<()> {
+        let (_render_tx, mut render_rx) = unbounded_channel::<()>();
+        let (action_tx, mut _action_rx) = unbounded_channel::<Action>();
+
+        let mut tui = Tui::new(4.0, 60.0)?;
+        // TODO: make a defer routine that restores the terminal on exit
+        tui.enter()?;
+
+        let mut event_receiver = tui.event_rx.take().expect("Missing event receiver");
+
+        // Render Task
+        tokio::spawn(async move {
+            while render_rx.recv().await.is_some() {
+                // TODO: render here
+                tui.terminal.draw(|_f| {})?;
+            }
+
+            Ok::<(), Box<dyn std::error::Error + Send + Sync + 'static>>(())
+        });
+
+        // Event monitoring task
+        tokio::spawn(async move {
+            while let Some(_event) = event_receiver.recv().await {
+                // TODO: derive action from the main component
+                let action = Action::Tick;
+                if let Err(e) = action_tx.send(action) {
+                    error!("Error sending action: {:?}", e);
+                }
+            }
+        });
+
+        Ok(())
+    }
+}

crates/chat-cli-ui/src/ui/component.rs

@@ -0,0 +1,45 @@
+#![allow(dead_code)]
+use crossterm::event::{
+    Event,
+    KeyEvent,
+    MouseEvent,
+};
+use eyre::Result;
+use ratatui::Frame;
+use ratatui::layout::Rect;
+use tokio::sync::mpsc::UnboundedSender;
+
+use super::action::Action;
+
+mod app;
+
+pub trait Component {
+    #[allow(unused_variables)]
+    fn register_action_handler(&mut self, tx: UnboundedSender<Action>) -> Result<()> {
+        Ok(())
+    }
+    fn init(&mut self) -> Result<()> {
+        Ok(())
+    }
+    fn handle_events(&mut self, event: Option<Event>) -> Result<Option<Action>> {
+        let r = match event {
+            Some(Event::Key(key_event)) => self.handle_key_events(key_event)?,
+            Some(Event::Mouse(mouse_event)) => self.handle_mouse_events(mouse_event)?,
+            _ => None,
+        };
+        Ok(r)
+    }
+    #[allow(unused_variables)]
+    fn handle_key_events(&mut self, key: KeyEvent) -> Result<Option<Action>> {
+        Ok(None)
+    }
+    #[allow(unused_variables)]
+    fn handle_mouse_events(&mut self, mouse: MouseEvent) -> Result<Option<Action>> {
+        Ok(None)
+    }
+    #[allow(unused_variables)]
+    fn update(&mut self, action: Action) -> Result<Option<Action>> {
+        Ok(None)
+    }
+    fn draw(&mut self, f: &mut Frame<'_>, rect: Rect) -> Result<()>;
+}

crates/chat-cli-ui/src/ui/components/app.rs

@@ -0,0 +1,3 @@
+mod action;
+mod components;
+mod tui;