{"header":{"message":"feat: add testapp","description":null,"timestamp":"2024-04-10T14:03:27.50104Z","authors":[{}]},"hash":"E72A4G7AN4VCNI2PICW2I4AY3KR2EOF6YQBDI4OMYJU3LR2DPSEQC","authors":[{"login":"Jengamon","key":"AFEuLzv5ecUJzaewFwoWh4jeCDqWZztr7dswYwyG9vfU"}],"deps":{"hashes":[["E72A4G7AN4VCNI2PICW2I4AY3KR2EOF6YQBDI4OMYJU3LR2DPSEQC","feat: add testapp"],["AA",null],["AVECOIN4RCRERCC2XE6ACFIZNAHQN3XF6YYJJ2BYKFE2VKL3CFAQC",""]],"deps":["AVECOIN4RCRERCC2XE6ACFIZNAHQN3XF6YYJJ2BYKFE2VKL3CFAQC"],"known":[]},"hunks":[{"FileAdd":{"meta":{"basename":"testapp","metadata":576},"context":[{"change":2,"pos":1}],"contents":[]}},{"FileAdd":{"meta":{"basename":"src","metadata":576},"context":[{"change":0,"pos":19}],"contents":[]}},{"FileAdd":{"meta":{"basename":"ui.rs","metadata":0},"context":[{"change":0,"pos":36}],"contents":[{"Add":"use std::{"},{"Add":" io::{self, Stdout},"},{"Add":" time::Duration,"},{"Add":"};"},{"Add":""},{"Add":"use anyhow::Context as _;"},{"Add":"use crossterm::{"},{"Add":" event::{DisableMouseCapture, EnableMouseCapture, Event, EventStream},"},{"Add":" execute,"},{"Add":" terminal::{disable_raw_mode, enable_raw_mode, EnterAlternateScreen, LeaveAlternateScreen},"},{"Add":"};"},{"Add":"use ratatui::{backend::CrosstermBackend, Terminal};"},{"Add":"use tokio::sync::{"},{"Add":" broadcast,"},{"Add":" mpsc::{self, UnboundedReceiver, UnboundedSender},"},{"Add":"};"},{"Add":"use tokio_stream::StreamExt;"},{"Add":""},{"Add":"use crate::{"},{"Add":" state::{Action, State},"},{"Add":" termination::Interrupted,"},{"Add":"};"},{"Add":""},{"Add":"use self::components::{Component, ComponentRender};"},{"Add":""},{"Add":"mod components;"},{"Add":"mod pages;"},{"Add":"pub use pages::AppRouter;"},{"Add":""},{"Add":"const RENDERING_TICK_RATE: Duration = Duration::from_millis(250);"},{"Add":""},{"Add":"pub struct UiManager {"},{"Add":" action_tx: mpsc::UnboundedSender,"},{"Add":"}"},{"Add":""},{"Add":"impl UiManager {"},{"Add":" pub fn new() -> (Self, UnboundedReceiver) {"},{"Add":" let (action_tx, action_rx) = mpsc::unbounded_channel();"},{"Add":""},{"Add":" (Self { action_tx }, action_rx)"},{"Add":" }"},{"Add":""},{"Add":" pub async fn main_loop + Component>("},{"Add":" self,"},{"Add":" mut state_rx: UnboundedReceiver,"},{"Add":" mut interrupt_rx: broadcast::Receiver,"},{"Add":" ) -> anyhow::Result {"},{"Add":" let mut app_router = {"},{"Add":" let state = state_rx.recv().await.unwrap();"},{"Add":""},{"Add":" Router::new(&state, self.action_tx.clone())"},{"Add":" };"},{"Add":""},{"Add":" let mut terminal = setup_terminal()?;"},{"Add":" let mut ticker = tokio::time::interval(RENDERING_TICK_RATE);"},{"Add":" let mut crossterm_events = EventStream::new();"},{"Add":""},{"Add":" let result: anyhow::Result = loop {"},{"Add":" tokio::select! {"},{"Add":" // Tick"},{"Add":" _ = ticker.tick() => (),"},{"Add":" // Catch and handle crossterm events"},{"Add":" maybe_event = crossterm_events.next() => match maybe_event {"},{"Add":" Some(Ok(Event::Key(key))) => {"},{"Add":" app_router.handle_key_event(key);"},{"Add":" }"},{"Add":" Some(Ok(Event::Mouse(mouse))) => {"},{"Add":" app_router.handle_mouse_event(mouse);"},{"Add":" }"},{"Add":" None => break Ok(Interrupted::UserInt),"},{"Add":" _ => (),"},{"Add":" },"},{"Add":" // Handle state updates"},{"Add":" Some(state) = state_rx.recv() => {"},{"Add":" app_router = app_router.move_with_state(&state);"},{"Add":" },"},{"Add":" // Catch and handle interrupt signal"},{"Add":" Ok(interrupted) = interrupt_rx.recv() => {"},{"Add":" break Ok(interrupted);"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" if let Err(err) = terminal"},{"Add":" .draw(|frame| app_router.render(frame, ()))"},{"Add":" .context(\"could not render to the terminal\")"},{"Add":" {"},{"Add":" break Err(err);"},{"Add":" }"},{"Add":" };"},{"Add":""},{"Add":" restore_terminal(&mut terminal);"},{"Add":""},{"Add":" result"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"fn setup_terminal() -> anyhow::Result>> {"},{"Add":" let mut stdout = io::stdout();"},{"Add":""},{"Add":" enable_raw_mode()?;"},{"Add":""},{"Add":" execute!(stdout, EnterAlternateScreen, EnableMouseCapture)?;"},{"Add":""},{"Add":" Ok(Terminal::new(CrosstermBackend::new(stdout))?)"},{"Add":"}"},{"Add":""},{"Add":"fn restore_terminal(terminal: &mut Terminal>) -> anyhow::Result<()> {"},{"Add":" disable_raw_mode()?;"},{"Add":""},{"Add":" execute!("},{"Add":" terminal.backend_mut(),"},{"Add":" LeaveAlternateScreen,"},{"Add":" DisableMouseCapture,"},{"Add":" )?;"},{"Add":""},{"Add":" Ok(terminal.show_cursor()?)"},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"ui","metadata":576},"context":[{"change":0,"pos":36}],"contents":[]}},{"FileAdd":{"meta":{"basename":"pages.rs","metadata":0},"context":[{"change":0,"pos":3460}],"contents":[{"Add":"use crossterm::event::{KeyCode, KeyEvent};"},{"Add":"use ratatui::{"},{"Add":" layout::{Constraint, Direction, Layout},"},{"Add":" widgets::Paragraph,"},{"Add":"};"},{"Add":"use tokio::sync::mpsc::UnboundedSender;"},{"Add":""},{"Add":"use crate::state::{Action, State};"},{"Add":""},{"Add":"use super::components::{Component, ComponentRender};"},{"Add":""},{"Add":"enum ActivePage {"},{"Add":" MainPage,"},{"Add":"}"},{"Add":""},{"Add":"struct Props {"},{"Add":" active_page: ActivePage,"},{"Add":"}"},{"Add":""},{"Add":"impl From<&State> for Props {"},{"Add":" fn from(state: &State) -> Self {"},{"Add":" Self {"},{"Add":" active_page: ActivePage::MainPage,"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"pub struct AppRouter {"},{"Add":" props: Props,"},{"Add":" // ..pages"},{"Add":" action_tx: UnboundedSender,"},{"Add":"}"},{"Add":""},{"Add":"impl Component for AppRouter {"},{"Add":" fn new(state: &State, action_tx: UnboundedSender) -> Self"},{"Add":" where"},{"Add":" Self: Sized,"},{"Add":" {"},{"Add":" Self {"},{"Add":" props: Props::from(state),"},{"Add":" action_tx,"},{"Add":" }"},{"Add":" .move_with_state(state)"},{"Add":" }"},{"Add":""},{"Add":" fn move_with_state(self, state: &State) -> Self"},{"Add":" where"},{"Add":" Self: Sized,"},{"Add":" {"},{"Add":" Self {"},{"Add":" props: Props::from(state),"},{"Add":" ..self"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" fn name(&self) -> &str {"},{"Add":" \"Main Screen\""},{"Add":" }"},{"Add":""},{"Add":" fn handle_key_event(&mut self, key: KeyEvent) {"},{"Add":" #[allow(clippy::single_match)]"},{"Add":" match key.code {"},{"Add":" KeyCode::Char('q') => {"},{"Add":" let _ = self.action_tx.send(Action::Exit);"},{"Add":" }"},{"Add":" _ => {}"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl ComponentRender<()> for AppRouter {"},{"Add":" fn render(&self, frame: &mut ratatui::prelude::Frame, _props: ()) {"},{"Add":" frame.render_widget(Paragraph::new(\"Press q to exit.\"), frame.size());"},{"Add":" }"},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"components.rs","metadata":0},"context":[{"change":0,"pos":3460}],"contents":[{"Add":"use crossterm::event::{KeyEvent, MouseEvent};"},{"Add":"use ratatui::prelude::Frame;"},{"Add":"use tokio::sync::mpsc::UnboundedSender;"},{"Add":""},{"Add":"use crate::state::{Action, State};"},{"Add":""},{"Add":"pub trait Component {"},{"Add":" fn new(state: &State, action_tx: UnboundedSender) -> Self"},{"Add":" where"},{"Add":" Self: Sized;"},{"Add":" fn move_with_state(self, state: &State) -> Self"},{"Add":" where"},{"Add":" Self: Sized;"},{"Add":""},{"Add":" fn name(&self) -> &str;"},{"Add":""},{"Add":" fn handle_key_event(&mut self, _key: KeyEvent) {}"},{"Add":" fn handle_mouse_event(&mut self, _mouse: MouseEvent) {}"},{"Add":"}"},{"Add":""},{"Add":"pub trait ComponentRender {"},{"Add":" fn render(&self, frame: &mut Frame, props: Props);"},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"termination.rs","metadata":0},"context":[{"change":0,"pos":36}],"contents":[{"Add":"#[cfg(unix)]"},{"Add":"use tokio::signal::unix::signal;"},{"Add":"use tokio::sync::broadcast;"},{"Add":""},{"Add":"#[derive(Debug, Clone)]"},{"Add":"pub enum Interrupted {"},{"Add":" OsSigInt,"},{"Add":" UserInt,"},{"Add":"}"},{"Add":""},{"Add":"#[derive(Debug, Clone)]"},{"Add":"pub struct Terminator {"},{"Add":" interrupt_tx: broadcast::Sender,"},{"Add":"}"},{"Add":""},{"Add":"impl Terminator {"},{"Add":" pub fn new(interrupt_tx: broadcast::Sender) -> Self {"},{"Add":" Self { interrupt_tx }"},{"Add":" }"},{"Add":""},{"Add":" pub fn terminate(&mut self, interrupted: Interrupted) -> anyhow::Result<()> {"},{"Add":" self.interrupt_tx.send(interrupted)?;"},{"Add":""},{"Add":" Ok(())"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"#[cfg(unix)]"},{"Add":"async fn terminate_by_unix_signal(mut terminator: Terminator) {"},{"Add":" let mut interrupt_signal = signal(tokio::signal::unix::SignalKind::interrupt())"},{"Add":" .expect(\"failed to create interrupt signal stream\");"},{"Add":""},{"Add":" interrupt_signal.recv().await;"},{"Add":""},{"Add":" terminator"},{"Add":" .terminate(Interrupted::OsSigInt)"},{"Add":" .expect(\"failed to send interrupt signal\");"},{"Add":"}"},{"Add":""},{"Add":"/// Create a broadcast channel for retrieving the application kill signal"},{"Add":"pub fn create_termination() -> (Terminator, broadcast::Receiver) {"},{"Add":" let (tx, rx) = broadcast::channel(1);"},{"Add":" let terminator = Terminator::new(tx);"},{"Add":""},{"Add":" #[cfg(unix)]"},{"Add":" tokio::spawn(terminate_by_unix_signal(terminator.clone()));"},{"Add":""},{"Add":" (terminator, rx)"},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"state.rs","metadata":0},"context":[{"change":0,"pos":36}],"contents":[{"Add":"pub mod action;"},{"Add":"pub mod store;"},{"Add":""},{"Add":"pub use self::{action::Action, store::StateStore};"},{"Add":""},{"Add":"#[derive(Debug, Clone)]"},{"Add":"pub struct State {"},{"Add":" pub counter: usize,"},{"Add":"}"},{"Add":""},{"Add":"impl Default for State {"},{"Add":" fn default() -> Self {"},{"Add":" Self { counter: 0 }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl State {"},{"Add":" fn upcount(&mut self) {"},{"Add":" self.counter += 1;"},{"Add":" }"},{"Add":""},{"Add":" fn downcount(&mut self) {"},{"Add":" self.counter -= 1;"},{"Add":" }"},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"state","metadata":576},"context":[{"change":0,"pos":36}],"contents":[]}},{"FileAdd":{"meta":{"basename":"store.rs","metadata":0},"context":[{"change":0,"pos":7412}],"contents":[{"Add":"use tokio::sync::{"},{"Add":" broadcast,"},{"Add":" mpsc::{self, UnboundedReceiver, UnboundedSender},"},{"Add":"};"},{"Add":""},{"Add":"use crate::termination::{Interrupted, Terminator};"},{"Add":""},{"Add":"use super::{Action, State};"},{"Add":""},{"Add":"pub struct StateStore {"},{"Add":" state_tx: UnboundedSender,"},{"Add":"}"},{"Add":""},{"Add":"impl StateStore {"},{"Add":" pub fn new() -> (Self, UnboundedReceiver) {"},{"Add":" let (state_tx, state_rx) = mpsc::unbounded_channel::();"},{"Add":""},{"Add":" (StateStore { state_tx }, state_rx)"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl StateStore {"},{"Add":" pub async fn main_loop("},{"Add":" self,"},{"Add":" mut terminator: Terminator,"},{"Add":" mut action_rx: UnboundedReceiver,"},{"Add":" mut interrupt_rx: broadcast::Receiver,"},{"Add":" ) -> anyhow::Result {"},{"Add":" let mut state = State::default();"},{"Add":""},{"Add":" self.state_tx.send(state.clone())?;"},{"Add":""},{"Add":" let result = loop {"},{"Add":" tokio::select! {"},{"Add":" Some(action) = action_rx.recv() => match action {"},{"Add":" Action::IncCounter => {"},{"Add":" state.upcount();"},{"Add":" },"},{"Add":" Action::DecCounter => {"},{"Add":" state.downcount();"},{"Add":" },"},{"Add":" Action::Exit => {"},{"Add":" let _ = terminator.terminate(Interrupted::UserInt);"},{"Add":""},{"Add":" break Interrupted::UserInt;"},{"Add":" }"},{"Add":" },"},{"Add":" Ok(interrupted) = interrupt_rx.recv() => {"},{"Add":" break interrupted;"},{"Add":" }"},{"Add":" }"},{"Add":" };"},{"Add":""},{"Add":" Ok(result)"},{"Add":" }"},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"action.rs","metadata":0},"context":[{"change":0,"pos":7412}],"contents":[{"Add":"#[derive(Debug, Clone)]"},{"Add":"pub enum Action {"},{"Add":" IncCounter,"},{"Add":" DecCounter,"},{"Add":" Exit,"},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"main.rs","metadata":0},"context":[{"change":0,"pos":36}],"contents":[{"Add":"use crate::{"},{"Add":" state::StateStore,"},{"Add":" termination::{create_termination, Interrupted},"},{"Add":" ui::{AppRouter, UiManager},"},{"Add":"};"},{"Add":""},{"Add":"mod state;"},{"Add":"mod termination;"},{"Add":"mod ui;"},{"Add":""},{"Add":"#[tokio::main]"},{"Add":"async fn main() -> anyhow::Result<()> {"},{"Add":" let (terminator, mut interrupt_rx) = create_termination();"},{"Add":" let (state_store, state_rx) = StateStore::new();"},{"Add":" let (ui_manager, action_rx) = UiManager::new();"},{"Add":""},{"Add":" tokio::try_join!("},{"Add":" state_store.main_loop(terminator, action_rx, interrupt_rx.resubscribe()),"},{"Add":" ui_manager.main_loop::(state_rx, interrupt_rx.resubscribe()),"},{"Add":" )?;"},{"Add":""},{"Add":" if let Ok(reason) = interrupt_rx.recv().await {"},{"Add":" match reason {"},{"Add":" Interrupted::UserInt => eprintln!(\"exited per user request\"),"},{"Add":" Interrupted::OsSigInt => eprintln!(\"exited because of OS sigint\"),"},{"Add":" }"},{"Add":" } else {"},{"Add":" println!(\"exited because of an unexpected error\");"},{"Add":" }"},{"Add":""},{"Add":" Ok(())"},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"Cargo.toml","metadata":0},"context":[{"change":0,"pos":19}],"contents":[{"Add":"[package]"},{"Add":"name = \"testapp\""},{"Add":"edition = \"2021\""},{"Add":"version.workspace = true"},{"Add":""},{"Add":"# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html"},{"Add":""},{"Add":"[dependencies]"},{"Add":"anyhow = \"1.0.82\""},{"Add":"crossterm = { version = \"0.27.0\", features = [\"event-stream\"] }"},{"Add":"rand = \"0.8.5\""},{"Add":"ratatui = \"0.26.1\""},{"Add":"tokio = { version = \"1.37.0\", features = [\"rt-multi-thread\", \"time\", \"net\", \"macros\", \"signal\", \"sync\"] }"},{"Add":"tokio-stream = \"0.1.15\""}]}}],"owner":"Jengamon","repo":"magister_engine","token":"nRaKVJueXwDawhTjwdCAZ3caKXKARVDtUvgHTtkiwNw=","login":null}

…

Dependencies

Change contents