socks5-impl
Fundamental abstractions and async read / write functions for SOCKS5 protocol and Relatively low-level asynchronized SOCKS5 server implementation based on tokio.
This repo hosts at socks5-impl
Features
- Fully asynchronized
- Supports all SOCKS5 commands
- CONNECT
- BIND
- ASSOCIATE
- Customizable authentication
- No authentication
- Username / password
- GSSAPI
Usage
The entry point of this crate is socks5_impl::server::Server.
Check examples for usage examples.
Example
use socks5_impl::protocol::{handshake, Address, AuthMethod, Reply, Request, Response, StreamOperation};
fn main() -> socks5_impl::Result<()> {
let listener = std::net::TcpListener::bind("127.0.0.1:5000")?;
let (mut stream, _) = listener.accept()?;
let request = handshake::Request::retrieve_from_stream(&mut stream)?;
if request.evaluate_method(AuthMethod::NoAuth) {
let response = handshake::Response::new(AuthMethod::NoAuth);
response.write_to_stream(&mut stream)?;
} else {
let response = handshake::Response::new(AuthMethod::NoAcceptableMethods);
response.write_to_stream(&mut stream)?;
let _ = stream.shutdown(std::net::Shutdown::Both);
let err = "No available handshake method provided by client";
return Err(std::io::Error::new(std::io::ErrorKind::Unsupported, err).into());
}
let req = match Request::retrieve_from_stream(&mut stream) {
Ok(req) => req,
Err(err) => {
let resp = Response::new(Reply::GeneralFailure, Address::unspecified());
resp.write_to_stream(&mut stream)?;
let _ = stream.shutdown(std::net::Shutdown::Both);
return Err(err.into());
}
};
match req.command {
_ => {} // process request
}
Ok(())
}
License
GNU General Public License v3.0
3 Jul 27, 2023
142 Oct 23, 2023
2 Nov 13, 2021
94 Oct 18, 2022
782 Dec 30, 2022
8 Dec 26, 2022
79 Sep 9, 2022
1 Dec 6, 2021
10 Dec 18, 2022
7 Oct 3, 2022
246 Dec 20, 2022
8 Aug 30, 2022
4 Apr 11, 2024
259 Jan 6, 2023
2.7k Dec 30, 2022
32 Oct 6, 2023
34 Nov 29, 2022
47 Oct 15, 2022
17 Sep 27, 2022