Misc fixes

build.sbt

@@ -13,8 +13,8 @@ name             := "consensus-client"
 maintainer       := "Units Network Team"
 resolvers ++= Resolver.sonatypeOssRepos("releases") ++ Resolver.sonatypeOssRepos("snapshots") ++ Seq(Resolver.mavenLocal)
 libraryDependencies ++= Seq(
-  "com.wavesplatform"              % "node-testkit"  % "1.5.7-3964-SNAPSHOT" % "test",
-  "com.wavesplatform"              % "node"          % "1.5.7-3964-SNAPSHOT" % "provided",
+  "com.wavesplatform"              % "node-testkit"  % "1.5.8-SNAPSHOT" % "test",
+  "com.wavesplatform"              % "node"          % "1.5.8-SNAPSHOT" % "provided",
   "com.softwaremill.sttp.client3"  % "core_2.13"     % "3.9.8",
   "com.softwaremill.sttp.client3" %% "play-json"     % "3.9.8",
   "com.github.jwt-scala"          %% "jwt-play-json" % "10.0.1"

docker/docker-compose-geth.yml

@@ -1,8 +1,17 @@
 services:
+  geth-init:
+    extends:
+      file: ./services/geth.yml
+      service: geth-init
+
   geth:
     extends:
       file: ./services/geth.yml
       service: geth
+    depends_on:
+      geth-init:
+        condition: service_completed_successfully
+
   waves-node:
     extends:
       file: ./services/waves-node.yml

docker/services/geth.yml

@@ -1,4 +1,12 @@
 services:
+  geth-init:
+    container_name: geth-init
+    image: ethereum/client-go:stable
+    entrypoint: /tmp/init-geth.sh
+    volumes:
+      - ../genesis-${NETWORK}.json:/tmp/genesis.json
+      - ../data/geth:/root/.ethereum
+      - ../init-geth.sh:/tmp/init-geth.sh
   geth:
     container_name: geth
     image: ethereum/client-go:stable
@@ -34,6 +42,7 @@ services:
     ports:
       - '30303:30303/tcp'
       - '30303:30303/udp'
+      - '8551:8551'
     healthcheck:
       test: 'wget -qO /dev/null --header "content-type: application/json" --post-data {\"jsonrpc\":\"2.0\",\"method\":\"eth_blockNumber\",\"params\":[],\"id\":1}  http://127.0.0.1:8545'
       interval: 5s

local-network/deploy/src/waves-txs.ts

@@ -54,9 +54,8 @@ export const ccMinerJoin1 = wt.invokeScript(
       args: [
         {
           // Reward address
-          type: "binary",
-          // 0x7dbcf9c6c3583b76669100f9be3caf6d722bc9f9
-          value: "base64:fbz5xsNYO3ZmkQD5vjyvbXIryfk="
+          type: "string",
+          value: "0x7dbcf9c6c3583b76669100f9be3caf6d722bc9f9"
         }
       ]
     }
@@ -74,9 +73,8 @@ export const ccMinerJoin2 = wt.invokeScript(
       args: [
         {
           // Reward address
-          type: "binary",
-          // 0xcf0b9e13fdd593f4ca26d36afcaa44dd3fdccbed
-          value: "base64:zwueE/3Vk/TKJtNq/KpE3T/cy+0="
+          type: "string",
+          value: "0xcf0b9e13fdd593f4ca26d36afcaa44dd3fdccbed"
         }
       ]
     }
@@ -131,4 +129,3 @@ export function mkE2CTransfer(senderPrivateKey: string, blockHash: string, merkl
     { privateKey: senderPrivateKey }
   )
 }
-

src/test/resources/main.ride

@@ -487,7 +487,7 @@ func appendBlock(
 }
 
 @Callable(i)
-func join(rewardAddress: ByteVector) = {
+func join(rewardAddressHex: String) = {
   # EL miner must sign a Network block by own private key
   func ensureNotOverrideOtherMinerPk(elAddressHex: String) = {
     match getBinary(minerPkKey(elAddressHex)) {
@@ -500,6 +500,9 @@ func join(rewardAddress: ByteVector) = {
     }
   }
 
+  let parts = rewardAddressHex.split("0x")
+  let rewardAddress = parts[parts.size() - 1].fromBase16String()
+
   if (!isContractSetup()) then
     throw("The contract has not yet set up")
   else if (i.originCaller.wavesBalance().generating < MIN_BALANCE) then
@@ -513,8 +516,8 @@ func join(rewardAddress: ByteVector) = {
     then []
     else {
       let newMiner = i.originCaller.toString()
-      let rewardAddressHex = rewardAddress.toBase16String()
-      strict check = ensureNotOverrideOtherMinerPk(rewardAddressHex)
+      let lowercaseRewardAddress = rewardAddress.toBase16String()
+      strict check = ensureNotOverrideOtherMinerPk(lowercaseRewardAddress)
 
       let newMiners =
         if (allMiners.size() == 0)
@@ -531,8 +534,8 @@ func join(rewardAddress: ByteVector) = {
       }
       [
         StringEntry(allMinersKey, newMiners),
-        StringEntry(minerRewardAddressKey(newMiner), "0x" + rewardAddressHex),
-        BinaryEntry(minerPkKey(rewardAddressHex), i.originCallerPublicKey)
+        StringEntry(minerRewardAddressKey(newMiner), "0x" + lowercaseRewardAddress),
+        BinaryEntry(minerPkKey(lowercaseRewardAddress), i.originCallerPublicKey)
       ] ++ deletePrevRewardAddressPk
     }
   }

src/test/scala/units/client/contract/HasConsensusLayerDappTxHelpers.scala

@@ -13,7 +13,6 @@ import units.client.L2BlockLike
 import units.client.contract.HasConsensusLayerDappTxHelpers.*
 import units.client.contract.HasConsensusLayerDappTxHelpers.defaultFees.chainContract.*
 import units.eth.{EthAddress, EthereumConstants}
-import units.util.HexBytesConverter
 
 trait HasConsensusLayerDappTxHelpers {
   def currentHitSource: ByteStr
@@ -38,7 +37,7 @@ trait HasConsensusLayerDappTxHelpers {
       invoker = minerAccount,
       dApp = chainContractAddress,
       func = "join".some,
-      args = List(Terms.CONST_BYTESTR(ByteStr(HexBytesConverter.toBytes(elRewardAddress.hexNoPrefix))).explicitGet()),
+      args = List(Terms.CONST_STRING(elRewardAddress.hexNoPrefix).explicitGet()),
       fee = joinFee
     )