use crate::{ item::{ClosePosition, Item, ItemHandle, ItemSettings, WeakItemHandle}, toolbar::Toolbar, workspace_settings::{AutosaveSetting, WorkspaceSettings}, NewCenterTerminal, NewFile, NewSearch, SplitDirection, ToggleZoom, Workspace, }; use anyhow::Result; use collections::{HashMap, HashSet, VecDeque}; use gpui::{ actions, impl_actions, overlay, prelude::*, Action, AnchorCorner, AnyElement, AppContext, AsyncWindowContext, DismissEvent, Div, DragMoveEvent, EntityId, EventEmitter, FocusHandle, FocusableView, Model, MouseButton, NavigationDirection, Pixels, Point, PromptLevel, Render, ScrollHandle, Subscription, Task, View, ViewContext, VisualContext, WeakView, WindowContext, }; use parking_lot::Mutex; use project::{Project, ProjectEntryId, ProjectPath}; use serde::Deserialize; use settings::Settings; use std::{ any::Any, cmp, fmt, mem, path::{Path, PathBuf}, rc::Rc, sync::{ atomic::{AtomicUsize, Ordering}, Arc, }, }; use theme::ThemeSettings; use ui::{ prelude::*, right_click_menu, ButtonSize, Color, Icon, IconButton, IconSize, Indicator, Label, Tab, TabBar, TabPosition, Tooltip, }; use ui::{v_stack, ContextMenu}; use util::{maybe, truncate_and_remove_front, ResultExt}; #[derive(PartialEq, Clone, Copy, Deserialize, Debug)] #[serde(rename_all = "camelCase")] pub enum SaveIntent { /// write all files (even if unchanged) /// prompt before overwriting on-disk changes Save, /// write any files that have local changes /// prompt before overwriting on-disk changes SaveAll, /// always prompt for a new path SaveAs, /// prompt "you have unsaved changes" before writing Close, /// write all dirty files, don't prompt on conflict Overwrite, /// skip all save-related behavior Skip, } #[derive(Clone, Deserialize, PartialEq, Debug)] pub struct ActivateItem(pub usize); // #[derive(Clone, PartialEq)] // pub struct CloseItemById { // pub item_id: usize, // pub pane: WeakView, // } // #[derive(Clone, PartialEq)] // pub struct CloseItemsToTheLeftById { // pub item_id: usize, // pub pane: WeakView, // } // #[derive(Clone, PartialEq)] // pub struct CloseItemsToTheRightById { // pub item_id: usize, // pub pane: WeakView, // } #[derive(Clone, PartialEq, Debug, Deserialize, Default)] #[serde(rename_all = "camelCase")] pub struct CloseActiveItem { pub save_intent: Option, } #[derive(Clone, PartialEq, Debug, Deserialize, Default)] #[serde(rename_all = "camelCase")] pub struct CloseAllItems { pub save_intent: Option, } #[derive(Clone, PartialEq, Debug, Deserialize)] #[serde(rename_all = "camelCase")] pub struct RevealInProjectPanel { pub entry_id: u64, } impl_actions!( pane, [ CloseAllItems, CloseActiveItem, ActivateItem, RevealInProjectPanel ] ); actions!( pane, [ ActivatePrevItem, ActivateNextItem, ActivateLastItem, CloseInactiveItems, CloseCleanItems, CloseItemsToTheLeft, CloseItemsToTheRight, GoBack, GoForward, ReopenClosedItem, SplitLeft, SplitUp, SplitRight, SplitDown, ] ); const MAX_NAVIGATION_HISTORY_LEN: usize = 1024; pub enum Event { AddItem { item: Box }, ActivateItem { local: bool }, Remove, RemoveItem { item_id: EntityId }, Split(SplitDirection), ChangeItemTitle, Focus, ZoomIn, ZoomOut, } impl fmt::Debug for Event { fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { match self { Event::AddItem { item } => f .debug_struct("AddItem") .field("item", &item.item_id()) .finish(), Event::ActivateItem { local } => f .debug_struct("ActivateItem") .field("local", local) .finish(), Event::Remove => f.write_str("Remove"), Event::RemoveItem { item_id } => f .debug_struct("RemoveItem") .field("item_id", item_id) .finish(), Event::Split(direction) => f .debug_struct("Split") .field("direction", direction) .finish(), Event::ChangeItemTitle => f.write_str("ChangeItemTitle"), Event::Focus => f.write_str("Focus"), Event::ZoomIn => f.write_str("ZoomIn"), Event::ZoomOut => f.write_str("ZoomOut"), } } } pub struct Pane { focus_handle: FocusHandle, items: Vec>, activation_history: Vec, zoomed: bool, was_focused: bool, active_item_index: usize, last_focused_view_by_item: HashMap, nav_history: NavHistory, toolbar: View, new_item_menu: Option>, split_item_menu: Option>, // tab_context_menu: View, workspace: WeakView, project: Model, drag_split_direction: Option, can_drop_predicate: Option bool>>, can_split: bool, render_tab_bar_buttons: Rc) -> AnyElement>, _subscriptions: Vec, tab_bar_scroll_handle: ScrollHandle, display_nav_history_buttons: bool, } pub struct ItemNavHistory { history: NavHistory, item: Arc, } #[derive(Clone)] pub struct NavHistory(Arc>); struct NavHistoryState { mode: NavigationMode, backward_stack: VecDeque, forward_stack: VecDeque, closed_stack: VecDeque, paths_by_item: HashMap)>, pane: WeakView, next_timestamp: Arc, } #[derive(Copy, Clone)] pub enum NavigationMode { Normal, GoingBack, GoingForward, ClosingItem, ReopeningClosedItem, Disabled, } impl Default for NavigationMode { fn default() -> Self { Self::Normal } } pub struct NavigationEntry { pub item: Arc, pub data: Option>, pub timestamp: usize, } #[derive(Clone)] pub struct DraggedTab { pub pane: View, pub ix: usize, pub item_id: EntityId, pub detail: usize, pub is_active: bool, } // pub struct DraggedItem { // pub handle: Box, // pub pane: WeakView, // } // pub enum ReorderBehavior { // None, // MoveAfterActive, // MoveToIndex(usize), // } // #[derive(Debug, Clone, Copy, PartialEq, Eq)] // enum TabBarContextMenuKind { // New, // Split, // } // struct TabBarContextMenu { // kind: TabBarContextMenuKind, // handle: View, // } // impl TabBarContextMenu { // fn handle_if_kind(&self, kind: TabBarContextMenuKind) -> Option> { // if self.kind == kind { // return Some(self.handle.clone()); // } // None // } // } // #[allow(clippy::too_many_arguments)] // fn nav_button)>( // svg_path: &'static str, // style: theme::Interactive, // nav_button_height: f32, // tooltip_style: TooltipStyle, // enabled: bool, // on_click: F, // tooltip_action: A, // action_name: &str, // cx: &mut ViewContext, // ) -> AnyElement { // MouseEventHandler::new::(0, cx, |state, _| { // let style = if enabled { // style.style_for(state) // } else { // style.disabled_style() // }; // Svg::new(svg_path) // .with_color(style.color) // .constrained() // .with_width(style.icon_width) // .aligned() // .contained() // .with_style(style.container) // .constrained() // .with_width(style.button_width) // .with_height(nav_button_height) // .aligned() // .top() // }) // .with_cursor_style(if enabled { // CursorStyle::PointingHand // } else { // CursorStyle::default() // }) // .on_click(MouseButton::Left, move |_, toolbar, cx| { // on_click(toolbar, cx) // }) // .with_tooltip::( // 0, // action_name.to_string(), // Some(Box::new(tooltip_action)), // tooltip_style, // cx, // ) // .contained() // .into_any_named("nav button") // } impl EventEmitter for Pane {} impl Pane { pub fn new( workspace: WeakView, project: Model, next_timestamp: Arc, can_drop_predicate: Option bool + 'static>>, cx: &mut ViewContext, ) -> Self { // todo!("context menu") // let pane_view_id = cx.view_id(); // let context_menu = cx.build_view(|cx| ContextMenu::new(pane_view_id, cx)); // context_menu.update(cx, |menu, _| { // menu.set_position_mode(OverlayPositionMode::Local) // }); // let focus_handle = cx.focus_handle(); let subscriptions = vec![ cx.on_focus_in(&focus_handle, move |this, cx| this.focus_in(cx)), cx.on_focus_out(&focus_handle, move |this, cx| this.focus_out(cx)), ]; let handle = cx.view().downgrade(); Self { focus_handle, items: Vec::new(), activation_history: Vec::new(), was_focused: false, zoomed: false, active_item_index: 0, last_focused_view_by_item: Default::default(), nav_history: NavHistory(Arc::new(Mutex::new(NavHistoryState { mode: NavigationMode::Normal, backward_stack: Default::default(), forward_stack: Default::default(), closed_stack: Default::default(), paths_by_item: Default::default(), pane: handle.clone(), next_timestamp, }))), toolbar: cx.new_view(|_| Toolbar::new()), new_item_menu: None, split_item_menu: None, tab_bar_scroll_handle: ScrollHandle::new(), drag_split_direction: None, // tab_bar_context_menu: TabBarContextMenu { // kind: TabBarContextMenuKind::New, // handle: context_menu, // }, // tab_context_menu: cx.build_view(|_| ContextMenu::new(pane_view_id, cx)), workspace, project, can_drop_predicate, can_split: true, render_tab_bar_buttons: Rc::new(move |pane, cx| { h_stack() .gap_2() .child( IconButton::new("plus", Icon::Plus) .icon_size(IconSize::Small) .icon_color(Color::Muted) .on_click(cx.listener(|pane, _, cx| { let menu = ContextMenu::build(cx, |menu, _| { menu.action("New File", NewFile.boxed_clone()) .action("New Terminal", NewCenterTerminal.boxed_clone()) .action("New Search", NewSearch.boxed_clone()) }); cx.subscribe(&menu, |pane, _, _: &DismissEvent, cx| { pane.focus(cx); pane.new_item_menu = None; }) .detach(); pane.new_item_menu = Some(menu); })) .tooltip(|cx| Tooltip::text("New...", cx)), ) .when_some(pane.new_item_menu.as_ref(), |el, new_item_menu| { el.child(Self::render_menu_overlay(new_item_menu)) }) .child( IconButton::new("split", Icon::Split) .icon_size(IconSize::Small) .icon_color(Color::Muted) .on_click(cx.listener(|pane, _, cx| { let menu = ContextMenu::build(cx, |menu, _| { menu.action("Split Right", SplitRight.boxed_clone()) .action("Split Left", SplitLeft.boxed_clone()) .action("Split Up", SplitUp.boxed_clone()) .action("Split Down", SplitDown.boxed_clone()) }); cx.subscribe(&menu, |pane, _, _: &DismissEvent, cx| { pane.focus(cx); pane.split_item_menu = None; }) .detach(); pane.split_item_menu = Some(menu); })) .tooltip(|cx| Tooltip::text("Split Pane", cx)), ) .child({ let zoomed = pane.is_zoomed(); IconButton::new("toggle_zoom", Icon::Maximize) .icon_size(IconSize::Small) .icon_color(Color::Muted) .selected(zoomed) .selected_icon(Icon::Minimize) .on_click(cx.listener(|pane, _, cx| { pane.toggle_zoom(&crate::ToggleZoom, cx); })) .tooltip(move |cx| { Tooltip::text(if zoomed { "Zoom Out" } else { "Zoom In" }, cx) }) }) .when_some(pane.split_item_menu.as_ref(), |el, split_item_menu| { el.child(Self::render_menu_overlay(split_item_menu)) }) .into_any_element() }), display_nav_history_buttons: true, _subscriptions: subscriptions, } } pub fn has_focus(&self, cx: &WindowContext) -> bool { // todo!(); // inline this manually self.focus_handle.contains_focused(cx) } fn focus_in(&mut self, cx: &mut ViewContext) { if !self.was_focused { self.was_focused = true; cx.emit(Event::Focus); cx.notify(); } self.toolbar.update(cx, |toolbar, cx| { toolbar.focus_changed(true, cx); }); if let Some(active_item) = self.active_item() { if self.focus_handle.is_focused(cx) { // Pane was focused directly. We need to either focus a view inside the active item, // or focus the active item itself if let Some(weak_last_focused_view) = self.last_focused_view_by_item.get(&active_item.item_id()) { weak_last_focused_view.focus(cx); return; } active_item.focus_handle(cx).focus(cx); } else if let Some(focused) = cx.focused() { if !self.context_menu_focused(cx) { self.last_focused_view_by_item .insert(active_item.item_id(), focused); } } } } fn context_menu_focused(&self, cx: &mut ViewContext) -> bool { self.new_item_menu .as_ref() .or(self.split_item_menu.as_ref()) .map_or(false, |menu| menu.focus_handle(cx).is_focused(cx)) } fn focus_out(&mut self, cx: &mut ViewContext) { self.was_focused = false; self.toolbar.update(cx, |toolbar, cx| { toolbar.focus_changed(false, cx); }); cx.notify(); } pub fn active_item_index(&self) -> usize { self.active_item_index } // pub fn on_can_drop(&mut self, can_drop: F) // where // F: 'static + Fn(&DragAndDrop, &WindowContext) -> bool, // { // self.can_drop = Rc::new(can_drop); // } pub fn set_can_split(&mut self, can_split: bool, cx: &mut ViewContext) { self.can_split = can_split; cx.notify(); } pub fn set_can_navigate(&mut self, can_navigate: bool, cx: &mut ViewContext) { self.toolbar.update(cx, |toolbar, cx| { toolbar.set_can_navigate(can_navigate, cx); }); cx.notify(); } pub fn set_render_tab_bar_buttons(&mut self, cx: &mut ViewContext, render: F) where F: 'static + Fn(&mut Pane, &mut ViewContext) -> AnyElement, { self.render_tab_bar_buttons = Rc::new(render); cx.notify(); } pub fn nav_history_for_item(&self, item: &View) -> ItemNavHistory { ItemNavHistory { history: self.nav_history.clone(), item: Arc::new(item.downgrade()), } } pub fn nav_history(&self) -> &NavHistory { &self.nav_history } pub fn nav_history_mut(&mut self) -> &mut NavHistory { &mut self.nav_history } pub fn disable_history(&mut self) { self.nav_history.disable(); } pub fn enable_history(&mut self) { self.nav_history.enable(); } pub fn can_navigate_backward(&self) -> bool { !self.nav_history.0.lock().backward_stack.is_empty() } pub fn can_navigate_forward(&self) -> bool { !self.nav_history.0.lock().forward_stack.is_empty() } fn navigate_backward(&mut self, cx: &mut ViewContext) { if let Some(workspace) = self.workspace.upgrade() { let pane = cx.view().downgrade(); cx.window_context().defer(move |cx| { workspace.update(cx, |workspace, cx| { workspace.go_back(pane, cx).detach_and_log_err(cx) }) }) } } fn navigate_forward(&mut self, cx: &mut ViewContext) { if let Some(workspace) = self.workspace.upgrade() { let pane = cx.view().downgrade(); cx.window_context().defer(move |cx| { workspace.update(cx, |workspace, cx| { workspace.go_forward(pane, cx).detach_and_log_err(cx) }) }) } } fn history_updated(&mut self, cx: &mut ViewContext) { self.toolbar.update(cx, |_, cx| cx.notify()); } pub(crate) fn open_item( &mut self, project_entry_id: Option, focus_item: bool, cx: &mut ViewContext, build_item: impl FnOnce(&mut ViewContext) -> Box, ) -> Box { let mut existing_item = None; if let Some(project_entry_id) = project_entry_id { for (index, item) in self.items.iter().enumerate() { if item.is_singleton(cx) && item.project_entry_ids(cx).as_slice() == [project_entry_id] { let item = item.boxed_clone(); existing_item = Some((index, item)); break; } } } if let Some((index, existing_item)) = existing_item { self.activate_item(index, focus_item, focus_item, cx); existing_item } else { let new_item = build_item(cx); self.add_item(new_item.clone(), true, focus_item, None, cx); new_item } } pub fn add_item( &mut self, item: Box, activate_pane: bool, focus_item: bool, destination_index: Option, cx: &mut ViewContext, ) { if item.is_singleton(cx) { if let Some(&entry_id) = item.project_entry_ids(cx).get(0) { let project = self.project.read(cx); if let Some(project_path) = project.path_for_entry(entry_id, cx) { let abs_path = project.absolute_path(&project_path, cx); self.nav_history .0 .lock() .paths_by_item .insert(item.item_id(), (project_path, abs_path)); } } } // If no destination index is specified, add or move the item after the active item. let mut insertion_index = { cmp::min( if let Some(destination_index) = destination_index { destination_index } else { self.active_item_index + 1 }, self.items.len(), ) }; // Does the item already exist? let project_entry_id = if item.is_singleton(cx) { item.project_entry_ids(cx).get(0).copied() } else { None }; let existing_item_index = self.items.iter().position(|existing_item| { if existing_item.item_id() == item.item_id() { true } else if existing_item.is_singleton(cx) { existing_item .project_entry_ids(cx) .get(0) .map_or(false, |existing_entry_id| { Some(existing_entry_id) == project_entry_id.as_ref() }) } else { false } }); if let Some(existing_item_index) = existing_item_index { // If the item already exists, move it to the desired destination and activate it if existing_item_index != insertion_index { let existing_item_is_active = existing_item_index == self.active_item_index; // If the caller didn't specify a destination and the added item is already // the active one, don't move it if existing_item_is_active && destination_index.is_none() { insertion_index = existing_item_index; } else { self.items.remove(existing_item_index); if existing_item_index < self.active_item_index { self.active_item_index -= 1; } insertion_index = insertion_index.min(self.items.len()); self.items.insert(insertion_index, item.clone()); if existing_item_is_active { self.active_item_index = insertion_index; } else if insertion_index <= self.active_item_index { self.active_item_index += 1; } } cx.notify(); } self.activate_item(insertion_index, activate_pane, focus_item, cx); } else { self.items.insert(insertion_index, item.clone()); if insertion_index <= self.active_item_index { self.active_item_index += 1; } self.activate_item(insertion_index, activate_pane, focus_item, cx); cx.notify(); } cx.emit(Event::AddItem { item }); } pub fn items_len(&self) -> usize { self.items.len() } pub fn items(&self) -> impl Iterator> + DoubleEndedIterator { self.items.iter() } pub fn items_of_type(&self) -> impl '_ + Iterator> { self.items .iter() .filter_map(|item| item.to_any().downcast().ok()) } pub fn active_item(&self) -> Option> { self.items.get(self.active_item_index).cloned() } pub fn pixel_position_of_cursor(&self, cx: &AppContext) -> Option> { self.items .get(self.active_item_index)? .pixel_position_of_cursor(cx) } pub fn item_for_entry( &self, entry_id: ProjectEntryId, cx: &AppContext, ) -> Option> { self.items.iter().find_map(|item| { if item.is_singleton(cx) && item.project_entry_ids(cx).as_slice() == [entry_id] { Some(item.boxed_clone()) } else { None } }) } pub fn index_for_item(&self, item: &dyn ItemHandle) -> Option { self.items .iter() .position(|i| i.item_id() == item.item_id()) } pub fn item_for_index(&self, ix: usize) -> Option<&dyn ItemHandle> { self.items.get(ix).map(|i| i.as_ref()) } pub fn toggle_zoom(&mut self, _: &ToggleZoom, cx: &mut ViewContext) { if self.zoomed { cx.emit(Event::ZoomOut); } else if !self.items.is_empty() { if !self.focus_handle.contains_focused(cx) { cx.focus_self(); } cx.emit(Event::ZoomIn); } } pub fn activate_item( &mut self, index: usize, activate_pane: bool, focus_item: bool, cx: &mut ViewContext, ) { use NavigationMode::{GoingBack, GoingForward}; if index < self.items.len() { let prev_active_item_ix = mem::replace(&mut self.active_item_index, index); if prev_active_item_ix != self.active_item_index || matches!(self.nav_history.mode(), GoingBack | GoingForward) { if let Some(prev_item) = self.items.get(prev_active_item_ix) { prev_item.deactivated(cx); } cx.emit(Event::ActivateItem { local: activate_pane, }); } if let Some(newly_active_item) = self.items.get(index) { self.activation_history .retain(|&previously_active_item_id| { previously_active_item_id != newly_active_item.item_id() }); self.activation_history.push(newly_active_item.item_id()); } self.update_toolbar(cx); self.update_status_bar(cx); if focus_item { self.focus_active_item(cx); } self.tab_bar_scroll_handle.scroll_to_item(index); cx.notify(); } } pub fn activate_prev_item(&mut self, activate_pane: bool, cx: &mut ViewContext) { let mut index = self.active_item_index; if index > 0 { index -= 1; } else if !self.items.is_empty() { index = self.items.len() - 1; } self.activate_item(index, activate_pane, activate_pane, cx); } pub fn activate_next_item(&mut self, activate_pane: bool, cx: &mut ViewContext) { let mut index = self.active_item_index; if index + 1 < self.items.len() { index += 1; } else { index = 0; } self.activate_item(index, activate_pane, activate_pane, cx); } pub fn close_active_item( &mut self, action: &CloseActiveItem, cx: &mut ViewContext, ) -> Option>> { if self.items.is_empty() { return None; } let active_item_id = self.items[self.active_item_index].item_id(); Some(self.close_item_by_id( active_item_id, action.save_intent.unwrap_or(SaveIntent::Close), cx, )) } pub fn close_item_by_id( &mut self, item_id_to_close: EntityId, save_intent: SaveIntent, cx: &mut ViewContext, ) -> Task> { self.close_items(cx, save_intent, move |view_id| view_id == item_id_to_close) } pub fn close_inactive_items( &mut self, _: &CloseInactiveItems, cx: &mut ViewContext, ) -> Option>> { if self.items.is_empty() { return None; } let active_item_id = self.items[self.active_item_index].item_id(); Some(self.close_items(cx, SaveIntent::Close, move |item_id| { item_id != active_item_id })) } pub fn close_clean_items( &mut self, _: &CloseCleanItems, cx: &mut ViewContext, ) -> Option>> { let item_ids: Vec<_> = self .items() .filter(|item| !item.is_dirty(cx)) .map(|item| item.item_id()) .collect(); Some(self.close_items(cx, SaveIntent::Close, move |item_id| { item_ids.contains(&item_id) })) } pub fn close_items_to_the_left( &mut self, _: &CloseItemsToTheLeft, cx: &mut ViewContext, ) -> Option>> { if self.items.is_empty() { return None; } let active_item_id = self.items[self.active_item_index].item_id(); Some(self.close_items_to_the_left_by_id(active_item_id, cx)) } pub fn close_items_to_the_left_by_id( &mut self, item_id: EntityId, cx: &mut ViewContext, ) -> Task> { let item_ids: Vec<_> = self .items() .take_while(|item| item.item_id() != item_id) .map(|item| item.item_id()) .collect(); self.close_items(cx, SaveIntent::Close, move |item_id| { item_ids.contains(&item_id) }) } pub fn close_items_to_the_right( &mut self, _: &CloseItemsToTheRight, cx: &mut ViewContext, ) -> Option>> { if self.items.is_empty() { return None; } let active_item_id = self.items[self.active_item_index].item_id(); Some(self.close_items_to_the_right_by_id(active_item_id, cx)) } pub fn close_items_to_the_right_by_id( &mut self, item_id: EntityId, cx: &mut ViewContext, ) -> Task> { let item_ids: Vec<_> = self .items() .rev() .take_while(|item| item.item_id() != item_id) .map(|item| item.item_id()) .collect(); self.close_items(cx, SaveIntent::Close, move |item_id| { item_ids.contains(&item_id) }) } pub fn close_all_items( &mut self, action: &CloseAllItems, cx: &mut ViewContext, ) -> Option>> { if self.items.is_empty() { return None; } Some( self.close_items(cx, action.save_intent.unwrap_or(SaveIntent::Close), |_| { true }), ) } pub(super) fn file_names_for_prompt( items: &mut dyn Iterator>, all_dirty_items: usize, cx: &AppContext, ) -> String { /// Quantity of item paths displayed in prompt prior to cutoff.. const FILE_NAMES_CUTOFF_POINT: usize = 10; let mut file_names: Vec<_> = items .filter_map(|item| { item.project_path(cx).and_then(|project_path| { project_path .path .file_name() .and_then(|name| name.to_str().map(ToOwned::to_owned)) }) }) .take(FILE_NAMES_CUTOFF_POINT) .collect(); let should_display_followup_text = all_dirty_items > FILE_NAMES_CUTOFF_POINT || file_names.len() != all_dirty_items; if should_display_followup_text { let not_shown_files = all_dirty_items - file_names.len(); if not_shown_files == 1 { file_names.push(".. 1 file not shown".into()); } else { file_names.push(format!(".. {} files not shown", not_shown_files).into()); } } let file_names = file_names.join("\n"); format!( "Do you want to save changes to the following {} files?\n{file_names}", all_dirty_items ) } pub fn close_items( &mut self, cx: &mut ViewContext, mut save_intent: SaveIntent, should_close: impl Fn(EntityId) -> bool, ) -> Task> { // Find the items to close. let mut items_to_close = Vec::new(); let mut dirty_items = Vec::new(); for item in &self.items { if should_close(item.item_id()) { items_to_close.push(item.boxed_clone()); if item.is_dirty(cx) { dirty_items.push(item.boxed_clone()); } } } // If a buffer is open both in a singleton editor and in a multibuffer, make sure // to focus the singleton buffer when prompting to save that buffer, as opposed // to focusing the multibuffer, because this gives the user a more clear idea // of what content they would be saving. items_to_close.sort_by_key(|item| !item.is_singleton(cx)); let workspace = self.workspace.clone(); cx.spawn(|pane, mut cx| async move { if save_intent == SaveIntent::Close && dirty_items.len() > 1 { let answer = pane.update(&mut cx, |_, cx| { let prompt = Self::file_names_for_prompt(&mut dirty_items.iter(), dirty_items.len(), cx); cx.prompt( PromptLevel::Warning, &prompt, &["Save all", "Discard all", "Cancel"], ) })?; match answer.await { Ok(0) => save_intent = SaveIntent::SaveAll, Ok(1) => save_intent = SaveIntent::Skip, _ => {} } } let mut saved_project_items_ids = HashSet::default(); for item in items_to_close.clone() { // Find the item's current index and its set of project item models. Avoid // storing these in advance, in case they have changed since this task // was started. let (item_ix, mut project_item_ids) = pane.update(&mut cx, |pane, cx| { (pane.index_for_item(&*item), item.project_item_model_ids(cx)) })?; let item_ix = if let Some(ix) = item_ix { ix } else { continue; }; // Check if this view has any project items that are not open anywhere else // in the workspace, AND that the user has not already been prompted to save. // If there are any such project entries, prompt the user to save this item. let project = workspace.update(&mut cx, |workspace, cx| { for item in workspace.items(cx) { if !items_to_close .iter() .any(|item_to_close| item_to_close.item_id() == item.item_id()) { let other_project_item_ids = item.project_item_model_ids(cx); project_item_ids.retain(|id| !other_project_item_ids.contains(id)); } } workspace.project().clone() })?; let should_save = project_item_ids .iter() .any(|id| saved_project_items_ids.insert(*id)); if should_save && !Self::save_item( project.clone(), &pane, item_ix, &*item, save_intent, &mut cx, ) .await? { break; } // Remove the item from the pane. pane.update(&mut cx, |pane, cx| { if let Some(item_ix) = pane .items .iter() .position(|i| i.item_id() == item.item_id()) { pane.remove_item(item_ix, false, cx); } }) .ok(); } pane.update(&mut cx, |_, cx| cx.notify()).ok(); Ok(()) }) } pub fn remove_item( &mut self, item_index: usize, activate_pane: bool, cx: &mut ViewContext, ) { self.activation_history .retain(|&history_entry| history_entry != self.items[item_index].item_id()); if item_index == self.active_item_index { let index_to_activate = self .activation_history .pop() .and_then(|last_activated_item| { self.items.iter().enumerate().find_map(|(index, item)| { (item.item_id() == last_activated_item).then_some(index) }) }) // We didn't have a valid activation history entry, so fallback // to activating the item to the left .unwrap_or_else(|| item_index.min(self.items.len()).saturating_sub(1)); let should_activate = activate_pane || self.has_focus(cx); if self.items.len() == 1 && should_activate { self.focus_handle.focus(cx); } else { self.activate_item(index_to_activate, should_activate, should_activate, cx); } } let item = self.items.remove(item_index); cx.emit(Event::RemoveItem { item_id: item.item_id(), }); if self.items.is_empty() { item.deactivated(cx); self.update_toolbar(cx); cx.emit(Event::Remove); } if item_index < self.active_item_index { self.active_item_index -= 1; } self.nav_history.set_mode(NavigationMode::ClosingItem); item.deactivated(cx); self.nav_history.set_mode(NavigationMode::Normal); if let Some(path) = item.project_path(cx) { let abs_path = self .nav_history .0 .lock() .paths_by_item .get(&item.item_id()) .and_then(|(_, abs_path)| abs_path.clone()); self.nav_history .0 .lock() .paths_by_item .insert(item.item_id(), (path, abs_path)); } else { self.nav_history .0 .lock() .paths_by_item .remove(&item.item_id()); } if self.items.is_empty() && self.zoomed { cx.emit(Event::ZoomOut); } cx.notify(); } pub async fn save_item( project: Model, pane: &WeakView, item_ix: usize, item: &dyn ItemHandle, save_intent: SaveIntent, cx: &mut AsyncWindowContext, ) -> Result { const CONFLICT_MESSAGE: &str = "This file has changed on disk since you started editing it. Do you want to overwrite it?"; if save_intent == SaveIntent::Skip { return Ok(true); } let (mut has_conflict, mut is_dirty, mut can_save, can_save_as) = cx.update(|_, cx| { ( item.has_conflict(cx), item.is_dirty(cx), item.can_save(cx), item.is_singleton(cx), ) })?; // when saving a single buffer, we ignore whether or not it's dirty. if save_intent == SaveIntent::Save { is_dirty = true; } if save_intent == SaveIntent::SaveAs { is_dirty = true; has_conflict = false; can_save = false; } if save_intent == SaveIntent::Overwrite { has_conflict = false; } if has_conflict && can_save { let answer = pane.update(cx, |pane, cx| { pane.activate_item(item_ix, true, true, cx); cx.prompt( PromptLevel::Warning, CONFLICT_MESSAGE, &["Overwrite", "Discard", "Cancel"], ) })?; match answer.await { Ok(0) => pane.update(cx, |_, cx| item.save(project, cx))?.await?, Ok(1) => pane.update(cx, |_, cx| item.reload(project, cx))?.await?, _ => return Ok(false), } } else if is_dirty && (can_save || can_save_as) { if save_intent == SaveIntent::Close { let will_autosave = cx.update(|_, cx| { matches!( WorkspaceSettings::get_global(cx).autosave, AutosaveSetting::OnFocusChange | AutosaveSetting::OnWindowChange ) && Self::can_autosave_item(&*item, cx) })?; if !will_autosave { let answer = pane.update(cx, |pane, cx| { pane.activate_item(item_ix, true, true, cx); let prompt = dirty_message_for(item.project_path(cx)); cx.prompt( PromptLevel::Warning, &prompt, &["Save", "Don't Save", "Cancel"], ) })?; match answer.await { Ok(0) => {} Ok(1) => return Ok(true), // Don't save this file _ => return Ok(false), // Cancel } } } if can_save { pane.update(cx, |_, cx| item.save(project, cx))?.await?; } else if can_save_as { let start_abs_path = project .update(cx, |project, cx| { let worktree = project.visible_worktrees(cx).next()?; Some(worktree.read(cx).as_local()?.abs_path().to_path_buf()) })? .unwrap_or_else(|| Path::new("").into()); let abs_path = cx.update(|_, cx| cx.prompt_for_new_path(&start_abs_path))?; if let Some(abs_path) = abs_path.await.ok().flatten() { pane.update(cx, |_, cx| item.save_as(project, abs_path, cx))? .await?; } else { return Ok(false); } } } Ok(true) } fn can_autosave_item(item: &dyn ItemHandle, cx: &AppContext) -> bool { let is_deleted = item.project_entry_ids(cx).is_empty(); item.is_dirty(cx) && !item.has_conflict(cx) && item.can_save(cx) && !is_deleted } pub fn autosave_item( item: &dyn ItemHandle, project: Model, cx: &mut WindowContext, ) -> Task> { if Self::can_autosave_item(item, cx) { item.save(project, cx) } else { Task::ready(Ok(())) } } pub fn focus(&mut self, cx: &mut ViewContext) { cx.focus(&self.focus_handle); } pub fn focus_active_item(&mut self, cx: &mut ViewContext) { if let Some(active_item) = self.active_item() { let focus_handle = active_item.focus_handle(cx); cx.focus(&focus_handle); } } pub fn split(&mut self, direction: SplitDirection, cx: &mut ViewContext) { cx.emit(Event::Split(direction)); } // fn deploy_split_menu(&mut self, cx: &mut ViewContext) { // self.tab_bar_context_menu.handle.update(cx, |menu, cx| { // menu.toggle( // Default::default(), // AnchorCorner::TopRight, // vec![ // ContextMenuItem::action("Split Right", SplitRight), // ContextMenuItem::action("Split Left", SplitLeft), // ContextMenuItem::action("Split Up", SplitUp), // ContextMenuItem::action("Split Down", SplitDown), // ], // cx, // ); // }); // self.tab_bar_context_menu.kind = TabBarContextMenuKind::Split; // } // fn deploy_new_menu(&mut self, cx: &mut ViewContext) { // self.tab_bar_context_menu.handle.update(cx, |menu, cx| { // menu.toggle( // Default::default(), // AnchorCorner::TopRight, // vec![ // ContextMenuItem::action("New File", NewFile), // ContextMenuItem::action("New Terminal", NewCenterTerminal), // ContextMenuItem::action("New Search", NewSearch), // ], // cx, // ); // }); // self.tab_bar_context_menu.kind = TabBarContextMenuKind::New; // } // fn deploy_tab_context_menu( // &mut self, // position: Vector2F, // target_item_id: usize, // cx: &mut ViewContext, // ) { // let active_item_id = self.items[self.active_item_index].id(); // let is_active_item = target_item_id == active_item_id; // let target_pane = cx.weak_handle(); // // The `CloseInactiveItems` action should really be called "CloseOthers" and the behaviour should be dynamically based on the tab the action is ran on. Currently, this is a weird action because you can run it on a non-active tab and it will close everything by the actual active tab // self.tab_context_menu.update(cx, |menu, cx| { // menu.show( // position, // AnchorCorner::TopLeft, // if is_active_item { // vec![ // ContextMenuItem::action( // "Close Active Item", // CloseActiveItem { save_intent: None }, // ), // ContextMenuItem::action("Close Inactive Items", CloseInactiveItems), // ContextMenuItem::action("Close Clean Items", CloseCleanItems), // ContextMenuItem::action("Close Items To The Left", CloseItemsToTheLeft), // ContextMenuItem::action("Close Items To The Right", CloseItemsToTheRight), // ContextMenuItem::action( // "Close All Items", // CloseAllItems { save_intent: None }, // ), // ] // } else { // // In the case of the user right clicking on a non-active tab, for some item-closing commands, we need to provide the id of the tab, for the others, we can reuse the existing command. // vec![ // ContextMenuItem::handler("Close Inactive Item", { // let pane = target_pane.clone(); // move |cx| { // if let Some(pane) = pane.upgrade(cx) { // pane.update(cx, |pane, cx| { // pane.close_item_by_id( // target_item_id, // SaveIntent::Close, // cx, // ) // .detach_and_log_err(cx); // }) // } // } // }), // ContextMenuItem::action("Close Inactive Items", CloseInactiveItems), // ContextMenuItem::action("Close Clean Items", CloseCleanItems), // ContextMenuItem::handler("Close Items To The Left", { // let pane = target_pane.clone(); // move |cx| { // if let Some(pane) = pane.upgrade(cx) { // pane.update(cx, |pane, cx| { // pane.close_items_to_the_left_by_id(target_item_id, cx) // .detach_and_log_err(cx); // }) // } // } // }), // ContextMenuItem::handler("Close Items To The Right", { // let pane = target_pane.clone(); // move |cx| { // if let Some(pane) = pane.upgrade(cx) { // pane.update(cx, |pane, cx| { // pane.close_items_to_the_right_by_id(target_item_id, cx) // .detach_and_log_err(cx); // }) // } // } // }), // ContextMenuItem::action( // "Close All Items", // CloseAllItems { save_intent: None }, // ), // ] // }, // cx, // ); // }); // } pub fn toolbar(&self) -> &View { &self.toolbar } pub fn handle_deleted_project_item( &mut self, entry_id: ProjectEntryId, cx: &mut ViewContext, ) -> Option<()> { let (item_index_to_delete, item_id) = self.items().enumerate().find_map(|(i, item)| { if item.is_singleton(cx) && item.project_entry_ids(cx).as_slice() == [entry_id] { Some((i, item.item_id())) } else { None } })?; self.remove_item(item_index_to_delete, false, cx); self.nav_history.remove_item(item_id); Some(()) } fn update_toolbar(&mut self, cx: &mut ViewContext) { let active_item = self .items .get(self.active_item_index) .map(|item| item.as_ref()); self.toolbar.update(cx, |toolbar, cx| { toolbar.set_active_item(active_item, cx); }); } fn update_status_bar(&mut self, cx: &mut ViewContext) { let workspace = self.workspace.clone(); let pane = cx.view().clone(); cx.window_context().defer(move |cx| { let Ok(status_bar) = workspace.update(cx, |workspace, _| workspace.status_bar.clone()) else { return; }; status_bar.update(cx, move |status_bar, cx| { status_bar.set_active_pane(&pane, cx); }); }); } fn render_tab( &self, ix: usize, item: &Box, detail: usize, cx: &mut ViewContext<'_, Pane>, ) -> impl IntoElement { let is_active = ix == self.active_item_index; let label = item.tab_content(Some(detail), is_active, cx); let close_side = &ItemSettings::get_global(cx).close_position; let indicator = maybe!({ let indicator_color = match (item.has_conflict(cx), item.is_dirty(cx)) { (true, _) => Color::Warning, (_, true) => Color::Accent, (false, false) => return None, }; Some(Indicator::dot().color(indicator_color)) }); let item_id = item.item_id(); let is_first_item = ix == 0; let is_last_item = ix == self.items.len() - 1; let position_relative_to_active_item = ix.cmp(&self.active_item_index); let tab = Tab::new(ix) .position(if is_first_item { TabPosition::First } else if is_last_item { TabPosition::Last } else { TabPosition::Middle(position_relative_to_active_item) }) .close_side(match close_side { ClosePosition::Left => ui::TabCloseSide::Start, ClosePosition::Right => ui::TabCloseSide::End, }) .selected(is_active) .on_click( cx.listener(move |pane: &mut Self, _, cx| pane.activate_item(ix, true, true, cx)), ) // TODO: This should be a click listener with the middle mouse button instead of a mouse down listener. .on_mouse_down( MouseButton::Middle, cx.listener(move |pane, _event, cx| { pane.close_item_by_id(item_id, SaveIntent::Close, cx) .detach_and_log_err(cx); }), ) .on_drag( DraggedTab { pane: cx.view().clone(), detail, item_id, is_active, ix, }, |tab, cx| cx.new_view(|_| tab.clone()), ) .drag_over::(|tab| tab.bg(cx.theme().colors().drop_target_background)) .drag_over::(|tab| tab.bg(cx.theme().colors().drop_target_background)) .when_some(self.can_drop_predicate.clone(), |this, p| { this.can_drop(move |a, cx| p(a, cx)) }) .on_drop(cx.listener(move |this, dragged_tab: &DraggedTab, cx| { this.drag_split_direction = None; this.handle_tab_drop(dragged_tab, ix, cx) })) .on_drop(cx.listener(move |this, entry_id: &ProjectEntryId, cx| { this.drag_split_direction = None; this.handle_project_entry_drop(entry_id, cx) })) .when_some(item.tab_tooltip_text(cx), |tab, text| { tab.tooltip(move |cx| Tooltip::text(text.clone(), cx)) }) .start_slot::(indicator) .end_slot( IconButton::new("close tab", Icon::Close) .icon_color(Color::Muted) .size(ButtonSize::None) .icon_size(IconSize::XSmall) .on_click(cx.listener(move |pane, _, cx| { pane.close_item_by_id(item_id, SaveIntent::Close, cx) .detach_and_log_err(cx); })), ) .child(label); let single_entry_to_resolve = { let item_entries = self.items[ix].project_entry_ids(cx); if item_entries.len() == 1 { Some(item_entries[0]) } else { None } }; let pane = cx.view().downgrade(); right_click_menu(ix).trigger(tab).menu(move |cx| { let pane = pane.clone(); ContextMenu::build(cx, move |mut menu, cx| { if let Some(pane) = pane.upgrade() { menu = menu .entry( "Close", Some(Box::new(CloseActiveItem { save_intent: None })), cx.handler_for(&pane, move |pane, cx| { pane.close_item_by_id(item_id, SaveIntent::Close, cx) .detach_and_log_err(cx); }), ) .entry( "Close Others", Some(Box::new(CloseInactiveItems)), cx.handler_for(&pane, move |pane, cx| { pane.close_items(cx, SaveIntent::Close, |id| id != item_id) .detach_and_log_err(cx); }), ) .separator() .entry( "Close Left", Some(Box::new(CloseItemsToTheLeft)), cx.handler_for(&pane, move |pane, cx| { pane.close_items_to_the_left_by_id(item_id, cx) .detach_and_log_err(cx); }), ) .entry( "Close Right", Some(Box::new(CloseItemsToTheRight)), cx.handler_for(&pane, move |pane, cx| { pane.close_items_to_the_right_by_id(item_id, cx) .detach_and_log_err(cx); }), ) .separator() .entry( "Close Clean", Some(Box::new(CloseCleanItems)), cx.handler_for(&pane, move |pane, cx| { pane.close_clean_items(&CloseCleanItems, cx) .map(|task| task.detach_and_log_err(cx)); }), ) .entry( "Close All", Some(Box::new(CloseAllItems { save_intent: None })), cx.handler_for(&pane, |pane, cx| { pane.close_all_items(&CloseAllItems { save_intent: None }, cx) .map(|task| task.detach_and_log_err(cx)); }), ); if let Some(entry) = single_entry_to_resolve { let entry_id = entry.to_proto(); menu = menu.separator().entry( "Reveal In Project Panel", Some(Box::new(RevealInProjectPanel { entry_id })), cx.handler_for(&pane, move |pane, cx| { pane.project.update(cx, |_, cx| { cx.emit(project::Event::RevealInProjectPanel( ProjectEntryId::from_proto(entry_id), )) }); }), ); } } menu }) }) } fn render_tab_bar(&mut self, cx: &mut ViewContext<'_, Pane>) -> impl IntoElement { TabBar::new("tab_bar") .track_scroll(self.tab_bar_scroll_handle.clone()) .when(self.display_nav_history_buttons, |tab_bar| { tab_bar.start_child( h_stack() .gap_2() .child( IconButton::new("navigate_backward", Icon::ArrowLeft) .icon_size(IconSize::Small) .on_click({ let view = cx.view().clone(); move |_, cx| view.update(cx, Self::navigate_backward) }) .disabled(!self.can_navigate_backward()) .tooltip(|cx| Tooltip::for_action("Go Back", &GoBack, cx)), ) .child( IconButton::new("navigate_forward", Icon::ArrowRight) .icon_size(IconSize::Small) .on_click({ let view = cx.view().clone(); move |_, cx| view.update(cx, Self::navigate_backward) }) .disabled(!self.can_navigate_forward()) .tooltip(|cx| Tooltip::for_action("Go Forward", &GoForward, cx)), ), ) }) .when(self.was_focused || self.has_focus(cx), |tab_bar| { tab_bar.end_child({ let render_tab_buttons = self.render_tab_bar_buttons.clone(); render_tab_buttons(self, cx) }) }) .children( self.items .iter() .enumerate() .zip(self.tab_details(cx)) .map(|((ix, item), detail)| self.render_tab(ix, item, detail, cx)), ) .child( div() .min_w_6() // HACK: This empty child is currently necessary to force the drop traget to appear // despite us setting a min width above. .child("") .h_full() .flex_grow() .drag_over::(|bar| { bar.bg(cx.theme().colors().drop_target_background) }) .drag_over::(|bar| { bar.bg(cx.theme().colors().drop_target_background) }) .on_drop(cx.listener(move |this, dragged_tab: &DraggedTab, cx| { this.drag_split_direction = None; this.handle_tab_drop(dragged_tab, this.items.len(), cx) })) .on_drop(cx.listener(move |this, entry_id: &ProjectEntryId, cx| { this.drag_split_direction = None; this.handle_project_entry_drop(entry_id, cx) })), ) } fn render_menu_overlay(menu: &View) -> Div { div() .absolute() .z_index(1) .bottom_0() .right_0() .size_0() .child(overlay().anchor(AnchorCorner::TopRight).child(menu.clone())) } fn tab_details(&self, cx: &AppContext) -> Vec { let mut tab_details = self.items.iter().map(|_| 0).collect::>(); let mut tab_descriptions = HashMap::default(); let mut done = false; while !done { done = true; // Store item indices by their tab description. for (ix, (item, detail)) in self.items.iter().zip(&tab_details).enumerate() { if let Some(description) = item.tab_description(*detail, cx) { if *detail == 0 || Some(&description) != item.tab_description(detail - 1, cx).as_ref() { tab_descriptions .entry(description) .or_insert(Vec::new()) .push(ix); } } } // If two or more items have the same tab description, increase eir level // of detail and try again. for (_, item_ixs) in tab_descriptions.drain() { if item_ixs.len() > 1 { done = false; for ix in item_ixs { tab_details[ix] += 1; } } } } tab_details } pub fn set_zoomed(&mut self, zoomed: bool, cx: &mut ViewContext) { self.zoomed = zoomed; cx.notify(); } pub fn is_zoomed(&self) -> bool { self.zoomed } fn handle_drag_move(&mut self, event: &DragMoveEvent, cx: &mut ViewContext) { if !self.can_split { return; } let edge_width = cx.rem_size() * 8; let cursor = event.event.position; let direction = if cursor.x < event.bounds.left() + edge_width { Some(SplitDirection::Left) } else if cursor.x > event.bounds.right() - edge_width { Some(SplitDirection::Right) } else if cursor.y < event.bounds.top() + edge_width { Some(SplitDirection::Up) } else if cursor.y > event.bounds.bottom() - edge_width { Some(SplitDirection::Down) } else { None }; if direction != self.drag_split_direction { self.drag_split_direction = direction; } } fn handle_tab_drop( &mut self, dragged_tab: &DraggedTab, ix: usize, cx: &mut ViewContext<'_, Pane>, ) { let mut to_pane = cx.view().clone(); let split_direction = self.drag_split_direction; let item_id = dragged_tab.item_id; let from_pane = dragged_tab.pane.clone(); self.workspace .update(cx, |_, cx| { cx.defer(move |workspace, cx| { if let Some(split_direction) = split_direction { to_pane = workspace.split_pane(to_pane, split_direction, cx); } workspace.move_item(from_pane, to_pane, item_id, ix, cx); }); }) .log_err(); } fn handle_project_entry_drop( &mut self, project_entry_id: &ProjectEntryId, cx: &mut ViewContext<'_, Pane>, ) { let mut to_pane = cx.view().clone(); let split_direction = self.drag_split_direction; let project_entry_id = *project_entry_id; self.workspace .update(cx, |_, cx| { cx.defer(move |workspace, cx| { if let Some(path) = workspace .project() .read(cx) .path_for_entry(project_entry_id, cx) { if let Some(split_direction) = split_direction { to_pane = workspace.split_pane(to_pane, split_direction, cx); } workspace .open_path(path, Some(to_pane.downgrade()), true, cx) .detach_and_log_err(cx); } }); }) .log_err(); } pub fn display_nav_history_buttons(&mut self, display: bool) { self.display_nav_history_buttons = display; } } impl FocusableView for Pane { fn focus_handle(&self, _cx: &AppContext) -> FocusHandle { self.focus_handle.clone() } } impl Render for Pane { fn render(&mut self, cx: &mut ViewContext) -> impl IntoElement { v_stack() .key_context("Pane") .track_focus(&self.focus_handle) .size_full() .flex_none() .overflow_hidden() .on_action(cx.listener(|pane, _: &SplitLeft, cx| pane.split(SplitDirection::Left, cx))) .on_action(cx.listener(|pane, _: &SplitUp, cx| pane.split(SplitDirection::Up, cx))) .on_action( cx.listener(|pane, _: &SplitRight, cx| pane.split(SplitDirection::Right, cx)), ) .on_action(cx.listener(|pane, _: &SplitDown, cx| pane.split(SplitDirection::Down, cx))) .on_action(cx.listener(|pane, _: &GoBack, cx| pane.navigate_backward(cx))) .on_action(cx.listener(|pane, _: &GoForward, cx| pane.navigate_forward(cx))) .on_action(cx.listener(Pane::toggle_zoom)) .on_action(cx.listener(|pane: &mut Pane, action: &ActivateItem, cx| { pane.activate_item(action.0, true, true, cx); })) .on_action(cx.listener(|pane: &mut Pane, _: &ActivateLastItem, cx| { pane.activate_item(pane.items.len() - 1, true, true, cx); })) .on_action(cx.listener(|pane: &mut Pane, _: &ActivatePrevItem, cx| { pane.activate_prev_item(true, cx); })) .on_action(cx.listener(|pane: &mut Pane, _: &ActivateNextItem, cx| { pane.activate_next_item(true, cx); })) .on_action( cx.listener(|pane: &mut Self, action: &CloseActiveItem, cx| { pane.close_active_item(action, cx) .map(|task| task.detach_and_log_err(cx)); }), ) .on_action( cx.listener(|pane: &mut Self, action: &CloseInactiveItems, cx| { pane.close_inactive_items(action, cx) .map(|task| task.detach_and_log_err(cx)); }), ) .on_action( cx.listener(|pane: &mut Self, action: &CloseCleanItems, cx| { pane.close_clean_items(action, cx) .map(|task| task.detach_and_log_err(cx)); }), ) .on_action( cx.listener(|pane: &mut Self, action: &CloseItemsToTheLeft, cx| { pane.close_items_to_the_left(action, cx) .map(|task| task.detach_and_log_err(cx)); }), ) .on_action( cx.listener(|pane: &mut Self, action: &CloseItemsToTheRight, cx| { pane.close_items_to_the_right(action, cx) .map(|task| task.detach_and_log_err(cx)); }), ) .on_action(cx.listener(|pane: &mut Self, action: &CloseAllItems, cx| { pane.close_all_items(action, cx) .map(|task| task.detach_and_log_err(cx)); })) .on_action( cx.listener(|pane: &mut Self, action: &CloseActiveItem, cx| { pane.close_active_item(action, cx) .map(|task| task.detach_and_log_err(cx)); }), ) .on_action( cx.listener(|pane: &mut Self, action: &RevealInProjectPanel, cx| { pane.project.update(cx, |_, cx| { cx.emit(project::Event::RevealInProjectPanel( ProjectEntryId::from_proto(action.entry_id), )) }) }), ) .when(self.active_item().is_some(), |pane| { pane.child(self.render_tab_bar(cx)) }) .child({ let has_worktrees = self.project.read(cx).worktrees().next().is_some(); // main content div() .flex_1() .relative() .group("") .on_drag_move::(cx.listener(Self::handle_drag_move)) .on_drag_move::(cx.listener(Self::handle_drag_move)) .map(|div| { if let Some(item) = self.active_item() { div.v_flex() .child(self.toolbar.clone()) .child(item.to_any()) } else { let placeholder = div.h_flex().size_full().justify_center(); if has_worktrees { placeholder } else { placeholder.child( Label::new("Open a file or project to get started.") .color(Color::Muted), ) } } }) .child( // drag target div() .z_index(1) .invisible() .absolute() .bg(theme::color_alpha( cx.theme().colors().drop_target_background, 0.75, )) .group_drag_over::("", |style| style.visible()) .group_drag_over::("", |style| style.visible()) .when_some(self.can_drop_predicate.clone(), |this, p| { this.can_drop(move |a, cx| p(a, cx)) }) .on_drop(cx.listener(move |this, dragged_tab, cx| { this.handle_tab_drop(dragged_tab, this.active_item_index(), cx) })) .on_drop(cx.listener(move |this, entry_id, cx| { this.handle_project_entry_drop(entry_id, cx) })) .map(|div| match self.drag_split_direction { None => div.top_0().left_0().right_0().bottom_0(), Some(SplitDirection::Up) => div.top_0().left_0().right_0().h_32(), Some(SplitDirection::Down) => { div.left_0().bottom_0().right_0().h_32() } Some(SplitDirection::Left) => { div.top_0().left_0().bottom_0().w_32() } Some(SplitDirection::Right) => { div.top_0().bottom_0().right_0().w_32() } }), ) }) .on_mouse_down( MouseButton::Navigate(NavigationDirection::Back), cx.listener(|pane, _, cx| { if let Some(workspace) = pane.workspace.upgrade() { let pane = cx.view().downgrade(); cx.window_context().defer(move |cx| { workspace.update(cx, |workspace, cx| { workspace.go_back(pane, cx).detach_and_log_err(cx) }) }) } }), ) .on_mouse_down( MouseButton::Navigate(NavigationDirection::Forward), cx.listener(|pane, _, cx| { if let Some(workspace) = pane.workspace.upgrade() { let pane = cx.view().downgrade(); cx.window_context().defer(move |cx| { workspace.update(cx, |workspace, cx| { workspace.go_forward(pane, cx).detach_and_log_err(cx) }) }) } }), ) } } impl ItemNavHistory { pub fn push(&mut self, data: Option, cx: &mut WindowContext) { self.history.push(data, self.item.clone(), cx); } pub fn pop_backward(&mut self, cx: &mut WindowContext) -> Option { self.history.pop(NavigationMode::GoingBack, cx) } pub fn pop_forward(&mut self, cx: &mut WindowContext) -> Option { self.history.pop(NavigationMode::GoingForward, cx) } } impl NavHistory { pub fn for_each_entry( &self, cx: &AppContext, mut f: impl FnMut(&NavigationEntry, (ProjectPath, Option)), ) { let borrowed_history = self.0.lock(); borrowed_history .forward_stack .iter() .chain(borrowed_history.backward_stack.iter()) .chain(borrowed_history.closed_stack.iter()) .for_each(|entry| { if let Some(project_and_abs_path) = borrowed_history.paths_by_item.get(&entry.item.id()) { f(entry, project_and_abs_path.clone()); } else if let Some(item) = entry.item.upgrade() { if let Some(path) = item.project_path(cx) { f(entry, (path, None)); } } }) } pub fn set_mode(&mut self, mode: NavigationMode) { self.0.lock().mode = mode; } pub fn mode(&self) -> NavigationMode { self.0.lock().mode } pub fn disable(&mut self) { self.0.lock().mode = NavigationMode::Disabled; } pub fn enable(&mut self) { self.0.lock().mode = NavigationMode::Normal; } pub fn pop(&mut self, mode: NavigationMode, cx: &mut WindowContext) -> Option { let mut state = self.0.lock(); let entry = match mode { NavigationMode::Normal | NavigationMode::Disabled | NavigationMode::ClosingItem => { return None } NavigationMode::GoingBack => &mut state.backward_stack, NavigationMode::GoingForward => &mut state.forward_stack, NavigationMode::ReopeningClosedItem => &mut state.closed_stack, } .pop_back(); if entry.is_some() { state.did_update(cx); } entry } pub fn push( &mut self, data: Option, item: Arc, cx: &mut WindowContext, ) { let state = &mut *self.0.lock(); match state.mode { NavigationMode::Disabled => {} NavigationMode::Normal | NavigationMode::ReopeningClosedItem => { if state.backward_stack.len() >= MAX_NAVIGATION_HISTORY_LEN { state.backward_stack.pop_front(); } state.backward_stack.push_back(NavigationEntry { item, data: data.map(|data| Box::new(data) as Box), timestamp: state.next_timestamp.fetch_add(1, Ordering::SeqCst), }); state.forward_stack.clear(); } NavigationMode::GoingBack => { if state.forward_stack.len() >= MAX_NAVIGATION_HISTORY_LEN { state.forward_stack.pop_front(); } state.forward_stack.push_back(NavigationEntry { item, data: data.map(|data| Box::new(data) as Box), timestamp: state.next_timestamp.fetch_add(1, Ordering::SeqCst), }); } NavigationMode::GoingForward => { if state.backward_stack.len() >= MAX_NAVIGATION_HISTORY_LEN { state.backward_stack.pop_front(); } state.backward_stack.push_back(NavigationEntry { item, data: data.map(|data| Box::new(data) as Box), timestamp: state.next_timestamp.fetch_add(1, Ordering::SeqCst), }); } NavigationMode::ClosingItem => { if state.closed_stack.len() >= MAX_NAVIGATION_HISTORY_LEN { state.closed_stack.pop_front(); } state.closed_stack.push_back(NavigationEntry { item, data: data.map(|data| Box::new(data) as Box), timestamp: state.next_timestamp.fetch_add(1, Ordering::SeqCst), }); } } state.did_update(cx); } pub fn remove_item(&mut self, item_id: EntityId) { let mut state = self.0.lock(); state.paths_by_item.remove(&item_id); state .backward_stack .retain(|entry| entry.item.id() != item_id); state .forward_stack .retain(|entry| entry.item.id() != item_id); state .closed_stack .retain(|entry| entry.item.id() != item_id); } pub fn path_for_item(&self, item_id: EntityId) -> Option<(ProjectPath, Option)> { self.0.lock().paths_by_item.get(&item_id).cloned() } } impl NavHistoryState { pub fn did_update(&self, cx: &mut WindowContext) { if let Some(pane) = self.pane.upgrade() { cx.defer(move |cx| { pane.update(cx, |pane, cx| pane.history_updated(cx)); }); } } } fn dirty_message_for(buffer_path: Option) -> String { let path = buffer_path .as_ref() .and_then(|p| p.path.to_str()) .unwrap_or(&"This buffer"); let path = truncate_and_remove_front(path, 80); format!("{path} contains unsaved edits. Do you want to save it?") } #[cfg(test)] mod tests { use super::*; use crate::item::test::{TestItem, TestProjectItem}; use gpui::{TestAppContext, VisualTestContext}; use project::FakeFs; use settings::SettingsStore; use theme::LoadThemes; #[gpui::test] async fn test_remove_active_empty(cx: &mut TestAppContext) { init_test(cx); let fs = FakeFs::new(cx.executor()); let project = Project::test(fs, None, cx).await; let (workspace, cx) = cx.add_window_view(|cx| Workspace::test_new(project.clone(), cx)); let pane = workspace.update(cx, |workspace, _| workspace.active_pane().clone()); pane.update(cx, |pane, cx| { assert!(pane .close_active_item(&CloseActiveItem { save_intent: None }, cx) .is_none()) }); } #[gpui::test] async fn test_add_item_with_new_item(cx: &mut TestAppContext) { init_test(cx); let fs = FakeFs::new(cx.executor()); let project = Project::test(fs, None, cx).await; let (workspace, cx) = cx.add_window_view(|cx| Workspace::test_new(project.clone(), cx)); let pane = workspace.update(cx, |workspace, _| workspace.active_pane().clone()); // 1. Add with a destination index // a. Add before the active item set_labeled_items(&pane, ["A", "B*", "C"], cx); pane.update(cx, |pane, cx| { pane.add_item( Box::new(cx.new_view(|cx| TestItem::new(cx).with_label("D"))), false, false, Some(0), cx, ); }); assert_item_labels(&pane, ["D*", "A", "B", "C"], cx); // b. Add after the active item set_labeled_items(&pane, ["A", "B*", "C"], cx); pane.update(cx, |pane, cx| { pane.add_item( Box::new(cx.new_view(|cx| TestItem::new(cx).with_label("D"))), false, false, Some(2), cx, ); }); assert_item_labels(&pane, ["A", "B", "D*", "C"], cx); // c. Add at the end of the item list (including off the length) set_labeled_items(&pane, ["A", "B*", "C"], cx); pane.update(cx, |pane, cx| { pane.add_item( Box::new(cx.new_view(|cx| TestItem::new(cx).with_label("D"))), false, false, Some(5), cx, ); }); assert_item_labels(&pane, ["A", "B", "C", "D*"], cx); // 2. Add without a destination index // a. Add with active item at the start of the item list set_labeled_items(&pane, ["A*", "B", "C"], cx); pane.update(cx, |pane, cx| { pane.add_item( Box::new(cx.new_view(|cx| TestItem::new(cx).with_label("D"))), false, false, None, cx, ); }); set_labeled_items(&pane, ["A", "D*", "B", "C"], cx); // b. Add with active item at the end of the item list set_labeled_items(&pane, ["A", "B", "C*"], cx); pane.update(cx, |pane, cx| { pane.add_item( Box::new(cx.new_view(|cx| TestItem::new(cx).with_label("D"))), false, false, None, cx, ); }); assert_item_labels(&pane, ["A", "B", "C", "D*"], cx); } #[gpui::test] async fn test_add_item_with_existing_item(cx: &mut TestAppContext) { init_test(cx); let fs = FakeFs::new(cx.executor()); let project = Project::test(fs, None, cx).await; let (workspace, cx) = cx.add_window_view(|cx| Workspace::test_new(project.clone(), cx)); let pane = workspace.update(cx, |workspace, _| workspace.active_pane().clone()); // 1. Add with a destination index // 1a. Add before the active item let [_, _, _, d] = set_labeled_items(&pane, ["A", "B*", "C", "D"], cx); pane.update(cx, |pane, cx| { pane.add_item(d, false, false, Some(0), cx); }); assert_item_labels(&pane, ["D*", "A", "B", "C"], cx); // 1b. Add after the active item let [_, _, _, d] = set_labeled_items(&pane, ["A", "B*", "C", "D"], cx); pane.update(cx, |pane, cx| { pane.add_item(d, false, false, Some(2), cx); }); assert_item_labels(&pane, ["A", "B", "D*", "C"], cx); // 1c. Add at the end of the item list (including off the length) let [a, _, _, _] = set_labeled_items(&pane, ["A", "B*", "C", "D"], cx); pane.update(cx, |pane, cx| { pane.add_item(a, false, false, Some(5), cx); }); assert_item_labels(&pane, ["B", "C", "D", "A*"], cx); // 1d. Add same item to active index let [_, b, _] = set_labeled_items(&pane, ["A", "B*", "C"], cx); pane.update(cx, |pane, cx| { pane.add_item(b, false, false, Some(1), cx); }); assert_item_labels(&pane, ["A", "B*", "C"], cx); // 1e. Add item to index after same item in last position let [_, _, c] = set_labeled_items(&pane, ["A", "B*", "C"], cx); pane.update(cx, |pane, cx| { pane.add_item(c, false, false, Some(2), cx); }); assert_item_labels(&pane, ["A", "B", "C*"], cx); // 2. Add without a destination index // 2a. Add with active item at the start of the item list let [_, _, _, d] = set_labeled_items(&pane, ["A*", "B", "C", "D"], cx); pane.update(cx, |pane, cx| { pane.add_item(d, false, false, None, cx); }); assert_item_labels(&pane, ["A", "D*", "B", "C"], cx); // 2b. Add with active item at the end of the item list let [a, _, _, _] = set_labeled_items(&pane, ["A", "B", "C", "D*"], cx); pane.update(cx, |pane, cx| { pane.add_item(a, false, false, None, cx); }); assert_item_labels(&pane, ["B", "C", "D", "A*"], cx); // 2c. Add active item to active item at end of list let [_, _, c] = set_labeled_items(&pane, ["A", "B", "C*"], cx); pane.update(cx, |pane, cx| { pane.add_item(c, false, false, None, cx); }); assert_item_labels(&pane, ["A", "B", "C*"], cx); // 2d. Add active item to active item at start of list let [a, _, _] = set_labeled_items(&pane, ["A*", "B", "C"], cx); pane.update(cx, |pane, cx| { pane.add_item(a, false, false, None, cx); }); assert_item_labels(&pane, ["A*", "B", "C"], cx); } #[gpui::test] async fn test_add_item_with_same_project_entries(cx: &mut TestAppContext) { init_test(cx); let fs = FakeFs::new(cx.executor()); let project = Project::test(fs, None, cx).await; let (workspace, cx) = cx.add_window_view(|cx| Workspace::test_new(project.clone(), cx)); let pane = workspace.update(cx, |workspace, _| workspace.active_pane().clone()); // singleton view pane.update(cx, |pane, cx| { pane.add_item( Box::new(cx.new_view(|cx| { TestItem::new(cx) .with_singleton(true) .with_label("buffer 1") .with_project_items(&[TestProjectItem::new(1, "one.txt", cx)]) })), false, false, None, cx, ); }); assert_item_labels(&pane, ["buffer 1*"], cx); // new singleton view with the same project entry pane.update(cx, |pane, cx| { pane.add_item( Box::new(cx.new_view(|cx| { TestItem::new(cx) .with_singleton(true) .with_label("buffer 1") .with_project_items(&[TestProjectItem::new(1, "1.txt", cx)]) })), false, false, None, cx, ); }); assert_item_labels(&pane, ["buffer 1*"], cx); // new singleton view with different project entry pane.update(cx, |pane, cx| { pane.add_item( Box::new(cx.new_view(|cx| { TestItem::new(cx) .with_singleton(true) .with_label("buffer 2") .with_project_items(&[TestProjectItem::new(2, "2.txt", cx)]) })), false, false, None, cx, ); }); assert_item_labels(&pane, ["buffer 1", "buffer 2*"], cx); // new multibuffer view with the same project entry pane.update(cx, |pane, cx| { pane.add_item( Box::new(cx.new_view(|cx| { TestItem::new(cx) .with_singleton(false) .with_label("multibuffer 1") .with_project_items(&[TestProjectItem::new(1, "1.txt", cx)]) })), false, false, None, cx, ); }); assert_item_labels(&pane, ["buffer 1", "buffer 2", "multibuffer 1*"], cx); // another multibuffer view with the same project entry pane.update(cx, |pane, cx| { pane.add_item( Box::new(cx.new_view(|cx| { TestItem::new(cx) .with_singleton(false) .with_label("multibuffer 1b") .with_project_items(&[TestProjectItem::new(1, "1.txt", cx)]) })), false, false, None, cx, ); }); assert_item_labels( &pane, ["buffer 1", "buffer 2", "multibuffer 1", "multibuffer 1b*"], cx, ); } #[gpui::test] async fn test_remove_item_ordering(cx: &mut TestAppContext) { init_test(cx); let fs = FakeFs::new(cx.executor()); let project = Project::test(fs, None, cx).await; let (workspace, cx) = cx.add_window_view(|cx| Workspace::test_new(project.clone(), cx)); let pane = workspace.update(cx, |workspace, _| workspace.active_pane().clone()); add_labeled_item(&pane, "A", false, cx); add_labeled_item(&pane, "B", false, cx); add_labeled_item(&pane, "C", false, cx); add_labeled_item(&pane, "D", false, cx); assert_item_labels(&pane, ["A", "B", "C", "D*"], cx); pane.update(cx, |pane, cx| pane.activate_item(1, false, false, cx)); add_labeled_item(&pane, "1", false, cx); assert_item_labels(&pane, ["A", "B", "1*", "C", "D"], cx); pane.update(cx, |pane, cx| { pane.close_active_item(&CloseActiveItem { save_intent: None }, cx) }) .unwrap() .await .unwrap(); assert_item_labels(&pane, ["A", "B*", "C", "D"], cx); pane.update(cx, |pane, cx| pane.activate_item(3, false, false, cx)); assert_item_labels(&pane, ["A", "B", "C", "D*"], cx); pane.update(cx, |pane, cx| { pane.close_active_item(&CloseActiveItem { save_intent: None }, cx) }) .unwrap() .await .unwrap(); assert_item_labels(&pane, ["A", "B*", "C"], cx); pane.update(cx, |pane, cx| { pane.close_active_item(&CloseActiveItem { save_intent: None }, cx) }) .unwrap() .await .unwrap(); assert_item_labels(&pane, ["A", "C*"], cx); pane.update(cx, |pane, cx| { pane.close_active_item(&CloseActiveItem { save_intent: None }, cx) }) .unwrap() .await .unwrap(); assert_item_labels(&pane, ["A*"], cx); } #[gpui::test] async fn test_close_inactive_items(cx: &mut TestAppContext) { init_test(cx); let fs = FakeFs::new(cx.executor()); let project = Project::test(fs, None, cx).await; let (workspace, cx) = cx.add_window_view(|cx| Workspace::test_new(project.clone(), cx)); let pane = workspace.update(cx, |workspace, _| workspace.active_pane().clone()); set_labeled_items(&pane, ["A", "B", "C*", "D", "E"], cx); pane.update(cx, |pane, cx| { pane.close_inactive_items(&CloseInactiveItems, cx) }) .unwrap() .await .unwrap(); assert_item_labels(&pane, ["C*"], cx); } #[gpui::test] async fn test_close_clean_items(cx: &mut TestAppContext) { init_test(cx); let fs = FakeFs::new(cx.executor()); let project = Project::test(fs, None, cx).await; let (workspace, cx) = cx.add_window_view(|cx| Workspace::test_new(project.clone(), cx)); let pane = workspace.update(cx, |workspace, _| workspace.active_pane().clone()); add_labeled_item(&pane, "A", true, cx); add_labeled_item(&pane, "B", false, cx); add_labeled_item(&pane, "C", true, cx); add_labeled_item(&pane, "D", false, cx); add_labeled_item(&pane, "E", false, cx); assert_item_labels(&pane, ["A^", "B", "C^", "D", "E*"], cx); pane.update(cx, |pane, cx| pane.close_clean_items(&CloseCleanItems, cx)) .unwrap() .await .unwrap(); assert_item_labels(&pane, ["A^", "C*^"], cx); } #[gpui::test] async fn test_close_items_to_the_left(cx: &mut TestAppContext) { init_test(cx); let fs = FakeFs::new(cx.executor()); let project = Project::test(fs, None, cx).await; let (workspace, cx) = cx.add_window_view(|cx| Workspace::test_new(project.clone(), cx)); let pane = workspace.update(cx, |workspace, _| workspace.active_pane().clone()); set_labeled_items(&pane, ["A", "B", "C*", "D", "E"], cx); pane.update(cx, |pane, cx| { pane.close_items_to_the_left(&CloseItemsToTheLeft, cx) }) .unwrap() .await .unwrap(); assert_item_labels(&pane, ["C*", "D", "E"], cx); } #[gpui::test] async fn test_close_items_to_the_right(cx: &mut TestAppContext) { init_test(cx); let fs = FakeFs::new(cx.executor()); let project = Project::test(fs, None, cx).await; let (workspace, cx) = cx.add_window_view(|cx| Workspace::test_new(project.clone(), cx)); let pane = workspace.update(cx, |workspace, _| workspace.active_pane().clone()); set_labeled_items(&pane, ["A", "B", "C*", "D", "E"], cx); pane.update(cx, |pane, cx| { pane.close_items_to_the_right(&CloseItemsToTheRight, cx) }) .unwrap() .await .unwrap(); assert_item_labels(&pane, ["A", "B", "C*"], cx); } #[gpui::test] async fn test_close_all_items(cx: &mut TestAppContext) { init_test(cx); let fs = FakeFs::new(cx.executor()); let project = Project::test(fs, None, cx).await; let (workspace, cx) = cx.add_window_view(|cx| Workspace::test_new(project.clone(), cx)); let pane = workspace.update(cx, |workspace, _| workspace.active_pane().clone()); add_labeled_item(&pane, "A", false, cx); add_labeled_item(&pane, "B", false, cx); add_labeled_item(&pane, "C", false, cx); assert_item_labels(&pane, ["A", "B", "C*"], cx); pane.update(cx, |pane, cx| { pane.close_all_items(&CloseAllItems { save_intent: None }, cx) }) .unwrap() .await .unwrap(); assert_item_labels(&pane, [], cx); add_labeled_item(&pane, "A", true, cx); add_labeled_item(&pane, "B", true, cx); add_labeled_item(&pane, "C", true, cx); assert_item_labels(&pane, ["A^", "B^", "C*^"], cx); let save = pane .update(cx, |pane, cx| { pane.close_all_items(&CloseAllItems { save_intent: None }, cx) }) .unwrap(); cx.executor().run_until_parked(); cx.simulate_prompt_answer(2); save.await.unwrap(); assert_item_labels(&pane, [], cx); } fn init_test(cx: &mut TestAppContext) { cx.update(|cx| { let settings_store = SettingsStore::test(cx); cx.set_global(settings_store); theme::init(LoadThemes::JustBase, cx); crate::init_settings(cx); Project::init_settings(cx); }); } fn add_labeled_item( pane: &View, label: &str, is_dirty: bool, cx: &mut VisualTestContext, ) -> Box> { pane.update(cx, |pane, cx| { let labeled_item = Box::new( cx.new_view(|cx| TestItem::new(cx).with_label(label).with_dirty(is_dirty)), ); pane.add_item(labeled_item.clone(), false, false, None, cx); labeled_item }) } fn set_labeled_items( pane: &View, labels: [&str; COUNT], cx: &mut VisualTestContext, ) -> [Box>; COUNT] { pane.update(cx, |pane, cx| { pane.items.clear(); let mut active_item_index = 0; let mut index = 0; let items = labels.map(|mut label| { if label.ends_with("*") { label = label.trim_end_matches("*"); active_item_index = index; } let labeled_item = Box::new(cx.new_view(|cx| TestItem::new(cx).with_label(label))); pane.add_item(labeled_item.clone(), false, false, None, cx); index += 1; labeled_item }); pane.activate_item(active_item_index, false, false, cx); items }) } // Assert the item label, with the active item label suffixed with a '*' fn assert_item_labels( pane: &View, expected_states: [&str; COUNT], cx: &mut VisualTestContext, ) { pane.update(cx, |pane, cx| { let actual_states = pane .items .iter() .enumerate() .map(|(ix, item)| { let mut state = item .to_any() .downcast::() .unwrap() .read(cx) .label .clone(); if ix == pane.active_item_index { state.push('*'); } if item.is_dirty(cx) { state.push('^'); } state }) .collect::>(); assert_eq!( actual_states, expected_states, "pane items do not match expectation" ); }) } } impl Render for DraggedTab { fn render(&mut self, cx: &mut ViewContext) -> impl IntoElement { let ui_font = ThemeSettings::get_global(cx).ui_font.family.clone(); let item = &self.pane.read(cx).items[self.ix]; let label = item.tab_content(Some(self.detail), false, cx); Tab::new("") .selected(self.is_active) .child(label) .render(cx) .font(ui_font) } }