github.rs

 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}