Skip to content

Commit

Permalink
remove geth_db (#2189)
Browse files Browse the repository at this point in the history
doesn't look like it's used
  • Loading branch information
arnetheduck authored May 16, 2024
1 parent f1d7d2d commit 293ce28
Show file tree
Hide file tree
Showing 6 changed files with 15 additions and 93 deletions.
45 changes: 0 additions & 45 deletions nimbus/db/geth_db.nim

This file was deleted.

12 changes: 3 additions & 9 deletions nimbus/db/incomplete_db.nim
Original file line number Diff line number Diff line change
Expand Up @@ -55,16 +55,10 @@ proc ifNodesExistGetAccount*(trie: AccountsTrie, address: EthAddress): Option[Ac
ifNodesExistGetAccountBytes(trie, address).map(accountFromBytes)

proc maybeGetCode*(db: CoreDbRef, codeHash: Hash256): Option[seq[byte]] =
when defined(geth):
if db.isLegacy:
db.newKvt.backend.toLegacy.maybeGet(codeHash.data)
else:
db.kvt.get(codeHash.data)
if db.isLegacy:
db.newKvt.backend.toLegacy.maybeGet(contractHashKey(codeHash).toOpenArray)
else:
if db.isLegacy:
db.newKvt.backend.toLegacy.maybeGet(contractHashKey(codeHash).toOpenArray)
else:
some(db.kvt.get(contractHashKey(codeHash).toOpenArray))
some(db.kvt.get(contractHashKey(codeHash).toOpenArray))

proc maybeGetCode*(trie: AccountsTrie, address: EthAddress): Option[seq[byte]] =
let maybeAcc = trie.ifNodesExistGetAccount(address)
Expand Down
10 changes: 2 additions & 8 deletions nimbus/db/ledger/accounts_cache.nim
Original file line number Diff line number Diff line change
Expand Up @@ -303,10 +303,7 @@ proc persistMode(acc: RefAccount): PersistMode =

proc persistCode(acc: RefAccount, db: CoreDbRef) =
if acc.code.len != 0:
when defined(geth):
db.kvt.put(acc.account.codeHash.data, acc.code)
else:
db.kvt.put(contractHashKey(acc.account.codeHash).toOpenArray, acc.code)
db.kvt.put(contractHashKey(acc.account.codeHash).toOpenArray, acc.code)

proc persistStorage(acc: RefAccount, db: CoreDbRef, clearCache: bool) =
if acc.overlayStorage.len == 0:
Expand Down Expand Up @@ -385,10 +382,7 @@ proc getCode*(ac: AccountsCache, address: EthAddress): seq[byte] =
if CodeLoaded in acc.flags or CodeChanged in acc.flags:
result = acc.code
else:
when defined(geth):
let data = ac.kvt.get(acc.account.codeHash.data)
else:
let data = ac.kvt.get(contractHashKey(acc.account.codeHash).toOpenArray)
let data = ac.kvt.get(contractHashKey(acc.account.codeHash).toOpenArray)

acc.code = data
acc.flags.incl CodeLoaded
Expand Down
14 changes: 3 additions & 11 deletions nimbus/db/ledger/accounts_ledger.nim
Original file line number Diff line number Diff line change
Expand Up @@ -322,12 +322,8 @@ proc persistMode(acc: AccountRef): PersistMode =

proc persistCode(acc: AccountRef, ac: AccountsLedgerRef) =
if acc.code.len != 0:
when defined(geth):
let rc = ac.kvt.put(
acc.statement.codeHash.data, acc.code)
else:
let rc = ac.kvt.put(
contractHashKey(acc.statement.codeHash).toOpenArray, acc.code)
let rc = ac.kvt.put(
contractHashKey(acc.statement.codeHash).toOpenArray, acc.code)
if rc.isErr:
warn logTxt "persistCode()",
codeHash=acc.statement.codeHash, error=($$rc.error)
Expand Down Expand Up @@ -410,11 +406,7 @@ proc getCode*(ac: AccountsLedgerRef, address: EthAddress): seq[byte] =
if CodeLoaded in acc.flags or CodeChanged in acc.flags:
result = acc.code
else:
let rc = block:
when defined(geth):
ac.kvt.get(acc.statement.codeHash.data)
else:
ac.kvt.get(contractHashKey(acc.statement.codeHash).toOpenArray)
let rc = ac.kvt.get(contractHashKey(acc.statement.codeHash).toOpenArray)
if rc.isErr:
warn logTxt "getCode()", codeHash=acc.statement.codeHash, error=($$rc.error)
else:
Expand Down
16 changes: 5 additions & 11 deletions nimbus/evm/state.nim
Original file line number Diff line number Diff line change
Expand Up @@ -235,35 +235,29 @@ proc statelessInit*(
asyncFactory = asyncFactory)
return true

method coinbase*(vmState: BaseVMState): EthAddress {.base, gcsafe.} =
proc coinbase*(vmState: BaseVMState): EthAddress =
vmState.blockCtx.coinbase

method blockNumber*(vmState: BaseVMState): BlockNumber {.base, gcsafe.} =
proc blockNumber*(vmState: BaseVMState): BlockNumber =
# it should return current block number
# and not head.blockNumber
vmState.parent.blockNumber + 1

method difficultyOrPrevRandao*(vmState: BaseVMState): UInt256 {.base, gcsafe.} =
proc difficultyOrPrevRandao*(vmState: BaseVMState): UInt256 =
if vmState.com.consensus == ConsensusType.POS:
# EIP-4399/EIP-3675
UInt256.fromBytesBE(vmState.blockCtx.prevRandao.data)
else:
vmState.blockCtx.difficulty

method baseFee*(vmState: BaseVMState): UInt256 {.base, gcsafe.} =
proc baseFee*(vmState: BaseVMState): UInt256 =
vmState.blockCtx.fee.get(0.u256)

when defined(geth):
import db/geth_db

method getAncestorHash*(
vmState: BaseVMState, blockNumber: BlockNumber):
Hash256 {.base, gcsafe, raises: [CatchableError].} =
let db = vmState.com.db
when defined(geth):
result = db.headerHash(blockNumber.truncate(uint64))
else:
result = db.getBlockHash(blockNumber)
db.getBlockHash(blockNumber)

proc readOnlyStateDB*(vmState: BaseVMState): ReadOnlyStateDB {.inline.} =
ReadOnlyStateDB(vmState.stateDB)
Expand Down
11 changes: 2 additions & 9 deletions nimbus/tracer.nim
Original file line number Diff line number Diff line change
Expand Up @@ -20,15 +20,8 @@ import
results,
./beacon/web3_eth_conv

when defined(geth):
import db/geth_db

proc getParentHeader(db: CoreDbRef, header: BlockHeader): BlockHeader =
db.blockHeader(header.blockNumber.truncate(uint64) - 1)

else:
proc getParentHeader(self: CoreDbRef, header: BlockHeader): BlockHeader =
self.getBlockHeader(header.parentHash)
proc getParentHeader(self: CoreDbRef, header: BlockHeader): BlockHeader =
self.getBlockHeader(header.parentHash)

type
SaveCtxEnv = object
Expand Down

0 comments on commit 293ce28

Please sign in to comment.