fix(relay): 每个节点的会话与挑战数量设上限;agent 侧加 fuzz
设计假定节点是敌对方("被攻陷的节点不该能读到另一个节点的流量"),而中继为它 保存两份状态:会话(TTL 30 分钟)与挑战(TTL 60 秒)。两者此前只在**过期**时被 清理,所以一个循环握手的节点可以让它们无界增长——实测 5000ms 中继时间内 5000 次 握手留下 5000 个存活会话,且没有任何东西阻止接下来的 5000 次。 诚实值是 1:每节点只有一个连接,注册表也只保留一个挂起的轮询。所以上限取 每节点 4 个会话、16 个挑战,超出时淘汰最旧的而非拒绝——"最新一次握手获胜"已经是 注册表对连接本身的规则,拒绝会让一次合法的重连被自己早先的尝试挡住。 写这个上限时踩到并修掉了一个自己造的 bug:第一版保留最旧、删掉刚加入的,于是 循环握手的节点会被自己下一次握手淘汰掉最新会话,每次轮询都 401。只断言"表很小" 的测试抓不到它——能抓住它的是"最新会话仍然可用"这条断言。 agent 侧新增 fuzz(agent/internal/agent/fuzz_test.go):Handle 是唯一一个输入来自 被假定敌对一方的函数,而 agent 是单进程,这里的一次 panic 不是一次坏请求而是节点 下线直到 systemd 拉起。断言故意弱——不 panic,且要么返回错误要么返回合法 JSON—— 拒绝逻辑由旁边的表驱动测试覆盖。跑 45 秒、134 万次执行,无失败;测试内跑的是种子 语料(Go 的常规做法,fuzztime 只在显式 -fuzz 时生效)。 Node 112 项、Go 全包、Swift 101 项通过。
This commit is contained in:
@@ -26,7 +26,7 @@ type pair struct {
|
||||
appKx []byte
|
||||
}
|
||||
|
||||
func newPair(t *testing.T) pair {
|
||||
func newPair(t testing.TB) pair {
|
||||
t.Helper()
|
||||
_, sign, err := ed25519.GenerateKey(rand.Reader)
|
||||
if err != nil {
|
||||
@@ -51,7 +51,7 @@ type harness struct {
|
||||
sentEphemeral map[string][]byte
|
||||
}
|
||||
|
||||
func newHarness(t *testing.T, handler http.Handler) *harness {
|
||||
func newHarness(t testing.TB, handler http.Handler) *harness {
|
||||
t.Helper()
|
||||
server := httptest.NewServer(handler)
|
||||
t.Cleanup(server.Close)
|
||||
@@ -105,7 +105,7 @@ func newHarness(t *testing.T, handler http.Handler) *harness {
|
||||
}
|
||||
|
||||
// seal builds a complete request envelope the way the phone does.
|
||||
func (h *harness) seal(t *testing.T, reqID string, inner wire.InnerRequest) []byte {
|
||||
func (h *harness) seal(t testing.TB, reqID string, inner wire.InnerRequest) []byte {
|
||||
t.Helper()
|
||||
body, err := json.Marshal(inner)
|
||||
if err != nil {
|
||||
|
||||
Reference in New Issue
Block a user