-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathserver.js
More file actions
106 lines (86 loc) · 2.8 KB
/
Copy pathserver.js
File metadata and controls
106 lines (86 loc) · 2.8 KB
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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
var express = require('express');
var app = express();
var server = require('http').createServer(app);
var io = require('socket.io').listen(server);
var moment = require('moment');
//var cors = require('cors');
// var bodyparser = require('body-parser');
// var mongoose = require('mongoose');
// var Schema = mongoose.Schema;
users = [];
connections = [];
//messages = [];
// let dev_db_url = 'mongodb://localhost:27017/chatapp';
// const mongoDB = process.env.MONGODB_URI || dev_db_url;
// mongoose.connect(mongoDB, {useNewUrlParser: true});
// mongoose.Promise = global.Promise;
// const db = mongoose.connection;
// db.on('error', console.error.bind(console, 'MongoDB Connection Error'));
// let Users = new Schema({
// username: {
// type: String,
// required: true
// },
// message: {
// type: String
// }
// });
server.listen(process.env.PORT || 4000);
server.listen(function () {
console.info('Server listening on port ' + this.address().port);
});
//app.use(cors());
app.get('/', function (req, res) {
res.sendFile(__dirname + '/index.html');
});
app.get('/users', function (req, res) {
res.send(users);
});
// app.get('/messages', function (req, res) {
// res.send();
// });
// //Connection with socket
io.sockets.on('connection', function (socket) {
connections.push(socket);
console.log('Connected: %s sockets Connected', connections.length);
//Disconnection with socket
socket.on('disconnnection', function (socket) {
//if(!socket.username) return;
users.splice(users.indexOf(socket.users), 1);
updateUsernames();
connections.splice(connections.indexOf(socket), 1);
//console.log('Disconnected: %s sockets Connected', connections.length);
});
//Send Message
socket.on('send message', function (data) {
io.sockets.emit('new message', {
msg: data,
user: socket.username,
time: moment().format('lll')
});
});
socket.on('typing', function (data) {
io.sockets.emit('typing', {
message: data.message,
user: data.user
});
});
// socket.on('get data', function (data) {
// io.sockets.emit('get data', {
// username: req.params.username,
// message: req.params.message
// });
// });
//New Users
socket.on('new user', function (message, callback) {
callback(true);
socket.username = message;
users.push(socket.username);
updateUsernames();
});
function updateUsernames() {
io.sockets.emit('get users', users);
}
console.log('Login Time: ', moment().format('lll'));
//console.log((users));
});