Mercurial > urweb

annotate lib/js/urweb.js @ 925:552c989c1601

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Change string URLification to avoid using the empty string, which confuses Apache no2slash()
author Adam Chlipala <adamc@hcoop.net>
date Sat, 12 Sep 2009 09:31:50 -0400
parents 771449d8b411
children d136bc34e4ca
rev   line source
adamc@692 1 // Lists
adamc@692 2
adamc@580 3 function cons(v, ls) {
adamc@690 4 return { next : ls, data : v };
adamc@690 5 }
adamc@690 6 function concat(ls1, ls2) {
adamc@690 7 return (ls1 ? cons(ls1.data, concat(ls1.next, ls2)) : ls2);
adamc@690 8 }
adamc@690 9 function member(x, ls) {
adamc@690 10 for (; ls; ls = ls.next)
adamc@690 11 if (ls.data == x)
adamc@690 12 return true;
adamc@690 13 return false;
adamc@690 14 }
adamc@690 15 function remove(x, ls) {
adamc@690 16 return (ls ? (ls.data == x ? ls.next : cons(ls.data, remove(x, ls.next))) : null);
adamc@690 17 }
adamc@690 18 function union(ls1, ls2) {
adamc@690 19 return (ls1 ? (member(ls1.data, ls2) ? union(ls1.next, ls2) : cons(ls1.data, union(ls1.next, ls2))) : ls2);
adamc@580 20 }
adamc@703 21 function length(ls) {
adamc@703 22 return (ls ? 1 + length(ls.next) : 0);
adamc@703 23 }
adamc@670 24
adamc@690 25
adamc@729 26 // Error handling
adamc@729 27
adamc@729 28 function whine(msg) {
adamc@729 29 alert(msg);
adamc@729 30 throw msg;
adamc@729 31 }
adamc@729 32
adamc@810 33 function pf(loc) {
adamc@835 34 throw ("Pattern match failure (" + loc + ")");
adamc@729 35 }
adamc@729 36
adamc@798 37 function runHandlers(kind, ls, arg) {
adamc@798 38 if (ls == null)
adamc@798 39 alert(kind + ": " + arg);
adamc@729 40 for (; ls; ls = ls.next)
adamc@729 41 try {
adamc@729 42 ls.data(arg)(null);
adamc@729 43 } catch (v) { }
adamc@729 44 }
adamc@729 45
adamc@729 46 var errorHandlers = null;
adamc@729 47
adamc@729 48 function onError(f) {
adamc@729 49 errorHandlers = cons(f, errorHandlers);
adamc@729 50 }
adamc@729 51
adamc@729 52 function er(s) {
adamc@798 53 runHandlers("Error", errorHandlers, s);
adamc@729 54 throw {uw_error: s};
adamc@729 55 }
adamc@729 56
adamc@729 57 var failHandlers = null;
adamc@729 58
adamc@729 59 function onFail(f) {
adamc@729 60 failHandlers = cons(f, failHandlers);
adamc@729 61 }
adamc@729 62
adamc@729 63 function doExn(v) {
adamc@729 64 if (v == null || v.uw_error == null) {
adamc@729 65 var s = (v == null ? "null" : v.toString());
adamc@798 66 runHandlers("Fail", failHandlers, s);
adamc@729 67 }
adamc@729 68 }
adamc@729 69
adamc@729 70 var disconnectHandlers = null;
adamc@729 71
adamc@729 72 function onDisconnect(f) {
adamc@729 73 disconnectHandlers = cons(function (_){return f}, disconnectHandlers);
adamc@729 74 }
adamc@729 75
adamc@729 76 function discon() {
adamc@798 77 runHandlers("Disconnect", disconnectHandlers, null);
adamc@729 78 }
adamc@729 79
adamc@729 80 var connectHandlers = null;
adamc@729 81
adamc@729 82 function onConnectFail(f) {
adamc@729 83 connectHandlers = cons(function (_){return f}, connectHandlers);
adamc@729 84 }
adamc@729 85
adamc@729 86 function conn() {
adamc@798 87 runHandlers("Connect", connectHandlers, null);
adamc@729 88 }
adamc@729 89
adamc@729 90 var serverHandlers = null;
adamc@729 91
adamc@729 92 function onServerError(f) {
adamc@729 93 serverHandlers = cons(f, serverHandlers);
adamc@729 94 }
adamc@729 95
adamc@729 96 function servErr(s) {
adamc@824 97 window.setTimeout(function () { runHandlers("Server", serverHandlers, s); }, 0);
adamc@729 98 }
adamc@729 99
adamc@729 100
adamc@692 101 // Embedding closures in XML strings
adamc@692 102
adamc@693 103 function cs(f) {
adamc@693 104 return {closure: f};
adamc@693 105 }
adamc@693 106
adamc@693 107 function isWeird(v) {
adamc@693 108 return v.closure != null || v.cat1 != null;
adamc@693 109 }
adamc@693 110
adamc@692 111 function cat(s1, s2) {
adamc@693 112 if (isWeird(s1) || isWeird(s2))
adamc@693 113 return {cat1: s1, cat2: s2};
adamc@693 114 else
adamc@692 115 return s1 + s2;
adamc@692 116 }
adamc@692 117
adamc@692 118 var closures = [];
adamc@703 119 var freeClosures = null;
adamc@692 120
adamc@692 121 function newClosure(f) {
adamc@703 122 var n;
adamc@703 123 if (freeClosures == null) {
adamc@703 124 n = closures.length;
adamc@703 125 } else {
adamc@703 126 n = freeClosures.data;
adamc@703 127 freeClosures = freeClosures.next;
adamc@703 128 }
adamc@692 129 closures[n] = f;
adamc@692 130 return n;
adamc@692 131 }
adamc@692 132
adamc@703 133 function freeClosure(n) {
adamc@703 134 closures[n] = null;
adamc@703 135 freeClosures = cons(n, freeClosures);
adamc@703 136 }
adamc@703 137
adamc@692 138 function cr(n) {
adamc@692 139 return closures[n]();
adamc@692 140 }
adamc@692 141
adamc@703 142 function flatten(cls, tr) {
adamc@693 143 if (tr.cat1 != null)
adamc@703 144 return flatten(cls, tr.cat1) + flatten(cls, tr.cat2);
adamc@703 145 else if (tr.closure != null) {
adamc@703 146 var cl = newClosure(tr.closure);
adamc@703 147 cls.v = cons(cl, cls.v);
adamc@703 148 return "cr(" + cl + ")";
adamc@703 149 } else
adamc@692 150 return tr;
adamc@692 151 }
adamc@692 152
adamc@728 153 function flattenLocal(s) {
adamc@728 154 var cls = {v : null};
adamc@728 155 var r = flatten(cls, s);
adamc@728 156 for (cl = cls.v; cl != null; cl = cl.next)
adamc@728 157 freeClosure(cl.data);
adamc@728 158 return r;
adamc@728 159 }
adamc@728 160
adamc@692 161
adamc@692 162
adamc@692 163 // Dynamic tree management
adamc@692 164
adamc@690 165 function populate(node) {
adamc@690 166 var s = node.signal;
adamc@690 167 var oldSources = node.sources;
adamc@729 168 try {
adamc@729 169 var sr = s();
adamc@729 170 var newSources = sr.sources;
adamc@690 171
adamc@729 172 for (var sp = oldSources; sp; sp = sp.next)
adamc@729 173 if (!member(sp.data, newSources))
adamc@729 174 sp.data.dyns = remove(node, sp.data.dyns);
adamc@690 175
adamc@729 176 for (var sp = newSources; sp; sp = sp.next)
adamc@729 177 if (!member(sp.data, oldSources))
adamc@729 178 sp.data.dyns = cons(node, sp.data.dyns);
adamc@690 179
adamc@729 180 node.sources = newSources;
adamc@729 181 node.recreate(sr.data);
adamc@729 182 } catch (v) {
adamc@729 183 doExn(v);
adamc@729 184 }
adamc@579 185 }
adamc@574 186
adamc@580 187 function sc(v) {
adamc@690 188 return {data : v, dyns : null};
adamc@580 189 }
adamc@580 190 function sv(s, v) {
adamc@690 191 s.data = v;
adamc@690 192 for (var ls = s.dyns; ls; ls = ls.next)
adamc@690 193 if (!ls.dead)
adamc@690 194 populate(ls.data);
adamc@580 195 }
adamc@601 196 function sg(s) {
adamc@690 197 return s.data;
adamc@601 198 }
adamc@579 199
adamc@580 200 function ss(s) {
adamc@690 201 return function() { return {sources : cons(s, null), data : s.data } };
adamc@580 202 }
adamc@580 203 function sr(v) {
adamc@690 204 return function() { return {sources : null, data : v } };
adamc@580 205 }
adamc@580 206 function sb(x,y) {
adamc@690 207 return function() {
adamc@690 208 var xr = x();
adamc@690 209 var yr = y(xr.data)();
adamc@690 210 return {sources : union(xr.sources, yr.sources), data : yr.data};
adamc@690 211 };
adamc@580 212 }
adamc@841 213 function scur(s) {
adamc@841 214 return s().data;
adamc@841 215 }
adamc@571 216
adamc@604 217 function lastParent() {
adamc@604 218 var pos = document;
adamc@604 219
adamc@600 220 while (pos.lastChild && pos.lastChild.nodeType == 1)
adamc@600 221 pos = pos.lastChild;
adamc@600 222
adamc@600 223 return pos.parentNode;
adamc@600 224 }
adamc@600 225
adamc@898 226 function parent() {
adamc@898 227 return thisScript ? thisScript.parentNode : lastParent();
adamc@898 228 }
adamc@898 229
adamc@604 230 function addNode(node) {
adamc@899 231 if (thisScript)
adamc@899 232 thisScript.parentNode.replaceChild(node, thisScript);
adamc@899 233 else
adamc@604 234 lastParent().appendChild(node);
adamc@603 235 }
adamc@603 236
adamc@690 237 var thisScript = null;
adamc@690 238
adamc@604 239 function runScripts(node) {
adamc@899 240 if (node.getElementsByTagName) {
adamc@899 241 var savedScript = thisScript;
adamc@603 242
adamc@899 243 var scripts = node.getElementsByTagName("script"), scriptsCopy = [];
adamc@899 244 var len = scripts.length;
adamc@899 245 for (var i = 0; i < len; ++i)
adamc@899 246 scriptsCopy[i] = scripts[i];
adamc@899 247 for (var i = 0; i < len; ++i) {
adamc@899 248 thisScript = scriptsCopy[i];
adamc@899 249 try {
adamc@899 250 eval(thisScript.textContent);
adamc@899 251 } catch (v) {
adamc@899 252 doExn(v);
adamc@899 253 }
adamc@899 254 if (thisScript.parentNode)
adamc@901 255 thisScript.parentNode.removeChild(thisScript);
adamc@729 256 }
adamc@899 257
adamc@899 258 thisScript = savedScript;
adamc@604 259 }
adamc@603 260 }
adamc@603 261
adamc@603 262
adamc@692 263 // Dynamic tree entry points
adamc@692 264
adamc@901 265 function dyn(pnode, s) {
adamc@901 266 var x = document.createElement("script");
adamc@690 267 x.dead = false;
adamc@690 268 x.signal = s;
adamc@690 269 x.sources = null;
adamc@703 270 x.closures = null;
adamc@899 271
adamc@902 272 var firstChild = null;
adamc@899 273
adamc@690 274 x.recreate = function(v) {
adamc@703 275 for (var ls = x.closures; ls; ls = ls.next)
adamc@703 276 freeClosure(ls.data);
adamc@692 277
adamc@902 278 var next;
adamc@902 279 for (var child = firstChild; child && child != x; child = next) {
adamc@902 280 next = child.nextSibling;
adamc@901 281 if (child.getElementsByTagName) {
adamc@901 282 var arr = child.getElementsByTagName("script");
adamc@899 283 for (var i = 0; i < arr.length; ++i) {
adamc@899 284 var span = arr[i];
adamc@899 285 span.dead = true;
adamc@899 286 for (var ls = span.sources; ls; ls = ls.next)
adamc@899 287 ls.data.dyns = remove(span, ls.data.dyns);
adamc@899 288 for (var ls = span.closures; ls; ls = ls.next)
adamc@899 289 freeClosure(ls.data);
adamc@899 290 }
adamc@847 291 }
adamc@847 292
adamc@901 293 if (child.parentNode)
adamc@901 294 child.parentNode.removeChild(child);
adamc@899 295 }
adamc@690 296
adamc@703 297 var cls = {v : null};
adamc@901 298 var html = flatten(cls, v);
adamc@703 299 x.closures = cls.v;
adamc@899 300
adamc@901 301 if (pnode == "table") {
adamc@901 302 var dummy = document.createElement("body");
adamc@901 303 dummy.innerHTML = "<table>" + html + "</table>";
adamc@901 304 runScripts(dummy);
adamc@901 305 var table = x.parentNode;
adamc@901 306
adamc@901 307 var arr = dummy.getElementsByTagName("tbody");
adamc@902 308 firstChild = null;
adamc@905 309 if (arr.length > 0 && table != null) {
adamc@901 310 var tbody = arr[0], next;
adamc@902 311 firstChild = document.createElement("script");
adamc@902 312 table.insertBefore(firstChild, x);
adamc@901 313 for (var node = tbody.firstChild; node; node = next) {
adamc@901 314 next = node.nextSibling;
adamc@902 315 table.insertBefore(node, x);
adamc@901 316 }
adamc@901 317 }
adamc@903 318 } else if (pnode == "tr") {
adamc@903 319 var dummy = document.createElement("body");
adamc@903 320 dummy.innerHTML = "<table><tr>" + html + "</tr></table>";
adamc@903 321 runScripts(dummy);
adamc@903 322 var table = x.parentNode;
adamc@903 323
adamc@903 324 var arr = dummy.getElementsByTagName("tr");
adamc@903 325 firstChild = null;
adamc@905 326 if (arr.length > 0 && table != null) {
adamc@903 327 var tbody = arr[0], next;
adamc@903 328 firstChild = document.createElement("script");
adamc@903 329 table.insertBefore(firstChild, x);
adamc@903 330 for (var node = tbody.firstChild; node; node = next) {
adamc@903 331 next = node.nextSibling;
adamc@903 332 table.insertBefore(node, x);
adamc@903 333 }
adamc@903 334 }
adamc@901 335 } else {
adamc@902 336 firstChild = document.createElement("span");
adamc@902 337 firstChild.innerHTML = html;
adamc@902 338 runScripts(firstChild);
adamc@900 339 if (x.parentNode)
adamc@902 340 x.parentNode.insertBefore(firstChild, x);
adamc@899 341 }
adamc@690 342 };
adamc@899 343
adamc@899 344 addNode(x);
adamc@690 345 populate(x);
adamc@571 346 }
adamc@582 347
adamc@817 348 function input(t, s, recreate) {
adamc@598 349 var x = document.createElement(t);
adamc@690 350 x.dead = false;
adamc@690 351 x.signal = ss(s);
adamc@690 352 x.sources = null;
adamc@817 353 x.recreate = recreate(x);
adamc@899 354 addNode(x);
adamc@690 355 populate(x);
adamc@816 356
adamc@816 357 return x;
adamc@816 358 }
adamc@816 359
adamc@816 360 function inp(s) {
adamc@817 361 var x = input("input", s, function(x) { return function(v) { if (x.value != v) x.value = v; }; });
adamc@816 362 x.value = s.data;
adamc@816 363 x.onkeyup = function() { sv(s, x.value) };
adamc@816 364
adamc@816 365 return x;
adamc@816 366 }
adamc@816 367
adamc@816 368 function sel(s, content) {
adamc@817 369 var x = input("select", s, function(x) { return function(v) { if (x.value != v) x.value = v; }; });
adamc@816 370 x.innerHTML = content;
adamc@816 371 x.value = s.data;
adamc@835 372 if (x.value != s.data)
adamc@835 373 sv(s, x.value);
adamc@816 374 x.onchange = function() { sv(s, x.value) };
adamc@797 375
adamc@606 376 return x;
adamc@598 377 }
adamc@598 378
adamc@817 379 function chk(s) {
adamc@817 380 var x = input("input", s, function(x) { return function(v) { if (x.checked != v) x.checked = v; }; });
adamc@817 381 x.type = "checkbox";
adamc@817 382 x.checked = s.data;
adamc@817 383 x.onchange = function() { sv(s, x.checked) };
adamc@817 384
adamc@817 385 return x;
adamc@817 386 }
adamc@817 387
adamc@800 388 function addOnChange(x, f) {
adamc@800 389 var old = x.onchange;
adamc@800 390 x.onchange = function() { old(); f (); };
adamc@800 391 }
adamc@800 392
adamc@692 393
adamc@692 394 // Basic string operations
adamc@692 395
adamc@597 396 function eh(x) {
adamc@800 397 if (x == null)
adamc@800 398 return "NULL";
adamc@800 399 else
adamc@800 400 return x.split("&").join("&amp;").split("<").join("&lt;").split(">").join("&gt;");
adamc@597 401 }
adamc@597 402
adamc@582 403 function ts(x) { return x.toString() }
adamc@586 404 function bs(b) { return (b ? "True" : "False") }
adamc@586 405
adamc@828 406 function sub(s, i) { return s[i]; }
adamc@828 407 function suf(s, i) { return s.substring(i); }
adamc@828 408 function slen(s) { return s.length; }
adamc@829 409 function sidx(s, ch) {
adamc@829 410 var r = s.indexOf(ch);
adamc@829 411 if (r == -1)
adamc@829 412 return null;
adamc@829 413 else
adamc@829 414 return r;
adamc@829 415 }
adamc@831 416 function sspn(s, chs) {
adamc@831 417 for (var i = 0; i < s.length; ++i)
adamc@831 418 if (chs.indexOf(s[i]) != -1)
adamc@831 419 return i;
adamc@831 420
adamc@831 421 return null;
adamc@831 422 }
adamc@829 423 function schr(s, ch) {
adamc@829 424 var r = s.indexOf(ch);
adamc@829 425 if (r == -1)
adamc@829 426 return null;
adamc@829 427 else
adamc@829 428 return s.substring(r);
adamc@829 429 }
adamc@829 430 function ssub(s, start, len) {
adamc@829 431 return s.substring(start, start+len);
adamc@829 432 }
adamc@821 433
adamc@649 434 function pi(s) {
adamc@649 435 var r = parseInt(s);
adamc@649 436 if (r.toString() == s)
adamc@649 437 return r;
adamc@649 438 else
adamc@729 439 er("Can't parse int: " + s);
adamc@649 440 }
adamc@649 441
adamc@649 442 function pfl(s) {
adamc@649 443 var r = parseFloat(s);
adamc@649 444 if (r.toString() == s)
adamc@649 445 return r;
adamc@649 446 else
adamc@729 447 er("Can't parse float: " + s);
adamc@649 448 }
adamc@649 449
adamc@838 450 function pio(s) {
adamc@838 451 var r = parseInt(s);
adamc@838 452 if (r.toString() == s)
adamc@838 453 return r;
adamc@838 454 else
adamc@838 455 return null;
adamc@838 456 }
adamc@838 457
adamc@838 458 function pflo(s) {
adamc@838 459 var r = parseFloat(s);
adamc@838 460 if (r.toString() == s)
adamc@838 461 return r;
adamc@838 462 else
adamc@838 463 return null;
adamc@838 464 }
adamc@838 465
adamc@692 466 function uf(s) {
adamc@925 467 if (s.length == 0)
adamc@925 468 return "_";
adamc@925 469 return (s[0] == '_' ? "_" : "")
adamc@925 470 + escape(s).replace(new RegExp ("/", "g"), "%2F").replace(new RegExp ("\\+", "g"), "%2B");
adamc@691 471 }
adamc@691 472
adamc@692 473 function uu(s) {
adamc@925 474 if (s.length > 0 && s[0] == '_')
adamc@925 475 s = s.substring(1);
adamc@905 476 return unescape(s.replace(new RegExp ("\\+", "g"), " "));
adamc@905 477 }
adamc@905 478
adamc@912 479 function ub(b) {
adamc@912 480 return b ? "1" : "0";
adamc@912 481 }
adamc@912 482
adamc@905 483 function uul(getToken, getData) {
adamc@905 484 var tok = getToken();
adamc@905 485 if (tok == "Nil") {
adamc@905 486 return null;
adamc@905 487 } else if (tok == "Cons") {
adamc@905 488 var d = getData();
adamc@905 489 var l = uul(getToken, getData);
adamc@905 490 return {_1:d, _2:l};
adamc@905 491 } else
adamc@905 492 throw ("Can't unmarshal list (" + tok + ")");
adamc@692 493 }
adamc@692 494
adamc@692 495
adamc@603 496
adamc@692 497 // Remote calls
adamc@609 498
adamc@703 499 var client_id = null;
adamc@668 500 var client_pass = 0;
adamc@668 501 var url_prefix = "/";
adamc@673 502 var timeout = 60;
adamc@668 503
adamc@668 504 function getXHR(uri)
adamc@609 505 {
adamc@609 506 try {
adamc@609 507 return new XMLHttpRequest();
adamc@609 508 } catch (e) {
adamc@609 509 try {
adamc@609 510 return new ActiveXObject("Msxml2.XMLHTTP");
adamc@609 511 } catch (e) {
adamc@609 512 try {
adamc@609 513 return new ActiveXObject("Microsoft.XMLHTTP");
adamc@609 514 } catch (e) {
adamc@609 515 throw "Your browser doesn't seem to support AJAX.";
adamc@609 516 }
adamc@609 517 }
adamc@609 518 }
adamc@609 519 }
adamc@609 520
adamc@736 521 var sig = null;
adamc@736 522
adamc@736 523 function requestUri(xhr, uri, needsSig) {
adamc@668 524 xhr.open("GET", uri, true);
adamc@668 525
adamc@703 526 if (client_id != null) {
adamc@668 527 xhr.setRequestHeader("UrWeb-Client", client_id.toString());
adamc@668 528 xhr.setRequestHeader("UrWeb-Pass", client_pass.toString());
adamc@668 529 }
adamc@668 530
adamc@736 531 if (needsSig) {
adamc@736 532 if (sig == null)
adamc@736 533 whine("Missing cookie signature!");
adamc@736 534
adamc@736 535 xhr.setRequestHeader("UrWeb-Sig", sig);
adamc@736 536 }
adamc@736 537
adamc@668 538 xhr.send(null);
adamc@668 539 }
adamc@668 540
adamc@736 541 function rc(uri, parse, k, needsSig) {
adamc@728 542 uri = flattenLocal(uri);
adamc@609 543 var xhr = getXHR();
adamc@609 544
adamc@609 545 xhr.onreadystatechange = function() {
adamc@612 546 if (xhr.readyState == 4) {
adamc@612 547 var isok = false;
adamc@612 548
adamc@612 549 try {
adamc@612 550 if (xhr.status == 200)
adamc@612 551 isok = true;
adamc@612 552 } catch (e) { }
adamc@612 553
adamc@729 554 if (isok) {
adamc@729 555 try {
adamc@729 556 k(parse(xhr.responseText));
adamc@729 557 } catch (v) {
adamc@729 558 doExn(v);
adamc@729 559 }
adamc@729 560 } else {
adamc@729 561 conn();
adamc@649 562 }
adamc@612 563 }
adamc@609 564 };
adamc@609 565
adamc@736 566 requestUri(xhr, uri, needsSig);
adamc@609 567 }
adamc@667 568
adamc@667 569 function path_join(s1, s2) {
adamc@667 570 if (s1.length > 0 && s1[s1.length-1] == '/')
adamc@667 571 return s1 + s2;
adamc@667 572 else
adamc@667 573 return s1 + "/" + s2;
adamc@667 574 }
adamc@667 575
adamc@670 576 var channels = [];
adamc@670 577
adamc@670 578 function newQueue() {
adamc@670 579 return { front : null, back : null };
adamc@670 580 }
adamc@670 581 function enqueue(q, v) {
adamc@670 582 if (q.front == null) {
adamc@670 583 q.front = cons(v, null);
adamc@670 584 q.back = q.front;
adamc@670 585 } else {
adamc@670 586 var node = cons(v, null);
adamc@690 587 q.back.next = node;
adamc@670 588 q.back = node;
adamc@670 589 }
adamc@670 590 }
adamc@670 591 function dequeue(q) {
adamc@670 592 if (q.front == null)
adamc@670 593 return null;
adamc@670 594 else {
adamc@690 595 var r = q.front.data;
adamc@690 596 q.front = q.front.next;
adamc@670 597 if (q.front == null)
adamc@670 598 q.back = null;
adamc@670 599 return r;
adamc@670 600 }
adamc@670 601 }
adamc@670 602
adamc@670 603 function newChannel() {
adamc@670 604 return { msgs : newQueue(), listeners : newQueue() };
adamc@670 605 }
adamc@670 606
adamc@667 607 function listener() {
adamc@668 608 var uri = path_join(url_prefix, ".msgs");
adamc@667 609 var xhr = getXHR();
adamc@673 610 var tid, orsc, onTimeout;
adamc@673 611
adamc@673 612 var connect = function () {
adamc@673 613 xhr.onreadystatechange = orsc;
adamc@673 614 tid = window.setTimeout(onTimeout, timeout * 500);
adamc@736 615 requestUri(xhr, uri, false);
adamc@673 616 }
adamc@673 617
adamc@673 618 orsc = function() {
adamc@667 619 if (xhr.readyState == 4) {
adamc@673 620 window.clearTimeout(tid);
adamc@673 621
adamc@667 622 var isok = false;
adamc@667 623
adamc@667 624 try {
adamc@667 625 if (xhr.status == 200)
adamc@667 626 isok = true;
adamc@667 627 } catch (e) { }
adamc@667 628
adamc@668 629 if (isok) {
adamc@889 630 var text = xhr.responseText
adamc@889 631 if (text == "")
adamc@889 632 return;
adamc@889 633 var lines = text.split("\n");
adamc@889 634
adamc@729 635 if (lines.length < 2) {
adamc@729 636 discon();
adamc@729 637 return;
adamc@729 638 }
adamc@669 639
adamc@669 640 for (var i = 0; i+1 < lines.length; i += 2) {
adamc@670 641 var chn = lines[i];
adamc@670 642 var msg = lines[i+1];
adamc@670 643
adamc@670 644 if (chn < 0)
adamc@670 645 whine("Out-of-bounds channel in message from remote server");
adamc@670 646
adamc@670 647 var ch;
adamc@670 648
adamc@670 649 if (chn >= channels.length || channels[chn] == null) {
adamc@670 650 ch = newChannel();
adamc@670 651 channels[chn] = ch;
adamc@670 652 } else
adamc@670 653 ch = channels[chn];
adamc@670 654
adamc@670 655 var listener = dequeue(ch.listeners);
adamc@670 656 if (listener == null) {
adamc@670 657 enqueue(ch.msgs, msg);
adamc@670 658 } else {
adamc@728 659 try {
adamc@728 660 listener(msg);
adamc@728 661 } catch (v) {
adamc@728 662 doExn(v);
adamc@728 663 }
adamc@670 664 }
adamc@669 665 }
adamc@669 666
adamc@673 667 connect();
adamc@668 668 }
adamc@667 669 else {
adamc@729 670 try {
adamc@824 671 if (xhr.status != 0)
adamc@824 672 servErr("Error querying remote server for messages: " + xhr.status);
adamc@889 673 } catch (e) { }
adamc@667 674 }
adamc@667 675 }
adamc@667 676 };
adamc@667 677
adamc@673 678 onTimeout = function() {
adamc@673 679 xhr.abort();
adamc@673 680 connect();
adamc@673 681 };
adamc@673 682
adamc@673 683 connect();
adamc@667 684 }
adamc@670 685
adamc@670 686 function rv(chn, parse, k) {
adamc@682 687 if (chn == null)
adamc@682 688 return;
adamc@682 689
adamc@670 690 if (chn < 0)
adamc@670 691 whine("Out-of-bounds channel receive");
adamc@670 692
adamc@670 693 var ch;
adamc@670 694
adamc@670 695 if (chn >= channels.length || channels[chn] == null) {
adamc@670 696 ch = newChannel();
adamc@670 697 channels[chn] = ch;
adamc@670 698 } else
adamc@670 699 ch = channels[chn];
adamc@670 700
adamc@670 701 var msg = dequeue(ch.msgs);
adamc@670 702 if (msg == null) {
adamc@670 703 enqueue(ch.listeners, function(msg) { k(parse(msg))(null); });
adamc@670 704 } else {
adamc@728 705 try {
adamc@728 706 k(parse(msg))(null);
adamc@728 707 } catch (v) {
adamc@728 708 doExn(v);
adamc@728 709 }
adamc@670 710 }
adamc@670 711 }
adamc@693 712
adamc@693 713
adamc@895 714 // Key events
adamc@895 715
adamc@895 716 function kc(e) {
adamc@895 717 return window.event ? e.keyCode : e.which;
adamc@895 718 }
adamc@895 719
adamc@895 720
adamc@693 721 // App-specific code
adamc@693 722