feat: add hysteria (HY2) server

Author: spacemeowx2

Cargo.lock

@@ -3,6 +3,7 @@
 目标：
 - 按照官方文档在本机启动一个 Hysteria v2 服务端（用于联调）
 - 在本项目实现 HY2 对应的 client protocol（Rust）
+- 在本项目实现 HY2 对应的 server protocol（Rust）
 - 全程用 Markdown 跟踪进度与决策（本文件）
 
 参考文档（上游）：
@@ -18,6 +19,8 @@
 - [x] 3. 实现 HY2 client：QUIC + `/auth` + TCP CONNECT(stream)
 - [x] 4. 实现 HY2 client：UDP(datagram) + Salamander(可选)
 - [x] 5. 接入到 registry/feature，补最小测试与使用说明
+- [ ] 6. 实现 HY2 server：QUIC + HTTP/3 `/auth` + TCP/UDP 转发（进行中）
+- [ ] 7. 单测：server+client 联调（进行中）
 
 ---
 
@@ -78,6 +81,7 @@
 - 2026-02-10：新增 `protocol/hysteria`：完成 HY2 `/auth` + TCP stream request 的最小实现（编译/单测通过）
 - 2026-02-10：`protocol/hysteria` 增加 UDP(datagram) 与 Salamander(传输层混淆) 支持（编译/单测通过）
 - 2026-02-10：本地联调验证：`rabbit-digger-pro` 通过 HY2(TCP) 成功代理访问本机 `python -m http.server`（socks5 -> rdp -> hysteria server -> localhost 目标）
+- 2026-02-11：新增 `protocol/hysteria` server（QUIC + H3 `/auth` + TCP/UDP 转发，编译通过）
 
 ---
 

agent-docs/hysteria.md

@@ -7,6 +7,7 @@ edition = "2021"
 rd-interface = { path = "../../rd-interface", version = "0.4" }
 tokio = { version = "1.49.0", features = ["full"] }
 serde = "1.0"
+rd-std = { path = "../../rd-std", version = "0.1" }
 
 quinn = { version = "0.11.9", default-features = false, features = ["runtime-tokio", "rustls-ring"] }
 h3 = "0.0.8"
@@ -20,6 +21,8 @@ blake2 = "0.10"
 rand = "0.8"
 parking_lot = "0.12"
 tokio-stream = { version = "0.1.18", features = ["sync"] }
+tracing = "0.1.44"
 
 [dev-dependencies]
-rd-std = { path = "../../rd-std", version = "0.1" }
+rcgen = "0.13"
+tempfile = "3.24.0"

protocol/hysteria/Cargo.toml

@@ -32,6 +32,41 @@ pub(crate) fn write_varint(out: &mut Vec<u8>, mut x: u64) {
     }
 }
 
+pub(crate) fn decode_varint(input: &[u8]) -> Option<(u64, usize)> {
+    let first = *input.first()?;
+    let tag = first >> 6;
+    match tag {
+        0b00 => Some(((first & 0b0011_1111) as u64, 1)),
+        0b01 => {
+            if input.len() < 2 {
+                return None;
+            }
+            let b0 = input[0] & 0b0011_1111;
+            let v = u16::from_be_bytes([b0, input[1]]) as u64;
+            Some((v, 2))
+        }
+        0b10 => {
+            if input.len() < 4 {
+                return None;
+            }
+            let b0 = input[0] & 0b0011_1111;
+            let v = u32::from_be_bytes([b0, input[1], input[2], input[3]]) as u64;
+            Some((v, 4))
+        }
+        0b11 => {
+            if input.len() < 8 {
+                return None;
+            }
+            let b0 = input[0] & 0b0011_1111;
+            let v = u64::from_be_bytes([
+                b0, input[1], input[2], input[3], input[4], input[5], input[6], input[7],
+            ]);
+            Some((v, 8))
+        }
+        _ => None,
+    }
+}
+
 pub(crate) fn write_tcp_request(out: &mut Vec<u8>, target: &Address) {
     write_varint(out, HY2_TCP_REQUEST);
     match target {

protocol/hysteria/src/codec.rs

@@ -1,9 +1,11 @@
 use client::{HysteriaNet, HysteriaNetConfig};
-use rd_interface::{registry::Builder, Net, Registry, Result};
+use rd_interface::{registry::Builder, Net, Registry, Result, Server};
+use server::{HysteriaServer, HysteriaServerConfig};
 
 mod client;
 mod codec;
 mod salamander;
+mod server;
 mod stream;
 mod transport;
 mod udp;
@@ -18,7 +20,18 @@ impl Builder<Net> for HysteriaNet {
     }
 }
 
+impl Builder<Server> for HysteriaServer {
+    const NAME: &'static str = "hysteria";
+    type Config = HysteriaServerConfig;
+    type Item = Self;
+
+    fn build(config: Self::Config) -> Result<Self> {
+        HysteriaServer::new(config)
+    }
+}
+
 pub fn init(registry: &mut Registry) -> Result<()> {
     registry.add_net::<HysteriaNet>();
+    registry.add_server::<server::HysteriaServer>();
     Ok(())
 }