test: Split realtime/resend browser tests.

Author: timoxley

.github/workflows/test-build.yml

@@ -77,7 +77,7 @@ jobs:
       - name: npm run test-exports
         run: npm run test-exports
 
-  browser:
+  browser-realtime:
     name: Test Browser using Node 14.x
     runs-on: ubuntu-latest
     needs: build
@@ -96,14 +96,35 @@ jobs:
         uses: streamr-dev/streamr-docker-dev-action@v1.0.0-alpha.3
         with:
           services-to-start: "mysql redis core-api cassandra parity-node0 parity-sidechain-node0 bridge broker-node-no-storage-1 broker-node-no-storage-2 broker-node-storage-1 nginx smtp"
+      - name: Run Realtime Test
+        run: npm run test-browser-realtime
 
+  browser-resend:
+    name: Test Browser using Node 14.x
+    runs-on: ubuntu-latest
+    needs: build
+    steps:
+      - uses: actions/checkout@v2
+      - uses: actions/setup-node@v2
+        with:
+          node-version: "14.x"
+      - uses: actions/download-artifact@v2
+        with:
+          name: build
+          path: dist
+      - name: npm ci
+        run: npm ci
+      - name: Start Streamr Docker Stack
+        uses: streamr-dev/streamr-docker-dev-action@v1.0.0-alpha.3
+        with:
+          services-to-start: "mysql redis core-api cassandra parity-node0 parity-sidechain-node0 bridge broker-node-no-storage-1 broker-node-no-storage-2 broker-node-storage-1 nginx smtp"
       - uses: nick-invision/retry@v2
-        name: Run Test
+        name: Run Resend Test
         with:
           max_attempts: 3
           timeout_minutes: 3
           retry_on: error
-          command: npm run test-browser
+          command: npm run test-browser-resend
 
   benchmarks:
     name: Test Benchmark using Node ${{ matrix.node-version }}

package.json

@@ -51,6 +51,12 @@
     "test-memory": "node --gc-global --predictable-gc-schedule node_modules/.bin/jest test/memory",
     "test-flakey": "jest --verbose --useStderr --forceExit test/flakey/*",
     "test-browser": "node ./test/browser/server.js & node node_modules/nightwatch/bin/nightwatch ./test/browser/browser.js && pkill -f server.js",
+    "setup-browser": "node ./test/browser/server.js & node node_modules/nightwatch/bin/nightwatch",
+    "teardown-browser": "pkill -f server.js",
+    "test-browser-realtime": "npm run setup-browser; node ./test/browser/server.js & node node_modules/nightwatch/bin/nightwatch ./test/browser/realtime.js; ",
+    "posttest-browser-realtime": "npm run teardown-browser",
+    "test-browser-resend": "npm run setup-browser; node ./test/browser/server.js & node node_modules/nightwatch/bin/nightwatch ./test/browser/resend.js; npm run teardown-browser",
+    "posttest-browser-resend": "npm run teardown-browser",
     "install-example": "cd examples/webpack && npm ci",
     "build-example": "cd examples/webpack && npm run build-with-parent",
     "clear-cache": "rm -rf node_modules/.cache; rm -rf .cache; rm -rf dist; rm -rf vendor; jest --clearCache;",

test/browser/realtime.js

@@ -0,0 +1,54 @@
+/* eslint-disable no-undef */
+const { v4: uuidv4 } = require('uuid')
+
+describe('StreamrClient Realtime', () => {
+    const streamName = uuidv4()
+
+    before((browser) => {
+        // optionally forward url env vars as query params
+        const url = process.env.WEBSOCKET_URL ? `&WEBSOCKET_URL=${encodeURIComponent(process.env.WEBSOCKET_URL)}` : ''
+        const restUrl = process.env.REST_URL ? `&REST_URL=${encodeURIComponent(process.env.REST_URL)}` : ''
+        const browserUrl = `http://localhost:8880?streamName=${streamName}${url}${restUrl}`
+        // eslint-disable-next-line no-console
+        console.info(browserUrl)
+        return browser.url(browserUrl)
+    })
+
+    test('Test StreamrClient in Chrome Browser', (browser) => {
+        browser
+            .waitForElementVisible('body')
+            .assert.titleContains('Test StreamrClient in Chrome Browser')
+            .click('button[id=connect]')
+            .assert.containsText('#result', 'connected')
+            .click('button[id=create]')
+            .assert.containsText('#result', streamName)
+            .click('button[id=subscribe]')
+            .assert.containsText('#result', 'subscribed')
+            .click('button[id=publish]')
+            .pause(3000)
+            .verify.containsText('#result', '{"msg":0}')
+            .verify.containsText('#result', '{"msg":1}')
+            .verify.containsText('#result', '{"msg":2}')
+            .verify.containsText('#result', '{"msg":3}')
+            .verify.containsText('#result', '{"msg":4}')
+            .verify.containsText('#result', '{"msg":5}')
+            .verify.containsText('#result', '{"msg":6}')
+            .verify.containsText('#result', '{"msg":7}')
+            .verify.containsText('#result', '{"msg":8}')
+            .verify.containsText('#result', '{"msg":9}')
+            .assert.containsText('#result', '[{"msg":0},{"msg":1},{"msg":2},{"msg":3},{"msg":4},{"msg":5},{"msg":6},{"msg":7},{"msg":8},{"msg":9}]')
+            .click('button[id=disconnect]')
+            .assert.containsText('#result', 'disconnected')
+    })
+
+    after(async (browser) => {
+        browser.getLog('browser', (logs) => {
+            logs.forEach((log) => {
+                // eslint-disable-next-line no-console
+                const logger = console[String(log.level).toLowerCase()] || console.log
+                logger('[%s]: ', log.timestamp, log.message)
+            })
+        })
+        return browser.end()
+    })
+})

test/browser/browser.js test/browser/resend.jstest/browser/browser.js renamed to test/browser/resend.js

@@ -1,7 +1,7 @@
 /* eslint-disable no-undef */
 const { v4: uuidv4 } = require('uuid')
 
-describe('StreamrClient', () => {
+describe('StreamrClient Resend', () => {
     const streamName = uuidv4()
 
     before((browser) => {