!752

static long minPostDelay = 1000; // 1 second per program
static long presenceTimeout = 1000*60; // 1 minute
static S defaultUser = "anon";
static bool showAds;

static S myURL;
static S image = "http://eyeocr.sourceforge.net/filestore/filestore.php?cmd=serve&file=blob_1003097&contentType=image/png";
static S image2 = "http://eyeocr.sourceforge.net/filestore/filestore.php?cmd=serve&file=blob_1003101&contentType=image/png";

sclass Msg {
  long timestamp;
  S user, text;
  long id;
  
  S programID; // which program posted this
  
  *() {}
  *(long *timestamp, S *user, S *text) {}
}

sclass Presence {
  long timestamp;

  *() {}
  *(long *timestamp) {}
}

sclass Suggest {
  long id, onMsgID;
  S text, user, _if, byUser, ip;
  bool likeNow;
}

static PersistentLog<Msg> messages;
static new Map<S, Presence> presences;
static Map<S, L<S>> permanentPresences = new TreeMap;
static PersistentLog<Suggest> suggests;
static new MultiMap<Long, Suggest> suggestsByOnMsg;
static Q feeder;
static new L<S> listeners; // bot IDs

p {
  showAds = amIProgram("#1003081");
  myURL = rawBotLink();
  messages = new PersistentLog("messages");
  load("presences");
  load("permanentPresences");
  clearPresences();
  feeder = new Q("Simple Chat Room Feeder", true);
  load("listeners");
  suggests = new PersistentLog("suggests");
  for (Suggest s : suggests) index(s);
}

static void index(Suggest s) {
  suggestsByOnMsg.put(s.onMsgID, s);
}

ssynchronized bool clearPresences() {
  long expire = now()-presenceTimeout;
  bool anyChange = false;
  for (S name : cloneList(keys(presences))) {
    Presence p = presences.get(name);
    
    // presences expired or program gone away => drop presence
    if (p.timestamp < expire) {
      anyChange = true;
      presences.remove(name);
    }
  }
  if (anyChange)
    save("presences");
  ret anyChange;
}

ssynchronized bool clearPermanentPresences() {
  bool anyChange = false;
  for (S programID : cloneList(keys(permanentPresences))) {
    if (getBot(programID) == null) {
      anyChange = true;
      permanentPresences.remove(programID);
    }
  }
  if (anyChange)
    save("permanentPresences");
  ret anyChange;
}

ssynchronized S post(S user, S text) {
  ret post(user, text, programID());
}

ssynchronized S post(S user, S text, S programID) {
  addPresence(user);
  Msg last = last(messages);
  if (last != null) {
    if (eq(last.text, text) && eq(last.user, user))
      ret "don't repost"; // don't re-post
    if (!sameSnippetID(programID, programID())
      && sameSnippetID(last.programID, programID)
      && last.timestamp >= now()-minPostDelay)
      ret "don't hammer"; // anti hammering
  }
  Msg msg = new Msg(now(), user, text);
  msg.programID = programID;
  msg.id = l(messages)+1;
  messages.add(msg);
  feeder.add(runnable { feedThem(); });
  ret "ok";
}

ssynchronized int size() {
  ret l(messages);
}

ssynchronized L<Msg> getMessages(int startIndex, int endIndex) {
  ret newSubList(messages, startIndex, endIndex);
}

