2018-06-20 17:27:32 +00:00
|
|
|
|
# Nimbus
|
|
|
|
|
# Copyright (c) 2018 Status Research & Development GmbH
|
|
|
|
|
# Licensed under either of
|
|
|
|
|
# * Apache License, version 2.0, ([LICENSE-APACHE](LICENSE-APACHE))
|
|
|
|
|
# * MIT license ([LICENSE-MIT](LICENSE-MIT))
|
|
|
|
|
# at your option.
|
|
|
|
|
# This file may not be copied, modified, or distributed except according to
|
|
|
|
|
# those terms.
|
2018-07-31 17:18:43 +00:00
|
|
|
|
import
|
2018-08-13 18:29:38 +00:00
|
|
|
|
nimcrypto, json_rpc/rpcserver, eth_p2p, hexstrings, strutils, stint,
|
2018-08-22 21:15:26 +00:00
|
|
|
|
../config, ../vm_state, ../constants, eth_trie/[memdb, types], eth_keys,
|
2018-08-17 18:53:47 +00:00
|
|
|
|
../db/[db_chain, state_db, storage_types], eth_common, rpc_types, byteutils,
|
|
|
|
|
ranges/typedranges, times, ../utils/header, rlp
|
2018-08-14 17:22:31 +00:00
|
|
|
|
|
|
|
|
|
#[
|
|
|
|
|
Note:
|
|
|
|
|
* Hexstring types (HexQuantitySt, HexDataStr, EthAddressStr, EthHashStr)
|
|
|
|
|
are parsed to check format before the RPC blocks are executed and will
|
|
|
|
|
raise an exception if invalid.
|
2018-08-15 13:08:40 +00:00
|
|
|
|
* Many of the RPC calls do not validate hex string types when output, only
|
|
|
|
|
type cast to avoid extra processing.
|
2018-08-14 17:22:31 +00:00
|
|
|
|
]#
|
|
|
|
|
|
2018-08-15 13:08:40 +00:00
|
|
|
|
# Work around for https://github.com/nim-lang/Nim/issues/8645
|
|
|
|
|
proc `%`*(value: Time): JsonNode =
|
|
|
|
|
result = %value.toSeconds
|
|
|
|
|
|
2018-08-14 17:22:31 +00:00
|
|
|
|
func strToAddress(value: string): EthAddress = hexToPaddedByteArray[20](value)
|
2018-07-31 17:18:43 +00:00
|
|
|
|
|
2018-08-16 17:25:17 +00:00
|
|
|
|
func toHash(value: array[32, byte]): Hash256 {.inline.} =
|
|
|
|
|
result.data = value
|
|
|
|
|
|
|
|
|
|
func strToHash(value: string): Hash256 {.inline.} =
|
|
|
|
|
result = hexToPaddedByteArray[32](value).toHash
|
|
|
|
|
|
2018-08-23 21:45:14 +00:00
|
|
|
|
func hash(transaction: Transaction): Hash256 =
|
|
|
|
|
# Hash transaction without signature
|
|
|
|
|
type
|
|
|
|
|
TransHashObj = object
|
|
|
|
|
accountNonce: uint64
|
|
|
|
|
gasPrice: GasInt
|
|
|
|
|
gasLimit: GasInt
|
|
|
|
|
to: EthAddress
|
|
|
|
|
value: UInt256
|
|
|
|
|
payload: Blob
|
|
|
|
|
return TransHashObj(
|
|
|
|
|
accountNonce: transaction.accountNonce,
|
|
|
|
|
gasPrice: transaction.gasPrice,
|
|
|
|
|
gasLimit: transaction.gasLimit,
|
|
|
|
|
to: transaction.to,
|
|
|
|
|
value: transaction.value,
|
|
|
|
|
payload: transaction.payload
|
|
|
|
|
).rlpHash
|
|
|
|
|
|
2018-08-23 20:21:17 +00:00
|
|
|
|
template toSignature(transaction: Transaction): Signature =
|
|
|
|
|
var bytes: array[65, byte]
|
|
|
|
|
bytes[0..31] = cast[array[32, byte]](transaction.R)
|
|
|
|
|
bytes[32..63] = cast[array[32, byte]](transaction.S)
|
|
|
|
|
#[
|
|
|
|
|
TODO: In the yellow paper:
|
|
|
|
|
It is assumed that v is the ‘recovery id’, a 1 byte value
|
|
|
|
|
specifying the sign and finiteness of the curve point; this
|
|
|
|
|
value is in the range of [27,30].
|
|
|
|
|
Does this need to be checked that it is [0, 1] and inc by 27?
|
|
|
|
|
]#
|
|
|
|
|
# TODO: Ugly casting below, is there a better way/helper func?
|
|
|
|
|
bytes[64] = (cast[uint64](transaction.V.data.lo) and 0xff'u64).uint8
|
|
|
|
|
initSignature(bytes)
|
|
|
|
|
|
2018-08-23 21:45:14 +00:00
|
|
|
|
proc getSender(transaction: Transaction): EthAddress =
|
2018-08-23 20:37:59 +00:00
|
|
|
|
## Find the address the transaction was sent from.
|
2018-08-23 20:21:17 +00:00
|
|
|
|
let
|
2018-08-23 21:45:14 +00:00
|
|
|
|
txHash = transaction.hash # hash without signature
|
2018-08-23 20:21:17 +00:00
|
|
|
|
sig = transaction.toSignature()
|
|
|
|
|
pubKey = recoverKeyFromSignature(sig, txHash)
|
2018-08-24 12:59:55 +00:00
|
|
|
|
result = pubKey.toCanonicalAddress()
|
2018-08-23 20:21:17 +00:00
|
|
|
|
|
2018-08-23 20:37:59 +00:00
|
|
|
|
template balance(addressDb: AccountStateDb, address: EthAddress): GasInt =
|
|
|
|
|
# TODO: Account balance u256 but GasInt is int64?
|
|
|
|
|
cast[GasInt](addressDb.get_balance(address).data.lo)
|
|
|
|
|
|
2018-08-06 16:18:24 +00:00
|
|
|
|
func headerFromTag(chain:BaseChainDB, blockTag: string): BlockHeader =
|
2018-08-03 16:16:10 +00:00
|
|
|
|
let tag = blockTag.toLowerAscii
|
2018-07-31 17:18:43 +00:00
|
|
|
|
case tag
|
|
|
|
|
of "latest": result = chain.getCanonicalHead()
|
2018-08-16 17:25:17 +00:00
|
|
|
|
of "earliest": result = chain.getBlockHeader(GENESIS_BLOCK_NUMBER)
|
2018-07-31 17:18:43 +00:00
|
|
|
|
of "pending":
|
2018-08-06 16:18:24 +00:00
|
|
|
|
#TODO: Implement get pending block
|
2018-07-31 17:18:43 +00:00
|
|
|
|
raise newException(ValueError, "Pending tag not yet implemented")
|
|
|
|
|
else:
|
|
|
|
|
# Raises are trapped and wrapped in JSON when returned to the user.
|
2018-08-06 16:18:24 +00:00
|
|
|
|
tag.validateHexQuantity
|
2018-07-31 17:18:43 +00:00
|
|
|
|
let blockNum = stint.fromHex(UInt256, tag)
|
2018-08-16 17:25:17 +00:00
|
|
|
|
result = chain.getBlockHeader(blockNum)
|
2018-06-20 17:27:32 +00:00
|
|
|
|
|
2018-08-13 18:29:38 +00:00
|
|
|
|
proc setupP2PRPC*(node: EthereumNode, rpcsrv: RpcServer) =
|
|
|
|
|
template chain: untyped = BaseChainDB(node.chain) # TODO: Sensible casting
|
|
|
|
|
|
2018-08-22 21:15:26 +00:00
|
|
|
|
proc getAccountDb(readOnly = true): AccountStateDb =
|
|
|
|
|
## Retrieves the account db from canonical head
|
|
|
|
|
let
|
|
|
|
|
header = chain.getCanonicalHead()
|
|
|
|
|
vmState = newBaseVMState(header, chain)
|
|
|
|
|
result = vmState.chaindb.getStateDb(vmState.blockHeader.hash, readOnly)
|
|
|
|
|
|
|
|
|
|
proc getAccountDbFromTag(tag: string, readOnly = true): AccountStateDb =
|
2018-08-13 18:29:38 +00:00
|
|
|
|
let
|
|
|
|
|
header = chain.headerFromTag(tag)
|
|
|
|
|
vmState = newBaseVMState(header, chain)
|
2018-08-15 13:12:49 +00:00
|
|
|
|
result = vmState.chaindb.getStateDb(vmState.blockHeader.hash, readOnly)
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
2018-07-22 21:34:43 +00:00
|
|
|
|
rpcsrv.rpc("net_version") do() -> uint:
|
2018-06-20 17:27:32 +00:00
|
|
|
|
let conf = getConfiguration()
|
|
|
|
|
result = conf.net.networkId
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_syncing") do() -> JsonNode:
|
|
|
|
|
## Returns SyncObject or false when not syncing.
|
|
|
|
|
# TODO: Requires PeerPool to check sync state.
|
|
|
|
|
# TODO: Use variant objects
|
|
|
|
|
var
|
|
|
|
|
res: JsonNode
|
|
|
|
|
sync: SyncState
|
|
|
|
|
if true:
|
|
|
|
|
# TODO: Populate sync state, this is a placeholder
|
2018-08-15 13:08:40 +00:00
|
|
|
|
sync.startingBlock = GENESIS_BLOCK_NUMBER
|
|
|
|
|
sync.currentBlock = chain.getCanonicalHead().blockNumber
|
|
|
|
|
sync.highestBlock = chain.getCanonicalHead().blockNumber
|
2018-08-13 18:29:38 +00:00
|
|
|
|
result = %sync
|
|
|
|
|
else:
|
|
|
|
|
result = newJBool(false)
|
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_coinbase") do() -> EthAddress:
|
|
|
|
|
## Returns the current coinbase address.
|
|
|
|
|
result = chain.getCanonicalHead().coinbase
|
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_mining") do() -> bool:
|
|
|
|
|
## Returns true if the client is mining, otherwise false.
|
|
|
|
|
discard
|
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_hashrate") do() -> int:
|
|
|
|
|
## Returns the number of hashes per second that the node is mining with.
|
|
|
|
|
discard
|
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_gasPrice") do() -> int64:
|
|
|
|
|
## Returns an integer of the current gas price in wei.
|
|
|
|
|
discard
|
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_accounts") do() -> seq[EthAddressStr]:
|
|
|
|
|
## Returns a list of addresses owned by client.
|
|
|
|
|
result = @[]
|
2018-07-31 17:18:43 +00:00
|
|
|
|
|
2018-08-13 18:29:38 +00:00
|
|
|
|
rpcsrv.rpc("eth_blockNumber") do() -> BlockNumber:
|
|
|
|
|
## Returns integer of the current block number the client is on.
|
|
|
|
|
result = chain.getCanonicalHead().blockNumber
|
|
|
|
|
|
2018-08-23 20:37:59 +00:00
|
|
|
|
rpcsrv.rpc("eth_getBalance") do(data: EthAddressStr, quantityTag: string) -> GasInt:
|
2018-07-31 17:18:43 +00:00
|
|
|
|
## Returns the balance of the account of given address.
|
|
|
|
|
##
|
|
|
|
|
## data: address to check for balance.
|
|
|
|
|
## quantityTag: integer block number, or the string "latest", "earliest" or "pending", see the default block parameter.
|
|
|
|
|
## Returns integer of the current balance in wei.
|
|
|
|
|
let
|
2018-08-22 21:15:26 +00:00
|
|
|
|
accountDb = getAccountDbFromTag(quantityTag)
|
2018-08-14 17:22:31 +00:00
|
|
|
|
addrBytes = strToAddress(data.string)
|
2018-08-16 17:25:17 +00:00
|
|
|
|
balance = accountDb.get_balance(addrBytes)
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
|
|
|
|
result = balance.toInt
|
|
|
|
|
|
2018-08-15 13:08:40 +00:00
|
|
|
|
rpcsrv.rpc("eth_getStorageAt") do(data: EthAddressStr, quantity: int, quantityTag: string) -> UInt256:
|
2018-08-13 18:29:38 +00:00
|
|
|
|
## Returns the value from a storage position at a given address.
|
|
|
|
|
##
|
|
|
|
|
## data: address of the storage.
|
|
|
|
|
## quantity: integer of the position in the storage.
|
|
|
|
|
## quantityTag: integer block number, or the string "latest", "earliest" or "pending", see the default block parameter.
|
|
|
|
|
## Returns: the value at this storage position.
|
|
|
|
|
let
|
2018-08-22 21:15:26 +00:00
|
|
|
|
accountDb = getAccountDbFromTag(quantityTag)
|
2018-08-14 17:22:31 +00:00
|
|
|
|
addrBytes = strToAddress(data.string)
|
2018-08-16 17:25:17 +00:00
|
|
|
|
storage = accountDb.getStorage(addrBytes, quantity.u256)
|
2018-08-13 18:29:38 +00:00
|
|
|
|
if storage[1]:
|
2018-08-15 13:08:40 +00:00
|
|
|
|
result = storage[0]
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
2018-08-16 17:25:17 +00:00
|
|
|
|
rpcsrv.rpc("eth_getTransactionCount") do(data: EthAddressStr, quantityTag: string) -> UInt256:
|
2018-08-13 18:29:38 +00:00
|
|
|
|
## Returns the number of transactions sent from an address.
|
|
|
|
|
##
|
|
|
|
|
## data: address.
|
|
|
|
|
## quantityTag: integer block number, or the string "latest", "earliest" or "pending", see the default block parameter.
|
|
|
|
|
## Returns integer of the number of transactions send from this address.
|
2018-08-14 15:52:30 +00:00
|
|
|
|
let
|
2018-08-16 17:25:17 +00:00
|
|
|
|
addrBytes = data.string.strToAddress()
|
2018-08-22 21:15:26 +00:00
|
|
|
|
accountDb = getAccountDbFromTag(quantityTag)
|
2018-08-16 17:25:17 +00:00
|
|
|
|
result = accountDb.getNonce(addrBytes)
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_getBlockTransactionCountByHash") do(data: HexDataStr) -> int:
|
|
|
|
|
## Returns the number of transactions in a block from a block matching the given block hash.
|
|
|
|
|
##
|
|
|
|
|
## data: hash of a block
|
|
|
|
|
## Returns integer of the number of transactions in this block.
|
2018-08-16 17:25:17 +00:00
|
|
|
|
var hashData = strToHash(data.string)
|
2018-08-14 15:53:45 +00:00
|
|
|
|
let body = chain.getBlockBody(hashData)
|
2018-08-20 20:14:30 +00:00
|
|
|
|
if body == nil:
|
|
|
|
|
raise newException(ValueError, "Cannot find hash")
|
2018-08-14 15:53:45 +00:00
|
|
|
|
result = body.transactions.len
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_getBlockTransactionCountByNumber") do(quantityTag: string) -> int:
|
|
|
|
|
## Returns the number of transactions in a block matching the given block number.
|
|
|
|
|
##
|
|
|
|
|
## data: integer of a block number, or the string "earliest", "latest" or "pending", as in the default block parameter.
|
|
|
|
|
## Returns integer of the number of transactions in this block.
|
2018-08-14 15:54:59 +00:00
|
|
|
|
let
|
|
|
|
|
header = chain.headerFromTag(quantityTag)
|
2018-08-22 21:15:26 +00:00
|
|
|
|
accountDb = getAccountDbFromTag(quantityTag)
|
2018-08-15 13:12:49 +00:00
|
|
|
|
body = chain.getBlockBody(header.hash)
|
2018-08-20 20:14:30 +00:00
|
|
|
|
if body == nil:
|
|
|
|
|
raise newException(ValueError, "Cannot find hash")
|
2018-08-14 15:54:59 +00:00
|
|
|
|
result = body.transactions.len
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
2018-08-14 15:55:28 +00:00
|
|
|
|
rpcsrv.rpc("eth_getUncleCountByBlockHash") do(data: HexDataStr) -> int:
|
2018-08-13 18:29:38 +00:00
|
|
|
|
## Returns the number of uncles in a block from a block matching the given block hash.
|
|
|
|
|
##
|
|
|
|
|
## data: hash of a block.
|
|
|
|
|
## Returns integer of the number of uncles in this block.
|
2018-08-16 17:25:17 +00:00
|
|
|
|
var hashData = strToHash(data.string)
|
2018-08-14 15:55:28 +00:00
|
|
|
|
let body = chain.getBlockBody(hashData)
|
2018-08-20 20:14:30 +00:00
|
|
|
|
if body == nil:
|
|
|
|
|
raise newException(ValueError, "Cannot find hash")
|
2018-08-14 15:55:28 +00:00
|
|
|
|
result = body.uncles.len
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
2018-08-14 15:55:57 +00:00
|
|
|
|
rpcsrv.rpc("eth_getUncleCountByBlockNumber") do(quantityTag: string) -> int:
|
2018-08-13 18:29:38 +00:00
|
|
|
|
## Returns the number of uncles in a block from a block matching the given block number.
|
|
|
|
|
##
|
|
|
|
|
## quantityTag: integer of a block number, or the string "latest", "earliest" or "pending", see the default block parameter.
|
|
|
|
|
## Returns integer of uncles in this block.
|
2018-08-14 15:55:57 +00:00
|
|
|
|
let
|
|
|
|
|
header = chain.headerFromTag(quantityTag)
|
2018-08-15 13:12:49 +00:00
|
|
|
|
body = chain.getBlockBody(header.hash)
|
2018-08-20 20:14:30 +00:00
|
|
|
|
if body == nil:
|
|
|
|
|
raise newException(ValueError, "Cannot find hash")
|
2018-08-14 15:55:57 +00:00
|
|
|
|
result = body.uncles.len
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_getCode") do(data: EthAddressStr, quantityTag: string) -> HexDataStr:
|
|
|
|
|
## Returns code at a given address.
|
|
|
|
|
##
|
|
|
|
|
## data: address
|
|
|
|
|
## quantityTag: integer block number, or the string "latest", "earliest" or "pending", see the default block parameter.
|
|
|
|
|
## Returns the code from the given address.
|
2018-08-14 17:22:31 +00:00
|
|
|
|
let
|
2018-08-22 21:15:26 +00:00
|
|
|
|
accountDb = getAccountDbFromTag(quantityTag)
|
2018-08-14 17:22:31 +00:00
|
|
|
|
addrBytes = strToAddress(data.string)
|
2018-08-16 17:25:17 +00:00
|
|
|
|
storage = accountDb.getCode(addrBytes)
|
2018-08-15 13:08:40 +00:00
|
|
|
|
# Easier to return the string manually here rather than expect ByteRange to be marshalled
|
|
|
|
|
result = byteutils.toHex(storage.toOpenArray).HexDataStr
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
2018-08-22 21:15:26 +00:00
|
|
|
|
template sign(privateKey: PrivateKey, message: string): string =
|
|
|
|
|
# TODO: Is message length encoded as bytes or characters?
|
|
|
|
|
let msgData = "\x19Ethereum Signed Message:\n" & $message.len & message
|
|
|
|
|
$signMessage(privateKey, msgData)
|
|
|
|
|
|
2018-08-13 18:29:38 +00:00
|
|
|
|
rpcsrv.rpc("eth_sign") do(data: EthAddressStr, message: HexDataStr) -> HexDataStr:
|
|
|
|
|
## The sign method calculates an Ethereum specific signature with: sign(keccak256("\x19Ethereum Signed Message:\n" + len(message) + message))).
|
|
|
|
|
## By adding a prefix to the message makes the calculated signature recognisable as an Ethereum specific signature.
|
|
|
|
|
## This prevents misuse where a malicious DApp can sign arbitrary data (e.g. transaction) and use the signature to impersonate the victim.
|
|
|
|
|
## Note the address to sign with must be unlocked.
|
|
|
|
|
##
|
|
|
|
|
## data: address.
|
|
|
|
|
## message: message to sign.
|
|
|
|
|
## Returns signature.
|
2018-08-22 21:15:26 +00:00
|
|
|
|
let accountDb = getAccountDb(true)
|
|
|
|
|
var privateKey: PrivateKey # TODO: Get from key store
|
|
|
|
|
result = ("0x" & sign(privateKey, message.string)).HexDataStr
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_sendTransaction") do(obj: EthSend) -> HexDataStr:
|
|
|
|
|
## Creates new message call transaction or a contract creation, if the data field contains code.
|
|
|
|
|
##
|
|
|
|
|
## obj: the transaction object.
|
|
|
|
|
## Returns the transaction hash, or the zero hash if the transaction is not yet available.
|
|
|
|
|
## Note: Use eth_getTransactionReceipt to get the contract address, after the transaction was mined, when you created a contract.
|
|
|
|
|
discard
|
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_sendRawTransaction") do(data: string, quantityTag: int) -> HexDataStr:
|
|
|
|
|
## Creates new message call transaction or a contract creation for signed transactions.
|
|
|
|
|
##
|
|
|
|
|
## data: the signed transaction data.
|
|
|
|
|
## Returns the transaction hash, or the zero hash if the transaction is not yet available.
|
|
|
|
|
## Note: Use eth_getTransactionReceipt to get the contract address, after the transaction was mined, when you created a contract.
|
|
|
|
|
discard
|
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_call") do(call: EthCall, quantityTag: string) -> HexDataStr:
|
|
|
|
|
## Executes a new message call immediately without creating a transaction on the block chain.
|
|
|
|
|
##
|
|
|
|
|
## call: the transaction call object.
|
|
|
|
|
## quantityTag: integer block number, or the string "latest", "earliest" or "pending", see the default block parameter.
|
|
|
|
|
## Returns the return value of executed contract.
|
|
|
|
|
discard
|
|
|
|
|
|
2018-08-23 20:13:05 +00:00
|
|
|
|
rpcsrv.rpc("eth_estimateGas") do(call: EthCall, quantityTag: string) -> GasInt:
|
2018-08-13 18:29:38 +00:00
|
|
|
|
## Generates and returns an estimate of how much gas is necessary to allow the transaction to complete.
|
|
|
|
|
## The transaction will not be added to the blockchain. Note that the estimate may be significantly more than
|
|
|
|
|
## the amount of gas actually used by the transaction, for a variety of reasons including EVM mechanics and node performance.
|
|
|
|
|
##
|
|
|
|
|
## call: the transaction call object.
|
|
|
|
|
## quantityTag: integer block number, or the string "latest", "earliest" or "pending", see the default block parameter.
|
|
|
|
|
## Returns the amount of gas used.
|
|
|
|
|
discard
|
|
|
|
|
|
2018-08-15 13:08:40 +00:00
|
|
|
|
func populateBlockObject(header: BlockHeader, blockBody: BlockBodyRef): BlockObject =
|
|
|
|
|
result.number = new BlockNumber
|
|
|
|
|
result.number[] = header.blockNumber
|
|
|
|
|
result.hash = new Hash256
|
|
|
|
|
result.hash[] = header.hash
|
|
|
|
|
result.parentHash = header.parentHash
|
|
|
|
|
result.nonce = header.nonce.toUint
|
|
|
|
|
|
|
|
|
|
# Calculate hash for all uncle headers
|
|
|
|
|
var
|
|
|
|
|
rawdata = newSeq[byte](blockBody.uncles.len * 32)
|
|
|
|
|
startIdx = 0
|
|
|
|
|
for i in 0 ..< blockBody.uncles.len:
|
|
|
|
|
rawData[startIdx .. startIdx + 32] = blockBody.uncles[i].hash.data
|
|
|
|
|
startIdx += 32
|
|
|
|
|
result.sha3Uncles = keccak256.digest(rawData)
|
|
|
|
|
|
2018-08-23 20:13:05 +00:00
|
|
|
|
result.logsBloom = new BloomFilter
|
|
|
|
|
result.logsBloom[] = header.bloom
|
2018-08-15 13:08:40 +00:00
|
|
|
|
result.transactionsRoot = header.txRoot
|
|
|
|
|
result.stateRoot = header.stateRoot
|
|
|
|
|
result.receiptsRoot = header.receiptRoot
|
|
|
|
|
result.miner = ZERO_ADDRESS # TODO: Get miner address
|
|
|
|
|
result.difficulty = header.difficulty
|
|
|
|
|
result.totalDifficulty = header.difficulty # TODO: Calculate
|
|
|
|
|
result.extraData = header.extraData
|
|
|
|
|
result.size = 0 # TODO: Calculate block size
|
|
|
|
|
result.gasLimit = header.gasLimit
|
|
|
|
|
result.gasUsed = header.gasUsed
|
|
|
|
|
result.timestamp = header.timeStamp
|
|
|
|
|
result.transactions = blockBody.transactions
|
2018-08-20 19:52:09 +00:00
|
|
|
|
result.uncles = @[]
|
|
|
|
|
for i in 0 ..< blockBody.uncles.len:
|
|
|
|
|
result.uncles[i] = blockBody.uncles[i].hash
|
2018-08-15 13:08:40 +00:00
|
|
|
|
|
2018-08-13 18:29:38 +00:00
|
|
|
|
rpcsrv.rpc("eth_getBlockByHash") do(data: HexDataStr, fullTransactions: bool) -> BlockObject:
|
|
|
|
|
## Returns information about a block by hash.
|
|
|
|
|
##
|
|
|
|
|
## data: Hash of a block.
|
|
|
|
|
## fullTransactions: If true it returns the full transaction objects, if false only the hashes of the transactions.
|
|
|
|
|
## Returns BlockObject or nil when no block was found.
|
2018-08-15 13:08:40 +00:00
|
|
|
|
let
|
2018-08-16 17:25:17 +00:00
|
|
|
|
h = data.string.strToHash
|
|
|
|
|
header = chain.getBlockHeader(h)
|
|
|
|
|
body = chain.getBlockBody(h)
|
2018-08-20 20:14:30 +00:00
|
|
|
|
if body == nil:
|
|
|
|
|
raise newException(ValueError, "Cannot find hash")
|
2018-08-15 13:08:40 +00:00
|
|
|
|
populateBlockObject(header, body)
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_getBlockByNumber") do(quantityTag: string, fullTransactions: bool) -> BlockObject:
|
|
|
|
|
## Returns information about a block by block number.
|
|
|
|
|
##
|
|
|
|
|
## quantityTag: integer of a block number, or the string "earliest", "latest" or "pending", as in the default block parameter.
|
|
|
|
|
## fullTransactions: If true it returns the full transaction objects, if false only the hashes of the transactions.
|
|
|
|
|
## Returns BlockObject or nil when no block was found.
|
2018-08-15 13:12:49 +00:00
|
|
|
|
let
|
|
|
|
|
header = chain.headerFromTag(quantityTag)
|
|
|
|
|
body = chain.getBlockBody(header.hash)
|
2018-08-20 20:14:30 +00:00
|
|
|
|
if body == nil:
|
|
|
|
|
raise newException(ValueError, "Cannot find hash")
|
2018-08-15 13:12:49 +00:00
|
|
|
|
populateBlockObject(header, body)
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
2018-08-23 21:05:38 +00:00
|
|
|
|
proc populateTransactionObject(transaction: Transaction, txIndex: int, blockHeader: BlockHeader, blockHash: Hash256): TransactionObject =
|
|
|
|
|
let
|
|
|
|
|
vmState = newBaseVMState(blockHeader, chain)
|
|
|
|
|
accountDb = vmState.chaindb.getStateDb(blockHash, true)
|
2018-08-23 21:45:14 +00:00
|
|
|
|
address = transaction.getSender()
|
2018-08-23 21:05:38 +00:00
|
|
|
|
txCount = accountDb.getNonce(address)
|
|
|
|
|
txHash = transaction.rlpHash
|
|
|
|
|
accountGas = accountDb.balance(address)
|
|
|
|
|
|
2018-08-17 18:53:47 +00:00
|
|
|
|
result.hash = txHash
|
|
|
|
|
result.nonce = txCount
|
|
|
|
|
result.blockHash = new Hash256
|
2018-08-23 21:05:38 +00:00
|
|
|
|
result.blockHash[] = blockHash
|
2018-08-17 18:53:47 +00:00
|
|
|
|
result.blockNumber = new BlockNumber
|
|
|
|
|
result.blockNumber[] = blockHeader.blockNumber
|
|
|
|
|
result.transactionIndex = new int64
|
|
|
|
|
result.transactionIndex[] = txIndex
|
2018-08-23 21:45:14 +00:00
|
|
|
|
result.source = transaction.getSender()
|
2018-08-17 18:53:47 +00:00
|
|
|
|
result.to = new EthAddress
|
|
|
|
|
result.to[] = transaction.to
|
|
|
|
|
result.value = transaction.value
|
|
|
|
|
result.gasPrice = transaction.gasPrice
|
2018-08-23 21:05:38 +00:00
|
|
|
|
result.gas = accountGas
|
2018-08-17 18:53:47 +00:00
|
|
|
|
result.input = transaction.payload
|
2018-08-23 21:05:38 +00:00
|
|
|
|
|
2018-08-13 18:29:38 +00:00
|
|
|
|
rpcsrv.rpc("eth_getTransactionByHash") do(data: HexDataStr) -> TransactionObject:
|
|
|
|
|
## Returns the information about a transaction requested by transaction hash.
|
|
|
|
|
##
|
|
|
|
|
## data: hash of a transaction.
|
|
|
|
|
## Returns requested transaction information.
|
2018-08-17 18:53:47 +00:00
|
|
|
|
let
|
|
|
|
|
h = data.string.strToHash()
|
|
|
|
|
txDetails = chain.getTransactionKey(h)
|
|
|
|
|
header = chain.getBlockHeader(txDetails.blockNumber)
|
|
|
|
|
blockHash = chain.getBlockHash(txDetails.blockNumber)
|
|
|
|
|
body = chain.getBlockBody(blockHash)
|
2018-08-20 20:14:30 +00:00
|
|
|
|
if body == nil:
|
|
|
|
|
raise newException(ValueError, "Cannot find hash")
|
2018-08-23 21:05:38 +00:00
|
|
|
|
let transaction = body.transactions[txDetails.index]
|
|
|
|
|
populateTransactionObject(transaction, txDetails.index, header, blockHash)
|
2018-07-31 17:18:43 +00:00
|
|
|
|
|
2018-08-13 18:29:38 +00:00
|
|
|
|
rpcsrv.rpc("eth_getTransactionByBlockHashAndIndex") do(data: HexDataStr, quantity: int) -> TransactionObject:
|
|
|
|
|
## Returns information about a transaction by block hash and transaction index position.
|
|
|
|
|
##
|
|
|
|
|
## data: hash of a block.
|
|
|
|
|
## quantity: integer of the transaction index position.
|
|
|
|
|
## Returns requested transaction information.
|
2018-08-17 19:03:30 +00:00
|
|
|
|
let
|
|
|
|
|
blockHash = data.string.strToHash()
|
|
|
|
|
body = chain.getBlockBody(blockHash)
|
2018-08-20 20:14:30 +00:00
|
|
|
|
if body == nil:
|
|
|
|
|
raise newException(ValueError, "Cannot find hash")
|
|
|
|
|
let
|
2018-08-17 19:03:30 +00:00
|
|
|
|
header = chain.getBlockHeader(blockHash)
|
|
|
|
|
transaction = body.transactions[quantity]
|
2018-08-23 21:05:38 +00:00
|
|
|
|
populateTransactionObject(transaction, quantity, header, blockHash)
|
2018-08-17 19:03:30 +00:00
|
|
|
|
|
2018-08-13 18:29:38 +00:00
|
|
|
|
rpcsrv.rpc("eth_getTransactionByBlockNumberAndIndex") do(quantityTag: string, quantity: int) -> TransactionObject:
|
|
|
|
|
## Returns information about a transaction by block number and transaction index position.
|
|
|
|
|
##
|
|
|
|
|
## quantityTag: a block number, or the string "earliest", "latest" or "pending", as in the default block parameter.
|
|
|
|
|
## quantity: the transaction index position.
|
2018-08-17 19:06:43 +00:00
|
|
|
|
let
|
|
|
|
|
header = chain.headerFromTag(quantityTag)
|
|
|
|
|
blockHash = header.hash
|
|
|
|
|
body = chain.getBlockBody(blockHash)
|
2018-08-20 20:14:30 +00:00
|
|
|
|
if body == nil:
|
|
|
|
|
raise newException(ValueError, "Cannot find hash")
|
|
|
|
|
let
|
2018-08-17 19:06:43 +00:00
|
|
|
|
transaction = body.transactions[quantity]
|
2018-08-23 21:05:38 +00:00
|
|
|
|
populateTransactionObject(transaction, quantity, header, blockHash)
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
2018-08-22 17:45:31 +00:00
|
|
|
|
proc populateReceipt(receipt: Receipt, cumulativeGas: GasInt, transaction: Transaction, txIndex: int, blockHeader: BlockHeader): ReceiptObject =
|
2018-08-20 19:42:40 +00:00
|
|
|
|
result.transactionHash = transaction.rlpHash
|
|
|
|
|
result.transactionIndex = txIndex
|
|
|
|
|
result.blockHash = blockHeader.hash
|
|
|
|
|
result.blockNumber = blockHeader.blockNumber
|
2018-08-23 21:45:14 +00:00
|
|
|
|
result.sender = transaction.getSender()
|
2018-08-20 19:42:40 +00:00
|
|
|
|
result.to = new EthAddress
|
|
|
|
|
result.to[] = transaction.to
|
2018-08-22 17:45:31 +00:00
|
|
|
|
result.cumulativeGasUsed = cumulativeGas
|
|
|
|
|
result.gasUsed = receipt.gasUsed
|
2018-08-20 19:42:40 +00:00
|
|
|
|
# TODO: Get contract address if the transaction was a contract creation.
|
|
|
|
|
result.contractAddress = nil
|
2018-08-22 17:45:31 +00:00
|
|
|
|
result.logs = receipt.logs
|
2018-08-20 19:42:40 +00:00
|
|
|
|
result.logsBloom = blockHeader.bloom
|
|
|
|
|
# post-transaction stateroot (pre Byzantium).
|
|
|
|
|
result.root = blockHeader.stateRoot
|
2018-08-22 21:15:26 +00:00
|
|
|
|
# TODO: Respond to success/failure
|
2018-08-20 19:42:40 +00:00
|
|
|
|
# 1 = success, 0 = failure.
|
|
|
|
|
result.status = 1
|
|
|
|
|
|
2018-08-13 18:29:38 +00:00
|
|
|
|
rpcsrv.rpc("eth_getTransactionReceipt") do(data: HexDataStr) -> ReceiptObject:
|
|
|
|
|
## Returns the receipt of a transaction by transaction hash.
|
|
|
|
|
##
|
|
|
|
|
## data: hash of a transaction.
|
|
|
|
|
## Returns transaction receipt.
|
2018-08-20 19:42:40 +00:00
|
|
|
|
let
|
|
|
|
|
h = data.string.strToHash()
|
|
|
|
|
txDetails = chain.getTransactionKey(h)
|
|
|
|
|
header = chain.getBlockHeader(txDetails.blockNumber)
|
|
|
|
|
body = chain.getBlockBody(h)
|
2018-08-20 20:14:30 +00:00
|
|
|
|
if body == nil:
|
|
|
|
|
raise newException(ValueError, "Cannot find hash")
|
2018-08-22 17:45:31 +00:00
|
|
|
|
var
|
|
|
|
|
idx = 0
|
|
|
|
|
cumulativeGas: GasInt
|
2018-08-20 19:42:40 +00:00
|
|
|
|
for receipt in chain.getReceipts(header, Receipt):
|
2018-08-22 17:45:31 +00:00
|
|
|
|
cumulativeGas += receipt.gasUsed
|
2018-08-20 19:42:40 +00:00
|
|
|
|
if idx == txDetails.index:
|
2018-08-22 17:45:31 +00:00
|
|
|
|
return populateReceipt(receipt, cumulativeGas, body.transactions[txDetails.index], txDetails.index, header)
|
2018-08-20 19:42:40 +00:00
|
|
|
|
idx.inc
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
2018-08-20 19:52:09 +00:00
|
|
|
|
rpcsrv.rpc("eth_getUncleByBlockHashAndIndex") do(data: HexDataStr, quantity: int) -> BlockObject:
|
2018-08-13 18:29:38 +00:00
|
|
|
|
## Returns information about a uncle of a block by hash and uncle index position.
|
|
|
|
|
##
|
2018-08-20 19:52:09 +00:00
|
|
|
|
## data: hash of block.
|
2018-08-13 18:29:38 +00:00
|
|
|
|
## quantity: the uncle's index position.
|
|
|
|
|
## Returns BlockObject or nil when no block was found.
|
2018-08-20 19:52:09 +00:00
|
|
|
|
let
|
|
|
|
|
blockHash = data.string.strToHash()
|
|
|
|
|
body = chain.getBlockBody(blockHash)
|
2018-08-20 20:14:30 +00:00
|
|
|
|
if body == nil:
|
|
|
|
|
raise newException(ValueError, "Cannot find hash")
|
|
|
|
|
if quantity < 0 or quantity >= body.uncles.len:
|
|
|
|
|
raise newException(ValueError, "Uncle index out of range")
|
|
|
|
|
let uncle = body.uncles[quantity]
|
2018-08-20 19:52:09 +00:00
|
|
|
|
result = populateBlockObject(uncle, body)
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
2018-08-20 20:06:26 +00:00
|
|
|
|
rpcsrv.rpc("eth_getUncleByBlockNumberAndIndex") do(quantityTag: string, quantity: int) -> BlockObject:
|
2018-08-13 18:29:38 +00:00
|
|
|
|
# Returns information about a uncle of a block by number and uncle index position.
|
|
|
|
|
##
|
|
|
|
|
## quantityTag: a block number, or the string "earliest", "latest" or "pending", as in the default block parameter.
|
|
|
|
|
## quantity: the uncle's index position.
|
|
|
|
|
## Returns BlockObject or nil when no block was found.
|
2018-08-20 20:06:26 +00:00
|
|
|
|
let
|
|
|
|
|
header = chain.headerFromTag(quantityTag)
|
|
|
|
|
body = chain.getBlockBody(header.hash)
|
2018-08-20 20:14:30 +00:00
|
|
|
|
if body == nil:
|
|
|
|
|
raise newException(ValueError, "Cannot find hash")
|
|
|
|
|
if quantity < 0 or quantity >= body.uncles.len:
|
|
|
|
|
raise newException(ValueError, "Uncle index out of range")
|
|
|
|
|
let uncle = body.uncles[quantity]
|
2018-08-20 20:06:26 +00:00
|
|
|
|
result = populateBlockObject(uncle, body)
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_newFilter") do(filterOptions: FilterOptions) -> int:
|
|
|
|
|
## Creates a filter object, based on filter options, to notify when the state changes (logs).
|
|
|
|
|
## To check if the state has changed, call eth_getFilterChanges.
|
|
|
|
|
## Topics are order-dependent. A transaction with a log with topics [A, B] will be matched by the following topic filters:
|
|
|
|
|
## [] "anything"
|
|
|
|
|
## [A] "A in first position (and anything after)"
|
|
|
|
|
## [null, B] "anything in first position AND B in second position (and anything after)"
|
|
|
|
|
## [A, B] "A in first position AND B in second position (and anything after)"
|
|
|
|
|
## [[A, B], [A, B]] "(A OR B) in first position AND (A OR B) in second position (and anything after)"
|
|
|
|
|
##
|
|
|
|
|
## filterOptions: settings for this filter.
|
|
|
|
|
## Returns integer filter id.
|
|
|
|
|
discard
|
2018-07-31 17:18:43 +00:00
|
|
|
|
|
2018-08-13 18:29:38 +00:00
|
|
|
|
rpcsrv.rpc("eth_newBlockFilter") do() -> int:
|
|
|
|
|
## Creates a filter in the node, to notify when a new block arrives.
|
|
|
|
|
## To check if the state has changed, call eth_getFilterChanges.
|
|
|
|
|
##
|
|
|
|
|
## Returns integer filter id.
|
|
|
|
|
discard
|
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_newPendingTransactionFilter") do() -> int:
|
|
|
|
|
## Creates a filter in the node, to notify when a new block arrives.
|
|
|
|
|
## To check if the state has changed, call eth_getFilterChanges.
|
|
|
|
|
##
|
|
|
|
|
## Returns integer filter id.
|
|
|
|
|
discard
|
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_uninstallFilter") do(filterId: int) -> bool:
|
|
|
|
|
## Uninstalls a filter with given id. Should always be called when watch is no longer needed.
|
|
|
|
|
## Additonally Filters timeout when they aren't requested with eth_getFilterChanges for a period of time.
|
|
|
|
|
##
|
|
|
|
|
## filterId: The filter id.
|
|
|
|
|
## Returns true if the filter was successfully uninstalled, otherwise false.
|
|
|
|
|
discard
|
|
|
|
|
|
2018-08-22 17:45:31 +00:00
|
|
|
|
rpcsrv.rpc("eth_getFilterChanges") do(filterId: int) -> seq[FilterLog]:
|
2018-08-13 18:29:38 +00:00
|
|
|
|
## Polling method for a filter, which returns an list of logs which occurred since last poll.
|
|
|
|
|
##
|
|
|
|
|
## filterId: the filter id.
|
|
|
|
|
result = @[]
|
|
|
|
|
|
2018-08-22 17:45:31 +00:00
|
|
|
|
rpcsrv.rpc("eth_getFilterLogs") do(filterId: int) -> seq[FilterLog]:
|
2018-08-13 18:29:38 +00:00
|
|
|
|
## filterId: the filter id.
|
|
|
|
|
## Returns a list of all logs matching filter with given id.
|
|
|
|
|
result = @[]
|
|
|
|
|
|
2018-08-22 17:45:31 +00:00
|
|
|
|
rpcsrv.rpc("eth_getLogs") do(filterOptions: FilterOptions) -> seq[FilterLog]:
|
2018-08-13 18:29:38 +00:00
|
|
|
|
## filterOptions: settings for this filter.
|
|
|
|
|
## Returns a list of all logs matching a given filter object.
|
|
|
|
|
result = @[]
|
|
|
|
|
|
2018-08-22 17:45:31 +00:00
|
|
|
|
rpcsrv.rpc("eth_getWork") do() -> array[3, UInt256]:
|
2018-08-13 18:29:38 +00:00
|
|
|
|
## Returns the hash of the current block, the seedHash, and the boundary condition to be met ("target").
|
|
|
|
|
## Returned list has the following properties:
|
|
|
|
|
## DATA, 32 Bytes - current block header pow-hash.
|
|
|
|
|
## DATA, 32 Bytes - the seed hash used for the DAG.
|
|
|
|
|
## DATA, 32 Bytes - the boundary condition ("target"), 2^256 / difficulty.
|
2018-08-22 17:45:31 +00:00
|
|
|
|
discard
|
2018-08-13 18:29:38 +00:00
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_submitWork") do(nonce: int64, powHash: HexDataStr, mixDigest: HexDataStr) -> bool:
|
|
|
|
|
## Used for submitting a proof-of-work solution.
|
|
|
|
|
##
|
|
|
|
|
## nonce: the nonce found.
|
|
|
|
|
## headerPow: the header's pow-hash.
|
|
|
|
|
## mixDigest: the mix digest.
|
|
|
|
|
## Returns true if the provided solution is valid, otherwise false.
|
|
|
|
|
discard
|
|
|
|
|
|
|
|
|
|
rpcsrv.rpc("eth_submitHashrate") do(hashRate: HexDataStr, id: HexDataStr) -> bool:
|
|
|
|
|
## Used for submitting mining hashrate.
|
|
|
|
|
##
|
|
|
|
|
## hashRate: a hexadecimal string representation (32 bytes) of the hash rate.
|
|
|
|
|
## id: a random hexadecimal(32 bytes) ID identifying the client.
|
|
|
|
|
## Returns true if submitting went through succesfully and false otherwise.
|
|
|
|
|
discard
|
|
|
|
|
|
|
|
|
|
|