mod dev_servers; pub use dev_servers::DevServerProjects;use feature_flags::FeatureFlagAppExt;use fuzzy::{StringMatch, StringMatchCandidate};use gpui::{ Action, AnyElement, AppContext, DismissEvent, EventEmitter, FocusHandle, FocusableView, Subscription, Task, View, ViewContext, WeakView,};use ordered_float::OrderedFloat;use picker::{ highlighted_match_with_paths::{HighlightedMatchWithPaths, HighlightedText}, Picker, PickerDelegate,};use rpc::proto::DevServerStatus;use serde::Deserialize;use std::{ path::{Path, PathBuf}, sync::Arc,};use ui::{ prelude::*, tooltip_container, ButtonLike, IconWithIndicator, Indicator, KeyBinding, ListItem, ListItemSpacing, Tooltip,};use util::{paths::PathExt, ResultExt};use workspace::{ AppState, ModalView, SerializedWorkspaceLocation, Workspace, WorkspaceId, WORKSPACE_DB,}; #[derive(PartialEq, Clone, Deserialize, Default)]pub struct OpenRecent { #[serde(default = "default_create_new_window")] pub create_new_window: bool,} fn default_create_new_window() -> bool { true} gpui::impl_actions!(projects, [OpenRecent]);gpui::actions!(projects, [OpenRemote]); pub fn init(cx: &mut AppContext) { cx.observe_new_views(RecentProjects::register).detach(); cx.observe_new_views(DevServerProjects::register).detach();} pub struct RecentProjects { pub picker: View<Picker<RecentProjectsDelegate>>, rem_width: f32, _subscription: Subscription,} impl ModalView for RecentProjects {} impl RecentProjects { fn new(delegate: RecentProjectsDelegate, rem_width: f32, cx: &mut ViewContext<Self>) -> Self { let picker = cx.new_view(|cx| { // We want to use a list when we render paths, because the items can have different heights (multiple paths). if delegate.render_paths { Picker::list(delegate, cx) } else { Picker::uniform_list(delegate, cx) } }); let _subscription = cx.subscribe(&picker, |_, _, _, cx| cx.emit(DismissEvent)); // We do not want to block the UI on a potentially lengthy call to DB, so we're gonna swap // out workspace locations once the future runs to completion. cx.spawn(|this, mut cx| async move { let workspaces = WORKSPACE_DB .recent_workspaces_on_disk() .await .log_err() .unwrap_or_default(); this.update(&mut cx, move |this, cx| { this.picker.update(cx, move |picker, cx| { picker.delegate.set_workspaces(workspaces); picker.update_matches(picker.query(cx), cx) }) }) .ok() }) .detach(); Self { picker, rem_width, _subscription, } } fn register(workspace: &mut Workspace, _: &mut ViewContext<Workspace>) { workspace.register_action(|workspace, open_recent: &OpenRecent, cx| { let Some(recent_projects) = workspace.active_modal::<Self>(cx) else { Self::open(workspace, open_recent.create_new_window, cx); return; }; recent_projects.update(cx, |recent_projects, cx| { recent_projects .picker .update(cx, |picker, cx| picker.cycle_selection(cx)) }); }); } pub fn open( workspace: &mut Workspace, create_new_window: bool, cx: &mut ViewContext<Workspace>, ) { let weak = cx.view().downgrade(); workspace.toggle_modal(cx, |cx| { let delegate = RecentProjectsDelegate::new(weak, create_new_window, true); let modal = Self::new(delegate, 34., cx); modal }) } pub fn open_popover(workspace: WeakView<Workspace>, cx: &mut WindowContext<'_>) -> View<Self> { cx.new_view(|cx| { Self::new( RecentProjectsDelegate::new(workspace, false, false), 20., cx, ) }) }} impl EventEmitter<DismissEvent> for RecentProjects {} impl FocusableView for RecentProjects { fn focus_handle(&self, cx: &AppContext) -> FocusHandle { self.picker.focus_handle(cx) }} impl Render for RecentProjects { fn render(&mut self, cx: &mut ViewContext<Self>) -> impl IntoElement { v_flex() .w(rems(self.rem_width)) .child(self.picker.clone()) .on_mouse_down_out(cx.listener(|this, _, cx| { this.picker.update(cx, |this, cx| { this.cancel(&Default::default(), cx); }) })) }} pub struct RecentProjectsDelegate { workspace: WeakView<Workspace>, workspaces: Vec<(WorkspaceId, SerializedWorkspaceLocation)>, selected_match_index: usize, matches: Vec<StringMatch>, render_paths: bool, create_new_window: bool, // Flag to reset index when there is a new query vs not reset index when user delete an item reset_selected_match_index: bool, has_any_dev_server_projects: bool,} impl RecentProjectsDelegate { fn new(workspace: WeakView<Workspace>, create_new_window: bool, render_paths: bool) -> Self { Self { workspace, workspaces: Vec::new(), selected_match_index: 0, matches: Default::default(), create_new_window, render_paths, reset_selected_match_index: true, has_any_dev_server_projects: false, } } pub fn set_workspaces(&mut self, workspaces: Vec<(WorkspaceId, SerializedWorkspaceLocation)>) { self.workspaces = workspaces; self.has_any_dev_server_projects = self .workspaces .iter() .any(|(_, location)| matches!(location, SerializedWorkspaceLocation::DevServer(_))); }}impl EventEmitter<DismissEvent> for RecentProjectsDelegate {}impl PickerDelegate for RecentProjectsDelegate { type ListItem = ListItem; fn placeholder_text(&self, cx: &mut WindowContext) -> Arc<str> { let (create_window, reuse_window) = if self.create_new_window { ( cx.keystroke_text_for(&menu::Confirm), cx.keystroke_text_for(&menu::SecondaryConfirm), ) } else { ( cx.keystroke_text_for(&menu::SecondaryConfirm), cx.keystroke_text_for(&menu::Confirm), ) }; Arc::from(format!( "{reuse_window} reuses this window, {create_window} opens a new one", )) } fn match_count(&self) -> usize { self.matches.len() } fn selected_index(&self) -> usize { self.selected_match_index } fn set_selected_index(&mut self, ix: usize, _cx: &mut ViewContext<Picker<Self>>) { self.selected_match_index = ix; } fn update_matches( &mut self, query: String, cx: &mut ViewContext<Picker<Self>>, ) -> gpui::Task<()> { let query = query.trim_start(); let smart_case = query.chars().any(|c| c.is_uppercase()); let candidates = self .workspaces .iter() .enumerate() .map(|(id, (_, location))| { let combined_string = match location { SerializedWorkspaceLocation::Local(paths) => paths .paths() .iter() .map(|path| path.compact().to_string_lossy().into_owned()) .collect::<Vec<_>>() .join(""), SerializedWorkspaceLocation::DevServer(dev_server_project) => { format!( "{}{}", dev_server_project.dev_server_name, dev_server_project.path ) } }; StringMatchCandidate::new(id, combined_string) }) .collect::<Vec<_>>(); self.matches = smol::block_on(fuzzy::match_strings( candidates.as_slice(), query, smart_case, 100, &Default::default(), cx.background_executor().clone(), )); self.matches.sort_unstable_by_key(|m| m.candidate_id); if self.reset_selected_match_index { self.selected_match_index = self .matches .iter() .enumerate() .rev() .max_by_key(|(_, m)| OrderedFloat(m.score)) .map(|(ix, _)| ix) .unwrap_or(0); } self.reset_selected_match_index = true; Task::ready(()) } fn confirm(&mut self, secondary: bool, cx: &mut ViewContext<Picker<Self>>) { if let Some((selected_match, workspace)) = self .matches .get(self.selected_index()) .zip(self.workspace.upgrade()) { let (candidate_workspace_id, candidate_workspace_location) = &self.workspaces[selected_match.candidate_id]; let replace_current_window = if self.create_new_window { secondary } else { !secondary }; workspace .update(cx, |workspace, cx| { if workspace.database_id() == *candidate_workspace_id { Task::ready(Ok(())) } else { match candidate_workspace_location { SerializedWorkspaceLocation::Local(paths) => { let paths = paths.paths().as_ref().clone(); if replace_current_window { cx.spawn(move |workspace, mut cx| async move { let continue_replacing = workspace .update(&mut cx, |workspace, cx| { workspace.prepare_to_close(true, cx) })? .await?; if continue_replacing { workspace .update(&mut cx, |workspace, cx| { workspace .open_workspace_for_paths(true, paths, cx) })? .await } else { Ok(()) } }) } else { workspace.open_workspace_for_paths(false, paths, cx) } } SerializedWorkspaceLocation::DevServer(dev_server_project) => { let store = dev_server_projects::Store::global(cx).read(cx); let Some(project_id) = store .dev_server_project(dev_server_project.id) .and_then(|p| p.project_id) else { let dev_server_name = dev_server_project.dev_server_name.clone(); return cx.spawn(|workspace, mut cx| async move { let response = cx.prompt(gpui::PromptLevel::Warning, "Dev Server is offline", Some(format!("Cannot connect to {}. To debug open the remote project settings.", dev_server_name).as_str()), &["Ok", "Open Settings"] ).await?; if response == 1 { workspace.update(&mut cx, |workspace, cx| { workspace.toggle_modal(cx, |cx| DevServerProjects::new(cx)) })?; } else { workspace.update(&mut cx, |workspace, cx| { RecentProjects::open(workspace, true, cx); })?; } Ok(()) }) }; if let Some(app_state) = AppState::global(cx).upgrade() { let handle = if replace_current_window { cx.window_handle().downcast::<Workspace>() } else { None }; if let Some(handle) = handle { cx.spawn(move |workspace, mut cx| async move { let continue_replacing = workspace .update(&mut cx, |workspace, cx| { workspace. prepare_to_close(true, cx) })? .await?; if continue_replacing { workspace .update(&mut cx, |_workspace, cx| { workspace::join_dev_server_project(project_id, app_state, Some(handle), cx) })? .await?; } Ok(()) }) } else { let task = workspace::join_dev_server_project(project_id, app_state, None, cx); cx.spawn(|_, _| async move { task.await?; Ok(()) }) } } else { Task::ready(Err(anyhow::anyhow!("App state not found"))) } } } } }) .detach_and_log_err(cx); cx.emit(DismissEvent); } } fn dismissed(&mut self, _: &mut ViewContext<Picker<Self>>) {} fn no_matches_text(&self, _cx: &mut WindowContext) -> SharedString { if self.workspaces.is_empty() { "Recently opened projects will show up here".into() } else { "No matches".into() } } fn render_match( &self, ix: usize, selected: bool, cx: &mut ViewContext<Picker<Self>>, ) -> Option<Self::ListItem> { let Some(hit) = self.matches.get(ix) else { return None; }; let (workspace_id, location) = &self.workspaces[hit.candidate_id]; let is_current_workspace = self.is_current_workspace(*workspace_id, cx); let is_remote = matches!(location, SerializedWorkspaceLocation::DevServer(_)); let dev_server_status = if let SerializedWorkspaceLocation::DevServer(dev_server_project) = location { let store = dev_server_projects::Store::global(cx).read(cx); Some( store .dev_server_project(dev_server_project.id) .and_then(|p| store.dev_server(p.dev_server_id)) .map(|s| s.status) .unwrap_or_default(), ) } else { None }; let mut path_start_offset = 0; let paths = match location { SerializedWorkspaceLocation::Local(paths) => paths.paths(), SerializedWorkspaceLocation::DevServer(dev_server_project) => { Arc::new(vec![PathBuf::from(format!( "{}:{}", dev_server_project.dev_server_name, dev_server_project.path ))]) } }; let (match_labels, paths): (Vec<_>, Vec<_>) = paths .iter() .map(|path| { let path = path.compact(); let highlighted_text = highlights_for_path(path.as_ref(), &hit.positions, path_start_offset); path_start_offset += highlighted_text.1.char_count; highlighted_text }) .unzip(); let highlighted_match = HighlightedMatchWithPaths { match_label: HighlightedText::join(match_labels.into_iter().flatten(), ", ").color( if matches!(dev_server_status, Some(DevServerStatus::Offline)) { Color::Disabled } else { Color::Default }, ), paths, }; Some( ListItem::new(ix) .selected(selected) .inset(true) .spacing(ListItemSpacing::Sparse) .child( h_flex() .flex_grow() .gap_3() .when(self.has_any_dev_server_projects, |this| { this.child(if is_remote { // if disabled, Color::Disabled let indicator_color = match dev_server_status { Some(DevServerStatus::Online) => Color::Created, Some(DevServerStatus::Offline) => Color::Hidden, _ => unreachable!(), }; IconWithIndicator::new( Icon::new(IconName::Server).color(Color::Muted), Some(Indicator::dot()), ) .indicator_color(indicator_color) .indicator_border_color(if selected { Some(cx.theme().colors().element_selected) } else { None }) .into_any_element() } else { Icon::new(IconName::Screen) .color(Color::Muted) .into_any_element() }) }) .child({ let mut highlighted = highlighted_match.clone(); if !self.render_paths { highlighted.paths.clear(); } highlighted.render(cx) }), ) .when(!is_current_workspace, |el| {Lines 1–500 of 809. Load more
mod dev_servers; pub use dev_servers::DevServerProjects; use feature_flags::FeatureFlagAppExt; use fuzzy::{StringMatch, StringMatchCandidate}; use gpui::{ Action, AnyElement, AppContext, DismissEvent, EventEmitter, FocusHandle, FocusableView, Subscription, Task, View, ViewContext, WeakView, }; use ordered_float::OrderedFloat; use picker::{ highlighted_match_with_paths::{HighlightedMatchWithPaths, HighlightedText}, Picker, PickerDelegate, }; use rpc::proto::DevServerStatus; use serde::Deserialize; use std::{ path::{Path, PathBuf}, sync::Arc, }; use ui::{ prelude::*, tooltip_container, ButtonLike, IconWithIndicator, Indicator, KeyBinding, ListItem, ListItemSpacing, Tooltip, }; use util::{paths::PathExt, ResultExt}; use workspace::{ AppState, ModalView, SerializedWorkspaceLocation, Workspace, WorkspaceId, WORKSPACE_DB, }; #[derive(PartialEq, Clone, Deserialize, Default)] pub struct OpenRecent { #[serde(default = "default_create_new_window")] pub create_new_window: bool, } fn default_create_new_window() -> bool { true } gpui::impl_actions!(projects, [OpenRecent]); gpui::actions!(projects, [OpenRemote]); pub fn init(cx: &mut AppContext) { cx.observe_new_views(RecentProjects::register).detach(); cx.observe_new_views(DevServerProjects::register).detach(); } pub struct RecentProjects { pub picker: View<Picker<RecentProjectsDelegate>>, rem_width: f32, _subscription: Subscription, } impl ModalView for RecentProjects {} impl RecentProjects { fn new(delegate: RecentProjectsDelegate, rem_width: f32, cx: &mut ViewContext<Self>) -> Self { let picker = cx.new_view(|cx| { // We want to use a list when we render paths, because the items can have different heights (multiple paths). if delegate.render_paths { Picker::list(delegate, cx) } else { Picker::uniform_list(delegate, cx) } }); let _subscription = cx.subscribe(&picker, |_, _, _, cx| cx.emit(DismissEvent)); // We do not want to block the UI on a potentially lengthy call to DB, so we're gonna swap // out workspace locations once the future runs to completion. cx.spawn(|this, mut cx| async move { let workspaces = WORKSPACE_DB .recent_workspaces_on_disk() .await .log_err() .unwrap_or_default(); this.update(&mut cx, move |this, cx| { this.picker.update(cx, move |picker, cx| { picker.delegate.set_workspaces(workspaces); picker.update_matches(picker.query(cx), cx) }) }) .ok() }) .detach(); Self { picker, rem_width, _subscription, } } fn register(workspace: &mut Workspace, _: &mut ViewContext<Workspace>) { workspace.register_action(|workspace, open_recent: &OpenRecent, cx| { let Some(recent_projects) = workspace.active_modal::<Self>(cx) else { Self::open(workspace, open_recent.create_new_window, cx); return; }; recent_projects.update(cx, |recent_projects, cx| { recent_projects .picker .update(cx, |picker, cx| picker.cycle_selection(cx)) }); }); } pub fn open( workspace: &mut Workspace, create_new_window: bool, cx: &mut ViewContext<Workspace>, ) { let weak = cx.view().downgrade(); workspace.toggle_modal(cx, |cx| { let delegate = RecentProjectsDelegate::new(weak, create_new_window, true); let modal = Self::new(delegate, 34., cx); modal }) } pub fn open_popover(workspace: WeakView<Workspace>, cx: &mut WindowContext<'_>) -> View<Self> { cx.new_view(|cx| { Self::new( RecentProjectsDelegate::new(workspace, false, false), 20., cx, ) }) } } impl EventEmitter<DismissEvent> for RecentProjects {} impl FocusableView for RecentProjects { fn focus_handle(&self, cx: &AppContext) -> FocusHandle { self.picker.focus_handle(cx) } } impl Render for RecentProjects { fn render(&mut self, cx: &mut ViewContext<Self>) -> impl IntoElement { v_flex() .w(rems(self.rem_width)) .child(self.picker.clone()) .on_mouse_down_out(cx.listener(|this, _, cx| { this.picker.update(cx, |this, cx| { this.cancel(&Default::default(), cx); }) })) } } pub struct RecentProjectsDelegate { workspace: WeakView<Workspace>, workspaces: Vec<(WorkspaceId, SerializedWorkspaceLocation)>, selected_match_index: usize, matches: Vec<StringMatch>, render_paths: bool, create_new_window: bool, // Flag to reset index when there is a new query vs not reset index when user delete an item reset_selected_match_index: bool, has_any_dev_server_projects: bool, } impl RecentProjectsDelegate { fn new(workspace: WeakView<Workspace>, create_new_window: bool, render_paths: bool) -> Self { Self { workspace, workspaces: Vec::new(), selected_match_index: 0, matches: Default::default(), create_new_window, render_paths, reset_selected_match_index: true, has_any_dev_server_projects: false, } } pub fn set_workspaces(&mut self, workspaces: Vec<(WorkspaceId, SerializedWorkspaceLocation)>) { self.workspaces = workspaces; self.has_any_dev_server_projects = self .workspaces .iter() .any(|(_, location)| matches!(location, SerializedWorkspaceLocation::DevServer(_))); } } impl EventEmitter<DismissEvent> for RecentProjectsDelegate {} impl PickerDelegate for RecentProjectsDelegate { type ListItem = ListItem; fn placeholder_text(&self, cx: &mut WindowContext) -> Arc<str> { let (create_window, reuse_window) = if self.create_new_window { ( cx.keystroke_text_for(&menu::Confirm), cx.keystroke_text_for(&menu::SecondaryConfirm), ) } else { ( cx.keystroke_text_for(&menu::SecondaryConfirm), cx.keystroke_text_for(&menu::Confirm), ) }; Arc::from(format!( "{reuse_window} reuses this window, {create_window} opens a new one", )) } fn match_count(&self) -> usize { self.matches.len() } fn selected_index(&self) -> usize { self.selected_match_index } fn set_selected_index(&mut self, ix: usize, _cx: &mut ViewContext<Picker<Self>>) { self.selected_match_index = ix; } fn update_matches( &mut self, query: String, cx: &mut ViewContext<Picker<Self>>, ) -> gpui::Task<()> { let query = query.trim_start(); let smart_case = query.chars().any(|c| c.is_uppercase()); let candidates = self .workspaces .iter() .enumerate() .map(|(id, (_, location))| { let combined_string = match location { SerializedWorkspaceLocation::Local(paths) => paths .paths() .iter() .map(|path| path.compact().to_string_lossy().into_owned()) .collect::<Vec<_>>() .join(""), SerializedWorkspaceLocation::DevServer(dev_server_project) => { format!( "{}{}", dev_server_project.dev_server_name, dev_server_project.path ) } }; StringMatchCandidate::new(id, combined_string) }) .collect::<Vec<_>>(); self.matches = smol::block_on(fuzzy::match_strings( candidates.as_slice(), query, smart_case, 100, &Default::default(), cx.background_executor().clone(), )); self.matches.sort_unstable_by_key(|m| m.candidate_id); if self.reset_selected_match_index { self.selected_match_index = self .matches .iter() .enumerate() .rev() .max_by_key(|(_, m)| OrderedFloat(m.score)) .map(|(ix, _)| ix) .unwrap_or(0); } self.reset_selected_match_index = true; Task::ready(()) } fn confirm(&mut self, secondary: bool, cx: &mut ViewContext<Picker<Self>>) { if let Some((selected_match, workspace)) = self .matches .get(self.selected_index()) .zip(self.workspace.upgrade()) { let (candidate_workspace_id, candidate_workspace_location) = &self.workspaces[selected_match.candidate_id]; let replace_current_window = if self.create_new_window { secondary } else { !secondary }; workspace .update(cx, |workspace, cx| { if workspace.database_id() == *candidate_workspace_id { Task::ready(Ok(())) } else { match candidate_workspace_location { SerializedWorkspaceLocation::Local(paths) => { let paths = paths.paths().as_ref().clone(); if replace_current_window { cx.spawn(move |workspace, mut cx| async move { let continue_replacing = workspace .update(&mut cx, |workspace, cx| { workspace.prepare_to_close(true, cx) })? .await?; if continue_replacing { workspace .update(&mut cx, |workspace, cx| { workspace .open_workspace_for_paths(true, paths, cx) })? .await } else { Ok(()) } }) } else { workspace.open_workspace_for_paths(false, paths, cx) } } SerializedWorkspaceLocation::DevServer(dev_server_project) => { let store = dev_server_projects::Store::global(cx).read(cx); let Some(project_id) = store .dev_server_project(dev_server_project.id) .and_then(|p| p.project_id) else { let dev_server_name = dev_server_project.dev_server_name.clone(); return cx.spawn(|workspace, mut cx| async move { let response = cx.prompt(gpui::PromptLevel::Warning, "Dev Server is offline", Some(format!("Cannot connect to {}. To debug open the remote project settings.", dev_server_name).as_str()), &["Ok", "Open Settings"] ).await?; if response == 1 { workspace.update(&mut cx, |workspace, cx| { workspace.toggle_modal(cx, |cx| DevServerProjects::new(cx)) })?; } else { workspace.update(&mut cx, |workspace, cx| { RecentProjects::open(workspace, true, cx); })?; } Ok(()) }) }; if let Some(app_state) = AppState::global(cx).upgrade() { let handle = if replace_current_window { cx.window_handle().downcast::<Workspace>() } else { None }; if let Some(handle) = handle { cx.spawn(move |workspace, mut cx| async move { let continue_replacing = workspace .update(&mut cx, |workspace, cx| { workspace. prepare_to_close(true, cx) })? .await?; if continue_replacing { workspace .update(&mut cx, |_workspace, cx| { workspace::join_dev_server_project(project_id, app_state, Some(handle), cx) })? .await?; } Ok(()) }) } else { let task = workspace::join_dev_server_project(project_id, app_state, None, cx); cx.spawn(|_, _| async move { task.await?; Ok(()) }) } } else { Task::ready(Err(anyhow::anyhow!("App state not found"))) } } } } }) .detach_and_log_err(cx); cx.emit(DismissEvent); } } fn dismissed(&mut self, _: &mut ViewContext<Picker<Self>>) {} fn no_matches_text(&self, _cx: &mut WindowContext) -> SharedString { if self.workspaces.is_empty() { "Recently opened projects will show up here".into() } else { "No matches".into() } } fn render_match( &self, ix: usize, selected: bool, cx: &mut ViewContext<Picker<Self>>, ) -> Option<Self::ListItem> { let Some(hit) = self.matches.get(ix) else { return None; }; let (workspace_id, location) = &self.workspaces[hit.candidate_id]; let is_current_workspace = self.is_current_workspace(*workspace_id, cx); let is_remote = matches!(location, SerializedWorkspaceLocation::DevServer(_)); let dev_server_status = if let SerializedWorkspaceLocation::DevServer(dev_server_project) = location { let store = dev_server_projects::Store::global(cx).read(cx); Some( store .dev_server_project(dev_server_project.id) .and_then(|p| store.dev_server(p.dev_server_id)) .map(|s| s.status) .unwrap_or_default(), ) } else { None }; let mut path_start_offset = 0; let paths = match location { SerializedWorkspaceLocation::Local(paths) => paths.paths(), SerializedWorkspaceLocation::DevServer(dev_server_project) => { Arc::new(vec![PathBuf::from(format!( "{}:{}", dev_server_project.dev_server_name, dev_server_project.path ))]) } }; let (match_labels, paths): (Vec<_>, Vec<_>) = paths .iter() .map(|path| { let path = path.compact(); let highlighted_text = highlights_for_path(path.as_ref(), &hit.positions, path_start_offset); path_start_offset += highlighted_text.1.char_count; highlighted_text }) .unzip(); let highlighted_match = HighlightedMatchWithPaths { match_label: HighlightedText::join(match_labels.into_iter().flatten(), ", ").color( if matches!(dev_server_status, Some(DevServerStatus::Offline)) { Color::Disabled } else { Color::Default }, ), paths, }; Some( ListItem::new(ix) .selected(selected) .inset(true) .spacing(ListItemSpacing::Sparse) .child( h_flex() .flex_grow() .gap_3() .when(self.has_any_dev_server_projects, |this| { this.child(if is_remote { // if disabled, Color::Disabled let indicator_color = match dev_server_status { Some(DevServerStatus::Online) => Color::Created, Some(DevServerStatus::Offline) => Color::Hidden, _ => unreachable!(), }; IconWithIndicator::new( Icon::new(IconName::Server).color(Color::Muted), Some(Indicator::dot()), ) .indicator_color(indicator_color) .indicator_border_color(if selected { Some(cx.theme().colors().element_selected) } else { None }) .into_any_element() } else { Icon::new(IconName::Screen) .color(Color::Muted) .into_any_element() }) }) .child({ let mut highlighted = highlighted_match.clone(); if !self.render_paths { highlighted.paths.clear(); } highlighted.render(cx) }), ) .when(!is_current_workspace, |el| {