Bugfix

list test with channel
file style

Author: Ricardo Malta

lib/socket.js

@@ -1,39 +1,39 @@
-'use strict'
+'use strict';
 
-const _ = require('lodash')
-const log = require('./logger').log('socket.io')
-const models = require('./models')
-const broker = require('./broker')
+const _ = require('lodash');
+const log = require('./logger').log('socket.io');
+const models = require('./models');
+const broker = require('./broker');
 
 module.exports = (server, callback) => {
-  let io
+  let io;
   try {
     // init socket.io
-    io = require('socket.io').listen(server)
+    io = require('socket.io').listen(server);
   } catch (e) {
-    log.error(e)
-    return callback(e)
+    log.error(e);
+    return callback(e);
   }
 
   io.on('connection', (socket) => {
-    socket.join('public')
-    log.info(socket.id, 'connected')
+    socket.join('public');
+    log.info(socket.id, 'connected');
     models.messages.list((err, messages) => {
       if (err) {
-        log.error(err)
-        return
+        log.error(err);
+        return;
       }
-      let messagesByGroup = _.groupBy(messages, 'Room')
+      let messagesByGroup = _.groupBy(messages, 'Room');
       for (let room in messagesByGroup) {
-        io.to(room).emit('messages', messagesByGroup[room].map((m) => { return m }))
+        io.to(room).emit('messages', messagesByGroup[room].map((m) => { return m }));
       }
-    })
-  })
+    });
+  });
 
   broker.on('message', (data) => {
-    log.info(`message to ${data.room} channel: ${data.message.Text}`)
-    io.to(data.room).emit('messages', data.message)
-  })
+    log.info(`message to ${data.room} channel: ${data.message.Text}`);
+    io.to(data.room).emit('messages', data.message);
+  });
 
-  return callback(null, io)
-}
+  return callback(null, io);
+};

test/test_db.js

@@ -20,11 +20,11 @@ describe('Check if there is a RethinkDB running and could do the ORM read and wr
     }
   });
 
-  it('Get a list of messages in the DB.', function (done) {
+  it('Get a list of messages in public channel from the DB.', function (done) {
     try {
       let messages = require('../lib/models/messages');
 
-      messages.list((err, messages) => {
+      messages.list('public', (err, messages) => {
         if (err) {
           return done(err);
         }