ethereum as generic upstream - tests

drpcorg · Oct 30, 2023 · 6c0e150 · 6c0e150
1 parent 5c0b93d
commit 6c0e150
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 5 deletions.
diff --git a/...le/test/EthereumPosRpcUpstreamMock.groovy → .../dshackle/test/GenericUpstreamMock.groovy b/...le/test/EthereumPosRpcUpstreamMock.groovy → .../dshackle/test/GenericUpstreamMock.groovy
@@ -63,15 +63,19 @@ class GenericUpstreamMock extends GenericUpstream {
     }
 
     GenericUpstreamMock(@NotNull String id, @NotNull Chain chain, @NotNull Reader<JsonRpcRequest, JsonRpcResponse> api, CallMethods methods, Map<String, String> labels) {
-        super(id, (byte)id.hashCode(), chain,
+        super(id,
+                chain,
+                (byte)id.hashCode(),
                 getOpts(),
                 UpstreamsConfig.UpstreamRole.PRIMARY,
                 methods,
                 new QuorumForLabels.QuorumItem(1, UpstreamsConfig.Labels.fromMap(labels)),
-                new ConnectorFactoryMock(api, new EthereumHeadMock()),
                 ChainConfig.default(),
-                true,
-                null
+                new ConnectorFactoryMock(api, new EthereumHeadMock()),
+                null,
+                io.emeraldpay.dshackle.upstream.starknet.StarknetChainSpecific.INSTANCE.&validator,
+                io.emeraldpay.dshackle.upstream.starknet.StarknetChainSpecific.INSTANCE.&labelDetector,
+                io.emeraldpay.dshackle.upstream.starknet.StarknetChainSpecific.INSTANCE.&subscriptionTopics,
         )
         this.ethereumHeadMock = this.getHead() as EthereumHeadMock
         setLag(0)

diff --git a/src/test/groovy/io/emeraldpay/dshackle/test/TestingCommons.groovy b/src/test/groovy/io/emeraldpay/dshackle/test/TestingCommons.groovy
@@ -90,7 +90,7 @@ class TestingCommons {
     }
 
     static Multistream multistream(GenericUpstreamMock up) {
-        return new GenericUpstreamMock(Chain.ETHEREUM__MAINNET, [up], Caches.default(), Schedulers.boundedElastic(), tracerMock()).tap {
+        return new EthereumMultistreamMock(Chain.ETHEREUM__MAINNET, [up], Caches.default(), Schedulers.boundedElastic(), tracerMock()).tap {
             start()
         }
     }
-Original file line number
+Diff line change
@@ Expand Up / @@ -90,7 +90,7 @@ class TestingCommons { @@
         }
         static Multistream multistream(GenericUpstreamMock up) {
-            return new GenericUpstreamMock(Chain.ETHEREUM__MAINNET, [up], Caches.default(), Schedulers.boundedElastic(), tracerMock()).tap {
+            return new EthereumMultistreamMock(Chain.ETHEREUM__MAINNET, [up], Caches.default(), Schedulers.boundedElastic(), tracerMock()).tap {
                 start()
             }
         }
@@ Expand Down @@