typo
This commit is contained in:
@@ -68,7 +68,7 @@ var sendChannelMessage = function (ctx, channel, msg, cb) {
|
|||||||
sendMsg(msg, user.socket);
|
sendMsg(msg, user.socket);
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
console.log(e.stack);
|
console.log(e.stack);
|
||||||
try { dropClient(ctx, user.userPass); } catch (e) { }
|
try { user.socket.close(); } catch (e) { }
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
cb && cb();
|
cb && cb();
|
||||||
@@ -130,7 +130,6 @@ console.log("[" + userPass + "] registered");
|
|||||||
};
|
};
|
||||||
if (user.socket && user.socket !== socket) { user.socket.close(); }
|
if (user.socket && user.socket !== socket) { user.socket.close(); }
|
||||||
user.socket = socket;
|
user.socket = socket;
|
||||||
user.userPass = userPass;
|
|
||||||
|
|
||||||
var chan = ctx.channels[parsed.channelId] = ctx.channels[parsed.channelId] || [];
|
var chan = ctx.channels[parsed.channelId] = ctx.channels[parsed.channelId] || [];
|
||||||
var newChan = (chan.length === 0);
|
var newChan = (chan.length === 0);
|
||||||
@@ -142,7 +141,7 @@ console.log("[" + userPass + "] registered");
|
|||||||
|
|
||||||
var sendMsgs = function () {
|
var sendMsgs = function () {
|
||||||
sendChannelMessage(ctx, chan, msg, function () {
|
sendChannelMessage(ctx, chan, msg, function () {
|
||||||
chan.push(client);
|
chan.push(user);
|
||||||
ctx.store.getMessages(chan.name, function (msg) {
|
ctx.store.getMessages(chan.name, function (msg) {
|
||||||
try {
|
try {
|
||||||
sendMsg(msg, socket);
|
sendMsg(msg, socket);
|
||||||
|
|||||||
Reference in New Issue
Block a user