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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136

# Zeloxy

[Russian Documentation](https://codeberg.org/nullclyze/zeloxy/src/branch/main/docs/RU.md) | [English Documentation](https://codeberg.org/nullclyze/zeloxy/src/branch/main/docs/EN.md) | [Examples](https://codeberg.org/nullclyze/zeloxy/src/branch/main/examples) | [License](https://codeberg.org/nullclyze/zeloxy/src/branch/main/LICENSE)

A Rust library for working with various proxies.

Supported proxy protocols:

- **HTTP** (without auth / with basic auth)
- **HTTPS** (without auth / with basic auth)
- **SOCKS5** (without auth / with `user / pass` auth)
- **SOCKS4** (without auth / with `ident` auth)

# Focusing

- **Lightweight:** This crate does not use unnecessary dependencies and useless functionality.
- **Simplicity:** This crate contains clear and logical functionality with examples.
- **Built-in:** This crate offers built-in tools for convenient proxy management.
- **Asynchrony:** This crate is based on an asynchronous environment.
- **Lag-free:** This crate limits almost all operations with timeouts to prevent lags / freezes.

# Tasks and Goals

- [x] SOCKS4 proxy support
- [x] SOCKS5 proxy support
- [x] HTTP proxy support
- [x] HTTPS proxy support
- [x] Basic authorizations support
- [x] Proxy chain implementation
- [x] Automatic reordering of proxy chain on error
- [x] Built-in proxy stream
- [ ] Proxy scraper
- [x] Proxy lookup
- [x] Proxy ping
- [ ] Proxy stealth check

# Include

In `Cargo.toml`:

```toml
[dependencies]
zeloxy = { version = "0.4.0", features = ["all"] }
```

Information about available features: [read](https://codeberg.org/nullclyze/zeloxy/src/branch/main/docs/EN.md#library-features)

# Examples

Current examples can be found here: [browse](https://codeberg.org/nullclyze/zeloxy/src/branch/main/examples)

## Create a HTTP proxy stream

```rust
use zeloxy::{Proxy, ProxyResult, ProxyStream, ProxyProtocol};

#[tokio::main]
async fn main() -> ProxyResult<()> {
  // Создаём HTTP-прокси (в данном примере используется публичный прокси)
  let proxy = Proxy::new("91.132.92.231:80", ProxyProtocol::Http);

  // Создаём поток с прокси
  let stream = ProxyStream::new(proxy);

  // Подключаемся к целевому серверу
  stream.connect("example.com", 80).await?;

  // Отправляем GET-запрос на example.com
  let buf = "GET / HTTP/1.0\r\nHost: example.com\r\n\r\n".as_bytes();
  stream.write(buf).await?;

  // Читаем ответ и логгируем его
  let mut resp = Vec::new();
  stream.read_to_end(&mut resp).await?;
  println!("Ответ от example.com: {}", String::from_utf8_lossy(&resp));

  Ok(())
}
```

## Connect to SOCKS5 proxy

```rust
use zeloxy::Proxy;

#[tokio::main]
async fn main() {
  // Создаём SOCKS5-прокси (в данном примере используется публичный прокси)
  let proxy = Proxy::from("socks5://212.58.132.5:1080");

  // Подключаемся к прокси и логгируем результат
  match proxy.connect("ipinfo.io", 80).await {
    Ok(_) => {
      println!("Подключение установлено");
    }
    Err(e) => {
      println!("Ошибка подключения: {:?}", e);
    }
  }
}
```

## Create a proxy chain

```rust
use tokio::io::{AsyncReadExt, AsyncWriteExt};
use zeloxy::{Proxy, ProxyChain, ProxyResult};

#[tokio::main]
async fn main() -> ProxyResult<()> {
  // Создаём список прокси
  let proxies = vec![
    "socks4://98.181.137.83:4145",
    "socks4://98.170.57.249:4145",
    "socks5://212.58.132.5:1080",
  ];

  // Создаём цепочку прокси
  let mut chain = ProxyChain::from(proxies);

  // Подключаемся к целевому серверу через цепочку
  let mut stream = chain.connect("ipinfo.io", 80, false).await?;

  // Отправляем GET-запрос
  stream.write_all(b"GET / HTTP/1.0\r\nHost: ipinfo.io\r\n\r\n").await?;

  // Читаем ответ (в данном случае информация об IP)
  let mut resp = Vec::new();
  stream.read_to_end(&mut resp).await?;

  // Логгируем выходной IP (здесь должно быть { "ip": "212.58.132.5:1080" })
  println!("Выход: {}", String::from_utf8_lossy(&resp));

  Ok(())
}
```