-
Notifications
You must be signed in to change notification settings - Fork 66
/
channel.js
107 lines (93 loc) · 2.28 KB
/
channel.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
101
102
103
104
105
106
107
var sys = require("sys"),
Session = require("./session").Session;
function Channel(name, options) {
// TODO: handle invalid name and/or basePath
options = options || {};
this.name = name;
this.basePath = options.basePath || ("/" + name);
this.messageBacklog = options.messageBacklog || 200;
this.sessionTimeout = (options.sessionTimeout || 60) * 1000;
this.messages = [];
this.callbacks = [];
this.sessions = {};
}
process.mixin(Channel.prototype, {
appendMessage: function(nick, type, text) {
var message = {
nick: nick,
type: type,
text: text,
timestamp: (new Date()).getTime()
};
this.messages.push(message);
switch (type) {
case "msg":
sys.puts("<" + nick + "> " + text);
break;
case "join":
sys.puts(nick + " join");
break;
case "part":
sys.puts(nick + " part");
break;
}
while (this.callbacks.length > 0) {
this.callbacks.shift().callback([message]);
}
while (this.messages.length > this.messageBacklog) {
sys.puts("shifing message");
this.messages.shift();
}
},
query: function(since, callback) {
// TODO: just use .slice()
var matching = [];
for (var i = 0; i < this.messages.length; i++) {
var message = this.messages[i];
if (message.timestamp > since) {
matching.push(message);
}
}
if (matching.length) {
callback(matching);
} else {
this.callbacks.push({
timestamp: new Date(),
callback: callback
});
}
},
flushCallbacks: function() {
var now = new Date();
while (this.callbacks.length && now - this.callbacks[0].timestamp > this.sessionTimeout / 2) {
this.callbacks.shift().callback([]);
}
},
createSession: function(nick) {
var session = new Session(nick);
if (!session) {
return;
}
nick = nick.toLowerCase();
for (var i in this.sessions) {
if (this.sessions[i].nick.toLowerCase() === nick) {
return;
}
}
this.sessions[session.id] = session;
return session;
},
destroySession: function(id) {
this.appendMessage(this.sessions[id].nick, "part");
delete this.sessions[id];
},
expireOldSessions: function() {
var now = new Date();
for (var session in this.sessions) {
if (now - this.sessions[session].timestamp > this.sessionTimeout) {
this.destroySession(session);
}
}
}
});
exports.Channel = Channel;