Commit: 00ab1e144e417bc42d78ae9d8415f1fbc7c19b64 - node_sample_minichat (git)

Node.js sample application with Socket.IO

Commit MetaInfo

• Revision: 00ab1e144e417bc42d78ae9d8415f1fbc7c19b64 (tree)
• Zeit: 2012-10-25 00:32:15
• Autor: hylom <hylom@hylo...>
• Commiter: hylom

Log Message

fix basic socket connection protocol

Ändern Zusammenfassung

• modified: app.js
• modified: public/js/minichat.js
• add: public/js/room.js
• modified: routes/index.js
• modified: views/room.jade

Diff

--- a/app.js
+++ b/app.js
@@ -37,3 +37,30 @@ var io = socketIO.listen(server);
 server.listen(app.get('port'), function(){
   console.log("Express server listening on port " + app.get('port'));
 });
+
+var socketsOf = {};
+
+io.sockets.on('connection', function (socket) {
+  socket.emit('connected', {});
+  socket.on('regist request', function (data) {
+    console.log('regist client for ' + data.roomId);
+    if (socketsOf[data.roomId] !== undefined) {
+      socketsOf[data.roomId].push(socket);
+    } else {
+      socketsOf[data.roomId] = [socket];
+    }
+  });
+
+  socket.on('say', function (data) {
+    console.log('receive message');
+    socket.emit('say accept', {});
+    if (socketsOf[data.roomId] !== undefined) {
+      var targets = socketsOf[data.roomId];
+      for (var i = 0; i < targets.length; i++) {
+        targets[i].emit('push message', data);
+      }
+    }
+  });
+
+});
+

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

--- /dev/null
+++ b/public/js/room.js
@@ -0,0 +1,34 @@
+// room.js
+
+
+(function () {
+  var socket;
+
+  // ページロード時の処理
+  $(document).ready(function () {
+    // ユーザー名、ルーム名、パスワードを送信
+    socket = io.connect('http://localhost');
+    // ページロード時の処理ここまで
+    socket.on('connected', function(data) {
+      socket.emit('regist request', {roomId: minichat.roomId});
+    });
+    socket.on('push message', function (data) {
+      alert(data.message);
+    });
+    socket.on('say accept', function (data) {
+      $('#message').val('');
+    });
+  });
+
+  $('#post-message').live('click', function () {
+    socket.emit('say', {
+      name: minichat.userName,
+      message: $('#message').val(),
+      roomId: minichat.roomId
+    });
+  });
+
+
+
+}).apply(this);
+

--- a/routes/index.js
+++ b/routes/index.js
@@ -9,13 +9,24 @@ exports.index = function(req, res){
 };
 
 exports.echo = function(req, res) {
+  var roomName = req.params.name;
+  var yourName = 'test';
+  var password = 'minichattest';
+  var hashedPassword = '';
+  var shasum = crypto.createHash('sha512');
+
+  if (password !== '') {
+    shasum.update(password);
+    hashedPassword = shasum.digest('hex');
+  }
+
   var params = {
-    title: 'チャットルーム：' + req.params.name,
+    title: 'チャットルーム：' + roomName,
     room: {
-      name: req.params.name,
-      password: ''
+      name: roomName,
+      password: hashedPassword
     },
-    user: {name: ''}
+    user: {name: yourName}
   };
   res.render('room', params);
 };

--- a/views/room.jade
+++ b/views/room.jade
@@ -1,5 +1,13 @@
 extends layout
 block content
+  script(src='/js/room.js')
+  script
+    var minichat = {
+      roomName: '#{room.name}',
+      password: '#{room.password}',
+      userName: '#{user.name}',
+      roomId: '#{room.name}#{room.password}'
+    };
 
   .navbar.navbar-inverse.navbar-fixed-top
     .navbar-inner
@@ -15,16 +23,18 @@ block content
       .span4
         h3
           span#yourname #{user.name}
-        form(action='#')
+        form
           label
-            textarea#new-message.span4(rows='5', placeholder='メッセージを入力...')
-          button(type='submit', class='btn') メッセージを投稿
+            textarea#message.span4(rows='5', placeholder='メッセージを入力...')
+          button#post-message.btn.btn-primary(type='button') メッセージを投稿
       .span8
         #messages.well
           .message
             p.postdate.pull-right 10/23 12:34
             p.author システムメッセージ：
             p.comment チャットルーム「hogehoge」が作成されました。HASH: #{room.password}
+
+
   hr
   footer
-    p minichat 0.0.1
\ No newline at end of file
+    p minichat 0.0.1