use { crate::{ backend::KeyState, cursor::KnownCursor, fixed::Fixed, ifs::wl_seat::{ collect_kb_foci, collect_kb_foci2, wl_pointer::PendingScroll, NodeSeatState, SeatId, WlSeatGlobal, BTN_LEFT, }, rect::Rect, renderer::Renderer, scale::Scale, state::State, text::{self, TextTexture}, tree::{ walker::NodeVisitor, ContainingNode, Direction, FindTreeResult, FoundNode, Node, NodeId, ToplevelData, ToplevelNode, WorkspaceNode, }, utils::{ clonecell::CloneCell, errorfmt::ErrorFmt, linkedlist::{LinkedList, LinkedNode, NodeRef}, numcell::NumCell, rc_eq::rc_eq, scroller::Scroller, smallmap::{SmallMap, SmallMapMut}, threshold_counter::ThresholdCounter, }, }, ahash::AHashMap, jay_config::Axis, smallvec::SmallVec, std::{ cell::{Cell, RefCell}, fmt::{Debug, Formatter}, mem, ops::{Deref, DerefMut, Sub}, rc::Rc, }, }; #[allow(dead_code)] #[derive(Copy, Clone, Debug, Eq, PartialEq)] pub enum ContainerSplit { Horizontal, Vertical, } impl From for ContainerSplit { fn from(a: Axis) -> Self { match a { Axis::Horizontal => Self::Horizontal, Axis::Vertical => Self::Vertical, } } } impl Into for ContainerSplit { fn into(self) -> Axis { match self { ContainerSplit::Horizontal => Axis::Horizontal, ContainerSplit::Vertical => Axis::Vertical, } } } #[allow(dead_code)] #[derive(Copy, Clone, Debug, Eq, PartialEq)] pub enum ContainerFocus { None, Child, Yes, } tree_id!(ContainerNodeId); pub struct ContainerTitle { pub x: i32, pub y: i32, pub tex: TextTexture, } #[derive(Default)] pub struct ContainerRenderData { pub title_rects: Vec, pub active_title_rects: Vec, pub attention_title_rects: Vec, pub last_active_rect: Option, pub border_rects: Vec, pub underline_rects: Vec, pub titles: SmallMapMut, 2>, } pub struct ContainerNode { pub id: ContainerNodeId, pub parent: CloneCell>, pub split: Cell, pub mono_child: CloneCell>>, pub mono_body: Cell, pub mono_content: Cell, pub abs_x1: Cell, pub abs_y1: Cell, pub width: Cell, pub height: Cell, pub content_width: Cell, pub content_height: Cell, pub sum_factors: Cell, layout_scheduled: Cell, compute_render_data_scheduled: Cell, num_children: NumCell, pub children: LinkedList, focus_history: LinkedList>, child_nodes: RefCell>>, workspace: CloneCell>, seats: RefCell>, state: Rc, pub render_data: RefCell, scroller: Scroller, toplevel_data: ToplevelData, attention_requests: ThresholdCounter, } impl Debug for ContainerNode { fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { f.debug_struct("ContainerNode").finish_non_exhaustive() } } pub struct ContainerChild { pub node: Rc, pub active: Cell, pub attention_requested: Cell, title: RefCell, pub title_tex: SmallMap, pub title_rect: Cell, focus_history: Cell>>>, // fields below only valid in tabbed layout pub body: Cell, pub content: Cell, factor: Cell, } struct SeatState { cursor: KnownCursor, target: bool, x: i32, y: i32, op: Option, } impl ContainerChild { fn position_content(&self) { let mut content = self.content.get(); let body = self.body.get(); let width = content.width(); let height = content.height(); // let x1 = body.x1() + (body.width() - width) / 2; // let y1 = body.y1() + (body.height() - height) / 2; let x1 = body.x1(); let y1 = body.y1(); content = Rect::new_sized(x1, y1, width, height).unwrap(); // log::debug!("body: {:?}", body); // log::debug!("content: {:?}", content); self.content.set(content); } } impl ContainerNode { pub fn new( state: &Rc, workspace: &Rc, parent: Rc, child: Rc, split: ContainerSplit, ) -> Rc { child.clone().tl_set_workspace(workspace); let children = LinkedList::new(); let child_node = children.add_last(ContainerChild { node: child.clone(), active: Default::default(), body: Default::default(), content: Default::default(), factor: Cell::new(1.0), title: Default::default(), title_tex: Default::default(), title_rect: Default::default(), focus_history: Default::default(), attention_requested: Cell::new(false), }); let child_node_ref = child_node.clone(); let mut child_nodes = AHashMap::new(); child_nodes.insert(child.node_id(), child_node); let slf = Rc::new(Self { id: state.node_ids.next(), parent: CloneCell::new(parent.clone()), split: Cell::new(split), mono_child: CloneCell::new(None), mono_body: Cell::new(Default::default()), mono_content: Cell::new(Default::default()), abs_x1: Cell::new(0), abs_y1: Cell::new(0), width: Cell::new(0), height: Cell::new(0), content_width: Cell::new(0), content_height: Cell::new(0), sum_factors: Cell::new(1.0), layout_scheduled: Cell::new(false), compute_render_data_scheduled: Cell::new(false), num_children: NumCell::new(1), children, focus_history: Default::default(), child_nodes: RefCell::new(child_nodes), workspace: CloneCell::new(workspace.clone()), seats: RefCell::new(Default::default()), state: state.clone(), render_data: Default::default(), scroller: Default::default(), toplevel_data: ToplevelData::new(state, Default::default(), None), attention_requests: Default::default(), }); slf.tl_set_parent(parent); child.tl_set_parent(slf.clone()); slf.apply_child_flags(&child_node_ref); slf } pub fn prepend_child(self: &Rc, new: Rc) { if let Some(child) = self.children.first() { self.add_child_before_(&child, new); } } pub fn append_child(self: &Rc, new: Rc) { if let Some(child) = self.children.last() { self.add_child_after_(&child, new); } } pub fn add_child_after(self: &Rc, prev: &dyn Node, new: Rc) { self.add_child_x(prev, new, |prev, new| self.add_child_after_(prev, new)); } pub fn add_child_before(self: &Rc, prev: &dyn Node, new: Rc) { self.add_child_x(prev, new, |prev, new| self.add_child_before_(prev, new)); } fn add_child_x(self: &Rc, prev: &dyn Node, new: Rc, f: F) where F: FnOnce(&NodeRef, Rc), { let node = self .child_nodes .borrow() .get(&prev.node_id()) .map(|n| n.to_ref()); if let Some(node) = node { f(&node, new); return; } log::error!( "Tried to add a child to a container but the preceding node is not in the container" ); } fn add_child_after_( self: &Rc, prev: &NodeRef, new: Rc, ) { self.add_child(|cc| prev.append(cc), new); } fn add_child_before_( self: &Rc, prev: &NodeRef, new: Rc, ) { self.add_child(|cc| prev.prepend(cc), new); } fn add_child(self: &Rc, f: F, new: Rc) where F: FnOnce(ContainerChild) -> LinkedNode, { let new_ref = { let mut links = self.child_nodes.borrow_mut(); if links.contains_key(&new.node_id()) { log::error!("Tried to add a child to a container that already contains the child"); return; } let link = f(ContainerChild { node: new.clone(), active: Default::default(), body: Default::default(), content: Default::default(), factor: Default::default(), title: Default::default(), title_tex: Default::default(), title_rect: Default::default(), focus_history: Default::default(), attention_requested: Default::default(), }); let r = link.to_ref(); links.insert(new.node_id(), link); r }; self.apply_child_flags(&new_ref); new.clone().tl_set_workspace(&self.workspace.get()); new.tl_set_parent(self.clone()); new.tl_set_visible(self.toplevel_data.visible.get()); let num_children = self.num_children.fetch_add(1) + 1; self.update_content_size(); let new_child_factor = 1.0 / num_children as f64; let mut sum_factors = 0.0; for child in self.children.iter() { let factor = if rc_eq(&child.node, &new) { new_child_factor } else { child.factor.get() * (1.0 - new_child_factor) }; child.factor.set(factor); sum_factors += factor; } self.sum_factors.set(sum_factors); if self.mono_child.get().is_some() { self.activate_child(&new_ref); } // log::info!("add_child"); self.schedule_layout(); self.cancel_seat_ops(); } fn cancel_seat_ops(&self) { let mut seats = self.seats.borrow_mut(); for seat in seats.values_mut() { seat.op = None; } } pub fn on_spaces_changed(self: &Rc) { self.update_content_size(); // log::info!("on_spaces_changed"); self.schedule_layout(); } pub fn on_colors_changed(self: &Rc) { // log::info!("on_colors_changed"); self.schedule_compute_render_data(); } fn schedule_layout(self: &Rc) { if !self.layout_scheduled.replace(true) { self.state.pending_container_layout.push(self.clone()); } } fn perform_layout(self: &Rc) { if self.num_children.get() == 0 { return; } self.layout_scheduled.set(false); if let Some(child) = self.mono_child.get() { self.perform_mono_layout(&child); } else { self.perform_split_layout(); } self.state.tree_changed(); // log::info!("perform_layout"); self.schedule_compute_render_data(); } fn perform_mono_layout(self: &Rc, child: &ContainerChild) { let mb = self.mono_body.get(); child .node .clone() .tl_change_extents(&mb.move_(self.abs_x1.get(), self.abs_y1.get())); self.mono_content .set(child.content.get().at_point(mb.x1(), mb.y1())); let th = self.state.theme.sizes.title_height.get(); let bw = self.state.theme.sizes.border_width.get(); let num_children = self.num_children.get() as i32; let content_width = self.width.get().sub(bw * (num_children - 1)).max(0); let width_per_child = content_width / num_children; let mut rem = content_width % num_children; let mut pos = 0; for child in self.children.iter() { let mut width = width_per_child; if rem > 0 { width += 1; rem -= 1; } child .title_rect .set(Rect::new_sized(pos, 0, width, th).unwrap()); pos += width + bw; } } fn perform_split_layout(self: &Rc) { let sum_factors = self.sum_factors.get(); let border_width = self.state.theme.sizes.border_width.get(); let title_height = self.state.theme.sizes.title_height.get(); let split = self.split.get(); let (content_size, other_content_size) = match split { ContainerSplit::Horizontal => (self.content_width.get(), self.content_height.get()), ContainerSplit::Vertical => (self.content_height.get(), self.content_width.get()), }; let num_children = self.num_children.get(); if num_children == 0 { return; } let mut pos = 0; let mut remaining_content_size = content_size; for child in self.children.iter() { let factor = child.factor.get() / sum_factors; child.factor.set(factor); let mut body_size = (content_size as f64 * factor).round() as i32; body_size = body_size.min(remaining_content_size); remaining_content_size -= body_size; let (x1, y1, width, height) = match split { ContainerSplit::Horizontal => { (pos, title_height + 1, body_size, other_content_size) } _ => (0, pos + title_height + 1, other_content_size, body_size), }; let body = Rect::new_sized(x1, y1, width, height).unwrap(); child.body.set(body); pos += body_size + border_width; if split == ContainerSplit::Vertical { pos += title_height + 1; } } if remaining_content_size > 0 { let size_per = remaining_content_size / num_children as i32; let mut rem = remaining_content_size % num_children as i32; pos = 0; for child in self.children.iter() { let mut body = child.body.get(); let mut add = size_per; if rem > 0 { rem -= 1; add += 1; } let (x1, y1, width, height, size) = match split { ContainerSplit::Horizontal => { let width = body.width() + add; (pos, title_height + 1, width, other_content_size, width) } _ => { let height = body.height() + add; ( 0, pos + title_height + 1, other_content_size, height, height, ) } }; body = Rect::new_sized(x1, y1, width, height).unwrap(); child.body.set(body); pos += size + border_width; if split == ContainerSplit::Vertical { pos += title_height + 1; } } } self.sum_factors.set(1.0); for child in self.children.iter() { let body = child.body.get(); child.title_rect.set( Rect::new_sized( body.x1(), body.y1() - title_height - 1, body.width(), title_height, ) .unwrap(), ); let body = body.move_(self.abs_x1.get(), self.abs_y1.get()); child.node.clone().tl_change_extents(&body); child.position_content(); } } fn update_content_size(&self) { let border_width = self.state.theme.sizes.border_width.get(); let title_height = self.state.theme.sizes.title_height.get(); let nc = self.num_children.get(); match self.split.get() { ContainerSplit::Horizontal => { let new_content_size = self.width.get().sub((nc - 1) as i32 * border_width).max(0); self.content_width.set(new_content_size); self.content_height .set(self.height.get().sub(title_height + 1).max(0)); } ContainerSplit::Vertical => { let new_content_size = self .height .get() .sub(title_height + 1 + (nc - 1) as i32 * (border_width + title_height + 1)) .max(0); self.content_height.set(new_content_size); self.content_width.set(self.width.get()); } } self.mono_body.set( Rect::new_sized( 0, title_height + 1, self.width.get(), self.height.get().sub(title_height + 1).max(0), ) .unwrap(), ); } fn pointer_move(self: &Rc, seat: &Rc, mut x: i32, mut y: i32) { let title_height = self.state.theme.sizes.title_height.get(); let mut seats = self.seats.borrow_mut(); let seat_state = seats.entry(seat.id()).or_insert_with(|| SeatState { cursor: KnownCursor::Default, target: false, x, y, op: None, }); let mut changed = false; changed |= mem::replace(&mut seat_state.x, x) != x; changed |= mem::replace(&mut seat_state.y, y) != y; if !changed { return; } if let Some(op) = &seat_state.op { match op.kind { SeatOpKind::Move => { // todo } SeatOpKind::Resize { dist_left, dist_right, } => { let prev = op.child.prev().unwrap(); let prev_body = prev.body.get(); let child_body = op.child.body.get(); let (prev_factor, child_factor) = match self.split.get() { ContainerSplit::Horizontal => { let cw = self.content_width.get(); x = x .max(prev_body.x1() + dist_left) .min(child_body.x2() - dist_right); let prev_factor = (x - prev_body.x1() - dist_left) as f64 / cw as f64; let child_factor = (child_body.x2() - x - dist_right) as f64 / cw as f64; (prev_factor, child_factor) } ContainerSplit::Vertical => { let ch = self.content_height.get(); y = y .max(prev_body.y1() + dist_left) .min(child_body.y2() - dist_right); let prev_factor = (y - prev_body.y1() - dist_left) as f64 / ch as f64; let child_factor = (child_body.y2() - y - dist_right) as f64 / ch as f64; (prev_factor, child_factor) } }; let sum_factors = self.sum_factors.get() - prev.factor.get() - op.child.factor.get() + prev_factor + child_factor; prev.factor.set(prev_factor); op.child.factor.set(child_factor); self.sum_factors.set(sum_factors); // log::info!("pointer_move"); self.schedule_layout(); } } return; } let new_cursor = if self.mono_child.get().is_some() { KnownCursor::Default } else if self.split.get() == ContainerSplit::Horizontal { if y < title_height + 1 { KnownCursor::Default } else { KnownCursor::EwResize } } else { let mut cursor = KnownCursor::Default; for child in self.children.iter() { let body = child.body.get(); if body.y1() > y { if body.y1() - y > title_height + 1 { cursor = KnownCursor::NsResize } break; } } cursor }; if new_cursor != mem::replace(&mut seat_state.cursor, new_cursor) { if seat_state.target { seat.set_known_cursor(new_cursor); } } } fn update_title(self: &Rc) { let mut title = self.toplevel_data.title.borrow_mut(); title.clear(); let split = match (self.mono_child.get().is_some(), self.split.get()) { (true, _) => "T", (_, ContainerSplit::Horizontal) => "H", (_, ContainerSplit::Vertical) => "V", }; title.push_str(split); title.push_str("["); for (i, c) in self.children.iter().enumerate() { if i > 0 { title.push_str(", "); } title.push_str(c.title.borrow_mut().deref()); } title.push_str("]"); drop(title); self.tl_title_changed(); } pub fn schedule_compute_render_data(self: &Rc) { if !self.compute_render_data_scheduled.replace(true) { self.state.pending_container_render_data.push(self.clone()); } } fn compute_render_data(&self) { self.compute_render_data_scheduled.set(false); let mut rd = self.render_data.borrow_mut(); let rd = rd.deref_mut(); let theme = &self.state.theme; let th = theme.sizes.title_height.get(); let bw = theme.sizes.border_width.get(); let font = theme.font.borrow_mut(); let cwidth = self.width.get(); let cheight = self.height.get(); let ctx = self.state.render_ctx.get(); for (_, v) in rd.titles.iter_mut() { v.clear(); } rd.title_rects.clear(); rd.active_title_rects.clear(); rd.attention_title_rects.clear(); rd.border_rects.clear(); rd.underline_rects.clear(); rd.last_active_rect.take(); let last_active = self.focus_history.last().map(|v| v.node.node_id()); let mono = self.mono_child.get().is_some(); let split = self.split.get(); let have_active = self.children.iter().any(|c| c.active.get()); let scales = self.state.scales.lock(); for (i, child) in self.children.iter().enumerate() { let rect = child.title_rect.get(); if i > 0 { let rect = if mono { Rect::new_sized(rect.x1() - bw, 0, bw, th) } else if split == ContainerSplit::Horizontal { Rect::new_sized(rect.x1() - bw, 0, bw, cheight) } else { Rect::new_sized(0, rect.y1() - bw, cwidth, bw) }; rd.border_rects.push(rect.unwrap()); } let color = if child.active.get() { rd.active_title_rects.push(rect); theme.colors.focused_title_text.get() } else if child.attention_requested.get() { rd.attention_title_rects.push(rect); theme.colors.unfocused_title_text.get() } else if !have_active && last_active == Some(child.node.node_id()) { rd.last_active_rect = Some(rect); theme.colors.focused_inactive_title_text.get() } else { rd.title_rects.push(rect); theme.colors.unfocused_title_text.get() }; if !mono { let rect = Rect::new_sized(rect.x1(), rect.y2(), rect.width(), 1).unwrap(); rd.underline_rects.push(rect); } let title = child.title.borrow_mut(); for (scale, _) in scales.iter() { let old_tex = child.title_tex.remove(scale); let titles = rd.titles.get_or_default_mut(*scale); 'render_title: { let mut th = th; let mut scalef = None; let mut width = rect.width(); if *scale != 1 { let scale = scale.to_f64(); th = (th as f64 * scale).round() as _; width = (width as f64 * scale).round() as _; scalef = Some(scale); } if th == 0 || width == 0 || title.is_empty() { break 'render_title; } if let Some(ctx) = &ctx { match text::render( ctx, old_tex, width, th, &font, title.deref(), color, scalef, ) { Ok(t) => { child.title_tex.insert(*scale, t.clone()); titles.push(ContainerTitle { x: rect.x1(), y: rect.y1(), tex: t, }) } Err(e) => { log::error!("Could not render title {}: {}", title, ErrorFmt(e)); } } } } } } if mono { rd.underline_rects .push(Rect::new_sized(0, th, cwidth, 1).unwrap()); } rd.titles.remove_if(|_, v| v.is_empty()); } fn activate_child(self: &Rc, child: &NodeRef) { self.activate_child2(child, false); } fn activate_child2(self: &Rc, child: &NodeRef, preserve_focus: bool) { if let Some(mc) = self.mono_child.get() { if mc.node.node_id() == child.node.node_id() { return; } if !preserve_focus { let seats = collect_kb_foci(mc.node.clone().tl_into_node()); mc.node.tl_set_visible(false); for seat in seats { child .node .clone() .node_do_focus(&seat, Direction::Unspecified); } } self.mono_child.set(Some(child.clone())); child.node.tl_set_visible(true); // log::info!("activate_child2"); self.schedule_layout(); } } pub fn set_mono(self: &Rc, child: Option<&dyn ToplevelNode>) { if self.mono_child.get().is_some() == child.is_some() { return; } let child = { let children = self.child_nodes.borrow(); match child { Some(c) => match children.get(&c.node_id()) { Some(c) => Some(c.to_ref()), _ => { log::warn!("set_mono called with a node that is not a child"); return; } }, _ => None, } }; if self.toplevel_data.visible.get() { if let Some(child) = &child { let child_id = child.node.node_id(); let mut seats = SmallVec::<[_; 3]>::new(); for other in self.children.iter() { if other.node.node_id() != child_id { collect_kb_foci2(other.node.clone().tl_into_node(), &mut seats); other.node.tl_set_visible(false); } } for seat in seats { child .node .clone() .node_do_focus(&seat, Direction::Unspecified); } } else { for child in self.children.iter() { child.node.tl_set_visible(true); } } } self.mono_child.set(child); // log::info!("set_mono"); self.schedule_layout(); self.update_title(); } pub fn set_split(self: &Rc, split: ContainerSplit) { if self.split.replace(split) != split { self.update_content_size(); // log::info!("set_split"); self.schedule_layout(); self.update_title(); } } pub fn move_focus_from_child( self: Rc, seat: &Rc, child: &dyn ToplevelNode, direction: Direction, ) { let child = match self.child_nodes.borrow().get(&child.node_id()) { Some(c) => c.to_ref(), _ => return, }; let mc = self.mono_child.get(); let in_line = if mc.is_some() { matches!(direction, Direction::Left | Direction::Right) } else { match self.split.get() { ContainerSplit::Horizontal => { matches!(direction, Direction::Left | Direction::Right) } ContainerSplit::Vertical => matches!(direction, Direction::Up | Direction::Down), } }; if !in_line { if let Some(c) = self.parent.get().node_into_container() { c.move_focus_from_child(seat, self.deref(), direction); } return; } let prev = match direction { Direction::Left => true, Direction::Down => false, Direction::Up => true, Direction::Right => false, Direction::Unspecified => true, }; let sibling = match prev { true => child.prev(), false => child.next(), }; let sibling = match sibling { Some(s) => s, None => { if let Some(c) = self.parent.get().node_into_container() { c.move_focus_from_child(seat, self.deref(), direction); } return; } }; if mc.is_some() { self.activate_child(&sibling); } else { sibling.node.clone().node_do_focus(seat, direction); } } // pub fn move_child(self: Rc, child: Rc, direction: Direction) { // CASE 1: This is the only child of the container. Replace the container by the child. if self.num_children.get() == 1 { let parent = self.parent.get(); if !self.toplevel_data.is_fullscreen.get() && parent.cnode_accepts_child(child.tl_as_node()) { parent.cnode_replace_child(self.deref(), child.clone()); } return; } let (split, prev) = direction_to_split(direction); // CASE 2: We're moving the child within the container. if split == self.split.get() || (split == ContainerSplit::Horizontal && self.mono_child.get().is_some()) { let cc = match self.child_nodes.borrow().get(&child.node_id()) { Some(l) => l.to_ref(), None => return, }; let neighbor = match prev { true => cc.prev(), false => cc.next(), }; if let Some(neighbor) = neighbor { if let Some(cn) = neighbor.node.clone().node_into_container() { if cn.cnode_accepts_child(child.tl_as_node()) { self.cnode_remove_child2(child.tl_as_node(), true); cn.insert_child(child, direction); return; } } match prev { true => neighbor.prepend_existing(&cc), false => neighbor.append_existing(&cc), } // log::info!("move_child"); self.schedule_layout(); return; } } // CASE 3: We're moving the child out of the container. let mut neighbor = self.clone(); let mut parent_opt = self.parent.get().node_into_container(); while let Some(parent) = &parent_opt { if parent.split.get() == split { break; } neighbor = parent.clone(); parent_opt = parent.parent.get().node_into_container(); } let parent = match parent_opt { Some(p) => p, _ => return, }; self.cnode_remove_child2(child.tl_as_node(), true); match prev { true => parent.add_child_before(&*neighbor, child.clone()), false => parent.add_child_after(&*neighbor, child.clone()), } } pub fn insert_child(self: &Rc, node: Rc, direction: Direction) { let (split, right) = direction_to_split(direction); if split != self.split.get() || right { self.append_child(node); } else { self.prepend_child(node); } } fn apply_child_flags(&self, child: &ContainerChild) { let data = child.node.tl_data(); let attention_requested = data.wants_attention.get(); child.attention_requested.set(attention_requested); if attention_requested { self.mod_attention_requests(true); } } fn discard_child_flags(&self, child: &ContainerChild) { if child.attention_requested.get() { self.mod_attention_requests(false); } } fn mod_attention_requests(&self, set: bool) { let propagate = self.attention_requests.adj(set); if set || propagate { self.toplevel_data.wants_attention.set(set); } if propagate { self.parent .get() .cnode_child_attention_request_changed(self, set); } } } struct SeatOp { child: NodeRef, kind: SeatOpKind, } #[derive(Copy, Clone, Debug, Eq, PartialEq)] enum SeatOpKind { Move, Resize { dist_left: i32, dist_right: i32 }, } pub async fn container_layout(state: Rc) { loop { let container = state.pending_container_layout.pop().await; if container.layout_scheduled.get() { container.perform_layout(); } } } pub async fn container_render_data(state: Rc) { loop { let container = state.pending_container_render_data.pop().await; if container.compute_render_data_scheduled.get() { container.compute_render_data(); } } } impl Node for ContainerNode { fn node_id(&self) -> NodeId { self.id.into() } fn node_seat_state(&self) -> &NodeSeatState { &self.toplevel_data.seat_state } fn node_visit(self: Rc, visitor: &mut dyn NodeVisitor) { visitor.visit_container(&self); } fn node_visit_children(&self, visitor: &mut dyn NodeVisitor) { for child in self.children.iter() { child.node.clone().node_visit(visitor); } } fn node_visible(&self) -> bool { self.toplevel_data.visible.get() } fn node_absolute_position(&self) -> Rect { Rect::new_sized( self.abs_x1.get(), self.abs_y1.get(), self.width.get(), self.height.get(), ) .unwrap() } fn node_child_title_changed(self: Rc, child: &dyn Node, title: &str) { let child = match self.child_nodes.borrow().get(&child.node_id()) { Some(cn) => cn.to_ref(), _ => return, }; { let mut ct = child.title.borrow_mut(); if ct.deref() == title { return; } ct.clear(); ct.push_str(title); } self.update_title(); // log::info!("node_child_title_changed"); self.schedule_compute_render_data(); } fn node_do_focus(self: Rc, seat: &Rc, direction: Direction) { let node = if let Some(cn) = self.mono_child.get() { Some(cn) } else { let split = self.split.get(); match (direction, split) { (Direction::Left, ContainerSplit::Horizontal) => self.children.last(), (Direction::Down, ContainerSplit::Vertical) => self.children.first(), (Direction::Up, ContainerSplit::Vertical) => self.children.last(), (Direction::Right, ContainerSplit::Horizontal) => self.children.first(), _ => match self.focus_history.last() { Some(n) => Some(n.deref().clone()), None => self.children.last(), }, } }; if let Some(node) = node { node.node.clone().node_do_focus(seat, direction); } } fn node_active_changed(&self, active: bool) { self.toplevel_data.active.set(active); self.parent.get().node_child_active_changed(self, active, 1); } fn node_find_tree_at(&self, x: i32, y: i32, tree: &mut Vec) -> FindTreeResult { let mut recurse = |content: Rect, child: NodeRef| { if content.contains(x, y) { let (x, y) = content.translate(x, y); tree.push(FoundNode { node: child.node.clone().tl_into_node(), x, y, }); child.node.node_find_tree_at(x, y, tree); } }; if let Some(child) = self.mono_child.get() { recurse(self.mono_content.get(), child); } else { for child in self.children.iter() { if child.body.get().contains(x, y) { recurse(child.content.get(), child); break; } } } FindTreeResult::AcceptsInput } fn node_child_size_changed(&self, child: &dyn Node, width: i32, height: i32) { let cn = self.child_nodes.borrow(); if let Some(node) = cn.get(&child.node_id()) { let rect = Rect::new(0, 0, width, height).unwrap(); node.content.set(rect); node.position_content(); if let Some(mono) = self.mono_child.get() { if mono.node.node_id() == node.node.node_id() { let body = self.mono_body.get(); self.mono_content.set(rect.at_point(body.x1(), body.y1())); } } } } fn node_child_active_changed(self: Rc, child: &dyn Node, active: bool, depth: u32) { let node = match self.child_nodes.borrow().get(&child.node_id()) { Some(l) => l.to_ref(), None => return, }; if depth == 1 { node.active.set(active); } if active { node.focus_history .set(Some(self.focus_history.add_last(node.clone()))); } // log::info!("node_child_active_changed"); self.schedule_compute_render_data(); self.parent .get() .node_child_active_changed(self.deref(), active, depth + 1); } fn node_render(&self, renderer: &mut Renderer, x: i32, y: i32, _bounds: Option<&Rect>) { renderer.render_container(self, x, y); } fn node_toplevel(self: Rc) -> Option> { Some(self) } fn node_on_button( self: Rc, seat: &Rc, _time_usec: u64, button: u32, state: KeyState, _serial: u32, ) { if button != BTN_LEFT { return; } let mut seat_datas = self.seats.borrow_mut(); let seat_data = match seat_datas.get_mut(&seat.id()) { Some(s) => s, _ => return, }; if seat_data.op.is_none() { if state != KeyState::Pressed { return; } let (kind, child) = 'res: { let mono = self.mono_child.get().is_some(); for child in self.children.iter() { let rect = child.title_rect.get(); if rect.contains(seat_data.x, seat_data.y) { self.activate_child(&child); child .node .clone() .node_do_focus(seat, Direction::Unspecified); break 'res (SeatOpKind::Move, child); } else if !mono { if self.split.get() == ContainerSplit::Horizontal { if seat_data.x < rect.x1() { break 'res ( SeatOpKind::Resize { dist_left: seat_data.x - child.prev().unwrap().body.get().x2(), dist_right: child.body.get().x1() - seat_data.x, }, child, ); } } else { if seat_data.y < rect.y1() { break 'res ( SeatOpKind::Resize { dist_left: seat_data.y - child.prev().unwrap().body.get().y2(), dist_right: child.body.get().y1() - seat_data.y, }, child, ); } } } } return; }; seat_data.op = Some(SeatOp { child, kind }) } else if state == KeyState::Released { let op = seat_data.op.take().unwrap(); drop(seat_datas); if op.kind == SeatOpKind::Move { // todo } } } fn node_on_axis_event(self: Rc, seat: &Rc, event: &PendingScroll) { let mut seat_datas = self.seats.borrow_mut(); let seat_data = match seat_datas.get_mut(&seat.id()) { Some(s) => s, _ => return, }; if seat_data.y > self.state.theme.sizes.title_height.get() { return; } let cur_mc = match self.mono_child.get() { Some(mc) => mc, _ => return, }; let discrete = match self.scroller.handle(event) { Some(d) => d, _ => return, }; let mut new_mc = cur_mc.clone(); for _ in 0..discrete.abs() { let new = if discrete < 0 { new_mc.prev() } else { new_mc.next() }; new_mc = match new { Some(n) => n, None => break, }; } self.activate_child(&new_mc); new_mc .node .clone() .node_do_focus(seat, Direction::Unspecified); } fn node_on_pointer_enter(self: Rc, seat: &Rc, x: Fixed, y: Fixed) { // log::info!("node_on_pointer_enter"); self.pointer_move(seat, x.round_down(), y.round_down()); } fn node_on_pointer_unfocus(&self, seat: &Rc) { // log::info!("unfocus"); let mut seats = self.seats.borrow_mut(); if let Some(seat_state) = seats.get_mut(&seat.id()) { seat_state.target = false; } } fn node_on_pointer_focus(&self, seat: &Rc) { // log::info!("container focus"); let mut seats = self.seats.borrow_mut(); if let Some(seat_state) = seats.get_mut(&seat.id()) { seat_state.target = true; seat.set_known_cursor(seat_state.cursor); } } fn node_on_pointer_motion(self: Rc, seat: &Rc, x: Fixed, y: Fixed) { // log::info!("node_on_pointer_motion"); self.pointer_move(seat, x.round_down(), y.round_down()); } fn node_into_container(self: Rc) -> Option> { Some(self.clone()) } fn node_into_containing_node(self: Rc) -> Option> { Some(self) } fn node_is_container(&self) -> bool { true } } impl ContainingNode for ContainerNode { containing_node_impl!(); fn cnode_replace_child(self: Rc, old: &dyn Node, new: Rc) { let node = match self.child_nodes.borrow_mut().remove(&old.node_id()) { Some(c) => c, None => { log::error!("Trying to replace a node that isn't a child of this container"); return; } }; let (have_mc, was_mc) = match self.mono_child.get() { None => (false, false), Some(mc) => (true, mc.node.node_id() == old.node_id()), }; self.discard_child_flags(&node); let link = node.append(ContainerChild { node: new.clone(), active: Cell::new(false), body: Cell::new(node.body.get()), content: Default::default(), factor: Cell::new(node.factor.get()), title: Default::default(), title_tex: Default::default(), title_rect: Cell::new(node.title_rect.get()), focus_history: Cell::new(None), attention_requested: Cell::new(false), }); self.apply_child_flags(&link); if let Some(fh) = node.focus_history.take() { link.focus_history.set(Some(fh.append(link.to_ref()))); } new.tl_set_visible(node.node.node_visible()); drop(node); let mut body = None; if was_mc { self.mono_child.set(Some(link.to_ref())); body = Some(self.mono_body.get()); } else if !have_mc { body = Some(link.body.get()); }; self.child_nodes.borrow_mut().insert(new.node_id(), link); new.tl_set_parent(self.clone()); new.clone().tl_set_workspace(&self.workspace.get()); if let Some(body) = body { let body = body.move_(self.abs_x1.get(), self.abs_y1.get()); new.clone().tl_change_extents(&body); } } fn cnode_remove_child2(self: Rc, child: &dyn Node, preserve_focus: bool) { let node = match self.child_nodes.borrow_mut().remove(&child.node_id()) { Some(c) => c, None => return, }; node.focus_history.set(None); self.discard_child_flags(&node); if let Some(mono) = self.mono_child.get() { if mono.node.node_id() == child.node_id() { let mut new = self.focus_history.last().map(|n| n.deref().clone()); if new.is_none() { new = node.next(); if new.is_none() { new = node.prev(); } } if let Some(child) = &new { self.activate_child2(child, preserve_focus); } } } let node = { let node = node; node.focus_history.set(None); node.to_ref() }; let num_children = self.num_children.fetch_sub(1) - 1; if num_children == 0 { self.tl_destroy(); return; } self.update_content_size(); let rem = 1.0 - node.factor.get(); let mut sum = 0.0; if rem <= 0.0 { let factor = 1.0 / num_children as f64; for child in self.children.iter() { child.factor.set(factor) } sum = 1.0; } else { for child in self.children.iter() { let factor = child.factor.get() / rem; child.factor.set(factor); sum += factor; } } self.sum_factors.set(sum); self.update_title(); // log::info!("cnode_remove_child2"); self.schedule_layout(); self.cancel_seat_ops(); } fn cnode_accepts_child(&self, _node: &dyn Node) -> bool { true } fn cnode_child_attention_request_changed(self: Rc, child: &dyn Node, set: bool) { let children = self.child_nodes.borrow(); let child = match children.get(&child.node_id()) { Some(c) => c, _ => return, }; if child.attention_requested.replace(set) == set { return; } self.mod_attention_requests(set); self.schedule_compute_render_data(); } } impl ToplevelNode for ContainerNode { tl_node_impl!(); fn tl_data(&self) -> &ToplevelData { &self.toplevel_data } fn tl_default_focus_child(&self) -> Option> { self.focus_history .last() .map(|v| v.node.clone()) .or_else(|| self.children.first().map(|c| c.node.clone())) .map(|tl| tl.tl_into_node()) } fn tl_after_parent_set(&self, parent: Rc) { self.parent.set(parent); } fn tl_set_workspace_ext(self: Rc, ws: &Rc) { for child in self.children.iter() { child.node.clone().tl_set_workspace(ws); } } fn tl_change_extents(self: Rc, rect: &Rect) { self.toplevel_data.pos.set(*rect); self.abs_x1.set(rect.x1()); self.abs_y1.set(rect.y1()); let mut size_changed = false; size_changed |= self.width.replace(rect.width()) != rect.width(); size_changed |= self.height.replace(rect.height()) != rect.height(); if size_changed { self.update_content_size(); // log::info!("tl_change_extents"); self.perform_layout(); self.cancel_seat_ops(); self.parent .get() .node_child_size_changed(self.deref(), rect.width(), rect.height()); } else { if let Some(c) = self.mono_child.get() { let body = self .mono_body .get() .move_(self.abs_x1.get(), self.abs_y1.get()); c.node.clone().tl_change_extents(&body); } else { for child in self.children.iter() { let body = child.body.get().move_(self.abs_x1.get(), self.abs_y1.get()); child.node.clone().tl_change_extents(&body); } } } } fn tl_close(self: Rc) { for child in self.children.iter() { child.node.clone().tl_close(); } } fn tl_set_visible(&self, visible: bool) { if let Some(mc) = self.mono_child.get() { mc.node.tl_set_visible(visible); } else { for child in self.children.iter() { child.node.tl_set_visible(visible); } } self.toplevel_data.set_visible(self, visible); } fn tl_destroy(&self) { self.toplevel_data.destroy_node(self); mem::take(self.seats.borrow_mut().deref_mut()); let mut cn = self.child_nodes.borrow_mut(); for (_, n) in cn.drain() { n.node.tl_destroy(); } } fn tl_last_active_child(self: Rc) -> Rc { if let Some(last) = self.focus_history.last() { return last.node.clone().tl_last_active_child(); } self } } fn direction_to_split(dir: Direction) -> (ContainerSplit, bool) { match dir { Direction::Left => (ContainerSplit::Horizontal, true), Direction::Down => (ContainerSplit::Vertical, false), Direction::Up => (ContainerSplit::Vertical, true), Direction::Right => (ContainerSplit::Horizontal, false), Direction::Unspecified => (ContainerSplit::Horizontal, true), } }