hysteria2 0.1.2

A feature-rich, asynchronous Rust client library for the Hysteria 2 proxy protocol. / 功能丰富、异步的 Hysteria 2 代理协议 Rust 客户端库。
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

use std::io;

use tokio::io::{AsyncReadExt, sink};

use super::{get_varint::get_varint, tcp_response_status::TCPResponseStatus};

/// 从服务器解析TCP响应
pub async fn read_tcp_response<R: tokio::io::AsyncRead + Unpin>(
  reader: &mut R,
) -> io::Result<(TCPResponseStatus, String)> {
  let status_byte = reader.read_u8().await?;
  let status = if status_byte == 0x00 {
    TCPResponseStatus::Ok
  } else {
    TCPResponseStatus::Error
  };

  let msg_len = get_varint(reader).await? as usize;
  let mut msg_buf = vec![0u8; msg_len];
  reader.read_exact(&mut msg_buf).await?;
  let message = String::from_utf8_lossy(&msg_buf).to_string();

  // Ignore padding.
  // 忽略填充。
  let padding_len = get_varint(reader).await?;
  if padding_len > 0 {
    // Efficiently discard padding without allocating a buffer.
    // 高效地丢弃填充，无需分配缓冲区。
    tokio::io::copy(&mut reader.take(padding_len), &mut sink()).await?;
  }

  Ok((status, message))
}