You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository was archived by the owner on Aug 1, 2023. It is now read-only.
Copy file name to clipboardexpand all lines: eth-client/src/main/kotlin/org/apache/tuweni/ethclient/EthereumClient.kt
+19-6
Original file line number
Diff line number
Diff line change
@@ -309,10 +309,18 @@ class EthereumClient(
309
309
}
310
310
).thenRun {
311
311
for (sync in config.synchronizers()) {
312
-
val syncRepository = storageRepositories[sync.getRepository()] ?:throwIllegalArgumentException("Repository ${sync.getRepository()} missing for synchronizer ${sync.getName()}")
313
-
val syncService = rlpxServices[sync.getRlpxService()] ?:throwIllegalArgumentException("Service ${sync.getRlpxService()} missing for synchronizer ${sync.getName()}")
314
-
val syncPeerRepository = peerRepositories[sync.getPeerRepository()] ?:throwIllegalArgumentException("Peer repository ${sync.getPeerRepository()} missing for synchronizer ${sync.getName()}")
315
-
val adapter = adapters[sync.getRlpxService()] ?:throwIllegalArgumentException("Service ${sync.getRlpxService()} missing for synchronizer ${sync.getName()}")
312
+
val syncRepository = storageRepositories[sync.getRepository()] ?:throwIllegalArgumentException(
313
+
"Repository ${sync.getRepository()} missing for synchronizer ${sync.getName()}"
314
+
)
315
+
val syncService = rlpxServices[sync.getRlpxService()] ?:throwIllegalArgumentException(
316
+
"Service ${sync.getRlpxService()} missing for synchronizer ${sync.getName()}"
317
+
)
318
+
val syncPeerRepository = peerRepositories[sync.getPeerRepository()] ?:throwIllegalArgumentException(
319
+
"Peer repository ${sync.getPeerRepository()} missing for synchronizer ${sync.getName()}"
320
+
)
321
+
val adapter = adapters[sync.getRlpxService()] ?:throwIllegalArgumentException(
322
+
"Service ${sync.getRlpxService()} missing for synchronizer ${sync.getName()}"
323
+
)
316
324
317
325
when (sync.getType()) {
318
326
SynchronizerType.BEST-> {
@@ -351,7 +359,9 @@ class EthereumClient(
351
359
}
352
360
SynchronizerType.CANONICAL-> {
353
361
val fromRepository = storageRepositories.get(sync.getFromRepository())
354
-
?:throwIllegalArgumentException("Missing repository for canonical repository ${sync.getFromRepository()}")
362
+
?:throwIllegalArgumentException(
363
+
"Missing repository for canonical repository ${sync.getFromRepository()}"
@@ -46,7 +46,6 @@ class CrawlerConfig(val filePath: Path) {
46
46
// Ethereum Foundation Aleth Bootnodes
47
47
"enode://979b7fa28feeb35a4741660a16076f1943202cb72b6af70d327f053e248bab9ba81760f39d0701ef1d8f89cc1fbd2cacba0710a12cd5314d5e0c9021aa3637f9@5.1.83.226:30303"// DE
48
48
)
49
-
50
49
val mainnetDiscoveryDNS ="enrtree://AKA3AM6LPBYEUDMVNU3BSVQJ5AD45Y7YPOHJLEF6W26QOE4VTUDPE@all.mainnet.ethdisco.net"
51
50
52
51
funschema(): Schema {
@@ -73,15 +72,25 @@ class CrawlerConfig(val filePath: Path) {
0 commit comments