mirror of
https://github.com/fawney19/Aether.git
synced 2026-10-12 04:09:48 +08:00
fawney19
f3b9f42202
- 删除 TunnelTransport 及 TunnelManager 相关引用，所有 tunnel 请求统一走 Hub - 简化 health_scheduler，不再依赖进程内 TunnelManager 状态判断节点在线 - 简化 resolver，移除本地 tunnel miss 判断与多 worker 告警逻辑 - 简化 service 中 tunnel 连通性检测，统一以 DB 状态为准 - 启动/关闭流程移除 hub_enabled 分支，始终初始化 Hub 连接 - Rust 端 RequestMeta.timeout 增加浮点数反序列化支持，Python 端确保发送整数
15 lines
643 B
Python
15 lines
643 B
Python
from src.services.proxy_node.hub_transport import HubTunnelTransport
|
|
from src.services.proxy_node.tunnel_protocol import Frame, MsgType
|
|
from src.services.proxy_node.tunnel_transport import create_tunnel_transport
|
|
|
|
|
|
def test_create_tunnel_transport_always_uses_hub_transport() -> None:
|
|
transport = create_tunnel_transport("node-1", timeout=12.0)
|
|
assert isinstance(transport, HubTunnelTransport)
|
|
|
|
|
|
def test_tunnel_protocol_supports_node_status_msg_type() -> None:
|
|
raw = Frame(0, MsgType.NODE_STATUS, 0, b'{"node_id":"n1","connected":true}').encode()
|
|
decoded = Frame.decode(raw)
|
|
assert decoded.msg_type == MsgType.NODE_STATUS
|