recent_projects.rs

  1pub mod disconnected_overlay;
  2mod remote_connections;
  3mod remote_servers;
  4mod ssh_config;
  5
  6#[cfg(target_os = "windows")]
  7mod wsl_picker;
  8
  9use remote::RemoteConnectionOptions;
 10pub use remote_connections::open_remote_project;
 11
 12use disconnected_overlay::DisconnectedOverlay;
 13use fuzzy::{StringMatch, StringMatchCandidate};
 14use gpui::{
 15    Action, AnyElement, App, Context, DismissEvent, Entity, EventEmitter, FocusHandle, Focusable,
 16    Subscription, Task, WeakEntity, Window,
 17};
 18use ordered_float::OrderedFloat;
 19use picker::{
 20    Picker, PickerDelegate,
 21    highlighted_match_with_paths::{HighlightedMatch, HighlightedMatchWithPaths},
 22};
 23pub use remote_connections::SshSettings;
 24pub use remote_servers::RemoteServerProjects;
 25use settings::Settings;
 26use std::{path::Path, sync::Arc};
 27use ui::{KeyBinding, ListItem, ListItemSpacing, Tooltip, prelude::*, tooltip_container};
 28use util::{ResultExt, paths::PathExt};
 29use workspace::{
 30    CloseIntent, HistoryManager, ModalView, OpenOptions, PathList, SerializedWorkspaceLocation,
 31    WORKSPACE_DB, Workspace, WorkspaceId, with_active_or_new_workspace,
 32};
 33use zed_actions::{OpenRecent, OpenRemote};
 34
 35pub fn init(cx: &mut App) {
 36    SshSettings::register(cx);
 37
 38    #[cfg(target_os = "windows")]
 39    cx.on_action(|open_wsl: &zed_actions::wsl_actions::OpenFolderInWsl, cx| {
 40        let create_new_window = open_wsl.create_new_window;
 41        with_active_or_new_workspace(cx, move |workspace, window, cx| {
 42            use gpui::PathPromptOptions;
 43            use project::DirectoryLister;
 44
 45            let paths = workspace.prompt_for_open_path(
 46                PathPromptOptions {
 47                    files: true,
 48                    directories: true,
 49                    multiple: false,
 50                    prompt: None,
 51                },
 52                DirectoryLister::Local(
 53                    workspace.project().clone(),
 54                    workspace.app_state().fs.clone(),
 55                ),
 56                window,
 57                cx,
 58            );
 59
 60            cx.spawn_in(window, async move |workspace, cx| {
 61                use util::paths::SanitizedPath;
 62
 63                let Some(paths) = paths.await.log_err().flatten() else {
 64                    return;
 65                };
 66
 67                let paths = paths
 68                    .into_iter()
 69                    .filter_map(|path| SanitizedPath::new(&path).local_to_wsl())
 70                    .collect::<Vec<_>>();
 71
 72                if paths.is_empty() {
 73                    let message = indoc::indoc! { r#"
 74                        Invalid path specified when trying to open a folder inside WSL.
 75
 76                        Please note that Zed currently does not support opening network share folders inside wsl.
 77                    "#};
 78
 79                    let _ = cx.prompt(gpui::PromptLevel::Critical, "Invalid path", Some(&message), &["Ok"]).await;
 80                    return;
 81                }
 82
 83                workspace.update_in(cx, |workspace, window, cx| {
 84                    workspace.toggle_modal(window, cx, |window, cx| {
 85                        crate::wsl_picker::WslOpenModal::new(paths, create_new_window, window, cx)
 86                    });
 87                }).log_err();
 88            })
 89            .detach();
 90        });
 91    });
 92
 93    #[cfg(target_os = "windows")]
 94    cx.on_action(|open_wsl: &zed_actions::wsl_actions::OpenWsl, cx| {
 95        let create_new_window = open_wsl.create_new_window;
 96        with_active_or_new_workspace(cx, move |workspace, window, cx| {
 97            let handle = cx.entity().downgrade();
 98            let fs = workspace.project().read(cx).fs().clone();
 99            workspace.toggle_modal(window, cx, |window, cx| {
100                RemoteServerProjects::wsl(create_new_window, fs, window, handle, cx)
101            });
102        });
103    });
104
105    cx.on_action(|open_recent: &OpenRecent, cx| {
106        let create_new_window = open_recent.create_new_window;
107        with_active_or_new_workspace(cx, move |workspace, window, cx| {
108            let Some(recent_projects) = workspace.active_modal::<RecentProjects>(cx) else {
109                RecentProjects::open(workspace, create_new_window, window, cx);
110                return;
111            };
112
113            recent_projects.update(cx, |recent_projects, cx| {
114                recent_projects
115                    .picker
116                    .update(cx, |picker, cx| picker.cycle_selection(window, cx))
117            });
118        });
119    });
120    cx.on_action(|open_remote: &OpenRemote, cx| {
121        let from_existing_connection = open_remote.from_existing_connection;
122        let create_new_window = open_remote.create_new_window;
123        with_active_or_new_workspace(cx, move |workspace, window, cx| {
124            if from_existing_connection {
125                cx.propagate();
126                return;
127            }
128            let handle = cx.entity().downgrade();
129            let fs = workspace.project().read(cx).fs().clone();
130            workspace.toggle_modal(window, cx, |window, cx| {
131                RemoteServerProjects::new(create_new_window, fs, window, handle, cx)
132            })
133        });
134    });
135
136    cx.observe_new(DisconnectedOverlay::register).detach();
137}
138
139pub struct RecentProjects {
140    pub picker: Entity<Picker<RecentProjectsDelegate>>,
141    rem_width: f32,
142    _subscription: Subscription,
143}
144
145impl ModalView for RecentProjects {}
146
147impl RecentProjects {
148    fn new(
149        delegate: RecentProjectsDelegate,
150        rem_width: f32,
151        window: &mut Window,
152        cx: &mut Context<Self>,
153    ) -> Self {
154        let picker = cx.new(|cx| {
155            // We want to use a list when we render paths, because the items can have different heights (multiple paths).
156            if delegate.render_paths {
157                Picker::list(delegate, window, cx)
158            } else {
159                Picker::uniform_list(delegate, window, cx)
160            }
161        });
162        let _subscription = cx.subscribe(&picker, |_, _, _, cx| cx.emit(DismissEvent));
163        // We do not want to block the UI on a potentially lengthy call to DB, so we're gonna swap
164        // out workspace locations once the future runs to completion.
165        cx.spawn_in(window, async move |this, cx| {
166            let workspaces = WORKSPACE_DB
167                .recent_workspaces_on_disk()
168                .await
169                .log_err()
170                .unwrap_or_default();
171            this.update_in(cx, move |this, window, cx| {
172                this.picker.update(cx, move |picker, cx| {
173                    picker.delegate.set_workspaces(workspaces);
174                    picker.update_matches(picker.query(cx), window, cx)
175                })
176            })
177            .ok()
178        })
179        .detach();
180        Self {
181            picker,
182            rem_width,
183            _subscription,
184        }
185    }
186
187    pub fn open(
188        workspace: &mut Workspace,
189        create_new_window: bool,
190        window: &mut Window,
191        cx: &mut Context<Workspace>,
192    ) {
193        let weak = cx.entity().downgrade();
194        workspace.toggle_modal(window, cx, |window, cx| {
195            let delegate = RecentProjectsDelegate::new(weak, create_new_window, true);
196
197            Self::new(delegate, 34., window, cx)
198        })
199    }
200}
201
202impl EventEmitter<DismissEvent> for RecentProjects {}
203
204impl Focusable for RecentProjects {
205    fn focus_handle(&self, cx: &App) -> FocusHandle {
206        self.picker.focus_handle(cx)
207    }
208}
209
210impl Render for RecentProjects {
211    fn render(&mut self, _: &mut Window, cx: &mut Context<Self>) -> impl IntoElement {
212        v_flex()
213            .key_context("RecentProjects")
214            .w(rems(self.rem_width))
215            .child(self.picker.clone())
216            .on_mouse_down_out(cx.listener(|this, _, window, cx| {
217                this.picker.update(cx, |this, cx| {
218                    this.cancel(&Default::default(), window, cx);
219                })
220            }))
221    }
222}
223
224pub struct RecentProjectsDelegate {
225    workspace: WeakEntity<Workspace>,
226    workspaces: Vec<(WorkspaceId, SerializedWorkspaceLocation, PathList)>,
227    selected_match_index: usize,
228    matches: Vec<StringMatch>,
229    render_paths: bool,
230    create_new_window: bool,
231    // Flag to reset index when there is a new query vs not reset index when user delete an item
232    reset_selected_match_index: bool,
233    has_any_non_local_projects: bool,
234}
235
236impl RecentProjectsDelegate {
237    fn new(workspace: WeakEntity<Workspace>, create_new_window: bool, render_paths: bool) -> Self {
238        Self {
239            workspace,
240            workspaces: Vec::new(),
241            selected_match_index: 0,
242            matches: Default::default(),
243            create_new_window,
244            render_paths,
245            reset_selected_match_index: true,
246            has_any_non_local_projects: false,
247        }
248    }
249
250    pub fn set_workspaces(
251        &mut self,
252        workspaces: Vec<(WorkspaceId, SerializedWorkspaceLocation, PathList)>,
253    ) {
254        self.workspaces = workspaces;
255        self.has_any_non_local_projects = !self
256            .workspaces
257            .iter()
258            .all(|(_, location, _)| matches!(location, SerializedWorkspaceLocation::Local));
259    }
260}
261impl EventEmitter<DismissEvent> for RecentProjectsDelegate {}
262impl PickerDelegate for RecentProjectsDelegate {
263    type ListItem = ListItem;
264
265    fn placeholder_text(&self, window: &mut Window, _: &mut App) -> Arc<str> {
266        let (create_window, reuse_window) = if self.create_new_window {
267            (
268                window.keystroke_text_for(&menu::Confirm),
269                window.keystroke_text_for(&menu::SecondaryConfirm),
270            )
271        } else {
272            (
273                window.keystroke_text_for(&menu::SecondaryConfirm),
274                window.keystroke_text_for(&menu::Confirm),
275            )
276        };
277        Arc::from(format!(
278            "{reuse_window} reuses this window, {create_window} opens a new one",
279        ))
280    }
281
282    fn match_count(&self) -> usize {
283        self.matches.len()
284    }
285
286    fn selected_index(&self) -> usize {
287        self.selected_match_index
288    }
289
290    fn set_selected_index(
291        &mut self,
292        ix: usize,
293        _window: &mut Window,
294        _cx: &mut Context<Picker<Self>>,
295    ) {
296        self.selected_match_index = ix;
297    }
298
299    fn update_matches(
300        &mut self,
301        query: String,
302        _: &mut Window,
303        cx: &mut Context<Picker<Self>>,
304    ) -> gpui::Task<()> {
305        let query = query.trim_start();
306        let smart_case = query.chars().any(|c| c.is_uppercase());
307        let candidates = self
308            .workspaces
309            .iter()
310            .enumerate()
311            .filter(|(_, (id, _, _))| !self.is_current_workspace(*id, cx))
312            .map(|(id, (_, _, paths))| {
313                let combined_string = paths
314                    .paths()
315                    .iter()
316                    .map(|path| path.compact().to_string_lossy().into_owned())
317                    .collect::<Vec<_>>()
318                    .join("");
319                StringMatchCandidate::new(id, &combined_string)
320            })
321            .collect::<Vec<_>>();
322        self.matches = smol::block_on(fuzzy::match_strings(
323            candidates.as_slice(),
324            query,
325            smart_case,
326            true,
327            100,
328            &Default::default(),
329            cx.background_executor().clone(),
330        ));
331        self.matches.sort_unstable_by_key(|m| m.candidate_id);
332
333        if self.reset_selected_match_index {
334            self.selected_match_index = self
335                .matches
336                .iter()
337                .enumerate()
338                .rev()
339                .max_by_key(|(_, m)| OrderedFloat(m.score))
340                .map(|(ix, _)| ix)
341                .unwrap_or(0);
342        }
343        self.reset_selected_match_index = true;
344        Task::ready(())
345    }
346
347    fn confirm(&mut self, secondary: bool, window: &mut Window, cx: &mut Context<Picker<Self>>) {
348        if let Some((selected_match, workspace)) = self
349            .matches
350            .get(self.selected_index())
351            .zip(self.workspace.upgrade())
352        {
353            let (candidate_workspace_id, candidate_workspace_location, candidate_workspace_paths) =
354                &self.workspaces[selected_match.candidate_id];
355            let replace_current_window = if self.create_new_window {
356                secondary
357            } else {
358                !secondary
359            };
360            workspace
361                .update(cx, |workspace, cx| {
362                    if workspace.database_id() == Some(*candidate_workspace_id) {
363                        Task::ready(Ok(()))
364                    } else {
365                        match candidate_workspace_location.clone() {
366                            SerializedWorkspaceLocation::Local => {
367                                let paths = candidate_workspace_paths.paths().to_vec();
368                                if replace_current_window {
369                                    cx.spawn_in(window, async move |workspace, cx| {
370                                        let continue_replacing = workspace
371                                            .update_in(cx, |workspace, window, cx| {
372                                                workspace.prepare_to_close(
373                                                    CloseIntent::ReplaceWindow,
374                                                    window,
375                                                    cx,
376                                                )
377                                            })?
378                                            .await?;
379                                        if continue_replacing {
380                                            workspace
381                                                .update_in(cx, |workspace, window, cx| {
382                                                    workspace.open_workspace_for_paths(
383                                                        true, paths, window, cx,
384                                                    )
385                                                })?
386                                                .await
387                                        } else {
388                                            Ok(())
389                                        }
390                                    })
391                                } else {
392                                    workspace.open_workspace_for_paths(false, paths, window, cx)
393                                }
394                            }
395                            SerializedWorkspaceLocation::Remote(mut connection) => {
396                                let app_state = workspace.app_state().clone();
397
398                                let replace_window = if replace_current_window {
399                                    window.window_handle().downcast::<Workspace>()
400                                } else {
401                                    None
402                                };
403
404                                let open_options = OpenOptions {
405                                    replace_window,
406                                    ..Default::default()
407                                };
408
409                                if let RemoteConnectionOptions::Ssh(connection) = &mut connection {
410                                    SshSettings::get_global(cx)
411                                        .fill_connection_options_from_settings(connection);
412                                };
413
414                                let paths = candidate_workspace_paths.paths().to_vec();
415
416                                cx.spawn_in(window, async move |_, cx| {
417                                    open_remote_project(
418                                        connection.clone(),
419                                        paths,
420                                        app_state,
421                                        open_options,
422                                        cx,
423                                    )
424                                    .await
425                                })
426                            }
427                        }
428                    }
429                })
430                .detach_and_log_err(cx);
431            cx.emit(DismissEvent);
432        }
433    }
434
435    fn dismissed(&mut self, _window: &mut Window, _: &mut Context<Picker<Self>>) {}
436
437    fn no_matches_text(&self, _window: &mut Window, _cx: &mut App) -> Option<SharedString> {
438        let text = if self.workspaces.is_empty() {
439            "Recently opened projects will show up here".into()
440        } else {
441            "No matches".into()
442        };
443        Some(text)
444    }
445
446    fn render_match(
447        &self,
448        ix: usize,
449        selected: bool,
450        window: &mut Window,
451        cx: &mut Context<Picker<Self>>,
452    ) -> Option<Self::ListItem> {
453        let hit = self.matches.get(ix)?;
454
455        let (_, location, paths) = self.workspaces.get(hit.candidate_id)?;
456
457        let mut path_start_offset = 0;
458
459        let (match_labels, paths): (Vec<_>, Vec<_>) = paths
460            .paths()
461            .iter()
462            .map(|p| p.compact())
463            .map(|path| {
464                let highlighted_text =
465                    highlights_for_path(path.as_ref(), &hit.positions, path_start_offset);
466
467                path_start_offset += highlighted_text.1.char_count;
468                highlighted_text
469            })
470            .unzip();
471
472        let highlighted_match = HighlightedMatchWithPaths {
473            match_label: HighlightedMatch::join(match_labels.into_iter().flatten(), ", "),
474            paths,
475        };
476
477        Some(
478            ListItem::new(ix)
479                .toggle_state(selected)
480                .inset(true)
481                .spacing(ListItemSpacing::Sparse)
482                .child(
483                    h_flex()
484                        .flex_grow()
485                        .gap_3()
486                        .when(self.has_any_non_local_projects, |this| {
487                            this.child(match location {
488                                SerializedWorkspaceLocation::Local => Icon::new(IconName::Screen)
489                                    .color(Color::Muted)
490                                    .into_any_element(),
491                                SerializedWorkspaceLocation::Remote(options) => {
492                                    Icon::new(match options {
493                                        RemoteConnectionOptions::Ssh { .. } => IconName::Server,
494                                        RemoteConnectionOptions::Wsl { .. } => IconName::Linux,
495                                    })
496                                    .color(Color::Muted)
497                                    .into_any_element()
498                                }
499                            })
500                        })
501                        .child({
502                            let mut highlighted = highlighted_match.clone();
503                            if !self.render_paths {
504                                highlighted.paths.clear();
505                            }
506                            highlighted.render(window, cx)
507                        }),
508                )
509                .map(|el| {
510                    let delete_button = div()
511                        .child(
512                            IconButton::new("delete", IconName::Close)
513                                .icon_size(IconSize::Small)
514                                .on_click(cx.listener(move |this, _event, window, cx| {
515                                    cx.stop_propagation();
516                                    window.prevent_default();
517
518                                    this.delegate.delete_recent_project(ix, window, cx)
519                                }))
520                                .tooltip(Tooltip::text("Delete from Recent Projects...")),
521                        )
522                        .into_any_element();
523
524                    if self.selected_index() == ix {
525                        el.end_slot::<AnyElement>(delete_button)
526                    } else {
527                        el.end_hover_slot::<AnyElement>(delete_button)
528                    }
529                })
530                .tooltip(move |_, cx| {
531                    let tooltip_highlighted_location = highlighted_match.clone();
532                    cx.new(|_| MatchTooltip {
533                        highlighted_location: tooltip_highlighted_location,
534                    })
535                    .into()
536                }),
537        )
538    }
539
540    fn render_footer(
541        &self,
542        window: &mut Window,
543        cx: &mut Context<Picker<Self>>,
544    ) -> Option<AnyElement> {
545        Some(
546            h_flex()
547                .w_full()
548                .p_2()
549                .gap_2()
550                .justify_end()
551                .border_t_1()
552                .border_color(cx.theme().colors().border_variant)
553                .child(
554                    Button::new("remote", "Open Remote Folder")
555                        .key_binding(KeyBinding::for_action(
556                            &OpenRemote {
557                                from_existing_connection: false,
558                                create_new_window: false,
559                            },
560                            window,
561                            cx,
562                        ))
563                        .on_click(|_, window, cx| {
564                            window.dispatch_action(
565                                OpenRemote {
566                                    from_existing_connection: false,
567                                    create_new_window: false,
568                                }
569                                .boxed_clone(),
570                                cx,
571                            )
572                        }),
573                )
574                .child(
575                    Button::new("local", "Open Local Folder")
576                        .key_binding(KeyBinding::for_action(&workspace::Open, window, cx))
577                        .on_click(|_, window, cx| {
578                            window.dispatch_action(workspace::Open.boxed_clone(), cx)
579                        }),
580                )
581                .into_any(),
582        )
583    }
584}
585
586// Compute the highlighted text for the name and path
587fn highlights_for_path(
588    path: &Path,
589    match_positions: &Vec<usize>,
590    path_start_offset: usize,
591) -> (Option<HighlightedMatch>, HighlightedMatch) {
592    let path_string = path.to_string_lossy();
593    let path_char_count = path_string.chars().count();
594    // Get the subset of match highlight positions that line up with the given path.
595    // Also adjusts them to start at the path start
596    let path_positions = match_positions
597        .iter()
598        .copied()
599        .skip_while(|position| *position < path_start_offset)
600        .take_while(|position| *position < path_start_offset + path_char_count)
601        .map(|position| position - path_start_offset)
602        .collect::<Vec<_>>();
603
604    // Again subset the highlight positions to just those that line up with the file_name
605    // again adjusted to the start of the file_name
606    let file_name_text_and_positions = path.file_name().map(|file_name| {
607        let text = file_name.to_string_lossy();
608        let char_count = text.chars().count();
609        let file_name_start = path_char_count - char_count;
610        let highlight_positions = path_positions
611            .iter()
612            .copied()
613            .skip_while(|position| *position < file_name_start)
614            .take_while(|position| *position < file_name_start + char_count)
615            .map(|position| position - file_name_start)
616            .collect::<Vec<_>>();
617        HighlightedMatch {
618            text: text.to_string(),
619            highlight_positions,
620            char_count,
621            color: Color::Default,
622        }
623    });
624
625    (
626        file_name_text_and_positions,
627        HighlightedMatch {
628            text: path_string.to_string(),
629            highlight_positions: path_positions,
630            char_count: path_char_count,
631            color: Color::Default,
632        },
633    )
634}
635impl RecentProjectsDelegate {
636    fn delete_recent_project(
637        &self,
638        ix: usize,
639        window: &mut Window,
640        cx: &mut Context<Picker<Self>>,
641    ) {
642        if let Some(selected_match) = self.matches.get(ix) {
643            let (workspace_id, _, _) = self.workspaces[selected_match.candidate_id];
644            cx.spawn_in(window, async move |this, cx| {
645                let _ = WORKSPACE_DB.delete_workspace_by_id(workspace_id).await;
646                let workspaces = WORKSPACE_DB
647                    .recent_workspaces_on_disk()
648                    .await
649                    .unwrap_or_default();
650                this.update_in(cx, move |picker, window, cx| {
651                    picker.delegate.set_workspaces(workspaces);
652                    picker
653                        .delegate
654                        .set_selected_index(ix.saturating_sub(1), window, cx);
655                    picker.delegate.reset_selected_match_index = false;
656                    picker.update_matches(picker.query(cx), window, cx);
657                    // After deleting a project, we want to update the history manager to reflect the change.
658                    // But we do not emit a update event when user opens a project, because it's handled in `workspace::load_workspace`.
659                    if let Some(history_manager) = HistoryManager::global(cx) {
660                        history_manager
661                            .update(cx, |this, cx| this.delete_history(workspace_id, cx));
662                    }
663                })
664            })
665            .detach();
666        }
667    }
668
669    fn is_current_workspace(
670        &self,
671        workspace_id: WorkspaceId,
672        cx: &mut Context<Picker<Self>>,
673    ) -> bool {
674        if let Some(workspace) = self.workspace.upgrade() {
675            let workspace = workspace.read(cx);
676            if Some(workspace_id) == workspace.database_id() {
677                return true;
678            }
679        }
680
681        false
682    }
683}
684struct MatchTooltip {
685    highlighted_location: HighlightedMatchWithPaths,
686}
687
688impl Render for MatchTooltip {
689    fn render(&mut self, window: &mut Window, cx: &mut Context<Self>) -> impl IntoElement {
690        tooltip_container(window, cx, |div, _, _| {
691            self.highlighted_location.render_paths_children(div)
692        })
693    }
694}
695
696#[cfg(test)]
697mod tests {
698    use std::path::PathBuf;
699
700    use dap::debugger_settings::DebuggerSettings;
701    use editor::Editor;
702    use gpui::{TestAppContext, UpdateGlobal, WindowHandle};
703    use project::Project;
704    use serde_json::json;
705    use settings::SettingsStore;
706    use util::path;
707    use workspace::{AppState, open_paths};
708
709    use super::*;
710
711    #[gpui::test]
712    async fn test_prompts_on_dirty_before_submit(cx: &mut TestAppContext) {
713        let app_state = init_test(cx);
714
715        cx.update(|cx| {
716            SettingsStore::update_global(cx, |store, cx| {
717                store.update_user_settings(cx, |settings| {
718                    settings
719                        .session
720                        .get_or_insert_default()
721                        .restore_unsaved_buffers = Some(false)
722                });
723            });
724        });
725
726        app_state
727            .fs
728            .as_fake()
729            .insert_tree(
730                path!("/dir"),
731                json!({
732                    "main.ts": "a"
733                }),
734            )
735            .await;
736        cx.update(|cx| {
737            open_paths(
738                &[PathBuf::from(path!("/dir/main.ts"))],
739                app_state,
740                workspace::OpenOptions::default(),
741                cx,
742            )
743        })
744        .await
745        .unwrap();
746        assert_eq!(cx.update(|cx| cx.windows().len()), 1);
747
748        let workspace = cx.update(|cx| cx.windows()[0].downcast::<Workspace>().unwrap());
749        workspace
750            .update(cx, |workspace, _, _| assert!(!workspace.is_edited()))
751            .unwrap();
752
753        let editor = workspace
754            .read_with(cx, |workspace, cx| {
755                workspace
756                    .active_item(cx)
757                    .unwrap()
758                    .downcast::<Editor>()
759                    .unwrap()
760            })
761            .unwrap();
762        workspace
763            .update(cx, |_, window, cx| {
764                editor.update(cx, |editor, cx| editor.insert("EDIT", window, cx));
765            })
766            .unwrap();
767        workspace
768            .update(cx, |workspace, _, _| assert!(workspace.is_edited(), "After inserting more text into the editor without saving, we should have a dirty project"))
769            .unwrap();
770
771        let recent_projects_picker = open_recent_projects(&workspace, cx);
772        workspace
773            .update(cx, |_, _, cx| {
774                recent_projects_picker.update(cx, |picker, cx| {
775                    assert_eq!(picker.query(cx), "");
776                    let delegate = &mut picker.delegate;
777                    delegate.matches = vec![StringMatch {
778                        candidate_id: 0,
779                        score: 1.0,
780                        positions: Vec::new(),
781                        string: "fake candidate".to_string(),
782                    }];
783                    delegate.set_workspaces(vec![(
784                        WorkspaceId::default(),
785                        SerializedWorkspaceLocation::Local,
786                        PathList::new(&[path!("/test/path")]),
787                    )]);
788                });
789            })
790            .unwrap();
791
792        assert!(
793            !cx.has_pending_prompt(),
794            "Should have no pending prompt on dirty project before opening the new recent project"
795        );
796        cx.dispatch_action(*workspace, menu::Confirm);
797        workspace
798            .update(cx, |workspace, _, cx| {
799                assert!(
800                    workspace.active_modal::<RecentProjects>(cx).is_none(),
801                    "Should remove the modal after selecting new recent project"
802                )
803            })
804            .unwrap();
805        assert!(
806            cx.has_pending_prompt(),
807            "Dirty workspace should prompt before opening the new recent project"
808        );
809        cx.simulate_prompt_answer("Cancel");
810        assert!(
811            !cx.has_pending_prompt(),
812            "Should have no pending prompt after cancelling"
813        );
814        workspace
815            .update(cx, |workspace, _, _| {
816                assert!(
817                    workspace.is_edited(),
818                    "Should be in the same dirty project after cancelling"
819                )
820            })
821            .unwrap();
822    }
823
824    fn open_recent_projects(
825        workspace: &WindowHandle<Workspace>,
826        cx: &mut TestAppContext,
827    ) -> Entity<Picker<RecentProjectsDelegate>> {
828        cx.dispatch_action(
829            (*workspace).into(),
830            OpenRecent {
831                create_new_window: false,
832            },
833        );
834        workspace
835            .update(cx, |workspace, _, cx| {
836                workspace
837                    .active_modal::<RecentProjects>(cx)
838                    .unwrap()
839                    .read(cx)
840                    .picker
841                    .clone()
842            })
843            .unwrap()
844    }
845
846    fn init_test(cx: &mut TestAppContext) -> Arc<AppState> {
847        cx.update(|cx| {
848            let state = AppState::test(cx);
849            language::init(cx);
850            crate::init(cx);
851            editor::init(cx);
852            workspace::init_settings(cx);
853            DebuggerSettings::register(cx);
854            Project::init_settings(cx);
855            state
856        })
857    }
858}