socks5_impl/protocol/handshake/
response.rs

1#[cfg(feature = "tokio")]
2use crate::protocol::AsyncStreamOperation;
3use crate::protocol::{AuthMethod, StreamOperation, Version};
4#[cfg(feature = "tokio")]
5use async_trait::async_trait;
6#[cfg(feature = "tokio")]
7use tokio::io::{AsyncRead, AsyncReadExt};
8
9/// SOCKS5 handshake response
10///
11/// ```plain
12/// +-----+--------+
13/// | VER | METHOD |
14/// +-----+--------+
15/// |  1  |   1    |
16/// +-----+--------+
17/// ```
18#[derive(Clone, Debug)]
19pub struct Response {
20    pub method: AuthMethod,
21}
22
23impl Response {
24    pub fn new(method: AuthMethod) -> Self {
25        Self { method }
26    }
27}
28
29impl StreamOperation for Response {
30    fn retrieve_from_stream<R: std::io::Read>(r: &mut R) -> std::io::Result<Self> {
31        let mut ver = [0; 1];
32        r.read_exact(&mut ver)?;
33        let ver = Version::try_from(ver[0])?;
34
35        if ver != Version::V5 {
36            let err = format!("Unsupported SOCKS version {0:#x}", u8::from(ver));
37            return Err(std::io::Error::new(std::io::ErrorKind::Unsupported, err));
38        }
39
40        let mut method = [0; 1];
41        r.read_exact(&mut method)?;
42        let method = AuthMethod::from(method[0]);
43
44        Ok(Self { method })
45    }
46
47    fn write_to_buf<B: bytes::BufMut>(&self, buf: &mut B) {
48        buf.put_u8(Version::V5.into());
49        buf.put_u8(u8::from(self.method));
50    }
51
52    fn len(&self) -> usize {
53        2
54    }
55}
56
57#[cfg(feature = "tokio")]
58#[async_trait]
59impl AsyncStreamOperation for Response {
60    async fn retrieve_from_async_stream<R>(r: &mut R) -> std::io::Result<Self>
61    where
62        R: AsyncRead + Unpin + Send + ?Sized,
63    {
64        let ver = Version::try_from(r.read_u8().await?)?;
65
66        if ver != Version::V5 {
67            let err = format!("Unsupported SOCKS version {0:#x}", u8::from(ver));
68            return Err(std::io::Error::new(std::io::ErrorKind::Unsupported, err));
69        }
70
71        let method = AuthMethod::from(r.read_u8().await?);
72
73        Ok(Self { method })
74    }
75}
socks5_impl/protocol/handshake/response.rs

socks5_impl/protocol/handshake/
response.rs
