Changeset 842 for trunk

Timestamp:

12/16/11 02:37:52 (5 months ago)

Author:

FeepingCreature

Message:

Stuff

Files:

• trunk/idc/dice.d (modified) (1 diff)
• trunk/idc/dsss.conf (modified) (1 diff)
• trunk/idc/idc.d (modified) (53 diffs)
• trunk/idc/irc.d (modified) (10 diffs)
• trunk/idc/pad/cgi.d (modified) (9 diffs)
• trunk/idc/pad/engine.d (modified) (14 diffs)
• trunk/idc/pad/mainloop.d (modified) (8 diffs)
• trunk/idc/pad/utils.d (modified) (4 diffs)

trunk/idc/dice.d

@@ -289 +289 @@
-    res = stuple(res, times) /apply/ (typeof(res) dg, typeof(times) times) {
-      auto tv = times();
+      if (tv.sum > 128) throw new Exception("Cannot roll more than 128 dice. ");
-      Result r; 
-      // r.text = Format(tv.info, "x [");

trunk/idc/dsss.conf

@@ -5 +5 @@
-# [dice.d]
-# target=dice
+[pad/cgi.d]
+target=cgi
+buildflags=-g -L-lbz2 -J.
+[pad/console.d]
+target=console
+buildflags=-g -L-lbz2 -J.

trunk/idc/idc.d

@@ -1 +1 @@
-module idc; // Internet delay chat! Yay!
-
-, std.string
+
-import tools.log, tools.threads, tools.threadpool;
-import tools.time;
-
-import irc;
-import std.process;
-alias std.process.system system;
-
-import cah;
+
+extern(C) void exit(int);
+
+alias irc.tolower tolower;
-
-string characters(string s) {
@@ -19 +21 @@
-
-string clean(string s) {
-
+
+
+
-}
-
@@ -76 +80 @@
-
-import std.file;
+import std.process;
+alias std.process.system system;
+
-void reload(Query query) {
-  if (system("sh -c \"make >/dev/null 2> /tmp/idc_errors || exit 1\"") != 0) {
@@ -105 +112 @@
-  if (site) q = "site:"~site~" "~q;
-  auto hash = "http://www.google.com/uds/?file=search&v=1.0".download().between("JSHash = '", "'");
-google.search.W
+Gw
-  // if (site) url ~= "&as_sitesearch="~site;
-
-
+
+
+
+
+
-  // if (!res.length) throw new Exception("Cannot identify Google result for "~url);
-  if (!res.startsWith("http://")) res = "http://"~res;
@@ -212 +222 @@
-bool pwn_site(string url, ref string[string] urls, ref string src) {
-  if (url.find("youtube.com") != -1) {
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-    return true;
-  }
@@ -254 +287 @@
-  }
-  void do_megavideo(string hit) {
-
-
-
-
-
-
+
+
+
+
-    auto link = hit.between("v=", "&");
-    if (link.find("\"") != -1) link = link.between("", "\"");
@@ -304 +335 @@
-}
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
-
-void gun(Query query) {
-b
+B
-  query.answer(gs);
-}
-
-void fwoosh_upd(Query query) {
-b
+B
-}
-
-import std.utf;
-string htmlFormat(string s) {
-w
+d
-  s.glomp_parse([
->"[]: (string pre, ref string post) { res ~= pre.toUTF16(
+"[]: (string pre, ref string post) { res ~= pre.toUTF32(); post.slice(">"
-    "</sup>": (string pre, ref string post) {
-      bool onlyAsciiHighables = true, onlyUnicodeHighables = true;
-      foreach (ch; pre) {
-        if (ch < '1' || ch > '3') onlyAsciiHighables = false;
-ch != '-' && ch != '+' && ch != ' '
+" +-=[]()Nn".find(ch) == -1
-      }
-      if (onlyAsciiHighables) {
@@ -360 +363 @@
-            case '2': res ~= '²'; break;
-            case '3': res ~= '³'; break;
-            case ' ': res ~= ' '; break;
-            default: assert(false);
-          }
@@ -375 +377 @@
-            case '+': res ~= '⁺'; break;
-            case '-': res ~= '⁻'; break;
+            case '=': res ~= '⁌'; break;
+            case '[', '(': res ~= '⁜'; break;
+            case ']', ')': res ~= ' '; break;
+            case 'N', 'n': res ~= 'ⁿ'; break;
-            default: assert(false);
-          }
-        }
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-    },
-    "<font": (string pre, ref string post) {
-16
- = post[post.find(">")+1 .. $]
+32
+.slice(">")
-    },
-
-
-
+
+
+
+
+
+
+
+
-}
-
@@ -419 +456 @@
-  string res;
-  const string exclude = "-intitle:\"Discussion\" -inurl:editors.php -inurl:inboundcount.php -inurl:posts.php";
-
+
+
-    res = (exclude~" \"pmwiki.php/main/"~q~"\"").googleQuery("tvtropes.org");
-
+
+
-    res = (exclude~" \""~q~"\"").googleQuery("tvtropes.org");
-
+
+
-    res = (exclude~" "~q).googleQuery("tvtropes.org");
+  }
-  auto alt = res.between("", "?");
-  query.answer(alt?alt:res);
@@ -701 +742 @@
-  }
-  unref;
-fn -> a, b -> fn(a.count, b.count)")(&cmp!(int)
+a, b -> a.count < b.count"
-  if (!res[$-1].count) {
-    return query.say("Time's up and nobody voted! Sorry. Better luck next time!");
@@ -941 +982 @@
-  (ref int[string] stats, ref string[string] namestats, string user, string host) {
-    string country;
+    if (host.endsWith(".hmsk")) return;;
-    auto parts = host.split(".");
-    while (parts.length > 1) {
@@ -948 +990 @@
-        country = GeoIP.lookup(ip);
-        break;
-
+logln("fail: ", ex); 
-    }
-    if (!country) return;
@@ -960 +1002 @@
-    }
-  }, stuple(stats, namestats, query) /apply/ (ref int[string] stats, ref string[string] namestats, Query query) {
+    if (!stats.length) return query.answer("No country stats available. This is probably due to hostmasking. ");
-    auto rstats = invert(stats), top = rstats.keys.sort;
-    string[][int] res;
@@ -1010 +1053 @@
-
-import std.stream;
-bridget
+readers, writers
-
-void bridge(Query query) {
@@ -1022 +1065 @@
-    // query.say("Setting up read pipe on |", params[2], "|");
-    bridge_read = new File(params[2], FileMode.In);
+    readers[ch] = bridge_read;
-  }
-  void setupWrite() {
-    // query.say("Setting up write pipe on |", params[3], "|");
-bridget
+writers
-  }
-  if (order == "first") {
@@ -1041 +1085 @@
-}
-
+void listen(Query query) {
+  if (query.name != root_user) return query.answer("You are not authorized to set up a listen pipe! ");
+  auto file = new File(query.param, FileMode.In);
+  readers["<main>"] = file;
+  while (true) {
+    auto cmd = file.readLine();
+    query.connection.raw_sendln(IRCFormat(cmd));
+  }
+}
+
-void wbOnJoin(Query query) {
-//   sleep(1);
@@ -1047 +1101 @@
-//   q2.notice("No it hasn't. STFU GreetBot you tard. ");
-  // query.answer(Format("wbOnJoin(", query, ")"));
+  if (query.channel == "#yackfest") return;
-  auto ch = query.channel.replace("#", ""), name = cast(string) query.name;
-  if (!wbfile.has(ch.clean(), name)) return;
@@ -1064 +1119 @@
-    // else q.say(": not in file");
-    
-notes ~
+auto privnotes 
-    if (notefile.has("global", name)) notefile.del("global", name);
-    
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-}
-
-void dbg(Query q) {
-
+
+
+
-}
-
-void addnote(Query q) {
-
+, checked
-  if (auto rest = q.param.startsWith("global ")) {
-    q.param = rest;
-    global = true;
-  }
-
+
+
+
+
+
+
-  // if (!q.connection.registered(q.name)) {
-  //   return q.answer("You have to be registered to do that! ");
@@ -1099 +1181 @@
-    foreach (note; notes)
-      if (note._0 == cast(string) q.name.tolower()) count++;
-
-
+
+
+
+
+
+
+
-    notefile.set(a, b, notes);
-    return q.notice("Note saved! ");
@@ -1122 +1209 @@
-  }
-  auto ch = query.channel.replace("#", "");
-
+.strip()
-  if (nick.startsWith("<")) {
-    query.param = nick ~ " " ~ query.param; // part of message
-    nick = nick[1 .. $];
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
-  if (cast(nickname) nick == query.name && query.name != root_user) return query.answer("Please don't selfquote! ");
-  last_added[ch.clean() ~ "\x00" ~ cast(string) query.name] = nick;
@@ -1223 +1319 @@
-  }
-  auto text = std.string.join(parts, "\n  ==========\n");
+  if (text.length > 64000) {
+    query.answer("Hosting locally. ");
+    auto fn = "quotes_"~ch~".txt";
+    auto localfn = "/home/mathis/public_html/"~fn;
+    localfn.write(text);
+    system("chmod a+r "~localfn);
+    query.answer("http://demented.no-ip.org/~feep/"~fn);
+    return;
+  }
+  query.answer("Uploading ", text.length, "b .. ");
-  return query.answer(pastepost(text, query.connection.nick, "d"));
-}
@@ -1239 +1345 @@
-  temp[] flat;
-  foreach (key, value; answer) flat ~= temp(value, key);
-fn -> a, b -> fn(a.key, b.key)")(&cmp!(int)
+a, b -> a.key < b.key"
-  query.answer("WB stats: ", std.string.join(flat /map/ ex!("a -> a.val"), "; "));
-}
@@ -1248 +1354 @@
-struct PixivSession {
-  string session_id;
-qqqwwwqqq", Pass = "qqqwwwqqq
+guest1234", Pass = "bugmenot
-  string relogin() {
-    logln("Acquiring new session id");
@@ -1299 +1405 @@
-string getTitle(string url, string src = null) {
-  try return _getTitle(url, src);
-
+
+
+
+
+
-}
-
@@ -1334 +1444 @@
-  if (!src) src = url.download_first();
-  if (!src) src = url.download();
-"D code. "
+null
-  
-  // return first paragraph
@@ -1340 +1450 @@
-    
-    string para = src;
-
+>
-      para = para.after(box);
+    if (string nav = para.between("<table", "navbox", "</table>"))
+      para = para.after(nav);
-    para = para.between("<p>", "</p>");
+    
+    para = htmlFormat(para);
-    
-    void rmTag(string tag) {
-      while (true) {
-
+~" "
-        if (!betw) break;
-        para = para.remove(betw);
-      }
+      para = para.replace("<"~tag~">", "");
-      para = para.replace("</"~tag~">", "");
-    }
-    rmTag("a");
+    rmTag("abbr");
-    rmTag("sup");
-    rmTag("span");
-    rmTag("small");
+    rmTag("big");
+    para = para.replace("<br />", "").replace("<br/>", "");
-    bool rmDot;
-    auto Limit = 384 - url.length - 32; // safety margin, magic number! yay.
@@ -1399 +1517 @@
-  if (pwn_site(url, extras, src)) {
-    foreach (key, value; extras)
-
-
-zero
+ 
+
+
-    src = src.replace("&quot;", "\"");
-    auto js_url = src.between("flashvars=\"config=", "\"");
@@ -1420 +1538 @@
-  }
-  mistake: // Wait, my mistake. Not a ZP video after all.
+  if (title.length > 128) title = title[0..128] ~ "[snip]";
-  auto res = title.replaceEntities().replace("\n", "").strip() ~ extra;
-  bool booru =
@@ -1454 +1573 @@
-
-void ip(Query query) {
-whatismyip.com/automation
+automation.whatismyip.com
-}
-
-void control_char(Query query) {
+  if (query.name != root_user) return query.answer("You are not authorized to do that.");
-  setCtrl(query.channel, query.param);
-  if (query.name != root_user) return query.answer("You are not authorized to do that.");
-  query.answer("Control character is now `", CTRL(query.channel), "'.");
-}
@@ -1490 +1609 @@
-void seen(Query query) {
-  if (!query.param.length) return query.answer("Usage: "~CTRL(query.channel)~"seen <nick>");
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-  string mesg;
-
+
+
+
-    rest = rest[0 .. $-1];
-    mesg = Format(" doing \" * ", query.param, " ", rest, "\".");
-  } else mesg = Format(" saying \"", entry._0, "\".");
-
+
+
+
+
+
+
+
+
-}
-
@@ -1530 +1726 @@
-      return;
-    } catch (Exception ex) {
+      logln("Closing pipes. ");
+      foreach (reader; readers) reader.close;
+      foreach (writer; writers) writer.close;
-      logln(ex, "! Restarting in 10s, resetting resume. ");
-      foreach (i, arg; args) if (arg == "--resume") { args = args[0 .. i]; break; }
@@ -1563 +1762 @@
-  New(tgtp, Threadpool.GROW);
-  threadgens["ps"] = (nickname nick) {
-tru
+fals
-    tp.addTask(stuple(conduit, nick) /apply/ (typeof(conduit) conduit, nickname nick) {
-      start: scope(exit) goto start;
-      Query last;
-      string getCmd() { last = conduit.get(); return last.param; }
@@ -1590 +1788 @@
-        int[6] dest = points;
-        foreach (part; parts) {
+          part = part.strip();
-          if (auto rest = part.startsWith("add " /or/ "put ")) {
-            auto name = rest.slice(" "), value = rest;
@@ -1981 +2180 @@
-}
-
+void dcode(Query query) {
+  auto code = query.param.strip();
+  if (!code.length) { query.answer("Usage: <D program>"); return; }
+  auto response = ("POST=lang=D&code="~urlencode(code)~"&run=True&submit=Submit http://codepad.org/").download();
+  auto output = response.between("<span class=\"heading\">Output:", "</table>").between("</pre>", "</pre>").between("<pre>", "").strip().replace("\n", "\\");
+  if (output.length > 512) output = output[0 .. 512] ~ Format("[...] ", output.length - 512, " omitted. ");
+  while (true) {
+    auto pos1 = output.find("<a href");
+    if (pos1 != -1) {
+      output = output[0 .. pos1] ~ output.between("<a href", "").between(">", "");
+      continue;
+    }
+    auto pos2 = output.find("</a>");
+    if (pos2 != -1) {
+      output = output[0 .. pos2] ~ output.between("</a>", "");
+      continue;
+    }
+    break;
+  }
+  query.answer(output.replace("&quot;", "\""));
+}
+
+void magic(Query q) {
+  if (!q.param.length) {
+    return q.answer("Usage: magic <card name>");
+  }
+  auto site = googleQuery("site:magiccards.info -inurl:query "~q.param).download();
+  auto name = site.between("<title>", "</title>").strip();
+  auto type = site
+    .between("0 0 0.5", "").between("<p>", "</p>").replace("\n", "");
+  auto pricelink = site.between("href=\"", "magic.tcgplayer.com/db", "\"");
+  string priceinfo;
+  if (!pricelink) priceinfo = "No price info. ";
+  else {
+    auto pricesite = pricelink.download();
+    auto pricedata = pricesite.between("#D9FCD1", "</div").betweens("<B>", "</b>"); // lol
+    assert(pricedata.length == 3);
+    priceinfo = Format("L ", pricedata[2], ", M ", pricedata[1], ", H ", pricedata[0]);
+  }
+  return q.answer(name, ", ", type, ": ", priceinfo, " ", mktiny(pricelink));
+}
+
+import neatcode;
+
-import vars, loli, maid, std.date: getUTCtime, dateToString = toString;
-// Organically grown.
@@ -2011 +2254 @@
-  anypos["trope"] = anypos["roll"] = true;
-  bool mask_rp;
+  auto d_imports = "import std.stdio, std.file, std.stream, std.string, std.math; ";
-  foreach (key, value; [
-    "roll"[]: &roll /todg, "dice": &roll /todg, "google": &google /todg, "gcalc": &gcalc /todg,
-    "anidb": (Query q) { return anidb(q, 0, "", false); }, "decide": &decide /todg,
-"vote": &vote /todg, 
+/*"vote": &vote /todg, */
-    "more": &more /todg, "join": &join /todg, "part": &part /todg,
-    "help": &help, "cstats": &cstats /todg, "cfind": &cfind /todg, "vstats": &vstats /todg,
@@ -2030 +2274 @@
-    "note": &addnote /todg, "dbg": &dbg /todg, "overlap": &overlap /todg,
-    "fwoosh": &gun /todg, "fwoosh_up": &fwoosh_upd /todg,
-
+
+
+
-    "rp": (Query q) {
-      bool mask = true;
@@ -2038 +2284 @@
-      q.channel = "#fetishfuel"; q.answer(mask?"#ffsa masked for RP. ":"#ffsa unmasked. ");
-      q.channel = "#ffsa";       q.answer(mask?"#fetishfuel masked for RP. ":"#fetishfuel unmasked. ");
-
+ "forcequit": (Query q) { if (q.name != root_user) return q.answer("Unauthorized access! "); exit(0); },
-    "woof": (Query q) {
-      if (rand()%100>95) return q.answer("I'm a doggie!");
@@ -2051 +2297 @@
-      if (q.param.length) q.answer("<b>", q.param.getTitle(), "</b>");
-      else synchronized(last_url_sync) if (auto p = q.channel in last_url) q.answer("<b>", (*p).getTitle(), "</b>");
-
+
+
+
+
+
+
-  ]) commands[key] = value;
-
-
+
+
+
+
+
+
+
+
-  conn.onFind = conn /apply/ &onFind;
+  conn.onNickChange = conn /apply/ &onNickChange;
-  auto aborted = new bool;
-  scope(exit) *aborted = true;
@@ -2077 +2335 @@
-  // int[hostmask] strikes;
-  int freebird; auto lastbird = sec();
-
-
+
+
+
-      if (!channel.length && notice_cb) { notice_cb(host, msg); return true; }
-      logln("< ", msg);
@@ -2089 +2348 @@
-        if (!netsplit) wbOnJoin(q);
-        justJoined[host] = true;
+        auto entry = IRCconfig.get!(Stuple!(int, typeof(µsec()), string)) (conn.host, "peak_"~channel.clean(), { return stuple(0, µsec(), ""); }());
+        if (auto p = channel in conn.users) {
+          auto users = p.length;
+          if (users >= entry._0)
+            IRCconfig.set(conn.host, "peak_"~channel.clean(), stuple(conn.users[channel].length, µsec(), cast(string) .nick(host)));
+        }
-      } else {
-        if (host in justJoined) {
@@ -2112 +2377 @@
-      if (channel.tolower() == "#himitsu" && msg.startsWith("!list" /or/ "!new")) {
-        tp.addTask(stuple(Query(conn, .nick(host), channel), conn) /apply/ (Query q, IRCconn ic) {
-_Millenium_Rob
+B
-          q.notice("Our bot isn't here right now. Perhaps try the archive bots in #lurk? ");
-        });
@@ -2120 +2385 @@
-      seenfile.set(channel.clean(), (cast(string) .nick(host)).tolower(), stuple(msg, µsec()));
-      bool permit = true;
+      permit &= .nick(host) != cast(nickname) "retardedFaggot";
-      // if (channel.endsWith("tropers")) permit = false; // fucking bot nazis
-      if (channel.tolower().endsWith("anime")) permit = false; // moar nazis
+      if (channel.tolower().endsWith("lesswrong")) permit = false; // nice people
-      permit &= .nick(host) != cast(nickname) "TropeBot";
-      // echo is a silly feature
@@ -2142 +2409 @@
-      */
-      // uncomment for awesome
-/*if (msg.ifind("
+if (msg.ifind("__
-        auto q = Query(conn, .nick(host), channel);
-        if (freebird == -1 && sec() - lastbird > 300) {
@@ -2157 +2424 @@
-          else freebird ++;
-        }
-*/
+
-      if (false && msg.ifind("stop") != -1 && isPoking()) {
-        auto r = rand();
@@ -2166 +2433 @@
-        cooldown = sec();
-      }
-
+
+
+
+
+
+
+
+
+
+
+
-      const vocals="aeiouAEIOUqQ";
-
-Query(conn, .nick(host), channel).answer(
+ && channel.ifind("yackfest") == -1
+auto answer = 
-          ["Anime."[], "It's anime.", "Anime is its own plural. ", "Anime.", "Anime >_>", "Just \"anime\"."]
-
-
+;
+Query(conn, .nick(host), channel).answer(answer
-        return true;
-
+*/
-      if (onFind) onFind(channel, host);
-      auto name = .nick(host);
@@ -2181 +2458 @@
-      auto lpos = msg.find("http://");
-      if (auto rest = msg.startsWith(CTRL(channel))) {
-
-
-
-
+
+
+
+
+
+
+
-      }
-      if (auto rest = msg.startsWith("> ")) {
@@ -2198 +2478 @@
-        }
-        bool flooded;
-
-
-
+
+
+
+
+
-        auto query = Query(conn, name, channel, cmd);
-        if (flooded && (name != root_user)) query.notice("You have triggered my flood guard prevention. Please wait a bit.");
@@ -2220 +2502 @@
-        }
-        permit &= link.ifind("scp-wiki.wikidot.com") == -1;
-
+
+
+
+
+
+
-        if (permit) {
-          tp.addTask(stuple(link, channel, Query(conn, name, channel, ""), lpos + link.length + 2)
-            /apply/ (string link, string channel, Query query, int ll) {
-            auto title = link.getTitle();
+            if (!title) return;
-            if (channel.endsWith("tropers")) {
-              string rss;
@@ -2259 +2547 @@
-            string f;
-            if (channel.endsWith("tropers")) f = "b";
+            else if (channel.endsWith("lets-read")) f = "u";
-            if (title.length) {
-              if (f) query.say(/*foo, */"<", f, ">", title, "</", f, ">");
@@ -2269 +2558 @@
-        if (key.strip() /notin/ anypos) continue;
-        if (match != -1) {
-
+
+
+
+
-          wasCommand = true;
-        }
@@ -2282 +2574 @@
-      }
-      if (!wasCommand && !(mask_rp && (channel == "#fetishfuel" /or/ "#ffsa"))) {
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-          }
-        }
-      }
-      return false;
-
+
+
+
-    privmsg = defaultChanHandler /fix/ "";
-    tp.addTask(aborted /apply/ (ref bool aborted) {
-
+
+
+
+
+
+
+
+
-      if (aborted) return;
-      join(args[2], defaultChanHandler);
-Start(args[0])
+start
-        privmsg(cast(hostmask) (cast(string) root_user ~ "!@"), line);
-      }
@@ -2321 +2630 @@
-        message(channel, ex.toString~". Time to die. :(");
-      }*/
+      conn.invalidateHandlers();
-      logln(ex, " Rethrowing. ");
-      throw ex;

trunk/idc/irc.d

@@ -8 +8 @@
-
-import tools.time;
+
+string tolower(string s) {
+  s = s.dup;
+  foreach (ref ch; s) { if (ch >= 'A' && ch <= 'Z') ch = 'a' + (ch - 'A'); }
+  return s;
+}
-
-template GuardTypes(bool B) {
@@ -37 +43 @@
-        while (sum > calls) {
-          cleanup();
-slowyield(
+usleep(200_000
-        }
-      } else cleanup();
@@ -88 +94 @@
-  void delegate(int) guard;
-  void delegate(string channel, hostmask host) onFind;
+  void delegate(string channel, hostmask from, hostmask to) onNickChange;
-  void delegate(string) onJoin;
+  void invalidateHandlers() {
+    onFind = null;
+    onJoin = null;
+    channels = null;
+    onNickChange = null;
+  }
-  bool registered(nickname n) {
-    auto waiter = new Semaphore;
@@ -114 +127 @@
-  this(string host, nickname nick, int port = 6667, uint resume_handle = -1) {
-    this.host = host;
-00_000, 60); // 100 kb per 60
+_000, 5); // 1 kB / 5
-    if (resume_handle == -1) {
-      auto dpos = host.find(":");
@@ -189 +202 @@
-      logln(chan, " -> users: ", users[chan]);
-    }
-
-
+
+
+
-      if (onFind) onFind(channel, host);
-      if (channel /notin/ channels)
@@ -209 +223 @@
-      return;
-    }
-
+ :
-      outer:foreach (channel, value; users) {
-        foreach (ref person; value) {
-          if (person == cast(string) .nick(host)) {
-            if (onFind) onFind(channel, cast(hostmask) host.replace(person, rest));
+            if (onNickChange) onNickChange(channel, host, cast(hostmask) host.replace(person, rest));
-            break outer;
-          }
@@ -222 +237 @@
-    if (auto rest = line.startsWith("433")) {
-      if (line.find("already in use") != -1) {
-
+'"~line~"'
-      }
-    }
@@ -321 +336 @@
-}
-
-
+
+
-  string res;
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-    // recreate formatting
-    if (bold_depth) res ~= "\x02";
-    if (ul_depth) res ~= "\x1F";
-    if (inv_depth) res ~= "\x16";
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-  auto base = Format(t);
-  auto nfpos = base.find("<noformat/>");
-  if (nfpos != -1) return IRCFormat(base[0 .. nfpos]) ~ base[nfpos + 8+3 .. $];
-
-
+
+
+
+
-}
-
@@ -369 +408 @@
-  }
-  void notice(T...)(T t) {
-connection.raw_sendln(IRCFormat("NOTICE ", name, " :", t)
+output((string line) { connection.raw_sendln(IRCFormat("NOTICE ", name, " :", line)); }, t
-  }
-  void answer(T...)(T t) { say(cast(string) name, ": ", t); }
-
+
+
-    auto msg = Format(t);
-    string pre_line;
@@ -408 +448 @@
-    else breakIt(msg);
-    auto lines = IRCFormat(pre_line).split("\n");
-
-
+
-  }
-  void act(T...)(T t) { connection.message(channel, "\x01"~Format("ACTION ", t).IRCFormat()~"\x01"); }

trunk/idc/pad/cgi.d

@@ -72 +72 @@
-    else res ~= "<"~ent~">";
-  }
-
+, "/p", "/a"
-    ent_map["&lt;"~ent~"&gt;"] = ent.dup /apply/ &fun;
-  }
@@ -79 +79 @@
-    auto imgbody = post.slice("&gt;");
-    if (imgbody.find(" on") != -1) throw new Exception("JavaScript is a security risk, and not supported. ");
-
+.replace("&quot;", "\"")
-  };
-  ent_map["&lt;p"] = (string pre, ref string post) {
@@ -86 +86 @@
-    if (peabody.find(" on") != -1) throw new Exception("JavaScript is a security risk, and not supported. ");
-    res ~= "<p"~peabody~">";
+  };
+  ent_map["&lt;a"] = (string pre, ref string post) {
+    res ~= pre;
+    auto abody = post.slice("&gt;");
+    if (abody.find(" on") != -1) throw new Exception("JavaScript is a security risk, and not supported. ");
+    res ~= "<a"~abody.replace("&quot;", "\"")~">";
-  };
-  ent_map["http://"] = (string pre, ref string post) {
@@ -159 +165 @@
-  if (back && lines.length) lines = lines[0 .. $-1];
-  string default_input;
+  string[] input_lines = lines;
-  if (auto lstr = "backToLine" in chunks) {
-    auto line = (*lstr).atoi();
@@ -193 +200 @@
-    output = null;
-    ex.msg = ex.msg.replace("<", "&lt;").replace(">", "&gt;");
-
+
+
-  }
-  auto needed = sec() - start;
@@ -214 +222 @@
-    postText = "</div>";
-  }
+  string res;
-  "Content-type: text/html; charset=utf-8\r\n
-<!DOCTYPE html PUBLIC \"-//W3C//DTD XHTML 1.0 Strict//EN\"
@@ -220 +229 @@
-<head>
-  <meta http-equiv=\"Content-type\" content=\"text/html;charset=UTF-8\" />
-
+ for I/O
-</head>
-<body>
@@ -254 +263 @@
-</body>
-</html>
-
+res ~= s; 
-    "%PREVENCODED%", encoded,
-    "%PREV_REENCODED%", encoded.entitiesEncode(),
@@ -273 +282 @@
-    "%MEM%", { GCStats gs = void; getStats(gs); return Format(gs.poolsize / 1_000_000f); }()
-  );
+  "/tmp/lastpage.html".write(res);
-}
-

trunk/idc/pad/engine.d

@@ -37 +37 @@
-    }
-  }
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
-}
-
@@ -202 +200 @@
-  auto res = s2.take(matched);
-  if (!res.length) {
-
+
+
+
+
-    st = s2; s = st.take(1); // single-symbol token
-    return true;
@@ -408 +409 @@
-                 | bool          | int         | string               | float   | Scope
-      -----------+---------------+-------------+----------------------+---------+----------
-Þ       | Þ
-Þ
-Þ
-Þ             | cast(int) f | Format(f)            | f       | Þ
-Þ           | (sr?sr.fqn:q{(null:r)}p) | Þ  
+        | 
+
+
+              | cast(int) f | Format(f)            | f       | 
+            | (sr?sr.fqn:q{(null:r)}p) |
-      ScopeValue | sr.value().to!(T) | sr.value().to!(T) | sr.value().to!(T) | sr.value().to!(T) | sr`;
-    mixin(ctTableUnrollColMajor(Table,
@@ -422 +423 @@
-      else `,
-      `case FlatType.$ROW:
-q{$CELL}p == "Þ"
+!q{$CELL}p.length
-          throw new Exception(q{Cannot convert $ROW to $COL: }p~to!(string)~q{! }p);
-return $CELL;
+{ return $CELL; }
-      `
-    ).litstring_expand() ~ `static assert(false, "Unsupported type: "~T.stringof); `);
@@ -1224 +1225 @@
-      } else break;
-    }
-
+
+
+
-    s = s2;
-    return true;
@@ -1532 +1535 @@
-  static void getThis(ref string s, out Scope sc) {
-    try _getThis(s, sc);
-
+ '", sc?sc.name:"", "'
-  }
-  static void _getThis(ref string s, out Scope sc) {
@@ -1575 +1578 @@
-        scp.replant(this);
-    }
+  }
+  bool noStmts() {
+    foreach (statement; statements)
+      if (auto sc = castToScope(statement)) {
+        if (sc.name == "default") return false; // SORT of a statement
+      } else return false;
+    return true;
-  }
-  // breaks on gdc with final
@@ -1682 +1692 @@
-  Scope lookdown(string var, ref RecursionCheck visited, bool userquery = false, bool below = false) {
-    if (!var.length) {
-"failLookup" in this
+("failLookup" in this || noStmts)
-      return this;
-    }
@@ -1721 +1731 @@
-      }
-      return cur.lookdown(var, visited, userquery, below);
-) return lookdown(var, visited, userquery, below);
+ && !parent) return lookdown(var, visited, userquery, below); // only do this if we're the root!!
-    else {
-      Scope[] fallbacks;
@@ -1731 +1741 @@
-          // pure recursion
-          if (!mst.checkingRightNow) // a scope can't depend on itself
-
+
+
-        }
-        if (auto ast = cast(AliasStatement) entry) {
@@ -1761 +1772 @@
-          }
-          if (sc.isNamed(first)) {
-
+
+
-          }
-        }
@@ -1767 +1779 @@
-      // Multiple fallbacks because instances might introduce more than one "any" block
-      if (fallbacks) {
-
+if (!(userquery && res.noStmts)) 
-          fallback.value = Value(first);
-          return res;
@@ -1797 +1809 @@
-      auto from = re.from(sc).to!(string), to = re.to(sc).to!(string);
-      auto alt = regex_sub(name, from, to);
+      // throw new Exception(Format("|", from, "| |", to, "| |", name, "| |", alt, "|"));
-      if (alt != name) {
-        auto res = lookup(alt, userquery, vp);
@@ -1807 +1820 @@
-        if (sc.global) {
-          auto rest = name, first = rest.slice(".");
-
-
+
+
+
+
-              if (auto res2 = res.lookdown(rest, *vp, userquery)) return stuple(res2, true);
-            }

trunk/idc/pad/mainloop.d

@@ -1 +1 @@
-module pad.mainloop;
-
-: string
+
-static import tools.compat;
-
@@ -71 +71 @@
-  return runLoop(src, "", write, read, readFS, dontSave, stopstart);
-}
+
+import tools.rd: next_text;
-
-const bool ReadFS = true, DontSave = true;
@@ -88 +90 @@
-      Scope.getThis(s2, root);
-    }
+    if (s2.strip().length) {
+      throw new PadException(Format("Unknown/leftover text at `", s2.strip().next_text(), "'"));
+    }
-    if (full || !stream) stream = new SaveStream;
-    if (!root) return;
@@ -93 +98 @@
-    location = root.eval(initial, root);
-    if (!location) {
-
+/* ~ data*/
-    }
-    if (verbose) write(initial.collate);
@@ -108 +113 @@
-    }
-    while (line) {
-
+.strip()
-      auto parts = chunk.split(" ");
-      if (parts.length == 1) cmd = parts[0];
@@ -139 +144 @@
-    write("Forwarded. ");
-  } else reset(true);
-
+
+
-  while (true) {
-    auto line = read();
+    lines ++;
-    if (line == "quit" || line == "q") return write("Bye! ");
-    if (line == "forcequit") return;
@@ -162 +169 @@
-        auto url = pastepost(postdata);
-        write(Format("Saved ", postdata.length, " (", predata.length, ") to ", url));
+        continue;
+      }
+      if (line == "info") {
+        write(Format("You are playing ", lastLoaded, ", ", lines, " lines in. "));
-        continue;
-      }
@@ -191 +202 @@
-      continue;
-    }
-
+!src) if (
-      if (from.find(" ") != -1) throw new Exception("Invalid URL: \""~from~"\". "); // No POST hacking! Bad user!
-      if (stopstart) stopstart();

trunk/idc/pad/utils.d

@@ -22 +22 @@
-      string data2;
-      foreach (entry; data.betweens("<pre class=\"code\">", "<"))
-
+
+
+
+
-      data = data2;
+    }
+    if (data.find("/ep/pad/view/") != -1) { // EtherPad
+      auto id = data.between(`href="`, `" id="docbarslider`, GLOMP_RIGHT);
+      auto redir = addr.followLink(id)~"?pt=1";
+      data = redir.download();      
-    }
-    if (data.find("%PAD START%") != -1) {
@@ -39 +47 @@
-      if (inTarget)
-        data ~= line.between("content=\"", "")[0 .. $-1]
-
+
+
+
+
+
-      if (line.endsWith("title=\""~addr~"\"")) inTarget = true;
-    }
@@ -97 +109 @@
-  string res;
-  int nest_level = 0;
-Break
+Newline
-    auto pos = s.find("\n");
-    if (pos == -1) return;
@@ -104 +116 @@
-  text.glomp_parse([
-    "\""[]: (string pre, ref string post) { if (!nest_level) { res ~= pre ~ "\"" ~ getLiteral(post, true) ~ "\""; } },
-Break
+Newline
-    "/*": (string pre, ref string post) { if (!nest_level) res ~= pre; nest_level ++; },
-    "*/": (string pre, ref string post) { if (!nest_level) throw new Exception("Too many */"); nest_level --; }