static int slackSpeed = 1000;

static int historySuckSize = 10;

static L<S> attnPrefixes = litlist("!", "bot");

static new L<Channel> channels;

static class Channel {

  S teamName;

  S channelName; // includes the site

  S channelID;

  S tokenPath;

  boolean generalRelease, postAsUser;

  boolean firstTime = true;

  new Map<S, Map> userInfos;

  S lastQuestion, lastAnswer;

  S lastAnswerTimestamp; // only for posted in this session

  int lastAnswerScore;

  void tendTo() {

    if (lastAnswerTimestamp != null) {

      // Poll reactions to our last answer - is there a more efficient way?

      int score = slackReactionScore(token, channelID, lastAnswerTimestamp);

      if (score != lastAnswerScore) {

        print("Reaction score changes to " + score);

        recordFeedback(lastQuestion, lastAnswer, lastAnswerTimestamp, "emoji", score-lastAnswerScore);

        lastAnswerScore = score;

      }

    }

    L<SlackMsg> qs = getNewQuestions();

    //print(l(qs) + " question(s).");

    //printList(qs);

    for (SlackMsg msg : qs) if (!isMyAnswer(msg)) {

      S q = msg.text;

      S userName = getUserName(msg.user);

      Map userInfo = getUserInfo(msg.user);

      if (userInfo != null && eq(true, userInfo.get("is_bot"))) {

        print("Skipping question from bot " + userName + ": " + quote(q));

        continue;

      }

      q = q.trim();

      print("Processing question: " + quote(q));

      if (lastAnswer != null) { // TODO: maybe check the time delay

        int score = feedbackScore(q);

        if (score != 0) {

          recordFeedback(lastQuestion /*lastPostByUser.get(userName)*/, lastAnswer, lastAnswerTimestamp, q, score);

          if (score > 0)

            pcall { slackSmile(token, channelID, msg.ts); }

          else

            pcall { slackReact(token, channelID, msg.ts, "thinking_face"); }

        }

        lastAnswer = null;

      }

      //if (userName != null) lastPostByUser.put(userName, msg.text);

      pcall {

        originalLine.set(q);

        main.userName.set(userName);

        S dialogID = "slack-" + userName;

        main.dialogID.set(dialogID);

        main.slackTS.set(msg.ts);

        main.channelName.set(channelName);

        // attn yes/no?

        attn.set(false);

        pcall {

          if (attnPrefixes.contains(get(javaTok(q), 1))) {

            attn.set(true);

            q = join(subList(javaTok(q), 3)).trim();

          }

        }

        S a = answer(q, generalRelease);

        if (a != null) {

          // slack snippets have some size limit - let's forget that

          /*if (l(a) > maxAnswerLength)

            a = "```" + a + "```";*/

          // post long stuff to tinybrain instead

          if (l(a) > maxAnswerLength) {

            S title = "Answer for " + userName + " (>> " + q + ")";

            S id = ntUpload("eleutheria-for-user", title, unSlackSnippet(a));

            boolean isSnippet = a.contains("```");

            a = shorten(a, shortenTo) + (isSnippet ? "```" : "") + "\nFull answer here: tinybrain.de/" + parseSnippetID(id);

          }

          if (userName != null)

            a = "<@" + userName + "> " + a;

          print("Answering with: " + quote(a));

          lastAnswer = a;

          lastQuestion = q;

          if (actuallyPost) {

            S answerTime = postAnswer(a);

            Map logEntry = litmap("question", q, "answertime", answerTime, "answer", a, "user", userName);

            historyAdd(logEntry);

          }

        }

      }

    }

  }

  Map getUserInfo(S userID) {

    if (userID == null) ret null;

    Map userInfo = userInfos.get(userID);

    if (userInfo == null) pcall {

      userInfo = slackGetUserInfo(token, userID);

      userInfos.put(userID, userInfo);

    }

    ret userInfo;

  }

  S getUserName(S userID) {

    Map userInfo = getUserInfo(userID);

    ret userInfo == null ? null : (S) userInfo.get("name");

  }

  // returns the slack timestamp

