Cargo.toml

@@ -7,7 +7,10 @@ license = "MIT"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [features]
-default = ["tui"]
+default = ["cli"]
+full = ["cli", "tui"]
+
+cli = ["tokio/io-std"]
 tui = ["dep:tui", "dep:tui-textarea", "dep:crossterm", "dep:tokio-util", "dep:serde", "dep:indexmap"]
 
 [dependencies]
@@ -15,7 +18,7 @@ clap = { version = "4.3.19", features = ["derive"] }
 cli-log = "2.0"
 anyhow = "1.0"
 matrix-sdk = "0.6"
-tokio = { version = "1.29", features = ["macros", "rt-multi-thread", "io-std"] }
+tokio = { version = "1.29", features = ["macros", "rt-multi-thread"] }
 
 # lua stuff
 lua_macros = { path = "./lua_macros" }

src/cli.rs

@@ -11,7 +11,13 @@ pub struct Args {
 }
 #[derive(Subcommand, Debug)]
 pub enum Command {
+    /// Starts a repl, for the lua interface
+    #[cfg(feature = "cli")]
+    #[clap(value_parser)]
+    Repl {},
+
     /// Starts the main tui client
+    #[cfg(feature = "tui")]
     #[clap(value_parser)]
     Start {},
 }

src/main.rs

@@ -1,12 +1,17 @@
-//mod app;
-//mod ui;
-//mod accounts;
 mod cli;
+pub mod event_handler;
+
+#[cfg(feature = "tui")]
 mod tui_app;
 
+#[cfg(feature = "cli")]
+mod repl;
+
 use clap::Parser;
 
 use crate::cli::{Args, Command};
+
+#[cfg(feature = "tui")]
 pub use tui_app::*;
 
 #[tokio::main]
