proxifier-rs 0.1.61

Proxy client library supporting SOCKS4/SOCKS5 and HTTP/HTTPS proxies with TLS support
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

#![doc = include_str!("../SOCKS5.md")]
use rustls::ClientConfig;
use rustls_pki_types::ServerName;
use std::{
    marker::PhantomData,
    net::{SocketAddr, SocketAddrV4, SocketAddrV6},
    sync::Arc,
};
use tokio::{
    io::{AsyncReadExt, AsyncWriteExt},
    net::TcpStream,
};
use tokio_rustls::{TlsConnector, client::TlsStream};

use crate::errors;
static VERSION_5: u8 = 0x05;
static NULL: u8 = 0x00;

/// Represents either IPV4 and IPV6 via [`NetworkAddress::IP`] or domain [`NetworkAddress::Domain`]
pub enum TargetNetwork {
    IP(SocketAddr),
    Domain(String),
}

impl From<SocketAddrV4> for TargetNetwork {
    fn from(value: SocketAddrV4) -> Self {
        Self::IP(SocketAddr::V4(value))
    }
}

impl From<SocketAddrV6> for TargetNetwork {
    fn from(value: SocketAddrV6) -> Self {
        Self::IP(SocketAddr::V6(value))
    }
}

impl From<String> for TargetNetwork {
    fn from(value: String) -> Self {
        Self::Domain(value)
    }
}

impl<'a> From<&'a str> for TargetNetwork {
    fn from(value: &'a str) -> Self {
        Self::Domain(value.into())
    }
}

enum ATYP {
    IPV4 = 0x01,
    IPV6 = 0x04,
    DOMAIN = 0x03,
}

enum AuthMethods {
    NoAuth = 0x00,
    UserPass = 0x02,
    NotAcceptable = 0xff,
}

#[derive(Debug)]
pub(crate) struct ReplyOK;

impl TryFrom<u8> for ReplyOK {
    type Error = errors::Error;
    fn try_from(value: u8) -> Result<Self, Self::Error> {
        match value {
            0 => Ok(ReplyOK),
            1 => Err(Self::Error::Socks5Error(1)),
            2 => Err(Self::Error::Socks5Error(2)),
            3 => Err(Self::Error::Socks5Error(3)),
            4 => Err(Self::Error::Socks5Error(4)),
            5 => Err(Self::Error::Socks5Error(5)),
            6 => Err(Self::Error::Socks5Error(6)),
            7 => Err(Self::Error::Socks5Error(7)),
            8 => Err(Self::Error::Socks5Error(8)),
            9 => Err(Self::Error::Socks5Error(9)),
            10 => Err(Self::Error::Socks5Error(10)),
            _ => Err(errors::Error::ProxyResponseNotOk(
                "unknown status reply from proxy server".into(),
            )),
        }
    }
}

pub struct NoProxy;
pub struct HasProxy;

pub struct Socks5Builder<S = NoProxy> {
    phantom: PhantomData<S>,
}