]>
Commit | Line | Data |
---|---|---|
1 | <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.1//EN" | |
2 | "http://www.w3.org/TR/xhtml11/DTD/xhtml11.dtd"> | |
3 | <html xmlns="http://www.w3.org/1999/xhtml"> | |
4 | <!-- | |
5 | reliable-chat - multipath chat | |
6 | Copyright (C) 2012 Scott Worley <sworley@chkno.net> | |
7 | Copyright (C) 2012 Jason Hibbs <skitch@gmail.com> | |
8 | ||
9 | This program is free software: you can redistribute it and/or modify | |
10 | it under the terms of the GNU Affero General Public License as | |
11 | published by the Free Software Foundation, either version 3 of the | |
12 | License, or (at your option) any later version. | |
13 | ||
14 | This program is distributed in the hope that it will be useful, | |
15 | but WITHOUT ANY WARRANTY; without even the implied warranty of | |
16 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
17 | GNU Affero General Public License for more details. | |
18 | ||
19 | You should have received a copy of the GNU Affero General Public License | |
20 | along with this program. If not, see <http://www.gnu.org/licenses/>. | |
21 | --> | |
22 | <head> | |
23 | <title>Reliable Chat</title> | |
24 | <style type="text/css"><!--/*--><![CDATA[/*><!--*/ | |
25 | html, body { | |
26 | width: 99.9%; | |
27 | height: 100%; | |
28 | margin: 0; | |
29 | padding: 0; | |
30 | background-color: #293134; | |
31 | color: silver; | |
32 | font-family: monospace; | |
33 | } | |
34 | a { | |
35 | color: white; | |
36 | } | |
37 | #container { | |
38 | height: 100%; | |
39 | } | |
40 | #status { | |
41 | width: 100%; | |
42 | text-align: right; | |
43 | background-color: #293134; | |
44 | padding: 5px 5px 5px 0px; | |
45 | } | |
46 | #client { | |
47 | width: 98.5%; | |
48 | padding: 0px 0px 0px 5px; | |
49 | height: 50px; | |
50 | position: fixed; | |
51 | bottom: 0; | |
52 | } | |
53 | #input { | |
54 | width: 100%; | |
55 | background-color: #293134; | |
56 | } | |
57 | #say { width: 100% } | |
58 | #history { | |
59 | padding: 0px 5px 55px 5px; | |
60 | vertical-align: bottom | |
61 | } | |
62 | .banner { | |
63 | font-size: 85%; | |
64 | text-align: right; | |
65 | } | |
66 | .servercount { | |
67 | margin-right: -0.5em; | |
68 | font-size: 70%; | |
69 | } | |
70 | .timestamp:hover, .timestamp:hover .servertimestamps { | |
71 | background-color: #556; | |
72 | } | |
73 | .timestamp:hover .servertimestamps { | |
74 | display: block; | |
75 | } | |
76 | .servertimestamps { | |
77 | display: none; | |
78 | position: absolute; | |
79 | left: 3em; | |
80 | z-index: 1; | |
81 | border: 1px solid black; | |
82 | border-radius: 5px; | |
83 | padding-left: 5px; | |
84 | padding-right: 5px; | |
85 | } | |
86 | img { width: 1px; height: 1px; } | |
87 | iframe { display: none } | |
88 | #status span { margin-right: 10px; } | |
89 | #status span.sad { | |
90 | background-color: #f00; | |
91 | color: #fff; | |
92 | border: 1px solid black; | |
93 | border-radius: 5px; | |
94 | padding-left: 5px; | |
95 | padding-right: 5px; | |
96 | } | |
97 | #status span.happy { | |
98 | background-color: #0f0; | |
99 | color: #000; | |
100 | border: 1px solid black; | |
101 | border-radius: 5px; | |
102 | padding-left: 5px; | |
103 | padding-right: 5px; | |
104 | } | |
105 | /*]]>*/--></style> | |
106 | <script type="text/javascript"><!--//--><![CDATA[//><!-- | |
107 | var servers = ['chkno.net', 'rc2.chkno.net', 'echto.net', 'the-wes.com', 'vibrantlogic.com']; | |
108 | ||
109 | var session = Math.random(); // For outgoing message IDs | |
110 | var since = {}; // server -> time: For fetch?since= | |
111 | var seen = {}; // seen_key -> message | |
112 | var history = []; // List of messages sorted by Time | |
113 | // Messages have these fields: | |
114 | // Time: The timestamp. Median of ServerTimes | |
115 | // ID: Some unique string for deduping | |
116 | // Text: The text of the message | |
117 | // ServerTimes: server -> timestamp | |
118 | // UI: The DOM node for this message in the UI | |
119 | ||
120 | function rcnick() { | |
121 | var nick = localStorage.getItem("nick"); | |
122 | if (nick) { | |
123 | return nick; | |
124 | } | |
125 | return 'anonymous'; | |
126 | } | |
127 | ||
128 | function rcsetnick(new_nick) { | |
129 | localStorage.setItem("nick", new_nick); | |
130 | } | |
131 | ||
132 | function rcserverbase(server) { | |
133 | // Add the default port if server doesn't contain a port number already | |
134 | if (server.indexOf(":") == -1) { | |
135 | return "http://" + server + ":21059"; | |
136 | } else { | |
137 | return "http://" + server; | |
138 | } | |
139 | } | |
140 | ||
141 | function rcchangeserverstatus(server, new_status) { | |
142 | var statusbar = document.getElementById("status"); | |
143 | var spans = statusbar.getElementsByTagName("span"); | |
144 | for (var i in spans) { | |
145 | if (spans[i].firstChild && 'data' in spans[i].firstChild && spans[i].firstChild.data == server) { | |
146 | spans[i].setAttribute("class", new_status); | |
147 | } | |
148 | } | |
149 | } | |
150 | ||
151 | function rcpad2(x) { | |
152 | return (x < 10 ? "0" : "") + x; | |
153 | } | |
154 | function rcpad3(x) { | |
155 | return (x < 10 ? "00" : (x < 100 ? "0" : "")) + x; | |
156 | } | |
157 | ||
158 | function rcformattime(t) { | |
159 | var d = t.getDay(); | |
160 | d = ["Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat"][d]; | |
161 | var h = t.getHours(); | |
162 | var m = t.getMinutes(); | |
163 | var s = t.getSeconds(); | |
164 | return d + " " + rcpad2(h) + ":" + rcpad2(m) + ":" + rcpad2(s); | |
165 | } | |
166 | ||
167 | function rcaddservertimestamptohover(message, server) { | |
168 | var divs = message.UI.getElementsByTagName("div"); | |
169 | var t = message.ServerTimes[server]; | |
170 | for (var i in divs) { | |
171 | if (divs[i].getAttribute && divs[i].getAttribute("class") == "servertimestamps") { | |
172 | var d = document.createElement("div"); | |
173 | var text = t.getFullYear() + "-" + | |
174 | rcpad2(t.getMonth()) + "-" + | |
175 | rcpad2(t.getDay()) + " " + | |
176 | rcformattime(t) + "." + | |
177 | rcpad3(t.getMilliseconds()) + " " + | |
178 | server; | |
179 | d.appendChild(document.createTextNode(text)); | |
180 | divs[i].appendChild(d); | |
181 | } | |
182 | } | |
183 | } | |
184 | ||
185 | function rcmakemessageUI(message) { | |
186 | message.UI = document.createElement("div"); | |
187 | ||
188 | // Server count | |
189 | var servercount = document.createElement("span"); | |
190 | servercount.setAttribute("class", "servercount"); | |
191 | servercount.appendChild(document.createTextNode(Object.keys(message.ServerTimes).length)); | |
192 | message.UI.appendChild(servercount); | |
193 | message.UI.appendChild(document.createTextNode(" ")); | |
194 | ||
195 | // Timestamp | |
196 | var timestamp_text = message.Time ? rcformattime(message.Time) : ""; | |
197 | var timestamp = document.createElement("span"); | |
198 | timestamp.setAttribute("class", "timestamp"); | |
199 | timestamp.appendChild(document.createTextNode(timestamp_text)); | |
200 | message.UI.appendChild(timestamp); | |
201 | message.UI.appendChild(document.createTextNode(" ")); | |
202 | ||
203 | // Timestamp hover | |
204 | var timestamp_hover = document.createElement("div"); | |
205 | timestamp_hover.setAttribute("class", "servertimestamps"); | |
206 | timestamp.appendChild(timestamp_hover); | |
207 | for (var server in message.ServerTimes) { | |
208 | rcaddservertimestamptohover(message, server); | |
209 | } | |
210 | ||
211 | // Classify different message types | |
212 | var text_span = document.createElement("span"); | |
213 | var type; | |
214 | if (/^\*\*\* /.test(message.Text)) { | |
215 | type = "status"; | |
216 | } else if (/^\* /.test(message.Text)) { | |
217 | type = "me"; | |
218 | } else { | |
219 | type = "text"; | |
220 | } | |
221 | if (Object.keys(message.ServerTimes).length == 0) { | |
222 | type += " self"; | |
223 | } | |
224 | text_span.setAttribute("class", type); | |
225 | ||
226 | // URL detection | |
227 | var text = message.Text; | |
228 | var URL_re = /\bhttps?:\/\/\S+/; | |
229 | while (URL_re.test(text)) { | |
230 | var match = URL_re.exec(text); | |
231 | var leading_text = text.substr(0, match.index); | |
232 | if (leading_text) { | |
233 | text_span.appendChild(document.createTextNode(leading_text)); | |
234 | } | |
235 | var anchor = document.createElement("a"); | |
236 | anchor.setAttribute("rel", "nofollow"); | |
237 | anchor.setAttribute("href", encodeURI(match[0])); | |
238 | anchor.appendChild(document.createTextNode(match[0])); | |
239 | text_span.appendChild(anchor); | |
240 | text = text.substr(match.index + match[0].length); | |
241 | } | |
242 | if (text) { | |
243 | text_span.appendChild(document.createTextNode(text)); | |
244 | } | |
245 | ||
246 | message.UI.appendChild(text_span); | |
247 | } | |
248 | ||
249 | function rcaddmessagetohistory(message) { | |
250 | var message_i; | |
251 | if (message.Time) { | |
252 | for (var i = history.length - 1; ; i--) { | |
253 | if (i < 0 || (history[i].Time && message.Time >= history[i].Time)) { | |
254 | message_i = i+1; | |
255 | history.splice(message_i, 0, message); | |
256 | break; | |
257 | } | |
258 | } | |
259 | } else { | |
260 | history.push(message); | |
261 | message_i = history.length-1; | |
262 | } | |
263 | ||
264 | if (!message.UI) { | |
265 | rcmakemessageUI(message); | |
266 | } | |
267 | var h = document.getElementById("history"); | |
268 | if (message_i + 1 < history.length) { | |
269 | h.insertBefore(message.UI, history[message_i + 1].UI); | |
270 | } else { | |
271 | h.appendChild(message.UI); | |
272 | } | |
273 | window.scrollTo(0, document.body.scrollHeight); | |
274 | } | |
275 | ||
276 | function make_seen_key(id, text) { | |
277 | return id.replace(/@/g, "@@") + "_@_" + text.replace(/@/g, "@@"); | |
278 | } | |
279 | ||
280 | function rcupdatemessagetime(message) { | |
281 | // Set message.Time to be the median of message.ServerTimes | |
282 | var times = []; | |
283 | for (var i in message.ServerTimes) { | |
284 | times.push(message.ServerTimes[i]); | |
285 | } | |
286 | times.sort(); | |
287 | if (times.length % 2) { | |
288 | message.Time = times[(times.length-1)/2]; | |
289 | } else { | |
290 | var middle = times.length/2; | |
291 | var difference = times[middle].getTime() - times[middle-1].getTime(); | |
292 | message.Time = new Date(times[middle-1].getTime() + difference/2); | |
293 | } | |
294 | ||
295 | // This may have broken history's in-sorted-order invariant | |
296 | var hi = history.indexOf(message); | |
297 | if ((history[hi-1] && history[hi-1].Time > message.Time) || | |
298 | (history[hi+1] && history[hi+1].Time < message.Time)) { | |
299 | history.splice(hi,1); | |
300 | rcaddmessagetohistory(message); | |
301 | } | |
302 | ||
303 | // Update the UI | |
304 | var spans = message.UI.getElementsByTagName("span"); | |
305 | for (var i in spans) { | |
306 | if (spans[i].getAttribute) { | |
307 | var type = spans[i].getAttribute("class"); | |
308 | if (type == "servercount") { | |
309 | spans[i].firstChild.data = Object.keys(message.ServerTimes).length; | |
310 | } else if (type == "timestamp") { | |
311 | spans[i].firstChild.data = rcformattime(message.Time); | |
312 | } | |
313 | } | |
314 | } | |
315 | } | |
316 | ||
317 | function rcreceivemessages(server, messages) { | |
318 | for (var i in messages) { | |
319 | var m = messages[i]; | |
320 | m.Time = new Date(m.Time); | |
321 | var seen_key = make_seen_key(m.ID, m.Text); | |
322 | if (seen_key in seen) { | |
323 | seen[seen_key].ServerTimes[server] = m.Time; | |
324 | rcupdatemessagetime(seen[seen_key]); | |
325 | rcaddservertimestamptohover(seen[seen_key], server); | |
326 | } else { | |
327 | m.ServerTimes = {}; | |
328 | m.ServerTimes[server] = m.Time; | |
329 | seen[seen_key] = m; | |
330 | rcaddmessagetohistory(m); | |
331 | for (var i in servers) { | |
332 | rcchangeserverstatus(servers[i], "sad"); | |
333 | } | |
334 | } | |
335 | rcchangeserverstatus(server, "happy"); | |
336 | } | |
337 | } | |
338 | ||
339 | function rcfetch(server) { | |
340 | var delay = 10000; // TODO: Exponential backoff | |
341 | var xhr = new XMLHttpRequest(); | |
342 | xhr.onreadystatechange = function() { | |
343 | if (this.readyState == this.DONE) { | |
344 | if (this.status == 200) { | |
345 | var rtxt = this.responseText; | |
346 | if (rtxt != null) { | |
347 | var messages = JSON.parse(rtxt); | |
348 | if (messages != null) { | |
349 | delay = 40; | |
350 | if (messages.length >= 1 && "Time" in messages[messages.length-1]) { | |
351 | since[server] = messages[messages.length-1].Time; | |
352 | } | |
353 | rcreceivemessages(server, messages); | |
354 | } | |
355 | } | |
356 | } | |
357 | window.setTimeout(rcfetch, delay, server); | |
358 | } | |
359 | } | |
360 | var uri = rcserverbase(server) + "/fetch"; | |
361 | if (server in since) { | |
362 | uri += '?since="' + since[server] + '"'; | |
363 | } | |
364 | xhr.open("GET", uri); | |
365 | xhr.send(); | |
366 | } | |
367 | ||
368 | function rcconnect() { | |
369 | for (var i in servers) { | |
370 | rcfetch(servers[i]); | |
371 | // Status bar entry | |
372 | var status_indicator = document.createElement("span"); | |
373 | status_indicator.appendChild(document.createTextNode(servers[i])); | |
374 | status_indicator.setAttribute("class", "sad"); | |
375 | document.getElementById("status").appendChild(status_indicator); | |
376 | } | |
377 | } | |
378 | ||
379 | function rcsend(d, message) { | |
380 | message.ID = new Date().getTime() + "-" + session + "-" + Math.random(); | |
381 | seen[make_seen_key(message.ID, message.Text)] = message; | |
382 | var path = "/speak" + | |
383 | "?id=" + encodeURIComponent(message.ID) + | |
384 | "&text=" + encodeURIComponent(message.Text); | |
385 | for (var i in servers) { | |
386 | var uri = rcserverbase(servers[i]) + path; | |
387 | var img = document.createElement("img"); | |
388 | img.setAttribute("src", uri); | |
389 | d.appendChild(img); | |
390 | } | |
391 | } | |
392 | ||
393 | function rcinput(input) { | |
394 | var message; | |
395 | var re = /^\/([a-z]+) (.*)/ | |
396 | var match = re.exec(input); | |
397 | if (match && match[1] == 'me') { | |
398 | message = "* " + rcnick() + " " + match[2]; | |
399 | } else if (match && match[1] == 'nick') { | |
400 | message = "*** " + rcnick() + " is now known as " + match[2]; | |
401 | rcsetnick(match[2]); | |
402 | } else { | |
403 | message = "<" + rcnick() + "> " + input; | |
404 | } | |
405 | ||
406 | var m = {'Text': message, 'ServerTimes': {}}; | |
407 | rcaddmessagetohistory(m); | |
408 | rcsend(m.UI, m); | |
409 | } | |
410 | ||
411 | function rckeydown(event) { | |
412 | if (event.keyCode == 13) { | |
413 | rcinput(document.input.say.value); | |
414 | document.input.say.value = ""; | |
415 | ||
416 | } | |
417 | } | |
418 | //--><!]]></script> | |
419 | ||
420 | </head> | |
421 | ||
422 | <body onload="rcconnect()"> | |
423 | <div id="container"> | |
424 | <div class="banner">(You are using <a href="https://github.com/chkno/reliable-chat">Reliable Chat</a>)</div> | |
425 | <div id="history"></div> | |
426 | <div id="client"> | |
427 | <div id="input"> | |
428 | <form name="input" onsubmit="return false" autocomplete="off"> | |
429 | <input id="say" onkeydown="return rckeydown(event)" autocomplete="off" autofocus="autofocus"></input> | |
430 | </form></div> | |
431 | <div id="status"> </div> | |
432 | </div> | |
433 | </div> | |
434 | </body> | |
435 | </html> |