Support non-standard RPC methods for indexing services

etc/methods.yaml

@@ -211,7 +211,18 @@ eth_getTransactionByBlockNumberAndIndex:
  implementations:
  - etc/schema/functions/eth_getTransactionByBlockNumberAndIndex.sql
  - src/servers/skeleton.ts
-
+eth_getTransactionByBlockNumber:
+ status: ok
+ comment:
+ link: https://eth.wiki/json-rpc/API#eth_getTransactionByBlockNumber
+ implementations:
+ - src/servers/skeleton.ts
+eth_getTransactionReceiptsByBlockNumber:
+ status: ok
+ comment:
+ link: https://eth.wiki/json-rpc/API#eth_getTransactionReceiptsByBlockNumber
+ implementations:
+ - src/servers/skeleton.ts
 eth_getTransactionByHash:
  status: wip
  comment:

lib/servers/database.d.ts

@@ -21,10 +21,12 @@ export declare class DatabaseServer extends SkeletonServer {
  eth_getLogs(_request: any, filter: web3.FilterOptions): Promise<web3.LogObject[]>;
  eth_getStorageAt(_request: any, address: web3.Data, key: web3.Quantity, blockNumber: web3.Quantity | web3.Tag): Promise<web3.Data>;
  eth_getTransactionByBlockHashAndIndex(_request: any, blockHash: web3.Data, transactionIndex: web3.Quantity): Promise<web3.TransactionResult | null>;
+ eth_getTransactionsByBlockNumber(_request: any, blockNumber: web3.Quantity | web3.Tag): Promise<web3.TransactionResult | null>;
  eth_getTransactionByBlockNumberAndIndex(_request: any, blockNumber: web3.Quantity | web3.Tag, transactionIndex: web3.Quantity): Promise<web3.TransactionResult | null>;
  eth_getTransactionByHash(_request: any, transactionHash: web3.Data): Promise<web3.TransactionResult | null>;
  eth_getTransactionCount(_request: any, address: web3.Data, blockNumber: web3.Quantity | web3.Tag): Promise<web3.Quantity>;
  eth_getTransactionReceipt(_request: any, transactionHash: string): Promise<web3.TransactionReceipt | null>;
+ eth_getTransactionReceiptsByBlockNumber(_request: any, blockNumber: web3.Quantity | web3.Tag): Promise<web3.TransactionReceipt[] | null>;
  eth_getUncleCountByBlockHash(_request: any, blockHash: web3.Data): Promise<web3.Quantity | null>;
  eth_getUncleCountByBlockNumber(_request: any, blockNumber: web3.Quantity | web3.Tag): Promise<web3.Quantity | null>;
  eth_newBlockFilter(_request: any): Promise<web3.Quantity>;

lib/servers/skeleton.d.ts

@@ -44,6 +44,8 @@ export declare abstract class SkeletonServer implements web3.Service {
  eth_getStorageAt(_request: any, _address: web3.Data, _key: web3.Quantity, _blockNumber: web3.Quantity | web3.Tag): Promise<web3.Data>;
  eth_getTransactionByBlockHashAndIndex(_request: any, _blockHash: web3.Data, _transactionIndex: web3.Quantity): Promise<web3.TransactionResult | null>;
  eth_getTransactionByBlockNumberAndIndex(_request: any, _blockNumber: web3.Quantity | web3.Tag, _transactionIndex: web3.Quantity): Promise<web3.TransactionResult | null>;
+ eth_getTransactionsByBlockNumber(_request: any, _blockNumber: web3.Quantity | web3.Tag): Promise<web3.TransactionResult | null>;
+ eth_getTransactionReceiptsByBlockNumber(_request: any, _blockNumber: web3.Quantity | web3.Tag): Promise<web3.TransactionReceipt[] | null>;
  eth_getTransactionByHash(_request: any, _transactionHash: web3.Data): Promise<web3.TransactionResult | null>;
  eth_getTransactionCount(_request: any, _address: web3.Data, _blockNumber: web3.Quantity | web3.Tag): Promise<web3.Quantity>;
  eth_getTransactionReceipt(_request: any, _transactionHash: string): Promise<web3.TransactionReceipt | null>;

lib/web3.d.ts

@@ -77,6 +77,8 @@ export interface Service {
  eth_getProof(_request: any, address: Data, keys: Data[], blockNumber: Quantity | Tag): Promise<ProofResult>;
  eth_getStorageAt(_request: any, address: Data, key: Quantity, blockNumber: Quantity | Tag): Promise<Data>;
  eth_getTransactionByBlockHashAndIndex(_request: any, blockHash: Data, transactionIndex: Quantity): Promise<TransactionResult | null>;
+ eth_getTransactionsByBlockNumber(_request: any, blockNumber: Quantity | Tag): Promise<TransactionResult | null>;
+ eth_getTransactionReceiptsByBlockNumber(_request: any, blockNumber: Quantity | Tag): Promise<TransactionReceipt[] | null>;
  eth_getTransactionByBlockNumberAndIndex(_request: any, blockNumber: Quantity | Tag, transactionIndex: Quantity): Promise<TransactionResult | null>;
  eth_getTransactionByHash(_request: any, transactionHash: Data): Promise<TransactionResult | null>;
  eth_getTransactionCount(_request: any, address: Data, blockNumber: Quantity | Tag): Promise<Quantity>;

src/servers/database.ts

@@ -465,7 +465,45 @@ export class DatabaseServer extends SkeletonServer {
  return null;
  }
  }
-
+ async eth_getTransactionsByBlockNumber(
+ _request: any,
+ blockNumber: web3.Quantity | web3.Tag
+ ): Promise<web3.TransactionResult | null> {
+ const blockNumber_ =
+ parseBlockSpec(blockNumber) || (await this._fetchCurrentBlockID());
+
+ try {
+ const {
+ rows,
+ } = await this._query(
+ `SELECT
+ b.id AS "blockNumber",
+ b.hash AS "blockHash",
+ t.index AS "transactionIndex",
+ t.hash AS "hash",
+ t.from AS "from",
+ t.to AS "to",
+ t.gas_limit AS "gas",
+ t.gas_price AS "gasPrice",
+ t.nonce AS "nonce",
+ t.value AS "value",
+ coalesce(t.input, '\\x'::bytea) AS "input",
+ t.v AS "v",
+ t.r AS "r",
+ t.s AS "s"
+ FROM transaction t
+ LEFT JOIN block b ON t.block = b.id
+ WHERE b.id = $1`,
+ [blockNumber_]
+ );
+ return !rows || !rows.length ? null : exportJSON(rows[0]);
+ } catch (error) {
+ if (this.config.debug) {
+ console.debug('eth_getTransactionsByBlockNumber', error);
+ }
+ return null;
+ }
+ }
  async eth_getTransactionByBlockNumberAndIndex(
  _request: any,
  blockNumber: web3.Quantity | web3.Tag,
@@ -550,7 +588,49 @@ export class DatabaseServer extends SkeletonServer {
  return null;
  }
  }
+ async eth_getTransactionReceiptsByBlockNumber(
+ _request: any,
+ blockNumber: web3.Quantity | web3.Tag
+ ): Promise<web3.TransactionReceipt[] | null> {
+ const blockNumber_ =
+ parseBlockSpec(blockNumber) || (await this._fetchCurrentBlockID());
+ try {
+ const {
+ rows: [receipt],
+ } = await this._query(
+ `SELECT
+ b.id AS "blockNumber",
+ b.hash AS "blockHash",
+ t.index AS "transactionIndex",
+ t.hash AS "transactionHash",
+ t.from AS "from",
+ t.to AS "to",
+ t.gas_used AS "gasUsed",
+ 0::u256 AS "cumulativeGasUsed", -- TODO: tally?
+ CASE WHEN t.to IS NULL OR t.to = '\\x0000000000000000000000000000000000000000' THEN t.output
+ ELSE NULL
+ END AS "contractAddress",
+ NULL AS "logs", -- TODO: fetch event.id[]
+ repeat('\\000', 256)::bytea AS "logsBloom",
+ CASE WHEN t.status THEN 1 ELSE 0 END AS "status",
+ t.near_hash AS "nearTransactionHash",
+ t.near_receipt_hash AS "nearReceiptHash"
+ FROM transaction t
+ LEFT JOIN block b ON t.block = b.id
+ WHERE b.id = $1`,
+ [blockNumber_]
+ );
+ //assert(receipt, 'receipt is not null');
 
+ receipt.logs = await this._fetchEvents(hexToBytes(receipt.transactionHash.toString()));
+ return exportJSON(receipt);
+ } catch (error) {
+ if (this.config.debug) {
+ console.debug('eth_getTransactionReceiptsByBlockNumber', error);
+ }
+ return null;
+ }
+ }
  async eth_getUncleCountByBlockHash(
  _request: any,
  blockHash: web3.Data

src/servers/skeleton.ts

@@ -283,7 +283,20 @@ export abstract class SkeletonServer implements web3.Service {
  unimplemented('eth_getTransactionByBlockNumberAndIndex');
  return null;
  }
-
+ async eth_getTransactionsByBlockNumber(
+ _request: any,
+ _blockNumber: web3.Quantity | web3.Tag
+ ): Promise<web3.TransactionResult | null> {
+ unimplemented('eth_getTransactionsByBlockNumber');
+ return null;
+ }
+ async eth_getTransactionReceiptsByBlockNumber(
+ _request: any,
+ _blockNumber: web3.Quantity | web3.Tag
+ ): Promise<web3.TransactionReceipt[] | null> {
+ unimplemented('eth_getTransactionReceiptsByBlockNumber');
+ return null;
+ }
  async eth_getTransactionByHash(
  _request: any,
  _transactionHash: web3.Data

src/web3.ts

@@ -140,6 +140,14 @@ export interface Service {
  blockHash: Data,
  transactionIndex: Quantity
  ): Promise<TransactionResult | null>;
+ eth_getTransactionsByBlockNumber(
+ _request: any,
+ blockNumber: Quantity | Tag,
+ ): Promise<TransactionResult | null>;
+ eth_getTransactionReceiptsByBlockNumber(
+ _request: any,
+ blockNumber: Quantity | Tag,
+ ): Promise<TransactionReceipt[] | null>;
  eth_getTransactionByBlockNumberAndIndex(
  _request: any,
  blockNumber: Quantity | Tag,