1use crate::HttpClient;
2use anyhow::{anyhow, bail, Context, Result};
3use futures::AsyncReadExt;
4use serde::Deserialize;
5use std::sync::Arc;
6use url::Url;
7
8pub struct GitHubLspBinaryVersion {
9 pub name: String,
10 pub url: String,
11}
12
13#[derive(Deserialize, Debug)]
14pub struct GithubRelease {
15 pub tag_name: String,
16 #[serde(rename = "prerelease")]
17 pub pre_release: bool,
18 pub assets: Vec<GithubReleaseAsset>,
19 pub tarball_url: String,
20 pub zipball_url: String,
21}
22
23#[derive(Deserialize, Debug)]
24pub struct GithubReleaseAsset {
25 pub name: String,
26 pub browser_download_url: String,
27}
28
29pub async fn latest_github_release(
30 repo_name_with_owner: &str,
31 require_assets: bool,
32 pre_release: bool,
33 http: Arc<dyn HttpClient>,
34) -> Result<GithubRelease, anyhow::Error> {
35 let mut response = http
36 .get(
37 &format!("https://api.github.com/repos/{repo_name_with_owner}/releases"),
38 Default::default(),
39 true,
40 )
41 .await
42 .context("error fetching latest release")?;
43
44 let mut body = Vec::new();
45 response
46 .body_mut()
47 .read_to_end(&mut body)
48 .await
49 .context("error reading latest release")?;
50
51 if response.status().is_client_error() {
52 let text = String::from_utf8_lossy(body.as_slice());
53 bail!(
54 "status error {}, response: {text:?}",
55 response.status().as_u16()
56 );
57 }
58
59 let releases = match serde_json::from_slice::<Vec<GithubRelease>>(body.as_slice()) {
60 Ok(releases) => releases,
61
62 Err(err) => {
63 log::error!("Error deserializing: {:?}", err);
64 log::error!(
65 "GitHub API response text: {:?}",
66 String::from_utf8_lossy(body.as_slice())
67 );
68 return Err(anyhow!("error deserializing latest release"));
69 }
70 };
71
72 releases
73 .into_iter()
74 .filter(|release| !require_assets || !release.assets.is_empty())
75 .find(|release| release.pre_release == pre_release)
76 .ok_or(anyhow!("Failed to find a release"))
77}
78
79pub async fn get_release_by_tag_name(
80 repo_name_with_owner: &str,
81 tag: &str,
82 http: Arc<dyn HttpClient>,
83) -> Result<GithubRelease, anyhow::Error> {
84 let mut response = http
85 .get(
86 &format!("https://api.github.com/repos/{repo_name_with_owner}/releases/tags/{tag}"),
87 Default::default(),
88 true,
89 )
90 .await
91 .context("error fetching latest release")?;
92
93 let mut body = Vec::new();
94 response
95 .body_mut()
96 .read_to_end(&mut body)
97 .await
98 .context("error reading latest release")?;
99
100 if response.status().is_client_error() {
101 let text = String::from_utf8_lossy(body.as_slice());
102 bail!(
103 "status error {}, response: {text:?}",
104 response.status().as_u16()
105 );
106 }
107
108 let release = serde_json::from_slice::<GithubRelease>(body.as_slice()).map_err(|err| {
109 log::error!("Error deserializing: {:?}", err);
110 log::error!(
111 "GitHub API response text: {:?}",
112 String::from_utf8_lossy(body.as_slice())
113 );
114 anyhow!("error deserializing GitHub release")
115 })?;
116
117 Ok(release)
118}
119
120pub fn build_tarball_url(repo_name_with_owner: &str, tag: &str) -> Result<String> {
121 let mut url = Url::parse(&format!(
122 "https://github.com/{repo_name_with_owner}/archive/refs/tags",
123 ))?;
124 // We're pushing this here, because tags may contain `/` and other characters
125 // that need to be escaped.
126 let tarball_filename = format!("{}.tar.gz", tag);
127 url.path_segments_mut()
128 .map_err(|_| anyhow!("cannot modify url path segments"))?
129 .push(&tarball_filename);
130 Ok(url.to_string())
131}
132
133#[cfg(test)]
134mod tests {
135 use crate::github::build_tarball_url;
136
137 #[test]
138 fn test_build_tarball_url() {
139 let tag = "release/2.3.5";
140 let repo_name_with_owner = "microsoft/vscode-eslint";
141
142 let have = build_tarball_url(repo_name_with_owner, tag).unwrap();
143
144 assert_eq!(
145 have,
146 "https://github.com/microsoft/vscode-eslint/archive/refs/tags/release%2F2.3.5.tar.gz"
147 );
148 }
149}