add txpool_content RPC

Author: shunjizhan

packages/eth-providers/src/base-provider.ts

@@ -264,6 +264,24 @@ export interface CallReturnInfo {
   logs: Log[];
 }
 
+export interface PendingTx {
+  blockHash: string;
+  blockNumber: null;
+  from: string;
+  gas: string;
+  gasPrice: string;
+  hash: string;
+  input: string;
+  nonce: string;
+  to: string;
+  transactionIndex: null;
+  value: string;
+}
+export interface TxpoolContent {
+  pending: { [from: string]: { [nonce: string]: PendingTx } };
+  queued: { [from: string]: { [nonce: string]: PendingTx } };
+}
+
 export abstract class BaseProvider extends AbstractProvider {
   readonly _api?: ApiPromise;
   readonly subql?: SubqlProvider;
@@ -2070,6 +2088,42 @@ export abstract class BaseProvider extends AbstractProvider {
     return found;
   };
 
+  txpoolContent = async (): Promise<TxpoolContent> => {
+    const pendingExtrinsics = await this.api.rpc.author.pendingExtrinsics();
+    const pendingTxs = await Promise.all(pendingExtrinsics
+      .filter(isEvmExtrinsic)
+      .map(async extrinsic => {
+        const from = await this.getEvmAddress(extrinsic.signer.toString());
+        const { value, gas, input, to, nonce } = parseExtrinsic(extrinsic);
+
+        return {
+          blockHash: '0x0000000000000000000000000000000000000000000000000000000000000000',
+          blockNumber: null,
+          from,
+          gas,
+          gasPrice: 0, // hard to calculate
+          hash: extrinsic.toHex(),
+          input,
+          nonce,
+          to,
+          transactionIndex: null,
+          value,
+        };
+      }));
+
+    const pending = pendingTxs.reduce((res, tx) => {
+      res[tx.from] ??= {};
+      res[tx.from][tx.nonce] = hexlifyRpcResult(tx);
+
+      return res;
+    }, {} as TxpoolContent['pending']);
+
+    return {
+      pending,
+      queued: {},
+    };
+  };
+
   on = (_eventName: EventType, _listener: Listener): Provider => throwNotImplemented('on');
   once = (_eventName: EventType, _listener: Listener): Provider => throwNotImplemented('once');
   emit = (_eventName: EventType, ..._args: Array<any>): boolean => throwNotImplemented('emit');

packages/eth-providers/src/utils/receiptHelper.ts

@@ -6,7 +6,7 @@ import { TX } from '../base-provider';
 import { TransactionReceipt as TransactionReceiptSubql } from './gqlTypes';
 import { hexToU8a, nToU8a } from '@polkadot/util';
 import { hexValue } from '@ethersproject/bytes';
-import { isOrphanEvmEvent } from './utils';
+import { isEvmExtrinsic, isOrphanEvmEvent } from './utils';
 import { keccak256 } from '@ethersproject/keccak256';
 import { logger } from './logger';
 import type { EventRecord, SignedBlock } from '@polkadot/types/interfaces';
@@ -176,7 +176,6 @@ export const findEvmEvent = (events: EventRecord[]): EventRecord | undefined =>
 };
 
 // parse info that can be extracted from extrinsic alone
-// only works for EVM extrinsics
 export const parseExtrinsic = (
   extrinsic: GenericExtrinsic
 ): {
@@ -200,7 +199,7 @@ export const parseExtrinsic = (
     ...DUMMY_V_R_S, // TODO: get correct VRS
   };
 
-  if (extrinsic.method.section.toUpperCase() !== 'EVM') {
+  if (!isEvmExtrinsic(extrinsic)){
     return NONE_EVM_TX_DEFAULT_DATA;
   }
 

packages/eth-rpc-adapter/src/eip1193-bridge.ts

@@ -495,4 +495,9 @@ class Eip1193BridgeImpl {
 
     return this.#provider.removeEventListener(params[0]);
   }
+
+  async txpool_content(params: any[]): Promise<any> {
+    validate([], params);
+    return this.#provider.txpoolContent();
+  }
 }