Commit: 491df883272baa8279eafd5ea90bc7b980bfc5b2 - node_sample_minichat (git)

Node.js sample application with Socket.IO

Commit MetaInfo

• Revision: 491df883272baa8279eafd5ea90bc7b980bfc5b2 (tree)
• Time: 2012-12-09 22:26:36
• Author: hylom <hylom@hylo...>
• Commiter: hylom

Log Message

separate socket.io routines from app.js to sockets/chat.js

Change Summary

• modified: app.js
• delete: public/js/minichat.js
• add: sockets/chat.js
• modified: views/layout.jade
• modified: views/room.jade

Incremental Difference

--- a/app.js
+++ b/app.js
@@ -3,14 +3,13 @@
  * Module dependencies.
  */
 
-var express = require('express')
-  , routes = require('./routes')
-  , http = require('http')
-  , path = require('path')
-  , socketIO = require('socket.io');
+var express = require('express');
+var routes = require('./routes')
+var http = require('http');
+var path = require('path');
+var chatsockets = require('./sockets/chat.js');
 
 var app = express();
-var crypto = require('crypto');
 
 app.configure(function(){
   app.set('port', process.env.PORT || 3000);
@@ -32,172 +31,11 @@ app.get('/', routes.index);
 app.post('/room', routes.room);
 
 var server = http.createServer(app);
-var io = socketIO.listen(server, {log:false});
+var io = require('socket.io').listen(server, {log:false});
 
 server.listen(app.get('port'), function(){
-  console.log("Express server listening on port " + app.get('port'));
+  console.log('Express server listening on port ' + app.get('port'));
 });
 
-// socket.ioのソケットを管理するオブジェクト
-var socketsOf = {};
-
-// 指定したroomIdに属するクライアントすべてに対しイベントを送信する
-function emitToRoom(roomId, event, data, fn) {
-  if (socketsOf[roomId] === undefined) {
-    return;
-  }
-  var sockets = socketsOf[roomId];
-  Object.keys(sockets).forEach(function (key) {
-    sockets[key].emit(event, data, fn);
-  });
-};
-
 // socket.ioのコネクション設定
-io.sockets.on('connection', function (socket) {
-
-  // コネクションが確立されたら'connected'メッセージを送信する
-  socket.emit('connected', {});
-
-  // 認証情報を確認する
-  socket.on('hash password', function (password, fn) {
-    var hashedPassword = '';
-    var shasum = crypto.createHash('sha512');
-
-    if (password !== '') {
-      shasum.update('initialhash');
-      shasum.update(password);
-      hashedPassword = shasum.digest('hex');
-    }
-    fn(hashedPassword);
-  });
-
-  // 認証情報を確認する
-  socket.on('check credential', function (client) {
-    // クライアントはconnectedメッセージを受信したら、minichatオブジェクトを
-    // 引数にこのメッセージを送信する
-
-    // 認証情報の確認
-    if (client.mode == 'create') {
-      // modeが'create'の場合、すでに対応するroomIdのチャットルームがないか
-      // チェックする
-      if (socketsOf[client.roomId] !== undefined) {
-        socket.emit('room exists', {});
-        return;
-      }
-      socketsOf[client.roomId] = {};
-    }
-
-    if (client.mode == 'enter') {
-      // 対応するroomIdのチャットルームの存在をチェックする
-      if (socketsOf[client.roomId] === undefined) {
-        socket.emit('invalid credential', {});
-        return;
-      }
-      // ユーザー名がかぶっていないかチェックする
-      if (socketsOf[client.roomId][client.userName] !== undefined) {
-        socket.emit('userName exists', {});
-        return;
-      }
-    }
-
-    // ソケットにクライアントの情報をセットする
-    socket.set('client', client, function () {
-      socketsOf[client.roomId][client.userName] = socket;
-      if (client.userName) {
-        console.log('user ' + client.userName + '@' + client.roomId + ' connected');
-      }
-    });
-
-    // 認証成功
-    socket.emit('credential ok', {});
-
-    // 既存クライアントにメンバーの変更を通知する
-    var members = Object.keys(socketsOf[client.roomId]);
-    emitToRoom(client.roomId, 'update members', members);
-
-    var shasum = crypto.createHash('sha1')
-    var message = {
-        from: 'システムメッセージ',
-        body: client.userName + 'さんが入室しました',
-        roomId: client.roomId
-    }
-    message.date = _formatDate(new Date());
-    shasum.update('-' + message.roomId);
-    message.id = (new Date()).getTime() + '-' + shasum.digest('hex');
-    emitToRoom(message.roomId, 'push message', message);
-
-  });
-
-  // ソケットが切断された場合、ソケット一覧からソケットを削除する
-  socket.on('disconnect', function () {
-    socket.get('client', function (err, client) {
-      if (err || !client) {
-        return;
-      }
-      var sockets = socketsOf[client.roomId];
-      if(sockets !== undefined) {
-        delete sockets[client.userName];
-      }
-      console.log('user ' + client.userName + '@' + client.roomId + ' disconnected');
-      var members = Object.keys(sockets);
-      if (members.length === 0) {
-        delete socketsOf[client.roomId];
-      } else {
-        // 既存クライアントにメンバーの変更を通知する
-        emitToRoom(client.roomId, 'update members', members);
-        var message = {
-          from: 'システムメッセージ',
-          body: client.userName + 'さんが退室しました',
-          roomId: client.roomId
-        }
-        var shasum = crypto.createHash('sha1')
-        message.date = _formatDate(new Date());
-        shasum.update('-' + message.roomId);
-        message.id = (new Date()).getTime() + '-' + shasum.digest('hex');
-        emitToRoom(message.roomId, 'push message', message);
-
-      }
-    });
-  });
-
-  // クライアントは'say'メッセージとともにチャットメッセージを送信する
-  socket.on('say', function (message, fn) {
-    console.log('receive message');
-
-    var shasum = crypto.createHash('sha1')
-    message.date = _formatDate(new Date());
-    shasum.update(message.userName + '-' + message.roomId);
-    message.id = (new Date()).getTime() + '-' + shasum.digest('hex');
-    emitToRoom(message.roomId, 'push message', message);
-    // クライアント側のコールバックを実行する
-    fn();
-  });
-
-  // クライアントはログが必要な場合'request log'メッセージを送信する
-  socket.on('request log', function (data) {
-    socket.get('client', function (err, client) {
-      if (err || client === undefined) {
-        return;
-      }
-      emitToRoom(client.roomId, 'request log', {}, function (log) {
-        socket.emit('update log', log);
-      });
-    });
-  });
-
-});
-
-function _formatDate(date) {
-  var mm = date.getMonth();
-  var dd = date.getDate();
-  var HH = date.getHours();
-  var MM = date.getMinutes();
-  if (HH < 10) {
-    HH = '0' + HH;
-  }
-  if (MM < 10) {
-    MM = '0' + MM;
-  }
-  return mm + '/' + dd + ' ' + HH + ':' + MM;
-};
-
+io.sockets.on('connection', chatsockets.onConnection);

--- a/public/js/minichat.js
+++ /dev/null
@@ -1,4 +0,0 @@
-// minichat.js
-
-(function () {
-}).apply(this);

--- /dev/null
+++ b/sockets/chat.js
@@ -0,0 +1,166 @@
+var crypto = require('crypto');
+
+// 指定したroomIdに属するクライアントすべてに対しイベントを送信する
+function emitToRoom(roomId, event, data, fn) {
+  if (socketsOf[roomId] === undefined) {
+    return;
+  }
+  var sockets = socketsOf[roomId];
+  Object.keys(sockets).forEach(function (key) {
+    sockets[key].emit(event, data, fn);
+  });
+};
+
+// Dateオブジェクトから日時を表す文字列を生成する
+function _formatDate(date) {
+  var mm = date.getMonth();
+  var dd = date.getDate();
+  var HH = date.getHours();
+  var MM = date.getMinutes();
+  if (HH < 10) {
+    HH = '0' + HH;
+  }
+  if (MM < 10) {
+    MM = '0' + MM;
+  }
+  return mm + '/' + dd + ' ' + HH + ':' + MM;
+};
+
+// socket.ioのソケットを管理するオブジェクト
+var socketsOf = {};
+
+// socket.ioのコネクション設定
+exports.onConnection = function (socket) {
+
+  // コネクションが確立されたら'connected'メッセージを送信する
+  socket.emit('connected', {});
+
+  // 認証情報を確認する
+  socket.on('hash password', function (password, fn) {
+    var hashedPassword = '';
+    var shasum = crypto.createHash('sha512');
+
+    if (password !== '') {
+      shasum.update('initialhash');
+      shasum.update(password);
+      hashedPassword = shasum.digest('hex');
+    }
+    fn(hashedPassword);
+  });
+
+  // 認証情報を確認する
+  socket.on('check credential', function (client) {
+    // クライアントはconnectedメッセージを受信したら、
+    // minichatオブジェクトを引数にこのメッセージを送信する
+
+    // 認証情報の確認
+    if (client.mode == 'create') {
+      // modeが'create'の場合、すでに対応するroomIdのチャットルームがないか
+      // チェックする
+      if (socketsOf[client.roomId] !== undefined) {
+        socket.emit('room exists', {});
+        return;
+      }
+      socketsOf[client.roomId] = {};
+    }
+
+    if (client.mode == 'enter') {
+      // 対応するroomIdのチャットルームの存在をチェックする
+      if (socketsOf[client.roomId] === undefined) {
+        socket.emit('invalid credential', {});
+        return;
+      }
+      // ユーザー名がかぶっていないかチェックする
+      if (socketsOf[client.roomId][client.userName] !== undefined) {
+        socket.emit('userName exists', {});
+        return;
+      }
+    }
+
+    // ソケットにクライアントの情報をセットする
+    socket.set('client', client, function () {
+      socketsOf[client.roomId][client.userName] = socket;
+      if (client.userName) {
+        console.log('user ' + client.userName + '@' + client.roomId + ' connected');
+      }
+    });
+
+    // 認証成功
+    socket.emit('credential ok', {});
+
+    // 既存クライアントにメンバーの変更を通知する
+    var members = Object.keys(socketsOf[client.roomId]);
+    emitToRoom(client.roomId, 'update members', members);
+
+    var shasum = crypto.createHash('sha1')
+    var message = {
+        from: 'システムメッセージ',
+        body: client.userName + 'さんが入室しました',
+        roomId: client.roomId
+    }
+    message.date = _formatDate(new Date());
+    shasum.update('-' + message.roomId);
+    message.id = (new Date()).getTime() + '-' + shasum.digest('hex');
+    emitToRoom(message.roomId, 'push message', message);
+
+  });
+
+  // ソケットが切断された場合、ソケット一覧からソケットを削除する
+  socket.on('disconnect', function () {
+    socket.get('client', function (err, client) {
+      if (err || !client) {
+        return;
+      }
+      var sockets = socketsOf[client.roomId];
+      if(sockets !== undefined) {
+        delete sockets[client.userName];
+      }
+      console.log('user ' + client.userName + '@' + client.roomId + ' disconnected');
+      var members = Object.keys(sockets);
+      if (members.length === 0) {
+        delete socketsOf[client.roomId];
+      } else {
+        // 既存クライアントにメンバーの変更を通知する
+        emitToRoom(client.roomId, 'update members', members);
+        var message = {
+          from: 'システムメッセージ',
+          body: client.userName + 'さんが退室しました',
+          roomId: client.roomId
+        }
+        var shasum = crypto.createHash('sha1')
+        message.date = _formatDate(new Date());
+        shasum.update('-' + message.roomId);
+        message.id = (new Date()).getTime() + '-' + shasum.digest('hex');
+        emitToRoom(message.roomId, 'push message', message);
+
+      }
+    });
+  });
+
+  // クライアントは'say'メッセージとともにチャットメッセージを送信する
+  socket.on('say', function (message, fn) {
+    console.log('receive message');
+
+    var shasum = crypto.createHash('sha1')
+    message.date = _formatDate(new Date());
+    shasum.update(message.userName + '-' + message.roomId);
+    message.id = (new Date()).getTime() + '-' + shasum.digest('hex');
+    emitToRoom(message.roomId, 'push message', message);
+    // クライアント側のコールバックを実行する
+    fn();
+  });
+
+  // クライアントはログが必要な場合'request log'メッセージを送信する
+  socket.on('request log', function (data) {
+    socket.get('client', function (err, client) {
+      if (err || client === undefined) {
+        return;
+      }
+      emitToRoom(client.roomId, 'request log', {}, function (log) {
+        socket.emit('update log', log);
+      });
+    });
+  });
+
+};
+

--- a/views/layout.jade
+++ b/views/layout.jade
@@ -5,7 +5,6 @@ html
     link(rel='stylesheet', href='/css/style.css')
     link(rel='stylesheet', href='/css/bootstrap.css')
     script(src='/js/jquery-1.8.2.min.js')
-    script(src='/js/minichat.js')
     script(src='/js/bootstrap.min.js')
     script(src='/socket.io/socket.io.js')
   body

--- a/views/room.jade
+++ b/views/room.jade
@@ -15,15 +15,12 @@ block content
       .container
         a.brand(href='/') minichat
         ul.nav
-          li 
-            a ルーム名：#{room.name}
-          li
-            a(href='/') 退出する
+          li: a ルーム名：#{room.name}
+          li: a(href='/') 退出する
   #main-contents.container
     .row
       .span4
-        h3
-          span#yourname #{user.name}
+        h3: span#yourname #{user.name}
         form
           label
             textarea#message.span4(rows='5', placeholder='メッセージを入力...')
@@ -59,7 +56,6 @@ block content
 
     .modal-footer
       a(href='/') トップページへ戻る
-    
 
   hr
   footer