1use crate::http::HttpClient;
2use anyhow::{anyhow, bail, Context, Result};
3use futures::AsyncReadExt;
4use serde::Deserialize;
5use std::sync::Arc;
6
7pub struct GitHubLspBinaryVersion {
8 pub name: String,
9 pub url: String,
10}
11
12#[derive(Deserialize, Debug)]
13pub struct GithubRelease {
14 pub name: String,
15 #[serde(rename = "prerelease")]
16 pub pre_release: bool,
17 pub assets: Vec<GithubReleaseAsset>,
18 pub tarball_url: String,
19 pub zipball_url: String,
20}
21
22#[derive(Deserialize, Debug)]
23pub struct GithubReleaseAsset {
24 pub name: String,
25 pub browser_download_url: String,
26}
27
28pub async fn latest_github_release(
29 repo_name_with_owner: &str,
30 require_assets: bool,
31 pre_release: bool,
32 http: Arc<dyn HttpClient>,
33) -> Result<GithubRelease, anyhow::Error> {
34 let mut response = http
35 .get(
36 &format!("https://api.github.com/repos/{repo_name_with_owner}/releases"),
37 Default::default(),
38 true,
39 )
40 .await
41 .context("error fetching latest release")?;
42
43 let mut body = Vec::new();
44 response
45 .body_mut()
46 .read_to_end(&mut body)
47 .await
48 .context("error reading latest release")?;
49
50 if response.status().is_client_error() {
51 let text = String::from_utf8_lossy(body.as_slice());
52 bail!(
53 "status error {}, response: {text:?}",
54 response.status().as_u16()
55 );
56 }
57
58 let releases = match serde_json::from_slice::<Vec<GithubRelease>>(body.as_slice()) {
59 Ok(releases) => releases,
60
61 Err(_) => {
62 log::error!(
63 "Error deserializing GitHub API response text: {:?}",
64 String::from_utf8_lossy(body.as_slice())
65 );
66 return Err(anyhow!("error deserializing latest release"));
67 }
68 };
69
70 releases
71 .into_iter()
72 .filter(|release| !require_assets || !release.assets.is_empty())
73 .find(|release| release.pre_release == pre_release)
74 .ok_or(anyhow!("Failed to find a release"))
75}