@@ -14,8 +19,20 @@ async fn main() -> anyhow::Result<()> {
     cli_log::init_cli_log!();
 
     let args = Args::parse();
-    let command = args.subcommand.unwrap_or(Command::Start {});
+    let command = args.subcommand.unwrap_or(
+        #[cfg(all(feature = "tui", not(feature = "cli")))]
+        Command::Start {},
+        #[cfg(all(feature = "cli", not(feature = "tui")))]
+        Command::Repl {},
+        #[cfg(all(feature = "cli", feature = "tui"))]
+        Command::Start {},
+    );
     match command {
+        #[cfg(feature = "cli")]
+        Command::Repl {} => {
+            repl::run().await?;
+        }
+        #[cfg(feature = "tui")]
         Command::Start {} => {
             let mut app = app::App::new()?;
             app.run().await?;

src/repl/mod.rs

@@ -0,0 +1,41 @@
+use std::io::ErrorKind;
+
+use anyhow::{Context, Result};
+use cli_log::{info, warn};
+use tokio::io::{stdin, stdout, AsyncReadExt, AsyncWriteExt};
+
+pub async fn run() -> Result<()> {
+    let mut stdin = stdin();
+    let mut stdout = stdout();
+    let mut buffer = [0; 1];
+    let mut new_command = vec![];
+
+    loop {
+        stdout
+            .write("trinitrix:> ".as_bytes())
+            .await
+            .context("Failed to write prompt")?;
+        stdout.flush().await.context("Failed to flush prompt")?;
+        new_command.clear();
+        loop {
+            if let Err(err) = stdin.read_exact(&mut buffer).await {
+                if err.kind() == ErrorKind::UnexpectedEof {
+                    warn!("Unexpected EOF, we assume the user quit.");
+                    return Ok(());
+                } else {
+                    Err(err).context("Failed to read next character")?;
+                }
+            }
+            if buffer == "\n".as_bytes() {
+                break;
+            } else {
+                new_command.append(&mut buffer.to_vec());
+            }
+        }
+        info!(
+            "Got user repl input: {}",
+            String::from_utf8(new_command.clone())
+                .context("Failed to convert user input to utf8 string")?
+        )
+    }
+}

src/tui_app/app/command_interface.rs

@@ -2,7 +2,6 @@ use cli_log::debug;
 
 #[derive(Debug)]
 pub enum Command {
-    RaiseError(String),
     Greet(String),
     Exit,
     CommandLineShow,

src/tui_app/app/events/event_types/event/handlers/command.rs

@@ -1,105 +1,66 @@
 use crate::app::{command_interface::Command, events::event_types::EventStatus, App};
-use anyhow::{Context, Result};
-use cli_log::{info, warn, trace};
-use tokio::sync::mpsc;
+use anyhow::Result;
+use cli_log::info;
 
 pub async fn handle(
     app: &mut App<'_>,
     command: &Command,
-    output_callback: &Option<mpsc::Sender<String>>,
-) -> Result<EventStatus> {
-    // A command returns both _status output_ (what you would normally print to stderr)
-    // and _main output_ (the output which is normally printed to stdout).
-    // We simulate these by returning the main output to the lua function, and printing the
-    // status output to a status ui field.
-    //
-    // Every function should return some status output to show the user, that something is
-    // happening, while only some functions return some value to the main output, as this
-    // is reserved for functions called only for their output (for example `greet()`).
-    macro_rules! send_status_output {
+    send_output: bool,
+) -> Result<(EventStatus, String)> {
+    macro_rules! set_status_output {
         ($str:expr) => {
-             app.status.add_status_message($str.to_owned());
-        };
-        ($str:expr, $($args:ident),+) => {
-             app.status.add_status_message(format!($str, $($args),+));
-        };
-    }
-    macro_rules! send_error_output {
-        ($str:expr) => {
-             app.status.add_error_message($str.to_owned());
-        };
-        ($str:expr, $($args:ident),+) => {
-             app.status.add_error_message(format!($str, $($args),+));
-        };
-    }
-    macro_rules! send_main_output {
-        ($str:expr) => {
-            if let Some(sender) = output_callback {
-                sender
-                    .send($str.to_owned())
-                    .await
-                    .context("Failed to send command main output")?;
+            if send_output {
+                app.ui.set_command_output($str);
             }
         };
         ($str:expr, $($args:ident),+) => {
-            if let Some(sender) = output_callback {
-                sender
-                    .send(format!($str, $($args),+))
-                    .await
-                    .context("Failed to send command main output")?;
+            if send_output {
+                app.ui.set_command_output(&format!($str, $($args),+));
             }
         };
     }
-
-    trace!("Handling command: {:#?}", command);
+    info!("Handling command: {:#?}", command);
 
     Ok(match command {
-        Command::Exit => {
-            send_status_output!("Terminating the application..");
-            EventStatus::Terminate
-        }
+        Command::Exit => (
+            EventStatus::Terminate,
+            "Terminated the application".to_owned(),
+        ),
 
         Command::CommandLineShow => {
             app.ui.cli_enable();
-            send_status_output!("CLI online");
-            EventStatus::Ok
+            set_status_output!("CLI online");
+            (EventStatus::Ok, "".to_owned())
         }
         Command::CommandLineHide => {
             app.ui.cli_disable();
-            send_status_output!("CLI offline");
-            EventStatus::Ok
+            set_status_output!("CLI offline");
+            (EventStatus::Ok, "".to_owned())
         }
 
         Command::CyclePlanes => {
             app.ui.cycle_main_input_position();
-            send_status_output!("Switched main input position");
-            EventStatus::Ok
+            set_status_output!("Switched main input position");
+            (EventStatus::Ok, "".to_owned())
         }
         Command::CyclePlanesRev => {
             app.ui.cycle_main_input_position_rev();
-            send_status_output!("Switched main input position; reversed");
-            EventStatus::Ok
+            set_status_output!("Switched main input position; reversed");
+            (EventStatus::Ok, "".to_owned())
         }
 
         Command::RoomMessageSend(msg) => {
             if let Some(room) = app.status.room_mut() {
                 room.send(msg.clone()).await?;
-            } else {
-                // TODO(@Soispha): Should this raise a lua error? It could be very confusing,
-                // when a user doesn't read the log.
-                warn!("Can't send message: `{}`, as there is no open room!", &msg);
             }
-            send_status_output!("Send message: `{}`", msg);
-            EventStatus::Ok
+            set_status_output!("Send message: `{}`", msg);
+            (EventStatus::Ok, "".to_owned())
         }
         Command::Greet(name) => {
-            send_main_output!("Hi, {}!", name);
-            EventStatus::Ok
+            info!("Greated {}", name);
+            set_status_output!("Hi, {}!", name);
+            (EventStatus::Ok, "".to_owned())
         }
         Command::Help(_) => todo!(),
-        Command::RaiseError(err) => {
-            send_error_output!(err);
-            EventStatus::Ok
-        },
     })
 }

src/tui_app/app/events/event_types/event/handlers/lua_command.rs

@@ -1,14 +1,38 @@
-use anyhow::Result;
-use cli_log::trace;
+use std::{sync::Arc, time::Duration};
+
+use anyhow::{Context, Result};
+use cli_log::{debug, info};
+use tokio::{task, time::timeout};
 
 use crate::app::{events::event_types::EventStatus, App};
 
-// This function is here mainly to reserve this spot for further processing of the lua command.
-// TODO(@Soispha): Move the lua executor thread code from app to this module
 pub async fn handle(app: &mut App<'_>, command: String) -> Result<EventStatus> {
-    trace!("Recieved ci command: `{command}`; executing..");
+    info!("Recieved ci command: `{command}`; executing..");
 
-    app.lua_command_tx.send(command).await?;
+    let local = task::LocalSet::new();
+
+    // Run the local task set.
+    let output = local
+        .run_until(async move {
+            let lua = Arc::clone(&app.lua);
+            debug!("before_handle");
+            let c_handle = task::spawn_local(async move {
+                lua.load(&command)
+                    // FIXME this assumes string output only
+                    .eval_async::<String>()
+                    .await
+                    .with_context(|| format!("Failed to execute: `{command}`"))
+            });
+            debug!("after_handle");
+            c_handle
+        })
+        .await;
+    debug!("after_thread");
+
+    let output = timeout(Duration::from_secs(10), output)
+        .await
+        .context("Failed to join lua command executor")???;
+    info!("Command returned: `{}`", output);
 
     Ok(EventStatus::Ok)
 }

src/tui_app/app/events/event_types/event/handlers/main.rs

@@ -150,29 +150,26 @@ pub async fn handle(app: &mut App<'_>, input_event: &CrosstermEvent) -> Result<E
                 };
             }
             central::InputPosition::CLI => {
-                if let Some(cli) = &app.ui.cli {
+                if let Some(_) = app.ui.cli {
                     match input {
                         CrosstermEvent::Key(KeyEvent {
                             code: KeyCode::Enter,
                             ..
                         }) => {
-                            let ci_event = cli
+                            let ci_event = app.ui
+                                            .cli
+                                            .as_mut()
+                                            .expect("This is already checked")
                                             .lines()
                                             .get(0)
                                             .expect(
-                                    "One line always exists,
-                                     and others can't exists
-                                     because we collect on
-                                     enter",
+                                                "There can only be one line in the buffer, as we collect it on enter being inputted"
                                             )
                                             .to_owned();
                             app.tx
                                 .send(Event::LuaCommand(ci_event))
                                 .await
                                 .context("Failed to send lua command to internal event stream")?;
-                            app.tx
-                                .send(Event::CommandEvent(Command::CommandLineHide, None))
-                                .await?;
                         }
                         _ => {
                             app.ui

src/tui_app/app/events/event_types/event/mod.rs

@@ -1,7 +1,7 @@
 mod handlers;
 
 use anyhow::{Context, Result};
-use cli_log::trace;
+use cli_log::{info, trace};
 use crossterm::event::Event as CrosstermEvent;
 use tokio::sync::mpsc::Sender;
 
@@ -27,12 +27,22 @@ impl Event {
                 .await
                 .with_context(|| format!("Failed to handle matrix event: `{:#?}`", event)),
 
-            Event::CommandEvent(event, callback_tx) => command::handle(app, event, callback_tx)
+            Event::CommandEvent(event, callback_tx) => {
+                let (result, output) = command::handle(app, event, callback_tx.is_some())
                     .await
-                .with_context(|| format!("Failed to handle command event: `{:#?}`", event)),
+                    .with_context(|| format!("Failed to handle command event: `{:#?}`", event))?;
+
+                if let Some(callback_tx) = callback_tx {
+                    callback_tx
+                        .send(output.clone())
+                        .await
+                        .with_context(|| format!("Failed to send command output: {}", output))?;
+                }
+                Ok(result)
+            }
             Event::LuaCommand(lua_code) => lua_command::handle(app, lua_code.to_owned())
                 .await
-                .with_context(|| format!("Failed to handle lua code: `{}`", lua_code)),
+                .with_context(|| format!("Failed to handle lua code: `{:#?}`", lua_code)),
 
             Event::InputEvent(event) => match app.status.state() {
                 State::None => unreachable!(

src/tui_app/app/mod.rs

@@ -2,26 +2,22 @@ pub mod command_interface;
 pub mod events;
 pub mod status;
 
-use std::{path::Path, thread};
+use std::path::Path;
 
 use anyhow::{Context, Error, Result};
-use cli_log::{error, info};
+use cli_log::info;
 use matrix_sdk::Client;
 use once_cell::sync::OnceCell;
 use status::{State, Status};
 use tokio::{
-    runtime::Builder,
     sync::{mpsc, Mutex},
-    task::{self, LocalSet},
+    task::LocalSet,
 };
 use tokio_util::sync::CancellationToken;
 
 use crate::{
     accounts::{Account, AccountsManager},
-    app::{
-        command_interface::{generate_ci_functions, Command},
-        events::event_types::Event,
-    },
+    app::{command_interface::generate_ci_functions, events::event_types::Event},
     ui::{central, setup},
 };
 
@@ -43,67 +39,35 @@ pub struct App<'ui> {
 
 impl App<'_> {
     pub fn new() -> Result<Self> {
-        fn set_up_lua(event_call_tx: mpsc::Sender<Event>) -> mpsc::Sender<String> {
-            async fn exec_lua_command(
-                command: &str,
-                event_call_tx: mpsc::Sender<Event>,
-            ) -> Result<()> {
-                let second_event_call_tx = event_call_tx.clone();
-                let lua = LUA
-                    .get_or_init(|| {
-                        Mutex::new(generate_ci_functions(
-                            mlua::Lua::new(),
-                            second_event_call_tx,
-                        ))
-                    })
-                    .lock()
-                    .await;
-                info!("Recieved command to execute: `{}`", &command);
-                let output = lua
-                    .load(command)
-                    // FIXME this assumes string output only
-                    .eval_async::<String>()
-                    .await;
-                match output {
-                    Ok(out) => {
-                        info!("Function `{}` returned: `{}`", command, out);
-                    }
-                    Err(err) => {
-                        error!("Function `{}` returned error: `{}`", command, err);
-                        event_call_tx
-                            .send(Event::CommandEvent(
-                                Command::RaiseError(err.to_string()),
-                                None,
-                            ))
-                            .await?;
-                    }
-                };
-                Ok(())
-            }
-
+        fn set_up_lua(tx: mpsc::Sender<Event>) -> mpsc::Sender<String> {
             info!("Setting up Lua context..");
             static LUA: OnceCell<Mutex<mlua::Lua>> = OnceCell::new();
 
-            let (lua_command_tx, mut rx) = mpsc::channel::<String>(256);
+            let (lua_command_tx, mut rx) = mpsc::channel(256);
+
+            let local_set = LocalSet::new();
+            local_set.spawn_local(async move {
+                let lua = LUA
+                    .get_or_init(|| Mutex::new(generate_ci_functions(mlua::Lua::new(), tx)))
+                    .lock()
+                    .await;
+                info!("Initialized Lua context");
 
-            thread::spawn(move || {
-                let rt = Builder::new_current_thread().enable_all().build().expect(
-                    "Should always be able to build tokio runtime for lua command handling",
-                );
-                let local = LocalSet::new();
-                local.spawn_local(async move {
-                    info!("Lua command handling initialized, waiting for commands..");
                 while let Some(command) = rx.recv().await {
-                        info!("Recieved lua command: {}", &command);
-                        let local_event_call_tx = event_call_tx.clone();
-
-                        task::spawn_local(async move {
-                            exec_lua_command(&command, local_event_call_tx).await.expect("This should return all relevent errors by other messages, this should never error");
-                        });
+                    info!("Recieved command to execute: `{}`", &command);
+                    let output = lua
+                        .load(&command)
+                        // FIXME this assumes string output only
+                        .eval_async::<String>()
+                        .await
+                        .with_context(|| format!("Failed to execute: `{command}`"));
+                    info!(
+                        "Function `{}` returned: `{}`",
+                        command,
+                        output.unwrap_or("<returned error>".to_owned())
+                    );
                 }
             });
-                rt.block_on(local);
-            });
 
             lua_command_tx
         }

src/tui_app/app/status.rs

@@ -25,19 +25,6 @@ pub struct Room {
     view_scroll: Option<usize>,
 }
 
-pub struct StatusMessage {
-    content: String,
-    is_error: bool,
-}
-impl StatusMessage {
-    pub fn content(&self) -> String {
-        self.content.clone()
-    }
-    pub fn is_error(&self) -> bool {
-        self.is_error
-    }
-}
-
 pub struct Status {
     state: State,
     account_name: String,
@@ -46,7 +33,6 @@ pub struct Status {
     client: Option<Client>,
     rooms: IndexMap<String, Room>,
     current_room_id: String,
-    status_messages: Vec<StatusMessage>,
 }
 
 impl Room {
@@ -139,40 +125,14 @@ impl Status {
 
         Self {
             state: State::None,
-            account_name: "".to_owned(),
-            account_user_id: "".to_owned(),
+            account_name: "".to_string(),
+            account_user_id: "".to_string(),
             client,
             rooms,
-            current_room_id: "".to_owned(),
-            status_messages: vec![StatusMessage {
-                content: "Initialized!".to_owned(),
-                is_error: false,
-            }],
+            current_room_id: "".to_string(),
         }
     }
 
-    pub fn add_status_message(&mut self, msg: String) {
-        // TODO(@Soispha): This could allocate a lot of ram, when we don't
-        // add a limit to the messages.
-        // This needs to be proven.
-        self.status_messages.push(StatusMessage {
-            content: msg,
-            is_error: false,
-        })
-    }
-    pub fn add_error_message(&mut self, msg: String) {
-        // TODO(@Soispha): This could allocate a lot of ram, when we don't
-        // add a limit to the messages.
-        // This needs to be proven.
-        self.status_messages.push(StatusMessage {
-            content: msg,
-            is_error: true,
-        })
-    }
-    pub fn status_messages(&self) -> &Vec<StatusMessage> {
-        &self.status_messages
-    }
-
     pub fn account_name(&self) -> &String {
         &self.account_name
     }

src/tui_app/mod.rs

@@ -2,6 +2,6 @@ pub mod app;
 pub mod ui;
 pub mod accounts;
 
-//pub use app::*;
-//pub use ui::*;
-//pub use accounts::*;
+pub use app::*;
+pub use ui::*;
+pub use accounts::*;

src/tui_app/ui/central/mod.rs

@@ -11,13 +11,12 @@ use crossterm::{
 };
 use tui::{
     backend::CrosstermBackend,
-    style::Color,
     widgets::{Block, Borders, ListState},
     Terminal,
 };
 use tui_textarea::TextArea;
 
-use crate::ui::{terminal_prepare, textarea_inactivate, textarea_activate};
+use crate::ui::terminal_prepare;
 
 use super::setup;
 
@@ -29,121 +28,10 @@ pub enum InputPosition {
     Rooms,
     Messages,
     MessageCompose,
-    CommandMonitor,
     RoomInfo,
     CLI,
 }
 
-impl InputPosition {
-    // calculate to widgets colors, based of which widget is currently selected
-    pub fn colors(
-        &self,
-        mut cli: &mut Option<TextArea<'_>>,
-        mut message_compose: &mut TextArea<'_>,
-    ) -> Vec<Color> {
-        match self {
-            InputPosition::Status => {
-                textarea_inactivate(&mut message_compose);
-                if let Some(cli) = &mut cli {
-                    textarea_inactivate(cli);
-                }
-                vec![
-                    Color::White,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                ]
-            }
-            InputPosition::Rooms => {
-                textarea_inactivate(&mut message_compose);
-                if let Some(cli) = &mut cli {
-                    textarea_inactivate(cli);
-                }
-                vec![
-                    Color::DarkGray,
-                    Color::White,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                ]
-            }
-            InputPosition::Messages => {
-                textarea_inactivate(&mut message_compose);
-                if let Some(cli) = &mut cli {
-                    textarea_inactivate(cli);
-                }
-                vec![
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::White,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                ]
-            }
-            InputPosition::MessageCompose => {
-                textarea_activate(&mut message_compose);
-                if let Some(cli) = &mut cli {
-                    textarea_inactivate(cli);
-                }
-                vec![
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                ]
-            }
-            InputPosition::RoomInfo => {
-                textarea_inactivate(&mut message_compose);
-                if let Some(cli) = &mut cli {
-                    textarea_inactivate(cli);
-                }
-                vec![
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::White,
-                    Color::DarkGray,
-                ]
-            }
-            InputPosition::CLI => {
-                textarea_inactivate(&mut message_compose);
-                if let Some(cli) = &mut cli {
-                    textarea_activate(cli);
-                }
-                vec![
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                ]
-            }
-            InputPosition::CommandMonitor => {
-                textarea_inactivate(&mut message_compose);
-                if let Some(cli) = &mut cli {
-                    textarea_inactivate(cli);
-                }
-                vec![
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::DarkGray,
-                    Color::White,
-                ]
-            }
-        }
-    }
-}
-
 pub struct UI<'a> {
     terminal: Terminal<CrosstermBackend<Stdout>>,
     input_position: InputPosition,
@@ -201,8 +89,7 @@ impl UI<'_> {
             InputPosition::Status => InputPosition::Rooms,
             InputPosition::Rooms => InputPosition::Messages,
             InputPosition::Messages => InputPosition::MessageCompose,
-            InputPosition::MessageCompose => InputPosition::CommandMonitor,
-            InputPosition::CommandMonitor => InputPosition::RoomInfo,
+            InputPosition::MessageCompose => InputPosition::RoomInfo,
             InputPosition::RoomInfo => match self.cli {
                 Some(_) => InputPosition::CLI,
                 None => InputPosition::Status,
@@ -220,8 +107,7 @@ impl UI<'_> {
             InputPosition::Rooms => InputPosition::Status,
             InputPosition::Messages => InputPosition::Rooms,
             InputPosition::MessageCompose => InputPosition::Messages,
-            InputPosition::RoomInfo => InputPosition::CommandMonitor,
-            InputPosition::CommandMonitor => InputPosition::MessageCompose,
+            InputPosition::RoomInfo => InputPosition::MessageCompose,
             InputPosition::CLI => InputPosition::RoomInfo,
         };
     }
@@ -267,12 +153,12 @@ impl UI<'_> {
     }
 
     pub async fn update_setup(&mut self) -> Result<()> {
-        let setup_ui = match &mut self.setup_ui {
+        let ui = match &mut self.setup_ui {
             Some(c) => c,
             None => bail!("SetupUI instance not found"),
         };
 
-        setup_ui.update(&mut self.terminal).await?;
+        ui.update(&mut self.terminal).await?;
 
         Ok(())
     }

src/tui_app/ui/central/update/mod.rs

@@ -1,13 +1,19 @@
 use std::cmp;
 
 use anyhow::{Context, Result};
-use tui::layout::{Constraint, Direction, Layout};
+use tui::{
+    layout::{Constraint, Direction, Layout},
+    style::Color,
+};
 
-use crate::app::status::Status;
+use crate::{
+    app::status::Status,
+    ui::{textarea_activate, textarea_inactivate},
+};
 
-use self::widgets::{command_monitor, messages, room_info, rooms, status};
+use self::widgets::{messages, room_info, rooms, status};
 
-use super::UI;
+use super::{InputPosition, UI};
 
 pub mod widgets;
 
@@ -51,12 +57,90 @@ impl UI<'_> {
 
         let right_chunks = Layout::default()
             .direction(Direction::Vertical)
-            .constraints([Constraint::Length(5), Constraint::Min(4)].as_ref())
+            .constraints([Constraint::Min(4)].as_ref())
             .split(main_chunks[2]);
 
-        let colors = self
-            .input_position
-            .colors(&mut self.cli, &mut self.message_compose);
+        // calculate to widgets colors, based of which widget is currently selected
+        let colors = match self.input_position {
+            InputPosition::Status => {
+                textarea_inactivate(&mut self.message_compose);
+                if let Some(cli) = &mut self.cli {
+                    textarea_inactivate(cli);
+                }
+                vec![
+                    Color::White,
+                    Color::DarkGray,
+                    Color::DarkGray,
+                    Color::DarkGray,
+                    Color::DarkGray,
+                ]
+            }
+            InputPosition::Rooms => {
+                textarea_inactivate(&mut self.message_compose);
+                if let Some(cli) = &mut self.cli {
+                    textarea_inactivate(cli);
+                }
+                vec![
+                    Color::DarkGray,
+                    Color::White,
+                    Color::DarkGray,
+                    Color::DarkGray,
+                    Color::DarkGray,
+                ]
+            }
+            InputPosition::Messages => {
+                textarea_inactivate(&mut self.message_compose);
+                if let Some(cli) = &mut self.cli {
+                    textarea_inactivate(cli);
+                }
+                vec![
+                    Color::DarkGray,
+                    Color::DarkGray,
+                    Color::White,
+                    Color::DarkGray,
+                    Color::DarkGray,
+                ]
+            }
+            InputPosition::MessageCompose => {
+                textarea_activate(&mut self.message_compose);
+                if let Some(cli) = &mut self.cli {
+                    textarea_inactivate(cli);
+                }
+                vec![
+                    Color::DarkGray,
+                    Color::DarkGray,
+                    Color::DarkGray,
+                    Color::DarkGray,
+                    Color::DarkGray,
+                ]
+            }
+            InputPosition::RoomInfo => {
+                textarea_inactivate(&mut self.message_compose);
+                if let Some(cli) = &mut self.cli {
+                    textarea_inactivate(cli);
+                }
+                vec![
+                    Color::DarkGray,
+                    Color::DarkGray,
+                    Color::DarkGray,
+                    Color::DarkGray,
+                    Color::White,
+                ]
+            }
+            InputPosition::CLI => {
+                textarea_inactivate(&mut self.message_compose);
+                if let Some(cli) = &mut self.cli {
+                    textarea_activate(cli);
+                }
+                vec![
+                    Color::DarkGray,
+                    Color::DarkGray,
+                    Color::DarkGray,
+                    Color::DarkGray,
+                    Color::DarkGray,
+                ]
+            }
+        };
 
         // initiate the widgets
         let status_panel = status::init(status, &colors);
@@ -64,7 +148,6 @@ impl UI<'_> {
         let (messages_panel, mut messages_state) = messages::init(status.room(), &colors)
             .context("Failed to initiate the messages widget")?;
         let room_info_panel = room_info::init(status.room(), &colors);
-        let command_monitor = command_monitor::init(status.status_messages(), &colors);
 
         // render the widgets
         self.terminal.draw(|frame| {
@@ -77,7 +160,6 @@ impl UI<'_> {
                 None => (),
             };
             frame.render_widget(room_info_panel, right_chunks[0]);
-            frame.render_widget(command_monitor, right_chunks[1]);
         })?;
 
         Ok(())

src/tui_app/ui/central/update/widgets/command_monitor.rs

@@ -1,34 +0,0 @@
-use tui::{
-    layout::Alignment,
-    style::{Color, Style},
-    text::Text,
-    widgets::{Block, Borders, Paragraph},
-};
-
-use crate::{app::status::StatusMessage, ui::central::InputPosition};
-
-pub fn init<'a>(status_events: &Vec<StatusMessage>, colors: &Vec<Color>) -> Paragraph<'a> {
-    let mut command_monitor = Text::default();
-
-    status_events.iter().for_each(|event| {
-        // TODO(@Soispha): The added text (`event.content()`) doesn't wrap nicely,
-        // it would be nice if it did.
-        command_monitor.extend(Text::styled(
-            event.content(),
-            Style::default().fg(if event.is_error() {
-                Color::Red
-            } else {
-                Color::Cyan
-            }),
-        ));
-    });
-
-    Paragraph::new(command_monitor)
-        .block(
-            Block::default()
-                .title("Command Montior")
-                .borders(Borders::ALL)
-                .style(Style::default().fg(colors[InputPosition::CommandMonitor as usize])),
-        )
-        .alignment(Alignment::Center)
-}

src/tui_app/ui/central/update/widgets/mod.rs

@@ -2,4 +2,3 @@ pub mod messages;
 pub mod room_info;
 pub mod rooms;
 pub mod status;
-pub mod command_monitor;