commonware-chat 2026.4.0

use commonware_macros::select;
use commonware_p2p::{Receiver, Recipients, Sender};
use commonware_runtime::{Metrics, Spawner};
use commonware_utils::{channel::mpsc, hex, sync::Mutex};
use crossterm::{
    event::{self, Event as CEvent, KeyCode},
    execute,
    terminal::{disable_raw_mode, enable_raw_mode, EnterAlternateScreen, LeaveAlternateScreen},
};
use ratatui::{
    backend::CrosstermBackend,
    layout::{Constraint, Direction, Layout},
    style::{Color, Style},
    text::{Line, Text},
    widgets::{Block, Borders, Paragraph},
    Terminal,
};
use std::{io::stdout, str::FromStr, sync::Arc, time::Duration};
use tracing::{debug, warn};

pub const CHANNEL: u64 = 0;
const HEIGHT_OFFSET: u16 = 2;

enum Event<I> {
    Input(I),
    Tick,
}

#[derive(PartialEq, Eq)]
enum Focus {
    Input,
    Logs,
    Metrics,
    Messages,
}

pub async fn run(
    context: impl Spawner + Metrics,
    me: String,
    logs: Arc<Mutex<Vec<String>>>,
    mut sender: impl Sender,
    mut receiver: impl Receiver,
) {
    // Setup terminal
    enable_raw_mode().unwrap();
    let mut stdout = stdout();
    execute!(stdout, EnterAlternateScreen).unwrap();
    let backend = CrosstermBackend::new(stdout);
    let mut terminal = Terminal::new(backend).unwrap();

    // Listen for input
    let (tx, mut rx) = mpsc::channel(100);
    context.with_label("keyboard").spawn(|_| async move {
        loop {
            match event::poll(Duration::from_millis(500)) {
                Ok(true) => {}
                Ok(false) => {
                    if tx.send(Event::Tick).await.is_err() {
                        break;
                    }
                    continue;
                }
                Err(_) => break,
            };
            let e = match event::read() {
                Ok(e) => e,
                Err(_) => break,
            };
            if let CEvent::Key(key) = e {
                if tx.send(Event::Input(key)).await.is_err() {
                    break;
                }
            }
        }
    });

    // Application state
    let mut messages = Vec::new();
    let mut input = String::new();
    let mut cursor_visible = true;
    let mut logs_scroll_vertical: u16 = 0;
    let mut logs_scroll_horizontal: u16 = 0;
    let mut metrics_scroll_vertical: u16 = 0;
    let mut metrics_scroll_horizontal: u16 = 0;
    let mut messages_scroll_vertical: u16 = 0;
    let mut messages_scroll_horizontal: u16 = 0;
    let mut focused_window = Focus::Input;

    // Print messages received from peers
    loop {
        // Draw UI
        terminal
            .draw(|f| {
                let chunks = Layout::default()
                    .direction(Direction::Vertical)
                    .constraints([Constraint::Percentage(70), Constraint::Percentage(30)].as_ref())
                    .split(f.area());
                let horizontal_chunks = Layout::default()
                    .direction(Direction::Horizontal)
                    .constraints([Constraint::Percentage(50), Constraint::Percentage(50)].as_ref())
                    .split(chunks[0]);
                let messages_chunks = Layout::default()
                    .direction(Direction::Vertical)
                    .constraints([Constraint::Percentage(80), Constraint::Percentage(20)].as_ref())
                    .split(horizontal_chunks[0]);

                // Display messages
                let messages_height = messages_chunks[0].height - HEIGHT_OFFSET;
                let messages_len = messages.len() as u16;
                let messages_max_scroll = messages_len.saturating_sub(messages_height);
                if focused_window != Focus::Messages {
                    messages_scroll_vertical = messages_max_scroll;
                }
                let messages_text = Text::from(messages.clone());
                let messages_block = Paragraph::new(messages_text)
                    .style(Style::default().fg(Color::Cyan))
                    .block(
                        Block::default()
                            .borders(Borders::ALL)
                            .title("Messages")
                            .border_style(match focused_window {
                                Focus::Messages => Style::default().fg(Color::Red),
                                _ => Style::default(),
                            }),
                    )
                    .scroll((messages_scroll_vertical, messages_scroll_horizontal));
                f.render_widget(messages_block, messages_chunks[0]);

                // Display metrics
                let buffer = context.encode();
                let metrics_text = Text::from(buffer);
                let metrics_block = Paragraph::new(metrics_text)
                    .block(
                        Block::default()
                            .borders(Borders::ALL)
                            .title("Metrics")
                            .border_style(match focused_window {
                                Focus::Metrics => Style::default().fg(Color::Red),
                                _ => Style::default(),
                            }),
                    )
                    .scroll((metrics_scroll_vertical, metrics_scroll_horizontal));

                f.render_widget(metrics_block, horizontal_chunks[1]);

                // Display input
                //
                // Show or hide the cursor in the input block
                let input_with_cursor = if cursor_visible {
                    format!("> {input}_")
                } else {
                    format!("> {input}")
                };
                let input_block = Paragraph::new(input_with_cursor)
                    .style(Style::default().fg(Color::Yellow))
                    .block(
                        Block::default()
                            .borders(Borders::ALL)
                            .title("Input (TAB to switch panes | ESC to quit | ENTER to send)")
                            .border_style(match focused_window {
                                Focus::Input => Style::default().fg(Color::Red),
                                _ => Style::default(),
                            }),
                    );
                f.render_widget(input_block, messages_chunks[1]);

                // Display logs
                let logs_height = chunks[1].height - HEIGHT_OFFSET;
                let logs = logs.lock();
                let logs_len = logs.len() as u16;
                let logs_max_scroll = logs_len.saturating_sub(logs_height);
                if focused_window != Focus::Logs {
                    logs_scroll_vertical = logs_max_scroll;
                }
                let logs_text = Text::from(
                    logs.iter()
                        .map(|log| Line::raw(log.clone()))
                        .collect::<Vec<Line<'_>>>(),
                );
                let logs_block = Paragraph::new(logs_text)
                    .block(
                        Block::default()
                            .borders(Borders::ALL)
                            .title("Logs")
                            .border_style(match focused_window {
                                Focus::Logs => Style::default().fg(Color::Red),
                                _ => Style::default(),
                            }),
                    )
                    .scroll((logs_scroll_vertical, logs_scroll_horizontal));
                f.render_widget(logs_block, chunks[1]);
            })
            .unwrap();

        // Handle input
        let formatted_me = format!("{}**{}", &me[..4], &me[me.len() - 4..]);
        select! {
            event = rx.recv() => {
                let event = match event {
                    Some(event) => event,
                    None => break,
                };
                match event {
                    Event::Input(event) => match event.code {
                        KeyCode::Char(c) => {
                            input.push(c);
                        }
                        KeyCode::Backspace => {
                            input.pop();
                        }
                        KeyCode::Tab => {
                            focused_window = match focused_window {
                                Focus::Input => Focus::Logs,
                                Focus::Logs => Focus::Metrics,
                                Focus::Metrics => Focus::Messages,
                                Focus::Messages => Focus::Input,
                            };
                        }
                        KeyCode::Up => match focused_window {
                            Focus::Logs => {
                                logs_scroll_vertical = logs_scroll_vertical.saturating_sub(1)
                            }
                            Focus::Metrics => {
                                metrics_scroll_vertical = metrics_scroll_vertical.saturating_sub(1)
                            }
                            Focus::Messages => {
                                messages_scroll_vertical =
                                    messages_scroll_vertical.saturating_sub(1)
                            }
                            _ => {}
                        },
                        KeyCode::Down => match focused_window {
                            Focus::Logs => {
                                logs_scroll_vertical = logs_scroll_vertical.saturating_add(1)
                            }
                            Focus::Metrics => {
                                metrics_scroll_vertical = metrics_scroll_vertical.saturating_add(1)
                            }
                            Focus::Messages => {
                                messages_scroll_vertical =
                                    messages_scroll_vertical.saturating_add(1)
                            }
                            _ => {}
                        },
                        KeyCode::Left => match focused_window {
                            Focus::Logs => {
                                logs_scroll_horizontal = logs_scroll_horizontal.saturating_sub(1)
                            }
                            Focus::Metrics => {
                                metrics_scroll_horizontal =
                                    metrics_scroll_horizontal.saturating_sub(1)
                            }
                            Focus::Messages => {
                                messages_scroll_horizontal =
                                    messages_scroll_horizontal.saturating_sub(1)
                            }
                            _ => {}
                        },
                        KeyCode::Right => match focused_window {
                            Focus::Logs => {
                                logs_scroll_horizontal = logs_scroll_horizontal.saturating_add(1)
                            }
                            Focus::Metrics => {
                                metrics_scroll_horizontal =
                                    metrics_scroll_horizontal.saturating_add(1)
                            }
                            Focus::Messages => {
                                messages_scroll_horizontal =
                                    messages_scroll_horizontal.saturating_add(1)
                            }
                            _ => {}
                        },
                        KeyCode::Enter => {
                            if input.is_empty() {
                                continue;
                            }
                            let mut successful = sender
                                .send(Recipients::All, input.as_bytes().to_vec(), false)
                                .await
                                .expect("failed to send message");
                            if !successful.is_empty() {
                                successful.sort();
                                let mut friends = String::from_str("[").unwrap();
                                for friend in successful {
                                    friends.push_str(&format!("{friend:?},"));
                                }
                                friends.pop();
                                friends.push(']');
                                debug!(friends, input, "sent message");
                            } else {
                                warn!(input, "dropped message");
                            }
                            let msg = Line::styled(
                                format!(
                                    "[{}] {}: {}",
                                    chrono::Local::now().format("%m/%d %H:%M:%S"),
                                    formatted_me,
                                    input,
                                ),
                                Style::default().fg(Color::Yellow),
                            );
                            messages.push(msg);
                            input = String::new();
                        }
                        KeyCode::Esc => {
                            disable_raw_mode().unwrap();
                            execute!(terminal.backend_mut(), LeaveAlternateScreen).unwrap();
                            terminal.show_cursor().unwrap();
                            break;
                        }
                        _ => {}
                    },
                    Event::Tick => {
                        cursor_visible = !cursor_visible;
                    }
                }
            },
            result = receiver.recv() => match result {
                Ok((peer, msg)) => {
                    let peer = hex(&peer);
                    messages.push(
                        format!(
                            "[{}] {}**{}: {}",
                            chrono::Local::now().format("%m/%d %H:%M:%S"),
                            &peer[..4],
                            &peer[peer.len() - 4..],
                            String::from_utf8_lossy(msg.as_ref())
                        )
                        .into(),
                    );
                }
                Err(err) => {
                    debug!(?err, "failed to receive message");
                    continue;
                }
            },
        };
    }
}