zeloxy 0.2.2

A library for creating lightweight, asynchronous, 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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112

use std::sync::Arc;

use zeloxy::tools::{ping_proxy, ping_proxy_chain, ping_proxy_chain_parallel, ping_proxy_parallel};
use zeloxy::{Proxy, ProxyChain, ProxyType};

#[tokio::test]
async fn test_ping_proxy() {
  let proxy = Proxy::new("98.175.31.222:4145", ProxyType::Socks5);

  let result = ping_proxy(&proxy, None).await;

  for (name, ping) in result.pinged_services {
    println!("Пинг {}: {}ms", name, ping);
  }

  println!("===============================");

  if let Some(average_ping) = result.average_ping {
    println!("Средний пинг прокси: {}ms", average_ping);
  }
}

#[tokio::test]
async fn test_ping_proxy_parallel() {
  let proxy = Proxy::new("98.175.31.222:4145", ProxyType::Socks5);

  let result = ping_proxy_parallel(Arc::new(proxy), None).await;

  for (name, ping) in result.pinged_services {
    println!("Пинг {}: {}ms", name, ping);
  }

  println!("===============================");

  if let Some(average_ping) = result.average_ping {
    println!("Средний пинг прокси: {}ms", average_ping);
  }
}

#[tokio::test]
async fn test_ping_proxy_chain() {
  let proxies = vec![
    "socks4://98.181.137.83:4145",
    "socks4://98.170.57.249:4145",
    "socks5://212.58.132.5:1080",
  ];

  let chain = ProxyChain::from(proxies);

  let result = ping_proxy_chain(&chain, None).await;

  for (name, ping) in result.pinged_services {
    println!("Пинг {}: {}ms", name, ping);
  }

  println!("===============================");

  for ((from, to), ping) in result.from_to_ping_map {
    println!("Пинг {} <-> {}: {}ms", from, to, ping);
  }

  println!("===============================");

  if let Some(average_ping) = result.average_ping {
    println!("Средний пинг цепочки прокси: {}ms", average_ping);
  }

  if let Some(from_to_average_ping) = result.from_to_average_ping {
    println!("Средний from-to пинг цепочки прокси: {}ms", from_to_average_ping);
  }

  if let Some(from_to_total_ping) = result.from_to_total_ping {
    println!("Общий from-to пинг цепочки прокси: {}ms", from_to_total_ping);
  }
}

#[tokio::test]
async fn test_ping_proxy_chain_parallel() {
  let proxies = vec![
    "socks4://98.181.137.83:4145",
    "socks4://98.170.57.249:4145",
    "socks5://212.58.132.5:1080",
  ];

  let chain = ProxyChain::from(proxies);

  let result = ping_proxy_chain_parallel(Arc::new(chain), None).await;

  for (name, ping) in result.pinged_services {
    println!("Пинг {}: {}ms", name, ping);
  }

  println!("===============================");

  for ((from, to), ping) in result.from_to_ping_map {
    println!("Пинг {} <-> {}: {}ms", from, to, ping);
  }

  println!("===============================");

  if let Some(average_ping) = result.average_ping {
    println!("Средний пинг цепочки прокси: {}ms", average_ping);
  }

  if let Some(from_to_average_ping) = result.from_to_average_ping {
    println!("Средний from-to пинг цепочки прокси: {}ms", from_to_average_ping);
  }

  if let Some(from_to_total_ping) = result.from_to_total_ping {
    println!("Общий from-to пинг цепочки прокси: {}ms", from_to_total_ping);
  }
}