!7

lib 1400206 // jSlack 1.4.2 (fat jar)

import com.github.seratch.jslack.*;

import com.github.seratch.jslack.api.rtm.*;

import com.github.seratch.jslack.api.model.User;

import com.github.seratch.jslack.api.methods.request.users.*;

import com.github.seratch.jslack.api.methods.request.chat.*;

import com.github.seratch.jslack.api.methods.response.chat.*;

import com.github.seratch.jslack.api.methods.response.users.*;

static Slack slack;

sbool slackDump = true;

// no cmodule because of doPost / loadPage

module SlackModule > DynPrintLogAndEnabled {

  switchable S token;

  S botID;

  transient new ThreadLocal<Map> msgJSON;

  transient RTMClient rtm;

  start {

    if (!enabled) ret with print("Not enabled");

    vm_cleanPrints(); // avoid Swing Unicode problem

    logModuleOutput(); // good idea for chat bots

    dm_registerAs('slackModule);

    if (nempty(token))

      ret with startSlack();

    inputText("Please enter Slack bot token", voidfunc(S s) {

      setField(token := s);

      startSlack();

    });

  }

  void startSlack enter {

    ownResource(rtm = initSlackBot());

  }

  void getMyOwnUserInfo() ctex {

    User botUser = rtm.getConnectedBotUser();

    UsersInfoResponse response = slack.methods().usersInfo(

      UsersInfoRequest.builder().token(token).user(botUser.getId())

      .build());

    //print(response);

    setField(botID := response.getUser().getProfile().getBotId());

    print("My bot ID: " + botID);

  }

  RTMClient initSlackBot() ctex {

    if (slack != null) fail("Slack already started");

    fixContextClassLoader();

    slack = new Slack;

    RTMClient rtm = slack.rtm(token);

    rtm.addErrorHandler(error -> {

      print("Got Slack error: " + error);

      appendToTextFile("slack-errors.txt", "\n " + getStackTrace(error) + "\n");

      print("...reconnecting to be sure.");

      thread "Reconnect to Slack" {

        fixContextClassLoader();

        pcall { rtm.disconnect(); }

        print("Disconnected (hopefully)");

        print("Waiting 10, then reconnecting.");

        sleepSeconds(10);

        print("Reconnecting to Slack");

        try {

          rtm.connect();

          print("Done");

        } catch e {

          printStackTrace(e);

          print("Connect failed, restarting module.");

          dm_reloadModule();

        }

      }

    });

    rtm.addMessageHandler((message) -> {

      temp enter();

      Map json = jsonDecodeMap(message);

      if (slackDump) pnlStruct(json);

      if (eq(json.get("type"), "hello")) pcall {

        vmBus_send('slackConnected, this);

        getMyOwnUserInfo();

      }

      if (eq(json.get("type"), "message")) pcall {

        bool bot = eq(json.get("subtype"), "bot_message");

        S channelID = cast json.get("channel");

        S ts = cast json.get("ts");

        S text = cast json.get("text");

        vmBus_send('incomingSlackMessage,

          litmapparams(

            token := shorten(token, 10),

            myBotID := botID,

            module := dm_moduleID(),

            fromBot := bot,

            msgID := ts,

            +channelID,

            content := text,

            +json

            /*+isPrivate*/));

      }

    });

    // must connect within 30 seconds after issuing wss endpoint

    rtm.connect();

    print("Slack connect initiated");

    ret rtm;

  }

}