Skip to content

Commit 1850372

Browse files
author
Jaap van der Plas
committed
scalafmtAll
1 parent 5b24944 commit 1850372

File tree

5 files changed

+29
-6
lines changed

5 files changed

+29
-6
lines changed

src/it/scala/io/iohk/ethereum/sync/util/CommonFakePeer.scala

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,15 @@ import io.iohk.ethereum.network.handshaker.{EtcHandshaker, EtcHandshakerConfigur
2727
import io.iohk.ethereum.network.p2p.EthereumMessageDecoder
2828
import io.iohk.ethereum.network.rlpx.AuthHandshaker
2929
import io.iohk.ethereum.network.rlpx.RLPxConnectionHandler.RLPxConfiguration
30-
import io.iohk.ethereum.network.{EtcPeerManagerActor, ForkResolver, KnownNodesManager, PeerEventBusActor, PeerManagerActor, PeerStatisticsActor, ServerActor}
30+
import io.iohk.ethereum.network.{
31+
EtcPeerManagerActor,
32+
ForkResolver,
33+
KnownNodesManager,
34+
PeerEventBusActor,
35+
PeerManagerActor,
36+
PeerStatisticsActor,
37+
ServerActor
38+
}
3139
import io.iohk.ethereum.nodebuilder.PruningConfigBuilder
3240
import io.iohk.ethereum.sync.util.SyncCommonItSpec._
3341
import io.iohk.ethereum.sync.util.SyncCommonItSpecUtils._

src/it/scala/io/iohk/ethereum/sync/util/RegularSyncItSpecUtils.scala

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,10 @@ object RegularSyncItSpecUtils {
6767

6868
lazy val checkpointBlockGenerator: CheckpointBlockGenerator = new CheckpointBlockGenerator
6969
lazy val peersClient: ActorRef =
70-
system.actorOf(PeersClient.props(etcPeerManager, peerEventBus, blacklist, testSyncConfig, system.scheduler), "peers-client")
70+
system.actorOf(
71+
PeersClient.props(etcPeerManager, peerEventBus, blacklist, testSyncConfig, system.scheduler),
72+
"peers-client"
73+
)
7174

7275
lazy val ledger: Ledger =
7376
new LedgerImpl(bl, blockchainConfig, syncConfig, buildEthashConsensus(), Scheduler.global)
@@ -83,7 +86,14 @@ object RegularSyncItSpecUtils {
8386

8487
val broadcasterRef: ActorRef = system.actorOf(
8588
BlockBroadcasterActor
86-
.props(new BlockBroadcast(etcPeerManager), peerEventBus, etcPeerManager, blacklist, syncConfig, system.scheduler),
89+
.props(
90+
new BlockBroadcast(etcPeerManager),
91+
peerEventBus,
92+
etcPeerManager,
93+
blacklist,
94+
syncConfig,
95+
system.scheduler
96+
),
8797
"block-broadcaster"
8898
)
8999

src/it/scala/io/iohk/ethereum/txExecTest/ForksTest.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ class ForksTest extends AnyFlatSpec with Matchers {
5050
daoForkConfig = None,
5151
gasTieBreaker = false,
5252
ethCompatibleStorage = true,
53-
treasuryAddress = Address(0),
53+
treasuryAddress = Address(0)
5454
)
5555

5656
val noErrors = a[Right[_, Seq[Receipt]]]

src/main/scala/io/iohk/ethereum/blockchain/sync/fast/FastSyncBranchResolverActor.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,9 @@ class FastSyncBranchResolverActor(
4949
getPeerWithHighestBlock match {
5050
case Some(peerWithInfo @ PeerWithInfo(peer, _)) =>
5151
log.debug(
52-
"Starting branch resolution now with peer {} and block number {}", peerWithInfo, blockchain.getBestBlockNumber()
52+
"Starting branch resolution now with peer {} and block number {}",
53+
peerWithInfo,
54+
blockchain.getBestBlockNumber()
5355
)
5456
requestRecentBlockHeaders(peer, blockchain.getBestBlockNumber())
5557
case None =>

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

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -137,7 +137,10 @@ class RegularSyncSpec
137137
peersClient.expectMsgEq(getBodies)
138138
peersClient.reply(PeersClient.Response(defaultPeer, BlockBodies(testBlocksChunked.head.bodies)))
139139

140-
blockFetcher ! MessageFromPeer(NewBlock(testBlocks.last, ChainWeight.totalDifficultyOnly(testBlocks.last.number)), defaultPeer.id)
140+
blockFetcher ! MessageFromPeer(
141+
NewBlock(testBlocks.last, ChainWeight.totalDifficultyOnly(testBlocks.last.number)),
142+
defaultPeer.id
143+
)
141144
peersClient.expectMsgEq(blockHeadersChunkRequest(1))
142145
peersClient.reply(PeersClient.Response(defaultPeer, BlockHeaders(testBlocksChunked(5).headers)))
143146
peersClient.expectMsgPF() {

0 commit comments

Comments
 (0)