Merge pull request #1980 from dedis/fix-be2-daniel-new-server-connected

[BE2] Add notify new server connected
dedis · Jun 30, 2024 · b1d7574 · b1d7574
2 parents 2ab5e66 + be1e3a7
commit b1d7574
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/be2-scala/src/main/scala/ch/epfl/pop/decentralized/ConnectionMediator.scala b/be2-scala/src/main/scala/ch/epfl/pop/decentralized/ConnectionMediator.scala
@@ -74,6 +74,8 @@ final case class ConnectionMediator(
       if (serverMap.isEmpty) {
         monitorRef ! Monitor.AtLeastOneServerConnected
         gossipManagerRef ! Monitor.AtLeastOneServerConnected
+      } else {
+        gossipManagerRef ! ConnectionMediator.NewServerConnected(serverRef, greetServer)
       }
       serverMap += ((serverRef, greetServer))
 

diff --git a/be2-scala/src/test/scala/ch/epfl/pop/decentralized/GossipManagerSuite.scala b/be2-scala/src/test/scala/ch/epfl/pop/decentralized/GossipManagerSuite.scala
@@ -317,7 +317,6 @@ class GossipManagerSuite extends TestKit(ActorSystem("GossipManagerSuiteActorSys
 
     Await.result(output, duration)
 
-    // include rumor state
     peers.map(_.receiveOne(duration)).count(_ != null) shouldBe 1
 
   }
@@ -365,7 +364,7 @@ class GossipManagerSuite extends TestKit(ActorSystem("GossipManagerSuiteActorSys
     val response = Right(JsonRpcResponse(
       RpcValidator.JSON_RPC_VERSION,
       ResultObject(0),
-      Some(1)
+      Some(4)
     ))
 
     // by processing the reponse, gossipManager should send again a rumor to a new peer