txpool management API's implemented (web3-eth-txpool)

docs/web3-eth-txpool.rst

@@ -0,0 +1,265 @@
+.. _eth-txpool:
+
+.. include:: include_announcement.rst
+
+========
+web3.eth.txpool
+========
+
+
+The ``web3-eth-txpool`` package gives you access to several non-standard RPC methods to inspect the contents of the transaction pool containing all the currently pending transactions as well as the ones queued for future processing.
+
+
+.. code-block:: javascript
+
+    import Web3 from 'web3';
+    import {Txpool} from 'web3-eth-txpool';
+
+    // "Web3.givenProvider" will be set if in an Ethereum supported browser.
+    const txpool = new Txpool(Web3.givenProvider || 'ws://some.local-or-remote.node:8546', null, options);
+
+
+    // or using the web3 umbrella package
+    const web3 = new Web3(Web3.givenProvider || 'ws://some.local-or-remote.node:8546', null, options);
+
+    // -> web3.eth.txpool
+
+
+------------------------------------------------------------------------------
+
+
+.. include:: include_package-core.rst
+
+
+
+------------------------------------------------------------------------------
+
+.. _txpool-content:
+
+content
+=========
+
+.. code-block:: javascript
+
+    web3.eth.txpool.content([callback])
+
+This API can be used 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 executions.
+The RPC method used is ``txpool_content``.
+
+----------
+Parameters
+----------
+
+1. ``Function`` - (optional) Optional callback, returns an error object as first parameter and the result as second.
+
+-------
+Returns
+-------
+
+``Object`` - The list of pending as well as queued transactions.
+
+-------
+Example
+-------
+
+.. code-block:: javascript
+
+    web3.eth.txpool.content().then(console.log);
+    > {
+        pending: {
+            0x0216d5032f356960cd3749c31ab34eeff21b3395: {
+            806: [{
+                blockHash: "0x0000000000000000000000000000000000000000000000000000000000000000",
+                blockNumber: null,
+                from: "0x0216d5032f356960cd3749c31ab34eeff21b3395",
+                gas: "0x5208",
+                gasPrice: "0xba43b7400",
+                hash: "0xaf953a2d01f55cfe080c0c94150a60105e8ac3d51153058a1f03dd239dd08586",
+                input: "0x",
+                nonce: "0x326",
+                to: "0x7f69a91a3cf4be60020fb58b893b7cbb65376db8",
+                transactionIndex: null,
+                value: "0x19a99f0cf456000"
+            }]
+            },
+            0x24d407e5a0b506e1cb2fae163100b5de01f5193c: {
+            34: [{
+                blockHash: "0x0000000000000000000000000000000000000000000000000000000000000000",
+                blockNumber: null,
+                from: "0x24d407e5a0b506e1cb2fae163100b5de01f5193c",
+                gas: "0x44c72",
+                gasPrice: "0x4a817c800",
+                hash: "0xb5b8b853af32226755a65ba0602f7ed0e8be2211516153b75e9ed640a7d359fe",
+                input: "0xb61d27f600000000000000000000000024d407e5a0b506e1cb2fae163100b5de01f5193c00000000000000000000000000000000000000000000000053444835ec580000000000000000000000000000000000000000000000000000000000000000006000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000",
+                nonce: "0x22",
+                to: "0x7320785200f74861b69c49e4ab32399a71b34f1a",
+                transactionIndex: null,
+                value: "0x0"
+            }]
+            }
+        },
+        queued: {
+            0x976a3fc5d6f7d259ebfb4cc2ae75115475e9867c: {
+                3: [{
+                    blockHash: "0x0000000000000000000000000000000000000000000000000000000000000000",
+                    blockNumber: null,
+                    from: "0x976a3fc5d6f7d259ebfb4cc2ae75115475e9867c",
+                    gas: "0x15f90",
+                    gasPrice: "0x4a817c800",
+                    hash: "0x57b30c59fc39a50e1cba90e3099286dfa5aaf60294a629240b5bbec6e2e66576",
+                    input: "0x",
+                    nonce: "0x3",
+                    to: "0x346fb27de7e7370008f5da379f74dd49f5f2f80f",
+                    transactionIndex: null,
+                    value: "0x1f161421c8e0000"
+                }]
+            },
+            0x9b11bf0459b0c4b2f87f8cebca4cfc26f294b63a: {
+                2: [{
+                    blockHash: "0x0000000000000000000000000000000000000000000000000000000000000000",
+                    blockNumber: null,
+                    from: "0x9b11bf0459b0c4b2f87f8cebca4cfc26f294b63a",
+                    gas: "0x15f90",
+                    gasPrice: "0xba43b7400",
+                    hash: "0x3a3c0698552eec2455ed3190eac3996feccc806970a4a056106deaf6ceb1e5e3",
+                    input: "0x",
+                    nonce: "0x2",
+                    to: "0x24a461f25ee6a318bdef7f33de634a67bb67ac9d",
+                    transactionIndex: null,
+                    value: "0xebec21ee1da40000"
+                }]
+            }
+        }
+    }
+
+------------------------------------------------------------------------------
+
+
+inspect
+=====================
+
+.. code-block:: javascript
+
+    web3.eth.txpool.inspect([, callback])
+
+The 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 executions. 
+The RPC method used is ``txpool_inspect``.
+
+----------
+Parameters
+----------
+
+
+1. ``Function`` - (optional) Optional callback, returns an error object as first parameter and the result as second.
+
+
+-------
+Returns
+-------
+
+
+``Object`` - The List of pending and queued transactions summary.
+
+
+-------
+Example
+-------
+
+
+.. code-block:: javascript
+
+    web3.eth.txpool.inspect().then(console.log);
+    > {
+        pending: {
+            0x26588a9301b0428d95e6fc3a5024fce8bec12d51: {
+            31813: ["0x3375ee30428b2a71c428afa5e89e427905f95f7e: 0 wei + 500000 × 20000000000 gas"]
+            },
+            0x2a65aca4d5fc5b5c859090a6c34d164135398226: {
+            563662: ["0x958c1fa64b34db746925c6f8a3dd81128e40355e: 1051546810000000000 wei + 90000 × 20000000000 gas"],
+            563663: ["0x77517b1491a0299a44d668473411676f94e97e34: 1051190740000000000 wei + 90000 × 20000000000 gas"],
+            563664: ["0x3e2a7fe169c8f8eee251bb00d9fb6d304ce07d3a: 1050828950000000000 wei + 90000 × 20000000000 gas"],
+            563665: ["0xaf6c4695da477f8c663ea2d8b768ad82cb6a8522: 1050544770000000000 wei + 90000 × 20000000000 gas"],
+            563666: ["0x139b148094c50f4d20b01caf21b85edb711574db: 1048598530000000000 wei + 90000 × 20000000000 gas"],
+            563667: ["0x48b3bd66770b0d1eecefce090dafee36257538ae: 1048367260000000000 wei + 90000 × 20000000000 gas"],
+            563668: ["0x468569500925d53e06dd0993014ad166fd7dd381: 1048126690000000000 wei + 90000 × 20000000000 gas"],
+            563669: ["0x3dcb4c90477a4b8ff7190b79b524773cbe3be661: 1047965690000000000 wei + 90000 × 20000000000 gas"],
+            563670: ["0x6dfef5bc94b031407ffe71ae8076ca0fbf190963: 1047859050000000000 wei + 90000 × 20000000000 gas"]
+            },
+            0x9174e688d7de157c5c0583df424eaab2676ac162: {
+            3: ["0xbb9bc244d798123fde783fcc1c72d3bb8c189413: 30000000000000000000 wei + 85000 × 21000000000 gas"]
+            },
+            0xb18f9d01323e150096650ab989cfecd39d757aec: {
+            777: ["0xcd79c72690750f079ae6ab6ccd7e7aedc03c7720: 0 wei + 1000000 × 20000000000 gas"]
+            },
+            0xb2916c870cf66967b6510b76c07e9d13a5d23514: {
+            2: ["0x576f25199d60982a8f31a8dff4da8acb982e6aba: 26000000000000000000 wei + 90000 × 20000000000 gas"]
+            },
+            0xbc0ca4f217e052753614d6b019948824d0d8688b: {
+            0: ["0x2910543af39aba0cd09dbb2d50200b3e800a63d2: 1000000000000000000 wei + 50000 × 1171602790622 gas"]
+            },
+            0xea674fdde714fd979de3edf0f56aa9716b898ec8: {
+            70148: ["0xe39c55ead9f997f7fa20ebe40fb4649943d7db66: 1000767667434026200 wei + 90000 × 20000000000 gas"]
+            }
+        },
+        queued: {
+            0x0f6000de1578619320aba5e392706b131fb1de6f: {
+            6: ["0x8383534d0bcd0186d326c993031311c0ac0d9b2d: 9000000000000000000 wei + 21000 × 20000000000 gas"]
+            },
+            0x5b30608c678e1ac464a8994c3b33e5cdf3497112: {
+            6: ["0x9773547e27f8303c87089dc42d9288aa2b9d8f06: 50000000000000000000 wei + 90000 × 50000000000 gas"]
+            },
+            0x976a3fc5d6f7d259ebfb4cc2ae75115475e9867c: {
+            3: ["0x346fb27de7e7370008f5da379f74dd49f5f2f80f: 140000000000000000 wei + 90000 × 20000000000 gas"]
+            },
+            0x9b11bf0459b0c4b2f87f8cebca4cfc26f294b63a: {
+            2: ["0x24a461f25ee6a318bdef7f33de634a67bb67ac9d: 17000000000000000000 wei + 90000 × 50000000000 gas"],
+            6: ["0x6368f3f8c2b42435d6c136757382e4a59436a681: 17990000000000000000 wei + 90000 × 20000000000 gas", "0x8db7b4e0ecb095fbd01dffa62010801296a9ac78: 16998950000000000000 wei + 90000 × 20000000000 gas"],
+            7: ["0x6368f3f8c2b42435d6c136757382e4a59436a681: 17900000000000000000 wei + 90000 × 20000000000 gas"]
+            }
+        }
+    }
+
+
+------------------------------------------------------------------------------
+
+
+status
+=====================
+
+.. code-block:: javascript
+
+    web3.eth.txpool.status([, callback])
+
+This will provide the number of transactions currently pending for inclusion in the next block(s), as well as the ones that are being scheduled for future executions.
+The RPC method used is ``txpool_status``.
+
+----------
+Parameters
+----------
+
+
+1. ``Function`` - (optional) Optional callback, returns an error object as first parameter and the result as second.
+
+
+-------
+Returns
+-------
+
+
+``Object`` - A list of number of pending and queued transactions.
+
+
+-------
+Example
+-------
+
+
+.. code-block:: javascript
+
+    web3.eth.txpool.status().then(console.log);
+    > {
+        pending: 10,
+        queued: 7
+    }
+
+------------------------------------------------------------------------------

