convd 2.6.12

A profile converter for surge/clash.
Documentation 
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

#[path = "./server.rs"]
mod server;

use crate::server::{ServerContext, start_server};
use axum::body::Body;
use axum::extract::Request;
use color_eyre::eyre::{OptionExt, eyre};
use convd::server::response::ApiResponse;
use convertor::common::encrypt::encrypt;
use convertor::config::client_config::ProxyClient;
use convertor::config::provider_config::Provider;
use convertor::testkit::init_test;
use convertor::url::url_builder::HostPort;
use convertor::url::url_result::UrlResult;
use http_body_util::BodyExt;
use tower::ServiceExt;

async fn subscription(
    server_context: &ServerContext,
    client: ProxyClient,
    provider: Provider,
) -> color_eyre::Result<String> {
    let ServerContext { app, app_state, .. } = server_context;
    let sub_url = match app_state.config.providers.get(&provider) {
        Some(provider_config) => provider_config.sub_url.clone(),
        None => return Err(eyre!("未找到提供商配置: [providers.{}]", provider)),
    };

    let secret = app_state.config.secret.clone();
    let enc_secret = encrypt(secret.as_bytes(), secret.as_str())?;
    let enc_sub_url = encrypt(secret.as_bytes(), sub_url.as_str())?;
    let interval = 43200;
    let strict = true;

    let request = Request::builder()
        .uri(format!(
            "/api/subscription/{}/{}?secret={enc_secret}&interval={interval}&strict={strict}&sub_url={enc_sub_url}",
            client.as_ref().to_lowercase(),
            provider.as_ref().to_lowercase()
        ))
        .method("GET")
        .header("host", "127.0.0.1")
        .header("user-agent", concat!("convertor/", env!("CARGO_PKG_VERSION")))
        .body(Body::empty())?;
    let response = app.clone().oneshot(request).await?;

    let actual = String::from_utf8_lossy(&response.into_body().collect().await?.to_bytes())
        .to_string()
        .replace(&enc_secret, &secret)
        .replace(&enc_sub_url, sub_url.as_str())
        .replace(
            sub_url
                .host_port()
                .ok_or_eyre("无法从 sub_url 中提取 host port")?
                .as_str(),
            "mock_host_port",
        );

    Ok(actual)
}

#[tokio::test]
async fn test_subscription_surge_boslife() -> color_eyre::Result<()> {
    init_test();
    let server_context = start_server().await?;
    let url_result = subscription(&server_context, ProxyClient::Surge, Provider::BosLife).await?;
    let url_result: ApiResponse<UrlResult> = serde_json::from_str(&url_result)?;
    insta::assert_json_snapshot!(url_result.data.unwrap());
    Ok(())
}