Merge pull request #1076 from ainblockchain/hotfix/minsulee2/fix-inte…

…gration-test Hotfix integration test
ainblockchain · Jun 30, 2022 · c6129aa · c6129aa
2 parents f693e91 + 0c01e43
commit c6129aa
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 1 deletion.
diff --git a/test/integration/he_sharding.test.js b/test/integration/he_sharding.test.js
@@ -344,6 +344,10 @@ describe('HE Sharding', () => {
     });
 
     describe('Shard reporter node restart', () => {
+      before(() => {
+        ENV_VARIABLES[2].PEER_CANDIDATE_JSON_RPC_URL = "http://localhost:9092/json-rpc";
+      });
+
       it('can resume reporting after missing some reports', async () => {
         const latestBefore = parseOrLog(syncRequest(
             'GET', parentServer + `/get_value?ref=${sharding.sharding_path}/.shard/latest_block_number`)
@@ -369,6 +373,10 @@ describe('HE Sharding', () => {
         }
         expect(latestAfter).to.be.greaterThan(latestBefore);
       });
+
+      after(() => {
+        delete ENV_VARIABLES[2].PEER_CANDIDATE_JSON_RPC_URL;
+      });
     });
   });
 })
diff --git a/test/integration/sharding.test.js b/test/integration/sharding.test.js
@@ -449,6 +449,10 @@ describe('Sharding', () => {
     });
 
     describe('Shard reporter node restart', () => {
+      before(() => {
+        ENV_VARIABLES[2].PEER_CANDIDATE_JSON_RPC_URL = "http://localhost:9002/json-rpc";
+      });
+
       it('can resume reporting after missing some reports', async () => {
         const latestBefore = parseOrLog(syncRequest(
             'GET', parentServer + `/get_value?ref=${sharding.sharding_path}/.shard/latest_block_number`)
@@ -457,7 +461,6 @@ describe('Sharding', () => {
         server1_proc.kill();
         await waitForNewBlocks(server2, sharding.reporting_period * 3);
         console.log(`        --> Restarting server[0]...`);
-        ENV_VARIABLES[2].PEER_CANDIDATE_JSON_RPC_URL = "http://localhost:9002/json-rpc";
         server1_proc = startServer(APP_SERVER, 'server1', ENV_VARIABLES[2]);
         await waitUntilNodeSyncs(server1);
         await waitForNewShardingReports(parentServer, sharding.sharding_path);
@@ -476,6 +479,10 @@ describe('Sharding', () => {
         expect(latestAfter).to.be.greaterThan(latestBefore);
       });
     });
+
+    after(() => {
+      delete ENV_VARIABLES[2].PEER_CANDIDATE_JSON_RPC_URL;
+    });
   });
 
   describe('API tests', () => {