WIP

Author: Junha Yang0

test/src/tendermint.test/norpc.ts

@@ -56,7 +56,7 @@ import CodeChain from "../helper/spawn";
             additionalKeysPath: "tendermint/keys"
         });
     });
-    await Promise.all(nodes.map(node => node.start()));
+    await Promise.all(nodes.map(node => node.start({ argv: ["--no-tx-relay"] })));
 
     await Promise.all([
         nodes[0].connect(nodes[1]),

test/src/tendermint.test/txgen.ts

@@ -0,0 +1,84 @@
+// Copyright 2018-2019 Kodebox, Inc.
+// This file is part of CodeChain.
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Affero General Public License as
+// published by the Free Software Foundation, either version 3 of the
+// License, or (at your option) any later version.
+//
+// This program 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 Affero General Public License for more details.
+//
+// You should have received a copy of the GNU Affero General Public License
+// along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+import {
+    faucetAddress,
+    faucetSecret,
+    validator0Address,
+    validator1Address,
+    validator2Address,
+    validator3Address,
+    validator0Secret,
+    validator1Secret,
+    validator2Secret,
+    validator3Secret
+} from "../helper/constants";
+import { makeRandomH256 } from "../helper/random";
+import CodeChain from "../helper/spawn";
+const {
+    Worker,
+    isMainThread,
+    parentPort,
+    workerData
+} = require("worker_threads");
+const path = require("path");
+
+const RLP = require("rlp");
+
+(async () => {
+    let nodes: CodeChain[];
+
+    const validatorAddresses = [
+        validator0Address,
+        validator1Address,
+        validator2Address,
+        validator3Address
+    ];
+    let promises = [];
+    const validatorSecrets = [
+        validator0Secret,
+        validator1Secret,
+        validator2Secret,
+        validator3Secret
+    ];
+
+    for (let index = 0; index < 4; index += 1) {
+        const worker = new Worker(
+            path.resolve(__dirname, "./txgen_worker.js"),
+            {
+                workerData: {
+                    wname: `${index}`,
+                    secret: validatorSecrets[index],
+                    seqStart: 0,
+                    seqEnd: 10000,
+                    filePrefix: `${index}`
+                }
+            }
+        );
+
+        let workerPromise = new Promise((resolve, reject) => {
+            worker.on("error", reject);
+            worker.on("exit", (code: any) => {
+                if (code !== 0) {
+                    reject(new Error(`Worker stopped with exit code ${code}`));
+                }
+            });
+        });
+        promises.push(workerPromise);
+    }
+    await Promise.all(promises);
+})().catch(console.error);
+

test/src/tendermint.test/txgen_worker.js

@@ -0,0 +1,62 @@
+const {
+    Worker,
+    isMainThread,
+    parentPort,
+    workerData
+} = require("worker_threads");
+const { SDK } = require("codechain-sdk");
+const { existsSync , readFileSync, writeFileSync} = require("fs")
+
+async function main() {
+    console.log("Hello");
+    console.log("Bye");
+    await wait(100);
+
+    const { wname, secret, seqStart, seqEnd, filePrefix } = workerData;
+    console.log(`${wname} // ${secret} // ${seqStart} // ${seqEnd} // ${filePrefix}`);
+
+    const sdk = new SDK({
+        server: `http://localhost:${8080}`,
+        networkId: "tc"
+    });
+    let seqCount = seqStart;
+    while (seqCount < seqEnd) {
+        const transactions = [];
+        let chunkStart = seqCount;
+        for (let i = 0; i < 50000; i++) {
+
+            const value = makeRandomH256();
+            const accountId = sdk.util.getAccountIdFromPrivate(value);
+            const recipient = sdk.core.classes.PlatformAddress.fromAccountId(accountId, {
+                networkId: "tc"
+            });
+            if (seqCount % 1000 === 0) {
+                await console.log(`[tx prepared] Worker ${wname}: ${i}`);
+            }
+            const transaction = sdk.core
+                    .createPayTransaction({
+                        recipient,
+                        quantity: 1
+                    })
+                    .sign({
+                        secret: secret,
+                        seq: seqCount,
+                        fee: 10
+                    });
+            transactions.push(transaction.rlpBytes().toString("hex"));
+            seqCount++;
+        }
+        writeFileSync(`./tx/${filePrefix}_${chunkStart}_${seqCount}.json`, JSON.stringify(transactions));
+    }
+}
+
+main().catch(console.error);
+
+function makeRandomH256() {
+    let text = "";
+    const possible = "0123456789abcdef";
+    for (let i = 0; i < 64; i++) {
+        text += possible.charAt(Math.floor(Math.random() * possible.length));
+    }
+    return text;
+}