feat: add basic non-verifying eth_getLogs support

This commit is contained in:
Derrick Hammer 2023-10-23 20:23:23 -04:00
parent 77251407c3
commit b405ee2581
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 19 additions and 0 deletions

View File

@ -72,6 +72,7 @@ export default class VerifyingProvider implements IClientVerifyingProvider {
eth_estimateGas: this.estimateGas, eth_estimateGas: this.estimateGas,
eth_sendRawTransaction: this.sendRawTransaction, eth_sendRawTransaction: this.sendRawTransaction,
eth_getTransactionReceipt: this.getTransactionReceipt, eth_getTransactionReceipt: this.getTransactionReceipt,
eth_getLogs: this.getLogs,
}), }),
); );
private rpc: RPC; private rpc: RPC;
@ -396,6 +397,19 @@ export default class VerifyingProvider implements IClientVerifyingProvider {
}; };
} }
private async getLogs(...args: any) {
const { result: logs, success } = await this.rpc.request({
method: "eth_getLogs",
params: [args],
});
if (!(success && logs)) {
return null;
}
return logs;
}
private async getVMCopy(): Promise<VM> { private async getVMCopy(): Promise<VM> {
if (this.vm === null) { if (this.vm === null) {
const blockchain = await Blockchain.create({ common: this.common }); const blockchain = await Blockchain.create({ common: this.common });
@ -519,6 +533,7 @@ export default class VerifyingProvider implements IClientVerifyingProvider {
await vm.stateManager.commit(); await vm.stateManager.commit();
return vm; return vm;
} }
private async getBlockHeader( private async getBlockHeader(
blockOpt: BlockNumberOrTag, blockOpt: BlockNumberOrTag,
): Promise<BlockHeader> { ): Promise<BlockHeader> {
@ -527,6 +542,7 @@ export default class VerifyingProvider implements IClientVerifyingProvider {
const blockHash = await this.getBlockHash(blockNumber); const blockHash = await this.getBlockHash(blockNumber);
return this.getBlockHeaderByHash(blockHash); return this.getBlockHeaderByHash(blockHash);
} }
private getBlockNumberByBlockNumberOrTag(blockOpt: BlockNumberOrTag): bigint { private getBlockNumberByBlockNumberOrTag(blockOpt: BlockNumberOrTag): bigint {
// TODO: add support for blockOpts below // TODO: add support for blockOpts below
if ( if (
@ -548,6 +564,7 @@ export default class VerifyingProvider implements IClientVerifyingProvider {
return blockNumber; return blockNumber;
} }
} }
private async waitForBlockNumber(blockNumber: bigint) { private async waitForBlockNumber(blockNumber: bigint) {
if (blockNumber <= this.latestBlockNumber) return; if (blockNumber <= this.latestBlockNumber) return;
console.log(`waiting for blockNumber ${blockNumber}`); console.log(`waiting for blockNumber ${blockNumber}`);
@ -638,6 +655,7 @@ export default class VerifyingProvider implements IClientVerifyingProvider {
return true; return true;
} }
private verifyCodeHash(code: Bytes, codeHash: Bytes32): boolean { private verifyCodeHash(code: Bytes, codeHash: Bytes32): boolean {
return ( return (
(code === "0x" && codeHash === "0x" + KECCAK256_NULL_S) || (code === "0x" && codeHash === "0x" + KECCAK256_NULL_S) ||
@ -664,6 +682,7 @@ export default class VerifyingProvider implements IClientVerifyingProvider {
); );
} }
} }
private async getBlock(header: BlockHeader) { private async getBlock(header: BlockHeader) {
const { result: blockInfo, success } = await this.rpc.request({ const { result: blockInfo, success } = await this.rpc.request({
method: "eth_getBlockByNumber", method: "eth_getBlockByNumber",