sclass Tag {

  S name;

}

sclass 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;

  int index;

  new TreeSet<S> tags;

}

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

static PersistentLog<SlackMsg> msgs;

static new L<SlackMsg> taggedMsgs;

static new TreeMap<Integer, SlackMsg> msgsByIndex;

static new MultiMap<S, SlackMsg> msgsByTag;

static void init() {

  tagMap = new PersistentMap("#1002192", "tagsByTS.log");

  print("Tags: " + l(tagMap));

  S channelName = "talkingbots";

  msgs = new PersistentLog("#1002185", parseChannelName(channelName) + ".msgs");

  print("Msgs: " + l(msgs));

  if (empty(tagMap) || empty(msgs)) fail("no data");

  //printStructure(last(msgs));

  // put tags and index in messages

  int n = 1;

  for (SlackMsg msg : msgs) {

    L<Tag> tags = tagMap.get(msg.ts);

    /*if (nempty(tags))

      print(structure(tags) + " " + structure(msg));*/

    msg.text = trim(msg.text);

    msg.index = n++;

    msgsByIndex.put(msg.index, msg);

    for (Tag t : unnull(tags)) {

      if (msg.tags.add(t.name))

        msgsByTag.put(t.name, msg);

    }

    if (nempty(msg.tags))

      taggedMsgs.add(msg);

  }

  print(l(taggedMsgs) + " tagged msgs.");

}

static void filterTag(S tag) {

  for (SlackMsg msg : msgs) {

    msg.tags = msg.tags.contains(tag) ? littreeset(tag) : main.<S> littreeset();

  }

}