confly 2.6.0+alpha

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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103

use convertor::common::config::ConvertorConfig;
use convertor::common::config::proxy_client_config::ProxyClient;
use convertor::provider_api::ProviderApi;

use confly::cli::provider_cli::{ProviderCli, ProviderCmd};
use convertor::common::config::provider_config::Provider;
use convertor::testkit::{init_test, start_mock_provider_server};
use url::Url;

pub fn cmds(client: ProxyClient, provider: Provider) -> [ProviderCmd; 4] {
    [
        ProviderCmd {
            client,
            provider,
            ..Default::default()
        },
        ProviderCmd {
            client,
            provider,
            server: Some(Url::parse("http://localhost:8080").expect("不合法的服务器地址")),
            ..Default::default()
        },
        ProviderCmd {
            client,
            provider,
            interval: Some(86400),
            strict: Some(false),
            ..Default::default()
        },
        ProviderCmd {
            client,
            provider,
            reset: true,
            ..Default::default()
        },
    ]
}

#[tokio::test]
async fn test_subscription_surge_boslife() -> color_eyre::Result<()> {
    let client = ProxyClient::Surge;
    let provider = Provider::BosLife;
    init_test();
    let mut config = ConvertorConfig::template();
    config.providers.values_mut().for_each(|provider| {
        provider.api_config.headers.remove("Authorization");
    });
    start_mock_provider_server(&mut config).await?;
    let cmds = cmds(client, provider);
    for (i, cmd) in cmds.into_iter().enumerate() {
        let ctx = format!("test_subscription_surge_boslife_cmd_{i}");
        let api_map = ProviderApi::create_api_no_redis(config.providers.clone());
        let mut executor = ProviderCli::new(config.clone(), api_map);
        let (url_builder, result) = executor.execute(cmd).await?;
        let result = result.to_string();
        let result = result
            .replace(
                &url_builder
                    .sub_url
                    .port()
                    .map(|p| p.to_string())
                    .unwrap_or("".to_string()),
                "<PORT>",
            )
            .replace(&url_builder.server.to_string(), "<SERVER>")
            .replace(&url_builder.enc_sub_url, "<ENC_SUB_URL>");
        insta::assert_snapshot!(ctx, result);
    }
    Ok(())
}

#[tokio::test]
async fn test_subscription_clash_boslife() -> color_eyre::Result<()> {
    init_test();
    let client = ProxyClient::Clash;
    let provider = Provider::BosLife;
    let mut config = ConvertorConfig::template();
    config.providers.values_mut().for_each(|provider| {
        provider.api_config.headers.remove("Authorization");
    });
    start_mock_provider_server(&mut config).await?;
    let cmds = cmds(client, provider);
    for (i, cmd) in cmds.into_iter().enumerate() {
        let ctx = format!("test_subscription_clash_boslife_cmd_{i}");
        let api_map = ProviderApi::create_api_no_redis(config.providers.clone());
        let mut executor = ProviderCli::new(config.clone(), api_map);
        let (url_builder, result) = executor.execute(cmd).await?;
        let result = result.to_string();
        let result = result
            .replace(
                &url_builder
                    .sub_url
                    .port()
                    .map(|p| p.to_string())
                    .unwrap_or("".to_string()),
                "<PORT>",
            )
            .replace(&url_builder.server.to_string(), "<SERVER>")
            .replace(&url_builder.enc_sub_url, "<ENC_SUB_URL>");
        insta::assert_snapshot!(ctx, result);
    }
    Ok(())
}