Fix getting not enrich blocks (#165)
This commit is contained in:
@@ -35,13 +35,12 @@ open class BlocksMemCache(
|
|||||||
}
|
}
|
||||||
|
|
||||||
open fun get(key: BlockId): BlockContainer? {
|
open fun get(key: BlockId): BlockContainer? {
|
||||||
return mapping.getIfPresent(key)
|
return mapping.getIfPresent(key)?.let {
|
||||||
|
return@let if (it.enriched) it else null
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
open fun add(block: BlockContainer) {
|
open fun add(block: BlockContainer) {
|
||||||
// if (!block.enriched) {
|
|
||||||
// return
|
|
||||||
// }
|
|
||||||
mapping.put(block.hash, block)
|
mapping.put(block.hash, block)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -89,22 +89,22 @@ class BlocksMemCacheSpec extends Specification {
|
|||||||
act1 == null
|
act1 == null
|
||||||
}
|
}
|
||||||
|
|
||||||
// def "Try add not full block and read"() {
|
def "Try add not full block and read"() {
|
||||||
// setup:
|
setup:
|
||||||
// def cache = new BlocksMemCache()
|
def cache = new BlocksMemCache()
|
||||||
// def block = new BlockJson<TransactionRefJson>()
|
def block = new BlockJson<TransactionRefJson>()
|
||||||
// block.number = 100
|
block.number = 100
|
||||||
// block.hash = BlockHash.from(hash1)
|
block.hash = BlockHash.from(hash1)
|
||||||
// block.totalDifficulty = BigInteger.ONE
|
block.totalDifficulty = BigInteger.ONE
|
||||||
// block.timestamp = Instant.now().truncatedTo(ChronoUnit.SECONDS)
|
block.timestamp = Instant.now().truncatedTo(ChronoUnit.SECONDS)
|
||||||
// block.uncles = []
|
block.uncles = []
|
||||||
// block.transactions = []
|
block.transactions = []
|
||||||
//
|
|
||||||
// when:
|
when:
|
||||||
// cache.add(BlockContainer.from(block))
|
cache.add(BlockContainer.from(block))
|
||||||
// def act = cache.read(BlockId.from(hash1)).block()
|
def act = cache.read(BlockId.from(hash1)).block()
|
||||||
// then:
|
then:
|
||||||
// act == null
|
act == null
|
||||||
// }
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user