1use crate::http::HttpClient;
 2use anyhow::{anyhow, 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}
20
21#[derive(Deserialize, Debug)]
22pub struct GithubReleaseAsset {
23    pub name: String,
24    pub browser_download_url: String,
25}
26
27pub async fn latest_github_release(
28    repo_name_with_owner: &str,
29    pre_release: bool,
30    http: Arc<dyn HttpClient>,
31) -> Result<GithubRelease, anyhow::Error> {
32    let mut response = http
33        .get(
34            &format!("https://api.github.com/repos/{repo_name_with_owner}/releases"),
35            Default::default(),
36            true,
37        )
38        .await
39        .context("error fetching latest release")?;
40
41    let mut body = Vec::new();
42    response
43        .body_mut()
44        .read_to_end(&mut body)
45        .await
46        .context("error reading latest release")?;
47
48    let releases = match serde_json::from_slice::<Vec<GithubRelease>>(body.as_slice()) {
49        Ok(releases) => releases,
50
51        Err(_) => {
52            log::error!(
53                "Error deserializing Github API response text: {:?}",
54                String::from_utf8_lossy(body.as_slice())
55            );
56            return Err(anyhow!("error deserializing latest release"));
57        }
58    };
59
60    releases
61        .into_iter()
62        .find(|release| release.pre_release == pre_release)
63        .ok_or(anyhow!("Failed to find a release"))
64}