-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathapp.js
86 lines (73 loc) · 1.98 KB
/
app.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
var express =require('express'),
app = express(),
server = require('http').createServer(app),
io = require('socket.io').listen(server),
mongoose = require('mongoose'),
users = {};
server.listen(80);
mongoose.connect('mongodb://localhost/m_chat',function(err){
if(err){
console.log(err);
}else{
console.log('Connected to mongodb');
}
});
var chatSchema = mongoose.Schema({
// name:{first:String,last:String},
nick:String,
msg:String,
created:{type:Date,default:Date.now}
});
var Chat = mongoose.model('Message',chatSchema);
app.get('/',function(req,res){
res.sendfile(__dirname + '/index.html');
});
io.sockets.on('connection',function(socket){
var query = Chat.find({});
query.sort('-created').limit(8).exec(function(err,docs){
if(err) throw err;
console.log('sending old msgs');
socket.emit('load old msgs',docs);
});
socket.on('new user',function(data,callback){
if(data in users){
callback(false);
}else{
callback(true);
socket.nickname = data;
users[socket.nickname] = socket;
updateNicknames();
}
});
function updateNicknames(){
io.sockets.emit('usernames',Object.keys(users));
}
socket.on('send message',function(data,callback){
var msg = data.trim();
if(msg.substr(0,3) === '/w '){
msg = msg.substr(3);
var ind = msg.indexOf(' ');
if(ind !== -1){
var name = msg.substring(0,ind);
var msg = msg.substring(ind + 1);
if(name in users){
users[name].emit('whisper',{msg:msg,nick:socket.nickname});
console.log('Whisper');
}
}else{
callback('Error! Enter a message');
}
}else{
var newMsg = new Chat({msg:msg,nick:socket.nickname});
newMsg.save(function(err){
if(err) throw err;
io.sockets.emit('new message',{msg:msg,nick:socket.nickname});
});
}
});
socket.on('disconnect',function(data){
if(!socket.nickname) return;
delete users[socket.nickname];
updateNicknames();
});
});