1use std::time::Duration;
4
5use ratatui_core::buffer::Buffer;
6use ratatui_core::layout::Rect as BufferRect;
7use ratatui_core::style::{Color, Modifier};
8
9use super::app::App;
10use super::detached::DetachedOutcome;
11use super::engine::{Engine, TaskMode};
12use super::handoff::{HandoffOutcome, HandoffRequest};
13use super::open::{OpenOutcome, OpenRequest};
14use super::termination::Termination;
15use crate::color::{ColorDepth, Rgb};
16use crate::env::Env;
17use crate::event::{Event, KeyEvent, MouseButton, MouseEvent, MouseKind};
18use crate::icons::GlyphMode;
19use crate::keymap::Modifiers;
20
21const KEY_INTERVAL: Duration = Duration::from_millis(150);
24
25pub struct Harness<A: App> {
32 engine: Engine<A>,
33 buffer: Buffer,
34 now: Duration,
35}
36
37impl<A: App> Harness<A> {
38 pub fn new(app: A, width: u16, height: u16) -> Self {
44 Self::with_env(app, Env::builtin(), width, height)
45 }
46
47 pub fn with_env(app: A, env: Env, width: u16, height: u16) -> Self {
49 let mut harness = Self {
50 engine: Engine::new(app, env, TaskMode::Inline),
51 buffer: Buffer::empty(BufferRect::new(0, 0, width, height)),
52 now: Duration::ZERO,
53 };
54 harness.render();
55 harness
56 }
57
58 pub fn render(&mut self) -> &mut Self {
60 self.settle_tasks();
61 self.engine.render(&mut self.buffer, self.now);
62 for _ in 0..3 {
64 let due = self.engine.deadline().is_some_and(|deadline| deadline <= self.now);
65 if !self.engine.dirty && !due {
66 break;
67 }
68 self.engine.render(&mut self.buffer, self.now);
69 }
70 self
71 }
72
73 fn settle_tasks(&mut self) {
78 self.engine.run_queued_work();
79 loop {
80 self.engine.task_clock.settle(self.now);
81 if self.engine.poll_tasks() == 0 {
82 break;
83 }
84 }
85 }
86
87 pub fn send(&mut self, message: A::Msg) -> &mut Self {
89 self.engine.update(message);
90 self.render()
91 }
92
93 pub fn press(&mut self, chord: &str) -> &mut Self {
95 self.now += KEY_INTERVAL;
96 self.engine.handle(Event::Key(KeyEvent::press(chord)), self.now);
97 self.render()
98 }
99
100 pub fn type_text(&mut self, text: &str) -> &mut Self {
102 for c in text.chars() {
103 let chord = match c {
104 ' ' => "space".to_owned(),
105 '+' => "+".to_owned(),
106 c if c.is_uppercase() => format!("shift+{}", c.to_lowercase()),
107 c => c.to_string(),
108 };
109 self.press(&chord);
110 }
111 self
112 }
113
114 pub fn events(&mut self, events: &[Event]) -> &mut Self {
119 for event in events {
120 self.engine.handle(event.clone(), self.now);
121 }
122 self.render()
123 }
124
125 #[cfg(test)]
127 pub(crate) fn inject(&mut self, event: Event, at: Duration) -> &mut Self {
128 self.engine.handle(event, at);
129 self.render()
130 }
131
132 pub fn paste(&mut self, text: &str) -> &mut Self {
134 self.engine.handle(Event::Paste(text.to_owned()), self.now);
135 self.render()
136 }
137
138 pub fn click(&mut self, x: i32, y: i32) -> &mut Self {
140 self.mouse(MouseKind::Down(MouseButton::Left), x, y);
141 self.mouse(MouseKind::Up(MouseButton::Left), x, y)
142 }
143
144 pub fn click_text(&mut self, text: &str) -> &mut Self {
150 let (x, y) = self.find(text).unwrap_or_else(|| panic!("`{text}` is not on screen:\n{}", self.screen()));
151 self.click(x, y)
152 }
153
154 pub fn drag(&mut self, from: (i32, i32), to: (i32, i32)) -> &mut Self {
156 self.mouse(MouseKind::Down(MouseButton::Left), from.0, from.1);
157 self.mouse(MouseKind::Drag(MouseButton::Left), to.0, to.1);
158 self.mouse(MouseKind::Up(MouseButton::Left), to.0, to.1)
159 }
160
161 pub fn hover(&mut self, x: i32, y: i32) -> &mut Self {
163 self.mouse(MouseKind::Moved, x, y)
164 }
165
166 pub fn mouse(&mut self, kind: MouseKind, x: i32, y: i32) -> &mut Self {
168 self.engine.handle(Event::Mouse(MouseEvent { kind, x, y, mods: Modifiers::default() }), self.now);
169 self.render()
170 }
171
172 pub fn advance(&mut self, duration: Duration) -> &mut Self {
181 self.now += duration;
182 self.engine.tick(self.now);
183 self.engine.end_when_due(self.now);
184 self.render()
185 }
186
187 pub fn terminate(&mut self, cause: Termination) -> &mut Self {
224 self.engine.terminate(cause, self.now);
225 self.render()
226 }
227
228 pub fn key(&mut self, event: KeyEvent) -> &mut Self {
233 self.engine.handle(Event::Key(event), self.now);
234 self.render()
235 }
236
237 pub fn set_theme(&mut self, id: &str) -> &mut Self {
239 self.engine.env.set_theme(id);
240 self.render()
241 }
242
243 pub fn set_locale(&mut self, code: &str) -> &mut Self {
245 self.engine.env.set_locale(code);
246 self.render()
247 }
248
249 pub fn set_region(&mut self, region: Option<&str>) -> &mut Self {
251 self.engine.env.set_region(region);
252 self.render()
253 }
254
255 pub fn set_reduced_motion(&mut self, reduced: bool) -> &mut Self {
257 self.engine.env.set_reduced_motion(reduced);
258 self.render()
259 }
260
261 pub fn set_depth(&mut self, depth: ColorDepth) -> &mut Self {
265 self.engine.env.set_depth(depth);
266 self.render()
267 }
268
269 pub fn set_glyph_mode(&mut self, mode: GlyphMode) -> &mut Self {
271 self.engine.env.set_glyph_mode(mode);
272 self.render()
273 }
274
275 pub fn resize(&mut self, width: u16, height: u16) -> &mut Self {
279 self.buffer = Buffer::empty(BufferRect::new(0, 0, width, height));
280 self.engine.dirty = true;
281 self.render()
282 }
283
284 #[must_use]
287 pub fn screen(&self) -> String {
288 let mut out = String::new();
289 for y in 0..self.buffer.area.height {
290 out.push_str(self.row(y).0.trim_end());
291 out.push('\n');
292 }
293 out
294 }
295
296 #[must_use]
299 pub fn html(&self, caption: &str) -> String {
300 let area = self.buffer.area;
301 let escape = |text: &str| text.replace('&', "&").replace('<', "<").replace('>', ">");
302 let css = |color: Color| rgb(color).map_or_else(|| "inherit".to_owned(), |c| c.to_string());
303 let mut out = format!("<figure><figcaption>{}</figcaption><div class=\"screen\">", escape(caption));
304 for y in 0..area.height {
305 out.push_str("<div class=\"row\">");
306 for x in visible_columns(&self.buffer, y) {
307 let cell = &self.buffer[(x, y)];
308 let modifier = cell.modifier;
309 let weight = if modifier.contains(Modifier::BOLD) { "font-weight:700;" } else { "" };
310 let style = if modifier.contains(Modifier::ITALIC) { "font-style:italic;" } else { "" };
311 let line = if modifier.contains(Modifier::UNDERLINED) { "text-decoration:underline;" } else { "" };
312 out.push_str(&format!(
313 "<span style=\"color:{};background:{};width:{}ch;{weight}{style}{line}\">{}</span>",
314 css(cell.fg),
315 css(cell.bg),
316 crate::text::width(cell.symbol()).max(1),
317 escape(cell.symbol())
318 ));
319 }
320 out.push_str("</div>");
321 }
322 out.push_str("</div></figure>");
323 out
324 }
325
326 #[must_use]
329 pub fn find(&self, text: &str) -> Option<(i32, i32)> {
330 (0..self.buffer.area.height).find_map(|y| {
331 let (line, columns) = self.row(y);
332 line.find(text).map(|byte| (i32::from(columns[byte]), i32::from(y)))
333 })
334 }
335
336 fn row(&self, y: u16) -> (String, Vec<u16>) {
338 let mut line = String::new();
339 let mut columns = Vec::new();
340 for x in visible_columns(&self.buffer, y) {
341 let symbol = self.buffer[(x, y)].symbol();
342 columns.extend(std::iter::repeat_n(x, symbol.len()));
343 line.push_str(symbol);
344 }
345 (line, columns)
346 }
347
348 #[must_use]
354 pub fn fg(&self, x: u16, y: u16) -> Option<Rgb> {
355 rgb(self.buffer[(x, y)].fg)
356 }
357
358 #[must_use]
364 pub fn bg(&self, x: u16, y: u16) -> Option<Rgb> {
365 rgb(self.buffer[(x, y)].bg)
366 }
367
368 #[must_use]
374 pub fn is_bold(&self, x: u16, y: u16) -> bool {
375 self.buffer[(x, y)].modifier.contains(Modifier::BOLD)
376 }
377
378 #[must_use]
380 pub fn buffer(&self) -> &Buffer {
381 &self.buffer
382 }
383
384 #[must_use]
386 pub fn app(&self) -> &A {
387 &self.engine.app
388 }
389
390 #[must_use]
392 pub fn env(&self) -> &Env {
393 &self.engine.env
394 }
395
396 #[must_use]
398 pub fn copied(&self) -> &[String] {
399 &self.engine.clipboard
400 }
401
402 #[must_use]
404 pub fn clipboard(&self) -> Option<&str> {
405 self.engine.clipboard_text.as_deref()
406 }
407
408 pub fn set_system_clipboard(&mut self, text: Option<&str>) -> &mut Self {
413 let system = super::clipboard::SystemClipboard::Fixed(text.map(str::to_owned));
414 self.engine.clipboard_reader.set_system(system);
415 self
416 }
417
418 #[must_use]
423 pub fn handoffs(&self) -> &[HandoffRequest] {
424 self.engine.handoff_requests()
425 }
426
427 pub fn set_handoff_outcome(&mut self, outcome: HandoffOutcome) -> &mut Self {
430 self.engine.set_handoff_outcome(outcome);
431 self
432 }
433
434 #[must_use]
438 pub fn detached_handoffs(&self) -> &[HandoffRequest] {
439 self.engine.detached_requests()
440 }
441
442 pub fn set_detached_outcome(&mut self, outcome: DetachedOutcome) -> &mut Self {
453 self.engine.set_detached_outcome(outcome);
454 self
455 }
456
457 #[must_use]
465 pub fn opens(&self) -> &[OpenRequest] {
466 self.engine.open_requests()
467 }
468
469 pub fn set_open_outcome(&mut self, outcome: OpenOutcome) -> &mut Self {
471 self.engine.set_open_outcome(outcome);
472 self
473 }
474
475 #[must_use]
477 pub fn quit_requested(&self) -> bool {
478 self.engine.quit
479 }
480
481 #[must_use]
483 pub fn is_focused(&self, name: &str) -> bool {
484 self.engine.interaction.focused.is_some_and(|id| self.engine.frame.names.get(&id).is_some_and(|n| n == name))
485 }
486}
487
488#[must_use]
490pub fn html_page(fragments: &[String]) -> String {
491 format!(
492 "<!doctype html><meta charset=\"utf-8\"><title>Quvyta review</title><style>\
493 body{{background:#050507;margin:24px;font-family:'JetBrainsMono Nerd Font Mono','JetBrains Mono',monospace}}\
494 figure{{margin:0 0 28px}}figcaption{{color:#8a8f99;font:12px sans-serif;margin-bottom:6px}}\
495 .screen{{display:inline-block;font-size:14px;line-height:19px;white-space:pre}}\
496 .row{{display:flex;height:19px}}.row span{{display:inline-block;overflow:hidden}}</style>{}",
497 fragments.concat()
498 )
499}
500
501fn visible_columns(buffer: &Buffer, y: u16) -> impl Iterator<Item = u16> + '_ {
505 let mut covered = 0u16;
506 (0..buffer.area.width).filter(move |&x| {
507 if covered > 0 {
508 covered -= 1;
509 return false;
510 }
511 let symbol = buffer[(x, y)].symbol();
512 covered = crate::text::width(symbol).saturating_sub(1);
513 !symbol.is_empty()
514 })
515}
516
517fn rgb(color: Color) -> Option<Rgb> {
518 match color {
519 Color::Rgb(r, g, b) => Some(Rgb::new(r, g, b)),
520 _ => None,
521 }
522}
523
524#[cfg(test)]
525mod resize_tests {
526 use super::Harness;
527 use crate::runtime::{App, Command};
528 use crate::widget::View;
529 use crate::widgets::Text;
530
531 struct Greeting;
532
533 impl App for Greeting {
534 type Msg = ();
535 fn update(&mut self, (): ()) -> Command<()> {
536 Command::none()
537 }
538 fn view(&self, ui: &mut View<'_, ()>) {
539 ui.add(Text::new("container engines"));
540 }
541 }
542
543 #[test]
544 fn resize_redraws_the_whole_screen_at_the_new_size() {
545 let mut harness = Harness::new(Greeting, 30, 2);
546 assert_eq!(harness.screen(), "container engines\n\n");
547 harness.resize(9, 1);
548 assert_eq!(harness.screen(), "container\n");
549 harness.resize(0, 0);
550 assert_eq!(harness.screen(), "");
551 harness.resize(40, 3);
552 assert_eq!((harness.buffer().area.width, harness.buffer().area.height), (40, 3));
553 assert_eq!(harness.screen(), "container engines\n\n\n");
554 }
555}
556
557#[cfg(test)]
558mod handoff_tests {
559 use std::ffi::OsString;
560
561 use super::Harness;
562 use crate::runtime::{App, Command, Handoff, HandoffOutcome};
563 use crate::widget::View;
564 use crate::widgets::{Button, Text};
565
566 #[derive(Default)]
568 struct Installer {
569 outcomes: Vec<HandoffOutcome>,
570 }
571
572 #[derive(Clone)]
573 enum Msg {
574 Authorize,
575 Done(HandoffOutcome),
576 }
577
578 impl App for Installer {
579 type Msg = Msg;
580 fn update(&mut self, msg: Msg) -> Command<Msg> {
581 match msg {
582 Msg::Authorize => Command::handoff(
583 Handoff::new("sudo", Msg::Done).arg("-v").notice("Authorizing the installation").pause(false),
584 ),
585 Msg::Done(outcome) => {
586 self.outcomes.push(outcome);
587 Command::none()
588 }
589 }
590 }
591 fn view(&self, ui: &mut View<'_, Msg>) {
592 ui.add(Button::new("Authorize").on_press(Msg::Authorize)).id("authorize");
593 let text = match self.outcomes.last() {
594 None => "not asked yet".to_owned(),
595 Some(HandoffOutcome::Finished { code }) => format!("finished {code:?}"),
596 Some(HandoffOutcome::Failed(reason)) => format!("failed {reason}"),
597 };
598 ui.add(Text::new(text));
599 }
600 }
601
602 #[test]
603 fn a_handoff_is_recorded_and_answered_with_the_outcome_the_test_set() {
604 let mut harness = Harness::new(Installer::default(), 40, 3);
605 assert!(harness.handoffs().is_empty(), "nothing was asked for yet");
606 harness.send(Msg::Authorize);
607 let asked = harness.handoffs();
608 assert_eq!(asked.len(), 1);
609 assert_eq!(asked[0].program, OsString::from("sudo"));
610 assert_eq!(asked[0].args, vec![OsString::from("-v")]);
611 assert_eq!(asked[0].notice.as_deref(), Some("Authorizing the installation"));
612 assert!(!asked[0].pause);
613 assert_eq!(harness.app().outcomes, [HandoffOutcome::Finished { code: Some(0) }]);
615 assert!(harness.screen().contains("finished Some(0)"), "{}", harness.screen());
616 }
617
618 #[test]
619 fn the_outcome_a_test_sets_reaches_the_application() {
620 let mut harness = Harness::new(Installer::default(), 40, 3);
621 harness.set_handoff_outcome(HandoffOutcome::Finished { code: Some(1) });
622 harness.send(Msg::Authorize);
623 assert_eq!(harness.app().outcomes, [HandoffOutcome::Finished { code: Some(1) }]);
624 harness.set_handoff_outcome(HandoffOutcome::Failed("sudo is not installed".to_owned()));
625 harness.send(Msg::Authorize);
626 assert_eq!(harness.app().outcomes.len(), 2);
627 assert!(harness.screen().contains("failed sudo is not installed"), "{}", harness.screen());
628 assert_eq!(harness.handoffs().len(), 2, "both requests are kept, oldest first");
629 }
630
631 #[test]
632 fn several_handoffs_are_answered_one_after_another() {
633 let mut harness = Harness::new(Installer::default(), 40, 3);
634 harness.send(Msg::Authorize).send(Msg::Authorize).send(Msg::Authorize);
635 assert_eq!(harness.handoffs().len(), 3);
636 assert_eq!(harness.app().outcomes.len(), 3);
637 }
638}
639
640#[cfg(test)]
641mod wide_text_tests {
642 use super::Harness;
643 use crate::runtime::{App, Command};
644 use crate::widget::View;
645 use crate::widgets::{Button, Text};
646
647 #[derive(Default)]
649 struct Firewall {
650 presses: u32,
651 }
652
653 impl App for Firewall {
654 type Msg = ();
655 fn update(&mut self, (): ()) -> Command<()> {
656 self.presses += 1;
657 Command::none()
658 }
659 fn view(&self, ui: &mut View<'_, ()>) {
660 ui.add(Text::new("状态 防火墙 on"));
661 ui.add(Button::new("启用").on_press(()));
662 }
663 }
664
665 fn with_covered_cells_as_spaces(harness: &mut Harness<Firewall>) {
669 let area = harness.buffer.area;
670 for y in 0..area.height {
671 let mut covered = 0;
672 for x in 0..area.width {
673 let cell = &mut harness.buffer[(x, y)];
674 if covered > 0 {
675 covered -= 1;
676 cell.reset();
677 continue;
678 }
679 covered = crate::text::width(cell.symbol()).saturating_sub(1);
680 }
681 }
682 }
683
684 fn firewall() -> Harness<Firewall> {
685 let mut harness = Harness::new(Firewall::default(), 30, 3);
686 with_covered_cells_as_spaces(&mut harness);
687 harness
688 }
689
690 #[test]
691 fn the_screen_reads_wide_text_without_gaps() {
692 let harness = firewall();
693 let screen = harness.screen();
694 assert!(screen.starts_with("状态 防火墙 on\n"), "{screen}");
695 assert!(screen.contains("防火墙"), "{screen}");
696 }
697
698 #[test]
699 fn find_gives_the_column_a_wide_text_is_drawn_in() {
700 let harness = firewall();
701 assert_eq!(harness.find("防火墙"), Some((5, 0)));
702 assert_eq!(harness.find("on"), Some((12, 0)), "text after wide characters keeps its column");
703 let (x, y) = harness.find("启用").expect("the button label is on screen");
704 assert_eq!(harness.buffer()[(u16::try_from(x).unwrap(), u16::try_from(y).unwrap())].symbol(), "启");
705 }
706
707 #[test]
708 fn click_text_presses_a_wide_label() {
709 let mut harness = firewall();
710 harness.click_text("启用");
711 assert_eq!(harness.app().presses, 1);
712 }
713
714 #[test]
715 fn html_draws_a_wide_character_once() {
716 let harness = firewall();
717 let html = harness.html("wide");
718 let first_row = html.split("<div class=\"row\">").nth(1).expect("a first row");
719 assert_eq!(first_row.matches("<span").count(), 30 - 5, "five characters take two cells each: {first_row}");
720 assert!(first_row.contains(">防</span><span"), "{first_row}");
721 }
722}