trojan-ddns 0.9.0

Dynamic DNS update service for trojan-rs
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

//! Public IP address detection via HTTP endpoints.

use std::net::{Ipv4Addr, Ipv6Addr};
use std::time::Duration;

use tracing::{debug, warn};

/// Detects the public IP address by querying external HTTP endpoints.
pub struct IpDetector {
    client: reqwest::Client,
    ipv4_urls: Vec<String>,
    ipv6_urls: Vec<String>,
}

impl std::fmt::Debug for IpDetector {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.debug_struct("IpDetector")
            .field("ipv4_urls", &self.ipv4_urls)
            .field("ipv6_urls", &self.ipv6_urls)
            .finish()
    }
}

impl IpDetector {
    pub fn new(ipv4_urls: Vec<String>, ipv6_urls: Vec<String>) -> Self {
        let client = reqwest::Client::builder()
            .timeout(Duration::from_secs(10))
            .no_proxy()
            .build()
            .expect("failed to build HTTP client for IP detection");
        Self {
            client,
            ipv4_urls,
            ipv6_urls,
        }
    }

    /// Detect the public IPv4 address by trying each configured URL in order.
    pub async fn detect_ipv4(&self) -> Option<Ipv4Addr> {
        for url in &self.ipv4_urls {
            match self.client.get(url).send().await {
                Ok(resp) => match resp.text().await {
                    Ok(text) => match text.trim().parse::<Ipv4Addr>() {
                        Ok(ip) => {
                            debug!(ip = %ip, url, "detected IPv4 address");
                            return Some(ip);
                        }
                        Err(e) => {
                            warn!(url, error = %e, "failed to parse IPv4 from response");
                        }
                    },
                    Err(e) => warn!(url, error = %e, "failed to read response body"),
                },
                Err(e) => warn!(url, error = %e, "IPv4 detection request failed"),
            }
        }
        None
    }

    /// Detect the public IPv6 address by trying each configured URL in order.
    pub async fn detect_ipv6(&self) -> Option<Ipv6Addr> {
        for url in &self.ipv6_urls {
            match self.client.get(url).send().await {
                Ok(resp) => match resp.text().await {
                    Ok(text) => match text.trim().parse::<Ipv6Addr>() {
                        Ok(ip) => {
                            debug!(ip = %ip, url, "detected IPv6 address");
                            return Some(ip);
                        }
                        Err(e) => {
                            warn!(url, error = %e, "failed to parse IPv6 from response");
                        }
                    },
                    Err(e) => warn!(url, error = %e, "failed to read response body"),
                },
                Err(e) => warn!(url, error = %e, "IPv6 detection request failed"),
            }
        }
        None
    }
}