Expand description
all the skin things used by the broot application during running
Fields§
§focused: PanelSkin
the skin used in the focused panel
unfocused: PanelSkin
the skin used in unfocused panels
Implementations§
source§impl AppSkin
impl AppSkin
sourcepub fn new(conf: &Conf, no_style: bool) -> Self
pub fn new(conf: &Conf, no_style: bool) -> Self
Examples found in repository?
src/app/app.rs (line 697)
679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807
pub fn run(
mut self,
w: &mut W,
con: &mut AppContext,
conf: &Conf,
) -> Result<Option<Launchable>, ProgramError> {
#[cfg(feature = "clipboard")]
{
// different systems have different clipboard capabilities
// and it may be useful to know which one we have
debug!("Clipboard backend: {:?}", terminal_clipboard::get_type());
}
// we listen for events in a separate thread so that we can go on listening
// when a long search is running, and interrupt it if needed
let event_source = EventSource::new()?;
let rx_events = event_source.receiver();
let mut dam = Dam::from(rx_events);
let skin = AppSkin::new(conf, con.launch_args.color == TriBool::No);
let mut app_state = AppState {
stage: Stage::default(),
root: con.initial_root.clone(),
other_panel_path: None,
};
self.screen.clear_bottom_right_char(w, &skin.focused)?;
if let Some(raw_sequence) = &con.launch_args.cmd {
self.tx_seqs
.send(Sequence::new_local(raw_sequence.to_string()))
.unwrap();
}
#[cfg(unix)]
let _server = con.launch_args.listen.as_ref()
.map(|server_name| {
let shared_root = Arc::new(Mutex::new(app_state.root.clone()));
let server = crate::net::Server::new(
server_name,
self.tx_seqs.clone(),
Arc::clone(&shared_root),
);
self.shared_root = Some(shared_root);
server
})
.transpose()?;
loop {
if !self.quitting {
self.display_panels(w, &skin, &app_state, con)?;
time!(
Info,
"pending_tasks",
self.do_pending_tasks(w, &skin, &mut dam, &mut app_state, con)?,
);
}
#[allow(unused_mut)]
match dam.next(&self.rx_seqs) {
Either::First(Some(event)) => {
info!("event: {:?}", &event);
let mut handled = false;
// app level handling
if let Some((x, y)) = event.as_click() {
if self.clicked_panel_index(x, y) != self.active_panel_idx {
// panel activation click
self.active_panel_idx = self.clicked_panel_index(x, y);
handled = true;
}
} else if let Event::Resize(mut width, mut height) = event.event {
// I don't know why but Crossterm seems to always report an
// understimated size on Windows
#[cfg(windows)]
{
width += 1;
height += 1;
}
self.screen.set_terminal_size(width, height, con);
Areas::resize_all(
self.panels.as_mut_slice(),
self.screen,
self.preview_panel.is_some(),
);
for panel in &mut self.panels {
panel.mut_state().refresh(self.screen, con);
}
handled = true;
}
// event handled by the panel
if !handled {
let cmd = self.mut_panel().add_event(w, event, &app_state, con)?;
debug!("command after add_event: {:?}", &cmd);
self.apply_command(w, cmd, &skin.focused, &mut app_state, con)?;
}
event_source.unblock(self.quitting);
}
Either::First(None) => {
// this is how we quit the application,
// when the input thread is properly closed
break;
}
Either::Second(Some(raw_sequence)) => {
debug!("got command sequence: {:?}", &raw_sequence);
for (input, arg_cmd) in raw_sequence.parse(con)? {
self.mut_panel().set_input_content(&input);
self.apply_command(w, arg_cmd, &skin.focused, &mut app_state, con)?;
if self.quitting {
// is that a 100% safe way of quitting ?
return Ok(self.launch_at_end.take());
} else {
self.display_panels(w, &skin, &app_state, con)?;
time!(
"sequence pending tasks",
self.do_pending_tasks(w, &skin, &mut dam, &mut app_state, con)?,
);
}
}
}
Either::Second(None) => {
warn!("I didn't expect a None to occur here");
}
}
}
Ok(self.launch_at_end.take())
}