packages/web3-core-method/src/index.js

@@ -117,3 +117,8 @@ export PostMethod from './methods/shh/PostMethod';
 export SetMaxMessageSizeMethod from './methods/shh/SetMaxMessageSizeMethod';
 export SetMinPoWMethod from './methods/shh/SetMinPoWMethod';
 export ShhVersionMethod from './methods/shh/ShhVersionMethod';
+
+// Txpool
+export GetTxpoolContentMethod from './methods/txpool/GetTxpoolContentMethod';
+export GetTxpoolInspectMethod from './methods/txpool/GetTxpoolInspectMethod';
+export GetTxpoolStatusMethod from './methods/txpool/GetTxpoolStatusMethod';

packages/web3-core-method/src/methods/txpool/GetTxpoolContentMethod.js

@@ -0,0 +1,36 @@
+/*
+    This file is part of web3.js.
+
+    web3.js is free software: you can redistribute it and/or modify
+    it under the terms of the GNU Lesser General Public License as published by
+    the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+    web3.js is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU Lesser General Public License for more details.
+
+    You should have received a copy of the GNU Lesser General Public License
+    along with web3.js.  If not, see <http://www.gnu.org/licenses/>.
+*/
+/**
+ * @file GetTxpoolContentMethod.js
+ * @author Prince Sinha <sinhaprince013@gmail.com>
+ * @date 2019
+ */
+
+import AbstractMethod from '../../../lib/methods/AbstractMethod';
+
+export default class GetTxpoolContentMethod extends AbstractMethod {
+    /**
+     * @param {Utils} utils
+     * @param {Object} formatters
+     * @param {AbstractWeb3Module} moduleInstance
+     *
+     * @constructor
+     */
+    constructor(utils, formatters, moduleInstance) {
+        super('txpool_content', 0, utils, formatters, moduleInstance);
+    }
+}

