ETCM-697: Transaction get log hash implemented

Author: Igor Grahovac

src/main/scala/io/iohk/ethereum/jsonrpc/JsonRpcController.scala

@@ -247,6 +247,8 @@ case class JsonRpcController(
       handle[RewindToBlockRequest, RewindToBlockResponse](testService.rewindToBlock, req)
     case req @ JsonRpcRequest(_, "test_importRawBlock", _, _) =>
       handle[ImportRawBlockRequest, ImportRawBlockResponse](testService.importRawBlock, req)
+    case req @ JsonRpcRequest(_, "test_getLogHash", _, _) =>
+      handle[GetLogHashRequest, GetLogHashResponse](testService.getLogHash, req)
     case req @ JsonRpcRequest(_, "miner_setEtherbase", _, _) =>
       handle[SetEtherbaseRequest, SetEtherbaseResponse](testService.setEtherbase, req)
     case req @ JsonRpcRequest(_, "debug_accountRange", _, _) =>

src/main/scala/io/iohk/ethereum/jsonrpc/TestJsonMethodsImplicits.scala

@@ -216,4 +216,17 @@ object TestJsonMethodsImplicits extends JsonMethodsImplicits {
 
     override def encodeJson(t: StorageRangeResponse): JValue = Extraction.decompose(t)
   }
+
+  implicit val test_getLogHash = new JsonMethodDecoder[GetLogHashRequest] with JsonEncoder[GetLogHashResponse] {
+    def decodeJson(params: Option[JArray]): Either[JsonRpcError, GetLogHashRequest] =
+      params match {
+        case Some(JArray(JString(transactionHashString) :: Nil)) =>
+          for {
+            transactionHash <- extractHash(transactionHashString)
+          } yield GetLogHashRequest(transactionHash)
+        case _ => Left(InvalidParams())
+      }
+
+    override def encodeJson(t: GetLogHashResponse): JValue = encodeAsHex(t.logHash)
+  }
 }

src/main/scala/io/iohk/ethereum/jsonrpc/TestService.scala

@@ -5,7 +5,7 @@ import akka.util.{ByteString, Timeout}
 import io.iohk.ethereum.blockchain.data.{GenesisAccount, GenesisData, GenesisDataLoader}
 import io.iohk.ethereum.consensus.ConsensusConfig
 import io.iohk.ethereum.consensus.blocks._
-import io.iohk.ethereum.crypto
+import io.iohk.ethereum.{crypto, rlp}
 import io.iohk.ethereum.domain.Block._
 import io.iohk.ethereum.domain.{Address, Block, BlockchainImpl, UInt256}
 import io.iohk.ethereum.ledger._
@@ -17,7 +17,8 @@ import monix.eval.Task
 import monix.execution.Scheduler
 import org.bouncycastle.util.encoders.Hex
 import io.iohk.ethereum.jsonrpc.JsonMethodsImplicits._
-import io.iohk.ethereum.ledger.InMemoryWorldStateProxy.persistState
+
+import io.iohk.ethereum.rlp.RLPList
 
 import scala.concurrent.duration._
 import scala.util.{Failure, Success, Try}
@@ -98,6 +99,9 @@ object TestService {
 
   case class StorageRangeRequest(parameters: StorageRangeParams)
   case class StorageRangeResponse(complete: Boolean, storage: Map[ByteString, StorageEntry])
+
+  case class GetLogHashRequest(transactionHash: ByteString)
+  case class GetLogHashResponse(logHash: ByteString)
 }
 
 class TestService(
@@ -340,4 +344,21 @@ class TestService(
       )
     )
   }
+
+  def getLogHash(request: GetLogHashRequest): ServiceResponse[GetLogHashResponse] = {
+    import io.iohk.ethereum.network.p2p.messages.PV63.TxLogEntryImplicits._
+
+    val result = for {
+      transactionLocation <- blockchain.getTransactionLocation(request.transactionHash)
+      block <- blockchain.getBlockByHash(transactionLocation.blockHash)
+      _ <- block.body.transactionList.lift(transactionLocation.txIndex)
+      receipts <- blockchain.getReceiptsByHash(block.header.hash)
+      logs = receipts.flatMap(receipt => receipt.logs)
+      rlpList: RLPList = RLPList(logs.map(_.toRLPEncodable).toList: _*)
+    } yield ByteString(crypto.kec256(rlp.encode(rlpList)))
+
+    result
+      .map(rlpHash => Task.now(Right(GetLogHashResponse(rlpHash))))
+      .getOrElse(Task.now(Right(GetLogHashResponse(ByteString(crypto.kec256(rlp.encode(RLPList(List(): _*))))))))
+  }
 }

src/main/scala/io/iohk/ethereum/ledger/BlockPreparator.scala

@@ -60,7 +60,9 @@ class BlockPreparator(
       block: Block,
       worldStateProxy: InMemoryWorldStateProxy
   ): InMemoryWorldStateProxy = {
-    if (!Config.testmode) {
+    if (Config.testmode) {
+      worldStateProxy
+    } else {
       val blockNumber = block.header.number
 
       val minerRewardForBlock = blockRewardCalculator.calculateMiningRewardForBlock(blockNumber)
@@ -104,8 +106,7 @@ class BlockPreparator(
         log.debug(s"Paying block $blockNumber reward of $ommerReward to ommer with account address $ommerAddress")
         increaseAccountBalance(ommerAddress, UInt256(ommerReward))(ws)
       }
-    } else
-      worldStateProxy
+    }
   }
 
   /**

src/main/scala/io/iohk/ethereum/testmode/TestmodeConsensus.scala

@@ -65,7 +65,7 @@ class TestmodeConsensus(
     }
   }
 
-  override def validators: Validators = ValidatorsExecutor.apply(blockchainConfig, Protocol.Ethash)
+  override def validators: Validators = ValidatorsExecutor.apply(blockchainConfig, Protocol.MockedPow)
 
   override val blockPreparator: BlockPreparator = new BlockPreparator(
     vm = vm,