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
120#[derive(Debug, PartialEq, Eq, Clone, Copy)]
121pub enum AssetKind {
122 TarGz,
123 Zip,
124}
125
126pub fn build_asset_url(repo_name_with_owner: &str, tag: &str, kind: AssetKind) -> Result<String> {
127 let mut url = Url::parse(&format!(
128 "https://github.com/{repo_name_with_owner}/archive/refs/tags",
129 ))?;
130 // We're pushing this here, because tags may contain `/` and other characters
131 // that need to be escaped.
132 let asset_filename = format!(
133 "{tag}.{extension}",
134 extension = match kind {
135 AssetKind::TarGz => "tar.gz",
136 AssetKind::Zip => "zip",
137 }
138 );
139 url.path_segments_mut()
140 .map_err(|_| anyhow!("cannot modify url path segments"))?
141 .push(&asset_filename);
142 Ok(url.to_string())
143}
144
145#[cfg(test)]
146mod tests {
147 use crate::github::{build_asset_url, AssetKind};
148
149 #[test]
150 fn test_build_asset_url() {
151 let tag = "release/2.3.5";
152 let repo_name_with_owner = "microsoft/vscode-eslint";
153
154 let tarball = build_asset_url(repo_name_with_owner, tag, AssetKind::TarGz).unwrap();
155 assert_eq!(
156 tarball,
157 "https://github.com/microsoft/vscode-eslint/archive/refs/tags/release%2F2.3.5.tar.gz"
158 );
159
160 let zip = build_asset_url(repo_name_with_owner, tag, AssetKind::Zip).unwrap();
161 assert_eq!(
162 zip,
163 "https://github.com/microsoft/vscode-eslint/archive/refs/tags/release%2F2.3.5.zip"
164 );
165 }
166}