status-im
/
nim-json-rpc
mirror of https://github.com/status-im/nim-json-rpc.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Remove shared server

This commit is contained in:
coffeepots 2018-06-05 10:43:46 +01:00
parent f8d0050dff
commit 1ea23b4df2
2 changed files with 367 additions and 374 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
eth-rpc/server/servertypes.nim
View File

@ -27,12 +27,6 @@ proc newRpcServer*(address = "localhost", port: Port = Port(8545)): RpcServer =
procs: newTable[string, RpcProc]() procs: newTable[string, RpcProc]()
) )
var sharedServer: RpcServer
proc sharedRpcServer*(): RpcServer =
if sharedServer.isNil: sharedServer = newRpcServer("")
result = sharedServer
proc `$`*(port: Port): string = $int(port) proc `$`*(port: Port): string = $int(port)
proc makeProcName(s: string): string = proc makeProcName(s: string): string =

119
tests/ethprocs.nim
View File

@ -26,13 +26,12 @@ import ../rpcserver, nimcrypto, json, stint, strutils, ethtypes, stintjson
specified once without invoking `reset`. specified once without invoking `reset`.
]# ]#
var server = sharedRpcServer() proc addEthRpcs*(server: RpcServer) =
server.rpc("web3_clientVersion") do() -> string:
server.rpc("web3_clientVersion") do() -> string:
## Returns the current client version. ## Returns the current client version.
result = "Nimbus-RPC-Test" result = "Nimbus-RPC-Test"
server.rpc("web3_sha3") do(data: string) -> string: server.rpc("web3_sha3") do(data: string) -> string:
## Returns Keccak-256 (not the standardized SHA3-256) of the given data. ## Returns Keccak-256 (not the standardized SHA3-256) of the given data.
## ##
## data: the data to convert into a SHA3 hash. ## data: the data to convert into a SHA3 hash.
@ -46,7 +45,7 @@ server.rpc("web3_sha3") do(data: string) -> string:
# data will have 0x prefix # data will have 0x prefix
result = "0x" & $keccak_256.digest(rawData) result = "0x" & $keccak_256.digest(rawData)
server.rpc("net_version") do() -> string: server.rpc("net_version") do() -> string:
## Returns string of the current network id: ## Returns string of the current network id:
## "1": Ethereum Mainnet ## "1": Ethereum Mainnet
## "2": Morden Testnet (deprecated) ## "2": Morden Testnet (deprecated)
@ -59,19 +58,19 @@ server.rpc("net_version") do() -> string:
]# ]#
result = "" result = ""
server.rpc("net_listening") do() -> bool: server.rpc("net_listening") do() -> bool:
## Returns boolean true when listening, otherwise false. ## Returns boolean true when listening, otherwise false.
result = true result = true
server.rpc("net_peerCount") do() -> int: server.rpc("net_peerCount") do() -> int:
## Returns integer of the number of connected peers. ## Returns integer of the number of connected peers.
discard discard
server.rpc("eth_protocolVersion") do() -> string: server.rpc("eth_protocolVersion") do() -> string:
## Returns string of the current ethereum protocol version. ## Returns string of the current ethereum protocol version.
discard discard
server.rpc("eth_syncing") do() -> JsonNode: server.rpc("eth_syncing") do() -> JsonNode:
## Returns SyncObject or false when not syncing. ## Returns SyncObject or false when not syncing.
var var
res: JsonNode res: JsonNode
@ -80,33 +79,33 @@ server.rpc("eth_syncing") do() -> JsonNode:
else: res = newJBool(false) else: res = newJBool(false)
result = res result = res
server.rpc("eth_coinbase") do() -> string: server.rpc("eth_coinbase") do() -> string:
## Returns the current coinbase address. ## Returns the current coinbase address.
result = "" result = ""
server.rpc("eth_mining") do() -> bool: server.rpc("eth_mining") do() -> bool:
## Returns true of the client is mining, otherwise false. ## Returns true of the client is mining, otherwise false.
discard discard
server.rpc("eth_hashrate") do() -> int: server.rpc("eth_hashrate") do() -> int:
## Returns the number of hashes per second that the node is mining with. ## Returns the number of hashes per second that the node is mining with.
discard discard
server.rpc("eth_gasPrice") do() -> int64: server.rpc("eth_gasPrice") do() -> int64:
## Returns an integer of the current gas price in wei. ## Returns an integer of the current gas price in wei.
discard discard
server.rpc("eth_accounts") do() -> seq[array[20, byte]]: server.rpc("eth_accounts") do() -> seq[array[20, byte]]:
## Returns a list of addresses owned by client. ## Returns a list of addresses owned by client.
# TODO: this might be easier to use as seq[string] # TODO: this might be easier to use as seq[string]
# This is what's expected: "result": ["0x407d73d8a49eeb85d32cf465507dd71d507100c1"] # This is what's expected: "result": ["0x407d73d8a49eeb85d32cf465507dd71d507100c1"]
discard discard
server.rpc("eth_blockNumber") do() -> int: server.rpc("eth_blockNumber") do() -> int:
## Returns integer of the current block number the client is on. ## Returns integer of the current block number the client is on.
discard discard
server.rpc("eth_getBalance") do(data: array[20, byte], quantityTag: string) -> int: server.rpc("eth_getBalance") do(data: array[20, byte], quantityTag: string) -> int:
## Returns the balance of the account of given address. ## Returns the balance of the account of given address.
## ##
## data: address to check for balance. ## data: address to check for balance.
@ -114,7 +113,7 @@ server.rpc("eth_getBalance") do(data: array[20, byte], quantityTag: string) -> i
## Returns integer of the current balance in wei. ## Returns integer of the current balance in wei.
discard discard
server.rpc("eth_getStorageAt") do(data: array[20, byte], quantity: int, quantityTag: string) -> seq[byte]: server.rpc("eth_getStorageAt") do(data: array[20, byte], quantity: int, quantityTag: string) -> seq[byte]:
## Returns the value from a storage position at a given address. ## Returns the value from a storage position at a given address.
## ##
## data: address of the storage. ## data: address of the storage.
@ -125,7 +124,7 @@ server.rpc("eth_getStorageAt") do(data: array[20, byte], quantity: int, quantity
# For more details, see: https://github.com/ethereum/wiki/wiki/JSON-RPC#eth_getstorageat # For more details, see: https://github.com/ethereum/wiki/wiki/JSON-RPC#eth_getstorageat
result = @[] result = @[]
server.rpc("eth_getTransactionCount") do(data: array[20, byte], quantityTag: string): server.rpc("eth_getTransactionCount") do(data: array[20, byte], quantityTag: string):
## Returns the number of transactions sent from an address. ## Returns the number of transactions sent from an address.
## ##
## data: address. ## data: address.
@ -133,35 +132,35 @@ server.rpc("eth_getTransactionCount") do(data: array[20, byte], quantityTag: str
## Returns integer of the number of transactions send from this address. ## Returns integer of the number of transactions send from this address.
discard discard
server.rpc("eth_getBlockTransactionCountByHash") do(data: array[32, byte]) -> int: server.rpc("eth_getBlockTransactionCountByHash") do(data: array[32, byte]) -> int:
## Returns the number of transactions in a block from a block matching the given block hash. ## Returns the number of transactions in a block from a block matching the given block hash.
## ##
## data: hash of a block ## data: hash of a block
## Returns integer of the number of transactions in this block. ## Returns integer of the number of transactions in this block.
discard discard
server.rpc("eth_getBlockTransactionCountByNumber") do(quantityTag: string) -> int: server.rpc("eth_getBlockTransactionCountByNumber") do(quantityTag: string) -> int:
## Returns the number of transactions in a block matching the given block number. ## 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. ## 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. ## Returns integer of the number of transactions in this block.
discard discard
server.rpc("eth_getUncleCountByBlockHash") do(data: array[32, byte]): server.rpc("eth_getUncleCountByBlockHash") do(data: array[32, byte]):
## Returns the number of uncles in a block from a block matching the given block hash. ## Returns the number of uncles in a block from a block matching the given block hash.
## ##
## data: hash of a block. ## data: hash of a block.
## Returns integer of the number of uncles in this block. ## Returns integer of the number of uncles in this block.
discard discard
server.rpc("eth_getUncleCountByBlockNumber") do(quantityTag: string): server.rpc("eth_getUncleCountByBlockNumber") do(quantityTag: string):
## Returns the number of uncles in a block from a block matching the given block number. ## 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. ## 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. ## Returns integer of uncles in this block.
discard discard
server.rpc("eth_getCode") do(data: array[20, byte], quantityTag: string) -> seq[byte]: server.rpc("eth_getCode") do(data: array[20, byte], quantityTag: string) -> seq[byte]:
## Returns code at a given address. ## Returns code at a given address.
## ##
## data: address ## data: address
@ -169,7 +168,7 @@ server.rpc("eth_getCode") do(data: array[20, byte], quantityTag: string) -> seq[
## Returns the code from the given address. ## Returns the code from the given address.
result = @[] result = @[]
server.rpc("eth_sign") do(data: array[20, byte], message: seq[byte]) -> seq[byte]: server.rpc("eth_sign") do(data: array[20, byte], message: seq[byte]) -> seq[byte]:
## The sign method calculates an Ethereum specific signature with: sign(keccak256("\x19Ethereum Signed Message:\n" + len(message) + message))). ## 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. ## 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. ## This prevents misuse where a malicious DApp can sign arbitrary data (e.g. transaction) and use the signature to impersonate the victim.
@ -180,7 +179,7 @@ server.rpc("eth_sign") do(data: array[20, byte], message: seq[byte]) -> seq[byte
## Returns signature. ## Returns signature.
discard discard
server.rpc("eth_sendTransaction") do(obj: EthSend) -> UInt256: server.rpc("eth_sendTransaction") do(obj: EthSend) -> UInt256:
## Creates new message call transaction or a contract creation, if the data field contains code. ## Creates new message call transaction or a contract creation, if the data field contains code.
## ##
## obj: the transaction object. ## obj: the transaction object.
@ -188,7 +187,7 @@ server.rpc("eth_sendTransaction") do(obj: EthSend) -> UInt256:
## Note: Use eth_getTransactionReceipt to get the contract address, after the transaction was mined, when you created a contract. ## Note: Use eth_getTransactionReceipt to get the contract address, after the transaction was mined, when you created a contract.
discard discard
server.rpc("eth_sendRawTransaction") do(data: string, quantityTag: int) -> UInt256: # TODO: string or array of byte? server.rpc("eth_sendRawTransaction") do(data: string, quantityTag: int) -> UInt256: # TODO: string or array of byte?
## Creates new message call transaction or a contract creation for signed transactions. ## Creates new message call transaction or a contract creation for signed transactions.
## ##
## data: the signed transaction data. ## data: the signed transaction data.
@ -196,7 +195,7 @@ server.rpc("eth_sendRawTransaction") do(data: string, quantityTag: int) -> UInt2
## Note: Use eth_getTransactionReceipt to get the contract address, after the transaction was mined, when you created a contract. ## Note: Use eth_getTransactionReceipt to get the contract address, after the transaction was mined, when you created a contract.
discard discard
server.rpc("eth_call") do(call: EthCall, quantityTag: string) -> UInt256: server.rpc("eth_call") do(call: EthCall, quantityTag: string) -> UInt256:
## Executes a new message call immediately without creating a transaction on the block chain. ## Executes a new message call immediately without creating a transaction on the block chain.
## ##
## call: the transaction call object. ## call: the transaction call object.
@ -205,7 +204,7 @@ server.rpc("eth_call") do(call: EthCall, quantityTag: string) -> UInt256:
# TODO: Should return value be UInt256 or seq[byte] or string? # TODO: Should return value be UInt256 or seq[byte] or string?
discard discard
server.rpc("eth_estimateGas") do(call: EthCall, quantityTag: string) -> UInt256: # TODO: Int or U/Int256? server.rpc("eth_estimateGas") do(call: EthCall, quantityTag: string) -> UInt256: # TODO: Int or U/Int256?
## Generates and returns an estimate of how much gas is necessary to allow the transaction to complete. ## 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 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. ## the amount of gas actually used by the transaction, for a variety of reasons including EVM mechanics and node performance.
@ -215,7 +214,7 @@ server.rpc("eth_estimateGas") do(call: EthCall, quantityTag: string) -> UInt256:
## Returns the amount of gas used. ## Returns the amount of gas used.
discard discard
server.rpc("eth_getBlockByHash") do(data: array[32, byte], fullTransactions: bool) -> BlockObject: server.rpc("eth_getBlockByHash") do(data: array[32, byte], fullTransactions: bool) -> BlockObject:
## Returns information about a block by hash. ## Returns information about a block by hash.
## ##
## data: Hash of a block. ## data: Hash of a block.
@ -223,7 +222,7 @@ server.rpc("eth_getBlockByHash") do(data: array[32, byte], fullTransactions: boo
## Returns BlockObject or nil when no block was found. ## Returns BlockObject or nil when no block was found.
discard discard
server.rpc("eth_getBlockByNumber") do(quantityTag: string, fullTransactions: bool) -> BlockObject: server.rpc("eth_getBlockByNumber") do(quantityTag: string, fullTransactions: bool) -> BlockObject:
## Returns information about a block by block number. ## 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. ## quantityTag: integer of a block number, or the string "earliest", "latest" or "pending", as in the default block parameter.
@ -231,14 +230,14 @@ server.rpc("eth_getBlockByNumber") do(quantityTag: string, fullTransactions: boo
## Returns BlockObject or nil when no block was found. ## Returns BlockObject or nil when no block was found.
discard discard
server.rpc("eth_getTransactionByHash") do(data: Uint256) -> TransactionObject: server.rpc("eth_getTransactionByHash") do(data: Uint256) -> TransactionObject:
## Returns the information about a transaction requested by transaction hash. ## Returns the information about a transaction requested by transaction hash.
## ##
## data: hash of a transaction. ## data: hash of a transaction.
## Returns requested transaction information. ## Returns requested transaction information.
discard discard
server.rpc("eth_getTransactionByBlockHashAndIndex") do(data: UInt256, quantity: int) -> TransactionObject: server.rpc("eth_getTransactionByBlockHashAndIndex") do(data: UInt256, quantity: int) -> TransactionObject:
## Returns information about a transaction by block hash and transaction index position. ## Returns information about a transaction by block hash and transaction index position.
## ##
## data: hash of a block. ## data: hash of a block.
@ -246,21 +245,21 @@ server.rpc("eth_getTransactionByBlockHashAndIndex") do(data: UInt256, quantity:
## Returns requested transaction information. ## Returns requested transaction information.
discard discard
server.rpc("eth_getTransactionByBlockNumberAndIndex") do(quantityTag: string, quantity: int) -> TransactionObject: server.rpc("eth_getTransactionByBlockNumberAndIndex") do(quantityTag: string, quantity: int) -> TransactionObject:
## Returns information about a transaction by block number and transaction index position. ## 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. ## quantityTag: a block number, or the string "earliest", "latest" or "pending", as in the default block parameter.
## quantity: the transaction index position. ## quantity: the transaction index position.
discard discard
server.rpc("eth_getTransactionReceipt") do(data: UInt256) -> ReceiptObject: server.rpc("eth_getTransactionReceipt") do(data: UInt256) -> ReceiptObject:
## Returns the receipt of a transaction by transaction hash. ## Returns the receipt of a transaction by transaction hash.
## ##
## data: hash of a transaction. ## data: hash of a transaction.
## Returns transaction receipt. ## Returns transaction receipt.
discard discard
server.rpc("eth_getUncleByBlockHashAndIndex") do(data: UInt256, quantity: int64) -> BlockObject: server.rpc("eth_getUncleByBlockHashAndIndex") do(data: UInt256, quantity: int64) -> BlockObject:
## Returns information about a uncle of a block by hash and uncle index position. ## Returns information about a uncle of a block by hash and uncle index position.
## ##
## data: hash a block. ## data: hash a block.
@ -268,7 +267,7 @@ server.rpc("eth_getUncleByBlockHashAndIndex") do(data: UInt256, quantity: int64)
## Returns BlockObject or nil when no block was found. ## Returns BlockObject or nil when no block was found.
discard discard
server.rpc("eth_getUncleByBlockNumberAndIndex") do(quantityTag: string, quantity: int64) -> BlockObject: server.rpc("eth_getUncleByBlockNumberAndIndex") do(quantityTag: string, quantity: int64) -> BlockObject:
# Returns information about a uncle of a block by number and uncle index position. # 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. ## quantityTag: a block number, or the string "earliest", "latest" or "pending", as in the default block parameter.
@ -276,34 +275,34 @@ server.rpc("eth_getUncleByBlockNumberAndIndex") do(quantityTag: string, quantity
## Returns BlockObject or nil when no block was found. ## Returns BlockObject or nil when no block was found.
discard discard
server.rpc("eth_getCompilers") do() -> seq[string]: server.rpc("eth_getCompilers") do() -> seq[string]:
## Returns a list of available compilers in the client. ## Returns a list of available compilers in the client.
## ##
## Returns a list of available compilers. ## Returns a list of available compilers.
result = @[] result = @[]
server.rpc("eth_compileSolidity") do(sourceCode: string) -> seq[byte]: server.rpc("eth_compileSolidity") do(sourceCode: string) -> seq[byte]:
## Returns compiled solidity code. ## Returns compiled solidity code.
## ##
## sourceCode: source code as string. ## sourceCode: source code as string.
## Returns compiles source code. ## Returns compiles source code.
result = @[] result = @[]
server.rpc("eth_compileLLL") do(sourceCode: string) -> seq[byte]: server.rpc("eth_compileLLL") do(sourceCode: string) -> seq[byte]:
## Returns compiled LLL code. ## Returns compiled LLL code.
## ##
## sourceCode: source code as string. ## sourceCode: source code as string.
## Returns compiles source code. ## Returns compiles source code.
result = @[] result = @[]
server.rpc("eth_compileSerpent") do(sourceCode: string) -> seq[byte]: server.rpc("eth_compileSerpent") do(sourceCode: string) -> seq[byte]:
## Returns compiled serpent code. ## Returns compiled serpent code.
## ##
## sourceCode: source code as string. ## sourceCode: source code as string.
## Returns compiles source code. ## Returns compiles source code.
result = @[] result = @[]
server.rpc("eth_newFilter") do(filterOptions: FilterOptions) -> int: server.rpc("eth_newFilter") do(filterOptions: FilterOptions) -> int:
## Creates a filter object, based on filter options, to notify when the state changes (logs). ## 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. ## 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: ## Topics are order-dependent. A transaction with a log with topics [A, B] will be matched by the following topic filters:
@ -317,21 +316,21 @@ server.rpc("eth_newFilter") do(filterOptions: FilterOptions) -> int:
## Returns integer filter id. ## Returns integer filter id.
discard discard
server.rpc("eth_newBlockFilter") do() -> int: server.rpc("eth_newBlockFilter") do() -> int:
## Creates a filter in the node, to notify when a new block arrives. ## Creates a filter in the node, to notify when a new block arrives.
## To check if the state has changed, call eth_getFilterChanges. ## To check if the state has changed, call eth_getFilterChanges.
## ##
## Returns integer filter id. ## Returns integer filter id.
discard discard
server.rpc("eth_newPendingTransactionFilter") do() -> int: server.rpc("eth_newPendingTransactionFilter") do() -> int:
## Creates a filter in the node, to notify when a new block arrives. ## Creates a filter in the node, to notify when a new block arrives.
## To check if the state has changed, call eth_getFilterChanges. ## To check if the state has changed, call eth_getFilterChanges.
## ##
## Returns integer filter id. ## Returns integer filter id.
discard discard
server.rpc("eth_uninstallFilter") do(filterId: int) -> bool: server.rpc("eth_uninstallFilter") do(filterId: int) -> bool:
## Uninstalls a filter with given id. Should always be called when watch is no longer needed. ## 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. ## Additonally Filters timeout when they aren't requested with eth_getFilterChanges for a period of time.
## ##
@ -339,23 +338,23 @@ server.rpc("eth_uninstallFilter") do(filterId: int) -> bool:
## Returns true if the filter was successfully uninstalled, otherwise false. ## Returns true if the filter was successfully uninstalled, otherwise false.
discard discard
server.rpc("eth_getFilterChanges") do(filterId: int) -> seq[LogObject]: server.rpc("eth_getFilterChanges") do(filterId: int) -> seq[LogObject]:
## Polling method for a filter, which returns an list of logs which occurred since last poll. ## Polling method for a filter, which returns an list of logs which occurred since last poll.
## ##
## filterId: the filter id. ## filterId: the filter id.
result = @[] result = @[]
server.rpc("eth_getFilterLogs") do(filterId: int) -> seq[LogObject]: server.rpc("eth_getFilterLogs") do(filterId: int) -> seq[LogObject]:
## filterId: the filter id. ## filterId: the filter id.
## Returns a list of all logs matching filter with given id. ## Returns a list of all logs matching filter with given id.
result = @[] result = @[]
server.rpc("eth_getLogs") do(filterOptions: FilterOptions) -> seq[LogObject]: server.rpc("eth_getLogs") do(filterOptions: FilterOptions) -> seq[LogObject]:
## filterOptions: settings for this filter. ## filterOptions: settings for this filter.
## Returns a list of all logs matching a given filter object. ## Returns a list of all logs matching a given filter object.
result = @[] result = @[]
server.rpc("eth_getWork") do() -> seq[UInt256]: server.rpc("eth_getWork") do() -> seq[UInt256]:
## Returns the hash of the current block, the seedHash, and the boundary condition to be met ("target"). ## Returns the hash of the current block, the seedHash, and the boundary condition to be met ("target").
## Returned list has the following properties: ## Returned list has the following properties:
## DATA, 32 Bytes - current block header pow-hash. ## DATA, 32 Bytes - current block header pow-hash.
@ -363,7 +362,7 @@ server.rpc("eth_getWork") do() -> seq[UInt256]:
## DATA, 32 Bytes - the boundary condition ("target"), 2^256 / difficulty. ## DATA, 32 Bytes - the boundary condition ("target"), 2^256 / difficulty.
result = @[] result = @[]
server.rpc("eth_submitWork") do(nonce: int64, powHash: Uint256, mixDigest: Uint256) -> bool: server.rpc("eth_submitWork") do(nonce: int64, powHash: Uint256, mixDigest: Uint256) -> bool:
## Used for submitting a proof-of-work solution. ## Used for submitting a proof-of-work solution.
## ##
## nonce: the nonce found. ## nonce: the nonce found.
@ -372,7 +371,7 @@ server.rpc("eth_submitWork") do(nonce: int64, powHash: Uint256, mixDigest: Uint2
## Returns true if the provided solution is valid, otherwise false. ## Returns true if the provided solution is valid, otherwise false.
discard discard
server.rpc("eth_submitHashrate") do(hashRate: UInt256, id: Uint256) -> bool: server.rpc("eth_submitHashrate") do(hashRate: UInt256, id: Uint256) -> bool:
## Used for submitting mining hashrate. ## Used for submitting mining hashrate.
## ##
## hashRate: a hexadecimal string representation (32 bytes) of the hash rate. ## hashRate: a hexadecimal string representation (32 bytes) of the hash rate.
@ -380,44 +379,44 @@ server.rpc("eth_submitHashrate") do(hashRate: UInt256, id: Uint256) -> bool:
## Returns true if submitting went through succesfully and false otherwise. ## Returns true if submitting went through succesfully and false otherwise.
discard discard
server.rpc("shh_version") do() -> string: server.rpc("shh_version") do() -> string:
## Returns string of the current whisper protocol version. ## Returns string of the current whisper protocol version.
discard discard
server.rpc("shh_post") do(message: WhisperPost) -> bool: server.rpc("shh_post") do(message: WhisperPost) -> bool:
## Sends a whisper message. ## Sends a whisper message.
## ##
## message: Whisper message to post. ## message: Whisper message to post.
## Returns true if the message was send, otherwise false. ## Returns true if the message was send, otherwise false.
discard discard
server.rpc("shh_newIdentity") do() -> array[60, byte]: server.rpc("shh_newIdentity") do() -> array[60, byte]:
## Creates new whisper identity in the client. ## Creates new whisper identity in the client.
## ##
## Returns the address of the new identiy. ## Returns the address of the new identiy.
discard discard
server.rpc("shh_hasIdentity") do(identity: array[60, byte]) -> bool: server.rpc("shh_hasIdentity") do(identity: array[60, byte]) -> bool:
## Checks if the client holds the private keys for a given identity. ## Checks if the client holds the private keys for a given identity.
## ##
## identity: the identity address to check. ## identity: the identity address to check.
## Returns true if the client holds the privatekey for that identity, otherwise false. ## Returns true if the client holds the privatekey for that identity, otherwise false.
discard discard
server.rpc("shh_newGroup") do() -> array[60, byte]: server.rpc("shh_newGroup") do() -> array[60, byte]:
## (?) - This has no description information in the RPC wiki. ## (?) - This has no description information in the RPC wiki.
## ##
## Returns the address of the new group. (?) ## Returns the address of the new group. (?)
discard discard
server.rpc("shh_addToGroup") do(identity: array[60, byte]) -> bool: server.rpc("shh_addToGroup") do(identity: array[60, byte]) -> bool:
## (?) - This has no description information in the RPC wiki. ## (?) - This has no description information in the RPC wiki.
## ##
## identity: the identity address to add to a group (?). ## identity: the identity address to add to a group (?).
## Returns true if the identity was successfully added to the group, otherwise false (?). ## Returns true if the identity was successfully added to the group, otherwise false (?).
discard discard
server.rpc("shh_newFilter") do(filterOptions: FilterOptions, to: array[60, byte], topics: seq[UInt256]) -> int: # TODO: Is topic of right type? server.rpc("shh_newFilter") do(filterOptions: FilterOptions, to: array[60, byte], topics: seq[UInt256]) -> int: # TODO: Is topic of right type?
## Creates filter to notify, when client receives whisper message matching the filter options. ## Creates filter to notify, when client receives whisper message matching the filter options.
## ##
## filterOptions: The filter options: ## filterOptions: The filter options:
@ -429,7 +428,7 @@ server.rpc("shh_newFilter") do(filterOptions: FilterOptions, to: array[60, byte]
## Returns the newly created filter. ## Returns the newly created filter.
discard discard
server.rpc("shh_uninstallFilter") do(id: int) -> bool: server.rpc("shh_uninstallFilter") do(id: int) -> bool:
## Uninstalls a filter with given id. ## Uninstalls a filter with given id.
## Should always be called when watch is no longer needed. ## Should always be called when watch is no longer needed.
## Additonally Filters timeout when they aren't requested with shh_getFilterChanges for a period of time. ## Additonally Filters timeout when they aren't requested with shh_getFilterChanges for a period of time.
@ -438,14 +437,14 @@ server.rpc("shh_uninstallFilter") do(id: int) -> bool:
## Returns true if the filter was successfully uninstalled, otherwise false. ## Returns true if the filter was successfully uninstalled, otherwise false.
discard discard
server.rpc("shh_getFilterChanges") do(id: int) -> seq[WhisperMessage]: server.rpc("shh_getFilterChanges") do(id: int) -> seq[WhisperMessage]:
## Polling method for whisper filters. Returns new messages since the last call of this method. ## Polling method for whisper filters. Returns new messages since the last call of this method.
## Note: calling the shh_getMessages method, will reset the buffer for this method, so that you won't receive duplicate messages. ## Note: calling the shh_getMessages method, will reset the buffer for this method, so that you won't receive duplicate messages.
## ##
## id: the filter id. ## id: the filter id.
discard discard
server.rpc("shh_getMessages") do(id: int) -> seq[WhisperMessage]: server.rpc("shh_getMessages") do(id: int) -> seq[WhisperMessage]:
## Get all messages matching a filter. Unlike shh_getFilterChanges this returns all messages. ## Get all messages matching a filter. Unlike shh_getFilterChanges this returns all messages.
## ##
## id: the filter id. ## id: the filter id.