1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232
use std::{
any::Any,
cell::RefCell,
io::Write,
marker::PhantomData,
rc::Rc,
sync::mpsc::{channel, Receiver, Sender},
time::Duration,
};
use crossterm::{
cursor,
event::{Event, KeyCode, KeyEventKind},
execute, queue, terminal,
};
use crate::{
container::{Callable, Container, FromContainer, Res, State},
context::ViewContext,
view::View,
};
use super::input::Keyboard;
/// A renderer that can signal a render needs to take place.
pub struct Renderer {
tx: Sender<()>,
}
impl Renderer {
pub fn render(&self) {
let _ = self.tx.send(());
}
}
/// The app is the core container for the application logic, resources,
/// state, and run loop.
pub struct App<F, Args>
where
F: Callable<Args>,
Args: FromContainer,
{
container: Rc<RefCell<Container>>,
main_view: View,
render_signal: Receiver<()>,
render_tx: Sender<()>,
root: F,
args: PhantomData<Args>,
}
impl<F, Args> App<F, Args>
where
F: Callable<Args>,
Args: FromContainer,
{
/// Constructs a new App objcet. This object uses a builder pattern and
/// should be finalized with App::run(). which will start a blocking run
/// loop and perform the initial screen setup and render.
pub fn new(root: F) -> App<F, Args> {
let container = Rc::new(RefCell::new(Container::default()));
let size = terminal::size().unwrap();
let main_view = View::new(size);
let (render_tx, render_signal) = channel();
App {
container,
root,
main_view,
render_tx,
render_signal,
args: PhantomData,
}
}
/// Returns a renderer that can signal the application to rerender. This
/// renderer can be cloned and passed between threads.
pub fn get_renderer(&self) -> Renderer {
Renderer {
tx: self.render_tx.clone(),
}
}
/// Insert a resource which can be injected into component functions.
///
/// This resource can only be accessed immutably by reference.
/// Interior mutability must be used for anything that requires an internal
/// state.
///
/// Example:
/// ```
/// use arkham::prelude::*;
/// struct MyResource {
/// value: i32
/// }
///
/// fn main() {
/// App::new(root).insert_resource(MyResource { value: 12 });
/// }
///
/// fn root(ctx: &mut ViewContext, thing: Res<MyResource>) {
/// ctx.insert(0,format!("Value is {}", thing.value));
/// }
/// ````
/// Alternatively, App::insert_state can be used to insert a state object,
/// that can be borrowed mutable.
pub fn insert_resource<T: Any>(self, v: T) -> Self {
self.container.borrow_mut().bind(Res::new(v));
self
}
/// Insert a stateful object that can be injected into component functions
/// unlike App::insert_resource, this value can be borrowed mutably and
/// is meant to store application state.
///
/// Example:
/// ```
/// use arkham::prelude::*;
/// struct MyState {
/// value: i32
/// }
///
/// fn main() {
/// App::new(root).insert_state(MyState { value: 12 });
/// }
///
/// fn root(ctx: &mut ViewContext, thing: State<MyState>) {
/// thing.get_mut().value += 1;
/// ctx.insert(0,format!("Value is {}", thing.get().value));
/// }
/// ````
pub fn insert_state<T: Any>(self, v: T) -> Self {
self.container.borrow_mut().bind(State::new(v));
self
}
/// Repairs the terminal state so it operates properly.
fn teardown(&self) {
let mut out = std::io::stdout();
let _ = terminal::disable_raw_mode();
let _ = execute!(out, terminal::LeaveAlternateScreen, cursor::Show);
}
/// Executes the main run loop. This should be called to start the
/// application logic.
///
/// This function will block while it reads events and performs render
/// cycles.
pub fn run(&mut self) -> anyhow::Result<()> {
self.container.borrow_mut().bind(Res::new(Terminal));
self.container.borrow_mut().bind(Res::new(Keyboard::new()));
let _ = ctrlc::set_handler(|| {
let mut out = std::io::stdout();
let _ = terminal::disable_raw_mode();
let _ = execute!(out, terminal::LeaveAlternateScreen, cursor::Show);
std::process::exit(0);
});
let mut out = std::io::stdout();
execute!(out, terminal::EnterAlternateScreen, cursor::Hide)?;
terminal::enable_raw_mode()?;
loop {
loop {
let mut context =
ViewContext::new(self.container.clone(), terminal::size().unwrap().into());
self.root
.call(&mut context, Args::from_container(&self.container.borrow()));
self.main_view.apply((0, 0), &context.view);
self.render()?;
if !context.rerender {
break;
}
}
self.container
.borrow()
.get::<Res<Keyboard>>()
.unwrap()
.reset();
if crossterm::event::poll(Duration::from_millis(100)).unwrap_or(false) {
if let Ok(event) = crossterm::event::read() {
match event {
Event::FocusGained => self.render()?,
Event::FocusLost => {}
Event::Key(key_event) if key_event.code == KeyCode::Char('q') => {
break;
}
Event::Key(key_event) if key_event.kind == KeyEventKind::Press => {
let container = self.container.borrow();
let kb = container.get::<Res<Keyboard>>().unwrap();
kb.set_key(key_event.code);
}
Event::Mouse(_) => todo!(),
Event::Paste(_) => todo!(),
Event::Resize(_, _) => self.render()?,
_ => {}
}
}
}
if self.render_signal.try_recv().is_ok() {
self.render()?;
}
}
self.teardown();
Ok(())
}
fn render(&mut self) -> anyhow::Result<()> {
let mut out = std::io::stdout();
for (row, line) in self.main_view.iter().enumerate() {
for (col, rune) in line.iter().enumerate() {
queue!(out, cursor::MoveTo(col as u16, row as u16))?;
rune.render(&mut out)?;
}
}
out.flush()?;
Ok(())
}
}
pub struct Terminal;
impl Terminal {
pub fn set_title(&self, name: &str) {
let _ = execute!(std::io::stdout(), terminal::SetTitle(name));
}
pub fn size(&self) -> (u16, u16) {
crossterm::terminal::size().unwrap_or_default()
}
}