Make a node for e2e test be able to use IPC

Author: Seulgi Kim

test/src/e2e.long/discovery5.test.ts

@@ -27,10 +27,9 @@ describe("discovery5 nodes", function() {
         nodes = [new CodeChain()];
         bootstrapNode = nodes[0];
 
-        const startBootstrap = bootstrapNode.start([
-            "--discovery-refresh",
-            "50"
-        ]);
+        const startBootstrap = bootstrapNode.start({
+            argv: ["--discovery-refresh", "50"]
+        });
 
         const nonBootstrapNodes = [];
         for (let i = 1; i < numOfNodes; i++) {
@@ -43,12 +42,14 @@ describe("discovery5 nodes", function() {
 
         await Promise.all(
             nonBootstrapNodes.map(node =>
-                node.start([
-                    "--bootstrap-addresses",
-                    `127.0.0.1:${bootstrapNode.port}`,
-                    "--discovery-refresh",
-                    "50"
-                ])
+                node.start({
+                    argv: [
+                        "--bootstrap-addresses",
+                        `127.0.0.1:${bootstrapNode.port}`,
+                        "--discovery-refresh",
+                        "50"
+                    ]
+                })
             )
         );
     });

test/src/e2e.long/futureTransaction.test.ts

@@ -25,7 +25,7 @@ describe("Handle future transactions", function() {
     beforeEach(async function() {
         nodeA = new CodeChain();
 
-        await nodeA.start(["--no-tx-relay"]);
+        await nodeA.start({ argv: ["--no-tx-relay"] });
     });
 
     it("Alone", async function() {
@@ -42,7 +42,7 @@ describe("Handle future transactions", function() {
         beforeEach(async function() {
             this.timeout(60_000);
             nodeB = new CodeChain();
-            await nodeB.start(["--no-tx-relay"]);
+            await nodeB.start({ argv: ["--no-tx-relay"] });
             await promiseExpect.shouldFulfill("connect", nodeB.connect(nodeA));
         });
 

test/src/e2e.long/sync2.test.ts

@@ -202,8 +202,8 @@ describe("sync 2 nodes", function() {
             nodeB = new CodeChain();
 
             await Promise.all([
-                nodeA.start(["--no-tx-relay"]),
-                nodeB.start(["--no-tx-relay"])
+                nodeA.start({ argv: ["--no-tx-relay"] }),
+                nodeB.start({ argv: ["--no-tx-relay"] })
             ]);
             await nodeA.connect(nodeB);
 

test/src/helper/spawn.ts

@@ -124,7 +124,9 @@ export default class CodeChain {
         mkdirp.sync(`${projectRoot}/keys/`);
         mkdirp.sync(`${projectRoot}/test/log/`);
         this._dbPath = mkdtempSync(`${projectRoot}/db/`);
-        this._ipcPath = `/tmp/jsonrpc.${this.id}.ipc`;
+        this._ipcPath = `/tmp/jsonrpc.${new Date()
+            .toISOString()
+            .replace(/[-:.]/g, "_")}.${this.id}.ipc`;
         this._keysPath = mkdtempSync(`${projectRoot}/keys/`);
         if (additionalKeysPath) {
             this.keyFileMovePromise = new Promise((resolve, reject) => {
@@ -149,11 +151,18 @@ export default class CodeChain {
         this.isTestFailed = false;
     }
 
-    public async start(
-        argv: string[] = [],
-        logLevel = "trace,mio=warn,tokio=warn,hyper=warn,timer=warn",
-        disableLog = false
-    ) {
+    public async start(params?: {
+        argv?: string[];
+        logLevel?: string;
+        disableLog?: boolean;
+        disableIpc?: boolean;
+    }) {
+        const {
+            argv = [],
+            logLevel = "trace,mio=warn,tokio=warn,hyper=warn,timer=warn",
+            disableLog = false,
+            disableIpc = true
+        } = params || {};
         if (this.keyFileMovePromise) {
             await this.keyFileMovePromise;
         }
@@ -162,18 +171,24 @@ export default class CodeChain {
         // NOTE: https://github.com/CodeChain-io/codechain/issues/348
         process.env.WAIT_BEFORE_SHUTDOWN = "0";
 
+        const baseArgs = [...this.argv, ...argv];
+        if (disableIpc) {
+            baseArgs.push("--no-ipc");
+        } else {
+            baseArgs.push("--ipc-path");
+            baseArgs.push(this.ipcPath);
+        }
+
         // Resolves when CodeChain initialization completed.
         return new Promise((resolve, reject) => {
             this.process = spawn(
                 `target/${useDebugBuild ? "debug" : "release"}/codechain`,
                 [
-                    ...this.argv,
-                    ...argv,
+                    ...baseArgs,
                     "--chain",
                     this.chain,
                     "--db-path",
                     this.dbPath,
-                    "--no-ipc",
                     "--keys-path",
                     this.keysPath,
                     "--no-ws",