-
Notifications
You must be signed in to change notification settings - Fork 104
/
Copy pathapp.js
100 lines (87 loc) · 2.64 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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
var fs = require('fs'),
url = require('url'),
http = require('http'),
path = require('path'),
mime = require('mime'),
io = require('socket.io');
var httpServer = http.createServer(function(request, response) {
var pathname = url.parse(request.url).pathname;
if(pathname == "/") pathname = "index.html";
var filename = path.join(process.cwd(), 'public', pathname);
path.exists(filename, function(exists) {
if(!exists) {
response.writeHead(404, { "Content-Type": "text/plain" });
response.write("404 Not Found");
response.end();
return;
}
response.writeHead(200, { 'Content-Type': mime.lookup(filename) });
fs.createReadStream(filename, {
'flags': 'r',
'encoding': 'binary',
'mode': 0666,
'bufferSize': 4 * 1024
}).addListener("data", function(chunk) {
response.write(chunk, 'binary');
}).addListener("close", function() {
response.end();
});
});
});
var connectedUsers = {};
var webSocket = io.listen(httpServer);
if(process.env.NODE_ENV == 'production') {
webSocket.configure(function () {
webSocket.set("transports", ["xhr-polling"]);
webSocket.set("polling duration", 10);
});
}
webSocket.sockets.on('connection', function(socket) {
socket.on('join', function(user, sendKey) {
user.key = Date.now();
socket.set('userkey', user.key);
sendKey(user.key);
connectedUsers[user.key] = user;
socket.broadcast.emit("user connected", user);
});
socket.on('message', function(msg) {
socket.get('userkey', function(err, key) {
var user = connectedUsers[key];
if(user) {
var data = {
key : key,
sender : user.name,
message : msg
};
socket.broadcast.emit('new chat msg',data);
}
});
});
socket.on("send location", function(data) {
socket.get('userkey', function(err, key) {
var user = connectedUsers[key];
if(user) {
user.lat = data.lat;
user.lng = data.lng;
data.name = user.name
data.key = key;
socket.broadcast.emit("location update", data);
}
});
});
socket.on("request locations", function(sendData) {
sendData(connectedUsers);
});
socket.on('disconnect', function() {
socket.get('userkey', function(err, key) {
var userInfo = connectedUsers[key];
if(userInfo) {
console.log('User ', userInfo.username, ' has disconnected. Key = ', key);
delete connectedUsers[key];
socket.broadcast.emit("user disconnected", key);
}
});
});
});
httpServer.listen(process.env.PORT || 8080, "0.0.0.0");
console.log('Server running at 8080');