FetchErrors
Set of errors while fetching from a json rpc http endpoint.
Allocator.Error || Client.RequestError || Client.Request.WaitError || Client.Request.FinishError || Client.Request.ReadError || error{
InvalidRequest,
InvalidEndpointConfig,
StreamTooLong,
}InitErrors
Set of possible errors while starting the client.
Allocator.Error || error{ FailedToConnect, UnsupportedSchema, InvalidEndpointConfig }ParseEventErrors
Set of possible errors when parsing a rpc response.
EthereumZigErrors || error{ UnexpectedErrorFound, UnexpectedRpcErrorCode, UnexpectedTooManyRequestError }SendRpcRequestErrors
Set of possible errors when sending rpc requests.
ParseEventErrors || FetchErrors || error{ ReachedMaxRetryLimit, UnexpectedServerResponse }BasicRequestErrors
Set of possible errors when perfoming a generic rpc request.
SendRpcRequestErrors || error{NoSpaceLeft}InitOptions
Init options for defining the initial state of the http/s client.
Consider using the network options defined here if you need a default network config.
Properties
struct {
/// Allocator used to manage the memory arena.
allocator: Allocator
/// The network config for the client to use.
network_config: NetworkConfig
}Init
Sets the clients initial state. This is the HTTP/S implementation of the JSON RPC client.
Most of the client method are replicas of the JSON RPC methods name with the eth_ start.
The client will handle request with 429 errors via exponential backoff but not the rest of the http error codes.
Example:const std = @import("std");
const zabi = @import("zabi");
const RpcClient = zabi.clients.PubClient;
const allocator = std.heap.page_allocator;
const uri = std.Uri.parse("http://localhost:8545/");
var client = try RpcClient.init(.{
.network_config = .{.endpoint = .{.uri = uri }, .chain_id = .ethereum, },
.allocator = allocator,
})
defer client.deinit();Signature
pub fn init(opts: InitOptions) InitErrors!*PubClientDeinit
Clears all allocated memory and destroys any created pointers.
Signature
pub fn deinit(self: *PubClient) voidConnectRpcServer
Connects to the target JSON-RPC endpoint.
In case of failure this will retry the connect by the amount of times defined in the network_config.
This also increments the waiting period by the pooling_interval set in the initial config.
Signature
pub fn connectRpcServer(self: *PubClient) error{ InvalidEndpointConfig, UnsupportedSchema, FailedToConnect }!*HttpConnectionBlobBaseFee
Grabs the current base blob fee. Make sure that your endpoint supports eth_blobBaseFee
RPC Method: eth_blobBaseFee
Signature
pub fn blobBaseFee(self: *PubClient) BasicRequestErrors!RPCResponse(Gwei)CreateAccessList
Create an accessList of addresses and storageKeys for an transaction to access
RPC Method: eth_createAccessList
Example:const std = @import("std");
const zabi = @import("zabi");
const RpcClient = zabi.clients.PubClient;
const allocator = std.heap.page_allocator;
const uri = std.Uri.parse("http://localhost:8545/");
var client = try RpcClient.init(.{
.network_config = .{.endpoint = .{.uri = uri }, .chain_id = .ethereum, },
.allocator = allocator,
})
defer client.deinit();
const access = try client.createAccessList(.{ .london = .{ .value = 10 } }, .{});
defer access.deinit();Signature
pub fn createAccessList(self: *PubClient, call_object: EthCall, opts: BlockNumberRequest) BasicRequestErrors!RPCResponse(AccessListResult)EstimateBlobMaxFeePerGas
Estimate the gas used for blobs.
Uses blobBaseFee and gasPrice to calculate this estimation.
Signature
pub fn estimateBlobMaxFeePerGas(self: *PubClient) BasicRequestErrors!GweiEstimateFeesPerGas
Estimate maxPriorityFeePerGas and maxFeePerGas for london enabled chains and gasPrice if not.
This method will make multiple http requests in order to calculate this.
Uses the baseFeePerGas included in the block to calculate the gas fees.
Will return an error in case the baseFeePerGas is null.
const std = @import("std");
const zabi = @import("zabi");
const RpcClient = zabi.clients.PubClient;
const allocator = std.heap.page_allocator;
const uri = std.Uri.parse("http://localhost:8545/");
var client = try RpcClient.init(.{
.network_config = .{.endpoint = .{.uri = uri }, .chain_id = .ethereum, },
.allocator = allocator,
})
defer client.deinit();
const fees = try client.estimateFeesPerGas(.{ .london = .{ .value = 10 } }, null);
defer fees.deinit();
### Signature
```zig
pub fn estimateFeesPerGas(
self: *PubClient,
call_object: EthCall,
base_fee_per_gas: ?Gwei,
) (BasicRequestErrors || error{ UnableToFetchFeeInfoFromBlock, InvalidBlockNumber })!EstimateFeeReturnEstimateGas
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.
RPC Method: eth_estimateGas
Example:const std = @import("std");
const zabi = @import("zabi");
const RpcClient = zabi.clients.PubClient;
const allocator = std.heap.page_allocator;
const uri = std.Uri.parse("http://localhost:8545/");
var client = try RpcClient.init(.{
.network_config = .{.endpoint = .{.uri = uri }, .chain_id = .ethereum, },
.allocator = allocator,
})
defer client.deinit();
const gas = try client.estimateGas(.{ .london = .{ .value = 10 } }, .{});
defer gas.deinit();
### Signature
```zig
pub fn estimateGas(self: *PubClient, call_object: EthCall, opts: BlockNumberRequest) BasicRequestErrors!RPCResponse(Gwei)EstimateMaxFeePerGasManual
Estimates maxPriorityFeePerGas manually.
Gets the information based on the latest block if base_fee_per_gas is set to null.
If the node you are currently using supports eth_maxPriorityFeePerGas consider using estimateMaxFeePerGas.
Signature
pub fn estimateMaxFeePerGasManual(self: *PubClient, base_fee_per_gas: ?Gwei) (BasicRequestErrors || error{ UnableToFetchFeeInfoFromBlock, InvalidBlockNumber })!GweiEstimateMaxFeePerGas
Only use this if the node you are currently using supports eth_maxPriorityFeePerGas.
Signature
pub fn estimateMaxFeePerGas(self: *PubClient) BasicRequestErrors!RPCResponse(Gwei)FeeHistory
Returns historical gas information, allowing you to track trends over time.
RPC Method: eth_feeHistory
Signature
pub fn feeHistory(self: *PubClient, blockCount: u64, newest_block: BlockNumberRequest, reward_percentil: ?[]const f64) BasicRequestErrors!RPCResponse(FeeHistory)GetAccounts
Returns a list of addresses owned by client.
RPC Method: eth_accounts
Signature
pub fn getAccounts(self: *PubClient) BasicRequestErrors!RPCResponse([]const Address)GetAddressBalance
Returns the balance of the account of given address.
RPC Method: eth_getBalance
Signature
pub fn getAddressBalance(self: *PubClient, opts: BalanceRequest) BasicRequestErrors!RPCResponse(Wei)GetAddressTransactionCount
Returns the number of transactions sent from an address.
RPC Method: eth_getTransactionCount
Signature
pub fn getAddressTransactionCount(self: *PubClient, opts: BalanceRequest) BasicRequestErrors!RPCResponse(u64)GetBlockByHash
Returns information about a block by hash.
RPC Method: eth_getBlockByHash
Signature
pub fn getBlockByHash(self: *PubClient, opts: BlockHashRequest) (BasicRequestErrors || error{InvalidBlockHash})!RPCResponse(Block)GetBlockByHashType
Returns information about a block by hash.
Consider using this method if the provided Block types fail to json parse the request and
you know extractly the shape of the data that the block is expected to be like.
RPC Method: eth_getBlockByHash
Signature
pub fn getBlockByHashType(self: *PubClient, comptime T: type, opts: BlockHashRequest) (BasicRequestErrors || error{InvalidBlockHash})!RPCResponse(T)GetBlockByNumber
Returns information about a block by number.
RPC Method: eth_getBlockByNumber
Signature
pub fn getBlockByNumber(self: *PubClient, opts: BlockRequest) (BasicRequestErrors || error{InvalidBlockNumber})!RPCResponse(Block)GetBlockByNumberType
Returns information about a block by number.
Consider using this method if the provided Block types fail to json parse the request and
you know extractly the shape of the data that the block is expected to be like.
RPC Method: eth_getBlockByNumber
Signature
pub fn getBlockByNumberType(self: *PubClient, comptime T: type, opts: BlockRequest) (BasicRequestErrors || error{InvalidBlockNumber})!RPCResponse(T)GetBlockNumber
Returns the number of most recent block.
RPC Method: eth_blockNumber
Signature
pub fn getBlockNumber(self: *PubClient) BasicRequestErrors!RPCResponse(u64)GetBlockTransactionCountByHash
Returns the number of transactions in a block from a block matching the given block hash.
RPC Method: eth_getBlockTransactionCountByHash
Signature
pub fn getBlockTransactionCountByHash(self: *PubClient, block_hash: Hash) BasicRequestErrors!RPCResponse(usize)GetBlockTransactionCountByNumber
Returns the number of transactions in a block from a block matching the given block number.
RPC Method: eth_getBlockTransactionCountByNumber
Signature
pub fn getBlockTransactionCountByNumber(self: *PubClient, opts: BlockNumberRequest) BasicRequestErrors!RPCResponse(usize)GetChainId
Returns the chain ID used for signing replay-protected transactions.
RPC Method: eth_chainId
Signature
pub fn getChainId(self: *PubClient) BasicRequestErrors!RPCResponse(usize)GetClientVersion
Returns the node's client version
RPC Method: web3_clientVersion
Signature
pub fn getClientVersion(self: *PubClient) BasicRequestErrors!RPCResponse([]const u8)GetContractCode
Returns code at a given address.
RPC Method: eth_getCode
Signature
pub fn getContractCode(self: *PubClient, opts: BalanceRequest) !RPCResponse(Hex)GetFilterOrLogChanges
Polling method for a filter, which returns an array of logs which occurred since last poll or returns an array of all logs matching filter with given id depending on the selected method
https://ethereum.org/en/developers/docs/apis/json-rpc#eth_getfilterchanges
https://ethereum.org/en/developers/docs/apis/json-rpc#eth_getfilterlogs
Signature
pub fn getFilterOrLogChanges(self: *PubClient, filter_id: u128, method: EthereumRpcMethods) (BasicRequestErrors || error{ InvalidFilterId, InvalidRpcMethod })!RPCResponse(Logs)GetGasPrice
Returns an estimate of the current price per gas in wei. For example, the Besu client examines the last 100 blocks and returns the median gas unit price by default.
RPC Method: eth_gasPrice
Signature
pub fn getGasPrice(self: *PubClient) BasicRequestErrors!RPCResponse(Gwei)GetLogs
Returns an array of all logs matching a given filter object.
RPC Method: eth_getLogs
Signature
pub fn getLogs(self: *PubClient, opts: LogRequest, tag: ?BalanceBlockTag) (BasicRequestErrors || error{InvalidLogRequestParams})!RPCResponse(Logs)GetNetworkListenStatus
Returns true if client is actively listening for network connections.
RPC Method: net_listening
Signature
pub fn getNetworkListenStatus(self: *PubClient) BasicRequestErrors!RPCResponse(bool)GetNetworkPeerCount
Returns number of peers currently connected to the client.
RPC Method: net_peerCount
Signature
pub fn getNetworkPeerCount(self: *PubClient) BasicRequestErrors!RPCResponse(usize)GetNetworkVersionId
Returns the current network id.
RPC Method: net_version
Signature
pub fn getNetworkVersionId(self: *PubClient) BasicRequestErrors!RPCResponse(usize)GetProof
Returns the account and storage values, including the Merkle proof, of the specified account
RPC Method: eth_getProof
Signature
pub fn getProof(self: *PubClient, opts: ProofRequest, tag: ?ProofBlockTag) (BasicRequestErrors || error{ExpectBlockNumberOrTag})!RPCResponse(ProofResult)GetProtocolVersion
Returns the current Ethereum protocol version.
RPC Method: eth_protocolVersion
Signature
pub fn getProtocolVersion(self: *PubClient) !RPCResponse(u64)GetRawTransactionByHash
Returns the raw transaction data as a hexadecimal string for a given transaction hash
RPC Method: eth_getRawTransactionByHash
Signature
pub fn getRawTransactionByHash(self: *PubClient, tx_hash: Hash) BasicRequestErrors!RPCResponse(Hex)GetSha3Hash
Returns the Keccak256 hash of the given message. This converts the message into to hex values.
RPC Method: web_sha3
Signature
pub fn getSha3Hash(self: *PubClient, message: []const u8) (BasicRequestErrors || error{ InvalidCharacter, InvalidLength })!RPCResponse(Hash)GetStorage
Returns the value from a storage position at a given address.
RPC Method: eth_getStorageAt
Signature
pub fn getStorage(self: *PubClient, address: Address, storage_key: Hash, opts: BlockNumberRequest) BasicRequestErrors!RPCResponse(Hash)GetSyncStatus
Returns null if the node has finished syncing. Otherwise it will return the sync progress.
RPC Method: eth_syncing
Signature
pub fn getSyncStatus(self: *PubClient) ?RPCResponse(SyncProgress)GetTransactionByBlockHashAndIndex
Returns information about a transaction by block hash and transaction index position.
RPC Method: eth_getTransactionByBlockHashAndIndex
Signature
pub fn getTransactionByBlockHashAndIndex(self: *PubClient, block_hash: Hash, index: usize) (BasicRequestErrors || error{TransactionNotFound})!RPCResponse(Transaction)GetTransactionByBlockHashAndIndexType
Returns information about a transaction by block hash and transaction index position.
Consider using this method if the provided Transaction types fail to json parse the request and
you know extractly the shape of the data that the transaction is expected to be like.
RPC Method: eth_getTransactionByBlockHashAndIndex
Signature
pub fn getTransactionByBlockHashAndIndexType(
self: *PubClient,
comptime T: type,
block_hash: Hash,
index: usize,
) (BasicRequestErrors || error{TransactionNotFound})!RPCResponse(T)GetTransactionByBlockNumberAndIndex
Signature
pub fn getTransactionByBlockNumberAndIndex(
self: *PubClient,
opts: BlockNumberRequest,
index: usize,
) (BasicRequestErrors || error{TransactionNotFound})!RPCResponse(Transaction)GetTransactionByBlockNumberAndIndexType
Returns information about a transaction by block number and transaction index position.
Consider using this method if the provided Transaction types fail to json parse the request and
you know extractly the shape of the data that the transaction is expected to be like.
RPC Method: eth_getTransactionByBlockNumberAndIndex
Signature
pub fn getTransactionByBlockNumberAndIndexType(
self: *PubClient,
comptime T: type,
opts: BlockNumberRequest,
index: usize,
) (BasicRequestErrors || error{TransactionNotFound})!RPCResponse(T)GetTransactionByHash
Returns the information about a transaction requested by transaction hash.
RPC Method: eth_getTransactionByHash
Signature
pub fn getTransactionByHash(self: *PubClient, transaction_hash: Hash) (BasicRequestErrors || error{TransactionNotFound})!RPCResponse(Transaction)GetTransactionByHashType
Returns the information about a transaction requested by transaction hash.
Consider using this method if the provided Transaction types fail to json parse the request and
you know extractly the shape of the data that the transaction is expected to be like.
RPC Method: eth_getTransactionByHash
Signature
pub fn getTransactionByHashType(self: *PubClient, comptime T: type, transaction_hash: Hash) (BasicRequestErrors || error{TransactionNotFound})!RPCResponse(T)GetTransactionReceipt
Returns the receipt of a transaction by transaction hash.
Consider using this method if the provided TransactionReceipt types fail to json parse the request and
you know extractly the shape of the data that the receipt is expected to be like.
RPC Method: eth_getTransactionReceipt
Signature
pub fn getTransactionReceipt(self: *PubClient, transaction_hash: Hash) (BasicRequestErrors || error{TransactionReceiptNotFound})!RPCResponse(TransactionReceipt)GetTransactionReceiptType
Returns the receipt of a transaction by transaction hash.
RPC Method: eth_getTransactionReceipt
Signature
pub fn getTransactionReceiptType(self: *PubClient, comptime T: type, transaction_hash: Hash) (BasicRequestErrors || error{TransactionReceiptNotFound})!RPCResponse(TransactionReceipt)GetTxPoolContent
The content inspection property can be queried to list the exact details of all the transactions currently pending for inclusion in the next block(s), as well as the ones that are being scheduled for future execution only.
The result is an object with two fields pending and queued.
Each of these fields are associative arrays, in which each entry maps an origin-address to a batch of scheduled transactions.
These batches themselves are maps associating nonces with actual transactions.
RPC Method: txpool_content
Signature
pub fn getTxPoolContent(self: *PubClient) BasicRequestErrors!RPCResponse(TxPoolContent)GetTxPoolContentFrom
Retrieves the transactions contained within the txpool, returning pending as well as queued transactions of this address, grouped by nonce
RPC Method: txpool_contentFrom
Signature
pub fn getTxPoolContentFrom(self: *PubClient, from: Address) BasicRequestErrors!RPCResponse([]const PoolTransactionByNonce)GetTxPoolInspectStatus
The inspect inspection property can be queried to list a textual summary of all the transactions currently pending for inclusion in the next block(s),
as well as the ones that are being scheduled for future execution only.
This is a method specifically tailored to developers to quickly see the transactions in the pool and find any potential issues.
RPC Method: txpool_inspect
Signature
pub fn getTxPoolInspectStatus(self: *PubClient) BasicRequestErrors!RPCResponse(TxPoolInspect)GetTxPoolStatus
The status inspection property can be queried for the number of transactions currently pending for inclusion in the next block(s), as well as the ones that are being scheduled for future execution only.
RPC Method: txpool_status
Signature
pub fn getTxPoolStatus(self: *PubClient) BasicRequestErrors!RPCResponse(TxPoolStatus)GetUncleByBlockHashAndIndex
Returns information about a uncle of a block by hash and uncle index position.
RPC Method: eth_getUncleByBlockHashAndIndex
Signature
pub fn getUncleByBlockHashAndIndex(self: *PubClient, block_hash: Hash, index: usize) (BasicRequestErrors || error{InvalidBlockHashOrIndex})!RPCResponse(Block)GetUncleByBlockHashAndIndexType
Returns information about a uncle of a block by hash and uncle index position.
Consider using this method if the provided Block types fail to json parse the request and
you know extractly the shape of the data that the block is expected to be like.
RPC Method: eth_getUncleByBlockHashAndIndex
Signature
pub fn getUncleByBlockHashAndIndexType(self: *PubClient, comptime T: type, block_hash: Hash, index: usize) (BasicRequestErrors || error{InvalidBlockHashOrIndex})!RPCResponse(T)GetUncleByBlockNumberAndIndex
Returns information about a uncle of a block by number and uncle index position.
RPC Method: eth_getUncleByBlockNumberAndIndex
Signature
pub fn getUncleByBlockNumberAndIndex(self: *PubClient, opts: BlockNumberRequest, index: usize) (BasicRequestErrors || error{InvalidBlockNumberOrIndex})!RPCResponse(Block)GetUncleByBlockNumberAndIndexType
Returns information about a uncle of a block by number and uncle index position.
Consider using this method if the provided Block types fail to json parse the request and
you know extractly the shape of the data that the block is expected to be like.
RPC Method: eth_getUncleByBlockNumberAndIndex
Signature
pub fn getUncleByBlockNumberAndIndexType(
self: *PubClient,
comptime T: type,
opts: BlockNumberRequest,
index: usize,
) (BasicRequestErrors || error{InvalidBlockNumberOrIndex})!RPCResponse(T)GetUncleCountByBlockHash
Returns the number of uncles in a block from a block matching the given block hash.
RPC Method: eth_getUncleCountByBlockHash
Signature
pub fn getUncleCountByBlockHash(self: *PubClient, block_hash: Hash) BasicRequestErrors!RPCResponse(usize)GetUncleCountByBlockNumber
Returns the number of uncles in a block from a block matching the given block number.
RPC Method: eth_getUncleCountByBlockNumber
Signature
pub fn getUncleCountByBlockNumber(self: *PubClient, opts: BlockNumberRequest) BasicRequestErrors!RPCResponse(usize)Multicall3
Runs the selected multicall3 contracts.
This enables to read from multiple contract by a single eth_call.
Uses the contracts created here
To learn more about the multicall contract please go here
You will need to decoded each of the Result.
const supply: Function = .{
.type = .function,
.name = "totalSupply",
.stateMutability = .view,
.inputs = &.{},
.outputs = &.{.{ .type = .{ .uint = 256 }, .name = "supply" }},
};
const balance: Function = .{
.type = .function,
.name = "balanceOf",
.stateMutability = .view,
.inputs = &.{.{ .type = .{ .address = {} }, .name = "balanceOf" }},
.outputs = &.{.{ .type = .{ .uint = 256 }, .name = "supply" }},
};
const a: []const MulticallTargets = &.{
.{ .function = supply, .target_address = comptime utils.addressToBytes("0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48") catch unreachable },
.{ .function = balance, .target_address = comptime utils.addressToBytes("0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48") catch unreachable },
};
const res = try client.multicall3(a, .{ {}, .{try utils.addressToBytes("0xFded38DF0180039867E54EBdec2012D534862cE3")} }, true);
defer res.deinit();Signature
pub fn multicall3(
self: *PubClient,
comptime targets: []const MulticallTargets,
function_arguments: MulticallArguments(targets),
allow_failure: bool,
) Multicall(.http).Error!AbiDecoded([]const Result)NewBlockFilter
Creates a filter in the node, to notify when a new block arrives.
To check if the state has changed, call getFilterOrLogChanges.
RPC Method: eth_newBlockFilter
Signature
pub fn newBlockFilter(self: *PubClient) BasicRequestErrors!RPCResponse(u128)NewLogFilter
Creates a filter object, based on filter options, to notify when the state changes (logs).
To check if the state has changed, call getFilterOrLogChanges.
RPC Method: eth_newFilter
Signature
pub fn newLogFilter(self: *PubClient, opts: LogRequest, tag: ?BalanceBlockTag) BasicRequestErrors!RPCResponse(u128)NewPendingTransactionFilter
Creates a filter in the node, to notify when new pending transactions arrive.
To check if the state has changed, call getFilterOrLogChanges.
RPC Method: eth_newPendingTransactionFilter
Signature
pub fn newPendingTransactionFilter(self: *PubClient) BasicRequestErrors!RPCResponse(u128)SendEthCall
Executes a new message call immediately without creating a transaction on the block chain.
Often used for executing read-only smart contract functions,
for example the balanceOf for an ERC-20 contract.
Call object must be prefilled before hand. Including the data field. This will just make the request to the network.
RPC Method: eth_call
const std = @import("std");
const zabi = @import("zabi");
const RpcClient = zabi.clients.PubClient;
const allocator = std.heap.page_allocator;
const uri = std.Uri.parse("http://localhost:8545/");
var client = try RpcClient.init(.{
.network_config = .{.endpoint = .{.uri = uri }, .chain_id = .ethereum, },
.allocator = allocator,
})
defer client.deinit();
const gas = try client.sendEthCall(.{ .london = .{ .value = 10 } }, .{});
defer gas.deinit();
### Signature
```zig
pub fn sendEthCall(self: *PubClient, call_object: EthCall, opts: BlockNumberRequest) BasicRequestErrors!RPCResponse(Hex)SendRawTransaction
Creates new message call transaction or a contract creation for signed transactions. Transaction must be serialized and signed before hand.
RPC Method: eth_sendRawTransaction
Signature
pub fn sendRawTransaction(self: *PubClient, serialized_tx: Hex) BasicRequestErrors!RPCResponse(Hash)WaitForTransactionReceipt
Waits until a transaction gets mined and the receipt can be grabbed.
This is retry based on either the amount of confirmations given.
If 0 confirmations are given the transaction receipt can be null in case the transaction has not been mined yet. It's recommened to have atleast one confirmation because some nodes might be slower to sync.
RPC Method: eth_getTransactionReceipt
Signature
pub fn waitForTransactionReceipt(self: *PubClient, tx_hash: Hash, confirmations: u8) (BasicRequestErrors || error{
FailedToGetReceipt,
TransactionReceiptNotFound,
TransactionNotFound,
InvalidBlockNumber,
})!RPCResponse(TransactionReceipt)WaitForTransactionReceiptType
Waits until a transaction gets mined and the receipt can be grabbed.
This is retry based on either the amount of confirmations given.
If 0 confirmations are given the transaction receipt can be null in case the transaction has not been mined yet. It's recommened to have atleast one confirmation because some nodes might be slower to sync.
Consider using this method if the provided TransactionReceipt types fail to json parse the request and
you know extractly the shape of the data that the receipt is expected to be like.
RPC Method: eth_getTransactionReceipt
Signature
pub fn waitForTransactionReceiptType(self: *PubClient, comptime T: type, tx_hash: Hash, confirmations: u8) (BasicRequestErrors || error{
FailedToGetReceipt,
TransactionReceiptNotFound,
TransactionNotFound,
InvalidBlockNumber,
})!RPCResponse(T)UninstallFilter
Uninstalls a filter with given id. Should always be called when watch is no longer needed.
Additionally Filters timeout when they aren't requested with getFilterOrLogChanges for a period of time.
RPC Method: eth_uninstallFilter
Signature
pub fn uninstallFilter(self: *PubClient, id: usize) !RPCResponse(bool)SendRpcRequest
Writes request to RPC server and parses the response according to the provided type. Handles 429 errors but not the rest.
Signature
pub fn sendRpcRequest(self: *PubClient, comptime T: type, request: []const u8) SendRpcRequestErrors!RPCResponse(T)