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
71
72
73
74
75
76
77
78
79

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

use axum::body::Body;
use axum::extract::Request;
use color_eyre::eyre::OptionExt;
use convertor::config::client_config::ProxyClient;
use convertor::config::provider_config::Provider;
use convertor::core::profile::policy::Policy;
use convertor::core::renderer::Renderer;
use convertor::core::renderer::clash_renderer::ClashRenderer;
use convertor::testkit::{init_test, policies};
use convertor::url::url_builder::HostPort;
use http_body_util::BodyExt;
use server::{ServerContext, start_server};
use tower::ServiceExt;

async fn rule_provider(
    server_context: &ServerContext,
    client: ProxyClient,
    provider: Provider,
    policy: Policy,
) -> color_eyre::Result<String> {
    let ServerContext { app, app_state, .. } = server_context;
    let url_builder = app_state.config.create_url_builder(client, provider)?;

    let rule_provider_url = url_builder.build_rule_provider_url(&policy)?;
    let request = Request::builder()
        .uri(rule_provider_url.to_string())
        .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(
            &url_builder
                .sub_url
                .host_port()
                .ok_or_eyre("无法从 sub_url 中提取 host port")?,
            "localhost",
        );

    Ok(actual)
}

#[tokio::test]
async fn test_rule_provider_surge_boslife() -> color_eyre::Result<()> {
    init_test();
    let server_context = start_server().await?;
    let policies = policies();
    for policy in policies {
        let ctx = format!(
            "test_rule_provider_surge_boslife_{}",
            ClashRenderer::render_provider_name_for_policy(&policy)
        );
        let actual = rule_provider(&server_context, ProxyClient::Surge, Provider::BosLife, policy).await?;
        insta::assert_snapshot!(ctx, actual);
    }
    Ok(())
}

#[tokio::test]
async fn test_rule_provider_clash_boslife() -> color_eyre::Result<()> {
    init_test();
    let server_context = start_server().await?;
    let policies = policies();
    for policy in policies {
        let ctx = format!(
            "test_rule_provider_clash_boslife_{}",
            ClashRenderer::render_provider_name_for_policy(&policy)
        );
        let actual = rule_provider(&server_context, ProxyClient::Clash, Provider::BosLife, policy).await?;
        insta::assert_snapshot!(ctx, actual);
    }
    Ok(())
}