packages/web3-core-method/src/methods/txpool/GetTxpoolInspectMethod.js

@@ -0,0 +1,36 @@
+/*
+    This file is part of web3.js.
+
+    web3.js is free software: you can redistribute it and/or modify
+    it under the terms of the GNU Lesser General Public License as published by
+    the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+    web3.js is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU Lesser General Public License for more details.
+
+    You should have received a copy of the GNU Lesser General Public License
+    along with web3.js.  If not, see <http://www.gnu.org/licenses/>.
+*/
+/**
+ * @file GetTxpoolInspectMethod.js
+ * @author Prince Sinha <sinhaprince013@gmail.com>
+ * @date 2019
+ */
+
+import AbstractMethod from '../../../lib/methods/AbstractMethod';
+
+export default class GetTxpoolInspectMethod extends AbstractMethod {
+    /**
+     * @param {Utils} utils
+     * @param {Object} formatters
+     * @param {AbstractWeb3Module} moduleInstance
+     *
+     * @constructor
+     */
+    constructor(utils, formatters, moduleInstance) {
+        super('txpool_inspect', 0, utils, formatters, moduleInstance);
+    }
+}

packages/web3-core-method/src/methods/txpool/GetTxpoolStatusMethod.js

@@ -0,0 +1,36 @@
+/*
+    This file is part of web3.js.
+
+    web3.js is free software: you can redistribute it and/or modify
+    it under the terms of the GNU Lesser General Public License as published by
+    the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+    web3.js is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU Lesser General Public License for more details.
+
+    You should have received a copy of the GNU Lesser General Public License
+    along with web3.js.  If not, see <http://www.gnu.org/licenses/>.
+*/
+/**
+ * @file GetTxpoolStatusMethod.js
+ * @author Prince Sinha <sinhaprince013@gmail.com>
+ * @date 2019
+ */
+
+import AbstractMethod from '../../../lib/methods/AbstractMethod';
+
+export default class GetTxpoolStatusMethod extends AbstractMethod {
+    /**
+     * @param {Utils} utils
+     * @param {Object} formatters
+     * @param {AbstractWeb3Module} moduleInstance
+     *
+     * @constructor
+     */
+    constructor(utils, formatters, moduleInstance) {
+        super('txpool_status', 0, utils, formatters, moduleInstance);
+    }
+}