debugger_ui.rs

  1use std::any::TypeId;
  2
  3use dap::debugger_settings::DebuggerSettings;
  4use debugger_panel::DebugPanel;
  5use editor::Editor;
  6use gpui::{Action, App, DispatchPhase, EntityInputHandler, actions};
  7use new_process_modal::{NewProcessModal, NewProcessMode};
  8use onboarding_modal::DebuggerOnboardingModal;
  9use project::debugger::{self, breakpoint_store::SourceBreakpoint, session::ThreadStatus};
 10use schemars::JsonSchema;
 11use serde::Deserialize;
 12use session::DebugSession;
 13use settings::Settings;
 14use stack_trace_view::StackTraceView;
 15use tasks_ui::{Spawn, TaskOverrides};
 16use ui::{FluentBuilder, InteractiveElement};
 17use util::maybe;
 18use workspace::{ItemHandle, ShutdownDebugAdapters, Workspace};
 19use zed_actions::ToggleFocus;
 20use zed_actions::debugger::OpenOnboardingModal;
 21
 22pub mod attach_modal;
 23pub mod debugger_panel;
 24mod dropdown_menus;
 25mod new_process_modal;
 26mod onboarding_modal;
 27mod persistence;
 28pub(crate) mod session;
 29mod stack_trace_view;
 30
 31#[cfg(any(test, feature = "test-support"))]
 32pub mod tests;
 33
 34actions!(
 35    debugger,
 36    [
 37        /// Starts a new debugging session.
 38        Start,
 39        /// Continues execution until the next breakpoint.
 40        Continue,
 41        /// Detaches the debugger from the running process.
 42        Detach,
 43        /// Pauses the currently running program.
 44        Pause,
 45        /// Restarts the current debugging session.
 46        Restart,
 47        /// Reruns the current debugging session with the same configuration.
 48        RerunSession,
 49        /// Steps into the next function call.
 50        StepInto,
 51        /// Steps over the current line.
 52        StepOver,
 53        /// Steps out of the current function.
 54        StepOut,
 55        /// Steps back to the previous statement.
 56        StepBack,
 57        /// Stops the debugging session.
 58        Stop,
 59        /// Toggles whether to ignore all breakpoints.
 60        ToggleIgnoreBreakpoints,
 61        /// Clears all breakpoints in the project.
 62        ClearAllBreakpoints,
 63        /// Focuses on the debugger console panel.
 64        FocusConsole,
 65        /// Focuses on the variables panel.
 66        FocusVariables,
 67        /// Focuses on the breakpoint list panel.
 68        FocusBreakpointList,
 69        /// Focuses on the call stack frames panel.
 70        FocusFrames,
 71        /// Focuses on the loaded modules panel.
 72        FocusModules,
 73        /// Focuses on the loaded sources panel.
 74        FocusLoadedSources,
 75        /// Focuses on the terminal panel.
 76        FocusTerminal,
 77        /// Shows the stack trace for the current thread.
 78        ShowStackTrace,
 79        /// Toggles the thread picker dropdown.
 80        ToggleThreadPicker,
 81        /// Toggles the session picker dropdown.
 82        ToggleSessionPicker,
 83        /// Reruns the last debugging session.
 84        #[action(deprecated_aliases = ["debugger::RerunLastSession"])]
 85        Rerun,
 86        /// Toggles expansion of the selected item in the debugger UI.
 87        ToggleExpandItem,
 88    ]
 89);
 90
 91/// Extends selection down by a specified number of lines.
 92#[derive(PartialEq, Clone, Deserialize, Default, JsonSchema, Action)]
 93#[action(namespace = debugger)]
 94#[serde(deny_unknown_fields)]
 95/// Set a data breakpoint on the selected variable or memory region.
 96pub struct ToggleDataBreakpoint {
 97    /// The type of data breakpoint
 98    /// Read & Write
 99    /// Read
100    /// Write
101    #[serde(default)]
102    pub access_type: Option<dap::DataBreakpointAccessType>,
103}
104
105actions!(
106    dev,
107    [
108        /// Copies debug adapter launch arguments to clipboard.
109        CopyDebugAdapterArguments
110    ]
111);
112
113pub fn init(cx: &mut App) {
114    DebuggerSettings::register(cx);
115    workspace::FollowableViewRegistry::register::<DebugSession>(cx);
116
117    cx.observe_new(|workspace: &mut Workspace, _, _| {
118        workspace
119            .register_action(spawn_task_or_modal)
120            .register_action(|workspace, _: &ToggleFocus, window, cx| {
121                workspace.toggle_panel_focus::<DebugPanel>(window, cx);
122            })
123            .register_action(|workspace: &mut Workspace, _: &Start, window, cx| {
124                NewProcessModal::show(workspace, window, NewProcessMode::Debug, None, cx);
125            })
126            .register_action(|workspace: &mut Workspace, _: &Rerun, window, cx| {
127                let Some(debug_panel) = workspace.panel::<DebugPanel>(cx) else {
128                    return;
129                };
130
131                debug_panel.update(cx, |debug_panel, cx| {
132                    debug_panel.rerun_last_session(workspace, window, cx);
133                })
134            })
135            .register_action(
136                |workspace: &mut Workspace, _: &ShutdownDebugAdapters, _window, cx| {
137                    workspace.project().update(cx, |project, cx| {
138                        project.dap_store().update(cx, |store, cx| {
139                            store.shutdown_sessions(cx).detach();
140                        })
141                    })
142                },
143            )
144            .register_action(|workspace, _: &OpenOnboardingModal, window, cx| {
145                DebuggerOnboardingModal::toggle(workspace, window, cx)
146            })
147            .register_action_renderer(|div, workspace, _, cx| {
148                let Some(debug_panel) = workspace.panel::<DebugPanel>(cx) else {
149                    return div;
150                };
151                let Some(active_item) = debug_panel
152                    .read(cx)
153                    .active_session()
154                    .map(|session| session.read(cx).running_state().clone())
155                else {
156                    return div;
157                };
158                let running_state = active_item.read(cx);
159                if running_state.session().read(cx).is_terminated() {
160                    return div;
161                }
162
163                let caps = running_state.capabilities(cx);
164                let supports_step_back = caps.supports_step_back.unwrap_or_default();
165                let supports_detach = running_state.session().read(cx).is_attached();
166                let status = running_state.thread_status(cx);
167
168                let active_item = active_item.downgrade();
169                div.when(status == Some(ThreadStatus::Running), |div| {
170                    let active_item = active_item.clone();
171                    div.on_action(move |_: &Pause, _, cx| {
172                        active_item
173                            .update(cx, |item, cx| item.pause_thread(cx))
174                            .ok();
175                    })
176                })
177                .when(status == Some(ThreadStatus::Stopped), |div| {
178                    div.on_action({
179                        let active_item = active_item.clone();
180                        move |_: &StepInto, _, cx| {
181                            active_item.update(cx, |item, cx| item.step_in(cx)).ok();
182                        }
183                    })
184                    .on_action({
185                        let active_item = active_item.clone();
186                        move |_: &StepOver, _, cx| {
187                            active_item.update(cx, |item, cx| item.step_over(cx)).ok();
188                        }
189                    })
190                    .on_action({
191                        let active_item = active_item.clone();
192                        move |_: &StepOut, _, cx| {
193                            active_item.update(cx, |item, cx| item.step_out(cx)).ok();
194                        }
195                    })
196                    .when(supports_step_back, |div| {
197                        let active_item = active_item.clone();
198                        div.on_action(move |_: &StepBack, _, cx| {
199                            active_item.update(cx, |item, cx| item.step_back(cx)).ok();
200                        })
201                    })
202                    .on_action({
203                        let active_item = active_item.clone();
204                        move |_: &Continue, _, cx| {
205                            active_item
206                                .update(cx, |item, cx| item.continue_thread(cx))
207                                .ok();
208                        }
209                    })
210                    .on_action(cx.listener(
211                        |workspace, _: &ShowStackTrace, window, cx| {
212                            let Some(debug_panel) = workspace.panel::<DebugPanel>(cx) else {
213                                return;
214                            };
215
216                            if let Some(existing) = workspace.item_of_type::<StackTraceView>(cx) {
217                                let is_active = workspace
218                                    .active_item(cx)
219                                    .is_some_and(|item| item.item_id() == existing.item_id());
220                                workspace.activate_item(&existing, true, !is_active, window, cx);
221                            } else {
222                                let Some(active_session) = debug_panel.read(cx).active_session()
223                                else {
224                                    return;
225                                };
226
227                                let project = workspace.project();
228
229                                let stack_trace_view = active_session.update(cx, |session, cx| {
230                                    session.stack_trace_view(project, window, cx).clone()
231                                });
232
233                                workspace.add_item_to_active_pane(
234                                    Box::new(stack_trace_view),
235                                    None,
236                                    true,
237                                    window,
238                                    cx,
239                                );
240                            }
241                        },
242                    ))
243                })
244                .when(supports_detach, |div| {
245                    let active_item = active_item.clone();
246                    div.on_action(move |_: &Detach, _, cx| {
247                        active_item
248                            .update(cx, |item, cx| item.detach_client(cx))
249                            .ok();
250                    })
251                })
252                .on_action({
253                    let active_item = active_item.clone();
254                    move |_: &Restart, _, cx| {
255                        active_item
256                            .update(cx, |item, cx| item.restart_session(cx))
257                            .ok();
258                    }
259                })
260                .on_action({
261                    let active_item = active_item.clone();
262                    move |_: &RerunSession, window, cx| {
263                        active_item
264                            .update(cx, |item, cx| item.rerun_session(window, cx))
265                            .ok();
266                    }
267                })
268                .on_action({
269                    let active_item = active_item.clone();
270                    move |_: &Stop, _, cx| {
271                        active_item.update(cx, |item, cx| item.stop_thread(cx)).ok();
272                    }
273                })
274                .on_action({
275                    move |_: &ToggleIgnoreBreakpoints, _, cx| {
276                        active_item
277                            .update(cx, |item, cx| item.toggle_ignore_breakpoints(cx))
278                            .ok();
279                    }
280                })
281            });
282    })
283    .detach();
284
285    cx.observe_new({
286        move |editor: &mut Editor, _, _| {
287            editor
288                .register_action_renderer(move |editor, window, cx| {
289                    let Some(workspace) = editor.workspace() else {
290                        return;
291                    };
292                    let Some(debug_panel) = workspace.read(cx).panel::<DebugPanel>(cx) else {
293                        return;
294                    };
295                    let Some(active_session) =
296                        debug_panel.update(cx, |panel, _| panel.active_session())
297                    else {
298                        return;
299                    };
300
301                    let session = active_session
302                        .read(cx)
303                        .running_state
304                        .read(cx)
305                        .session()
306                        .read(cx);
307
308                    if session.is_terminated() {
309                        return;
310                    }
311
312                    let editor = cx.entity().downgrade();
313
314                    window.on_action_when(
315                        session.any_stopped_thread(),
316                        TypeId::of::<editor::actions::RunToCursor>(),
317                        {
318                            let editor = editor.clone();
319                            let active_session = active_session.clone();
320                            move |_, phase, _, cx| {
321                                if phase != DispatchPhase::Bubble {
322                                    return;
323                                }
324                                maybe!({
325                                    let (buffer, position, _) = editor
326                                        .update(cx, |editor, cx| {
327                                            let cursor_point: language::Point =
328                                                editor.selections.newest(cx).head();
329
330                                            editor
331                                                .buffer()
332                                                .read(cx)
333                                                .point_to_buffer_point(cursor_point, cx)
334                                        })
335                                        .ok()??;
336
337                                    let path =
338                                debugger::breakpoint_store::BreakpointStore::abs_path_from_buffer(
339                                    &buffer, cx,
340                                )?;
341
342                                    let source_breakpoint = SourceBreakpoint {
343                                        row: position.row,
344                                        path,
345                                        message: None,
346                                        condition: None,
347                                        hit_condition: None,
348                                        state: debugger::breakpoint_store::BreakpointState::Enabled,
349                                    };
350
351                                    active_session.update(cx, |session, cx| {
352                                        session.running_state().update(cx, |state, cx| {
353                                            if let Some(thread_id) = state.selected_thread_id() {
354                                                state.session().update(cx, |session, cx| {
355                                                    session.run_to_position(
356                                                        source_breakpoint,
357                                                        thread_id,
358                                                        cx,
359                                                    );
360                                                })
361                                            }
362                                        });
363                                    });
364
365                                    Some(())
366                                });
367                            }
368                        },
369                    );
370
371                    window.on_action(
372                        TypeId::of::<editor::actions::EvaluateSelectedText>(),
373                        move |_, _, window, cx| {
374                            maybe!({
375                                let text = editor
376                                    .update(cx, |editor, cx| {
377                                        editor.text_for_range(
378                                            editor.selections.newest(cx).range(),
379                                            &mut None,
380                                            window,
381                                            cx,
382                                        )
383                                    })
384                                    .ok()??;
385
386                                active_session.update(cx, |session, cx| {
387                                    session.running_state().update(cx, |state, cx| {
388                                        let stack_id = state.selected_stack_frame_id(cx);
389
390                                        state.session().update(cx, |session, cx| {
391                                            session
392                                                .evaluate(text, None, stack_id, None, cx)
393                                                .detach();
394                                        });
395                                    });
396                                });
397
398                                Some(())
399                            });
400                        },
401                    );
402                })
403                .detach();
404        }
405    })
406    .detach();
407}
408
409fn spawn_task_or_modal(
410    workspace: &mut Workspace,
411    action: &Spawn,
412    window: &mut ui::Window,
413    cx: &mut ui::Context<Workspace>,
414) {
415    match action {
416        Spawn::ByName {
417            task_name,
418            reveal_target,
419        } => {
420            let overrides = reveal_target.map(|reveal_target| TaskOverrides {
421                reveal_target: Some(reveal_target),
422            });
423            let name = task_name.clone();
424            tasks_ui::spawn_tasks_filtered(
425                move |(_, task)| task.label.eq(&name),
426                overrides,
427                window,
428                cx,
429            )
430            .detach_and_log_err(cx)
431        }
432        Spawn::ByTag {
433            task_tag,
434            reveal_target,
435        } => {
436            let overrides = reveal_target.map(|reveal_target| TaskOverrides {
437                reveal_target: Some(reveal_target),
438            });
439            let tag = task_tag.clone();
440            tasks_ui::spawn_tasks_filtered(
441                move |(_, task)| task.tags.contains(&tag),
442                overrides,
443                window,
444                cx,
445            )
446            .detach_and_log_err(cx)
447        }
448        Spawn::ViaModal { reveal_target } => {
449            NewProcessModal::show(workspace, window, NewProcessMode::Task, *reveal_target, cx);
450        }
451    }
452}