【Node.js】Socket.IO+MongoDBを使って保存できるチャットを作る方法

/**
 * Module dependencies.
 */
 
var express = require('express')
  , routes = require('./routes')
  , mongoose = require('mongoose');
 
var app = module.exports = express.createServer();
 
// Configuration
app.configure(function(){
  app.set('views', __dirname + '/views');
  app.set('view engine', 'ejs');
  app.use(express.bodyParser());
  app.use(express.methodOverride());
  app.use(express.cookieParser());
  app.use(express.session({ secret: 'your secret here' }));
  app.use(app.router);
  app.use(express.static(__dirname + '/public'));
});
 
app.configure('development', function(){
  app.use(express.errorHandler({ dumpExceptions: true, showStack: true }));
});
 
app.configure('production', function(){
  app.use(express.errorHandler());
});
 
// Routes
app.get('/', routes.index);
app.listen(3000, function(){
  console.log("Express server listening on port %d in %s mode", app.address().port, app.settings.env);
});
 
//mongoose
var Schema = mongoose.Schema;
var UserSchema = new Schema({
  message: String,
  date: Date
});
mongoose.model('User', UserSchema);
mongoose.connect('mongodb://localhost/chat_app');
var User = mongoose.model('User');
 
//socket
var io = require('socket.io').listen(app);
io.sockets.on('connection', function (socket) {
  socket.on('msg update', function(){
    //接続したらDBのメッセージを表示
    User.find(function(err, docs){
      socket.emit('msg open', docs);
    });
  });
 
  console.log('connected');
 
  socket.on('msg send', function (msg) {
    socket.emit('msg push', msg);
    socket.broadcast.emit('msg push', msg);
    //DBに登録
    var user = new User();
    user.message  = msg;
    user.date = new Date();
    user.save(function(err) {
      if (err) { console.log(err); }
    });
  });
 
  //DBにあるメッセージを削除
  socket.on('deleteDB', function(){
    socket.emit('db drop');
    socket.broadcast.emit('db drop');
    User.find().remove();
  });
 
  socket.on('disconnect', function() {
    console.log('disconnected');
  });
});

// Client
$(function() {
 
  var socket = io.connect('http://localhost');
 
  socket.on('connect', function() {
    socket.emit('msg update');
  });
 
  $('#btn').click(function() {
    var message = $('#message');
    socket.emit('msg send', message.val());
  });
 
  $('#delete').click(function(){
    socket.emit('deleteDB');
  });
 
  socket.on('msg push', function (msg) {
    var date = new Date();
    $('#list').prepend($('<dt>' + date + '</dt><dd>' + msg + '</dd>'));
  });
 
 
  //接続されたらDBにあるメッセージを表示
  socket.on('msg open', function(msg){
    //DBが空っぽだったら
    if(msg.length == 0){
        return;
    } else {
      $('#list').empty();
      $.each(msg, function(key, value){
        $('#list').prepend($('<dt>' + value.date + '</dt><dd>' + value.message + '</dd>'));
      });   
    }
  });
 
  //DBにあるメッセージを削除したので表示も消す
  socket.on('db drop', function(){
    $('#list').empty();
  });
 
});

//chat.js
 //接続されたらDBにあるメッセージを表示
  socket.on('msg open', function(msg){
    //DBが空っぽだったら
    if(msg.length == 0){
        return;
    } else {
      $('#list').empty();
      $.each(msg, function(key, value){
        $('#list').prepend($('<dt>' + value.date + '</dt><dd>' + value.message + '</dd>'));
      });   
    }
  });

//app.js
socket.on('msg send', function (msg) {
  socket.emit('msg push', msg); //自分へemit。
  socket.broadcast.emit('msg push', msg); //broadcastで相手側。
  //DBに登録
  var user = new User();
  user.message  = msg; //メッセージを代入。
  user.date = new Date(); //時間を記録。
  user.save(function(err) { //saveでMongoDBに登録。
    if (err) { console.log(err); }
  });
});

//chat.js
$('#delete').click(function(){
  socket.emit('deleteDB'); //emitしてapp.jsに伝えます。
});

//app.js
//DBにあるメッセージを削除
socket.on('deleteDB', function(){
  socket.emit('db drop'); //表示を消すためにchat.jsに伝えます。
  socket.broadcast.emit('db drop'); //broadcastで開いてる全員に伝えます。
  User.find().remove(); //データベースを削除します。
});

//chat.js
//DBにあるメッセージを削除したので表示も消す
socket.on('db drop', function(){
  $('#list').empty(); //表示を消す。
});