1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

//! 获取 authlib-injector 第三方登录代理 jar

use async_trait::async_trait;

use super::{DownloadSource, Downloader};
use crate::prelude::*;

#[derive(Debug, Deserialize)]
struct LatestData {
    pub version: String,
    pub download_url: String,
}

/// Authlib 第三方正版登录模块的下载特质
///
/// 你可以通过引入本特质和 [`crate::download::Downloader`] 来下载并安装 Authlib Injector
#[async_trait]
pub trait AuthlibDownloadExt: Sync {
    /// 下载最新版本的 Authlib Injector 并存放到指定路径，如果路径的文件夹不存在则会先创建它，如果文件已存在则会被覆盖
    async fn download_authlib_injector(&self, dest_path: &str) -> DynResult;
    /// 安装最新版本的 Authlib Injector
    async fn install_authlib_injector(&self) -> DynResult;
}

#[async_trait]
impl<R: Reporter> AuthlibDownloadExt for Downloader<R> {
    async fn download_authlib_injector(&self, dest_path: &str) -> DynResult {
        // https://authlib-injector.yushi.moe/
        // /artifact/latest.json
        // download_url
        let r = self.reporter.clone();
        r.add_max_progress(2.);
        r.set_message("正在获取 Authlib-Injector 版本元数据".into());
        let latest_data: LatestData = crate::http::get(match self.source {
            DownloadSource::BMCLAPI => {
                "https://bmclapi2.bangbang93.com/mirrors/authlib-injector/artifact/latest.json"
            }
            _ => "https://authlib-injector.yushi.moe/artifact/latest.json",
        })
        .recv_json()
        .await
        .map_err(|e| anyhow::anyhow!(e))?;
        r.add_progress(1.);
        r.set_message(format!("正在下载 Authlib-Injector {}", latest_data.version));
        let download_url = latest_data.download_url;
        let resp = crate::http::get(download_url)
            .await
            .map_err(|e| anyhow::anyhow!(e))?;
        let temp_dest_path = format!("{dest_path}.tmp");
        let f = inner_future::fs::OpenOptions::new()
            .write(true)
            .truncate(true)
            .create(true)
            .open(&temp_dest_path)
            .await?;
        inner_future::io::copy(resp, f).await?;
        r.add_progress(1.);
        inner_future::fs::rename(temp_dest_path, dest_path).await?;
        Ok(())
    }

    async fn install_authlib_injector(&self) -> DynResult {
        let dest_path = format!(
            "{}{sep}authlib-injector.jar",
            self.minecraft_path.as_str(),
            sep = std::path::MAIN_SEPARATOR
        );
        let p = std::path::Path::new(&dest_path);
        if !p.is_file() {
            inner_future::fs::create_dir_all(p.parent().unwrap()).await?;
            self.download_authlib_injector(&dest_path).await?;
        }
        Ok(())
    }
}