Merge branch 'develop' into feature/etcm_269_healthcheck_bugfix

Author: enriquerodbe

src/test/scala/io/iohk/ethereum/blockchain/sync/regular/BlockFetcherSpec.scala

@@ -6,7 +6,7 @@ import akka.actor.ActorSystem
 import akka.testkit.{TestKit, TestProbe}
 import com.miguno.akka.testing.VirtualTime
 import io.iohk.ethereum.Mocks.{MockValidatorsAlwaysSucceed, MockValidatorsFailingOnBlockBodies}
-import io.iohk.ethereum.{BlockHelpers, Timeouts}
+import io.iohk.ethereum.{BlockHelpers, Timeouts, WithActorSystemShutDown}
 import io.iohk.ethereum.Fixtures.{Blocks => FixtureBlocks}
 import io.iohk.ethereum.blockchain.sync.PeersClient.BlacklistPeer
 import io.iohk.ethereum.blockchain.sync.regular.BlockFetcher.{InternalLastBlockImport, InvalidateBlocksFrom, PickBlocks}
@@ -24,7 +24,11 @@ import org.scalatest.matchers.should.Matchers
 
 import scala.concurrent.duration._
 
-class BlockFetcherSpec extends TestKit(ActorSystem("BlockFetcherSpec_System")) with AnyFreeSpecLike with Matchers {
+class BlockFetcherSpec
+    extends TestKit(ActorSystem("BlockFetcherSpec_System"))
+    with AnyFreeSpecLike
+    with WithActorSystemShutDown
+    with Matchers {
 
   "BlockFetcher" - {
 

src/test/scala/io/iohk/ethereum/blockchain/sync/regular/BlockFetcherStateSpec.scala

@@ -3,14 +3,18 @@ package io.iohk.ethereum.blockchain.sync.regular
 import akka.actor.ActorSystem
 import akka.testkit.{TestKit, TestProbe}
 import io.iohk.ethereum.Mocks.MockValidatorsAlwaysSucceed
-import io.iohk.ethereum.BlockHelpers
+import io.iohk.ethereum.{BlockHelpers, WithActorSystemShutDown}
 import io.iohk.ethereum.network.PeerId
 import org.scalatest.matchers.should.Matchers
 import org.scalatest.wordspec.AnyWordSpecLike
 
 import scala.collection.immutable.Queue
 
-class BlockFetcherStateSpec extends TestKit(ActorSystem()) with AnyWordSpecLike with Matchers {
+class BlockFetcherStateSpec
+    extends TestKit(ActorSystem("BlockFetcherStateSpec_System"))
+    with AnyWordSpecLike
+    with WithActorSystemShutDown
+    with Matchers {
 
   lazy val validators = new MockValidatorsAlwaysSucceed
 

src/test/scala/io/iohk/ethereum/consensus/ethash/EthashMinerSpec.scala

@@ -3,7 +3,7 @@ package ethash
 
 import akka.actor.{ActorRef, ActorSystem}
 import akka.testkit.{TestActor, TestActorRef, TestKit, TestProbe}
-import io.iohk.ethereum.Fixtures
+import io.iohk.ethereum.{Fixtures, WithActorSystemShutDown}
 import io.iohk.ethereum.consensus.blocks.{PendingBlock, PendingBlockAndState}
 import io.iohk.ethereum.consensus.ethash.validators.EthashBlockHeaderValidator
 import io.iohk.ethereum.consensus.validators.BlockHeaderValid
@@ -16,11 +16,17 @@ import monix.eval.Task
 import org.bouncycastle.util.encoders.Hex
 import org.scalamock.scalatest.MockFactory
 import org.scalatest.Tag
+
 import scala.concurrent.duration._
 import org.scalatest.flatspec.AnyFlatSpecLike
 import org.scalatest.matchers.should.Matchers
 
-class EthashMinerSpec extends TestKit(ActorSystem("EthashMinerSpec_System")) with AnyFlatSpecLike with Matchers {
+class EthashMinerSpec
+    extends TestKit(ActorSystem("EthashMinerSpec_System"))
+    with AnyFlatSpecLike
+    with WithActorSystemShutDown
+    with Matchers {
+
   final val EthashMinerSpecTag = Tag("EthashMinerSpec")
 
   private implicit val timeout: Duration = 10.minutes

src/test/scala/io/iohk/ethereum/network/PeerManagerSpec.scala

@@ -18,7 +18,7 @@ import io.iohk.ethereum.network.p2p.messages.CommonMessages.NewBlock
 import io.iohk.ethereum.network.p2p.messages.ProtocolVersions
 import io.iohk.ethereum.network.p2p.messages.WireProtocol.Disconnect
 import io.iohk.ethereum.utils.Config
-import io.iohk.ethereum.{Fixtures, NormalPatience}
+import io.iohk.ethereum.{Fixtures, NormalPatience, WithActorSystemShutDown}
 import org.bouncycastle.util.encoders.Hex
 import org.scalatest.concurrent.Eventually
 import org.scalatest.flatspec.AnyFlatSpecLike
@@ -28,6 +28,7 @@ import org.scalatest.matchers.should.Matchers
 class PeerManagerSpec
     extends TestKit(ActorSystem("PeerManagerSpec_System"))
     with AnyFlatSpecLike
+    with WithActorSystemShutDown
     with Matchers
     with Eventually
     with NormalPatience {

src/test/scala/io/iohk/ethereum/network/discovery/PeerDiscoveryManagerSpec.scala

@@ -1,33 +1,33 @@
 package io.iohk.ethereum.network.discovery
 
-import akka.pattern.ask
 import akka.actor.ActorSystem
+import akka.pattern.{AskTimeoutException, ask}
 import akka.testkit.{TestActorRef, TestKit}
 import akka.util.{ByteString, Timeout}
 import cats.effect.Resource
-import io.iohk.ethereum.NormalPatience
-import io.iohk.ethereum.utils.Config
 import io.iohk.ethereum.db.storage.KnownNodesStorage
+import io.iohk.ethereum.utils.Config
+import io.iohk.ethereum.{NormalPatience, WithActorSystemShutDown}
 import io.iohk.scalanet.discovery.crypto.PublicKey
 import io.iohk.scalanet.discovery.ethereum.v4.DiscoveryService
 import io.iohk.scalanet.discovery.ethereum.{Node => ENode}
 import monix.eval.Task
 import monix.execution.Scheduler
 import monix.execution.atomic.AtomicInt
-import org.scalatest.concurrent.Eventually
+import org.scalamock.scalatest.MockFactory
+import org.scalatest.concurrent.{Eventually, ScalaFutures}
 import org.scalatest.flatspec.AnyFlatSpecLike
 import org.scalatest.matchers.should.Matchers
-import org.scalatest.concurrent.ScalaFutures
-import org.scalamock.scalatest.MockFactory
-import scala.concurrent.duration._
 import scodec.bits.BitVector
-import scala.util.control.NoStackTrace
+
 import scala.collection.immutable.SortedSet
-import akka.pattern.AskTimeoutException
+import scala.concurrent.duration._
+import scala.util.control.NoStackTrace
 
 class PeerDiscoveryManagerSpec
     extends TestKit(ActorSystem("PeerDiscoveryManagerSpec_System"))
     with AnyFlatSpecLike
+    with WithActorSystemShutDown
     with Matchers
     with Eventually
     with MockFactory