ssynchronized S html(S uri, Map<S, S> params) {
  registerVisitor();
  S user = or2(params.get("user"), defaultUser);
  if (params.get("user") != null) {
    setCookie("chatuser", user);
    //print("Setting user cookie: " + "chatuser" + " = " + user);
  } else {
    user = or2(getCookie("chatuser"), defaultUser);
    //print("Read user cookie: " + user);
  }
  S text = params.get("text");
  bool all = eq("1", params.get("all"));
  bool reveal = false; // eq("1", params.get("reveal"));
  bool ad = eq("1", params.get("ad"));
  if (params.get("ad") != null)
    setCookie("chatad", ad ? "1" : "0");
  else
    ad = eq("1", getCookie("chatad"));
  int lines = parseInt(or2(params.get("n"), "15"));
  //printAllCookies();
  
  addPresence(user);
  
  if (eq(uri, "/n"))
    ret str(l(messages));
    
  bool robo = eq("1", params.get("robo"));
    
  if (eq(uri, "/incremental")) {
    int a = parseInt(params.get("a"));
    int b = parseInt(params.get("b"));
    if (b == 0) b = l(messages);
    L msgs = subList(messages, a, b);
    if (robo)
      ret htmlencode(structure(msgs));
    if (empty(msgs)) ret "";
    ret "<!-- " + l(messages) + "-->\n" 
      + renderMessages(msgs, reveal, false, ad);
  }
  
  if (eq(uri, "/presences"))
    ret htmlencode(structure(allPresences()));
  
  S suggest = params.get("suggest");
  if (nempty(suggest)) {
    new Suggest s;
    s.text = suggest;
    s.user = params.get("user");
    s._if = params.get("if");
    s.onMsgID = parseLong(params.get("id"));
    s.id = l(suggests)+1;
    s.byUser = user;
    s.likeNow = params.get("likenow") != null;
    suggests.add(s);
    index(s);
    ret hrefresh(rawLink());
  }

  if (nempty(text)) {
    post(user, text);
    ret robo ? "ok" : hrefresh(rawLink());
  }
  
  if (robo) ret "ok";

  S formContents = "";
  
  formContents += "Your nick: " + htag("input", "", "type", "text", "name", "user", "value", user);
  formContents += " Your line: " + htag("input", "", "type", "text", "name", "text", "value", "", "autofocus", "1");
  formContents += " " + htag("input", "", "type", "submit", "value", "Send");
  //formContents += hiddenFields(params, keepFields);
  
  L msgs = messages;
  if (!all) msgs = takeLast(msgs, lines);
  
  ret /*h3("Computer Chat Room - where nobody knows you're a \"bot\"")*/
      mobileFontFixer()
    + loadJQuery()
    + javaScript()
    + htitle("RoboChat")
    + body(
        p(ahref(myURL, himg(image)) + " &nbsp; " + ahref(myURL, himg(image2)))
      + div(renderMessages(msgs, reveal, l(messages) > l(msgs), ad), "id", "maindiv", "style", "height: 400px; overflow-x: scroll")
      //+ htmlTable(objectToMap(msgs))
      + p("Present: " + structure(allPresences()))
      + p(htag("form", formContents, "method", "POST", "action", myURL))
      + p(targetBlankLink("http://ai1.lol/wiki/", "Other Homepage")
      + p(targetBlankLink("https://medium.com/@stefanreich", "Read Stefan on medium.com") + "<br>" + targetBlankLink(rawBotLink("#1002213"), "Talk to Eleu"))
      + (showAds ? p(ads()) : ""),
      "onLoad", [[ $("#maindiv").scrollTop(1E10); start(); ]]);
}

ssynchronized void addPresence(S user) {
  if (empty(user)) ret;
  if (permanentPresences.containsKey(user)) ret;
  Presence p = new Presence(now());
  presences.put(user, p);
  save("presences");
}

ssynchronized S postForeign(Class mainClass, S programID, S user, S text) {
  ret post(user, text, programID);
}

ssynchronized void addListener(S botID) {
  if (setAdd(listeners, formatSnippetID(botID))) {
    print("Chat: Added listener " + botID + ", now: " + structure(listeners));
    save("listeners");
  }
}

ssynchronized void removeListener(S botID) {
  listeners.remove(formatSnippetID(botID));
  print("Chat: Removing listener " + botID + ", remaining: " + structure(listeners));
  save("listeners");
}

ssynchronized L<S> getListeners() {
  ret cloneList(listeners);
}

static void feedThem() {
  L<S> listeners = getListeners();
  print("Feeding: " + structure(listeners));
  for (S botID : listeners) pcall {
    O bot = getBot(botID);
    if (bot != null)
      callOpt(bot, "simpleChatUpdated");
    else
      removeListener(botID);
  }
}

static S renderMessages(L<Msg> msgs, bool reveal, bool moreAbove,
  bool ad) {
  new StringBuilder buf;
  if (moreAbove)
    buf.append(ahref(rawLink() + "?all=1", "[...]") + "<br>\n");
  for (Msg m : msgs) {
    buf.append(b(htmlencode(m.user) + ":") + " " + htmlencode(m.text));
    if (ad) {
      S suggestLink = "#"; // rawLink("/suggest?id=" + m.id);
      S formContents = "Suggest saying " + hinputfield("suggest")
        + " as " + hinputfield("user", "someone") + " if (optional) " + hinputfield("if") + hhidden("id", m.id) + ", like now "
        + hcheckbox("likenow", true) + " . "
        + hsubmit("OK");
      S popupHtml = tag("form", formContents, "action", rawLink("suggest"), "method", "POST", "style", "display: inline-block;");
      S extra = "$('#extra" + m.id + "')";
      S onClick = extra + ".html(" + extra + ".html() == '' ? " + javascriptQuote(popupHtml) + " : ''); return false;";
      buf.append(" " + ahref(suggestLink, "&gt;", "onClick", onClick));
      L<Suggest> suggests = suggestsByOnMsg.get(m.id);
      if (nempty(suggests))
        buf.append(" [" + n(l(suggests), "suggest") + "]");
    }
    /*buf.append(" " + tag("div", "", "id", "extra" + m.id,
      "style", "display: inline"));*/
    buf.append(" " + tag("span", "", "id", "extra" + m.id));
    buf.append("<br>\n");
  }
  ret str(buf);
}

static S mobileFontFixer() {
  ret [[<meta name="viewport" content="width=device-width, initial-scale=1">]];
}

// called from other bots - sets a permanent presence
ssynchronized void setPermanentPresence(S programID, L<S> names) {
  permanentPresences.put(formatSnippetID(programID), names);
  clearPermanentPresences();
  save("permanentPresences");
}

ssynchronized L<S> allPresences() {
  clearPresences();
  clearPermanentPresences();
  ret asList(joinSets(
    asSet(concatLists(values(permanentPresences))),
    asSet(keys(presences))));
}

static S ads() {
  ret [[<a href="//www.interserver.net/r/251595"><img src="https://www.interserver.net/logos/interserver125by125.gif" alt="InterServer Web Hosting and VPS"></a>]];
}

static S javaScript() {
  S link = rawLink("incremental?a=");
  ret hjavascript([[
    var n = $N;
    function start() {
      $.get(LINK + n, function(src) {
        var match = src.match(/\d+/);
        if (match != null) {
          n = parseInt(match[0]);
          $("#maindiv").append(src);
          $("#maindiv").scrollTop(1E10);
        }
      }, 'text');
      setTimeout(start, 10000);
    }
  ]]).replace("LINK", jsQuote(link)).replace("$N", lstr(messages));
}