!752

static class Line {

  S id;

  S text;

  S type;

  new L<S> on;

  Source source;

}

static PersistentLog<Line> data;

static new Map<S, Line> byID;

static long nextID;

p {

  data = new PersistentLog("data");

  for (Line line : data) index(line);

  load("nextID");

}

synchronized answer {

  if "dn size"

    ret "Dialog network: " + n(data.size(), "line");

  if "dn add *" exceptionToUser{

    new Line line;

    line.text = m.unq(0);

    line.type = "user-added";

    add(line, new Source(s));

    ret "Yo! Your ID: " + line.id;

  }

  if (matchAny(litlist("dn add * on *", "dn add * to *"), s, m)) exceptionToUser {

    S ids = m.unq(1);

    new Line line;

    line.text = m.unq(0);

    line.type = "user-added";

    line.on.addAll(splitIDs(ids));

    add(line, new Source(s));

    ret "Yo! Your ID: " + line.id;

  }

  if "dn show *" exceptionToUser {

    S id = clearID(m.unq(0));

    Line line = byID.get(id);

    ret line == null ? format("Line * not found", id) : structure(line);

  }

  if "dn refs *" exceptionToUser {

    S id = clearID(m.unq(0));

    L<Line> refs = findRefsTo(id);

    ret empty(refs) ? "No references found" : formatList(refs);

  }

  if "dn search *" exceptionToUser {

    S query = m.unq(0);

    L<Line> refs = search(query);

    ret empty(refs) ? "No results" : formatList(refs);

  }

  if "dn clear yes i am sure" {

    if (master()) {

      clear();

      ret "OK";

    }

  }

  if "dn dump"

    ret "OK " + structure(data);

  if "dn copy from sister" exceptionToUser {

    O sisterBot = getBot("#1002626");

    if (sisterBot == null) ret "No sister bot (install #1002626!)";

    S url = getString(get(sisterBot, "sister"), "robotURL");

    S q = "dn dump";

    S a = loadPage(url + "?" + makePostData("q", q));

    a = htmldecode(a);

    a = dropPrefixMandatory("OK ", a);

    L<Line> newData = cast unstructure(a); // we're trusting the other server here as its URL was given to us by master

    if (empty(newData))

      ret "Empty data, did nothing";

    int l = l(data);

    clear();

    data.addAll(newData);

    for (Line line : newData) index(line);

    fixNextID();

    ret "OK, cleared " + l + " entries, added " + l(newData) + " entries.";

  }

}

static S formatList(L<Line> lines) {

  new L<S> l;

  for (Line line : lines) {

    S text = line.text;

    l.add(line.id + ": " + (text.contains("\n") ? quote(text) : text));

  }

  ret slackSnippet(fromLines(l));

}

static synchronized Line add(S s) {

  new Line line;

  line.text = s;

  add(line, new Source(""));

  ret line;

}

static void add(Line line, Source source) {

  line.source = source;

  line.id = newID();

  data.add(line);

  index(line);

}

static void index(Line line) {

  byID.put(line.id, line);

}

static S newID() {

  S id = "_" + ++nextID;

  save("nextID");

  ret id;

}

static L<Line> findRefsTo(S id) {

  new L<Line> l;

  for (Line line : data)

    if (line.on.contains(id))

      l.add(line);

  ret l;

}

static L<Line> search(S query) {

  new L<Line> l;

  for (Line line : data)

    if (indexOfIgnoreCase(line.text, query) >= 0)

      l.add(line);

  ret l;

}

static S clearID(S _id) {

  S id = dropPrefix("_", _id);

  if (!isInteger(id)) fail("woot bad id: " + quote(_id));

  ret "_" + id;

}

static L<S> splitIDs(S s) {

  new L<S> l;

  for (S id : s.split("[ ,]+"))

    l.add(clearID(id));

  ret l;

}

static void clear() {

  pcall { logQuoted("data.clear", loadTextFile(data.file)); }

  data.clear();

  byID.clear();

}

static synchronized L<Line> findStarters() {

  new L<Line> l;

  for (Line line : data)

    if (empty(line.on))

      l.add(line);

  ret l;

}

static void fixNextID() {

  long id = 0;

  for (Line line : data)

    id = max(id, parseLong(dropPrefix("_", line.id)));

  nextID = id+1;

  save("nextID");

}

static L<Line> getReferences(Line line) {

  ret findRefsTo(line.id);

}

// here's the magic! might as well match loosely

static Line findStarter(S s) {

  for (Line line : findStarters())

    if (match(s, line.text))

      ret line;

  ret null;

}