From 1ee579e3d43fe46323c2489b58e7c0dd5afc8127 Mon Sep 17 00:00:00 2001 From: Joachim Bauch Date: Wed, 31 Jul 2024 08:42:40 +0200 Subject: [PATCH] Use different NATS servers for federation tests. Otherwise it would be possible to send events to remote sessions (through NATS) even if they are connected to a separate signaling server which has it's own NATS server in reality. --- hub_test.go | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/hub_test.go b/hub_test.go index 3cf8ea21..c8c7b37b 100644 --- a/hub_test.go +++ b/hub_test.go @@ -196,11 +196,17 @@ func CreateClusteredHubsForTestWithConfig(t *testing.T, getConfigFunc func(*http server2.Close() }) - nats := startLocalNatsServer(t) + nats1 := startLocalNatsServer(t) + var nats2 string + if strings.Contains(t.Name(), "Federation") { + nats2 = startLocalNatsServer(t) + } else { + nats2 = nats1 + } grpcServer1, addr1 := NewGrpcServerForTest(t) grpcServer2, addr2 := NewGrpcServerForTest(t) - events1, err := NewAsyncEvents(nats) + events1, err := NewAsyncEvents(nats1) if err != nil { t.Fatal(err) } @@ -220,7 +226,7 @@ func CreateClusteredHubsForTestWithConfig(t *testing.T, getConfigFunc func(*http if err != nil { t.Fatal(err) } - events2, err := NewAsyncEvents(nats) + events2, err := NewAsyncEvents(nats2) if err != nil { t.Fatal(err) }