Merge pull request #81 from nguyenphuminh/tx-from-hash

Tx from hash

Author: nguyenphuminh

JSON-RPC.md

@@ -190,6 +190,18 @@ JSON-RPC APIs are APIs provided by running a JeChain RPC server. They can be use
             * Status: 400
             * Body: `{ success: false, payload: null, error: { message: "Invalid transaction index." } }`
 
+* `/get_transactionByTxHash`:
+    * Use case: Get transaction through its hash.
+    * Request body: `{ params: { hash: <tx_hash_hex_string> } }`
+    * Reply body: `{ success: true, payload: { transaction: <transaction_object> } }`
+    * Error body:
+        * Invalid request (not enough params):
+            * Status: 400
+            * Body: `{ success: false, payload: null, error: { message: "Invalid request." } }`
+        * Failed to get transaction with the given hash:
+            * Status: 400
+            * Body: `{ success: false, payload: null, error: { message: "Failed to get transaction with the given hash." } }`
+
 ### Other errors
 
 * Invalid option (non-existent API):

package.json

@@ -1,6 +1,6 @@
 {
   "name": "jechain",
-  "version": "0.28.1",
+  "version": "0.28.2",
   "description": "Node for JeChain - an experimental smart contract blockchain network",
   "main": "./index.js",
   "scripts": {

src/consensus/consensus.js

@@ -48,7 +48,7 @@ async function verifyBlock(newBlock, chainInfo, stateDB, codeDB, enableLogging =
         // Check gas limit
         Block.hasValidGasLimit(newBlock) &&
 
-        // Check transactions and transit state rih
+        // Check transactions and transit state right after
         await Block.verifyTxAndTransit(newBlock, stateDB, codeDB, enableLogging)
     )
 }

src/node/server.js

@@ -43,6 +43,7 @@ const chainInfo = {
 const stateDB = new Level(__dirname + "/../../log/stateStore", { valueEncoding: "buffer" });
 const blockDB = new Level(__dirname + "/../../log/blockStore", { valueEncoding: "buffer" });
 const bhashDB = new Level(__dirname + "/../../log/bhashStore", { valueEncoding: "buffer" });
+const txhashDB = new Level(__dirname + "/../../log/txhashStore");
 const codeDB = new Level(__dirname + "/../../log/codeStore");
 
 async function startServer(options) {
@@ -122,6 +123,14 @@ async function startServer(options) {
                             await blockDB.put(newBlock.blockNumber.toString(), Buffer.from(_message.data)); // Add block to chain
                             await bhashDB.put(newBlock.hash, numToBuffer(newBlock.blockNumber)); // Assign block number to the matching block hash
 
+                            // Apply to all txns of the block: Assign transaction index and block number to transaction hash
+                            for (let txIndex = 0; txIndex < newBlock.transactions.length; txIndex++) {
+                                const tx = Transaction.deserialize(newBlock.transactions[txIndex]);
+                                const txHash = Transaction.getHash(tx);
+
+                                await txhashDB.put(txHash, newBlock.blockNumber.toString() + " " + txIndex.toString());
+                            }
+
                             chainInfo.latestBlock = newBlock; // Update latest block cache
 
                             // Update the new transaction pool (remove all the transactions that are no longer valid).
@@ -237,6 +246,14 @@ async function startServer(options) {
                                 await blockDB.put(block.blockNumber.toString(), Buffer.from(_message.data)); // Add block to chain
                                 await bhashDB.put(block.hash, numToBuffer(block.blockNumber)); // Assign block number to the matching block hash
 
+                                // Assign transaction index and block number to transaction hash
+                                for (let txIndex = 0; txIndex < block.transactions.length; txIndex++) {
+                                    const tx = Transaction.deserialize(block.transactions[txIndex]);
+                                    const txHash = Transaction.getHash(tx);
+
+                                    await txhashDB.put(txHash, block.blockNumber.toString() + " " + txIndex.toString());
+                                }
+
                                 if (!chainInfo.latestSyncBlock) {
                                     chainInfo.latestSyncBlock = block; // Update latest synced block.
 
@@ -349,7 +366,7 @@ async function startServer(options) {
     }
 
     if (ENABLE_MINING) loopMine(publicKey, ENABLE_CHAIN_REQUEST, ENABLE_LOGGING);
-    if (ENABLE_RPC) rpc(RPC_PORT, { publicKey, mining: ENABLE_MINING, chainInfo }, sendTransaction, keyPair, stateDB, blockDB, bhashDB, codeDB);
+    if (ENABLE_RPC) rpc(RPC_PORT, { publicKey, mining: ENABLE_MINING, chainInfo }, sendTransaction, keyPair, stateDB, blockDB, bhashDB, codeDB, txhashDB);
 }
 
 // Function to connect to a node.
@@ -519,6 +536,14 @@ async function mine(publicKey, ENABLE_LOGGING) {
                 await blockDB.put(result.blockNumber.toString(), Buffer.from(Block.serialize(result))); // Add block to chain
                 await bhashDB.put(result.hash, numToBuffer(result.blockNumber)); // Assign block number to the matching block hash
 
+                // Assign transaction index and block number to transaction hash
+                for (let txIndex = 0; txIndex < result.transactions.length; txIndex++) {
+                    const tx = Transaction.deserialize(result.transactions[txIndex]);
+                    const txHash = Transaction.getHash(tx);
+
+                    await txhashDB.put(txHash, result.blockNumber.toString() + " " + txIndex.toString());
+                }
+
                 chainInfo.latestBlock = result; // Update latest block cache
 
                 // Reward

src/rpc/rpc.js

@@ -9,7 +9,7 @@ const { deserializeState, serializeState } = require("../utils/utils");
 
 const fastify = require("fastify")();
 
-function rpc(PORT, client, transactionHandler, keyPair, stateDB, blockDB, bhashDB, codeDB) {
+function rpc(PORT, client, transactionHandler, keyPair, stateDB, blockDB, bhashDB, codeDB, txhashDB) {
 
     process.on("uncaughtException", err => console.log(`\x1b[31mERROR\x1b[0m [${(new Date()).toISOString()}] Uncaught Exception`, err));
 
@@ -310,6 +310,29 @@ function rpc(PORT, client, transactionHandler, keyPair, stateDB, blockDB, bhashD
 
                 break;
 
+            case "get_transactionByTxHash":
+                if (
+                    typeof req.body.params !== "object" ||
+                    typeof req.body.params.hash !== "string"
+                ) {
+                    throwError("Invalid request.", 400);
+                } else {
+                    try {
+                        const indexPair = await txhashDB.get(req.body.params.hash);
+
+                        const [ blockNumber, txIndex ] = indexPair.split(" ").map(item => parseInt(item));
+
+                        const block = Block.deserialize([...await blockDB.get( blockNumber.toString() )]);
+                        const transaction = block.transactions[txIndex];
+
+                        respond({ transaction });
+                    } catch (e) {
+                        throwError("Failed to get transaction with the given hash.", 400);
+                    }
+                }
+
+                break;
+
             case "sendTransaction":
                 if (
                     typeof req.body.params !== "object" ||