1use gpui::AsyncApp;
2use std::{ffi::OsStr, path::PathBuf};
3use task::DebugTaskDefinition;
4
5use crate::*;
6
7#[derive(Default, Debug)]
8pub(crate) struct GoDebugAdapter;
9
10impl GoDebugAdapter {
11 const ADAPTER_NAME: &'static str = "Delve";
12}
13
14#[async_trait(?Send)]
15impl DebugAdapter for GoDebugAdapter {
16 fn name(&self) -> DebugAdapterName {
17 DebugAdapterName(Self::ADAPTER_NAME.into())
18 }
19
20 async fn get_binary(
21 &self,
22 delegate: &dyn DapDelegate,
23 config: &DebugAdapterConfig,
24 user_installed_path: Option<PathBuf>,
25 cx: &mut AsyncApp,
26 ) -> Result<DebugAdapterBinary> {
27 self.get_installed_binary(delegate, config, user_installed_path, cx)
28 .await
29 }
30
31 async fn fetch_latest_adapter_version(
32 &self,
33 _delegate: &dyn DapDelegate,
34 ) -> Result<AdapterVersion> {
35 unimplemented!("This adapter is used from path for now");
36 }
37
38 async fn install_binary(
39 &self,
40 version: AdapterVersion,
41 delegate: &dyn DapDelegate,
42 ) -> Result<()> {
43 adapters::download_adapter_from_github(
44 self.name(),
45 version,
46 adapters::DownloadedFileType::Zip,
47 delegate,
48 )
49 .await?;
50 Ok(())
51 }
52
53 async fn get_installed_binary(
54 &self,
55 delegate: &dyn DapDelegate,
56 config: &DebugAdapterConfig,
57 _: Option<PathBuf>,
58 _: &mut AsyncApp,
59 ) -> Result<DebugAdapterBinary> {
60 let delve_path = delegate
61 .which(OsStr::new("dlv"))
62 .and_then(|p| p.to_str().map(|p| p.to_string()))
63 .ok_or(anyhow!("Dlv not found in path"))?;
64
65 let tcp_connection = config.tcp_connection.clone().unwrap_or_default();
66 let (host, port, timeout) = crate::configure_tcp_connection(tcp_connection).await?;
67
68 Ok(DebugAdapterBinary {
69 command: delve_path,
70 arguments: Some(vec![
71 "dap".into(),
72 "--listen".into(),
73 format!("{}:{}", host, port).into(),
74 ]),
75 cwd: None,
76 envs: None,
77 connection: Some(adapters::TcpArguments {
78 host,
79 port,
80 timeout,
81 }),
82 })
83 }
84
85 fn request_args(&self, config: &DebugTaskDefinition) -> Value {
86 match &config.request {
87 dap::DebugRequestType::Attach(attach_config) => {
88 json!({
89 "processId": attach_config.process_id,
90 "stopOnEntry": config.stop_on_entry,
91 })
92 }
93 dap::DebugRequestType::Launch(launch_config) => json!({
94 "program": launch_config.program,
95 "cwd": launch_config.cwd,
96 "stopOnEntry": config.stop_on_entry,
97 "args": launch_config.args
98 }),
99 }
100 }
101}