  S postAnswer(S text) {

    S username = botUserName;

    S url = "https://slack.com/api/chat.postMessage";

    Map postData = litmap(

      "token", token,

      "channel", channelID,

      "text", text,

      "username", username/*,

      "parse", "none",

      "link_names", "1"*/);

    if (postAsUser)

      postData.put("as_user", "true");

    printStructure(postData);

    S data = doPost(postData, url);

    Map map = jsonDecodeMap(data);

    lastAnswerTimestamp = (S) map.get("ts");

    lastAnswerScore = 0;

    print("postAnswer: " + data);

    ret lastAnswerTimestamp;

  }

  S getNewQuestions_lastSeen;

  L<SlackMsg> getNewQuestions() {

    // Get historySuckSize on first call (history before bot start)

    // and 1000 thereafter (just grab anything new)

    int limit = getNewQuestions_lastSeen == null ? historySuckSize : 1000;

    L<SlackMsg> msgs = slackReadChannel(channelID, token, limit, getNewQuestions_lastSeen);

    if (!msgs.isEmpty()) getNewQuestions_lastSeen = last(msgs).ts;

    int i = indexOfLastBotAnswer(msgs);

    if (i >= 0) {

      print("Last bot answer at " + (i+1) + "/" + l(msgs) + ": " + structure(msgs.get(i)));

      // update variables

      lastAnswer = msgs.get(i).text;

      for (int j = 0; j < i; j++) {

        SlackMsg msg = msgs.get(j);

        S userName = getUserName(msg.user);

        //if (userName != null) lastPostByUser.put(userName, msg.text);

      }

      if (firstTime)

        msgs = subList(msgs, i+1);

    }

    firstTime = false;

    ret msgs;

  }

} // end of class Channel

static void initSlackBot() {

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

  S devChannelToken = devChannelToken();

  S nlbotsToken = loadSecretTextFileMandatory("#1001925", "nlbots-slack-token").trim();

  Channel c;

  c = new Channel;

  c.channelName = "devchannel, #general";

  c.channelID = "C0H0Q0J3D";

  c.token = devChannelToken;

  c.postAsUser = true;

  channels.add(c);

  c = new Channel;

  c.channelName = "devchannel, #talkingbots";

  c.channelID = "C0H0SR40J";

  c.token = devChannelToken;

  c.postAsUser = true;

  channels.add(c);

  c = new Channel;

  c.channelName = "devchannel, #programming";

  c.channelID = "C0H0MG0F6";

  c.token = devChannelToken;

  c.postAsUser = true;

  channels.add(c);

  c = new Channel;

  c.channelName = "devchannel, #c_sharp";

  c.channelID = "C0H0T0EQ6";

  c.token = devChannelToken;

  c.postAsUser = true;

  channels.add(c);

  c = new Channel;

  c.channelName = "nlbots, #general";

  c.channelID = "C0FHTG6SY"; // nlbots, #general

  c.token = nlbotsToken;

  channels.add(c);

  /*c = new Channel;

  c.channelID = "C0G5GPEMR"; // nlbots, #talkingbots

  c.token = nlbotsToken;

  channels.add(c);*/

  /*c = new Channel;

  c.channelID = "G0HLW98RY"; // devchannel, #bot_test

  c.token = devChannelToken;

  c.postAsUser = true;

  channels.add(c);*/

}

static int indexOfLastBotAnswer(L<SlackMsg> msgs) {

  for (int i = l(msgs)-1; i >= 0; i--)

    if (isMyAnswer(msgs.get(i))) ret i;

  ret -1;

}

static boolean isMyAnswer(SlackMsg msg) {

  ret msg.botName != null || eq(msg.userName, actualBotUserName);

}

static void slackBotLoop() {

  try {

    long lastPrinted = now();

    while true {

      for (Channel c : channels) pcall {

        c.tendTo();

      }

      sleep(slackSpeed);

      if (now() > lastPrinted + 60*1000) {

        lastPrinted = now();

        print("Slack loop still going. " + unixTime());

      }

    }

  } finally {

    print("Slack bot loop exit!?");

  }

}