Skip to main content

matchmaker/render/
mod.rs

1mod dynamic;
2mod state;
3
4use crossterm::event::{MouseButton, MouseEventKind};
5pub use dynamic::*;
6pub use state::*;
7// ------------------------------
8
9use std::io::Write;
10
11use log::{info, warn};
12use ratatui::Frame;
13use ratatui::layout::{Position, Rect};
14use tokio::sync::mpsc;
15
16#[cfg(feature = "bracketed-paste")]
17use crate::PasteHandler;
18use crate::action::{Action, ActionExt};
19use crate::config::{CursorSetting, ExitConfig, RowConnectionStyle};
20use crate::event::EventSender;
21use crate::message::{Event, Interrupt, RenderCommand};
22use crate::tui::Tui;
23use crate::ui::{DisplayUI, InputUI, OverlayUI, PickerUI, PreviewUI, ResultsUI, UI};
24use crate::{ActionAliaser, ActionExtHandler, Initializer, MatchError, SSS, Selection};
25
26fn apply_aliases<T: SSS, S: Selection, A: ActionExt>(
27    buffer: &mut Vec<RenderCommand<A>>,
28    aliaser: &mut ActionAliaser<T, S, A>,
29    dispatcher: &mut MMState<'_, '_, T, S>,
30) {
31    let mut out = Vec::new();
32
33    for cmd in buffer.drain(..) {
34        match cmd {
35            RenderCommand::Action(a) => out.extend(
36                aliaser(a, dispatcher)
37                    .into_iter()
38                    .map(RenderCommand::Action),
39            ),
40            other => out.push(other),
41        }
42    }
43
44    *buffer = out;
45}
46
47#[allow(clippy::too_many_arguments)]
48pub(crate) async fn render_loop<'a, W: Write, T: SSS, S: Selection, A: ActionExt>(
49    mut ui: UI,
50    mut picker_ui: PickerUI<'a, T, S>,
51    mut footer_ui: DisplayUI,
52    mut preview_ui: Option<PreviewUI>,
53    mut tui: Tui<W>,
54
55    mut overlay_ui: Option<OverlayUI<A>>,
56    exit_config: ExitConfig,
57
58    mut render_rx: mpsc::UnboundedReceiver<RenderCommand<A>>,
59    controller_tx: EventSender,
60
61    dynamic_handlers: DynamicHandlers<T, S>,
62    mut ext_handler: Option<ActionExtHandler<T, S, A>>,
63    mut ext_aliaser: Option<ActionAliaser<T, S, A>>,
64    initializer: Option<Initializer<T, S>>,
65    #[cfg(feature = "bracketed-paste")] //
66    mut paste_handler: Option<PasteHandler<T, S>>,
67) -> Result<Vec<S>, MatchError> {
68    let mut state = State::new();
69
70    if let Some(handler) = initializer {
71        handler(&mut state.dispatcher(
72            &mut ui,
73            &mut picker_ui,
74            &mut footer_ui,
75            &mut preview_ui,
76            &controller_tx,
77        ));
78    }
79
80    let mut click = Click::None;
81
82    // place the initial command in the state where the preview listener can access
83    if let Some(ref p) = preview_ui {
84        state.update_preview(p.get_initial_command());
85    }
86
87    let mut buffer = Vec::with_capacity(256);
88
89    while render_rx.recv_many(&mut buffer, 256).await > 0 {
90        if state.iterations == 0 {
91            log::debug!("Render loop started");
92        }
93        let mut did_pause = false;
94        let mut did_exit = false;
95        let mut did_resize = false;
96
97        // todo: why exactly can we not borrow the picker_ui mutably?
98        if let Some(aliaser) = &mut ext_aliaser {
99            apply_aliases(
100                &mut buffer,
101                aliaser,
102                &mut state.dispatcher(
103                    &mut ui,
104                    &mut picker_ui,
105                    &mut footer_ui,
106                    &mut preview_ui,
107                    &controller_tx,
108                ),
109            )
110            // effects could be moved out for efficiency, but it seems more logical to add them as they come so that we can trigger interrupts
111        };
112
113        if state.should_quit {
114            log::debug!("Exiting due to should_quit");
115            let ret = picker_ui.selector.output().collect::<Vec<S>>();
116            return if picker_ui.selector.is_disabled()
117                && let Some((_, item)) = get_current(&picker_ui)
118            {
119                Ok(vec![item])
120            } else if ret.is_empty() {
121                Err(MatchError::Abort(0))
122            } else {
123                Ok(ret)
124            };
125        } else if state.should_quit_nomatch {
126            log::debug!("Exiting due to should_quit_no_match");
127            return Err(MatchError::NoMatch);
128        }
129
130        for event in buffer.drain(..) {
131            state.clear_interrupt();
132
133            if !matches!(event, RenderCommand::Tick) {
134                info!("Recieved {event:?}");
135            } else {
136                // log::trace!("Recieved {event:?}");
137            }
138
139            match event {
140                #[cfg(feature = "bracketed-paste")]
141                RenderCommand::Paste(content) => {
142                    if let Some(handler) = &mut paste_handler {
143                        let content = {
144                            handler(
145                                content,
146                                &state.dispatcher(
147                                    &mut ui,
148                                    &mut picker_ui,
149                                    &mut footer_ui,
150                                    &mut preview_ui,
151                                    &controller_tx,
152                                ),
153                            )
154                        };
155                        if !content.is_empty() {
156                            if let Some(x) = overlay_ui.as_mut()
157                                && x.index().is_some()
158                            {
159                                for c in content.chars() {
160                                    x.handle_input(c);
161                                }
162                            } else {
163                                picker_ui.input.push_str(&content);
164                            }
165                        }
166                    }
167                }
168                RenderCommand::Resize(area) => {
169                    tui.resize(area);
170                    ui.update_dimensions(area);
171                }
172                RenderCommand::Refresh => {
173                    tui.redraw();
174                }
175                RenderCommand::HeaderTable(columns) => {
176                    picker_ui.header.header_table(columns);
177                }
178                RenderCommand::Mouse(mouse) => {
179                    // we could also impl this in the aliasing step
180                    let pos = Position::from((mouse.column, mouse.row));
181                    let [preview, input, status, result] = state.layout;
182
183                    match mouse.kind {
184                        MouseEventKind::Down(MouseButton::Left) => {
185                            // todo: clickable column headers, clickable results, also, grouping?
186                            if result.contains(pos) {
187                                click = Click::ResultPos(mouse.row - result.top());
188                            } else if input.contains(pos) {
189                                // The X offset of the start of the visible text relative to the terminal
190                                let text_start_x = input.x + picker_ui.input.left();
191
192                                if pos.x >= text_start_x {
193                                    let visual_offset = pos.x - text_start_x;
194                                    picker_ui.input.set_at_visual_offset(visual_offset);
195                                } else {
196                                    picker_ui.input.set(None, 0);
197                                }
198                            } else if status.contains(pos) {
199                                // todo
200                            }
201                        }
202                        MouseEventKind::ScrollDown => {
203                            if preview.contains(pos) {
204                                if let Some(p) = preview_ui.as_mut() {
205                                    p.down(1)
206                                }
207                            } else {
208                                picker_ui.results.cursor_next()
209                            }
210                        }
211                        MouseEventKind::ScrollUp => {
212                            if preview.contains(pos) {
213                                if let Some(p) = preview_ui.as_mut() {
214                                    p.up(1)
215                                }
216                            } else {
217                                picker_ui.results.cursor_prev()
218                            }
219                        }
220                        MouseEventKind::ScrollLeft => {
221                            // todo
222                        }
223                        MouseEventKind::ScrollRight => {
224                            // todo
225                        }
226                        // Drag tracking: todo
227                        _ => {}
228                    }
229                }
230                RenderCommand::QuitEmpty => {
231                    return Ok(vec![]);
232                }
233                RenderCommand::Action(action) => {
234                    if let Some(x) = overlay_ui.as_mut() {
235                        if match action {
236                            Action::Char(c) => x.handle_input(c),
237                            _ => x.handle_action(&action),
238                        } {
239                            continue;
240                        }
241                    }
242                    let PickerUI {
243                        input,
244                        results,
245                        worker,
246                        selector: selections,
247                        ..
248                    } = &mut picker_ui;
249                    match action {
250                        Action::Select => {
251                            if let Some(item) = worker.get_nth(results.index()) {
252                                selections.sel(item);
253                            }
254                        }
255                        Action::Deselect => {
256                            if let Some(item) = worker.get_nth(results.index()) {
257                                selections.desel(item);
258                            }
259                        }
260                        Action::Toggle => {
261                            if let Some(item) = worker.get_nth(results.index()) {
262                                selections.toggle(item);
263                            }
264                        }
265                        Action::CycleAll => {
266                            selections.cycle_all_bg(worker.raw_results());
267                        }
268                        Action::ClearSelections => {
269                            selections.clear();
270                        }
271                        Action::Accept => {
272                            let ret = if selections.is_empty() {
273                                if let Some(item) = get_current(&picker_ui) {
274                                    vec![item.1]
275                                } else if exit_config.allow_empty {
276                                    vec![]
277                                } else {
278                                    continue;
279                                }
280                            } else {
281                                selections.output().collect::<Vec<S>>()
282                            };
283                            return Ok(ret);
284                        }
285                        Action::Quit(code) => {
286                            return Err(MatchError::Abort(code));
287                        }
288
289                        // Results
290                        Action::ToggleWrap => {
291                            results.wrap(!results.is_wrap());
292                        }
293                        Action::Up(x) | Action::Down(x) => {
294                            let next = matches!(action, Action::Down(_)) ^ results.reverse();
295                            for _ in 0..x.into() {
296                                if next {
297                                    results.cursor_next();
298                                } else {
299                                    results.cursor_prev();
300                                }
301                            }
302                        }
303                        Action::Pos(pos) => {
304                            let pos = if pos >= 0 {
305                                pos as u32
306                            } else {
307                                results.status.matched_count.saturating_sub((-pos) as u32)
308                            };
309                            results.cursor_jump(pos);
310                        }
311                        Action::QueryPos(pos) => {
312                            let pos = if pos >= 0 {
313                                pos as u16
314                            } else {
315                                (input.len() as u16).saturating_sub((-pos) as u16)
316                            };
317                            input.set(None, pos);
318                        }
319                        Action::HScroll(n) | Action::VScroll(n) => {
320                            if let Some(p) = &mut preview_ui
321                                && !p.config.wrap
322                                && false
323                            // track mouse location?
324                            {
325                                p.scroll(true, n);
326                            } else {
327                                results.current_scroll(n, matches!(action, Action::HScroll(_)));
328                            }
329                        }
330                        Action::HalfPageDown | Action::HalfPageUp => {
331                            let x = (results.height() + 1) / 2;
332                            let next = matches!(action, Action::HalfPageDown) ^ results.reverse();
333                            for _ in 0..x.into() {
334                                if next {
335                                    results.cursor_next();
336                                } else {
337                                    results.cursor_prev();
338                                }
339                            }
340                        }
341
342                        // Preview Navigation
343                        Action::PreviewUp(n) => {
344                            if let Some(p) = preview_ui.as_mut() {
345                                p.up(n)
346                            }
347                        }
348                        Action::PreviewDown(n) => {
349                            if let Some(p) = preview_ui.as_mut() {
350                                p.down(n)
351                            }
352                        }
353                        Action::PreviewHalfPageUp | Action::PreviewHalfPageDown => {
354                            if let Some(p) = preview_ui.as_mut() {
355                                let n = (p.area.height + 1) / 2;
356
357                                if matches!(action, Action::PreviewHalfPageUp) {
358                                    p.up(n)
359                                } else {
360                                    p.down(n)
361                                }
362                            }
363                        }
364
365                        Action::PreviewHScroll(x) | Action::PreviewScroll(x) => {
366                            if let Some(p) = preview_ui.as_mut() {
367                                p.scroll(matches!(action, Action::PreviewHScroll(_)), x);
368                            }
369                        }
370                        Action::PreviewJump => {
371                            // todo
372                        }
373
374                        // Preview
375                        // this sometimes aborts the viewer on some files, why?
376                        Action::CyclePreview => {
377                            if let Some(p) = preview_ui.as_mut() {
378                                p.cycle_layout();
379                                if !p.command().is_empty() {
380                                    state.update_preview(p.command());
381                                }
382                            }
383                        }
384
385                        Action::Preview(context) => {
386                            if let Some(p) = preview_ui.as_mut() {
387                                if !state.update_preview(context.as_str()) {
388                                    p.toggle_show()
389                                } else {
390                                    p.show(true);
391                                }
392                            };
393                        }
394                        Action::Help(context) => {
395                            if let Some(p) = preview_ui.as_mut() {
396                                // empty payload signifies help
397                                if !state.update_preview_set(context) {
398                                    state.update_preview_unset()
399                                } else {
400                                    p.show(true);
401                                }
402                            };
403                        }
404                        Action::SetPreview(idx) => {
405                            if let Some(p) = preview_ui.as_mut() {
406                                if let Some(idx) = idx {
407                                    p.set_layout(idx);
408                                } else {
409                                    state.update_preview(p.command());
410                                }
411                            }
412                        }
413                        Action::SwitchPreview(idx) => {
414                            if let Some(p) = preview_ui.as_mut() {
415                                if let Some(idx) = idx {
416                                    if !p.set_layout(idx) && !state.update_preview(p.command()) {
417                                        p.toggle_show();
418                                    }
419                                } else {
420                                    p.toggle_show()
421                                }
422                            }
423                        }
424                        Action::TogglePreviewWrap => {
425                            if let Some(p) = preview_ui.as_mut() {
426                                p.wrap(!p.is_wrap());
427                            }
428                        }
429
430                        // Programmable
431                        Action::Execute(payload) => {
432                            state.set_interrupt(Interrupt::Execute, payload);
433                        }
434                        Action::ExecuteSilent(payload) => {
435                            state.set_interrupt(Interrupt::ExecuteSilent, payload);
436                        }
437                        Action::Store(payload) => {
438                            state.store_payload = payload;
439                        }
440                        Action::Become(payload) => {
441                            state.set_interrupt(Interrupt::Become, payload);
442                        }
443                        Action::Reload(payload) => {
444                            state.set_interrupt(Interrupt::Reload, payload);
445                        }
446                        Action::Print(payload) => {
447                            state.set_interrupt(Interrupt::Print, payload);
448                        }
449
450                        // Columns
451                        Action::SwitchColumn(col_name) => {
452                            if worker.query.active_column_name(input.str_at_cursor()) != col_name
453                                && worker.columns.iter().any(|c| *c.name == col_name)
454                            {
455                                input.prepare_column_change();
456                                input.push_str(&format!("%{} ", col_name));
457                            } else {
458                                log::warn!("Column {} not found in worker columns", col_name);
459                            }
460                        }
461                        Action::NextColumn | Action::PrevColumn => {
462                            let cursor_byte = input.byte_index(input.cursor() as usize);
463                            let active_idx = worker.query.active_column_index(cursor_byte);
464
465                            let num_columns = worker.columns.len();
466                            if num_columns > 0 {
467                                input.prepare_column_change();
468
469                                let mut next_idx = match action {
470                                    Action::NextColumn => active_idx + 1,
471                                    Action::PrevColumn => {
472                                        active_idx + num_columns - 1 % num_columns
473                                    }
474                                    _ => unreachable!(),
475                                } % num_columns;
476
477                                loop {
478                                    if next_idx < results.hidden_columns.len()
479                                        && results.hidden_columns[next_idx]
480                                    {
481                                        next_idx = match action {
482                                            Action::NextColumn => (next_idx + 1) % num_columns,
483                                            Action::PrevColumn => {
484                                                (next_idx + num_columns - 1) % num_columns
485                                            }
486                                            _ => unreachable!(),
487                                        };
488                                    } else {
489                                        break;
490                                    }
491                                }
492
493                                let col_name = &worker.columns[next_idx].name;
494                                input.push_str(&format!("%{} ", col_name));
495                            }
496                        }
497
498                        Action::ToggleColumn(col_name) => {
499                            let index = if let Some(name) = col_name {
500                                worker.columns.iter().position(|c| *c.name == name)
501                            } else {
502                                let cursor_byte = input.byte_index(input.cursor() as usize);
503                                Some(worker.query.active_column_index(cursor_byte))
504                            };
505
506                            if let Some(idx) = index {
507                                if idx >= results.hidden_columns.len() {
508                                    results.hidden_columns.resize(idx + 1, false);
509                                }
510                                results.hidden_columns[idx] = !results.hidden_columns[idx];
511                            }
512                        }
513
514                        Action::ShowColumn(col_name) => {
515                            if let Some(name) = col_name {
516                                if let Some(idx) =
517                                    worker.columns.iter().position(|c| *c.name == name)
518                                {
519                                    if idx < results.hidden_columns.len() {
520                                        results.hidden_columns[idx] = false;
521                                    }
522                                }
523                            } else {
524                                for val in results.hidden_columns.iter_mut() {
525                                    *val = false;
526                                }
527                            }
528                        }
529
530                        Action::ScrollLeft => {}
531                        Action::ScrollRight => {}
532
533                        // Edit
534                        Action::SetQuery(context) => {
535                            input.set(context, u16::MAX);
536                        }
537                        Action::ForwardChar => input.forward_char(),
538                        Action::BackwardChar => input.backward_char(),
539                        Action::ForwardWord => input.forward_word(),
540                        Action::BackwardWord => input.backward_word(),
541                        Action::DeleteChar => input.delete(),
542                        Action::DeleteWord => input.delete_word(),
543                        Action::DeleteLineStart => input.delete_line_start(),
544                        Action::DeleteLineEnd => input.delete_line_end(),
545                        Action::Cancel => input.cancel(),
546
547                        // Other
548                        Action::Redraw => {
549                            tui.redraw();
550                        }
551                        Action::Overlay(index) => {
552                            if let Some(x) = overlay_ui.as_mut() {
553                                x.enable(index, &ui.area());
554                                tui.redraw();
555                            };
556                        }
557                        Action::Custom(e) => {
558                            if let Some(handler) = &mut ext_handler {
559                                handler(
560                                    e,
561                                    &mut state.dispatcher(
562                                        &mut ui,
563                                        &mut picker_ui,
564                                        &mut footer_ui,
565                                        &mut preview_ui,
566                                        &controller_tx,
567                                    ),
568                                );
569                            }
570                        }
571                        Action::Char(c) => picker_ui.input.push_char(c),
572
573                        // unreachable
574                        Action::PrintKey => {}
575                        Action::Semantic(_) => {}
576                    }
577                }
578                _ => {}
579            }
580
581            let interrupt = state.interrupt();
582
583            match interrupt {
584                Interrupt::None => continue,
585                Interrupt::Execute => {
586                    if controller_tx.send(Event::Pause).is_err() {
587                        break;
588                    }
589                    tui.enter_execute();
590                    did_exit = true;
591                    did_pause = true;
592                }
593                Interrupt::Reload => {
594                    picker_ui.worker.restart(false);
595                    state.synced = [false; 2];
596                }
597                Interrupt::Become => {
598                    tui.exit();
599                }
600                _ => {}
601            }
602            // Apply interrupt effect
603            {
604                let mut dispatcher = state.dispatcher(
605                    &mut ui,
606                    &mut picker_ui,
607                    &mut footer_ui,
608                    &mut preview_ui,
609                    &controller_tx,
610                );
611                for h in dynamic_handlers.1.get(interrupt) {
612                    h(&mut dispatcher);
613                }
614
615                if matches!(interrupt, Interrupt::Become) {
616                    return Err(MatchError::Become(state.payload().clone()));
617                }
618            }
619
620            if state.should_quit {
621                log::debug!("Exiting due to should_quit");
622                let ret = picker_ui.selector.output().collect::<Vec<S>>();
623                return if picker_ui.selector.is_disabled()
624                    && let Some((_, item)) = get_current(&picker_ui)
625                {
626                    Ok(vec![item])
627                } else if ret.is_empty() {
628                    Err(MatchError::Abort(0))
629                } else {
630                    Ok(ret)
631                };
632            } else if state.should_quit_nomatch {
633                log::debug!("Exiting due to should_quit_nomatch");
634                return Err(MatchError::NoMatch);
635            }
636        }
637
638        // debug!("{state:?}");
639
640        // ------------- update state + render ------------------------
641        if state.filtering {
642            picker_ui.update();
643        } else {
644            // nothing
645        }
646        // process exit conditions
647        if exit_config.select_1
648            && picker_ui.results.status.matched_count == 1
649            && let Some((_, item)) = get_current(&picker_ui)
650        {
651            return Ok(vec![item]);
652        }
653
654        // resume tui
655        if did_exit {
656            tui.return_execute()
657                .map_err(|e| MatchError::TUIError(e.to_string()))?;
658            tui.redraw();
659        }
660
661        let mut overlay_ui_ref = overlay_ui.as_mut();
662        let mut cursor_y_offset = 0;
663
664        tui.terminal
665            .draw(|frame| {
666                let mut area = frame.area();
667
668                // mutates area!
669                render_ui(frame, &mut area, &ui);
670
671                let mut _area = area;
672
673                let full_width_footer = footer_ui.single()
674                    && footer_ui.config.row_connection == RowConnectionStyle::Full;
675
676                let mut footer =
677                    if full_width_footer || preview_ui.as_ref().is_none_or(|p| !p.visible()) {
678                        split(&mut _area, footer_ui.height(), picker_ui.reverse())
679                    } else {
680                        Rect::default()
681                    };
682
683                let [preview, picker_area, footer] = if let Some(preview_ui) = preview_ui.as_mut()
684                    && preview_ui.visible()
685                    && let Some(setting) = preview_ui.setting()
686                {
687                    let layout = &setting.layout;
688
689                    let [preview, mut picker_area] = layout.split(_area);
690
691                    if state.iterations == 0 && picker_area.width <= 5 {
692                        warn!("UI too narrow, hiding preview");
693                        preview_ui.show(false);
694
695                        [Rect::default(), _area, footer]
696                    } else {
697                        if !full_width_footer {
698                            footer =
699                                split(&mut picker_area, footer_ui.height(), picker_ui.reverse());
700                        }
701
702                        [preview, picker_area, footer]
703                    }
704                } else {
705                    [Rect::default(), _area, footer]
706                };
707
708                let [input, status, header, results] = picker_ui.layout(picker_area);
709
710                // compare and save dimensions
711                did_resize = state.update_layout([preview, input, status, results]);
712
713                if did_resize {
714                    picker_ui.results.update_dimensions(&results);
715                    picker_ui.input.update_width(input.width);
716                    footer_ui.update_width(
717                        if footer_ui.config.row_connection == RowConnectionStyle::Capped {
718                            area.width
719                        } else {
720                            footer.width
721                        },
722                    );
723                    picker_ui.header.update_width(header.width);
724                    // although these only want update when the whole ui change
725                    ui.update_dimensions(area);
726                    if let Some(x) = overlay_ui_ref.as_deref_mut() {
727                        x.update_dimensions(&area);
728                    }
729                };
730
731                cursor_y_offset = render_input(frame, input, &mut picker_ui.input).y;
732                render_status(frame, status, &picker_ui.results, ui.area().width);
733                render_results(frame, results, &mut picker_ui, &mut click);
734                render_display(frame, header, &mut picker_ui.header, &picker_ui.results);
735                render_display(frame, footer, &mut footer_ui, &picker_ui.results);
736                if let Some(preview_ui) = preview_ui.as_mut()
737                    && preview_ui.visible()
738                {
739                    state.update_preview_visible(preview_ui);
740                    if did_resize {
741                        preview_ui.update_dimensions(&preview);
742                    }
743                    render_preview(frame, preview, preview_ui);
744                }
745                if let Some(x) = overlay_ui_ref {
746                    x.draw(frame);
747                }
748            })
749            .map_err(|e| MatchError::TUIError(e.to_string()))?;
750
751        // useful to clear artifacts
752        if did_resize && tui.config.redraw_on_resize && !did_exit {
753            tui.redraw();
754            tui.cursor_y_offset = Some(cursor_y_offset)
755        }
756        buffer.clear();
757
758        // note: the remainder could be scoped by a conditional on having run?
759        // ====== Event handling ==========
760        state.update(&picker_ui, &overlay_ui);
761        let events = state.events();
762
763        // ---- Invoke handlers -------
764        let mut dispatcher = state.dispatcher(
765            &mut ui,
766            &mut picker_ui,
767            &mut footer_ui,
768            &mut preview_ui,
769            &controller_tx,
770        );
771        // if let Some((signal, handler)) = signal_handler &&
772        // let s = signal.load(std::sync::atomic::Ordering::Acquire) &&
773        // s > 0
774        // {
775        //     handler(s, &mut dispatcher);
776        //     signal.store(0, std::sync::atomic::Ordering::Release);
777        // };
778
779        // ping handlers with events
780        for e in events.iter() {
781            for h in dynamic_handlers.0.get(e) {
782                h(&mut dispatcher, &e)
783            }
784        }
785
786        // ------------------------------
787        // send events into controller
788        for e in events.iter() {
789            controller_tx
790                .send(e)
791                .unwrap_or_else(|err| eprintln!("send failed: {:?}", err));
792        }
793        // =================================
794
795        if did_pause {
796            log::debug!("Waiting for ack response to pause");
797            if controller_tx.send(Event::Resume).is_err() {
798                break;
799            };
800            // due to control flow, this does nothing, but is anyhow a useful safeguard to guarantee the pause
801            while let Some(msg) = render_rx.recv().await {
802                if matches!(msg, RenderCommand::Ack) {
803                    log::debug!("Recieved ack response to pause");
804                    break;
805                }
806            }
807        }
808
809        click.process(&mut buffer);
810    }
811
812    Err(MatchError::EventLoopClosed)
813}
814
815// ------------------------- HELPERS ----------------------------
816
817pub enum Click {
818    None,
819    ResultPos(u16),
820    ResultIdx(u32),
821}
822
823impl Click {
824    fn process<A: ActionExt>(&mut self, buffer: &mut Vec<RenderCommand<A>>) {
825        match self {
826            Self::ResultIdx(u) => {
827                buffer.push(RenderCommand::Action(Action::Pos(*u as i32)));
828            }
829            _ => {
830                // todo
831            }
832        }
833        *self = Click::None
834    }
835}
836
837fn render_preview(frame: &mut Frame, area: Rect, ui: &mut PreviewUI) {
838    // if ui.view.changed() {
839    // doesn't work, use resize
840    //     frame.render_widget(Clear, area);
841    // } else {
842    //     let widget = ui.make_preview();
843    //     frame.render_widget(widget, area);
844    // }
845    assert!(ui.visible()); // don't call if not visible.
846    let widget = ui.make_preview();
847    frame.render_widget(widget, area);
848}
849
850fn render_results<T: SSS, S: Selection>(
851    frame: &mut Frame,
852    mut area: Rect,
853    ui: &mut PickerUI<T, S>,
854    click: &mut Click,
855) {
856    let cap = matches!(ui.results.config.row_connection, RowConnectionStyle::Capped);
857    let (widget, table_width) = ui.make_table(click);
858
859    if cap {
860        area.width = area.width.min(table_width);
861    }
862
863    frame.render_widget(widget, area);
864}
865
866/// Returns the offset of the cursor against the drawing area
867fn render_input(frame: &mut Frame, area: Rect, ui: &mut InputUI) -> Position {
868    ui.scroll_to_cursor();
869    let widget = ui.make_input();
870    let p = ui.cursor_offset(&area);
871    if let CursorSetting::Default = ui.config.cursor {
872        frame.set_cursor_position(p)
873    };
874
875    frame.render_widget(widget, area);
876
877    p
878}
879
880fn render_status(frame: &mut Frame, area: Rect, ui: &ResultsUI, full_width: u16) {
881    if ui.status_config.show {
882        let widget = ui.make_status(full_width);
883        frame.render_widget(widget, area);
884    }
885}
886
887fn render_display(frame: &mut Frame, area: Rect, ui: &mut DisplayUI, results_ui: &ResultsUI) {
888    if !ui.show {
889        return;
890    }
891    let widget = ui.make_display(
892        results_ui.indentation() as u16,
893        results_ui.widths().to_vec(),
894        results_ui.config.column_spacing.0,
895    );
896
897    frame.render_widget(widget, area);
898
899    if ui.single() {
900        let widget = ui.make_full_width_row(results_ui.indentation() as u16);
901        frame.render_widget(widget, area);
902    }
903}
904
905// a bit weird, do we want mutable, do we want &mut ui, whatever this is simplest
906fn render_ui(frame: &mut Frame, area: &mut Rect, ui: &UI) {
907    let widget = ui.make_ui();
908    frame.render_widget(widget, *area);
909    *area = ui.compute_area(area);
910}
911
912fn split(rect: &mut Rect, height: u16, cut_top: bool) -> Rect {
913    let h = height.min(rect.height);
914
915    if cut_top {
916        let offshoot = Rect {
917            x: rect.x,
918            y: rect.y,
919            width: rect.width,
920            height: h,
921        };
922
923        rect.y += h;
924        rect.height -= h;
925
926        offshoot
927    } else {
928        let offshoot = Rect {
929            x: rect.x,
930            y: rect.y + rect.height - h,
931            width: rect.width,
932            height: h,
933        };
934
935        rect.height -= h;
936
937        offshoot
938    }
939}
940
941// -----------------------------------------------------------------------------------
942
943#[cfg(test)]
944mod test {}
945
946// #[cfg(test)]
947// async fn send_every_second(tx: mpsc::UnboundedSender<RenderCommand>) {
948//     let mut interval = tokio::time::interval(std::time::Duration::from_secs(1));
949
950//     loop {
951//         interval.tick().await;
952//         if tx.send(RenderCommand::quit()).is_err() {
953//             break;
954//         }
955//     }
956// }