[Test] Integration

test/integration.spec.js

@@ -0,0 +1,110 @@
+var childProcess = require('child_process');
+var request = require('supertest');
+var expect = require('expect');
+var scClient = require('socketcluster-client');
+var remotedev = require('../');
+
+describe('Server', function() {
+  var scServer;
+  this.timeout(5000);
+  before(function(done) {
+    scServer = childProcess.fork(__dirname + '/../bin/remotedev.js');
+    setTimeout(done, 2000);
+  });
+
+  after(function() {
+    if (scServer) {
+      scServer.kill();
+    }
+  });
+
+  describe('Express backend', function() {
+    it('loads main page', function(done) {
+      request('http://localhost:8000')
+        .get('/')
+        .expect('Content-Type', /text\/html/)
+        .expect(200)
+        .expect(function(res) {
+          expect(res.text).toMatch(/<title>RemoteDev<\/title>/);
+        })
+        .end(done);
+    });
+
+    it('resolves an inexistent url', function(done) {
+      request('http://localhost:8000/jreerfr/123')
+        .get('/')
+        .expect('Content-Type', /text\/html/)
+        .expect(200, done);
+    });
+  });
+
+  describe('Realtime monitoring', function() {
+    var socket, socket2, channel;
+    before(function() {
+      socket = scClient.connect({ hostname: 'localhost', port: 8000 });
+      socket.connect();
+      socket.on('error', function(error) {
+        console.error('Socket1 error', error);
+      });
+      socket2 = scClient.connect({ hostname: 'localhost', port: 8000 });
+      socket2.connect();
+      socket.on('error', function(error) {
+        console.error('Socket2 error', error);
+      });
+    });
+
+    after(function() {
+      socket.disconnect();
+      socket2.disconnect();
+    });
+
+    it('should connect', function(done) {
+      socket.on('connect', function(status) {
+        expect(status.id).toExist();
+        done();
+      });
+    });
+
+    it('should login', function() {
+      socket.emit('login', 'master', function(error, channelName) {
+        if (error) { console.log(error); return; }
+        expect(channelName).toBe('respond');
+        channel = socket.subscribe(channelName);
+        expect(channel.SUBSCRIBED).toBe('subscribed');
+      });
+    });
+
+    it('should send message', function(done) {
+      var data = {
+        "type": "ACTION",
+        "payload": {
+          "todos": "do some"
+        },
+        "action": {
+          "timestamp": 1483349708506,
+          "action": {
+            "type": "ADD_TODO",
+            "text": "hggg"
+          }
+        },
+        "instanceId": "tAmA7H5fclyWhvizAAAi",
+        "name": "LoggerInstance",
+        "id": "tAmA7H5fclyWhvizAAAi"
+      };
+
+      socket2.emit('login', '', function(error, channelName) {
+        if (error) { console.log(error); return; }
+        expect(channelName).toBe('log');
+        var channel2 = socket2.subscribe(channelName);
+        expect(channel2.SUBSCRIBED).toBe('subscribed');
+        channel2.on('subscribe', function() {
+          channel2.watch(function(message) {
+            expect(message).toEqual(data);
+            done();
+          });
+          socket.emit(channelName, data);
+        })
+      });
+    });
+  });
+});