implement pendingExtrinsics (#110)

AcalaNetwork · Dec 20, 2022 · 4bbb211 · 4bbb211
1 parent 0456a23
commit 4bbb211
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 1 deletion.
diff --git a/src/blockchain/index.ts b/src/blockchain/index.ts
@@ -70,6 +70,10 @@ export class Blockchain {
     return this.#head
   }
 
+  get pendingExtrinsics(): HexString[] {
+    return this.#txpool.pendingExtrinsics
+  }
+
   async getBlockAt(number?: number): Promise<Block | undefined> {
     if (number === undefined) {
       return this.head

diff --git a/src/blockchain/txpool.ts b/src/blockchain/txpool.ts
@@ -39,6 +39,10 @@ export class TxPool {
     this.#inherentProvider = inherentProvider
   }
 
+  get pendingExtrinsics(): HexString[] {
+    return this.#pool
+  }
+
   submitExtrinsic(extrinsic: HexString) {
     this.#pool.push(extrinsic)
 

diff --git a/src/rpc/substrate/author.ts b/src/rpc/substrate/author.ts
@@ -43,7 +43,9 @@ const handlers: Handlers = {
   author_unwatchExtrinsic: async (_context, [subid], { unsubscribe }) => {
     unsubscribe(subid)
   },
-  author_pendingExtrinsics: async (_context) => [],
+  author_pendingExtrinsics: async (context) => {
+    return context.chain.pendingExtrinsics
+  },
 }
 
 export default handlers