Function TestSession_ReconnectKicksOld

internal/nodehub/hub_test.go:326–354

---- 测试：重连踢旧连接 ----

(t *testing.T)

// ---- 测试：重连踢旧连接 ----

func TestSession_ReconnectKicksOld(t *testing.T) {
	hub := New(Options{PeerExtractor: mdPeerExtractor})
	env := newTestEnv(t, hub)

	cc1 := env.dial(t)
	mock1 := startNodeMock(t, cc1, "same-id")
	waitOnline(t, hub, "same-id")

	// 第二次连接（同一 nodeID）
	cc2 := env.dial(t)
	_ = startNodeMock(t, cc2, "same-id")

	// 旧连接的 closed 通道应该被关闭，且老 stream 在 server 侧的 conn 注册被替换。
	// 我们通过观察 hub.OnlineNodes() 仍只有 1 个 + 老 mock 的 done 关闭来验证。
	// 关闭老 client conn 让其 Recv 返回 EOF：
	_ = cc1.Close()

	select {
	case <-mock1.done:
		// ok
	case <-time.After(2 * time.Second):
		t.Fatal("old session did not exit after reconnect")
	}

	online := hub.OnlineNodes()
	if len(online) != 1 || online[0] != "same-id" {
		t.Fatalf("expected single online node 'same-id', got %v", online)
	}
}

// ---- 测试：usage_push ack ----