-
Notifications
You must be signed in to change notification settings - Fork 0
/
server.js
66 lines (55 loc) · 1.8 KB
/
server.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
const mongo = require('mongodb').MongoClient
const client = require('socket.io').listen(4000).sockets
//connect to mongodb
mongo.connect('mongodb://127.0.0.1:27017/mongochat', { useNewUrlParser: true }, (err, clientObject) => {
if(err){
throw err
}
console.log('MongoDB Connected...')
//connect to Socket.ii
client.on('connection', (socket) => {
// let chat = clientObject.db.collection('chats')
let db = clientObject.db()
let chat = db.collection('chats')
//Create function to send status
sendStatus = (s) => {
socket.emit('status', s)
}
//get chats from mongo collection
chat.find().limit(100).sort({_id:1}).toArray((err, res) => {
if(err){
throw err
}
//emit the messages
socket.emit('output', res)
})
//handle input events
socket.on('input', (data) => {
console.log(data)
let name = data.name
let message = data.message
//check for name and message
if(name == '' || message == ''){
sendStatus('Please enter a name and message!')
}else{
// insert to db
chat.insert({name: name, message: message}, () => {
client.emit('output', [data])
//send status object
sendStatus({
message: 'Message Sent',
clear: true
})
})
}
})
//handle clear
socket.on('clear', (data) => {
// remove all chats from collection
chat.remove({}, () => {
socket.emit('cleared')
})
})
})
// db.close();
})