[ETCM-468] merge develop

Signed-off-by: Piotr Paradziński <piotr.paradzinski@iohk.io>
input-output-hk · Jan 19, 2021 · 4aa4c62 · 4aa4c62
1 parent 459ed70
commit 4aa4c62
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/repo.nix b/repo.nix
diff --git a/src/main/scala/io/iohk/ethereum/network/PeerStatisticsActor.scala b/src/main/scala/io/iohk/ethereum/network/PeerStatisticsActor.scala
@@ -53,6 +53,17 @@ class PeerStatisticsActor(
     )
     maybeStats = maybeStats.map(_.add(peerId, obs))
   }
+
+  private def handleMessageFromPeer(msg: Message, peerId: PeerId): Unit = {
+    val now = clock.millis
+    val obs = PeerStat(
+      responsesReceived = if (ResponseCodes(msg.code)) 1 else 0,
+      requestsReceived = if (RequestCodes(msg.code)) 1 else 0,
+      firstSeenTimeMillis = Some(now),
+      lastSeenTimeMillis = Some(now)
+    )
+    maybeStats = maybeStats.map(_.add(peerId, obs))
+  }
 }
 
 object PeerStatisticsActor {