!752

// must be run together with sub-bot #1002185 (queries the
// slack slurper's database)

static class SlackMsg {
  S user, botName; // one of these is going to be set
  S userName; // looked up if user != null
  S type, text, ts;
  O reactions;
  S channelID;
}

static class McMsg {
  S miniChat, user, text;
  long when;
}

static PersistentMap<S, L<Tag>> tagsByTS;

static S editPW;

static class Tag {
  S name;
  //O addedBy; // not used yet
  
  *(S *name/*, O *addedBy*/) {}
  *() {}
}

p {
  tagsByTS = new PersistentMap("tagsByTS.log");
  editPW = loadSecretTextFileMandatory("edit-pw").trim();
  makeBot("Slack Tagger Bot!!");
}

synchronized answer {
  if match "get tags for msg *" {
    S msgID = m.unq(0);
    L<Tag> tags = tagsByTS.get(msgID);
    if (empty(tags))
      ret "No tags for that msg";
    else
      ret structure(tags);
  }
}

static S html(S uri, Map<S, S> params) {
  try answer serveTextFile(uri, "tagsByTS.log");
  
  L<S> keepFields = litlist("channel", "n", "q");
  
  S channelName = formatChannelName(or(params.get("channel"), "talkingbots"));
  O slurper = getBot("#1002185");
  if (slurper == null) ret "Slurper not found";
  L log = cast call(slurper, "getLog", channelName);
  log = filterLog(log, params.get("q")); // perform search
  
  boolean canEdit = master() || (!empty(editPW) && eq(editPW, params.get("edit-pw")));
  print("editPW has " + l(editPW) + " chars. canEdit: " + canEdit);
  
  if (canEdit)
    for (S key : keys(params))
      if (key.startsWith("tag_")) {
        S ts = dropPrefix("tag_", key);
        S val = params.get(key);
        new L<Tag> tags;
        for (S t : splitByJavaToken(val, ","))
          tags.add(new Tag(t.trim()));
        tagsByTS.put(ts, tags);
      }
      
  O mcBot = getBot("#1002433");

  new L data;
  int n;
  if (!empty(params.get("n")))
    n = parseInt(params.get("n"));
  else
    n = max(0, l(log)-1)/100*100;
  for (int i = n; i < min(n+100, l(log)); i++) {
    O o = log.get(i);
    S ts = getString(o, "ts");
    L<Tag> tags = unnull(tagsByTS.get(ts));
    L<S> names = asList(getSortedSet(tags, "name"));
    S tagNames = join(", ", names);
    
    // Pure text fields
    
    Map map = htmlencode(litmap(
      "Timestamp", ts,
      "User", get(o, "userName"),
      "Text", get(o, "text"),
      "#", i+1
    ));
    
    // Fields with actual HTML
    
    map.put("Tags",
      htag("input", "", "type", "text", "name", "tag_" + ts, "value", tagNames));
      
    if (mcBot != null) pcall {
      L mc = cast call(mcBot, "listMiniChat", "dc" + ts);
      new L<S> miniChat;
      for (O _m : mc) {
        McMsg m = cast restructure(_m);
        miniChat.add(htmlencode(m.user + ": " + m.text));
      }
      map.put("Mini-Chat", join("<br>", miniChat));
    }
      
    data.add(map);
  }
  
  new StringBuilder buf;
  S title = "Tagging " + channelName;
  buf.append(htag("title", title));
  buf.append(htag("h3", title));
  
  // navigation
  new L<S> l;
  for (int i = 0; i < l(log); i += 100)
    l.add(htag("a", str(i/100+1), "href", selfLink(params, keepFields, "n", str(i))));
  buf.append(htag("p", "Pages: " + join("\n", l)));
  
  S formContents = htmlTable(data, false);
  
  if (canEdit)
    formContents += htag("p","You are clear to edit.");
  
  formContents += htag("p", "Search term: " + htag("input", "", "type", "text", "name", "q", "value", params.get("q")));
  //formContents += htag("p", "Edit password: " + htag("input", "", "type", "password", "name", "edit-pw", "value", params.get("edit-pw")));
  formContents += htag("input", "", "type", "submit", "value", "Submit!");
  formContents += hiddenFields(params, minus(keepFields, "q"));
  buf.append(htag("form", formContents, "method", "POST"));
  ret str(buf);
}

static L filterLog(L log, S query) {
  query = trim(query);
  if (empty(query)) ret log;
  
  new L l;
  for (O o : log) {
    S text = getString(o, "text");
    if (indexOfIgnoreCase(text, query) >= 0)
      l.add(o);
  }
  ret l;
}

Began life as a copy of #1002190