new_process_modal.rs

   1use anyhow::{Context as _, bail};
   2use collections::{FxHashMap, HashMap, HashSet};
   3use language::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, 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;
  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", 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", 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 = shlex::split(&command).into_iter().flatten().peekable();
 848        let mut env = FxHashMap::default();
 849        while args.peek().is_some_and(|arg| arg.contains('=')) {
 850            let arg = args.next().unwrap();
 851            let (lhs, rhs) = arg.split_once('=').unwrap();
 852            env.insert(lhs.to_string(), rhs.to_string());
 853        }
 854
 855        let program = if let Some(program) = args.next() {
 856            program
 857        } else {
 858            env = FxHashMap::default();
 859            command
 860        };
 861
 862        let args = args.collect::<Vec<_>>();
 863
 864        task::LaunchRequest {
 865            program,
 866            cwd,
 867            args,
 868            env,
 869        }
 870    }
 871
 872    fn render(
 873        &mut self,
 874        adapter_menu: DropdownMenu,
 875        window: &mut Window,
 876        cx: &mut ui::Context<Self>,
 877    ) -> impl IntoElement {
 878        v_flex()
 879            .p_2()
 880            .w_full()
 881            .gap_2()
 882            .track_focus(&self.program.focus_handle(cx))
 883            .child(
 884                h_flex()
 885                    .gap_2()
 886                    .child(
 887                        Label::new("Debugger")
 888                            .size(LabelSize::Small)
 889                            .color(Color::Muted),
 890                    )
 891                    .child(adapter_menu),
 892            )
 893            .child(
 894                v_flex()
 895                    .gap_0p5()
 896                    .child(
 897                        Label::new("Program")
 898                            .size(LabelSize::Small)
 899                            .color(Color::Muted),
 900                    )
 901                    .child(render_editor(&self.program, window, cx)),
 902            )
 903            .child(
 904                v_flex()
 905                    .gap_0p5()
 906                    .child(
 907                        Label::new("Working Directory")
 908                            .size(LabelSize::Small)
 909                            .color(Color::Muted),
 910                    )
 911                    .child(render_editor(&self.cwd, window, cx)),
 912            )
 913            .child(
 914                CheckboxWithLabel::new(
 915                    "debugger-stop-on-entry",
 916                    Label::new("Stop on Entry")
 917                        .size(LabelSize::Small)
 918                        .color(Color::Muted),
 919                    self.stop_on_entry,
 920                    {
 921                        let this = cx.weak_entity();
 922                        move |state, _, cx| {
 923                            this.update(cx, |this, _| {
 924                                this.stop_on_entry = *state;
 925                            })
 926                            .ok();
 927                        }
 928                    },
 929                )
 930                .checkbox_position(ui::IconPosition::End),
 931            )
 932    }
 933}
 934
 935#[derive(Clone)]
 936pub(super) struct AttachMode {
 937    pub(super) definition: ZedDebugConfig,
 938    pub(super) attach_picker: Entity<AttachModal>,
 939}
 940
 941impl AttachMode {
 942    pub(super) fn new(
 943        debugger: Option<DebugAdapterName>,
 944        workspace: WeakEntity<Workspace>,
 945        project: Entity<Project>,
 946        window: &mut Window,
 947        cx: &mut Context<NewProcessModal>,
 948    ) -> Entity<Self> {
 949        let definition = ZedDebugConfig {
 950            adapter: debugger.unwrap_or(DebugAdapterName("".into())).0,
 951            label: "Attach New Session Setup".into(),
 952            request: dap::DebugRequest::Attach(task::AttachRequest { process_id: None }),
 953            stop_on_entry: Some(false),
 954        };
 955        let attach_picker = cx.new(|cx| {
 956            let modal = AttachModal::new(definition.clone(), workspace, project, false, window, cx);
 957            window.focus(&modal.focus_handle(cx));
 958
 959            modal
 960        });
 961
 962        cx.new(|_| Self {
 963            definition,
 964            attach_picker,
 965        })
 966    }
 967    pub(super) fn debug_request(&self) -> task::AttachRequest {
 968        task::AttachRequest { process_id: None }
 969    }
 970}
 971
 972#[derive(Clone)]
 973pub(super) struct TaskMode {
 974    pub(super) task_modal: Entity<TasksModal>,
 975}
 976
 977pub(super) struct DebugDelegate {
 978    task_store: Entity<TaskStore>,
 979    candidates: Vec<(
 980        Option<TaskSourceKind>,
 981        DebugScenario,
 982        Option<DebugScenarioContext>,
 983    )>,
 984    selected_index: usize,
 985    matches: Vec<StringMatch>,
 986    prompt: String,
 987    debug_panel: WeakEntity<DebugPanel>,
 988    task_contexts: Option<Arc<TaskContexts>>,
 989    divider_index: Option<usize>,
 990    last_used_candidate_index: Option<usize>,
 991}
 992
 993impl DebugDelegate {
 994    pub(super) fn new(debug_panel: WeakEntity<DebugPanel>, task_store: Entity<TaskStore>) -> Self {
 995        Self {
 996            task_store,
 997            candidates: Vec::default(),
 998            selected_index: 0,
 999            matches: Vec::new(),
1000            prompt: String::new(),
1001            debug_panel,
1002            task_contexts: None,
1003            divider_index: None,
1004            last_used_candidate_index: None,
1005        }
1006    }
1007
1008    fn get_scenario_kind(
1009        languages: &Arc<LanguageRegistry>,
1010        dap_registry: &DapRegistry,
1011        scenario: DebugScenario,
1012    ) -> (Option<TaskSourceKind>, DebugScenario) {
1013        let language_names = languages.language_names();
1014        let language = dap_registry
1015            .adapter_language(&scenario.adapter)
1016            .map(|language| TaskSourceKind::Language { name: language.0 });
1017
1018        let language = language.or_else(|| {
1019            scenario.label.split_whitespace().find_map(|word| {
1020                language_names
1021                    .iter()
1022                    .find(|name| name.as_ref().eq_ignore_ascii_case(word))
1023                    .map(|name| TaskSourceKind::Language {
1024                        name: name.to_owned().into(),
1025                    })
1026            })
1027        });
1028
1029        (language, scenario)
1030    }
1031
1032    pub fn tasks_loaded(
1033        &mut self,
1034        task_contexts: Arc<TaskContexts>,
1035        languages: Arc<LanguageRegistry>,
1036        lsp_tasks: Vec<(TaskSourceKind, task::ResolvedTask)>,
1037        current_resolved_tasks: Vec<(TaskSourceKind, task::ResolvedTask)>,
1038        add_current_language_tasks: bool,
1039        cx: &mut Context<Picker<Self>>,
1040    ) -> Task<()> {
1041        self.task_contexts = Some(task_contexts.clone());
1042        let task = self.task_store.update(cx, |task_store, cx| {
1043            task_store.task_inventory().map(|inventory| {
1044                inventory.update(cx, |inventory, cx| {
1045                    inventory.list_debug_scenarios(
1046                        &task_contexts,
1047                        lsp_tasks,
1048                        current_resolved_tasks,
1049                        add_current_language_tasks,
1050                        cx,
1051                    )
1052                })
1053            })
1054        });
1055
1056        let valid_adapters: HashSet<_> = cx.global::<DapRegistry>().enumerate_adapters();
1057
1058        cx.spawn(async move |this, cx| {
1059            let (recent, scenarios) = if let Some(task) = task {
1060                task.await
1061            } else {
1062                (Vec::new(), Vec::new())
1063            };
1064
1065            this.update(cx, |this, cx| {
1066                if !recent.is_empty() {
1067                    this.delegate.last_used_candidate_index = Some(recent.len() - 1);
1068                }
1069
1070                let dap_registry = cx.global::<DapRegistry>();
1071                let hide_vscode = scenarios.iter().any(|(kind, _)| match kind {
1072                    TaskSourceKind::Worktree {
1073                        id: _,
1074                        directory_in_worktree: dir,
1075                        id_base: _,
1076                    } => dir.ends_with(".zed"),
1077                    _ => false,
1078                });
1079
1080                this.delegate.candidates = recent
1081                    .into_iter()
1082                    .map(|(scenario, context)| {
1083                        let (kind, scenario) =
1084                            Self::get_scenario_kind(&languages, dap_registry, scenario);
1085                        (kind, scenario, Some(context))
1086                    })
1087                    .chain(
1088                        scenarios
1089                            .into_iter()
1090                            .filter(|(kind, _)| match kind {
1091                                TaskSourceKind::Worktree {
1092                                    id: _,
1093                                    directory_in_worktree: dir,
1094                                    id_base: _,
1095                                } => !(hide_vscode && dir.ends_with(".vscode")),
1096                                _ => true,
1097                            })
1098                            .filter(|(_, scenario)| valid_adapters.contains(&scenario.adapter))
1099                            .map(|(kind, scenario)| {
1100                                let (language, scenario) =
1101                                    Self::get_scenario_kind(&languages, dap_registry, scenario);
1102                                (language.or(Some(kind)), scenario, None)
1103                            }),
1104                    )
1105                    .collect();
1106            })
1107            .ok();
1108        })
1109    }
1110}
1111
1112impl PickerDelegate for DebugDelegate {
1113    type ListItem = ui::ListItem;
1114
1115    fn match_count(&self) -> usize {
1116        self.matches.len()
1117    }
1118
1119    fn selected_index(&self) -> usize {
1120        self.selected_index
1121    }
1122
1123    fn set_selected_index(
1124        &mut self,
1125        ix: usize,
1126        _window: &mut Window,
1127        _cx: &mut Context<picker::Picker<Self>>,
1128    ) {
1129        self.selected_index = ix;
1130    }
1131
1132    fn placeholder_text(&self, _window: &mut Window, _cx: &mut App) -> std::sync::Arc<str> {
1133        "Find a debug task, or debug a command.".into()
1134    }
1135
1136    fn update_matches(
1137        &mut self,
1138        query: String,
1139        window: &mut Window,
1140        cx: &mut Context<picker::Picker<Self>>,
1141    ) -> gpui::Task<()> {
1142        let candidates = self.candidates.clone();
1143
1144        cx.spawn_in(window, async move |picker, cx| {
1145            let candidates: Vec<_> = candidates
1146                .into_iter()
1147                .enumerate()
1148                .map(|(index, (_, candidate, _))| {
1149                    StringMatchCandidate::new(index, candidate.label.as_ref())
1150                })
1151                .collect();
1152
1153            let matches = fuzzy::match_strings(
1154                &candidates,
1155                &query,
1156                true,
1157                true,
1158                1000,
1159                &Default::default(),
1160                cx.background_executor().clone(),
1161            )
1162            .await;
1163
1164            picker
1165                .update(cx, |picker, _| {
1166                    let delegate = &mut picker.delegate;
1167
1168                    delegate.matches = matches;
1169                    delegate.prompt = query;
1170
1171                    delegate.divider_index = delegate.last_used_candidate_index.and_then(|index| {
1172                        let index = delegate
1173                            .matches
1174                            .partition_point(|matching_task| matching_task.candidate_id <= index);
1175                        Some(index).and_then(|index| (index != 0).then(|| index - 1))
1176                    });
1177
1178                    if delegate.matches.is_empty() {
1179                        delegate.selected_index = 0;
1180                    } else {
1181                        delegate.selected_index =
1182                            delegate.selected_index.min(delegate.matches.len() - 1);
1183                    }
1184                })
1185                .log_err();
1186        })
1187    }
1188
1189    fn separators_after_indices(&self) -> Vec<usize> {
1190        if let Some(i) = self.divider_index {
1191            vec![i]
1192        } else {
1193            Vec::new()
1194        }
1195    }
1196
1197    fn confirm_input(&mut self, _: bool, window: &mut Window, cx: &mut Context<Picker<Self>>) {
1198        let text = self.prompt.clone();
1199        let (task_context, worktree_id) = self
1200            .task_contexts
1201            .as_ref()
1202            .and_then(|task_contexts| {
1203                Some((
1204                    task_contexts.active_context().cloned()?,
1205                    task_contexts.worktree(),
1206                ))
1207            })
1208            .unwrap_or_default();
1209
1210        let mut args = shlex::split(&text).into_iter().flatten().peekable();
1211        let mut env = HashMap::default();
1212        while args.peek().is_some_and(|arg| arg.contains('=')) {
1213            let arg = args.next().unwrap();
1214            let (lhs, rhs) = arg.split_once('=').unwrap();
1215            env.insert(lhs.to_string(), rhs.to_string());
1216        }
1217
1218        let program = if let Some(program) = args.next() {
1219            program
1220        } else {
1221            env = HashMap::default();
1222            text
1223        };
1224
1225        let args = args.collect::<Vec<_>>();
1226        let task = task::TaskTemplate {
1227            label: "one-off".to_owned(), // TODO: rename using command as label
1228            env,
1229            command: program,
1230            args,
1231            ..Default::default()
1232        };
1233
1234        let Some(location) = self
1235            .task_contexts
1236            .as_ref()
1237            .and_then(|cx| cx.location().cloned())
1238        else {
1239            return;
1240        };
1241        let file = location.buffer.read(cx).file();
1242        let language = location.buffer.read(cx).language();
1243        let language_name = language.as_ref().map(|l| l.name());
1244        let Some(adapter): Option<DebugAdapterName> =
1245            language::language_settings::language_settings(language_name, file, cx)
1246                .debuggers
1247                .first()
1248                .map(SharedString::from)
1249                .map(Into::into)
1250                .or_else(|| {
1251                    language.and_then(|l| {
1252                        l.config()
1253                            .debuggers
1254                            .first()
1255                            .map(SharedString::from)
1256                            .map(Into::into)
1257                    })
1258                })
1259        else {
1260            return;
1261        };
1262        let locators = cx.global::<DapRegistry>().locators();
1263        cx.spawn_in(window, async move |this, cx| {
1264            let Some(debug_scenario) = cx
1265                .background_spawn(async move {
1266                    for locator in locators {
1267                        if let Some(scenario) =
1268                            // TODO: use a more informative label than "one-off"
1269                            locator
1270                                .1
1271                                .create_scenario(&task, &task.label, &adapter)
1272                                .await
1273                        {
1274                            return Some(scenario);
1275                        }
1276                    }
1277                    None
1278                })
1279                .await
1280            else {
1281                return;
1282            };
1283
1284            this.update_in(cx, |this, window, cx| {
1285                send_telemetry(&debug_scenario, TelemetrySpawnLocation::ScenarioList, cx);
1286                this.delegate
1287                    .debug_panel
1288                    .update(cx, |panel, cx| {
1289                        panel.start_session(
1290                            debug_scenario,
1291                            task_context,
1292                            None,
1293                            worktree_id,
1294                            window,
1295                            cx,
1296                        );
1297                    })
1298                    .ok();
1299                cx.emit(DismissEvent);
1300            })
1301            .ok();
1302        })
1303        .detach();
1304    }
1305
1306    fn confirm(
1307        &mut self,
1308        secondary: bool,
1309        window: &mut Window,
1310        cx: &mut Context<picker::Picker<Self>>,
1311    ) {
1312        let debug_scenario = self
1313            .matches
1314            .get(self.selected_index())
1315            .and_then(|match_candidate| self.candidates.get(match_candidate.candidate_id).cloned());
1316
1317        let Some((kind, debug_scenario, context)) = debug_scenario else {
1318            return;
1319        };
1320
1321        let context = context.unwrap_or_else(|| {
1322            self.task_contexts
1323                .as_ref()
1324                .and_then(|task_contexts| {
1325                    Some(DebugScenarioContext {
1326                        task_context: task_contexts.active_context().cloned()?,
1327                        active_buffer: None,
1328                        worktree_id: task_contexts.worktree(),
1329                    })
1330                })
1331                .unwrap_or_default()
1332        });
1333        let DebugScenarioContext {
1334            task_context,
1335            active_buffer: _,
1336            worktree_id,
1337        } = context;
1338
1339        if secondary {
1340            let Some(kind) = kind else { return };
1341            let Some(id) = worktree_id else { return };
1342            let debug_panel = self.debug_panel.clone();
1343            cx.spawn_in(window, async move |_, cx| {
1344                debug_panel
1345                    .update_in(cx, |debug_panel, window, cx| {
1346                        debug_panel.go_to_scenario_definition(kind, debug_scenario, id, window, cx)
1347                    })?
1348                    .await?;
1349                anyhow::Ok(())
1350            })
1351            .detach();
1352        } else {
1353            send_telemetry(&debug_scenario, TelemetrySpawnLocation::ScenarioList, cx);
1354            self.debug_panel
1355                .update(cx, |panel, cx| {
1356                    panel.start_session(
1357                        debug_scenario,
1358                        task_context,
1359                        None,
1360                        worktree_id,
1361                        window,
1362                        cx,
1363                    );
1364                })
1365                .ok();
1366        }
1367
1368        cx.emit(DismissEvent);
1369    }
1370
1371    fn dismissed(&mut self, _: &mut Window, cx: &mut Context<picker::Picker<Self>>) {
1372        cx.emit(DismissEvent);
1373    }
1374
1375    fn render_footer(
1376        &self,
1377        window: &mut Window,
1378        cx: &mut Context<Picker<Self>>,
1379    ) -> Option<ui::AnyElement> {
1380        let current_modifiers = window.modifiers();
1381        let footer = h_flex()
1382            .w_full()
1383            .p_1p5()
1384            .justify_between()
1385            .border_t_1()
1386            .border_color(cx.theme().colors().border_variant)
1387            .children({
1388                let action = menu::SecondaryConfirm.boxed_clone();
1389                if self.matches.is_empty() {
1390                    Some(
1391                        Button::new("edit-debug-json", "Edit debug.json")
1392                            .label_size(LabelSize::Small)
1393                            .on_click(cx.listener(|_picker, _, window, cx| {
1394                                window.dispatch_action(
1395                                    zed_actions::OpenProjectDebugTasks.boxed_clone(),
1396                                    cx,
1397                                );
1398                                cx.emit(DismissEvent);
1399                            })),
1400                    )
1401                } else {
1402                    KeyBinding::for_action(&*action, window, cx).map(|keybind| {
1403                        Button::new("edit-debug-task", "Edit in debug.json")
1404                            .label_size(LabelSize::Small)
1405                            .key_binding(keybind)
1406                            .on_click(move |_, window, cx| {
1407                                window.dispatch_action(action.boxed_clone(), cx)
1408                            })
1409                    })
1410                }
1411            })
1412            .map(|this| {
1413                if (current_modifiers.alt || self.matches.is_empty()) && !self.prompt.is_empty() {
1414                    let action = picker::ConfirmInput { secondary: false }.boxed_clone();
1415                    this.children(KeyBinding::for_action(&*action, window, cx).map(|keybind| {
1416                        Button::new("launch-custom", "Launch Custom")
1417                            .key_binding(keybind)
1418                            .on_click(move |_, window, cx| {
1419                                window.dispatch_action(action.boxed_clone(), cx)
1420                            })
1421                    }))
1422                } else {
1423                    this.children(KeyBinding::for_action(&menu::Confirm, window, cx).map(
1424                        |keybind| {
1425                            let is_recent_selected =
1426                                self.divider_index >= Some(self.selected_index);
1427                            let run_entry_label =
1428                                if is_recent_selected { "Rerun" } else { "Spawn" };
1429
1430                            Button::new("spawn", run_entry_label)
1431                                .key_binding(keybind)
1432                                .on_click(|_, window, cx| {
1433                                    window.dispatch_action(menu::Confirm.boxed_clone(), cx);
1434                                })
1435                        },
1436                    ))
1437                }
1438            });
1439        Some(footer.into_any_element())
1440    }
1441
1442    fn render_match(
1443        &self,
1444        ix: usize,
1445        selected: bool,
1446        window: &mut Window,
1447        cx: &mut Context<picker::Picker<Self>>,
1448    ) -> Option<Self::ListItem> {
1449        let hit = &self.matches[ix];
1450
1451        let highlighted_location = HighlightedMatch {
1452            text: hit.string.clone(),
1453            highlight_positions: hit.positions.clone(),
1454            char_count: hit.string.chars().count(),
1455            color: Color::Default,
1456        };
1457        let task_kind = &self.candidates[hit.candidate_id].0;
1458
1459        let icon = match task_kind {
1460            Some(TaskSourceKind::UserInput) => Some(Icon::new(IconName::Terminal)),
1461            Some(TaskSourceKind::AbsPath { .. }) => Some(Icon::new(IconName::Settings)),
1462            Some(TaskSourceKind::Worktree { .. }) => Some(Icon::new(IconName::FileTree)),
1463            Some(TaskSourceKind::Lsp {
1464                language_name: name,
1465                ..
1466            })
1467            | Some(TaskSourceKind::Language { name }) => file_icons::FileIcons::get(cx)
1468                .get_icon_for_type(&name.to_lowercase(), cx)
1469                .map(Icon::from_path),
1470            None => Some(Icon::new(IconName::HistoryRerun)),
1471        }
1472        .map(|icon| icon.color(Color::Muted).size(IconSize::Small));
1473        let indicator = if matches!(task_kind, Some(TaskSourceKind::Lsp { .. })) {
1474            Some(Indicator::icon(
1475                Icon::new(IconName::BoltFilled)
1476                    .color(Color::Muted)
1477                    .size(IconSize::Small),
1478            ))
1479        } else {
1480            None
1481        };
1482        let icon = icon.map(|icon| {
1483            IconWithIndicator::new(icon, indicator)
1484                .indicator_border_color(Some(cx.theme().colors().border_transparent))
1485        });
1486
1487        Some(
1488            ListItem::new(SharedString::from(format!("debug-scenario-selection-{ix}")))
1489                .inset(true)
1490                .start_slot::<IconWithIndicator>(icon)
1491                .spacing(ListItemSpacing::Sparse)
1492                .toggle_state(selected)
1493                .child(highlighted_location.render(window, cx)),
1494        )
1495    }
1496}
1497
1498pub(crate) fn resolve_path(path: &mut String) {
1499    if path.starts_with('~') {
1500        let home = paths::home_dir().to_string_lossy().to_string();
1501        let trimmed_path = path.trim().to_owned();
1502        *path = trimmed_path.replacen('~', &home, 1);
1503    } else if let Some(strip_path) = path.strip_prefix(&format!(".{}", std::path::MAIN_SEPARATOR)) {
1504        *path = format!(
1505            "$ZED_WORKTREE_ROOT{}{}",
1506            std::path::MAIN_SEPARATOR,
1507            &strip_path
1508        );
1509    };
1510}
1511
1512#[cfg(test)]
1513impl NewProcessModal {
1514    pub(crate) fn set_configure(
1515        &mut self,
1516        program: impl AsRef<str>,
1517        cwd: impl AsRef<str>,
1518        stop_on_entry: bool,
1519        window: &mut Window,
1520        cx: &mut Context<Self>,
1521    ) {
1522        self.mode = NewProcessMode::Launch;
1523        self.debugger = Some(dap::adapters::DebugAdapterName("fake-adapter".into()));
1524
1525        self.configure_mode.update(cx, |configure, cx| {
1526            configure.program.update(cx, |editor, cx| {
1527                editor.clear(window, cx);
1528                editor.set_text(program.as_ref(), window, cx);
1529            });
1530
1531            configure.cwd.update(cx, |editor, cx| {
1532                editor.clear(window, cx);
1533                editor.set_text(cwd.as_ref(), window, cx);
1534            });
1535
1536            configure.stop_on_entry = match stop_on_entry {
1537                true => ToggleState::Selected,
1538                _ => ToggleState::Unselected,
1539            }
1540        })
1541    }
1542}