Fix faulty server startup 'all failed' test, fix associated faulty ch…

…eck.
streamr-dev · Feb 13, 2020 · 5652043 · 5652043
1 parent 2bab764
commit 5652043
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/src/server.js b/src/server.js
@@ -108,9 +108,10 @@ module.exports = class CommunityProductServer {
             this.log(`Event ${num} of ${total} processed in ${Date.now() - startEventTime}ms, ${Math.round((num / total) * 100)}% complete.`)
         }
         this.log(`Finished playback of ${total} operator change events in ${Date.now() - startAllTime}ms.`)
-        if (numErrors && numErrors === total) {
+        const numCommunities = Object.keys(this.communities).length
+        if (numErrors && numErrors === numCommunities) {
             // kill if all operators errored
-            throw new Error(`All ${total} operator changed events failed to process. Shutting down.`)
+            throw new Error(`All ${numCommunities} communities failed to start. Shutting down.`)
         }
     }
 

diff --git a/test/unit/server.js b/test/unit/server.js
@@ -202,6 +202,6 @@ describe("CommunityProductServer", function () {
         server.getChannelFor.callsFake(async function () {
             throw new Error("expected fail")
         })
-        assert.rejects(() => server.start())
+        await assert.rejects(() => server.start())
     })
 })