!752

static S channelID = "C0FH9PY8J"; // relp, #talkingbots

static S token;

static PersistentLog<SlackMsg> msgs;

static new Map<S, S> lastSeenByChannel;

p {

  if (token == null)

    token = loadSecretTextFileMandatory("#1001889", "relp-slack-botstuff-token").trim();

  msgs = new PersistentLog<SlackMsg>("msgs");

  for (SlackMsg msg : msgs) {

    S s = lastSeenByChannel.get(msg);

    if (s == null || msg.ts.compareTo(s) > 0)

      lastSeenByChannel.put(channelID, msg.ts);

  }

  while true {

    pcall {

      int limit = 1000;

      L<SlackMsg> newMsgs = slackReadChannel(channelID, token, limit, 

        lastSeenByChannel.get(channelID));

      msgs.addAll(newMsgs);

      if (!newMsgs.isEmpty()) { 

        print(l(newMsgs) + " new messages in " + channelID + ".");

        lastSeenByChannel.put(channelID, last(newMsgs).ts);

      }

    }

    sleepSeconds(5);

  }

}