1use anyhow::{Context as _, bail};
2use collections::{FxHashMap, HashMap, HashSet};
3use language::{LanguageName, LanguageRegistry};
4use std::{
5 borrow::Cow,
6 path::{Path, PathBuf},
7 sync::Arc,
8 usize,
9};
10use tasks_ui::{TaskOverrides, TasksModal};
11
12use dap::{
13 DapRegistry, DebugRequest, TelemetrySpawnLocation, adapters::DebugAdapterName, send_telemetry,
14};
15use editor::{Editor, EditorElement, EditorStyle};
16use fuzzy::{StringMatch, StringMatchCandidate};
17use gpui::{
18 Action, App, AppContext, DismissEvent, Entity, EventEmitter, FocusHandle, Focusable,
19 KeyContext, Render, Subscription, Task, TextStyle, WeakEntity,
20};
21use itertools::Itertools as _;
22use picker::{Picker, PickerDelegate, highlighted_match_with_paths::HighlightedMatch};
23use project::{DebugScenarioContext, Project, TaskContexts, TaskSourceKind, task_store::TaskStore};
24use settings::Settings;
25use task::{DebugScenario, RevealTarget, VariableName, ZedDebugConfig};
26use theme::ThemeSettings;
27use ui::{
28 ActiveTheme, Button, ButtonCommon, ButtonSize, CheckboxWithLabel, Clickable, Color, Context,
29 ContextMenu, Disableable, DropdownMenu, FluentBuilder, Icon, IconName, IconSize,
30 IconWithIndicator, Indicator, InteractiveElement, IntoElement, KeyBinding, Label,
31 LabelCommon as _, LabelSize, ListItem, ListItemSpacing, ParentElement, RenderOnce,
32 SharedString, Styled, StyledExt, ToggleButton, ToggleState, Toggleable, Tooltip, Window, div,
33 h_flex, relative, rems, v_flex,
34};
35use util::{ResultExt, rel_path::RelPath, shell::ShellKind};
36use workspace::{ModalView, Workspace, notifications::DetachAndPromptErr, pane};
37
38use crate::{attach_modal::AttachModal, debugger_panel::DebugPanel};
39
40pub(super) struct NewProcessModal {
41 workspace: WeakEntity<Workspace>,
42 debug_panel: WeakEntity<DebugPanel>,
43 mode: NewProcessMode,
44 debug_picker: Entity<Picker<DebugDelegate>>,
45 attach_mode: Entity<AttachMode>,
46 configure_mode: Entity<ConfigureMode>,
47 task_mode: TaskMode,
48 debugger: Option<DebugAdapterName>,
49 _subscriptions: [Subscription; 3],
50}
51
52fn suggested_label(request: &DebugRequest, debugger: &str) -> SharedString {
53 match request {
54 DebugRequest::Launch(config) => {
55 let last_path_component = Path::new(&config.program)
56 .file_name()
57 .map(|name| name.to_string_lossy())
58 .unwrap_or_else(|| Cow::Borrowed(&config.program));
59
60 format!("{} ({debugger})", last_path_component).into()
61 }
62 DebugRequest::Attach(config) => format!(
63 "pid: {} ({debugger})",
64 config.process_id.unwrap_or(u32::MAX)
65 )
66 .into(),
67 }
68}
69
70impl NewProcessModal {
71 pub(super) fn show(
72 workspace: &mut Workspace,
73 window: &mut Window,
74 mode: NewProcessMode,
75 reveal_target: Option<RevealTarget>,
76 cx: &mut Context<Workspace>,
77 ) {
78 let Some(debug_panel) = workspace.panel::<DebugPanel>(cx) else {
79 return;
80 };
81 let task_store = workspace.project().read(cx).task_store().clone();
82 let languages = workspace.app_state().languages.clone();
83
84 cx.spawn_in(window, async move |workspace, cx| {
85 let task_contexts = workspace.update_in(cx, |workspace, window, cx| {
86 // todo(debugger): get the buffer here (if the active item is an editor) and store it so we can pass it to start_session later
87 tasks_ui::task_contexts(workspace, window, cx)
88 })?;
89 workspace.update_in(cx, |workspace, window, cx| {
90 let workspace_handle = workspace.weak_handle();
91 let project = workspace.project().clone();
92 workspace.toggle_modal(window, cx, |window, cx| {
93 let attach_mode =
94 AttachMode::new(None, workspace_handle.clone(), project, window, cx);
95
96 let debug_picker = cx.new(|cx| {
97 let delegate =
98 DebugDelegate::new(debug_panel.downgrade(), task_store.clone());
99 Picker::uniform_list(delegate, window, cx).modal(false)
100 });
101
102 let configure_mode = ConfigureMode::new(window, cx);
103
104 let task_overrides = Some(TaskOverrides { reveal_target });
105
106 let task_mode = TaskMode {
107 task_modal: cx.new(|cx| {
108 TasksModal::new(
109 task_store.clone(),
110 Arc::new(TaskContexts::default()),
111 task_overrides,
112 false,
113 workspace_handle.clone(),
114 window,
115 cx,
116 )
117 }),
118 };
119
120 let _subscriptions = [
121 cx.subscribe(&debug_picker, |_, _, _, cx| {
122 cx.emit(DismissEvent);
123 }),
124 cx.subscribe(
125 &attach_mode.read(cx).attach_picker.clone(),
126 |_, _, _, cx| {
127 cx.emit(DismissEvent);
128 },
129 ),
130 cx.subscribe(&task_mode.task_modal, |_, _, _: &DismissEvent, cx| {
131 cx.emit(DismissEvent)
132 }),
133 ];
134
135 cx.spawn_in(window, {
136 let debug_picker = debug_picker.downgrade();
137 let configure_mode = configure_mode.downgrade();
138 let task_modal = task_mode.task_modal.downgrade();
139 let workspace = workspace_handle.clone();
140
141 async move |this, cx| {
142 let task_contexts = task_contexts.await;
143 let task_contexts = Arc::new(task_contexts);
144 let lsp_task_sources = task_contexts.lsp_task_sources.clone();
145 let task_position = task_contexts.latest_selection;
146 // Get LSP tasks and filter out based on language vs lsp preference
147 let (lsp_tasks, prefer_lsp) =
148 workspace.update(cx, |workspace, cx| {
149 let lsp_tasks = editor::lsp_tasks(
150 workspace.project().clone(),
151 &lsp_task_sources,
152 task_position,
153 cx,
154 );
155 let prefer_lsp = workspace
156 .active_item(cx)
157 .and_then(|item| item.downcast::<Editor>())
158 .map(|editor| {
159 editor
160 .read(cx)
161 .buffer()
162 .read(cx)
163 .language_settings(cx)
164 .tasks
165 .prefer_lsp
166 })
167 .unwrap_or(false);
168 (lsp_tasks, prefer_lsp)
169 })?;
170
171 let lsp_tasks = lsp_tasks.await;
172 let add_current_language_tasks = !prefer_lsp || lsp_tasks.is_empty();
173
174 let lsp_tasks = lsp_tasks
175 .into_iter()
176 .flat_map(|(kind, tasks_with_locations)| {
177 tasks_with_locations
178 .into_iter()
179 .sorted_by_key(|(location, task)| {
180 (location.is_none(), task.resolved_label.clone())
181 })
182 .map(move |(_, task)| (kind.clone(), task))
183 })
184 .collect::<Vec<_>>();
185
186 let Some(task_inventory) = task_store
187 .update(cx, |task_store, _| task_store.task_inventory().cloned())?
188 else {
189 return Ok(());
190 };
191
192 let (used_tasks, current_resolved_tasks) = task_inventory
193 .update(cx, |task_inventory, cx| {
194 task_inventory
195 .used_and_current_resolved_tasks(task_contexts.clone(), cx)
196 })?
197 .await;
198
199 if let Ok(task) = debug_picker.update(cx, |picker, cx| {
200 picker.delegate.tasks_loaded(
201 task_contexts.clone(),
202 languages,
203 lsp_tasks.clone(),
204 current_resolved_tasks.clone(),
205 add_current_language_tasks,
206 cx,
207 )
208 }) {
209 task.await;
210 debug_picker
211 .update_in(cx, |picker, window, cx| {
212 picker.refresh(window, cx);
213 cx.notify();
214 })
215 .ok();
216 }
217
218 if let Some(active_cwd) = task_contexts
219 .active_context()
220 .and_then(|context| context.cwd.clone())
221 {
222 configure_mode
223 .update_in(cx, |configure_mode, window, cx| {
224 configure_mode.load(active_cwd, window, cx);
225 })
226 .ok();
227 }
228
229 task_modal
230 .update_in(cx, |task_modal, window, cx| {
231 task_modal.tasks_loaded(
232 task_contexts,
233 lsp_tasks,
234 used_tasks,
235 current_resolved_tasks,
236 add_current_language_tasks,
237 window,
238 cx,
239 );
240 })
241 .ok();
242
243 this.update(cx, |_, cx| {
244 cx.notify();
245 })
246 .ok();
247
248 anyhow::Ok(())
249 }
250 })
251 .detach();
252
253 Self {
254 debug_picker,
255 attach_mode,
256 configure_mode,
257 task_mode,
258 debugger: None,
259 mode,
260 debug_panel: debug_panel.downgrade(),
261 workspace: workspace_handle,
262 _subscriptions,
263 }
264 });
265 })?;
266
267 anyhow::Ok(())
268 })
269 .detach();
270 }
271
272 fn render_mode(&mut self, window: &mut Window, cx: &mut Context<Self>) -> impl ui::IntoElement {
273 let dap_menu = self.adapter_drop_down_menu(window, cx);
274 match self.mode {
275 NewProcessMode::Task => self
276 .task_mode
277 .task_modal
278 .read(cx)
279 .picker
280 .clone()
281 .into_any_element(),
282 NewProcessMode::Attach => self.attach_mode.update(cx, |this, cx| {
283 this.clone().render(window, cx).into_any_element()
284 }),
285 NewProcessMode::Launch => self.configure_mode.update(cx, |this, cx| {
286 this.clone().render(dap_menu, window, cx).into_any_element()
287 }),
288 NewProcessMode::Debug => v_flex()
289 .w(rems(34.))
290 .child(self.debug_picker.clone())
291 .into_any_element(),
292 }
293 }
294
295 fn mode_focus_handle(&self, cx: &App) -> FocusHandle {
296 match self.mode {
297 NewProcessMode::Task => self.task_mode.task_modal.focus_handle(cx),
298 NewProcessMode::Attach => self.attach_mode.read(cx).attach_picker.focus_handle(cx),
299 NewProcessMode::Launch => self.configure_mode.read(cx).program.focus_handle(cx),
300 NewProcessMode::Debug => self.debug_picker.focus_handle(cx),
301 }
302 }
303
304 fn debug_scenario(&self, debugger: &str, cx: &App) -> Task<Option<DebugScenario>> {
305 let request = match self.mode {
306 NewProcessMode::Launch => {
307 DebugRequest::Launch(self.configure_mode.read(cx).debug_request(cx))
308 }
309 NewProcessMode::Attach => {
310 DebugRequest::Attach(self.attach_mode.read(cx).debug_request())
311 }
312 _ => return Task::ready(None),
313 };
314 let label = suggested_label(&request, debugger);
315
316 let stop_on_entry = if let NewProcessMode::Launch = &self.mode {
317 Some(self.configure_mode.read(cx).stop_on_entry.selected())
318 } else {
319 None
320 };
321
322 let session_scenario = ZedDebugConfig {
323 adapter: debugger.to_owned().into(),
324 label,
325 request,
326 stop_on_entry,
327 };
328
329 let adapter = cx
330 .global::<DapRegistry>()
331 .adapter(&session_scenario.adapter);
332
333 cx.spawn(async move |_| adapter?.config_from_zed_format(session_scenario).await.ok())
334 }
335
336 fn start_new_session(&mut self, window: &mut Window, cx: &mut Context<Self>) {
337 if self.debugger.as_ref().is_none() {
338 return;
339 }
340
341 if let NewProcessMode::Debug = &self.mode {
342 self.debug_picker.update(cx, |picker, cx| {
343 picker.delegate.confirm(false, window, cx);
344 });
345 return;
346 }
347
348 if let NewProcessMode::Launch = &self.mode
349 && self.configure_mode.read(cx).save_to_debug_json.selected()
350 {
351 self.save_debug_scenario(window, cx);
352 }
353
354 let Some(debugger) = self.debugger.clone() else {
355 return;
356 };
357
358 let debug_panel = self.debug_panel.clone();
359 let Some(task_contexts) = self.task_contexts(cx) else {
360 return;
361 };
362
363 let task_context = task_contexts.active_context().cloned().unwrap_or_default();
364 let worktree_id = task_contexts.worktree();
365 let mode = self.mode;
366 cx.spawn_in(window, async move |this, cx| {
367 let Some(config) = this
368 .update(cx, |this, cx| this.debug_scenario(&debugger, cx))?
369 .await
370 else {
371 bail!("debug config not found in mode: {mode}");
372 };
373
374 debug_panel.update_in(cx, |debug_panel, window, cx| {
375 send_telemetry(&config, TelemetrySpawnLocation::Custom, cx);
376 debug_panel.start_session(config, task_context, None, worktree_id, window, cx)
377 })?;
378 this.update(cx, |_, cx| {
379 cx.emit(DismissEvent);
380 })
381 .ok();
382 anyhow::Ok(())
383 })
384 .detach_and_log_err(cx);
385 }
386
387 fn update_attach_picker(
388 attach: &Entity<AttachMode>,
389 adapter: &DebugAdapterName,
390 window: &mut Window,
391 cx: &mut App,
392 ) {
393 attach.update(cx, |this, cx| {
394 if adapter.0 != this.definition.adapter {
395 this.definition.adapter = adapter.0.clone();
396
397 this.attach_picker.update(cx, |this, cx| {
398 this.picker.update(cx, |this, cx| {
399 this.delegate.definition.adapter = adapter.0.clone();
400 this.focus(window, cx);
401 })
402 });
403 }
404
405 cx.notify();
406 })
407 }
408
409 fn task_contexts(&self, cx: &App) -> Option<Arc<TaskContexts>> {
410 self.debug_picker.read(cx).delegate.task_contexts.clone()
411 }
412
413 pub fn save_debug_scenario(&mut self, window: &mut Window, cx: &mut Context<Self>) {
414 let task_contexts = self.task_contexts(cx);
415 let Some(adapter) = self.debugger.as_ref() else {
416 return;
417 };
418 let scenario = self.debug_scenario(adapter, cx);
419 cx.spawn_in(window, async move |this, cx| {
420 let scenario = scenario.await.context("no scenario to save")?;
421 let worktree_id = task_contexts
422 .context("no task contexts")?
423 .worktree()
424 .context("no active worktree")?;
425 this.update_in(cx, |this, window, cx| {
426 this.debug_panel.update(cx, |panel, cx| {
427 panel.save_scenario(scenario, worktree_id, window, cx)
428 })
429 })??
430 .await?;
431 this.update_in(cx, |_, _, cx| {
432 cx.emit(DismissEvent);
433 })
434 })
435 .detach_and_prompt_err("Failed to edit debug.json", window, cx, |_, _, _| None);
436 }
437
438 fn adapter_drop_down_menu(
439 &mut self,
440 window: &mut Window,
441 cx: &mut Context<Self>,
442 ) -> ui::DropdownMenu {
443 let workspace = self.workspace.clone();
444 let weak = cx.weak_entity();
445 let active_buffer = self.task_contexts(cx).and_then(|tc| {
446 tc.active_item_context
447 .as_ref()
448 .and_then(|aic| aic.1.as_ref().map(|l| l.buffer.clone()))
449 });
450
451 let active_buffer_language = active_buffer
452 .and_then(|buffer| buffer.read(cx).language())
453 .cloned();
454
455 let mut available_adapters: Vec<_> = workspace
456 .update(cx, |_, cx| DapRegistry::global(cx).enumerate_adapters())
457 .unwrap_or_default();
458 if let Some(language) = active_buffer_language {
459 available_adapters.sort_by_key(|adapter| {
460 language
461 .config()
462 .debuggers
463 .get_index_of(adapter.0.as_ref())
464 .unwrap_or(usize::MAX)
465 });
466 if self.debugger.is_none() {
467 self.debugger = available_adapters.first().cloned();
468 }
469 }
470
471 let label = self
472 .debugger
473 .as_ref()
474 .map(|d| d.0.clone())
475 .unwrap_or_else(|| SELECT_DEBUGGER_LABEL.clone());
476
477 DropdownMenu::new(
478 "dap-adapter-picker",
479 label,
480 ContextMenu::build(window, cx, move |mut menu, _, _| {
481 let setter_for_name = |name: DebugAdapterName| {
482 let weak = weak.clone();
483 move |window: &mut Window, cx: &mut App| {
484 weak.update(cx, |this, cx| {
485 this.debugger = Some(name.clone());
486 cx.notify();
487 if let NewProcessMode::Attach = &this.mode {
488 Self::update_attach_picker(&this.attach_mode, &name, window, cx);
489 }
490 })
491 .ok();
492 }
493 };
494
495 for adapter in available_adapters.into_iter() {
496 menu = menu.entry(adapter.0.clone(), None, setter_for_name(adapter.clone()));
497 }
498
499 menu
500 }),
501 )
502 }
503}
504
505static SELECT_DEBUGGER_LABEL: SharedString = SharedString::new_static("Select Debugger");
506
507#[derive(Clone, Copy)]
508pub(crate) enum NewProcessMode {
509 Task,
510 Launch,
511 Attach,
512 Debug,
513}
514
515impl std::fmt::Display for NewProcessMode {
516 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
517 let mode = match self {
518 NewProcessMode::Task => "Run",
519 NewProcessMode::Debug => "Debug",
520 NewProcessMode::Attach => "Attach",
521 NewProcessMode::Launch => "Launch",
522 };
523
524 write!(f, "{}", mode)
525 }
526}
527
528impl Focusable for NewProcessMode {
529 fn focus_handle(&self, cx: &App) -> FocusHandle {
530 cx.focus_handle()
531 }
532}
533
534fn render_editor(editor: &Entity<Editor>, window: &mut Window, cx: &App) -> impl IntoElement {
535 let settings = ThemeSettings::get_global(cx);
536 let theme = cx.theme();
537
538 let text_style = TextStyle {
539 color: cx.theme().colors().text,
540 font_family: settings.buffer_font.family.clone(),
541 font_features: settings.buffer_font.features.clone(),
542 font_size: settings.buffer_font_size(cx).into(),
543 font_weight: settings.buffer_font.weight,
544 line_height: relative(settings.buffer_line_height.value()),
545 background_color: Some(theme.colors().editor_background),
546 ..Default::default()
547 };
548
549 let element = EditorElement::new(
550 editor,
551 EditorStyle {
552 background: theme.colors().editor_background,
553 local_player: theme.players().local(),
554 text: text_style,
555 ..Default::default()
556 },
557 );
558
559 div()
560 .rounded_md()
561 .p_1()
562 .border_1()
563 .border_color(theme.colors().border_variant)
564 .when(
565 editor.focus_handle(cx).contains_focused(window, cx),
566 |this| this.border_color(theme.colors().border_focused),
567 )
568 .child(element)
569 .bg(theme.colors().editor_background)
570}
571
572impl Render for NewProcessModal {
573 fn render(
574 &mut self,
575 window: &mut ui::Window,
576 cx: &mut ui::Context<Self>,
577 ) -> impl ui::IntoElement {
578 v_flex()
579 .key_context({
580 let mut key_context = KeyContext::new_with_defaults();
581 key_context.add("Pane");
582 key_context.add("RunModal");
583 key_context
584 })
585 .size_full()
586 .w(rems(34.))
587 .elevation_3(cx)
588 .overflow_hidden()
589 .on_action(cx.listener(|_, _: &menu::Cancel, _, cx| {
590 cx.emit(DismissEvent);
591 }))
592 .on_action(cx.listener(|this, _: &pane::ActivateNextItem, window, cx| {
593 this.mode = match this.mode {
594 NewProcessMode::Task => NewProcessMode::Debug,
595 NewProcessMode::Debug => NewProcessMode::Attach,
596 NewProcessMode::Attach => NewProcessMode::Launch,
597 NewProcessMode::Launch => NewProcessMode::Task,
598 };
599
600 this.mode_focus_handle(cx).focus(window);
601 }))
602 .on_action(
603 cx.listener(|this, _: &pane::ActivatePreviousItem, window, cx| {
604 this.mode = match this.mode {
605 NewProcessMode::Task => NewProcessMode::Launch,
606 NewProcessMode::Debug => NewProcessMode::Task,
607 NewProcessMode::Attach => NewProcessMode::Debug,
608 NewProcessMode::Launch => NewProcessMode::Attach,
609 };
610
611 this.mode_focus_handle(cx).focus(window);
612 }),
613 )
614 .child(
615 h_flex()
616 .p_2()
617 .w_full()
618 .border_b_1()
619 .border_color(cx.theme().colors().border_variant)
620 .child(
621 ToggleButton::new(
622 "debugger-session-ui-tasks-button",
623 NewProcessMode::Task.to_string(),
624 )
625 .size(ButtonSize::Default)
626 .toggle_state(matches!(self.mode, NewProcessMode::Task))
627 .style(ui::ButtonStyle::Subtle)
628 .on_click(cx.listener(|this, _, window, cx| {
629 this.mode = NewProcessMode::Task;
630 this.mode_focus_handle(cx).focus(window);
631 cx.notify();
632 }))
633 .tooltip(Tooltip::text("Run predefined task"))
634 .first(),
635 )
636 .child(
637 ToggleButton::new(
638 "debugger-session-ui-launch-button",
639 NewProcessMode::Debug.to_string(),
640 )
641 .size(ButtonSize::Default)
642 .style(ui::ButtonStyle::Subtle)
643 .toggle_state(matches!(self.mode, NewProcessMode::Debug))
644 .on_click(cx.listener(|this, _, window, cx| {
645 this.mode = NewProcessMode::Debug;
646 this.mode_focus_handle(cx).focus(window);
647 cx.notify();
648 }))
649 .tooltip(Tooltip::text("Start a predefined debug scenario"))
650 .middle(),
651 )
652 .child(
653 ToggleButton::new(
654 "debugger-session-ui-attach-button",
655 NewProcessMode::Attach.to_string(),
656 )
657 .size(ButtonSize::Default)
658 .toggle_state(matches!(self.mode, NewProcessMode::Attach))
659 .style(ui::ButtonStyle::Subtle)
660 .on_click(cx.listener(|this, _, window, cx| {
661 this.mode = NewProcessMode::Attach;
662
663 if let Some(debugger) = this.debugger.as_ref() {
664 Self::update_attach_picker(&this.attach_mode, debugger, window, cx);
665 }
666 this.mode_focus_handle(cx).focus(window);
667 cx.notify();
668 }))
669 .tooltip(Tooltip::text("Attach the debugger to a running process"))
670 .middle(),
671 )
672 .child(
673 ToggleButton::new(
674 "debugger-session-ui-custom-button",
675 NewProcessMode::Launch.to_string(),
676 )
677 .size(ButtonSize::Default)
678 .toggle_state(matches!(self.mode, NewProcessMode::Launch))
679 .style(ui::ButtonStyle::Subtle)
680 .on_click(cx.listener(|this, _, window, cx| {
681 this.mode = NewProcessMode::Launch;
682 this.mode_focus_handle(cx).focus(window);
683 cx.notify();
684 }))
685 .tooltip(Tooltip::text("Launch a new process with a debugger"))
686 .last(),
687 ),
688 )
689 .child(v_flex().child(self.render_mode(window, cx)))
690 .map(|el| {
691 let container = h_flex()
692 .w_full()
693 .p_1p5()
694 .gap_2()
695 .justify_between()
696 .border_t_1()
697 .border_color(cx.theme().colors().border_variant);
698 match self.mode {
699 NewProcessMode::Launch => el.child(
700 container
701 .child(
702 h_flex().child(
703 Button::new("edit-custom-debug", "Edit in debug.json")
704 .on_click(cx.listener(|this, _, window, cx| {
705 this.save_debug_scenario(window, cx);
706 }))
707 .disabled(
708 self.debugger.is_none()
709 || self
710 .configure_mode
711 .read(cx)
712 .program
713 .read(cx)
714 .is_empty(cx),
715 ),
716 ),
717 )
718 .child(
719 Button::new("debugger-spawn", "Start")
720 .on_click(cx.listener(|this, _, window, cx| {
721 this.start_new_session(window, cx)
722 }))
723 .disabled(
724 self.debugger.is_none()
725 || self
726 .configure_mode
727 .read(cx)
728 .program
729 .read(cx)
730 .is_empty(cx),
731 ),
732 ),
733 ),
734 NewProcessMode::Attach => el.child({
735 let disabled = self.debugger.is_none()
736 || self
737 .attach_mode
738 .read(cx)
739 .attach_picker
740 .read(cx)
741 .picker
742 .read(cx)
743 .delegate
744 .match_count()
745 == 0;
746 let secondary_action = menu::SecondaryConfirm.boxed_clone();
747 container
748 .child(div().children(
749 KeyBinding::for_action(&*secondary_action, window, cx).map(
750 |keybind| {
751 Button::new("edit-attach-task", "Edit in debug.json")
752 .label_size(LabelSize::Small)
753 .key_binding(keybind)
754 .on_click(move |_, window, cx| {
755 window.dispatch_action(
756 secondary_action.boxed_clone(),
757 cx,
758 )
759 })
760 .disabled(disabled)
761 },
762 ),
763 ))
764 .child(
765 h_flex()
766 .child(div().child(self.adapter_drop_down_menu(window, cx))),
767 )
768 }),
769 NewProcessMode::Debug => el,
770 NewProcessMode::Task => el,
771 }
772 })
773 }
774}
775
776impl EventEmitter<DismissEvent> for NewProcessModal {}
777impl Focusable for NewProcessModal {
778 fn focus_handle(&self, cx: &ui::App) -> gpui::FocusHandle {
779 self.mode_focus_handle(cx)
780 }
781}
782
783impl ModalView for NewProcessModal {}
784
785impl RenderOnce for AttachMode {
786 fn render(self, _: &mut Window, cx: &mut App) -> impl IntoElement {
787 v_flex()
788 .w_full()
789 .track_focus(&self.attach_picker.focus_handle(cx))
790 .child(self.attach_picker)
791 }
792}
793
794#[derive(Clone)]
795pub(super) struct ConfigureMode {
796 program: Entity<Editor>,
797 cwd: Entity<Editor>,
798 stop_on_entry: ToggleState,
799 save_to_debug_json: ToggleState,
800}
801
802impl ConfigureMode {
803 pub(super) fn new(window: &mut Window, cx: &mut App) -> Entity<Self> {
804 let program = cx.new(|cx| Editor::single_line(window, cx));
805 program.update(cx, |this, cx| {
806 this.set_placeholder_text("ENV=Zed ~/bin/program --option", window, cx);
807 });
808
809 let cwd = cx.new(|cx| Editor::single_line(window, cx));
810 cwd.update(cx, |this, cx| {
811 this.set_placeholder_text("Ex: $ZED_WORKTREE_ROOT", window, cx);
812 });
813
814 cx.new(|_| Self {
815 program,
816 cwd,
817 stop_on_entry: ToggleState::Unselected,
818 save_to_debug_json: ToggleState::Unselected,
819 })
820 }
821
822 fn load(&mut self, cwd: PathBuf, window: &mut Window, cx: &mut App) {
823 self.cwd.update(cx, |editor, cx| {
824 if editor.is_empty(cx) {
825 editor.set_text(cwd.to_string_lossy(), window, cx);
826 }
827 });
828 }
829
830 pub(super) fn debug_request(&self, cx: &App) -> task::LaunchRequest {
831 let cwd_text = self.cwd.read(cx).text(cx);
832 let cwd = if cwd_text.is_empty() {
833 None
834 } else {
835 Some(PathBuf::from(cwd_text))
836 };
837
838 if cfg!(windows) {
839 return task::LaunchRequest {
840 program: self.program.read(cx).text(cx),
841 cwd,
842 args: Default::default(),
843 env: Default::default(),
844 };
845 }
846 let command = self.program.read(cx).text(cx);
847 let mut args = ShellKind::Posix
848 .split(&command)
849 .into_iter()
850 .flatten()
851 .peekable();
852 let mut env = FxHashMap::default();
853 while args.peek().is_some_and(|arg| arg.contains('=')) {
854 let arg = args.next().unwrap();
855 let (lhs, rhs) = arg.split_once('=').unwrap();
856 env.insert(lhs.to_string(), rhs.to_string());
857 }
858
859 let program = if let Some(program) = args.next() {
860 program
861 } else {
862 env = FxHashMap::default();
863 command
864 };
865
866 let args = args.collect::<Vec<_>>();
867
868 task::LaunchRequest {
869 program,
870 cwd,
871 args,
872 env,
873 }
874 }
875
876 fn render(
877 &mut self,
878 adapter_menu: DropdownMenu,
879 window: &mut Window,
880 cx: &mut ui::Context<Self>,
881 ) -> impl IntoElement {
882 v_flex()
883 .p_2()
884 .w_full()
885 .gap_2()
886 .track_focus(&self.program.focus_handle(cx))
887 .child(
888 h_flex()
889 .gap_2()
890 .child(
891 Label::new("Debugger")
892 .size(LabelSize::Small)
893 .color(Color::Muted),
894 )
895 .child(adapter_menu),
896 )
897 .child(
898 v_flex()
899 .gap_0p5()
900 .child(
901 Label::new("Program")
902 .size(LabelSize::Small)
903 .color(Color::Muted),
904 )
905 .child(render_editor(&self.program, window, cx)),
906 )
907 .child(
908 v_flex()
909 .gap_0p5()
910 .child(
911 Label::new("Working Directory")
912 .size(LabelSize::Small)
913 .color(Color::Muted),
914 )
915 .child(render_editor(&self.cwd, window, cx)),
916 )
917 .child(
918 CheckboxWithLabel::new(
919 "debugger-stop-on-entry",
920 Label::new("Stop on Entry")
921 .size(LabelSize::Small)
922 .color(Color::Muted),
923 self.stop_on_entry,
924 {
925 let this = cx.weak_entity();
926 move |state, _, cx| {
927 this.update(cx, |this, _| {
928 this.stop_on_entry = *state;
929 })
930 .ok();
931 }
932 },
933 )
934 .checkbox_position(ui::IconPosition::End),
935 )
936 }
937}
938
939#[derive(Clone)]
940pub(super) struct AttachMode {
941 pub(super) definition: ZedDebugConfig,
942 pub(super) attach_picker: Entity<AttachModal>,
943}
944
945impl AttachMode {
946 pub(super) fn new(
947 debugger: Option<DebugAdapterName>,
948 workspace: WeakEntity<Workspace>,
949 project: Entity<Project>,
950 window: &mut Window,
951 cx: &mut Context<NewProcessModal>,
952 ) -> Entity<Self> {
953 let definition = ZedDebugConfig {
954 adapter: debugger.unwrap_or(DebugAdapterName("".into())).0,
955 label: "Attach New Session Setup".into(),
956 request: dap::DebugRequest::Attach(task::AttachRequest { process_id: None }),
957 stop_on_entry: Some(false),
958 };
959 let attach_picker = cx.new(|cx| {
960 let modal = AttachModal::new(definition.clone(), workspace, project, false, window, cx);
961 window.focus(&modal.focus_handle(cx));
962
963 modal
964 });
965
966 cx.new(|_| Self {
967 definition,
968 attach_picker,
969 })
970 }
971 pub(super) fn debug_request(&self) -> task::AttachRequest {
972 task::AttachRequest { process_id: None }
973 }
974}
975
976#[derive(Clone)]
977pub(super) struct TaskMode {
978 pub(super) task_modal: Entity<TasksModal>,
979}
980
981pub(super) struct DebugDelegate {
982 task_store: Entity<TaskStore>,
983 candidates: Vec<(
984 Option<TaskSourceKind>,
985 Option<LanguageName>,
986 DebugScenario,
987 Option<DebugScenarioContext>,
988 )>,
989 selected_index: usize,
990 matches: Vec<StringMatch>,
991 prompt: String,
992 debug_panel: WeakEntity<DebugPanel>,
993 task_contexts: Option<Arc<TaskContexts>>,
994 divider_index: Option<usize>,
995 last_used_candidate_index: Option<usize>,
996}
997
998impl DebugDelegate {
999 pub(super) fn new(debug_panel: WeakEntity<DebugPanel>, task_store: Entity<TaskStore>) -> Self {
1000 Self {
1001 task_store,
1002 candidates: Vec::default(),
1003 selected_index: 0,
1004 matches: Vec::new(),
1005 prompt: String::new(),
1006 debug_panel,
1007 task_contexts: None,
1008 divider_index: None,
1009 last_used_candidate_index: None,
1010 }
1011 }
1012
1013 fn get_task_subtitle(
1014 &self,
1015 task_kind: &Option<TaskSourceKind>,
1016 context: &Option<DebugScenarioContext>,
1017 cx: &mut App,
1018 ) -> Option<String> {
1019 match task_kind {
1020 Some(TaskSourceKind::Worktree {
1021 id: worktree_id,
1022 directory_in_worktree,
1023 ..
1024 }) => self
1025 .debug_panel
1026 .update(cx, |debug_panel, cx| {
1027 let project = debug_panel.project().read(cx);
1028 let worktrees: Vec<_> = project.visible_worktrees(cx).collect();
1029
1030 let mut path = if worktrees.len() > 1
1031 && let Some(worktree) = project.worktree_for_id(*worktree_id, cx)
1032 {
1033 worktree
1034 .read(cx)
1035 .root_name()
1036 .join(directory_in_worktree)
1037 .to_rel_path_buf()
1038 } else {
1039 directory_in_worktree.to_rel_path_buf()
1040 };
1041
1042 match path.components().next_back() {
1043 Some(".zed") => {
1044 path.push(RelPath::unix("debug.json").unwrap());
1045 }
1046 Some(".vscode") => {
1047 path.push(RelPath::unix("launch.json").unwrap());
1048 }
1049 _ => {}
1050 }
1051 path.display(project.path_style(cx)).to_string()
1052 })
1053 .ok(),
1054 Some(TaskSourceKind::AbsPath { abs_path, .. }) => {
1055 Some(abs_path.to_string_lossy().into_owned())
1056 }
1057 Some(TaskSourceKind::Lsp { language_name, .. }) => {
1058 Some(format!("LSP: {language_name}"))
1059 }
1060 Some(TaskSourceKind::Language { .. }) => None,
1061 _ => context.clone().and_then(|ctx| {
1062 ctx.task_context
1063 .task_variables
1064 .get(&VariableName::RelativeFile)
1065 .map(|f| format!("in {f}"))
1066 .or_else(|| {
1067 ctx.task_context
1068 .task_variables
1069 .get(&VariableName::Dirname)
1070 .map(|d| format!("in {d}/"))
1071 })
1072 }),
1073 }
1074 }
1075
1076 fn get_scenario_language(
1077 languages: &Arc<LanguageRegistry>,
1078 dap_registry: &DapRegistry,
1079 scenario: DebugScenario,
1080 ) -> (Option<LanguageName>, DebugScenario) {
1081 let language_names = languages.language_names();
1082 let language_name = dap_registry.adapter_language(&scenario.adapter);
1083
1084 let language_name = language_name.or_else(|| {
1085 scenario.label.split_whitespace().find_map(|word| {
1086 language_names
1087 .iter()
1088 .find(|name| name.as_ref().eq_ignore_ascii_case(word))
1089 .cloned()
1090 })
1091 });
1092
1093 (language_name, scenario)
1094 }
1095
1096 pub fn tasks_loaded(
1097 &mut self,
1098 task_contexts: Arc<TaskContexts>,
1099 languages: Arc<LanguageRegistry>,
1100 lsp_tasks: Vec<(TaskSourceKind, task::ResolvedTask)>,
1101 current_resolved_tasks: Vec<(TaskSourceKind, task::ResolvedTask)>,
1102 add_current_language_tasks: bool,
1103 cx: &mut Context<Picker<Self>>,
1104 ) -> Task<()> {
1105 self.task_contexts = Some(task_contexts.clone());
1106 let task = self.task_store.update(cx, |task_store, cx| {
1107 task_store.task_inventory().map(|inventory| {
1108 inventory.update(cx, |inventory, cx| {
1109 inventory.list_debug_scenarios(
1110 &task_contexts,
1111 lsp_tasks,
1112 current_resolved_tasks,
1113 add_current_language_tasks,
1114 cx,
1115 )
1116 })
1117 })
1118 });
1119
1120 let valid_adapters: HashSet<_> = cx.global::<DapRegistry>().enumerate_adapters();
1121
1122 cx.spawn(async move |this, cx| {
1123 let (recent, scenarios) = if let Some(task) = task {
1124 task.await
1125 } else {
1126 (Vec::new(), Vec::new())
1127 };
1128
1129 this.update(cx, |this, cx| {
1130 if !recent.is_empty() {
1131 this.delegate.last_used_candidate_index = Some(recent.len() - 1);
1132 }
1133
1134 let dap_registry = cx.global::<DapRegistry>();
1135 let hide_vscode = scenarios.iter().any(|(kind, _)| match kind {
1136 TaskSourceKind::Worktree {
1137 id: _,
1138 directory_in_worktree: dir,
1139 id_base: _,
1140 } => dir.ends_with(RelPath::unix(".zed").unwrap()),
1141 _ => false,
1142 });
1143
1144 this.delegate.candidates = recent
1145 .into_iter()
1146 .map(|(scenario, context)| {
1147 let (language_name, scenario) =
1148 Self::get_scenario_language(&languages, dap_registry, scenario);
1149 (None, language_name, scenario, Some(context))
1150 })
1151 .chain(
1152 scenarios
1153 .into_iter()
1154 .filter(|(kind, _)| match kind {
1155 TaskSourceKind::Worktree {
1156 id: _,
1157 directory_in_worktree: dir,
1158 id_base: _,
1159 } => {
1160 !(hide_vscode
1161 && dir.ends_with(RelPath::unix(".vscode").unwrap()))
1162 }
1163 _ => true,
1164 })
1165 .filter(|(_, scenario)| valid_adapters.contains(&scenario.adapter))
1166 .map(|(kind, scenario)| {
1167 let (language_name, scenario) =
1168 Self::get_scenario_language(&languages, dap_registry, scenario);
1169 (Some(kind), language_name, scenario, None)
1170 }),
1171 )
1172 .collect();
1173 })
1174 .ok();
1175 })
1176 }
1177}
1178
1179impl PickerDelegate for DebugDelegate {
1180 type ListItem = ui::ListItem;
1181
1182 fn match_count(&self) -> usize {
1183 self.matches.len()
1184 }
1185
1186 fn selected_index(&self) -> usize {
1187 self.selected_index
1188 }
1189
1190 fn set_selected_index(
1191 &mut self,
1192 ix: usize,
1193 _window: &mut Window,
1194 _cx: &mut Context<picker::Picker<Self>>,
1195 ) {
1196 self.selected_index = ix;
1197 }
1198
1199 fn placeholder_text(&self, _window: &mut Window, _cx: &mut App) -> std::sync::Arc<str> {
1200 "Find a debug task, or debug a command.".into()
1201 }
1202
1203 fn update_matches(
1204 &mut self,
1205 query: String,
1206 window: &mut Window,
1207 cx: &mut Context<picker::Picker<Self>>,
1208 ) -> gpui::Task<()> {
1209 let candidates = self.candidates.clone();
1210
1211 cx.spawn_in(window, async move |picker, cx| {
1212 let candidates: Vec<_> = candidates
1213 .into_iter()
1214 .enumerate()
1215 .map(|(index, (_, _, candidate, _))| {
1216 StringMatchCandidate::new(index, candidate.label.as_ref())
1217 })
1218 .collect();
1219
1220 let matches = fuzzy::match_strings(
1221 &candidates,
1222 &query,
1223 true,
1224 true,
1225 1000,
1226 &Default::default(),
1227 cx.background_executor().clone(),
1228 )
1229 .await;
1230
1231 picker
1232 .update(cx, |picker, _| {
1233 let delegate = &mut picker.delegate;
1234
1235 delegate.matches = matches;
1236 delegate.prompt = query;
1237
1238 delegate.divider_index = delegate.last_used_candidate_index.and_then(|index| {
1239 let index = delegate
1240 .matches
1241 .partition_point(|matching_task| matching_task.candidate_id <= index);
1242 Some(index).and_then(|index| (index != 0).then(|| index - 1))
1243 });
1244
1245 if delegate.matches.is_empty() {
1246 delegate.selected_index = 0;
1247 } else {
1248 delegate.selected_index =
1249 delegate.selected_index.min(delegate.matches.len() - 1);
1250 }
1251 })
1252 .log_err();
1253 })
1254 }
1255
1256 fn separators_after_indices(&self) -> Vec<usize> {
1257 if let Some(i) = self.divider_index {
1258 vec![i]
1259 } else {
1260 Vec::new()
1261 }
1262 }
1263
1264 fn confirm_input(&mut self, _: bool, window: &mut Window, cx: &mut Context<Picker<Self>>) {
1265 let text = self.prompt.clone();
1266 let (task_context, worktree_id) = self
1267 .task_contexts
1268 .as_ref()
1269 .and_then(|task_contexts| {
1270 Some((
1271 task_contexts.active_context().cloned()?,
1272 task_contexts.worktree(),
1273 ))
1274 })
1275 .unwrap_or_default();
1276
1277 let mut args = ShellKind::Posix
1278 .split(&text)
1279 .into_iter()
1280 .flatten()
1281 .peekable();
1282 let mut env = HashMap::default();
1283 while args.peek().is_some_and(|arg| arg.contains('=')) {
1284 let arg = args.next().unwrap();
1285 let (lhs, rhs) = arg.split_once('=').unwrap();
1286 env.insert(lhs.to_string(), rhs.to_string());
1287 }
1288
1289 let program = if let Some(program) = args.next() {
1290 program
1291 } else {
1292 env = HashMap::default();
1293 text
1294 };
1295
1296 let args = args.collect::<Vec<_>>();
1297 let task = task::TaskTemplate {
1298 label: "one-off".to_owned(), // TODO: rename using command as label
1299 env,
1300 command: program,
1301 args,
1302 ..Default::default()
1303 };
1304
1305 let Some(location) = self
1306 .task_contexts
1307 .as_ref()
1308 .and_then(|cx| cx.location().cloned())
1309 else {
1310 return;
1311 };
1312 let file = location.buffer.read(cx).file();
1313 let language = location.buffer.read(cx).language();
1314 let language_name = language.as_ref().map(|l| l.name());
1315 let Some(adapter): Option<DebugAdapterName> =
1316 language::language_settings::language_settings(language_name, file, cx)
1317 .debuggers
1318 .first()
1319 .map(SharedString::from)
1320 .map(Into::into)
1321 .or_else(|| {
1322 language.and_then(|l| {
1323 l.config()
1324 .debuggers
1325 .first()
1326 .map(SharedString::from)
1327 .map(Into::into)
1328 })
1329 })
1330 else {
1331 return;
1332 };
1333 let locators = cx.global::<DapRegistry>().locators();
1334 cx.spawn_in(window, async move |this, cx| {
1335 let Some(debug_scenario) = cx
1336 .background_spawn(async move {
1337 for locator in locators {
1338 if let Some(scenario) =
1339 // TODO: use a more informative label than "one-off"
1340 locator
1341 .1
1342 .create_scenario(&task, &task.label, &adapter)
1343 .await
1344 {
1345 return Some(scenario);
1346 }
1347 }
1348 None
1349 })
1350 .await
1351 else {
1352 return;
1353 };
1354
1355 this.update_in(cx, |this, window, cx| {
1356 send_telemetry(&debug_scenario, TelemetrySpawnLocation::ScenarioList, cx);
1357 this.delegate
1358 .debug_panel
1359 .update(cx, |panel, cx| {
1360 panel.start_session(
1361 debug_scenario,
1362 task_context,
1363 None,
1364 worktree_id,
1365 window,
1366 cx,
1367 );
1368 })
1369 .ok();
1370 cx.emit(DismissEvent);
1371 })
1372 .ok();
1373 })
1374 .detach();
1375 }
1376
1377 fn confirm(
1378 &mut self,
1379 secondary: bool,
1380 window: &mut Window,
1381 cx: &mut Context<picker::Picker<Self>>,
1382 ) {
1383 let debug_scenario = self
1384 .matches
1385 .get(self.selected_index())
1386 .and_then(|match_candidate| self.candidates.get(match_candidate.candidate_id).cloned());
1387
1388 let Some((kind, _, debug_scenario, context)) = debug_scenario else {
1389 return;
1390 };
1391
1392 let context = context.unwrap_or_else(|| {
1393 self.task_contexts
1394 .as_ref()
1395 .and_then(|task_contexts| {
1396 Some(DebugScenarioContext {
1397 task_context: task_contexts.active_context().cloned()?,
1398 active_buffer: None,
1399 worktree_id: task_contexts.worktree(),
1400 })
1401 })
1402 .unwrap_or_default()
1403 });
1404 let DebugScenarioContext {
1405 task_context,
1406 active_buffer: _,
1407 worktree_id,
1408 } = context;
1409
1410 if secondary {
1411 let Some(kind) = kind else { return };
1412 let Some(id) = worktree_id else { return };
1413 let debug_panel = self.debug_panel.clone();
1414 cx.spawn_in(window, async move |_, cx| {
1415 debug_panel
1416 .update_in(cx, |debug_panel, window, cx| {
1417 debug_panel.go_to_scenario_definition(kind, debug_scenario, id, window, cx)
1418 })?
1419 .await?;
1420 anyhow::Ok(())
1421 })
1422 .detach();
1423 } else {
1424 send_telemetry(&debug_scenario, TelemetrySpawnLocation::ScenarioList, cx);
1425 self.debug_panel
1426 .update(cx, |panel, cx| {
1427 panel.start_session(
1428 debug_scenario,
1429 task_context,
1430 None,
1431 worktree_id,
1432 window,
1433 cx,
1434 );
1435 })
1436 .ok();
1437 }
1438
1439 cx.emit(DismissEvent);
1440 }
1441
1442 fn dismissed(&mut self, _: &mut Window, cx: &mut Context<picker::Picker<Self>>) {
1443 cx.emit(DismissEvent);
1444 }
1445
1446 fn render_footer(
1447 &self,
1448 window: &mut Window,
1449 cx: &mut Context<Picker<Self>>,
1450 ) -> Option<ui::AnyElement> {
1451 let current_modifiers = window.modifiers();
1452 let footer = h_flex()
1453 .w_full()
1454 .p_1p5()
1455 .justify_between()
1456 .border_t_1()
1457 .border_color(cx.theme().colors().border_variant)
1458 .children({
1459 let action = menu::SecondaryConfirm.boxed_clone();
1460 if self.matches.is_empty() {
1461 Some(
1462 Button::new("edit-debug-json", "Edit debug.json")
1463 .label_size(LabelSize::Small)
1464 .on_click(cx.listener(|_picker, _, window, cx| {
1465 window.dispatch_action(
1466 zed_actions::OpenProjectDebugTasks.boxed_clone(),
1467 cx,
1468 );
1469 cx.emit(DismissEvent);
1470 })),
1471 )
1472 } else {
1473 KeyBinding::for_action(&*action, window, cx).map(|keybind| {
1474 Button::new("edit-debug-task", "Edit in debug.json")
1475 .label_size(LabelSize::Small)
1476 .key_binding(keybind)
1477 .on_click(move |_, window, cx| {
1478 window.dispatch_action(action.boxed_clone(), cx)
1479 })
1480 })
1481 }
1482 })
1483 .map(|this| {
1484 if (current_modifiers.alt || self.matches.is_empty()) && !self.prompt.is_empty() {
1485 let action = picker::ConfirmInput { secondary: false }.boxed_clone();
1486 this.children(KeyBinding::for_action(&*action, window, cx).map(|keybind| {
1487 Button::new("launch-custom", "Launch Custom")
1488 .key_binding(keybind)
1489 .on_click(move |_, window, cx| {
1490 window.dispatch_action(action.boxed_clone(), cx)
1491 })
1492 }))
1493 } else {
1494 this.children(KeyBinding::for_action(&menu::Confirm, window, cx).map(
1495 |keybind| {
1496 let is_recent_selected =
1497 self.divider_index >= Some(self.selected_index);
1498 let run_entry_label =
1499 if is_recent_selected { "Rerun" } else { "Spawn" };
1500
1501 Button::new("spawn", run_entry_label)
1502 .key_binding(keybind)
1503 .on_click(|_, window, cx| {
1504 window.dispatch_action(menu::Confirm.boxed_clone(), cx);
1505 })
1506 },
1507 ))
1508 }
1509 });
1510 Some(footer.into_any_element())
1511 }
1512
1513 fn render_match(
1514 &self,
1515 ix: usize,
1516 selected: bool,
1517 window: &mut Window,
1518 cx: &mut Context<picker::Picker<Self>>,
1519 ) -> Option<Self::ListItem> {
1520 let hit = &self.matches.get(ix)?;
1521 let (task_kind, language_name, _scenario, context) = &self.candidates[hit.candidate_id];
1522
1523 let highlighted_location = HighlightedMatch {
1524 text: hit.string.clone(),
1525 highlight_positions: hit.positions.clone(),
1526 color: Color::Default,
1527 };
1528
1529 let subtitle = self.get_task_subtitle(task_kind, context, cx);
1530
1531 let language_icon = language_name.as_ref().and_then(|lang| {
1532 file_icons::FileIcons::get(cx)
1533 .get_icon_for_type(&lang.0.to_lowercase(), cx)
1534 .map(Icon::from_path)
1535 });
1536
1537 let (icon, indicator) = match task_kind {
1538 Some(TaskSourceKind::UserInput) => (Some(Icon::new(IconName::Terminal)), None),
1539 Some(TaskSourceKind::AbsPath { .. }) => (Some(Icon::new(IconName::Settings)), None),
1540 Some(TaskSourceKind::Worktree { .. }) => (Some(Icon::new(IconName::FileTree)), None),
1541 Some(TaskSourceKind::Lsp { language_name, .. }) => (
1542 file_icons::FileIcons::get(cx)
1543 .get_icon_for_type(&language_name.to_lowercase(), cx)
1544 .map(Icon::from_path),
1545 Some(Indicator::icon(
1546 Icon::new(IconName::BoltFilled)
1547 .color(Color::Muted)
1548 .size(IconSize::Small),
1549 )),
1550 ),
1551 Some(TaskSourceKind::Language { name }) => (
1552 file_icons::FileIcons::get(cx)
1553 .get_icon_for_type(&name.to_lowercase(), cx)
1554 .map(Icon::from_path),
1555 None,
1556 ),
1557 None => (Some(Icon::new(IconName::HistoryRerun)), None),
1558 };
1559
1560 let icon = language_icon.or(icon).map(|icon| {
1561 IconWithIndicator::new(icon.color(Color::Muted).size(IconSize::Small), indicator)
1562 .indicator_border_color(Some(cx.theme().colors().border_transparent))
1563 });
1564
1565 Some(
1566 ListItem::new(SharedString::from(format!("debug-scenario-selection-{ix}")))
1567 .inset(true)
1568 .start_slot::<IconWithIndicator>(icon)
1569 .spacing(ListItemSpacing::Sparse)
1570 .toggle_state(selected)
1571 .child(
1572 v_flex()
1573 .items_start()
1574 .child(highlighted_location.render(window, cx))
1575 .when_some(subtitle, |this, subtitle_text| {
1576 this.child(
1577 Label::new(subtitle_text)
1578 .size(LabelSize::Small)
1579 .color(Color::Muted),
1580 )
1581 }),
1582 ),
1583 )
1584 }
1585}
1586
1587pub(crate) fn resolve_path(path: &mut String) {
1588 if path.starts_with('~') {
1589 let home = paths::home_dir().to_string_lossy().into_owned();
1590 let trimmed_path = path.trim().to_owned();
1591 *path = trimmed_path.replacen('~', &home, 1);
1592 } else if let Some(strip_path) = path.strip_prefix(&format!(".{}", std::path::MAIN_SEPARATOR)) {
1593 *path = format!(
1594 "$ZED_WORKTREE_ROOT{}{}",
1595 std::path::MAIN_SEPARATOR,
1596 &strip_path
1597 );
1598 };
1599}
1600
1601#[cfg(test)]
1602impl NewProcessModal {
1603 pub(crate) fn set_configure(
1604 &mut self,
1605 program: impl AsRef<str>,
1606 cwd: impl AsRef<str>,
1607 stop_on_entry: bool,
1608 window: &mut Window,
1609 cx: &mut Context<Self>,
1610 ) {
1611 self.mode = NewProcessMode::Launch;
1612 self.debugger = Some(dap::adapters::DebugAdapterName("fake-adapter".into()));
1613
1614 self.configure_mode.update(cx, |configure, cx| {
1615 configure.program.update(cx, |editor, cx| {
1616 editor.clear(window, cx);
1617 editor.set_text(program.as_ref(), window, cx);
1618 });
1619
1620 configure.cwd.update(cx, |editor, cx| {
1621 editor.clear(window, cx);
1622 editor.set_text(cwd.as_ref(), window, cx);
1623 });
1624
1625 configure.stop_on_entry = match stop_on_entry {
1626 true => ToggleState::Selected,
1627 _ => ToggleState::Unselected,
1628 }
1629 })
1630 }
1631
1632 pub(crate) fn debug_picker_candidate_subtitles(&self, cx: &mut App) -> Vec<String> {
1633 self.debug_picker.update(cx, |picker, cx| {
1634 picker
1635 .delegate
1636 .candidates
1637 .iter()
1638 .filter_map(|(task_kind, _, _, context)| {
1639 picker.delegate.get_task_subtitle(task_kind, context, cx)
1640 })
1641 .collect()
1642 })
1643 }
1644}