Key should be re-calculate via value for node data source. #8

khipu-io · Sep 21, 2019 · 803da16 · 803da16
1 parent c3e1152
commit 803da16
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/khipu-eth/src/main/scala/khipu/storage/KesqueNodeCompactor.scala b/khipu-eth/src/main/scala/khipu/storage/KesqueNodeCompactor.scala
@@ -14,6 +14,7 @@ import khipu.DataWord
 import khipu.config.DbConfig
 import khipu.config.KhipuConfig
 import khipu.config.RocksdbConfig
+import khipu.crypto
 import khipu.domain.Account
 import khipu.rlp
 import khipu.storage.datasource.KesqueBlockDataSource
@@ -137,11 +138,12 @@ object KesqueNodeCompactor {
 
     def flush() {
       val kvs = buf map {
-        case TKeyVal(key, value, offset) =>
+        case TKeyVal(_, value, offset) =>
           _maxOffset = math.max(_maxOffset, offset)
+          val key = crypto.kec256(value)
           Hash(key) -> value
       }
-      //nodeDataSource.update(Nil, kvs)
+      nodeDataSource.update(Nil, kvs)
 
       buf.clear()
     }

diff --git a/khipu-kesque/src/main/scala/khipu/storage/datasource/KesqueNodeDataSource.scala b/khipu-kesque/src/main/scala/khipu/storage/datasource/KesqueNodeDataSource.scala
@@ -106,7 +106,6 @@ final class KesqueNodeDataSource(
     var records = Vector[SimpleRecord]()
     toUpsert foreach {
       case kv @ (key, value) =>
-        val keyBytes = key.bytes
         val record = new SimpleRecord(null, value)
         if (firstTimestamp == Long.MinValue) {
           firstTimestamp = 0