Check connected after trying to connect

Author: Hyunsik Jeong

test/src/helper/spawn.ts

@@ -128,7 +128,10 @@ export default class CodeChain {
     if (!this.process) {
       return Promise.reject(Error("process isn't available"));
     }
-    return this.sdk.rpc.network.connect("127.0.0.1", peer.port);
+    await this.sdk.rpc.network.connect("127.0.0.1", peer.port);
+    while (await this.sdk.rpc.network.isConnected("127.0.0.1", peer.port) === false) {
+      wait(250);
+    }
   }
 
   public async disconnect(peer: CodeChain) {

test/src/integration/discovery.test.ts

@@ -30,8 +30,6 @@ describe("2 nodes", () => {
 
   test("should be able to connect", async () => {
     await nodeA.connect(nodeB);
-    await wait(250);
-    expect(await nodeA.sdk.rpc.network.isConnected("127.0.0.1", nodeB.port)).toBe(true);
   });
 
   afterEach(async () => {

test/src/integration/sync.test.ts

@@ -37,12 +37,10 @@ describe("2 nodes", () => {
 
   describe("A-B connected", () => {
     beforeEach(async () => {
-      await nodeA.sdk.rpc.network.connect("127.0.0.1", nodeB.port);
-      await wait(250);
+      await nodeA.connect(nodeB);
     });
 
     test("It should be synced when nodeA created a block", async () => {
-      expect(await nodeA.sdk.rpc.network.isConnected("127.0.0.1", nodeB.port)).toBe(true);
       const parcel = await nodeA.sendSignedParcel({ awaitInvoice: true });
       await nodeB.waitBlockNumberSync(nodeA);
       expect(await nodeB.getBestBlockHash()).toEqual(parcel.blockHash);