1use crate::http::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 fn build_tarball_url(repo_name_with_owner: &str, tag: &str) -> Result<String> {
 80    let mut url = Url::parse(&format!(
 81        "https://github.com/{repo_name_with_owner}/archive/refs/tags",
 82    ))?;
 83    // We're pushing this here, because tags may contain `/` and other characters
 84    // that need to be escaped.
 85    let tarball_filename = format!("{}.tar.gz", tag);
 86    url.path_segments_mut()
 87        .map_err(|_| anyhow!("cannot modify url path segments"))?
 88        .push(&tarball_filename);
 89    Ok(url.to_string())
 90}
 91
 92#[cfg(test)]
 93mod tests {
 94    use crate::github::build_tarball_url;
 95
 96    #[test]
 97    fn test_build_tarball_url() {
 98        let tag = "release/2.3.5";
 99        let repo_name_with_owner = "microsoft/vscode-eslint";
100
101        let have = build_tarball_url(repo_name_with_owner, tag).unwrap();
102
103        assert_eq!(
104            have,
105            "https://github.com/microsoft/vscode-eslint/archive/refs/tags/release%2F2.3.5.tar.gz"
106        );
107    }
108}