test(client): added SockJSClient test

Author: knagaitsev

test/SockJSClient.test.js

@@ -0,0 +1,59 @@
+'use strict';
+
+const http = require('http');
+const express = require('express');
+const sockjs = require('sockjs');
+const SockJSClient = require('../lib/clients/SockJSClient');
+
+describe('SockJSClient', () => {
+  let socketServer;
+  let listeningApp;
+
+  beforeAll((done) => {
+    // eslint-disable-next-line new-cap
+    const app = new express();
+    listeningApp = http.createServer(app);
+    listeningApp.listen(8080, 'localhost', () => {
+      socketServer = sockjs.createServer();
+      socketServer.installHandlers(listeningApp, {
+        prefix: '/sockjs-node',
+      });
+      done();
+    });
+  });
+
+  describe('client', () => {
+    it('should open, recieve message, and close', (done) => {
+      socketServer.on('connection', (connection) => {
+        connection.write('hello world');
+        setTimeout(() => {
+          connection.close();
+        }, 1000);
+      });
+      const client = new SockJSClient('http://localhost:8080/sockjs-node');
+      const data = [];
+      client.onOpen(() => {
+        data.push('open');
+      });
+      client.onClose(() => {
+        data.push('close');
+      });
+      client.onMessage((msg) => {
+        data.push(msg);
+      });
+      setTimeout(() => {
+        expect(data.length).toEqual(3);
+        expect(data[0]).toEqual('open');
+        expect(data[1]).toEqual('hello world');
+        expect(data[2]).toEqual('close');
+        done();
+      }, 3000);
+    });
+  });
+
+  afterAll((done) => {
+    listeningApp.close(() => {
+      done();
+    });
+  });
+});