public-mirrors/NewsBlur-viq
1
0
Fork 0
mirror of https://github.com/viq/NewsBlur.git synced 2025-09-18 21:43:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Handling socket level errors in socketio/node.

Browse source
This commit is contained in:
Samuel Clay 2013-08-12 11:52:29 -07:00
parent 456a4d1375
commit dcd37c4f50
2 changed files with 14 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
node/unread_counts.coffee
View file

@ -49,8 +49,8 @@ io.sockets.on 'connection', (socket) ->
if not @username
return
socket.subscribe?.on "error", (err) ->
console.log " ---> Error (pre): #{err}"
socket.on "error", (err) ->
console.log " ---> Error (socket): #{err}"
socket.subscribe?.end()
socket.subscribe = redis.createClient 6379, REDIS_SERVER
socket.subscribe.on "error", (err) ->
@ -72,3 +72,6 @@ io.sockets.on 'connection', (socket) ->
log.info @username, "Disconnect (#{@feeds?.length} feeds, #{ip})," +
" there are now #{io.sockets.clients().length-1} users. " +
" #{if SECURE then "(SSL)" else "(non-SSL)"}"
io.sockets.on 'error', (err) ->
console.log " ---> Error (sockets): #{err}"

16
node/unread_counts.js
View file

@ -40,7 +40,7 @@
var ip;
ip = socket.handshake.headers['x-real-ip'] || socket.handshake.address.address;
socket.on('subscribe:feeds', function(feeds, username) {
var _ref, _ref1,
var _ref,
_this = this;
this.feeds = feeds;
this.username = username;
@ -48,13 +48,11 @@
if (!this.username) {
return;
}
socket.on("error", function(err) {
return console.log(" ---> Error (socket): " + err);
});
if ((_ref = socket.subscribe) != null) {
_ref.on("error", function(err) {
return console.log(" ---> Error (pre): " + err);
});
}
if ((_ref1 = socket.subscribe) != null) {
_ref1.end();
_ref.end();
}
socket.subscribe = redis.createClient(6379, REDIS_SERVER);
socket.subscribe.on("error", function(err) {
@ -83,4 +81,8 @@
});
});
io.sockets.on('error', function(err) {
return console.log(" ---> Error (sockets): " + err);
});
}).call(this);