zeloxy 0.4.0

A library for creating lightweight, async, and lag-free proxy connections.
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

/// Функция валидации строковой записи прокси.
///
/// ## Примеры результатов
///
/// - `http://77.14.58.23:80` -> `true`
/// - `http://77.14.58.23` -> `false` (не указан порт)
/// - `socks5://77.14.58.23:1080` -> `true`
/// - `socks5://77.14.58:1080` -> `false` (неверный формат IP-адреса)
/// - `socks4://user:pass@77.14.58.23:4145` -> `false` (в SOCKS4 указывается только USER_ID)
/// - `socks5://user:pass@77.14.58.23:1080` -> `true`
/// - `socks4://user_id@77.14.58.23:4145` -> `true`
pub fn validate_proxy_str(proxy: impl Into<String>) -> bool {
  let proxy_str = proxy.into();
  let proxy_split = proxy_str.split("://").collect::<Vec<&str>>();

  if proxy_split.len() != 2 {
    return false;
  }

  let without_protocol = proxy_split[1].split("@").collect::<Vec<&str>>();

  if without_protocol.len() > 2 {
    return false;
  }

  let (protocol, auth, addr) = {
    if without_protocol.len() == 2 {
      (proxy_split[0], Some(without_protocol[0]), without_protocol[1])
    } else {
      (proxy_split[0], None, without_protocol[0])
    }
  };

  let allowed_protocols = {
    let mut list = Vec::new();

    #[cfg(feature = "http")]
    list.push("http");

    #[cfg(feature = "https")]
    list.push("https");

    #[cfg(feature = "socks4")]
    list.push("socks4");

    #[cfg(feature = "socks5")]
    list.push("socks5");

    list
  };

  if !allowed_protocols.contains(&protocol) {
    return false;
  }

  if let Some(a) = auth {
    let auth_data_count = a.split(":").count();

    #[cfg(feature = "socks4")]
    if protocol == "socks4" {
      if auth_data_count != 1 {
        return false;
      }
    } else {
      if auth_data_count != 2 {
        return false;
      }
    }

    #[cfg(not(feature = "socks4"))]
    if auth_data_count != 2 {
      return false;
    }
  }

  let addr_split = addr.split(":").collect::<Vec<&str>>();

  if addr_split.len() != 2 {
    return false;
  }

  let ip_octecs_count = addr_split[0].split(".").count();

  if ip_octecs_count != 4 {
    return false;
  }

  true
}