1use crate::{
2 BufferSearchBar, FocusSearch, NextHistoryQuery, PreviousHistoryQuery, ReplaceAll, ReplaceNext,
3 SearchOption, SearchOptions, SelectNextMatch, SelectPreviousMatch, ToggleCaseSensitive,
4 ToggleIncludeIgnored, ToggleRegex, ToggleReplace, ToggleWholeWord,
5 buffer_search::Deploy,
6 search_bar::{input_base_styles, render_action_button, render_text_input},
7};
8use anyhow::Context as _;
9use collections::HashMap;
10use editor::{
11 Anchor, Editor, EditorEvent, EditorSettings, MAX_TAB_TITLE_LEN, MultiBuffer, SelectionEffects,
12 actions::{Backtab, SelectAll, Tab},
13 items::active_match_index,
14};
15use futures::{StreamExt, stream::FuturesOrdered};
16use gpui::{
17 Action, AnyElement, AnyView, App, Axis, Context, Entity, EntityId, EventEmitter, FocusHandle,
18 Focusable, Global, Hsla, InteractiveElement, IntoElement, KeyContext, ParentElement, Point,
19 Render, SharedString, Styled, Subscription, Task, UpdateGlobal, WeakEntity, Window, actions,
20 div,
21};
22use language::{Buffer, Language};
23use menu::Confirm;
24use project::{
25 Project, ProjectPath,
26 search::{SearchInputKind, SearchQuery},
27 search_history::SearchHistoryCursor,
28};
29use settings::Settings;
30use std::{
31 any::{Any, TypeId},
32 mem,
33 ops::{Not, Range},
34 path::Path,
35 pin::pin,
36 sync::Arc,
37};
38use ui::{
39 Icon, IconButton, IconButtonShape, IconName, KeyBinding, Label, LabelCommon, LabelSize,
40 Toggleable, Tooltip, h_flex, prelude::*, utils::SearchInputWidth, v_flex,
41};
42use util::{ResultExt as _, paths::PathMatcher};
43use workspace::{
44 DeploySearch, ItemNavHistory, NewSearch, ToolbarItemEvent, ToolbarItemLocation,
45 ToolbarItemView, Workspace, WorkspaceId,
46 item::{BreadcrumbText, Item, ItemEvent, ItemHandle, SaveOptions},
47 searchable::{Direction, SearchableItem, SearchableItemHandle},
48};
49
50actions!(
51 project_search,
52 [
53 /// Searches in a new project search tab.
54 SearchInNew,
55 /// Toggles focus between the search bar and the search results.
56 ToggleFocus,
57 /// Moves to the next input field.
58 NextField,
59 /// Toggles the search filters panel.
60 ToggleFilters
61 ]
62);
63
64#[derive(Default)]
65struct ActiveSettings(HashMap<WeakEntity<Project>, ProjectSearchSettings>);
66
67impl Global for ActiveSettings {}
68
69pub fn init(cx: &mut App) {
70 cx.set_global(ActiveSettings::default());
71 cx.observe_new(|workspace: &mut Workspace, _window, _cx| {
72 register_workspace_action(workspace, move |search_bar, _: &Deploy, window, cx| {
73 search_bar.focus_search(window, cx);
74 });
75 register_workspace_action(workspace, move |search_bar, _: &FocusSearch, window, cx| {
76 search_bar.focus_search(window, cx);
77 });
78 register_workspace_action(
79 workspace,
80 move |search_bar, _: &ToggleFilters, window, cx| {
81 search_bar.toggle_filters(window, cx);
82 },
83 );
84 register_workspace_action(
85 workspace,
86 move |search_bar, _: &ToggleCaseSensitive, window, cx| {
87 search_bar.toggle_search_option(SearchOptions::CASE_SENSITIVE, window, cx);
88 },
89 );
90 register_workspace_action(
91 workspace,
92 move |search_bar, _: &ToggleWholeWord, window, cx| {
93 search_bar.toggle_search_option(SearchOptions::WHOLE_WORD, window, cx);
94 },
95 );
96 register_workspace_action(workspace, move |search_bar, _: &ToggleRegex, window, cx| {
97 search_bar.toggle_search_option(SearchOptions::REGEX, window, cx);
98 });
99 register_workspace_action(
100 workspace,
101 move |search_bar, action: &ToggleReplace, window, cx| {
102 search_bar.toggle_replace(action, window, cx)
103 },
104 );
105 register_workspace_action(
106 workspace,
107 move |search_bar, action: &SelectPreviousMatch, window, cx| {
108 search_bar.select_prev_match(action, window, cx)
109 },
110 );
111 register_workspace_action(
112 workspace,
113 move |search_bar, action: &SelectNextMatch, window, cx| {
114 search_bar.select_next_match(action, window, cx)
115 },
116 );
117
118 // Only handle search_in_new if there is a search present
119 register_workspace_action_for_present_search(workspace, |workspace, action, window, cx| {
120 ProjectSearchView::search_in_new(workspace, action, window, cx)
121 });
122
123 register_workspace_action_for_present_search(
124 workspace,
125 |workspace, _: &menu::Cancel, window, cx| {
126 if let Some(project_search_bar) = workspace
127 .active_pane()
128 .read(cx)
129 .toolbar()
130 .read(cx)
131 .item_of_type::<ProjectSearchBar>()
132 {
133 project_search_bar.update(cx, |project_search_bar, cx| {
134 let search_is_focused = project_search_bar
135 .active_project_search
136 .as_ref()
137 .is_some_and(|search_view| {
138 search_view
139 .read(cx)
140 .query_editor
141 .read(cx)
142 .focus_handle(cx)
143 .is_focused(window)
144 });
145 if search_is_focused {
146 project_search_bar.move_focus_to_results(window, cx);
147 } else {
148 project_search_bar.focus_search(window, cx)
149 }
150 });
151 } else {
152 cx.propagate();
153 }
154 },
155 );
156
157 // Both on present and dismissed search, we need to unconditionally handle those actions to focus from the editor.
158 workspace.register_action(move |workspace, action: &DeploySearch, window, cx| {
159 if workspace.has_active_modal(window, cx) {
160 cx.propagate();
161 return;
162 }
163 ProjectSearchView::deploy_search(workspace, action, window, cx);
164 cx.notify();
165 });
166 workspace.register_action(move |workspace, action: &NewSearch, window, cx| {
167 if workspace.has_active_modal(window, cx) {
168 cx.propagate();
169 return;
170 }
171 ProjectSearchView::new_search(workspace, action, window, cx);
172 cx.notify();
173 });
174 })
175 .detach();
176}
177
178fn contains_uppercase(str: &str) -> bool {
179 str.chars().any(|c| c.is_uppercase())
180}
181
182pub struct ProjectSearch {
183 project: Entity<Project>,
184 excerpts: Entity<MultiBuffer>,
185 pending_search: Option<Task<Option<()>>>,
186 match_ranges: Vec<Range<Anchor>>,
187 active_query: Option<SearchQuery>,
188 last_search_query_text: Option<String>,
189 search_id: usize,
190 no_results: Option<bool>,
191 limit_reached: bool,
192 search_history_cursor: SearchHistoryCursor,
193 search_included_history_cursor: SearchHistoryCursor,
194 search_excluded_history_cursor: SearchHistoryCursor,
195}
196
197#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
198enum InputPanel {
199 Query,
200 Replacement,
201 Exclude,
202 Include,
203}
204
205pub struct ProjectSearchView {
206 workspace: WeakEntity<Workspace>,
207 focus_handle: FocusHandle,
208 entity: Entity<ProjectSearch>,
209 query_editor: Entity<Editor>,
210 replacement_editor: Entity<Editor>,
211 results_editor: Entity<Editor>,
212 search_options: SearchOptions,
213 panels_with_errors: HashMap<InputPanel, String>,
214 active_match_index: Option<usize>,
215 search_id: usize,
216 included_files_editor: Entity<Editor>,
217 excluded_files_editor: Entity<Editor>,
218 filters_enabled: bool,
219 replace_enabled: bool,
220 included_opened_only: bool,
221 regex_language: Option<Arc<Language>>,
222 _subscriptions: Vec<Subscription>,
223}
224
225#[derive(Debug, Clone)]
226pub struct ProjectSearchSettings {
227 search_options: SearchOptions,
228 filters_enabled: bool,
229}
230
231pub struct ProjectSearchBar {
232 active_project_search: Option<Entity<ProjectSearchView>>,
233 subscription: Option<Subscription>,
234}
235
236impl ProjectSearch {
237 pub fn new(project: Entity<Project>, cx: &mut Context<Self>) -> Self {
238 let capability = project.read(cx).capability();
239
240 Self {
241 project,
242 excerpts: cx.new(|_| MultiBuffer::new(capability)),
243 pending_search: Default::default(),
244 match_ranges: Default::default(),
245 active_query: None,
246 last_search_query_text: None,
247 search_id: 0,
248 no_results: None,
249 limit_reached: false,
250 search_history_cursor: Default::default(),
251 search_included_history_cursor: Default::default(),
252 search_excluded_history_cursor: Default::default(),
253 }
254 }
255
256 fn clone(&self, cx: &mut Context<Self>) -> Entity<Self> {
257 cx.new(|cx| Self {
258 project: self.project.clone(),
259 excerpts: self
260 .excerpts
261 .update(cx, |excerpts, cx| cx.new(|cx| excerpts.clone(cx))),
262 pending_search: Default::default(),
263 match_ranges: self.match_ranges.clone(),
264 active_query: self.active_query.clone(),
265 last_search_query_text: self.last_search_query_text.clone(),
266 search_id: self.search_id,
267 no_results: self.no_results,
268 limit_reached: self.limit_reached,
269 search_history_cursor: self.search_history_cursor.clone(),
270 search_included_history_cursor: self.search_included_history_cursor.clone(),
271 search_excluded_history_cursor: self.search_excluded_history_cursor.clone(),
272 })
273 }
274 fn cursor(&self, kind: SearchInputKind) -> &SearchHistoryCursor {
275 match kind {
276 SearchInputKind::Query => &self.search_history_cursor,
277 SearchInputKind::Include => &self.search_included_history_cursor,
278 SearchInputKind::Exclude => &self.search_excluded_history_cursor,
279 }
280 }
281 fn cursor_mut(&mut self, kind: SearchInputKind) -> &mut SearchHistoryCursor {
282 match kind {
283 SearchInputKind::Query => &mut self.search_history_cursor,
284 SearchInputKind::Include => &mut self.search_included_history_cursor,
285 SearchInputKind::Exclude => &mut self.search_excluded_history_cursor,
286 }
287 }
288
289 fn search(&mut self, query: SearchQuery, cx: &mut Context<Self>) {
290 let search = self.project.update(cx, |project, cx| {
291 project
292 .search_history_mut(SearchInputKind::Query)
293 .add(&mut self.search_history_cursor, query.as_str().to_string());
294 let included = query.as_inner().files_to_include().sources().join(",");
295 if !included.is_empty() {
296 project
297 .search_history_mut(SearchInputKind::Include)
298 .add(&mut self.search_included_history_cursor, included);
299 }
300 let excluded = query.as_inner().files_to_exclude().sources().join(",");
301 if !excluded.is_empty() {
302 project
303 .search_history_mut(SearchInputKind::Exclude)
304 .add(&mut self.search_excluded_history_cursor, excluded);
305 }
306 project.search(query.clone(), cx)
307 });
308 self.last_search_query_text = Some(query.as_str().to_string());
309 self.search_id += 1;
310 self.active_query = Some(query);
311 self.match_ranges.clear();
312 self.pending_search = Some(cx.spawn(async move |project_search, cx| {
313 let mut matches = pin!(search.ready_chunks(1024));
314 project_search
315 .update(cx, |project_search, cx| {
316 project_search.match_ranges.clear();
317 project_search
318 .excerpts
319 .update(cx, |excerpts, cx| excerpts.clear(cx));
320 project_search.no_results = Some(true);
321 project_search.limit_reached = false;
322 })
323 .ok()?;
324
325 let mut limit_reached = false;
326 while let Some(results) = matches.next().await {
327 let mut buffers_with_ranges = Vec::with_capacity(results.len());
328 for result in results {
329 match result {
330 project::search::SearchResult::Buffer { buffer, ranges } => {
331 buffers_with_ranges.push((buffer, ranges));
332 }
333 project::search::SearchResult::LimitReached => {
334 limit_reached = true;
335 }
336 }
337 }
338
339 let mut new_ranges = project_search
340 .update(cx, |project_search, cx| {
341 project_search.excerpts.update(cx, |excerpts, cx| {
342 buffers_with_ranges
343 .into_iter()
344 .map(|(buffer, ranges)| {
345 excerpts.set_anchored_excerpts_for_path(
346 buffer,
347 ranges,
348 editor::DEFAULT_MULTIBUFFER_CONTEXT,
349 cx,
350 )
351 })
352 .collect::<FuturesOrdered<_>>()
353 })
354 })
355 .ok()?;
356
357 while let Some(new_ranges) = new_ranges.next().await {
358 project_search
359 .update(cx, |project_search, cx| {
360 project_search.match_ranges.extend(new_ranges);
361 cx.notify();
362 })
363 .ok()?;
364 }
365 }
366
367 project_search
368 .update(cx, |project_search, cx| {
369 if !project_search.match_ranges.is_empty() {
370 project_search.no_results = Some(false);
371 }
372 project_search.limit_reached = limit_reached;
373 project_search.pending_search.take();
374 cx.notify();
375 })
376 .ok()?;
377
378 None
379 }));
380 cx.notify();
381 }
382}
383
384#[derive(Clone, Debug, PartialEq, Eq)]
385pub enum ViewEvent {
386 UpdateTab,
387 Activate,
388 EditorEvent(editor::EditorEvent),
389 Dismiss,
390}
391
392impl EventEmitter<ViewEvent> for ProjectSearchView {}
393
394impl Render for ProjectSearchView {
395 fn render(&mut self, window: &mut Window, cx: &mut Context<Self>) -> impl IntoElement {
396 if self.has_matches() {
397 div()
398 .flex_1()
399 .size_full()
400 .track_focus(&self.focus_handle(cx))
401 .child(self.results_editor.clone())
402 } else {
403 let model = self.entity.read(cx);
404 let has_no_results = model.no_results.unwrap_or(false);
405 let is_search_underway = model.pending_search.is_some();
406
407 let heading_text = if is_search_underway {
408 "Searching…"
409 } else if has_no_results {
410 "No Results"
411 } else {
412 "Search All Files"
413 };
414
415 let heading_text = div()
416 .justify_center()
417 .child(Label::new(heading_text).size(LabelSize::Large));
418
419 let page_content: Option<AnyElement> = if let Some(no_results) = model.no_results {
420 if model.pending_search.is_none() && no_results {
421 Some(
422 Label::new("No results found in this project for the provided query")
423 .size(LabelSize::Small)
424 .into_any_element(),
425 )
426 } else {
427 None
428 }
429 } else {
430 Some(self.landing_text_minor(window, cx).into_any_element())
431 };
432
433 let page_content = page_content.map(|text| div().child(text));
434
435 h_flex()
436 .size_full()
437 .items_center()
438 .justify_center()
439 .overflow_hidden()
440 .bg(cx.theme().colors().editor_background)
441 .track_focus(&self.focus_handle(cx))
442 .child(
443 v_flex()
444 .id("project-search-landing-page")
445 .overflow_y_scroll()
446 .gap_1()
447 .child(heading_text)
448 .children(page_content),
449 )
450 }
451 }
452}
453
454impl Focusable for ProjectSearchView {
455 fn focus_handle(&self, _: &App) -> gpui::FocusHandle {
456 self.focus_handle.clone()
457 }
458}
459
460impl Item for ProjectSearchView {
461 type Event = ViewEvent;
462 fn tab_tooltip_text(&self, cx: &App) -> Option<SharedString> {
463 let query_text = self.query_editor.read(cx).text(cx);
464
465 query_text
466 .is_empty()
467 .not()
468 .then(|| query_text.into())
469 .or_else(|| Some("Project Search".into()))
470 }
471
472 fn act_as_type<'a>(
473 &'a self,
474 type_id: TypeId,
475 self_handle: &'a Entity<Self>,
476 _: &'a App,
477 ) -> Option<AnyView> {
478 if type_id == TypeId::of::<Self>() {
479 Some(self_handle.clone().into())
480 } else if type_id == TypeId::of::<Editor>() {
481 Some(self.results_editor.clone().into())
482 } else {
483 None
484 }
485 }
486 fn as_searchable(&self, _: &Entity<Self>) -> Option<Box<dyn SearchableItemHandle>> {
487 Some(Box::new(self.results_editor.clone()))
488 }
489
490 fn deactivated(&mut self, window: &mut Window, cx: &mut Context<Self>) {
491 self.results_editor
492 .update(cx, |editor, cx| editor.deactivated(window, cx));
493 }
494
495 fn tab_icon(&self, _window: &Window, _cx: &App) -> Option<Icon> {
496 Some(Icon::new(IconName::MagnifyingGlass))
497 }
498
499 fn tab_content_text(&self, _detail: usize, cx: &App) -> SharedString {
500 let last_query: Option<SharedString> = self
501 .entity
502 .read(cx)
503 .last_search_query_text
504 .as_ref()
505 .map(|query| {
506 let query = query.replace('\n', "");
507 let query_text = util::truncate_and_trailoff(&query, MAX_TAB_TITLE_LEN);
508 query_text.into()
509 });
510
511 last_query
512 .filter(|query| !query.is_empty())
513 .unwrap_or_else(|| "Project Search".into())
514 }
515
516 fn telemetry_event_text(&self) -> Option<&'static str> {
517 Some("Project Search Opened")
518 }
519
520 fn for_each_project_item(
521 &self,
522 cx: &App,
523 f: &mut dyn FnMut(EntityId, &dyn project::ProjectItem),
524 ) {
525 self.results_editor.for_each_project_item(cx, f)
526 }
527
528 fn is_singleton(&self, _: &App) -> bool {
529 false
530 }
531
532 fn can_save(&self, _: &App) -> bool {
533 true
534 }
535
536 fn is_dirty(&self, cx: &App) -> bool {
537 self.results_editor.read(cx).is_dirty(cx)
538 }
539
540 fn has_conflict(&self, cx: &App) -> bool {
541 self.results_editor.read(cx).has_conflict(cx)
542 }
543
544 fn save(
545 &mut self,
546 options: SaveOptions,
547 project: Entity<Project>,
548 window: &mut Window,
549 cx: &mut Context<Self>,
550 ) -> Task<anyhow::Result<()>> {
551 self.results_editor
552 .update(cx, |editor, cx| editor.save(options, project, window, cx))
553 }
554
555 fn save_as(
556 &mut self,
557 _: Entity<Project>,
558 _: ProjectPath,
559 _window: &mut Window,
560 _: &mut Context<Self>,
561 ) -> Task<anyhow::Result<()>> {
562 unreachable!("save_as should not have been called")
563 }
564
565 fn reload(
566 &mut self,
567 project: Entity<Project>,
568 window: &mut Window,
569 cx: &mut Context<Self>,
570 ) -> Task<anyhow::Result<()>> {
571 self.results_editor
572 .update(cx, |editor, cx| editor.reload(project, window, cx))
573 }
574
575 fn clone_on_split(
576 &self,
577 _workspace_id: Option<WorkspaceId>,
578 window: &mut Window,
579 cx: &mut Context<Self>,
580 ) -> Option<Entity<Self>>
581 where
582 Self: Sized,
583 {
584 let model = self.entity.update(cx, |model, cx| model.clone(cx));
585 Some(cx.new(|cx| Self::new(self.workspace.clone(), model, window, cx, None)))
586 }
587
588 fn added_to_workspace(
589 &mut self,
590 workspace: &mut Workspace,
591 window: &mut Window,
592 cx: &mut Context<Self>,
593 ) {
594 self.results_editor.update(cx, |editor, cx| {
595 editor.added_to_workspace(workspace, window, cx)
596 });
597 }
598
599 fn set_nav_history(
600 &mut self,
601 nav_history: ItemNavHistory,
602 _: &mut Window,
603 cx: &mut Context<Self>,
604 ) {
605 self.results_editor.update(cx, |editor, _| {
606 editor.set_nav_history(Some(nav_history));
607 });
608 }
609
610 fn navigate(
611 &mut self,
612 data: Box<dyn Any>,
613 window: &mut Window,
614 cx: &mut Context<Self>,
615 ) -> bool {
616 self.results_editor
617 .update(cx, |editor, cx| editor.navigate(data, window, cx))
618 }
619
620 fn to_item_events(event: &Self::Event, mut f: impl FnMut(ItemEvent)) {
621 match event {
622 ViewEvent::UpdateTab => {
623 f(ItemEvent::UpdateBreadcrumbs);
624 f(ItemEvent::UpdateTab);
625 }
626 ViewEvent::EditorEvent(editor_event) => {
627 Editor::to_item_events(editor_event, f);
628 }
629 ViewEvent::Dismiss => f(ItemEvent::CloseItem),
630 _ => {}
631 }
632 }
633
634 fn breadcrumb_location(&self, _: &App) -> ToolbarItemLocation {
635 if self.has_matches() {
636 ToolbarItemLocation::Secondary
637 } else {
638 ToolbarItemLocation::Hidden
639 }
640 }
641
642 fn breadcrumbs(&self, theme: &theme::Theme, cx: &App) -> Option<Vec<BreadcrumbText>> {
643 self.results_editor.breadcrumbs(theme, cx)
644 }
645}
646
647impl ProjectSearchView {
648 pub fn get_matches(&self, cx: &App) -> Vec<Range<Anchor>> {
649 self.entity.read(cx).match_ranges.clone()
650 }
651
652 fn toggle_filters(&mut self, cx: &mut Context<Self>) {
653 self.filters_enabled = !self.filters_enabled;
654 ActiveSettings::update_global(cx, |settings, cx| {
655 settings.0.insert(
656 self.entity.read(cx).project.downgrade(),
657 self.current_settings(),
658 );
659 });
660 }
661
662 fn current_settings(&self) -> ProjectSearchSettings {
663 ProjectSearchSettings {
664 search_options: self.search_options,
665 filters_enabled: self.filters_enabled,
666 }
667 }
668
669 fn toggle_search_option(&mut self, option: SearchOptions, cx: &mut Context<Self>) {
670 self.search_options.toggle(option);
671 ActiveSettings::update_global(cx, |settings, cx| {
672 settings.0.insert(
673 self.entity.read(cx).project.downgrade(),
674 self.current_settings(),
675 );
676 });
677 self.adjust_query_regex_language(cx);
678 }
679
680 fn toggle_opened_only(&mut self, _window: &mut Window, _cx: &mut Context<Self>) {
681 self.included_opened_only = !self.included_opened_only;
682 }
683
684 fn replace_next(&mut self, _: &ReplaceNext, window: &mut Window, cx: &mut Context<Self>) {
685 if self.entity.read(cx).match_ranges.is_empty() {
686 return;
687 }
688 let Some(active_index) = self.active_match_index else {
689 return;
690 };
691
692 let query = self.entity.read(cx).active_query.clone();
693 if let Some(query) = query {
694 let query = query.with_replacement(self.replacement(cx));
695
696 // TODO: Do we need the clone here?
697 let mat = self.entity.read(cx).match_ranges[active_index].clone();
698 self.results_editor.update(cx, |editor, cx| {
699 editor.replace(&mat, &query, window, cx);
700 });
701 self.select_match(Direction::Next, window, cx)
702 }
703 }
704 pub fn replacement(&self, cx: &App) -> String {
705 self.replacement_editor.read(cx).text(cx)
706 }
707 fn replace_all(&mut self, _: &ReplaceAll, window: &mut Window, cx: &mut Context<Self>) {
708 if self.active_match_index.is_none() {
709 return;
710 }
711
712 let Some(query) = self.entity.read(cx).active_query.as_ref() else {
713 return;
714 };
715 let query = query.clone().with_replacement(self.replacement(cx));
716
717 let match_ranges = self
718 .entity
719 .update(cx, |model, _| mem::take(&mut model.match_ranges));
720 if match_ranges.is_empty() {
721 return;
722 }
723
724 self.results_editor.update(cx, |editor, cx| {
725 editor.replace_all(&mut match_ranges.iter(), &query, window, cx);
726 });
727
728 self.entity.update(cx, |model, _cx| {
729 model.match_ranges = match_ranges;
730 });
731 }
732
733 pub fn new(
734 workspace: WeakEntity<Workspace>,
735 entity: Entity<ProjectSearch>,
736 window: &mut Window,
737 cx: &mut Context<Self>,
738 settings: Option<ProjectSearchSettings>,
739 ) -> Self {
740 let project;
741 let excerpts;
742 let mut replacement_text = None;
743 let mut query_text = String::new();
744 let mut subscriptions = Vec::new();
745
746 // Read in settings if available
747 let (mut options, filters_enabled) = if let Some(settings) = settings {
748 (settings.search_options, settings.filters_enabled)
749 } else {
750 let search_options =
751 SearchOptions::from_settings(&EditorSettings::get_global(cx).search);
752 (search_options, false)
753 };
754
755 {
756 let entity = entity.read(cx);
757 project = entity.project.clone();
758 excerpts = entity.excerpts.clone();
759 if let Some(active_query) = entity.active_query.as_ref() {
760 query_text = active_query.as_str().to_string();
761 replacement_text = active_query.replacement().map(ToOwned::to_owned);
762 options = SearchOptions::from_query(active_query);
763 }
764 }
765 subscriptions.push(cx.observe_in(&entity, window, |this, _, window, cx| {
766 this.entity_changed(window, cx)
767 }));
768
769 let query_editor = cx.new(|cx| {
770 let mut editor = Editor::single_line(window, cx);
771 editor.set_placeholder_text("Search all files…", cx);
772 editor.set_text(query_text, window, cx);
773 editor
774 });
775 // Subscribe to query_editor in order to reraise editor events for workspace item activation purposes
776 subscriptions.push(
777 cx.subscribe(&query_editor, |this, _, event: &EditorEvent, cx| {
778 if let EditorEvent::Edited { .. } = event {
779 if EditorSettings::get_global(cx).use_smartcase_search {
780 let query = this.search_query_text(cx);
781 if !query.is_empty()
782 && this.search_options.contains(SearchOptions::CASE_SENSITIVE)
783 != contains_uppercase(&query)
784 {
785 this.toggle_search_option(SearchOptions::CASE_SENSITIVE, cx);
786 }
787 }
788 }
789 cx.emit(ViewEvent::EditorEvent(event.clone()))
790 }),
791 );
792 let replacement_editor = cx.new(|cx| {
793 let mut editor = Editor::single_line(window, cx);
794 editor.set_placeholder_text("Replace in project…", cx);
795 if let Some(text) = replacement_text {
796 editor.set_text(text, window, cx);
797 }
798 editor
799 });
800 let results_editor = cx.new(|cx| {
801 let mut editor = Editor::for_multibuffer(excerpts, Some(project.clone()), window, cx);
802 editor.set_searchable(false);
803 editor.set_in_project_search(true);
804 editor
805 });
806 subscriptions.push(cx.observe(&results_editor, |_, _, cx| cx.emit(ViewEvent::UpdateTab)));
807
808 subscriptions.push(
809 cx.subscribe(&results_editor, |this, _, event: &EditorEvent, cx| {
810 if matches!(event, editor::EditorEvent::SelectionsChanged { .. }) {
811 this.update_match_index(cx);
812 }
813 // Reraise editor events for workspace item activation purposes
814 cx.emit(ViewEvent::EditorEvent(event.clone()));
815 }),
816 );
817
818 let included_files_editor = cx.new(|cx| {
819 let mut editor = Editor::single_line(window, cx);
820 editor.set_placeholder_text("Include: crates/**/*.toml", cx);
821
822 editor
823 });
824 // Subscribe to include_files_editor in order to reraise editor events for workspace item activation purposes
825 subscriptions.push(
826 cx.subscribe(&included_files_editor, |_, _, event: &EditorEvent, cx| {
827 cx.emit(ViewEvent::EditorEvent(event.clone()))
828 }),
829 );
830
831 let excluded_files_editor = cx.new(|cx| {
832 let mut editor = Editor::single_line(window, cx);
833 editor.set_placeholder_text("Exclude: vendor/*, *.lock", cx);
834
835 editor
836 });
837 // Subscribe to excluded_files_editor in order to reraise editor events for workspace item activation purposes
838 subscriptions.push(
839 cx.subscribe(&excluded_files_editor, |_, _, event: &EditorEvent, cx| {
840 cx.emit(ViewEvent::EditorEvent(event.clone()))
841 }),
842 );
843
844 let focus_handle = cx.focus_handle();
845 subscriptions.push(cx.on_focus(&focus_handle, window, |_, window, cx| {
846 cx.on_next_frame(window, |this, window, cx| {
847 if this.focus_handle.is_focused(window) {
848 if this.has_matches() {
849 this.results_editor.focus_handle(cx).focus(window);
850 } else {
851 this.query_editor.focus_handle(cx).focus(window);
852 }
853 }
854 });
855 }));
856
857 let languages = project.read(cx).languages().clone();
858 cx.spawn(async move |project_search_view, cx| {
859 let regex_language = languages
860 .language_for_name("regex")
861 .await
862 .context("loading regex language")?;
863 project_search_view
864 .update(cx, |project_search_view, cx| {
865 project_search_view.regex_language = Some(regex_language);
866 project_search_view.adjust_query_regex_language(cx);
867 })
868 .ok();
869 anyhow::Ok(())
870 })
871 .detach_and_log_err(cx);
872
873 // Check if Worktrees have all been previously indexed
874 let mut this = ProjectSearchView {
875 workspace,
876 focus_handle,
877 replacement_editor,
878 search_id: entity.read(cx).search_id,
879 entity,
880 query_editor,
881 results_editor,
882 search_options: options,
883 panels_with_errors: HashMap::default(),
884 active_match_index: None,
885 included_files_editor,
886 excluded_files_editor,
887 filters_enabled,
888 replace_enabled: false,
889 included_opened_only: false,
890 regex_language: None,
891 _subscriptions: subscriptions,
892 };
893 this.entity_changed(window, cx);
894 this
895 }
896
897 pub fn new_search_in_directory(
898 workspace: &mut Workspace,
899 dir_path: &Path,
900 window: &mut Window,
901 cx: &mut Context<Workspace>,
902 ) {
903 let Some(filter_str) = dir_path.to_str() else {
904 return;
905 };
906
907 let weak_workspace = cx.entity().downgrade();
908
909 let entity = cx.new(|cx| ProjectSearch::new(workspace.project().clone(), cx));
910 let search = cx.new(|cx| ProjectSearchView::new(weak_workspace, entity, window, cx, None));
911 workspace.add_item_to_active_pane(Box::new(search.clone()), None, true, window, cx);
912 search.update(cx, |search, cx| {
913 search
914 .included_files_editor
915 .update(cx, |editor, cx| editor.set_text(filter_str, window, cx));
916 search.filters_enabled = true;
917 search.focus_query_editor(window, cx)
918 });
919 }
920
921 /// Re-activate the most recently activated search in this pane or the most recent if it has been closed.
922 /// If no search exists in the workspace, create a new one.
923 pub fn deploy_search(
924 workspace: &mut Workspace,
925 action: &workspace::DeploySearch,
926 window: &mut Window,
927 cx: &mut Context<Workspace>,
928 ) {
929 let existing = workspace
930 .active_pane()
931 .read(cx)
932 .items()
933 .find_map(|item| item.downcast::<ProjectSearchView>());
934
935 Self::existing_or_new_search(workspace, existing, action, window, cx);
936 }
937
938 fn search_in_new(
939 workspace: &mut Workspace,
940 _: &SearchInNew,
941 window: &mut Window,
942 cx: &mut Context<Workspace>,
943 ) {
944 if let Some(search_view) = workspace
945 .active_item(cx)
946 .and_then(|item| item.downcast::<ProjectSearchView>())
947 {
948 let new_query = search_view.update(cx, |search_view, cx| {
949 let new_query = search_view.build_search_query(cx);
950 if new_query.is_some() {
951 if let Some(old_query) = search_view.entity.read(cx).active_query.clone() {
952 search_view.query_editor.update(cx, |editor, cx| {
953 editor.set_text(old_query.as_str(), window, cx);
954 });
955 search_view.search_options = SearchOptions::from_query(&old_query);
956 search_view.adjust_query_regex_language(cx);
957 }
958 }
959 new_query
960 });
961 if let Some(new_query) = new_query {
962 let entity = cx.new(|cx| {
963 let mut entity = ProjectSearch::new(workspace.project().clone(), cx);
964 entity.search(new_query, cx);
965 entity
966 });
967 let weak_workspace = cx.entity().downgrade();
968 workspace.add_item_to_active_pane(
969 Box::new(cx.new(|cx| {
970 ProjectSearchView::new(weak_workspace, entity, window, cx, None)
971 })),
972 None,
973 true,
974 window,
975 cx,
976 );
977 }
978 }
979 }
980
981 // Add another search tab to the workspace.
982 fn new_search(
983 workspace: &mut Workspace,
984 _: &workspace::NewSearch,
985 window: &mut Window,
986 cx: &mut Context<Workspace>,
987 ) {
988 Self::existing_or_new_search(workspace, None, &DeploySearch::find(), window, cx)
989 }
990
991 fn existing_or_new_search(
992 workspace: &mut Workspace,
993 existing: Option<Entity<ProjectSearchView>>,
994 action: &workspace::DeploySearch,
995 window: &mut Window,
996 cx: &mut Context<Workspace>,
997 ) {
998 let query = workspace.active_item(cx).and_then(|item| {
999 if let Some(buffer_search_query) = buffer_search_query(workspace, item.as_ref(), cx) {
1000 return Some(buffer_search_query);
1001 }
1002
1003 let editor = item.act_as::<Editor>(cx)?;
1004 let query = editor.query_suggestion(window, cx);
1005 if query.is_empty() { None } else { Some(query) }
1006 });
1007
1008 let search = if let Some(existing) = existing {
1009 workspace.activate_item(&existing, true, true, window, cx);
1010 existing
1011 } else {
1012 let settings = cx
1013 .global::<ActiveSettings>()
1014 .0
1015 .get(&workspace.project().downgrade());
1016
1017 let settings = settings.cloned();
1018
1019 let weak_workspace = cx.entity().downgrade();
1020
1021 let project_search = cx.new(|cx| ProjectSearch::new(workspace.project().clone(), cx));
1022 let project_search_view = cx.new(|cx| {
1023 ProjectSearchView::new(weak_workspace, project_search, window, cx, settings)
1024 });
1025
1026 workspace.add_item_to_active_pane(
1027 Box::new(project_search_view.clone()),
1028 None,
1029 true,
1030 window,
1031 cx,
1032 );
1033 project_search_view
1034 };
1035
1036 search.update(cx, |search, cx| {
1037 search.replace_enabled = action.replace_enabled;
1038 if let Some(query) = query {
1039 search.set_query(&query, window, cx);
1040 }
1041 if let Some(included_files) = action.included_files.as_deref() {
1042 search
1043 .included_files_editor
1044 .update(cx, |editor, cx| editor.set_text(included_files, window, cx));
1045 search.filters_enabled = true;
1046 }
1047 if let Some(excluded_files) = action.excluded_files.as_deref() {
1048 search
1049 .excluded_files_editor
1050 .update(cx, |editor, cx| editor.set_text(excluded_files, window, cx));
1051 search.filters_enabled = true;
1052 }
1053 search.focus_query_editor(window, cx)
1054 });
1055 }
1056
1057 fn prompt_to_save_if_dirty_then_search(
1058 &mut self,
1059 window: &mut Window,
1060 cx: &mut Context<Self>,
1061 ) -> Task<anyhow::Result<()>> {
1062 use workspace::AutosaveSetting;
1063
1064 let project = self.entity.read(cx).project.clone();
1065
1066 let can_autosave = self.results_editor.can_autosave(cx);
1067 let autosave_setting = self.results_editor.workspace_settings(cx).autosave;
1068
1069 let will_autosave = can_autosave
1070 && matches!(
1071 autosave_setting,
1072 AutosaveSetting::OnFocusChange | AutosaveSetting::OnWindowChange
1073 );
1074
1075 let is_dirty = self.is_dirty(cx);
1076
1077 cx.spawn_in(window, async move |this, cx| {
1078 let skip_save_on_close = this
1079 .read_with(cx, |this, cx| {
1080 this.workspace.read_with(cx, |workspace, cx| {
1081 workspace::Pane::skip_save_on_close(&this.results_editor, workspace, cx)
1082 })
1083 })?
1084 .unwrap_or(false);
1085
1086 let should_prompt_to_save = !skip_save_on_close && !will_autosave && is_dirty;
1087
1088 let should_search = if should_prompt_to_save {
1089 let options = &["Save", "Don't Save", "Cancel"];
1090 let result_channel = this.update_in(cx, |_, window, cx| {
1091 window.prompt(
1092 gpui::PromptLevel::Warning,
1093 "Project search buffer contains unsaved edits. Do you want to save it?",
1094 None,
1095 options,
1096 cx,
1097 )
1098 })?;
1099 let result = result_channel.await?;
1100 let should_save = result == 0;
1101 if should_save {
1102 this.update_in(cx, |this, window, cx| {
1103 this.save(
1104 SaveOptions {
1105 format: true,
1106 autosave: false,
1107 },
1108 project,
1109 window,
1110 cx,
1111 )
1112 })?
1113 .await
1114 .log_err();
1115 }
1116 let should_search = result != 2;
1117 should_search
1118 } else {
1119 true
1120 };
1121 if should_search {
1122 this.update(cx, |this, cx| {
1123 this.search(cx);
1124 })?;
1125 }
1126 anyhow::Ok(())
1127 })
1128 }
1129
1130 fn search(&mut self, cx: &mut Context<Self>) {
1131 if let Some(query) = self.build_search_query(cx) {
1132 self.entity.update(cx, |model, cx| model.search(query, cx));
1133 }
1134 }
1135
1136 pub fn search_query_text(&self, cx: &App) -> String {
1137 self.query_editor.read(cx).text(cx)
1138 }
1139
1140 fn build_search_query(&mut self, cx: &mut Context<Self>) -> Option<SearchQuery> {
1141 // Do not bail early in this function, as we want to fill out `self.panels_with_errors`.
1142 let text = self.query_editor.read(cx).text(cx);
1143 let open_buffers = if self.included_opened_only {
1144 Some(self.open_buffers(cx))
1145 } else {
1146 None
1147 };
1148 let included_files = self
1149 .filters_enabled
1150 .then(|| {
1151 match Self::parse_path_matches(&self.included_files_editor.read(cx).text(cx)) {
1152 Ok(included_files) => {
1153 let should_unmark_error =
1154 self.panels_with_errors.remove(&InputPanel::Include);
1155 if should_unmark_error.is_some() {
1156 cx.notify();
1157 }
1158 included_files
1159 }
1160 Err(e) => {
1161 let should_mark_error = self
1162 .panels_with_errors
1163 .insert(InputPanel::Include, e.to_string());
1164 if should_mark_error.is_none() {
1165 cx.notify();
1166 }
1167 PathMatcher::default()
1168 }
1169 }
1170 })
1171 .unwrap_or_default();
1172 let excluded_files = self
1173 .filters_enabled
1174 .then(|| {
1175 match Self::parse_path_matches(&self.excluded_files_editor.read(cx).text(cx)) {
1176 Ok(excluded_files) => {
1177 let should_unmark_error =
1178 self.panels_with_errors.remove(&InputPanel::Exclude);
1179 if should_unmark_error.is_some() {
1180 cx.notify();
1181 }
1182
1183 excluded_files
1184 }
1185 Err(e) => {
1186 let should_mark_error = self
1187 .panels_with_errors
1188 .insert(InputPanel::Exclude, e.to_string());
1189 if should_mark_error.is_none() {
1190 cx.notify();
1191 }
1192 PathMatcher::default()
1193 }
1194 }
1195 })
1196 .unwrap_or_default();
1197
1198 // If the project contains multiple visible worktrees, we match the
1199 // include/exclude patterns against full paths to allow them to be
1200 // disambiguated. For single worktree projects we use worktree relative
1201 // paths for convenience.
1202 let match_full_paths = self
1203 .entity
1204 .read(cx)
1205 .project
1206 .read(cx)
1207 .visible_worktrees(cx)
1208 .count()
1209 > 1;
1210
1211 let query = if self.search_options.contains(SearchOptions::REGEX) {
1212 match SearchQuery::regex(
1213 text,
1214 self.search_options.contains(SearchOptions::WHOLE_WORD),
1215 self.search_options.contains(SearchOptions::CASE_SENSITIVE),
1216 self.search_options.contains(SearchOptions::INCLUDE_IGNORED),
1217 self.search_options
1218 .contains(SearchOptions::ONE_MATCH_PER_LINE),
1219 included_files,
1220 excluded_files,
1221 match_full_paths,
1222 open_buffers,
1223 ) {
1224 Ok(query) => {
1225 let should_unmark_error = self.panels_with_errors.remove(&InputPanel::Query);
1226 if should_unmark_error.is_some() {
1227 cx.notify();
1228 }
1229
1230 Some(query)
1231 }
1232 Err(e) => {
1233 let should_mark_error = self
1234 .panels_with_errors
1235 .insert(InputPanel::Query, e.to_string());
1236 if should_mark_error.is_none() {
1237 cx.notify();
1238 }
1239
1240 None
1241 }
1242 }
1243 } else {
1244 match SearchQuery::text(
1245 text,
1246 self.search_options.contains(SearchOptions::WHOLE_WORD),
1247 self.search_options.contains(SearchOptions::CASE_SENSITIVE),
1248 self.search_options.contains(SearchOptions::INCLUDE_IGNORED),
1249 included_files,
1250 excluded_files,
1251 match_full_paths,
1252 open_buffers,
1253 ) {
1254 Ok(query) => {
1255 let should_unmark_error = self.panels_with_errors.remove(&InputPanel::Query);
1256 if should_unmark_error.is_some() {
1257 cx.notify();
1258 }
1259
1260 Some(query)
1261 }
1262 Err(e) => {
1263 let should_mark_error = self
1264 .panels_with_errors
1265 .insert(InputPanel::Query, e.to_string());
1266 if should_mark_error.is_none() {
1267 cx.notify();
1268 }
1269
1270 None
1271 }
1272 }
1273 };
1274 if !self.panels_with_errors.is_empty() {
1275 return None;
1276 }
1277 if query.as_ref().is_some_and(|query| query.is_empty()) {
1278 return None;
1279 }
1280 query
1281 }
1282
1283 fn open_buffers(&self, cx: &mut Context<Self>) -> Vec<Entity<Buffer>> {
1284 let mut buffers = Vec::new();
1285 self.workspace
1286 .update(cx, |workspace, cx| {
1287 for editor in workspace.items_of_type::<Editor>(cx) {
1288 if let Some(buffer) = editor.read(cx).buffer().read(cx).as_singleton() {
1289 buffers.push(buffer);
1290 }
1291 }
1292 })
1293 .ok();
1294 buffers
1295 }
1296
1297 fn parse_path_matches(text: &str) -> anyhow::Result<PathMatcher> {
1298 let queries = text
1299 .split(',')
1300 .map(str::trim)
1301 .filter(|maybe_glob_str| !maybe_glob_str.is_empty())
1302 .map(str::to_owned)
1303 .collect::<Vec<_>>();
1304 Ok(PathMatcher::new(&queries)?)
1305 }
1306
1307 fn select_match(&mut self, direction: Direction, window: &mut Window, cx: &mut Context<Self>) {
1308 if let Some(index) = self.active_match_index {
1309 let match_ranges = self.entity.read(cx).match_ranges.clone();
1310
1311 if !EditorSettings::get_global(cx).search_wrap
1312 && ((direction == Direction::Next && index + 1 >= match_ranges.len())
1313 || (direction == Direction::Prev && index == 0))
1314 {
1315 crate::show_no_more_matches(window, cx);
1316 return;
1317 }
1318
1319 let new_index = self.results_editor.update(cx, |editor, cx| {
1320 editor.match_index_for_direction(&match_ranges, index, direction, 1, window, cx)
1321 });
1322
1323 let range_to_select = match_ranges[new_index].clone();
1324 self.results_editor.update(cx, |editor, cx| {
1325 let range_to_select = editor.range_for_match(&range_to_select);
1326 editor.unfold_ranges(std::slice::from_ref(&range_to_select), false, true, cx);
1327 editor.change_selections(Default::default(), window, cx, |s| {
1328 s.select_ranges([range_to_select])
1329 });
1330 });
1331 }
1332 }
1333
1334 fn focus_query_editor(&mut self, window: &mut Window, cx: &mut Context<Self>) {
1335 self.query_editor.update(cx, |query_editor, cx| {
1336 query_editor.select_all(&SelectAll, window, cx);
1337 });
1338 let editor_handle = self.query_editor.focus_handle(cx);
1339 window.focus(&editor_handle);
1340 }
1341
1342 fn set_query(&mut self, query: &str, window: &mut Window, cx: &mut Context<Self>) {
1343 self.set_search_editor(SearchInputKind::Query, query, window, cx);
1344 if EditorSettings::get_global(cx).use_smartcase_search
1345 && !query.is_empty()
1346 && self.search_options.contains(SearchOptions::CASE_SENSITIVE)
1347 != contains_uppercase(query)
1348 {
1349 self.toggle_search_option(SearchOptions::CASE_SENSITIVE, cx)
1350 }
1351 }
1352
1353 fn set_search_editor(
1354 &mut self,
1355 kind: SearchInputKind,
1356 text: &str,
1357 window: &mut Window,
1358 cx: &mut Context<Self>,
1359 ) {
1360 let editor = match kind {
1361 SearchInputKind::Query => &self.query_editor,
1362 SearchInputKind::Include => &self.included_files_editor,
1363
1364 SearchInputKind::Exclude => &self.excluded_files_editor,
1365 };
1366 editor.update(cx, |included_editor, cx| {
1367 included_editor.set_text(text, window, cx)
1368 });
1369 }
1370
1371 fn focus_results_editor(&mut self, window: &mut Window, cx: &mut Context<Self>) {
1372 self.query_editor.update(cx, |query_editor, cx| {
1373 let cursor = query_editor.selections.newest_anchor().head();
1374 query_editor.change_selections(SelectionEffects::no_scroll(), window, cx, |s| {
1375 s.select_ranges([cursor..cursor])
1376 });
1377 });
1378 let results_handle = self.results_editor.focus_handle(cx);
1379 window.focus(&results_handle);
1380 }
1381
1382 fn entity_changed(&mut self, window: &mut Window, cx: &mut Context<Self>) {
1383 let match_ranges = self.entity.read(cx).match_ranges.clone();
1384 if match_ranges.is_empty() {
1385 self.active_match_index = None;
1386 } else {
1387 self.active_match_index = Some(0);
1388 self.update_match_index(cx);
1389 let prev_search_id = mem::replace(&mut self.search_id, self.entity.read(cx).search_id);
1390 let is_new_search = self.search_id != prev_search_id;
1391 self.results_editor.update(cx, |editor, cx| {
1392 if is_new_search {
1393 let range_to_select = match_ranges
1394 .first()
1395 .map(|range| editor.range_for_match(range));
1396 editor.change_selections(Default::default(), window, cx, |s| {
1397 s.select_ranges(range_to_select)
1398 });
1399 editor.scroll(Point::default(), Some(Axis::Vertical), window, cx);
1400 }
1401 editor.highlight_background::<Self>(
1402 &match_ranges,
1403 |theme| theme.colors().search_match_background,
1404 cx,
1405 );
1406 });
1407 if is_new_search && self.query_editor.focus_handle(cx).is_focused(window) {
1408 self.focus_results_editor(window, cx);
1409 }
1410 }
1411
1412 cx.emit(ViewEvent::UpdateTab);
1413 cx.notify();
1414 }
1415
1416 fn update_match_index(&mut self, cx: &mut Context<Self>) {
1417 let results_editor = self.results_editor.read(cx);
1418 let new_index = active_match_index(
1419 Direction::Next,
1420 &self.entity.read(cx).match_ranges,
1421 &results_editor.selections.newest_anchor().head(),
1422 &results_editor.buffer().read(cx).snapshot(cx),
1423 );
1424 if self.active_match_index != new_index {
1425 self.active_match_index = new_index;
1426 cx.notify();
1427 }
1428 }
1429
1430 pub fn has_matches(&self) -> bool {
1431 self.active_match_index.is_some()
1432 }
1433
1434 fn landing_text_minor(&self, window: &mut Window, cx: &App) -> impl IntoElement {
1435 let focus_handle = self.focus_handle.clone();
1436 v_flex()
1437 .gap_1()
1438 .child(
1439 Label::new("Hit enter to search. For more options:")
1440 .color(Color::Muted)
1441 .mb_2(),
1442 )
1443 .child(
1444 Button::new("filter-paths", "Include/exclude specific paths")
1445 .icon(IconName::Filter)
1446 .icon_position(IconPosition::Start)
1447 .icon_size(IconSize::Small)
1448 .key_binding(KeyBinding::for_action_in(
1449 &ToggleFilters,
1450 &focus_handle,
1451 window,
1452 cx,
1453 ))
1454 .on_click(|_event, window, cx| {
1455 window.dispatch_action(ToggleFilters.boxed_clone(), cx)
1456 }),
1457 )
1458 .child(
1459 Button::new("find-replace", "Find and replace")
1460 .icon(IconName::Replace)
1461 .icon_position(IconPosition::Start)
1462 .icon_size(IconSize::Small)
1463 .key_binding(KeyBinding::for_action_in(
1464 &ToggleReplace,
1465 &focus_handle,
1466 window,
1467 cx,
1468 ))
1469 .on_click(|_event, window, cx| {
1470 window.dispatch_action(ToggleReplace.boxed_clone(), cx)
1471 }),
1472 )
1473 .child(
1474 Button::new("regex", "Match with regex")
1475 .icon(IconName::Regex)
1476 .icon_position(IconPosition::Start)
1477 .icon_size(IconSize::Small)
1478 .key_binding(KeyBinding::for_action_in(
1479 &ToggleRegex,
1480 &focus_handle,
1481 window,
1482 cx,
1483 ))
1484 .on_click(|_event, window, cx| {
1485 window.dispatch_action(ToggleRegex.boxed_clone(), cx)
1486 }),
1487 )
1488 .child(
1489 Button::new("match-case", "Match case")
1490 .icon(IconName::CaseSensitive)
1491 .icon_position(IconPosition::Start)
1492 .icon_size(IconSize::Small)
1493 .key_binding(KeyBinding::for_action_in(
1494 &ToggleCaseSensitive,
1495 &focus_handle,
1496 window,
1497 cx,
1498 ))
1499 .on_click(|_event, window, cx| {
1500 window.dispatch_action(ToggleCaseSensitive.boxed_clone(), cx)
1501 }),
1502 )
1503 .child(
1504 Button::new("match-whole-words", "Match whole words")
1505 .icon(IconName::WholeWord)
1506 .icon_position(IconPosition::Start)
1507 .icon_size(IconSize::Small)
1508 .key_binding(KeyBinding::for_action_in(
1509 &ToggleWholeWord,
1510 &focus_handle,
1511 window,
1512 cx,
1513 ))
1514 .on_click(|_event, window, cx| {
1515 window.dispatch_action(ToggleWholeWord.boxed_clone(), cx)
1516 }),
1517 )
1518 }
1519
1520 fn border_color_for(&self, panel: InputPanel, cx: &App) -> Hsla {
1521 if self.panels_with_errors.contains_key(&panel) {
1522 Color::Error.color(cx)
1523 } else {
1524 cx.theme().colors().border
1525 }
1526 }
1527
1528 fn move_focus_to_results(&mut self, window: &mut Window, cx: &mut Context<Self>) {
1529 if !self.results_editor.focus_handle(cx).is_focused(window)
1530 && !self.entity.read(cx).match_ranges.is_empty()
1531 {
1532 cx.stop_propagation();
1533 self.focus_results_editor(window, cx)
1534 }
1535 }
1536
1537 #[cfg(any(test, feature = "test-support"))]
1538 pub fn results_editor(&self) -> &Entity<Editor> {
1539 &self.results_editor
1540 }
1541
1542 fn adjust_query_regex_language(&self, cx: &mut App) {
1543 let enable = self.search_options.contains(SearchOptions::REGEX);
1544 let query_buffer = self
1545 .query_editor
1546 .read(cx)
1547 .buffer()
1548 .read(cx)
1549 .as_singleton()
1550 .expect("query editor should be backed by a singleton buffer");
1551 if enable {
1552 if let Some(regex_language) = self.regex_language.clone() {
1553 query_buffer.update(cx, |query_buffer, cx| {
1554 query_buffer.set_language(Some(regex_language), cx);
1555 })
1556 }
1557 } else {
1558 query_buffer.update(cx, |query_buffer, cx| {
1559 query_buffer.set_language(None, cx);
1560 })
1561 }
1562 }
1563}
1564
1565fn buffer_search_query(
1566 workspace: &mut Workspace,
1567 item: &dyn ItemHandle,
1568 cx: &mut Context<Workspace>,
1569) -> Option<String> {
1570 let buffer_search_bar = workspace
1571 .pane_for(item)
1572 .and_then(|pane| {
1573 pane.read(cx)
1574 .toolbar()
1575 .read(cx)
1576 .item_of_type::<BufferSearchBar>()
1577 })?
1578 .read(cx);
1579 if buffer_search_bar.query_editor_focused() {
1580 let buffer_search_query = buffer_search_bar.query(cx);
1581 if !buffer_search_query.is_empty() {
1582 return Some(buffer_search_query);
1583 }
1584 }
1585 None
1586}
1587
1588impl Default for ProjectSearchBar {
1589 fn default() -> Self {
1590 Self::new()
1591 }
1592}
1593
1594impl ProjectSearchBar {
1595 pub fn new() -> Self {
1596 Self {
1597 active_project_search: None,
1598 subscription: None,
1599 }
1600 }
1601
1602 fn confirm(&mut self, _: &Confirm, window: &mut Window, cx: &mut Context<Self>) {
1603 if let Some(search_view) = self.active_project_search.as_ref() {
1604 search_view.update(cx, |search_view, cx| {
1605 if !search_view
1606 .replacement_editor
1607 .focus_handle(cx)
1608 .is_focused(window)
1609 {
1610 cx.stop_propagation();
1611 search_view
1612 .prompt_to_save_if_dirty_then_search(window, cx)
1613 .detach_and_log_err(cx);
1614 }
1615 });
1616 }
1617 }
1618
1619 fn tab(&mut self, _: &Tab, window: &mut Window, cx: &mut Context<Self>) {
1620 self.cycle_field(Direction::Next, window, cx);
1621 }
1622
1623 fn backtab(&mut self, _: &Backtab, window: &mut Window, cx: &mut Context<Self>) {
1624 self.cycle_field(Direction::Prev, window, cx);
1625 }
1626
1627 fn focus_search(&mut self, window: &mut Window, cx: &mut Context<Self>) {
1628 if let Some(search_view) = self.active_project_search.as_ref() {
1629 search_view.update(cx, |search_view, cx| {
1630 search_view.query_editor.focus_handle(cx).focus(window);
1631 });
1632 }
1633 }
1634
1635 fn cycle_field(&mut self, direction: Direction, window: &mut Window, cx: &mut Context<Self>) {
1636 let active_project_search = match &self.active_project_search {
1637 Some(active_project_search) => active_project_search,
1638 None => return,
1639 };
1640
1641 active_project_search.update(cx, |project_view, cx| {
1642 let mut views = vec![project_view.query_editor.focus_handle(cx)];
1643 if project_view.replace_enabled {
1644 views.push(project_view.replacement_editor.focus_handle(cx));
1645 }
1646 if project_view.filters_enabled {
1647 views.extend([
1648 project_view.included_files_editor.focus_handle(cx),
1649 project_view.excluded_files_editor.focus_handle(cx),
1650 ]);
1651 }
1652 let current_index = match views.iter().position(|focus| focus.is_focused(window)) {
1653 Some(index) => index,
1654 None => return,
1655 };
1656
1657 let new_index = match direction {
1658 Direction::Next => (current_index + 1) % views.len(),
1659 Direction::Prev if current_index == 0 => views.len() - 1,
1660 Direction::Prev => (current_index - 1) % views.len(),
1661 };
1662 let next_focus_handle = &views[new_index];
1663 window.focus(next_focus_handle);
1664 cx.stop_propagation();
1665 });
1666 }
1667
1668 fn toggle_search_option(
1669 &mut self,
1670 option: SearchOptions,
1671 window: &mut Window,
1672 cx: &mut Context<Self>,
1673 ) -> bool {
1674 if self.active_project_search.is_none() {
1675 return false;
1676 }
1677
1678 cx.spawn_in(window, async move |this, cx| {
1679 let task = this.update_in(cx, |this, window, cx| {
1680 let search_view = this.active_project_search.as_ref()?;
1681 search_view.update(cx, |search_view, cx| {
1682 search_view.toggle_search_option(option, cx);
1683 search_view
1684 .entity
1685 .read(cx)
1686 .active_query
1687 .is_some()
1688 .then(|| search_view.prompt_to_save_if_dirty_then_search(window, cx))
1689 })
1690 })?;
1691 if let Some(task) = task {
1692 task.await?;
1693 }
1694 this.update(cx, |_, cx| {
1695 cx.notify();
1696 })?;
1697 anyhow::Ok(())
1698 })
1699 .detach();
1700 true
1701 }
1702
1703 fn toggle_replace(&mut self, _: &ToggleReplace, window: &mut Window, cx: &mut Context<Self>) {
1704 if let Some(search) = &self.active_project_search {
1705 search.update(cx, |this, cx| {
1706 this.replace_enabled = !this.replace_enabled;
1707 let editor_to_focus = if this.replace_enabled {
1708 this.replacement_editor.focus_handle(cx)
1709 } else {
1710 this.query_editor.focus_handle(cx)
1711 };
1712 window.focus(&editor_to_focus);
1713 cx.notify();
1714 });
1715 }
1716 }
1717
1718 fn toggle_filters(&mut self, window: &mut Window, cx: &mut Context<Self>) -> bool {
1719 if let Some(search_view) = self.active_project_search.as_ref() {
1720 search_view.update(cx, |search_view, cx| {
1721 search_view.toggle_filters(cx);
1722 search_view
1723 .included_files_editor
1724 .update(cx, |_, cx| cx.notify());
1725 search_view
1726 .excluded_files_editor
1727 .update(cx, |_, cx| cx.notify());
1728 window.refresh();
1729 cx.notify();
1730 });
1731 cx.notify();
1732 true
1733 } else {
1734 false
1735 }
1736 }
1737
1738 fn toggle_opened_only(&mut self, window: &mut Window, cx: &mut Context<Self>) -> bool {
1739 if self.active_project_search.is_none() {
1740 return false;
1741 }
1742
1743 cx.spawn_in(window, async move |this, cx| {
1744 let task = this.update_in(cx, |this, window, cx| {
1745 let search_view = this.active_project_search.as_ref()?;
1746 search_view.update(cx, |search_view, cx| {
1747 search_view.toggle_opened_only(window, cx);
1748 search_view
1749 .entity
1750 .read(cx)
1751 .active_query
1752 .is_some()
1753 .then(|| search_view.prompt_to_save_if_dirty_then_search(window, cx))
1754 })
1755 })?;
1756 if let Some(task) = task {
1757 task.await?;
1758 }
1759 this.update(cx, |_, cx| {
1760 cx.notify();
1761 })?;
1762 anyhow::Ok(())
1763 })
1764 .detach();
1765 true
1766 }
1767
1768 fn is_opened_only_enabled(&self, cx: &App) -> bool {
1769 if let Some(search_view) = self.active_project_search.as_ref() {
1770 search_view.read(cx).included_opened_only
1771 } else {
1772 false
1773 }
1774 }
1775
1776 fn move_focus_to_results(&self, window: &mut Window, cx: &mut Context<Self>) {
1777 if let Some(search_view) = self.active_project_search.as_ref() {
1778 search_view.update(cx, |search_view, cx| {
1779 search_view.move_focus_to_results(window, cx);
1780 });
1781 cx.notify();
1782 }
1783 }
1784
1785 fn next_history_query(
1786 &mut self,
1787 _: &NextHistoryQuery,
1788 window: &mut Window,
1789 cx: &mut Context<Self>,
1790 ) {
1791 if let Some(search_view) = self.active_project_search.as_ref() {
1792 search_view.update(cx, |search_view, cx| {
1793 for (editor, kind) in [
1794 (search_view.query_editor.clone(), SearchInputKind::Query),
1795 (
1796 search_view.included_files_editor.clone(),
1797 SearchInputKind::Include,
1798 ),
1799 (
1800 search_view.excluded_files_editor.clone(),
1801 SearchInputKind::Exclude,
1802 ),
1803 ] {
1804 if editor.focus_handle(cx).is_focused(window) {
1805 let new_query = search_view.entity.update(cx, |model, cx| {
1806 let project = model.project.clone();
1807
1808 if let Some(new_query) = project.update(cx, |project, _| {
1809 project
1810 .search_history_mut(kind)
1811 .next(model.cursor_mut(kind))
1812 .map(str::to_string)
1813 }) {
1814 new_query
1815 } else {
1816 model.cursor_mut(kind).reset();
1817 String::new()
1818 }
1819 });
1820 search_view.set_search_editor(kind, &new_query, window, cx);
1821 }
1822 }
1823 });
1824 }
1825 }
1826
1827 fn previous_history_query(
1828 &mut self,
1829 _: &PreviousHistoryQuery,
1830 window: &mut Window,
1831 cx: &mut Context<Self>,
1832 ) {
1833 if let Some(search_view) = self.active_project_search.as_ref() {
1834 search_view.update(cx, |search_view, cx| {
1835 for (editor, kind) in [
1836 (search_view.query_editor.clone(), SearchInputKind::Query),
1837 (
1838 search_view.included_files_editor.clone(),
1839 SearchInputKind::Include,
1840 ),
1841 (
1842 search_view.excluded_files_editor.clone(),
1843 SearchInputKind::Exclude,
1844 ),
1845 ] {
1846 if editor.focus_handle(cx).is_focused(window) {
1847 if editor.read(cx).text(cx).is_empty() {
1848 if let Some(new_query) = search_view
1849 .entity
1850 .read(cx)
1851 .project
1852 .read(cx)
1853 .search_history(kind)
1854 .current(search_view.entity.read(cx).cursor(kind))
1855 .map(str::to_string)
1856 {
1857 search_view.set_search_editor(kind, &new_query, window, cx);
1858 return;
1859 }
1860 }
1861
1862 if let Some(new_query) = search_view.entity.update(cx, |model, cx| {
1863 let project = model.project.clone();
1864 project.update(cx, |project, _| {
1865 project
1866 .search_history_mut(kind)
1867 .previous(model.cursor_mut(kind))
1868 .map(str::to_string)
1869 })
1870 }) {
1871 search_view.set_search_editor(kind, &new_query, window, cx);
1872 }
1873 }
1874 }
1875 });
1876 }
1877 }
1878
1879 fn select_next_match(
1880 &mut self,
1881 _: &SelectNextMatch,
1882 window: &mut Window,
1883 cx: &mut Context<Self>,
1884 ) {
1885 if let Some(search) = self.active_project_search.as_ref() {
1886 search.update(cx, |this, cx| {
1887 this.select_match(Direction::Next, window, cx);
1888 })
1889 }
1890 }
1891
1892 fn select_prev_match(
1893 &mut self,
1894 _: &SelectPreviousMatch,
1895 window: &mut Window,
1896 cx: &mut Context<Self>,
1897 ) {
1898 if let Some(search) = self.active_project_search.as_ref() {
1899 search.update(cx, |this, cx| {
1900 this.select_match(Direction::Prev, window, cx);
1901 })
1902 }
1903 }
1904}
1905
1906impl Render for ProjectSearchBar {
1907 fn render(&mut self, window: &mut Window, cx: &mut Context<Self>) -> impl IntoElement {
1908 let Some(search) = self.active_project_search.clone() else {
1909 return div();
1910 };
1911 let search = search.read(cx);
1912 let focus_handle = search.focus_handle(cx);
1913
1914 let container_width = window.viewport_size().width;
1915 let input_width = SearchInputWidth::calc_width(container_width);
1916
1917 let input_base_styles = |panel: InputPanel| {
1918 input_base_styles(search.border_color_for(panel, cx), |div| match panel {
1919 InputPanel::Query | InputPanel::Replacement => div.w(input_width),
1920 InputPanel::Include | InputPanel::Exclude => div.flex_grow(),
1921 })
1922 };
1923 let theme_colors = cx.theme().colors();
1924 let project_search = search.entity.read(cx);
1925 let limit_reached = project_search.limit_reached;
1926
1927 let color_override = match (
1928 project_search.no_results,
1929 &project_search.active_query,
1930 &project_search.last_search_query_text,
1931 ) {
1932 (Some(true), Some(q), Some(p)) if q.as_str() == p => Some(Color::Error),
1933 _ => None,
1934 };
1935 let match_text = search
1936 .active_match_index
1937 .and_then(|index| {
1938 let index = index + 1;
1939 let match_quantity = project_search.match_ranges.len();
1940 if match_quantity > 0 {
1941 debug_assert!(match_quantity >= index);
1942 if limit_reached {
1943 Some(format!("{index}/{match_quantity}+"))
1944 } else {
1945 Some(format!("{index}/{match_quantity}"))
1946 }
1947 } else {
1948 None
1949 }
1950 })
1951 .unwrap_or_else(|| "0/0".to_string());
1952
1953 let query_column = input_base_styles(InputPanel::Query)
1954 .on_action(cx.listener(|this, action, window, cx| this.confirm(action, window, cx)))
1955 .on_action(cx.listener(|this, action, window, cx| {
1956 this.previous_history_query(action, window, cx)
1957 }))
1958 .on_action(
1959 cx.listener(|this, action, window, cx| this.next_history_query(action, window, cx)),
1960 )
1961 .child(render_text_input(&search.query_editor, color_override, cx))
1962 .child(
1963 h_flex()
1964 .gap_1()
1965 .child(
1966 SearchOption::CaseSensitive
1967 .as_button(search.search_options, focus_handle.clone()),
1968 )
1969 .child(
1970 SearchOption::WholeWord
1971 .as_button(search.search_options, focus_handle.clone()),
1972 )
1973 .child(
1974 SearchOption::Regex.as_button(search.search_options, focus_handle.clone()),
1975 ),
1976 );
1977
1978 let mode_column = h_flex()
1979 .gap_1()
1980 .min_w_64()
1981 .child(
1982 IconButton::new("project-search-filter-button", IconName::Filter)
1983 .shape(IconButtonShape::Square)
1984 .tooltip(|window, cx| {
1985 Tooltip::for_action("Toggle Filters", &ToggleFilters, window, cx)
1986 })
1987 .on_click(cx.listener(|this, _, window, cx| {
1988 this.toggle_filters(window, cx);
1989 }))
1990 .toggle_state(
1991 self.active_project_search
1992 .as_ref()
1993 .map(|search| search.read(cx).filters_enabled)
1994 .unwrap_or_default(),
1995 )
1996 .tooltip({
1997 let focus_handle = focus_handle.clone();
1998 move |window, cx| {
1999 Tooltip::for_action_in(
2000 "Toggle Filters",
2001 &ToggleFilters,
2002 &focus_handle,
2003 window,
2004 cx,
2005 )
2006 }
2007 }),
2008 )
2009 .child(render_action_button(
2010 "project-search",
2011 IconName::Replace,
2012 self.active_project_search
2013 .as_ref()
2014 .map(|search| search.read(cx).replace_enabled)
2015 .unwrap_or_default(),
2016 "Toggle Replace",
2017 &ToggleReplace,
2018 focus_handle.clone(),
2019 ));
2020
2021 let query_focus = search.query_editor.focus_handle(cx);
2022
2023 let matches_column = h_flex()
2024 .pl_2()
2025 .ml_2()
2026 .border_l_1()
2027 .border_color(theme_colors.border_variant)
2028 .child(render_action_button(
2029 "project-search-nav-button",
2030 IconName::ChevronLeft,
2031 search.active_match_index.is_some(),
2032 "Select Previous Match",
2033 &SelectPreviousMatch,
2034 query_focus.clone(),
2035 ))
2036 .child(render_action_button(
2037 "project-search-nav-button",
2038 IconName::ChevronRight,
2039 search.active_match_index.is_some(),
2040 "Select Next Match",
2041 &SelectNextMatch,
2042 query_focus,
2043 ))
2044 .child(
2045 div()
2046 .id("matches")
2047 .ml_2()
2048 .min_w(rems_from_px(40.))
2049 .child(Label::new(match_text).size(LabelSize::Small).color(
2050 if search.active_match_index.is_some() {
2051 Color::Default
2052 } else {
2053 Color::Disabled
2054 },
2055 ))
2056 .when(limit_reached, |el| {
2057 el.tooltip(Tooltip::text(
2058 "Search limits reached.\nTry narrowing your search.",
2059 ))
2060 }),
2061 );
2062
2063 let search_line = h_flex()
2064 .w_full()
2065 .gap_2()
2066 .child(query_column)
2067 .child(h_flex().min_w_64().child(mode_column).child(matches_column));
2068
2069 let replace_line = search.replace_enabled.then(|| {
2070 let replace_column = input_base_styles(InputPanel::Replacement)
2071 .child(render_text_input(&search.replacement_editor, None, cx));
2072
2073 let focus_handle = search.replacement_editor.read(cx).focus_handle(cx);
2074
2075 let replace_actions = h_flex()
2076 .min_w_64()
2077 .gap_1()
2078 .child(render_action_button(
2079 "project-search-replace-button",
2080 IconName::ReplaceNext,
2081 true,
2082 "Replace Next Match",
2083 &ReplaceNext,
2084 focus_handle.clone(),
2085 ))
2086 .child(render_action_button(
2087 "project-search-replace-button",
2088 IconName::ReplaceAll,
2089 true,
2090 "Replace All Matches",
2091 &ReplaceAll,
2092 focus_handle,
2093 ));
2094
2095 h_flex()
2096 .w_full()
2097 .gap_2()
2098 .child(replace_column)
2099 .child(replace_actions)
2100 });
2101
2102 let filter_line = search.filters_enabled.then(|| {
2103 let include = input_base_styles(InputPanel::Include)
2104 .on_action(cx.listener(|this, action, window, cx| {
2105 this.previous_history_query(action, window, cx)
2106 }))
2107 .on_action(cx.listener(|this, action, window, cx| {
2108 this.next_history_query(action, window, cx)
2109 }))
2110 .child(render_text_input(&search.included_files_editor, None, cx));
2111 let exclude = input_base_styles(InputPanel::Exclude)
2112 .on_action(cx.listener(|this, action, window, cx| {
2113 this.previous_history_query(action, window, cx)
2114 }))
2115 .on_action(cx.listener(|this, action, window, cx| {
2116 this.next_history_query(action, window, cx)
2117 }))
2118 .child(render_text_input(&search.excluded_files_editor, None, cx));
2119 let mode_column = h_flex()
2120 .gap_1()
2121 .min_w_64()
2122 .child(
2123 IconButton::new("project-search-opened-only", IconName::FolderSearch)
2124 .shape(IconButtonShape::Square)
2125 .toggle_state(self.is_opened_only_enabled(cx))
2126 .tooltip(Tooltip::text("Only Search Open Files"))
2127 .on_click(cx.listener(|this, _, window, cx| {
2128 this.toggle_opened_only(window, cx);
2129 })),
2130 )
2131 .child(
2132 SearchOption::IncludeIgnored
2133 .as_button(search.search_options, focus_handle.clone()),
2134 );
2135 h_flex()
2136 .w_full()
2137 .gap_2()
2138 .child(
2139 h_flex()
2140 .gap_2()
2141 .w(input_width)
2142 .child(include)
2143 .child(exclude),
2144 )
2145 .child(mode_column)
2146 });
2147
2148 let mut key_context = KeyContext::default();
2149 key_context.add("ProjectSearchBar");
2150 if search
2151 .replacement_editor
2152 .focus_handle(cx)
2153 .is_focused(window)
2154 {
2155 key_context.add("in_replace");
2156 }
2157
2158 let query_error_line = search
2159 .panels_with_errors
2160 .get(&InputPanel::Query)
2161 .map(|error| {
2162 Label::new(error)
2163 .size(LabelSize::Small)
2164 .color(Color::Error)
2165 .mt_neg_1()
2166 .ml_2()
2167 });
2168
2169 let filter_error_line = search
2170 .panels_with_errors
2171 .get(&InputPanel::Include)
2172 .or_else(|| search.panels_with_errors.get(&InputPanel::Exclude))
2173 .map(|error| {
2174 Label::new(error)
2175 .size(LabelSize::Small)
2176 .color(Color::Error)
2177 .mt_neg_1()
2178 .ml_2()
2179 });
2180
2181 v_flex()
2182 .gap_2()
2183 .py(px(1.0))
2184 .w_full()
2185 .key_context(key_context)
2186 .on_action(cx.listener(|this, _: &ToggleFocus, window, cx| {
2187 this.move_focus_to_results(window, cx)
2188 }))
2189 .on_action(cx.listener(|this, _: &ToggleFilters, window, cx| {
2190 this.toggle_filters(window, cx);
2191 }))
2192 .capture_action(cx.listener(Self::tab))
2193 .capture_action(cx.listener(Self::backtab))
2194 .on_action(cx.listener(|this, action, window, cx| this.confirm(action, window, cx)))
2195 .on_action(cx.listener(|this, action, window, cx| {
2196 this.toggle_replace(action, window, cx);
2197 }))
2198 .on_action(cx.listener(|this, _: &ToggleWholeWord, window, cx| {
2199 this.toggle_search_option(SearchOptions::WHOLE_WORD, window, cx);
2200 }))
2201 .on_action(cx.listener(|this, _: &ToggleCaseSensitive, window, cx| {
2202 this.toggle_search_option(SearchOptions::CASE_SENSITIVE, window, cx);
2203 }))
2204 .on_action(cx.listener(|this, action, window, cx| {
2205 if let Some(search) = this.active_project_search.as_ref() {
2206 search.update(cx, |this, cx| {
2207 this.replace_next(action, window, cx);
2208 })
2209 }
2210 }))
2211 .on_action(cx.listener(|this, action, window, cx| {
2212 if let Some(search) = this.active_project_search.as_ref() {
2213 search.update(cx, |this, cx| {
2214 this.replace_all(action, window, cx);
2215 })
2216 }
2217 }))
2218 .when(search.filters_enabled, |this| {
2219 this.on_action(cx.listener(|this, _: &ToggleIncludeIgnored, window, cx| {
2220 this.toggle_search_option(SearchOptions::INCLUDE_IGNORED, window, cx);
2221 }))
2222 })
2223 .on_action(cx.listener(Self::select_next_match))
2224 .on_action(cx.listener(Self::select_prev_match))
2225 .child(search_line)
2226 .children(query_error_line)
2227 .children(replace_line)
2228 .children(filter_line)
2229 .children(filter_error_line)
2230 }
2231}
2232
2233impl EventEmitter<ToolbarItemEvent> for ProjectSearchBar {}
2234
2235impl ToolbarItemView for ProjectSearchBar {
2236 fn set_active_pane_item(
2237 &mut self,
2238 active_pane_item: Option<&dyn ItemHandle>,
2239 _: &mut Window,
2240 cx: &mut Context<Self>,
2241 ) -> ToolbarItemLocation {
2242 cx.notify();
2243 self.subscription = None;
2244 self.active_project_search = None;
2245 if let Some(search) = active_pane_item.and_then(|i| i.downcast::<ProjectSearchView>()) {
2246 self.subscription = Some(cx.observe(&search, |_, _, cx| cx.notify()));
2247 self.active_project_search = Some(search);
2248 ToolbarItemLocation::PrimaryLeft {}
2249 } else {
2250 ToolbarItemLocation::Hidden
2251 }
2252 }
2253}
2254
2255fn register_workspace_action<A: Action>(
2256 workspace: &mut Workspace,
2257 callback: fn(&mut ProjectSearchBar, &A, &mut Window, &mut Context<ProjectSearchBar>),
2258) {
2259 workspace.register_action(move |workspace, action: &A, window, cx| {
2260 if workspace.has_active_modal(window, cx) {
2261 cx.propagate();
2262 return;
2263 }
2264
2265 workspace.active_pane().update(cx, |pane, cx| {
2266 pane.toolbar().update(cx, move |workspace, cx| {
2267 if let Some(search_bar) = workspace.item_of_type::<ProjectSearchBar>() {
2268 search_bar.update(cx, move |search_bar, cx| {
2269 if search_bar.active_project_search.is_some() {
2270 callback(search_bar, action, window, cx);
2271 cx.notify();
2272 } else {
2273 cx.propagate();
2274 }
2275 });
2276 }
2277 });
2278 })
2279 });
2280}
2281
2282fn register_workspace_action_for_present_search<A: Action>(
2283 workspace: &mut Workspace,
2284 callback: fn(&mut Workspace, &A, &mut Window, &mut Context<Workspace>),
2285) {
2286 workspace.register_action(move |workspace, action: &A, window, cx| {
2287 if workspace.has_active_modal(window, cx) {
2288 cx.propagate();
2289 return;
2290 }
2291
2292 let should_notify = workspace
2293 .active_pane()
2294 .read(cx)
2295 .toolbar()
2296 .read(cx)
2297 .item_of_type::<ProjectSearchBar>()
2298 .map(|search_bar| search_bar.read(cx).active_project_search.is_some())
2299 .unwrap_or(false);
2300 if should_notify {
2301 callback(workspace, action, window, cx);
2302 cx.notify();
2303 } else {
2304 cx.propagate();
2305 }
2306 });
2307}
2308
2309#[cfg(any(test, feature = "test-support"))]
2310pub fn perform_project_search(
2311 search_view: &Entity<ProjectSearchView>,
2312 text: impl Into<std::sync::Arc<str>>,
2313 cx: &mut gpui::VisualTestContext,
2314) {
2315 cx.run_until_parked();
2316 search_view.update_in(cx, |search_view, window, cx| {
2317 search_view.query_editor.update(cx, |query_editor, cx| {
2318 query_editor.set_text(text, window, cx)
2319 });
2320 search_view.search(cx);
2321 });
2322 cx.run_until_parked();
2323}
2324
2325#[cfg(test)]
2326pub mod tests {
2327 use std::{ops::Deref as _, sync::Arc};
2328
2329 use super::*;
2330 use editor::{DisplayPoint, display_map::DisplayRow};
2331 use gpui::{Action, TestAppContext, VisualTestContext, WindowHandle};
2332 use project::FakeFs;
2333 use serde_json::json;
2334 use settings::SettingsStore;
2335 use util::path;
2336 use workspace::DeploySearch;
2337
2338 #[gpui::test]
2339 async fn test_project_search(cx: &mut TestAppContext) {
2340 init_test(cx);
2341
2342 let fs = FakeFs::new(cx.background_executor.clone());
2343 fs.insert_tree(
2344 path!("/dir"),
2345 json!({
2346 "one.rs": "const ONE: usize = 1;",
2347 "two.rs": "const TWO: usize = one::ONE + one::ONE;",
2348 "three.rs": "const THREE: usize = one::ONE + two::TWO;",
2349 "four.rs": "const FOUR: usize = one::ONE + three::THREE;",
2350 }),
2351 )
2352 .await;
2353 let project = Project::test(fs.clone(), [path!("/dir").as_ref()], cx).await;
2354 let window = cx.add_window(|window, cx| Workspace::test_new(project.clone(), window, cx));
2355 let workspace = window.root(cx).unwrap();
2356 let search = cx.new(|cx| ProjectSearch::new(project.clone(), cx));
2357 let search_view = cx.add_window(|window, cx| {
2358 ProjectSearchView::new(workspace.downgrade(), search.clone(), window, cx, None)
2359 });
2360
2361 perform_search(search_view, "TWO", cx);
2362 search_view.update(cx, |search_view, window, cx| {
2363 assert_eq!(
2364 search_view
2365 .results_editor
2366 .update(cx, |editor, cx| editor.display_text(cx)),
2367 "\n\nconst THREE: usize = one::ONE + two::TWO;\n\n\nconst TWO: usize = one::ONE + one::ONE;"
2368 );
2369 let match_background_color = cx.theme().colors().search_match_background;
2370 assert_eq!(
2371 search_view
2372 .results_editor
2373 .update(cx, |editor, cx| editor.all_text_background_highlights(window, cx)),
2374 &[
2375 (
2376 DisplayPoint::new(DisplayRow(2), 32)..DisplayPoint::new(DisplayRow(2), 35),
2377 match_background_color
2378 ),
2379 (
2380 DisplayPoint::new(DisplayRow(2), 37)..DisplayPoint::new(DisplayRow(2), 40),
2381 match_background_color
2382 ),
2383 (
2384 DisplayPoint::new(DisplayRow(5), 6)..DisplayPoint::new(DisplayRow(5), 9),
2385 match_background_color
2386 )
2387 ]
2388 );
2389 assert_eq!(search_view.active_match_index, Some(0));
2390 assert_eq!(
2391 search_view
2392 .results_editor
2393 .update(cx, |editor, cx| editor.selections.display_ranges(cx)),
2394 [DisplayPoint::new(DisplayRow(2), 32)..DisplayPoint::new(DisplayRow(2), 35)]
2395 );
2396
2397 search_view.select_match(Direction::Next, window, cx);
2398 }).unwrap();
2399
2400 search_view
2401 .update(cx, |search_view, window, cx| {
2402 assert_eq!(search_view.active_match_index, Some(1));
2403 assert_eq!(
2404 search_view
2405 .results_editor
2406 .update(cx, |editor, cx| editor.selections.display_ranges(cx)),
2407 [DisplayPoint::new(DisplayRow(2), 37)..DisplayPoint::new(DisplayRow(2), 40)]
2408 );
2409 search_view.select_match(Direction::Next, window, cx);
2410 })
2411 .unwrap();
2412
2413 search_view
2414 .update(cx, |search_view, window, cx| {
2415 assert_eq!(search_view.active_match_index, Some(2));
2416 assert_eq!(
2417 search_view
2418 .results_editor
2419 .update(cx, |editor, cx| editor.selections.display_ranges(cx)),
2420 [DisplayPoint::new(DisplayRow(5), 6)..DisplayPoint::new(DisplayRow(5), 9)]
2421 );
2422 search_view.select_match(Direction::Next, window, cx);
2423 })
2424 .unwrap();
2425
2426 search_view
2427 .update(cx, |search_view, window, cx| {
2428 assert_eq!(search_view.active_match_index, Some(0));
2429 assert_eq!(
2430 search_view
2431 .results_editor
2432 .update(cx, |editor, cx| editor.selections.display_ranges(cx)),
2433 [DisplayPoint::new(DisplayRow(2), 32)..DisplayPoint::new(DisplayRow(2), 35)]
2434 );
2435 search_view.select_match(Direction::Prev, window, cx);
2436 })
2437 .unwrap();
2438
2439 search_view
2440 .update(cx, |search_view, window, cx| {
2441 assert_eq!(search_view.active_match_index, Some(2));
2442 assert_eq!(
2443 search_view
2444 .results_editor
2445 .update(cx, |editor, cx| editor.selections.display_ranges(cx)),
2446 [DisplayPoint::new(DisplayRow(5), 6)..DisplayPoint::new(DisplayRow(5), 9)]
2447 );
2448 search_view.select_match(Direction::Prev, window, cx);
2449 })
2450 .unwrap();
2451
2452 search_view
2453 .update(cx, |search_view, _, cx| {
2454 assert_eq!(search_view.active_match_index, Some(1));
2455 assert_eq!(
2456 search_view
2457 .results_editor
2458 .update(cx, |editor, cx| editor.selections.display_ranges(cx)),
2459 [DisplayPoint::new(DisplayRow(2), 37)..DisplayPoint::new(DisplayRow(2), 40)]
2460 );
2461 })
2462 .unwrap();
2463 }
2464
2465 #[gpui::test]
2466 async fn test_deploy_project_search_focus(cx: &mut TestAppContext) {
2467 init_test(cx);
2468
2469 let fs = FakeFs::new(cx.background_executor.clone());
2470 fs.insert_tree(
2471 "/dir",
2472 json!({
2473 "one.rs": "const ONE: usize = 1;",
2474 "two.rs": "const TWO: usize = one::ONE + one::ONE;",
2475 "three.rs": "const THREE: usize = one::ONE + two::TWO;",
2476 "four.rs": "const FOUR: usize = one::ONE + three::THREE;",
2477 }),
2478 )
2479 .await;
2480 let project = Project::test(fs.clone(), ["/dir".as_ref()], cx).await;
2481 let window = cx.add_window(|window, cx| Workspace::test_new(project, window, cx));
2482 let workspace = window;
2483 let search_bar = window.build_entity(cx, |_, _| ProjectSearchBar::new());
2484
2485 let active_item = cx.read(|cx| {
2486 workspace
2487 .read(cx)
2488 .unwrap()
2489 .active_pane()
2490 .read(cx)
2491 .active_item()
2492 .and_then(|item| item.downcast::<ProjectSearchView>())
2493 });
2494 assert!(
2495 active_item.is_none(),
2496 "Expected no search panel to be active"
2497 );
2498
2499 window
2500 .update(cx, move |workspace, window, cx| {
2501 assert_eq!(workspace.panes().len(), 1);
2502 workspace.panes()[0].update(cx, |pane, cx| {
2503 pane.toolbar()
2504 .update(cx, |toolbar, cx| toolbar.add_item(search_bar, window, cx))
2505 });
2506
2507 ProjectSearchView::deploy_search(
2508 workspace,
2509 &workspace::DeploySearch::find(),
2510 window,
2511 cx,
2512 )
2513 })
2514 .unwrap();
2515
2516 let Some(search_view) = cx.read(|cx| {
2517 workspace
2518 .read(cx)
2519 .unwrap()
2520 .active_pane()
2521 .read(cx)
2522 .active_item()
2523 .and_then(|item| item.downcast::<ProjectSearchView>())
2524 }) else {
2525 panic!("Search view expected to appear after new search event trigger")
2526 };
2527
2528 cx.spawn(|mut cx| async move {
2529 window
2530 .update(&mut cx, |_, window, cx| {
2531 window.dispatch_action(ToggleFocus.boxed_clone(), cx)
2532 })
2533 .unwrap();
2534 })
2535 .detach();
2536 cx.background_executor.run_until_parked();
2537 window
2538 .update(cx, |_, window, cx| {
2539 search_view.update(cx, |search_view, cx| {
2540 assert!(
2541 search_view.query_editor.focus_handle(cx).is_focused(window),
2542 "Empty search view should be focused after the toggle focus event: no results panel to focus on",
2543 );
2544 });
2545 }).unwrap();
2546
2547 window
2548 .update(cx, |_, window, cx| {
2549 search_view.update(cx, |search_view, cx| {
2550 let query_editor = &search_view.query_editor;
2551 assert!(
2552 query_editor.focus_handle(cx).is_focused(window),
2553 "Search view should be focused after the new search view is activated",
2554 );
2555 let query_text = query_editor.read(cx).text(cx);
2556 assert!(
2557 query_text.is_empty(),
2558 "New search query should be empty but got '{query_text}'",
2559 );
2560 let results_text = search_view
2561 .results_editor
2562 .update(cx, |editor, cx| editor.display_text(cx));
2563 assert!(
2564 results_text.is_empty(),
2565 "Empty search view should have no results but got '{results_text}'"
2566 );
2567 });
2568 })
2569 .unwrap();
2570
2571 window
2572 .update(cx, |_, window, cx| {
2573 search_view.update(cx, |search_view, cx| {
2574 search_view.query_editor.update(cx, |query_editor, cx| {
2575 query_editor.set_text("sOMETHINGtHATsURELYdOESnOTeXIST", window, cx)
2576 });
2577 search_view.search(cx);
2578 });
2579 })
2580 .unwrap();
2581 cx.background_executor.run_until_parked();
2582 window
2583 .update(cx, |_, window, cx| {
2584 search_view.update(cx, |search_view, cx| {
2585 let results_text = search_view
2586 .results_editor
2587 .update(cx, |editor, cx| editor.display_text(cx));
2588 assert!(
2589 results_text.is_empty(),
2590 "Search view for mismatching query should have no results but got '{results_text}'"
2591 );
2592 assert!(
2593 search_view.query_editor.focus_handle(cx).is_focused(window),
2594 "Search view should be focused after mismatching query had been used in search",
2595 );
2596 });
2597 }).unwrap();
2598
2599 cx.spawn(|mut cx| async move {
2600 window.update(&mut cx, |_, window, cx| {
2601 window.dispatch_action(ToggleFocus.boxed_clone(), cx)
2602 })
2603 })
2604 .detach();
2605 cx.background_executor.run_until_parked();
2606 window.update(cx, |_, window, cx| {
2607 search_view.update(cx, |search_view, cx| {
2608 assert!(
2609 search_view.query_editor.focus_handle(cx).is_focused(window),
2610 "Search view with mismatching query should be focused after the toggle focus event: still no results panel to focus on",
2611 );
2612 });
2613 }).unwrap();
2614
2615 window
2616 .update(cx, |_, window, cx| {
2617 search_view.update(cx, |search_view, cx| {
2618 search_view.query_editor.update(cx, |query_editor, cx| {
2619 query_editor.set_text("TWO", window, cx)
2620 });
2621 search_view.search(cx);
2622 });
2623 })
2624 .unwrap();
2625 cx.background_executor.run_until_parked();
2626 window.update(cx, |_, window, cx| {
2627 search_view.update(cx, |search_view, cx| {
2628 assert_eq!(
2629 search_view
2630 .results_editor
2631 .update(cx, |editor, cx| editor.display_text(cx)),
2632 "\n\nconst THREE: usize = one::ONE + two::TWO;\n\n\nconst TWO: usize = one::ONE + one::ONE;",
2633 "Search view results should match the query"
2634 );
2635 assert!(
2636 search_view.results_editor.focus_handle(cx).is_focused(window),
2637 "Search view with mismatching query should be focused after search results are available",
2638 );
2639 });
2640 }).unwrap();
2641 cx.spawn(|mut cx| async move {
2642 window
2643 .update(&mut cx, |_, window, cx| {
2644 window.dispatch_action(ToggleFocus.boxed_clone(), cx)
2645 })
2646 .unwrap();
2647 })
2648 .detach();
2649 cx.background_executor.run_until_parked();
2650 window.update(cx, |_, window, cx| {
2651 search_view.update(cx, |search_view, cx| {
2652 assert!(
2653 search_view.results_editor.focus_handle(cx).is_focused(window),
2654 "Search view with matching query should still have its results editor focused after the toggle focus event",
2655 );
2656 });
2657 }).unwrap();
2658
2659 workspace
2660 .update(cx, |workspace, window, cx| {
2661 ProjectSearchView::deploy_search(
2662 workspace,
2663 &workspace::DeploySearch::find(),
2664 window,
2665 cx,
2666 )
2667 })
2668 .unwrap();
2669 window.update(cx, |_, window, cx| {
2670 search_view.update(cx, |search_view, cx| {
2671 assert_eq!(search_view.query_editor.read(cx).text(cx), "two", "Query should be updated to first search result after search view 2nd open in a row");
2672 assert_eq!(
2673 search_view
2674 .results_editor
2675 .update(cx, |editor, cx| editor.display_text(cx)),
2676 "\n\nconst THREE: usize = one::ONE + two::TWO;\n\n\nconst TWO: usize = one::ONE + one::ONE;",
2677 "Results should be unchanged after search view 2nd open in a row"
2678 );
2679 assert!(
2680 search_view.query_editor.focus_handle(cx).is_focused(window),
2681 "Focus should be moved into query editor again after search view 2nd open in a row"
2682 );
2683 });
2684 }).unwrap();
2685
2686 cx.spawn(|mut cx| async move {
2687 window
2688 .update(&mut cx, |_, window, cx| {
2689 window.dispatch_action(ToggleFocus.boxed_clone(), cx)
2690 })
2691 .unwrap();
2692 })
2693 .detach();
2694 cx.background_executor.run_until_parked();
2695 window.update(cx, |_, window, cx| {
2696 search_view.update(cx, |search_view, cx| {
2697 assert!(
2698 search_view.results_editor.focus_handle(cx).is_focused(window),
2699 "Search view with matching query should switch focus to the results editor after the toggle focus event",
2700 );
2701 });
2702 }).unwrap();
2703 }
2704
2705 #[gpui::test]
2706 async fn test_filters_consider_toggle_state(cx: &mut TestAppContext) {
2707 init_test(cx);
2708
2709 let fs = FakeFs::new(cx.background_executor.clone());
2710 fs.insert_tree(
2711 "/dir",
2712 json!({
2713 "one.rs": "const ONE: usize = 1;",
2714 "two.rs": "const TWO: usize = one::ONE + one::ONE;",
2715 "three.rs": "const THREE: usize = one::ONE + two::TWO;",
2716 "four.rs": "const FOUR: usize = one::ONE + three::THREE;",
2717 }),
2718 )
2719 .await;
2720 let project = Project::test(fs.clone(), ["/dir".as_ref()], cx).await;
2721 let window = cx.add_window(|window, cx| Workspace::test_new(project, window, cx));
2722 let workspace = window;
2723 let search_bar = window.build_entity(cx, |_, _| ProjectSearchBar::new());
2724
2725 window
2726 .update(cx, move |workspace, window, cx| {
2727 workspace.panes()[0].update(cx, |pane, cx| {
2728 pane.toolbar()
2729 .update(cx, |toolbar, cx| toolbar.add_item(search_bar, window, cx))
2730 });
2731
2732 ProjectSearchView::deploy_search(
2733 workspace,
2734 &workspace::DeploySearch::find(),
2735 window,
2736 cx,
2737 )
2738 })
2739 .unwrap();
2740
2741 let Some(search_view) = cx.read(|cx| {
2742 workspace
2743 .read(cx)
2744 .unwrap()
2745 .active_pane()
2746 .read(cx)
2747 .active_item()
2748 .and_then(|item| item.downcast::<ProjectSearchView>())
2749 }) else {
2750 panic!("Search view expected to appear after new search event trigger")
2751 };
2752
2753 cx.spawn(|mut cx| async move {
2754 window
2755 .update(&mut cx, |_, window, cx| {
2756 window.dispatch_action(ToggleFocus.boxed_clone(), cx)
2757 })
2758 .unwrap();
2759 })
2760 .detach();
2761 cx.background_executor.run_until_parked();
2762
2763 window
2764 .update(cx, |_, window, cx| {
2765 search_view.update(cx, |search_view, cx| {
2766 search_view.query_editor.update(cx, |query_editor, cx| {
2767 query_editor.set_text("const FOUR", window, cx)
2768 });
2769 search_view.toggle_filters(cx);
2770 search_view
2771 .excluded_files_editor
2772 .update(cx, |exclude_editor, cx| {
2773 exclude_editor.set_text("four.rs", window, cx)
2774 });
2775 search_view.search(cx);
2776 });
2777 })
2778 .unwrap();
2779 cx.background_executor.run_until_parked();
2780 window
2781 .update(cx, |_, _, cx| {
2782 search_view.update(cx, |search_view, cx| {
2783 let results_text = search_view
2784 .results_editor
2785 .update(cx, |editor, cx| editor.display_text(cx));
2786 assert!(
2787 results_text.is_empty(),
2788 "Search view for query with the only match in an excluded file should have no results but got '{results_text}'"
2789 );
2790 });
2791 }).unwrap();
2792
2793 cx.spawn(|mut cx| async move {
2794 window.update(&mut cx, |_, window, cx| {
2795 window.dispatch_action(ToggleFocus.boxed_clone(), cx)
2796 })
2797 })
2798 .detach();
2799 cx.background_executor.run_until_parked();
2800
2801 window
2802 .update(cx, |_, _, cx| {
2803 search_view.update(cx, |search_view, cx| {
2804 search_view.toggle_filters(cx);
2805 search_view.search(cx);
2806 });
2807 })
2808 .unwrap();
2809 cx.background_executor.run_until_parked();
2810 window
2811 .update(cx, |_, _, cx| {
2812 search_view.update(cx, |search_view, cx| {
2813 assert_eq!(
2814 search_view
2815 .results_editor
2816 .update(cx, |editor, cx| editor.display_text(cx)),
2817 "\n\nconst FOUR: usize = one::ONE + three::THREE;",
2818 "Search view results should contain the queried result in the previously excluded file with filters toggled off"
2819 );
2820 });
2821 })
2822 .unwrap();
2823 }
2824
2825 #[gpui::test]
2826 async fn test_new_project_search_focus(cx: &mut TestAppContext) {
2827 init_test(cx);
2828
2829 let fs = FakeFs::new(cx.background_executor.clone());
2830 fs.insert_tree(
2831 path!("/dir"),
2832 json!({
2833 "one.rs": "const ONE: usize = 1;",
2834 "two.rs": "const TWO: usize = one::ONE + one::ONE;",
2835 "three.rs": "const THREE: usize = one::ONE + two::TWO;",
2836 "four.rs": "const FOUR: usize = one::ONE + three::THREE;",
2837 }),
2838 )
2839 .await;
2840 let project = Project::test(fs.clone(), [path!("/dir").as_ref()], cx).await;
2841 let window = cx.add_window(|window, cx| Workspace::test_new(project, window, cx));
2842 let workspace = window;
2843 let search_bar = window.build_entity(cx, |_, _| ProjectSearchBar::new());
2844
2845 let active_item = cx.read(|cx| {
2846 workspace
2847 .read(cx)
2848 .unwrap()
2849 .active_pane()
2850 .read(cx)
2851 .active_item()
2852 .and_then(|item| item.downcast::<ProjectSearchView>())
2853 });
2854 assert!(
2855 active_item.is_none(),
2856 "Expected no search panel to be active"
2857 );
2858
2859 window
2860 .update(cx, move |workspace, window, cx| {
2861 assert_eq!(workspace.panes().len(), 1);
2862 workspace.panes()[0].update(cx, |pane, cx| {
2863 pane.toolbar()
2864 .update(cx, |toolbar, cx| toolbar.add_item(search_bar, window, cx))
2865 });
2866
2867 ProjectSearchView::new_search(workspace, &workspace::NewSearch, window, cx)
2868 })
2869 .unwrap();
2870
2871 let Some(search_view) = cx.read(|cx| {
2872 workspace
2873 .read(cx)
2874 .unwrap()
2875 .active_pane()
2876 .read(cx)
2877 .active_item()
2878 .and_then(|item| item.downcast::<ProjectSearchView>())
2879 }) else {
2880 panic!("Search view expected to appear after new search event trigger")
2881 };
2882
2883 cx.spawn(|mut cx| async move {
2884 window
2885 .update(&mut cx, |_, window, cx| {
2886 window.dispatch_action(ToggleFocus.boxed_clone(), cx)
2887 })
2888 .unwrap();
2889 })
2890 .detach();
2891 cx.background_executor.run_until_parked();
2892
2893 window.update(cx, |_, window, cx| {
2894 search_view.update(cx, |search_view, cx| {
2895 assert!(
2896 search_view.query_editor.focus_handle(cx).is_focused(window),
2897 "Empty search view should be focused after the toggle focus event: no results panel to focus on",
2898 );
2899 });
2900 }).unwrap();
2901
2902 window
2903 .update(cx, |_, window, cx| {
2904 search_view.update(cx, |search_view, cx| {
2905 let query_editor = &search_view.query_editor;
2906 assert!(
2907 query_editor.focus_handle(cx).is_focused(window),
2908 "Search view should be focused after the new search view is activated",
2909 );
2910 let query_text = query_editor.read(cx).text(cx);
2911 assert!(
2912 query_text.is_empty(),
2913 "New search query should be empty but got '{query_text}'",
2914 );
2915 let results_text = search_view
2916 .results_editor
2917 .update(cx, |editor, cx| editor.display_text(cx));
2918 assert!(
2919 results_text.is_empty(),
2920 "Empty search view should have no results but got '{results_text}'"
2921 );
2922 });
2923 })
2924 .unwrap();
2925
2926 window
2927 .update(cx, |_, window, cx| {
2928 search_view.update(cx, |search_view, cx| {
2929 search_view.query_editor.update(cx, |query_editor, cx| {
2930 query_editor.set_text("sOMETHINGtHATsURELYdOESnOTeXIST", window, cx)
2931 });
2932 search_view.search(cx);
2933 });
2934 })
2935 .unwrap();
2936
2937 cx.background_executor.run_until_parked();
2938 window
2939 .update(cx, |_, window, cx| {
2940 search_view.update(cx, |search_view, cx| {
2941 let results_text = search_view
2942 .results_editor
2943 .update(cx, |editor, cx| editor.display_text(cx));
2944 assert!(
2945 results_text.is_empty(),
2946 "Search view for mismatching query should have no results but got '{results_text}'"
2947 );
2948 assert!(
2949 search_view.query_editor.focus_handle(cx).is_focused(window),
2950 "Search view should be focused after mismatching query had been used in search",
2951 );
2952 });
2953 })
2954 .unwrap();
2955 cx.spawn(|mut cx| async move {
2956 window.update(&mut cx, |_, window, cx| {
2957 window.dispatch_action(ToggleFocus.boxed_clone(), cx)
2958 })
2959 })
2960 .detach();
2961 cx.background_executor.run_until_parked();
2962 window.update(cx, |_, window, cx| {
2963 search_view.update(cx, |search_view, cx| {
2964 assert!(
2965 search_view.query_editor.focus_handle(cx).is_focused(window),
2966 "Search view with mismatching query should be focused after the toggle focus event: still no results panel to focus on",
2967 );
2968 });
2969 }).unwrap();
2970
2971 window
2972 .update(cx, |_, window, cx| {
2973 search_view.update(cx, |search_view, cx| {
2974 search_view.query_editor.update(cx, |query_editor, cx| {
2975 query_editor.set_text("TWO", window, cx)
2976 });
2977 search_view.search(cx);
2978 })
2979 })
2980 .unwrap();
2981 cx.background_executor.run_until_parked();
2982 window.update(cx, |_, window, cx|
2983 search_view.update(cx, |search_view, cx| {
2984 assert_eq!(
2985 search_view
2986 .results_editor
2987 .update(cx, |editor, cx| editor.display_text(cx)),
2988 "\n\nconst THREE: usize = one::ONE + two::TWO;\n\n\nconst TWO: usize = one::ONE + one::ONE;",
2989 "Search view results should match the query"
2990 );
2991 assert!(
2992 search_view.results_editor.focus_handle(cx).is_focused(window),
2993 "Search view with mismatching query should be focused after search results are available",
2994 );
2995 })).unwrap();
2996 cx.spawn(|mut cx| async move {
2997 window
2998 .update(&mut cx, |_, window, cx| {
2999 window.dispatch_action(ToggleFocus.boxed_clone(), cx)
3000 })
3001 .unwrap();
3002 })
3003 .detach();
3004 cx.background_executor.run_until_parked();
3005 window.update(cx, |_, window, cx| {
3006 search_view.update(cx, |search_view, cx| {
3007 assert!(
3008 search_view.results_editor.focus_handle(cx).is_focused(window),
3009 "Search view with matching query should still have its results editor focused after the toggle focus event",
3010 );
3011 });
3012 }).unwrap();
3013
3014 workspace
3015 .update(cx, |workspace, window, cx| {
3016 ProjectSearchView::new_search(workspace, &workspace::NewSearch, window, cx)
3017 })
3018 .unwrap();
3019 cx.background_executor.run_until_parked();
3020 let Some(search_view_2) = cx.read(|cx| {
3021 workspace
3022 .read(cx)
3023 .unwrap()
3024 .active_pane()
3025 .read(cx)
3026 .active_item()
3027 .and_then(|item| item.downcast::<ProjectSearchView>())
3028 }) else {
3029 panic!("Search view expected to appear after new search event trigger")
3030 };
3031 assert!(
3032 search_view_2 != search_view,
3033 "New search view should be open after `workspace::NewSearch` event"
3034 );
3035
3036 window.update(cx, |_, window, cx| {
3037 search_view.update(cx, |search_view, cx| {
3038 assert_eq!(search_view.query_editor.read(cx).text(cx), "TWO", "First search view should not have an updated query");
3039 assert_eq!(
3040 search_view
3041 .results_editor
3042 .update(cx, |editor, cx| editor.display_text(cx)),
3043 "\n\nconst THREE: usize = one::ONE + two::TWO;\n\n\nconst TWO: usize = one::ONE + one::ONE;",
3044 "Results of the first search view should not update too"
3045 );
3046 assert!(
3047 !search_view.query_editor.focus_handle(cx).is_focused(window),
3048 "Focus should be moved away from the first search view"
3049 );
3050 });
3051 }).unwrap();
3052
3053 window.update(cx, |_, window, cx| {
3054 search_view_2.update(cx, |search_view_2, cx| {
3055 assert_eq!(
3056 search_view_2.query_editor.read(cx).text(cx),
3057 "two",
3058 "New search view should get the query from the text cursor was at during the event spawn (first search view's first result)"
3059 );
3060 assert_eq!(
3061 search_view_2
3062 .results_editor
3063 .update(cx, |editor, cx| editor.display_text(cx)),
3064 "",
3065 "No search results should be in the 2nd view yet, as we did not spawn a search for it"
3066 );
3067 assert!(
3068 search_view_2.query_editor.focus_handle(cx).is_focused(window),
3069 "Focus should be moved into query editor of the new window"
3070 );
3071 });
3072 }).unwrap();
3073
3074 window
3075 .update(cx, |_, window, cx| {
3076 search_view_2.update(cx, |search_view_2, cx| {
3077 search_view_2.query_editor.update(cx, |query_editor, cx| {
3078 query_editor.set_text("FOUR", window, cx)
3079 });
3080 search_view_2.search(cx);
3081 });
3082 })
3083 .unwrap();
3084
3085 cx.background_executor.run_until_parked();
3086 window.update(cx, |_, window, cx| {
3087 search_view_2.update(cx, |search_view_2, cx| {
3088 assert_eq!(
3089 search_view_2
3090 .results_editor
3091 .update(cx, |editor, cx| editor.display_text(cx)),
3092 "\n\nconst FOUR: usize = one::ONE + three::THREE;",
3093 "New search view with the updated query should have new search results"
3094 );
3095 assert!(
3096 search_view_2.results_editor.focus_handle(cx).is_focused(window),
3097 "Search view with mismatching query should be focused after search results are available",
3098 );
3099 });
3100 }).unwrap();
3101
3102 cx.spawn(|mut cx| async move {
3103 window
3104 .update(&mut cx, |_, window, cx| {
3105 window.dispatch_action(ToggleFocus.boxed_clone(), cx)
3106 })
3107 .unwrap();
3108 })
3109 .detach();
3110 cx.background_executor.run_until_parked();
3111 window.update(cx, |_, window, cx| {
3112 search_view_2.update(cx, |search_view_2, cx| {
3113 assert!(
3114 search_view_2.results_editor.focus_handle(cx).is_focused(window),
3115 "Search view with matching query should switch focus to the results editor after the toggle focus event",
3116 );
3117 });}).unwrap();
3118 }
3119
3120 #[gpui::test]
3121 async fn test_new_project_search_in_directory(cx: &mut TestAppContext) {
3122 init_test(cx);
3123
3124 let fs = FakeFs::new(cx.background_executor.clone());
3125 fs.insert_tree(
3126 path!("/dir"),
3127 json!({
3128 "a": {
3129 "one.rs": "const ONE: usize = 1;",
3130 "two.rs": "const TWO: usize = one::ONE + one::ONE;",
3131 },
3132 "b": {
3133 "three.rs": "const THREE: usize = one::ONE + two::TWO;",
3134 "four.rs": "const FOUR: usize = one::ONE + three::THREE;",
3135 },
3136 }),
3137 )
3138 .await;
3139 let project = Project::test(fs.clone(), ["/dir".as_ref()], cx).await;
3140 let worktree_id = project.read_with(cx, |project, cx| {
3141 project.worktrees(cx).next().unwrap().read(cx).id()
3142 });
3143 let window = cx.add_window(|window, cx| Workspace::test_new(project, window, cx));
3144 let workspace = window.root(cx).unwrap();
3145 let search_bar = window.build_entity(cx, |_, _| ProjectSearchBar::new());
3146
3147 let active_item = cx.read(|cx| {
3148 workspace
3149 .read(cx)
3150 .active_pane()
3151 .read(cx)
3152 .active_item()
3153 .and_then(|item| item.downcast::<ProjectSearchView>())
3154 });
3155 assert!(
3156 active_item.is_none(),
3157 "Expected no search panel to be active"
3158 );
3159
3160 window
3161 .update(cx, move |workspace, window, cx| {
3162 assert_eq!(workspace.panes().len(), 1);
3163 workspace.panes()[0].update(cx, move |pane, cx| {
3164 pane.toolbar()
3165 .update(cx, |toolbar, cx| toolbar.add_item(search_bar, window, cx))
3166 });
3167 })
3168 .unwrap();
3169
3170 let a_dir_entry = cx.update(|cx| {
3171 workspace
3172 .read(cx)
3173 .project()
3174 .read(cx)
3175 .entry_for_path(&(worktree_id, "a").into(), cx)
3176 .expect("no entry for /a/ directory")
3177 });
3178 assert!(a_dir_entry.is_dir());
3179 window
3180 .update(cx, |workspace, window, cx| {
3181 ProjectSearchView::new_search_in_directory(workspace, &a_dir_entry.path, window, cx)
3182 })
3183 .unwrap();
3184
3185 let Some(search_view) = cx.read(|cx| {
3186 workspace
3187 .read(cx)
3188 .active_pane()
3189 .read(cx)
3190 .active_item()
3191 .and_then(|item| item.downcast::<ProjectSearchView>())
3192 }) else {
3193 panic!("Search view expected to appear after new search in directory event trigger")
3194 };
3195 cx.background_executor.run_until_parked();
3196 window
3197 .update(cx, |_, window, cx| {
3198 search_view.update(cx, |search_view, cx| {
3199 assert!(
3200 search_view.query_editor.focus_handle(cx).is_focused(window),
3201 "On new search in directory, focus should be moved into query editor"
3202 );
3203 search_view.excluded_files_editor.update(cx, |editor, cx| {
3204 assert!(
3205 editor.display_text(cx).is_empty(),
3206 "New search in directory should not have any excluded files"
3207 );
3208 });
3209 search_view.included_files_editor.update(cx, |editor, cx| {
3210 assert_eq!(
3211 editor.display_text(cx),
3212 a_dir_entry.path.to_str().unwrap(),
3213 "New search in directory should have included dir entry path"
3214 );
3215 });
3216 });
3217 })
3218 .unwrap();
3219 window
3220 .update(cx, |_, window, cx| {
3221 search_view.update(cx, |search_view, cx| {
3222 search_view.query_editor.update(cx, |query_editor, cx| {
3223 query_editor.set_text("const", window, cx)
3224 });
3225 search_view.search(cx);
3226 });
3227 })
3228 .unwrap();
3229 cx.background_executor.run_until_parked();
3230 window
3231 .update(cx, |_, _, cx| {
3232 search_view.update(cx, |search_view, cx| {
3233 assert_eq!(
3234 search_view
3235 .results_editor
3236 .update(cx, |editor, cx| editor.display_text(cx)),
3237 "\n\nconst ONE: usize = 1;\n\n\nconst TWO: usize = one::ONE + one::ONE;",
3238 "New search in directory should have a filter that matches a certain directory"
3239 );
3240 })
3241 })
3242 .unwrap();
3243 }
3244
3245 #[gpui::test]
3246 async fn test_search_query_history(cx: &mut TestAppContext) {
3247 init_test(cx);
3248
3249 let fs = FakeFs::new(cx.background_executor.clone());
3250 fs.insert_tree(
3251 path!("/dir"),
3252 json!({
3253 "one.rs": "const ONE: usize = 1;",
3254 "two.rs": "const TWO: usize = one::ONE + one::ONE;",
3255 "three.rs": "const THREE: usize = one::ONE + two::TWO;",
3256 "four.rs": "const FOUR: usize = one::ONE + three::THREE;",
3257 }),
3258 )
3259 .await;
3260 let project = Project::test(fs.clone(), [path!("/dir").as_ref()], cx).await;
3261 let window = cx.add_window(|window, cx| Workspace::test_new(project, window, cx));
3262 let workspace = window.root(cx).unwrap();
3263 let search_bar = window.build_entity(cx, |_, _| ProjectSearchBar::new());
3264
3265 window
3266 .update(cx, {
3267 let search_bar = search_bar.clone();
3268 |workspace, window, cx| {
3269 assert_eq!(workspace.panes().len(), 1);
3270 workspace.panes()[0].update(cx, |pane, cx| {
3271 pane.toolbar()
3272 .update(cx, |toolbar, cx| toolbar.add_item(search_bar, window, cx))
3273 });
3274
3275 ProjectSearchView::new_search(workspace, &workspace::NewSearch, window, cx)
3276 }
3277 })
3278 .unwrap();
3279
3280 let search_view = cx.read(|cx| {
3281 workspace
3282 .read(cx)
3283 .active_pane()
3284 .read(cx)
3285 .active_item()
3286 .and_then(|item| item.downcast::<ProjectSearchView>())
3287 .expect("Search view expected to appear after new search event trigger")
3288 });
3289
3290 // Add 3 search items into the history + another unsubmitted one.
3291 window
3292 .update(cx, |_, window, cx| {
3293 search_view.update(cx, |search_view, cx| {
3294 search_view.search_options = SearchOptions::CASE_SENSITIVE;
3295 search_view.query_editor.update(cx, |query_editor, cx| {
3296 query_editor.set_text("ONE", window, cx)
3297 });
3298 search_view.search(cx);
3299 });
3300 })
3301 .unwrap();
3302
3303 cx.background_executor.run_until_parked();
3304 window
3305 .update(cx, |_, window, cx| {
3306 search_view.update(cx, |search_view, cx| {
3307 search_view.query_editor.update(cx, |query_editor, cx| {
3308 query_editor.set_text("TWO", window, cx)
3309 });
3310 search_view.search(cx);
3311 });
3312 })
3313 .unwrap();
3314 cx.background_executor.run_until_parked();
3315 window
3316 .update(cx, |_, window, cx| {
3317 search_view.update(cx, |search_view, cx| {
3318 search_view.query_editor.update(cx, |query_editor, cx| {
3319 query_editor.set_text("THREE", window, cx)
3320 });
3321 search_view.search(cx);
3322 })
3323 })
3324 .unwrap();
3325 cx.background_executor.run_until_parked();
3326 window
3327 .update(cx, |_, window, cx| {
3328 search_view.update(cx, |search_view, cx| {
3329 search_view.query_editor.update(cx, |query_editor, cx| {
3330 query_editor.set_text("JUST_TEXT_INPUT", window, cx)
3331 });
3332 })
3333 })
3334 .unwrap();
3335 cx.background_executor.run_until_parked();
3336
3337 // Ensure that the latest input with search settings is active.
3338 window
3339 .update(cx, |_, _, cx| {
3340 search_view.update(cx, |search_view, cx| {
3341 assert_eq!(
3342 search_view.query_editor.read(cx).text(cx),
3343 "JUST_TEXT_INPUT"
3344 );
3345 assert_eq!(search_view.search_options, SearchOptions::CASE_SENSITIVE);
3346 });
3347 })
3348 .unwrap();
3349
3350 // Next history query after the latest should set the query to the empty string.
3351 window
3352 .update(cx, |_, window, cx| {
3353 search_bar.update(cx, |search_bar, cx| {
3354 search_bar.focus_search(window, cx);
3355 search_bar.next_history_query(&NextHistoryQuery, window, cx);
3356 })
3357 })
3358 .unwrap();
3359 window
3360 .update(cx, |_, _, cx| {
3361 search_view.update(cx, |search_view, cx| {
3362 assert_eq!(search_view.query_editor.read(cx).text(cx), "");
3363 assert_eq!(search_view.search_options, SearchOptions::CASE_SENSITIVE);
3364 });
3365 })
3366 .unwrap();
3367 window
3368 .update(cx, |_, window, cx| {
3369 search_bar.update(cx, |search_bar, cx| {
3370 search_bar.focus_search(window, cx);
3371 search_bar.next_history_query(&NextHistoryQuery, window, cx);
3372 })
3373 })
3374 .unwrap();
3375 window
3376 .update(cx, |_, _, cx| {
3377 search_view.update(cx, |search_view, cx| {
3378 assert_eq!(search_view.query_editor.read(cx).text(cx), "");
3379 assert_eq!(search_view.search_options, SearchOptions::CASE_SENSITIVE);
3380 });
3381 })
3382 .unwrap();
3383
3384 // First previous query for empty current query should set the query to the latest submitted one.
3385 window
3386 .update(cx, |_, window, cx| {
3387 search_bar.update(cx, |search_bar, cx| {
3388 search_bar.focus_search(window, cx);
3389 search_bar.previous_history_query(&PreviousHistoryQuery, window, cx);
3390 });
3391 })
3392 .unwrap();
3393 window
3394 .update(cx, |_, _, cx| {
3395 search_view.update(cx, |search_view, cx| {
3396 assert_eq!(search_view.query_editor.read(cx).text(cx), "THREE");
3397 assert_eq!(search_view.search_options, SearchOptions::CASE_SENSITIVE);
3398 });
3399 })
3400 .unwrap();
3401
3402 // Further previous items should go over the history in reverse order.
3403 window
3404 .update(cx, |_, window, cx| {
3405 search_bar.update(cx, |search_bar, cx| {
3406 search_bar.focus_search(window, cx);
3407 search_bar.previous_history_query(&PreviousHistoryQuery, window, cx);
3408 });
3409 })
3410 .unwrap();
3411 window
3412 .update(cx, |_, _, cx| {
3413 search_view.update(cx, |search_view, cx| {
3414 assert_eq!(search_view.query_editor.read(cx).text(cx), "TWO");
3415 assert_eq!(search_view.search_options, SearchOptions::CASE_SENSITIVE);
3416 });
3417 })
3418 .unwrap();
3419
3420 // Previous items should never go behind the first history item.
3421 window
3422 .update(cx, |_, window, cx| {
3423 search_bar.update(cx, |search_bar, cx| {
3424 search_bar.focus_search(window, cx);
3425 search_bar.previous_history_query(&PreviousHistoryQuery, window, cx);
3426 });
3427 })
3428 .unwrap();
3429 window
3430 .update(cx, |_, _, cx| {
3431 search_view.update(cx, |search_view, cx| {
3432 assert_eq!(search_view.query_editor.read(cx).text(cx), "ONE");
3433 assert_eq!(search_view.search_options, SearchOptions::CASE_SENSITIVE);
3434 });
3435 })
3436 .unwrap();
3437 window
3438 .update(cx, |_, window, cx| {
3439 search_bar.update(cx, |search_bar, cx| {
3440 search_bar.focus_search(window, cx);
3441 search_bar.previous_history_query(&PreviousHistoryQuery, window, cx);
3442 });
3443 })
3444 .unwrap();
3445 window
3446 .update(cx, |_, _, cx| {
3447 search_view.update(cx, |search_view, cx| {
3448 assert_eq!(search_view.query_editor.read(cx).text(cx), "ONE");
3449 assert_eq!(search_view.search_options, SearchOptions::CASE_SENSITIVE);
3450 });
3451 })
3452 .unwrap();
3453
3454 // Next items should go over the history in the original order.
3455 window
3456 .update(cx, |_, window, cx| {
3457 search_bar.update(cx, |search_bar, cx| {
3458 search_bar.focus_search(window, cx);
3459 search_bar.next_history_query(&NextHistoryQuery, window, cx);
3460 });
3461 })
3462 .unwrap();
3463 window
3464 .update(cx, |_, _, cx| {
3465 search_view.update(cx, |search_view, cx| {
3466 assert_eq!(search_view.query_editor.read(cx).text(cx), "TWO");
3467 assert_eq!(search_view.search_options, SearchOptions::CASE_SENSITIVE);
3468 });
3469 })
3470 .unwrap();
3471
3472 window
3473 .update(cx, |_, window, cx| {
3474 search_view.update(cx, |search_view, cx| {
3475 search_view.query_editor.update(cx, |query_editor, cx| {
3476 query_editor.set_text("TWO_NEW", window, cx)
3477 });
3478 search_view.search(cx);
3479 });
3480 })
3481 .unwrap();
3482 cx.background_executor.run_until_parked();
3483 window
3484 .update(cx, |_, _, cx| {
3485 search_view.update(cx, |search_view, cx| {
3486 assert_eq!(search_view.query_editor.read(cx).text(cx), "TWO_NEW");
3487 assert_eq!(search_view.search_options, SearchOptions::CASE_SENSITIVE);
3488 });
3489 })
3490 .unwrap();
3491
3492 // New search input should add another entry to history and move the selection to the end of the history.
3493 window
3494 .update(cx, |_, window, cx| {
3495 search_bar.update(cx, |search_bar, cx| {
3496 search_bar.focus_search(window, cx);
3497 search_bar.previous_history_query(&PreviousHistoryQuery, window, cx);
3498 });
3499 })
3500 .unwrap();
3501 window
3502 .update(cx, |_, _, cx| {
3503 search_view.update(cx, |search_view, cx| {
3504 assert_eq!(search_view.query_editor.read(cx).text(cx), "THREE");
3505 assert_eq!(search_view.search_options, SearchOptions::CASE_SENSITIVE);
3506 });
3507 })
3508 .unwrap();
3509 window
3510 .update(cx, |_, window, cx| {
3511 search_bar.update(cx, |search_bar, cx| {
3512 search_bar.focus_search(window, cx);
3513 search_bar.previous_history_query(&PreviousHistoryQuery, window, cx);
3514 });
3515 })
3516 .unwrap();
3517 window
3518 .update(cx, |_, _, cx| {
3519 search_view.update(cx, |search_view, cx| {
3520 assert_eq!(search_view.query_editor.read(cx).text(cx), "TWO");
3521 assert_eq!(search_view.search_options, SearchOptions::CASE_SENSITIVE);
3522 });
3523 })
3524 .unwrap();
3525 window
3526 .update(cx, |_, window, cx| {
3527 search_bar.update(cx, |search_bar, cx| {
3528 search_bar.focus_search(window, cx);
3529 search_bar.next_history_query(&NextHistoryQuery, window, cx);
3530 });
3531 })
3532 .unwrap();
3533 window
3534 .update(cx, |_, _, cx| {
3535 search_view.update(cx, |search_view, cx| {
3536 assert_eq!(search_view.query_editor.read(cx).text(cx), "THREE");
3537 assert_eq!(search_view.search_options, SearchOptions::CASE_SENSITIVE);
3538 });
3539 })
3540 .unwrap();
3541 window
3542 .update(cx, |_, window, cx| {
3543 search_bar.update(cx, |search_bar, cx| {
3544 search_bar.focus_search(window, cx);
3545 search_bar.next_history_query(&NextHistoryQuery, window, cx);
3546 });
3547 })
3548 .unwrap();
3549 window
3550 .update(cx, |_, _, cx| {
3551 search_view.update(cx, |search_view, cx| {
3552 assert_eq!(search_view.query_editor.read(cx).text(cx), "TWO_NEW");
3553 assert_eq!(search_view.search_options, SearchOptions::CASE_SENSITIVE);
3554 });
3555 })
3556 .unwrap();
3557 window
3558 .update(cx, |_, window, cx| {
3559 search_bar.update(cx, |search_bar, cx| {
3560 search_bar.focus_search(window, cx);
3561 search_bar.next_history_query(&NextHistoryQuery, window, cx);
3562 });
3563 })
3564 .unwrap();
3565 window
3566 .update(cx, |_, _, cx| {
3567 search_view.update(cx, |search_view, cx| {
3568 assert_eq!(search_view.query_editor.read(cx).text(cx), "");
3569 assert_eq!(search_view.search_options, SearchOptions::CASE_SENSITIVE);
3570 });
3571 })
3572 .unwrap();
3573 }
3574
3575 #[gpui::test]
3576 async fn test_search_query_history_with_multiple_views(cx: &mut TestAppContext) {
3577 init_test(cx);
3578
3579 let fs = FakeFs::new(cx.background_executor.clone());
3580 fs.insert_tree(
3581 path!("/dir"),
3582 json!({
3583 "one.rs": "const ONE: usize = 1;",
3584 }),
3585 )
3586 .await;
3587 let project = Project::test(fs.clone(), [path!("/dir").as_ref()], cx).await;
3588 let worktree_id = project.update(cx, |this, cx| {
3589 this.worktrees(cx).next().unwrap().read(cx).id()
3590 });
3591
3592 let window = cx.add_window(|window, cx| Workspace::test_new(project, window, cx));
3593 let workspace = window.root(cx).unwrap();
3594
3595 let panes: Vec<_> = window
3596 .update(cx, |this, _, _| this.panes().to_owned())
3597 .unwrap();
3598
3599 let search_bar_1 = window.build_entity(cx, |_, _| ProjectSearchBar::new());
3600 let search_bar_2 = window.build_entity(cx, |_, _| ProjectSearchBar::new());
3601
3602 assert_eq!(panes.len(), 1);
3603 let first_pane = panes.first().cloned().unwrap();
3604 assert_eq!(cx.update(|cx| first_pane.read(cx).items_len()), 0);
3605 window
3606 .update(cx, |workspace, window, cx| {
3607 workspace.open_path(
3608 (worktree_id, "one.rs"),
3609 Some(first_pane.downgrade()),
3610 true,
3611 window,
3612 cx,
3613 )
3614 })
3615 .unwrap()
3616 .await
3617 .unwrap();
3618 assert_eq!(cx.update(|cx| first_pane.read(cx).items_len()), 1);
3619
3620 // Add a project search item to the first pane
3621 window
3622 .update(cx, {
3623 let search_bar = search_bar_1.clone();
3624 |workspace, window, cx| {
3625 first_pane.update(cx, |pane, cx| {
3626 pane.toolbar()
3627 .update(cx, |toolbar, cx| toolbar.add_item(search_bar, window, cx))
3628 });
3629
3630 ProjectSearchView::new_search(workspace, &workspace::NewSearch, window, cx)
3631 }
3632 })
3633 .unwrap();
3634 let search_view_1 = cx.read(|cx| {
3635 workspace
3636 .read(cx)
3637 .active_item(cx)
3638 .and_then(|item| item.downcast::<ProjectSearchView>())
3639 .expect("Search view expected to appear after new search event trigger")
3640 });
3641
3642 let second_pane = window
3643 .update(cx, |workspace, window, cx| {
3644 workspace.split_and_clone(
3645 first_pane.clone(),
3646 workspace::SplitDirection::Right,
3647 window,
3648 cx,
3649 )
3650 })
3651 .unwrap()
3652 .unwrap();
3653 assert_eq!(cx.update(|cx| second_pane.read(cx).items_len()), 1);
3654
3655 assert_eq!(cx.update(|cx| second_pane.read(cx).items_len()), 1);
3656 assert_eq!(cx.update(|cx| first_pane.read(cx).items_len()), 2);
3657
3658 // Add a project search item to the second pane
3659 window
3660 .update(cx, {
3661 let search_bar = search_bar_2.clone();
3662 let pane = second_pane.clone();
3663 move |workspace, window, cx| {
3664 assert_eq!(workspace.panes().len(), 2);
3665 pane.update(cx, |pane, cx| {
3666 pane.toolbar()
3667 .update(cx, |toolbar, cx| toolbar.add_item(search_bar, window, cx))
3668 });
3669
3670 ProjectSearchView::new_search(workspace, &workspace::NewSearch, window, cx)
3671 }
3672 })
3673 .unwrap();
3674
3675 let search_view_2 = cx.read(|cx| {
3676 workspace
3677 .read(cx)
3678 .active_item(cx)
3679 .and_then(|item| item.downcast::<ProjectSearchView>())
3680 .expect("Search view expected to appear after new search event trigger")
3681 });
3682
3683 cx.run_until_parked();
3684 assert_eq!(cx.update(|cx| first_pane.read(cx).items_len()), 2);
3685 assert_eq!(cx.update(|cx| second_pane.read(cx).items_len()), 2);
3686
3687 let update_search_view =
3688 |search_view: &Entity<ProjectSearchView>, query: &str, cx: &mut TestAppContext| {
3689 window
3690 .update(cx, |_, window, cx| {
3691 search_view.update(cx, |search_view, cx| {
3692 search_view.query_editor.update(cx, |query_editor, cx| {
3693 query_editor.set_text(query, window, cx)
3694 });
3695 search_view.search(cx);
3696 });
3697 })
3698 .unwrap();
3699 };
3700
3701 let active_query =
3702 |search_view: &Entity<ProjectSearchView>, cx: &mut TestAppContext| -> String {
3703 window
3704 .update(cx, |_, _, cx| {
3705 search_view.update(cx, |search_view, cx| {
3706 search_view.query_editor.read(cx).text(cx).to_string()
3707 })
3708 })
3709 .unwrap()
3710 };
3711
3712 let select_prev_history_item =
3713 |search_bar: &Entity<ProjectSearchBar>, cx: &mut TestAppContext| {
3714 window
3715 .update(cx, |_, window, cx| {
3716 search_bar.update(cx, |search_bar, cx| {
3717 search_bar.focus_search(window, cx);
3718 search_bar.previous_history_query(&PreviousHistoryQuery, window, cx);
3719 })
3720 })
3721 .unwrap();
3722 };
3723
3724 let select_next_history_item =
3725 |search_bar: &Entity<ProjectSearchBar>, cx: &mut TestAppContext| {
3726 window
3727 .update(cx, |_, window, cx| {
3728 search_bar.update(cx, |search_bar, cx| {
3729 search_bar.focus_search(window, cx);
3730 search_bar.next_history_query(&NextHistoryQuery, window, cx);
3731 })
3732 })
3733 .unwrap();
3734 };
3735
3736 update_search_view(&search_view_1, "ONE", cx);
3737 cx.background_executor.run_until_parked();
3738
3739 update_search_view(&search_view_2, "TWO", cx);
3740 cx.background_executor.run_until_parked();
3741
3742 assert_eq!(active_query(&search_view_1, cx), "ONE");
3743 assert_eq!(active_query(&search_view_2, cx), "TWO");
3744
3745 // Selecting previous history item should select the query from search view 1.
3746 select_prev_history_item(&search_bar_2, cx);
3747 assert_eq!(active_query(&search_view_2, cx), "ONE");
3748
3749 // Selecting the previous history item should not change the query as it is already the first item.
3750 select_prev_history_item(&search_bar_2, cx);
3751 assert_eq!(active_query(&search_view_2, cx), "ONE");
3752
3753 // Changing the query in search view 2 should not affect the history of search view 1.
3754 assert_eq!(active_query(&search_view_1, cx), "ONE");
3755
3756 // Deploying a new search in search view 2
3757 update_search_view(&search_view_2, "THREE", cx);
3758 cx.background_executor.run_until_parked();
3759
3760 select_next_history_item(&search_bar_2, cx);
3761 assert_eq!(active_query(&search_view_2, cx), "");
3762
3763 select_prev_history_item(&search_bar_2, cx);
3764 assert_eq!(active_query(&search_view_2, cx), "THREE");
3765
3766 select_prev_history_item(&search_bar_2, cx);
3767 assert_eq!(active_query(&search_view_2, cx), "TWO");
3768
3769 select_prev_history_item(&search_bar_2, cx);
3770 assert_eq!(active_query(&search_view_2, cx), "ONE");
3771
3772 select_prev_history_item(&search_bar_2, cx);
3773 assert_eq!(active_query(&search_view_2, cx), "ONE");
3774
3775 // Search view 1 should now see the query from search view 2.
3776 assert_eq!(active_query(&search_view_1, cx), "ONE");
3777
3778 select_next_history_item(&search_bar_2, cx);
3779 assert_eq!(active_query(&search_view_2, cx), "TWO");
3780
3781 // Here is the new query from search view 2
3782 select_next_history_item(&search_bar_2, cx);
3783 assert_eq!(active_query(&search_view_2, cx), "THREE");
3784
3785 select_next_history_item(&search_bar_2, cx);
3786 assert_eq!(active_query(&search_view_2, cx), "");
3787
3788 select_next_history_item(&search_bar_1, cx);
3789 assert_eq!(active_query(&search_view_1, cx), "TWO");
3790
3791 select_next_history_item(&search_bar_1, cx);
3792 assert_eq!(active_query(&search_view_1, cx), "THREE");
3793
3794 select_next_history_item(&search_bar_1, cx);
3795 assert_eq!(active_query(&search_view_1, cx), "");
3796 }
3797
3798 #[gpui::test]
3799 async fn test_deploy_search_with_multiple_panes(cx: &mut TestAppContext) {
3800 init_test(cx);
3801
3802 // Setup 2 panes, both with a file open and one with a project search.
3803 let fs = FakeFs::new(cx.background_executor.clone());
3804 fs.insert_tree(
3805 path!("/dir"),
3806 json!({
3807 "one.rs": "const ONE: usize = 1;",
3808 }),
3809 )
3810 .await;
3811 let project = Project::test(fs.clone(), [path!("/dir").as_ref()], cx).await;
3812 let worktree_id = project.update(cx, |this, cx| {
3813 this.worktrees(cx).next().unwrap().read(cx).id()
3814 });
3815 let window = cx.add_window(|window, cx| Workspace::test_new(project, window, cx));
3816 let panes: Vec<_> = window
3817 .update(cx, |this, _, _| this.panes().to_owned())
3818 .unwrap();
3819 assert_eq!(panes.len(), 1);
3820 let first_pane = panes.first().cloned().unwrap();
3821 assert_eq!(cx.update(|cx| first_pane.read(cx).items_len()), 0);
3822 window
3823 .update(cx, |workspace, window, cx| {
3824 workspace.open_path(
3825 (worktree_id, "one.rs"),
3826 Some(first_pane.downgrade()),
3827 true,
3828 window,
3829 cx,
3830 )
3831 })
3832 .unwrap()
3833 .await
3834 .unwrap();
3835 assert_eq!(cx.update(|cx| first_pane.read(cx).items_len()), 1);
3836 let second_pane = window
3837 .update(cx, |workspace, window, cx| {
3838 workspace.split_and_clone(
3839 first_pane.clone(),
3840 workspace::SplitDirection::Right,
3841 window,
3842 cx,
3843 )
3844 })
3845 .unwrap()
3846 .unwrap();
3847 assert_eq!(cx.update(|cx| second_pane.read(cx).items_len()), 1);
3848 assert!(
3849 window
3850 .update(cx, |_, window, cx| second_pane
3851 .focus_handle(cx)
3852 .contains_focused(window, cx))
3853 .unwrap()
3854 );
3855 let search_bar = window.build_entity(cx, |_, _| ProjectSearchBar::new());
3856 window
3857 .update(cx, {
3858 let search_bar = search_bar.clone();
3859 let pane = first_pane.clone();
3860 move |workspace, window, cx| {
3861 assert_eq!(workspace.panes().len(), 2);
3862 pane.update(cx, move |pane, cx| {
3863 pane.toolbar()
3864 .update(cx, |toolbar, cx| toolbar.add_item(search_bar, window, cx))
3865 });
3866 }
3867 })
3868 .unwrap();
3869
3870 // Add a project search item to the second pane
3871 window
3872 .update(cx, {
3873 let search_bar = search_bar.clone();
3874 |workspace, window, cx| {
3875 assert_eq!(workspace.panes().len(), 2);
3876 second_pane.update(cx, |pane, cx| {
3877 pane.toolbar()
3878 .update(cx, |toolbar, cx| toolbar.add_item(search_bar, window, cx))
3879 });
3880
3881 ProjectSearchView::new_search(workspace, &workspace::NewSearch, window, cx)
3882 }
3883 })
3884 .unwrap();
3885
3886 cx.run_until_parked();
3887 assert_eq!(cx.update(|cx| second_pane.read(cx).items_len()), 2);
3888 assert_eq!(cx.update(|cx| first_pane.read(cx).items_len()), 1);
3889
3890 // Focus the first pane
3891 window
3892 .update(cx, |workspace, window, cx| {
3893 assert_eq!(workspace.active_pane(), &second_pane);
3894 second_pane.update(cx, |this, cx| {
3895 assert_eq!(this.active_item_index(), 1);
3896 this.activate_prev_item(false, window, cx);
3897 assert_eq!(this.active_item_index(), 0);
3898 });
3899 workspace.activate_pane_in_direction(workspace::SplitDirection::Left, window, cx);
3900 })
3901 .unwrap();
3902 window
3903 .update(cx, |workspace, _, cx| {
3904 assert_eq!(workspace.active_pane(), &first_pane);
3905 assert_eq!(first_pane.read(cx).items_len(), 1);
3906 assert_eq!(second_pane.read(cx).items_len(), 2);
3907 })
3908 .unwrap();
3909
3910 // Deploy a new search
3911 cx.dispatch_action(window.into(), DeploySearch::find());
3912
3913 // Both panes should now have a project search in them
3914 window
3915 .update(cx, |workspace, window, cx| {
3916 assert_eq!(workspace.active_pane(), &first_pane);
3917 first_pane.read_with(cx, |this, _| {
3918 assert_eq!(this.active_item_index(), 1);
3919 assert_eq!(this.items_len(), 2);
3920 });
3921 second_pane.update(cx, |this, cx| {
3922 assert!(!cx.focus_handle().contains_focused(window, cx));
3923 assert_eq!(this.items_len(), 2);
3924 });
3925 })
3926 .unwrap();
3927
3928 // Focus the second pane's non-search item
3929 window
3930 .update(cx, |_workspace, window, cx| {
3931 second_pane.update(cx, |pane, cx| pane.activate_next_item(true, window, cx));
3932 })
3933 .unwrap();
3934
3935 // Deploy a new search
3936 cx.dispatch_action(window.into(), DeploySearch::find());
3937
3938 // The project search view should now be focused in the second pane
3939 // And the number of items should be unchanged.
3940 window
3941 .update(cx, |_workspace, _, cx| {
3942 second_pane.update(cx, |pane, _cx| {
3943 assert!(
3944 pane.active_item()
3945 .unwrap()
3946 .downcast::<ProjectSearchView>()
3947 .is_some()
3948 );
3949
3950 assert_eq!(pane.items_len(), 2);
3951 });
3952 })
3953 .unwrap();
3954 }
3955
3956 #[gpui::test]
3957 async fn test_scroll_search_results_to_top(cx: &mut TestAppContext) {
3958 init_test(cx);
3959
3960 // We need many lines in the search results to be able to scroll the window
3961 let fs = FakeFs::new(cx.background_executor.clone());
3962 fs.insert_tree(
3963 path!("/dir"),
3964 json!({
3965 "1.txt": "\n\n\n\n\n A \n\n\n\n\n",
3966 "2.txt": "\n\n\n\n\n A \n\n\n\n\n",
3967 "3.rs": "\n\n\n\n\n A \n\n\n\n\n",
3968 "4.rs": "\n\n\n\n\n A \n\n\n\n\n",
3969 "5.rs": "\n\n\n\n\n A \n\n\n\n\n",
3970 "6.rs": "\n\n\n\n\n A \n\n\n\n\n",
3971 "7.rs": "\n\n\n\n\n A \n\n\n\n\n",
3972 "8.rs": "\n\n\n\n\n A \n\n\n\n\n",
3973 "9.rs": "\n\n\n\n\n A \n\n\n\n\n",
3974 "a.rs": "\n\n\n\n\n A \n\n\n\n\n",
3975 "b.rs": "\n\n\n\n\n B \n\n\n\n\n",
3976 "c.rs": "\n\n\n\n\n B \n\n\n\n\n",
3977 "d.rs": "\n\n\n\n\n B \n\n\n\n\n",
3978 "e.rs": "\n\n\n\n\n B \n\n\n\n\n",
3979 "f.rs": "\n\n\n\n\n B \n\n\n\n\n",
3980 "g.rs": "\n\n\n\n\n B \n\n\n\n\n",
3981 "h.rs": "\n\n\n\n\n B \n\n\n\n\n",
3982 "i.rs": "\n\n\n\n\n B \n\n\n\n\n",
3983 "j.rs": "\n\n\n\n\n B \n\n\n\n\n",
3984 "k.rs": "\n\n\n\n\n B \n\n\n\n\n",
3985 }),
3986 )
3987 .await;
3988 let project = Project::test(fs.clone(), [path!("/dir").as_ref()], cx).await;
3989 let window = cx.add_window(|window, cx| Workspace::test_new(project.clone(), window, cx));
3990 let workspace = window.root(cx).unwrap();
3991 let search = cx.new(|cx| ProjectSearch::new(project, cx));
3992 let search_view = cx.add_window(|window, cx| {
3993 ProjectSearchView::new(workspace.downgrade(), search.clone(), window, cx, None)
3994 });
3995
3996 // First search
3997 perform_search(search_view, "A", cx);
3998 search_view
3999 .update(cx, |search_view, window, cx| {
4000 search_view.results_editor.update(cx, |results_editor, cx| {
4001 // Results are correct and scrolled to the top
4002 assert_eq!(
4003 results_editor.display_text(cx).match_indices(" A ").count(),
4004 10
4005 );
4006 assert_eq!(results_editor.scroll_position(cx), Point::default());
4007
4008 // Scroll results all the way down
4009 results_editor.scroll(
4010 Point::new(0., f32::MAX),
4011 Some(Axis::Vertical),
4012 window,
4013 cx,
4014 );
4015 });
4016 })
4017 .expect("unable to update search view");
4018
4019 // Second search
4020 perform_search(search_view, "B", cx);
4021 search_view
4022 .update(cx, |search_view, _, cx| {
4023 search_view.results_editor.update(cx, |results_editor, cx| {
4024 // Results are correct...
4025 assert_eq!(
4026 results_editor.display_text(cx).match_indices(" B ").count(),
4027 10
4028 );
4029 // ...and scrolled back to the top
4030 assert_eq!(results_editor.scroll_position(cx), Point::default());
4031 });
4032 })
4033 .expect("unable to update search view");
4034 }
4035
4036 #[gpui::test]
4037 async fn test_buffer_search_query_reused(cx: &mut TestAppContext) {
4038 init_test(cx);
4039
4040 let fs = FakeFs::new(cx.background_executor.clone());
4041 fs.insert_tree(
4042 path!("/dir"),
4043 json!({
4044 "one.rs": "const ONE: usize = 1;",
4045 }),
4046 )
4047 .await;
4048 let project = Project::test(fs.clone(), [path!("/dir").as_ref()], cx).await;
4049 let worktree_id = project.update(cx, |this, cx| {
4050 this.worktrees(cx).next().unwrap().read(cx).id()
4051 });
4052 let window = cx.add_window(|window, cx| Workspace::test_new(project.clone(), window, cx));
4053 let workspace = window.root(cx).unwrap();
4054 let mut cx = VisualTestContext::from_window(*window.deref(), cx);
4055
4056 let editor = workspace
4057 .update_in(&mut cx, |workspace, window, cx| {
4058 workspace.open_path((worktree_id, "one.rs"), None, true, window, cx)
4059 })
4060 .await
4061 .unwrap()
4062 .downcast::<Editor>()
4063 .unwrap();
4064
4065 // Wait for the unstaged changes to be loaded
4066 cx.run_until_parked();
4067
4068 let buffer_search_bar = cx.new_window_entity(|window, cx| {
4069 let mut search_bar =
4070 BufferSearchBar::new(Some(project.read(cx).languages().clone()), window, cx);
4071 search_bar.set_active_pane_item(Some(&editor), window, cx);
4072 search_bar.show(window, cx);
4073 search_bar
4074 });
4075
4076 let panes: Vec<_> = window
4077 .update(&mut cx, |this, _, _| this.panes().to_owned())
4078 .unwrap();
4079 assert_eq!(panes.len(), 1);
4080 let pane = panes.first().cloned().unwrap();
4081 pane.update_in(&mut cx, |pane, window, cx| {
4082 pane.toolbar().update(cx, |toolbar, cx| {
4083 toolbar.add_item(buffer_search_bar.clone(), window, cx);
4084 })
4085 });
4086
4087 let buffer_search_query = "search bar query";
4088 buffer_search_bar
4089 .update_in(&mut cx, |buffer_search_bar, window, cx| {
4090 buffer_search_bar.focus_handle(cx).focus(window);
4091 buffer_search_bar.search(buffer_search_query, None, window, cx)
4092 })
4093 .await
4094 .unwrap();
4095
4096 workspace.update_in(&mut cx, |workspace, window, cx| {
4097 ProjectSearchView::new_search(workspace, &workspace::NewSearch, window, cx)
4098 });
4099 cx.run_until_parked();
4100 let project_search_view = pane
4101 .read_with(&mut cx, |pane, _| {
4102 pane.active_item()
4103 .and_then(|item| item.downcast::<ProjectSearchView>())
4104 })
4105 .expect("should open a project search view after spawning a new search");
4106 project_search_view.update(&mut cx, |search_view, cx| {
4107 assert_eq!(
4108 search_view.search_query_text(cx),
4109 buffer_search_query,
4110 "Project search should take the query from the buffer search bar since it got focused and had a query inside"
4111 );
4112 });
4113 }
4114
4115 fn init_test(cx: &mut TestAppContext) {
4116 cx.update(|cx| {
4117 let settings = SettingsStore::test(cx);
4118 cx.set_global(settings);
4119
4120 theme::init(theme::LoadThemes::JustBase, cx);
4121
4122 language::init(cx);
4123 client::init_settings(cx);
4124 editor::init(cx);
4125 workspace::init_settings(cx);
4126 Project::init_settings(cx);
4127 crate::init(cx);
4128 });
4129 }
4130
4131 fn perform_search(
4132 search_view: WindowHandle<ProjectSearchView>,
4133 text: impl Into<Arc<str>>,
4134 cx: &mut TestAppContext,
4135 ) {
4136 search_view
4137 .update(cx, |search_view, window, cx| {
4138 search_view.query_editor.update(cx, |query_editor, cx| {
4139 query_editor.set_text(text, window, cx)
4140 });
4141 search_view.search(cx);
4142 })
4143 .unwrap();
4144 cx.background_executor.run_until_parked();
4145 }
4146}