// TODO: stop when removed!!

!7

lib 1002612 // websocket (tyrus)

import javax.websocket.*;
import org.glassfish.tyrus.client.*;

static PersistentLog<S> log;
static volatile long started, triedStarting;

p {
  log = new PersistentLog("log");
  thread "Slack RTM Bot" {
    background();
  }
}

synchronized answer {
  if "rtm started"
    ret yn(started != 0);
  if "rtm log size"
    ret lstr(log);
    
  if (master() && match("rtm last event", s))
    ret structure(last(log));
    
  if (master() && match("rtm clear", s)) {
    ret confirm("Clear RTM log?", new ClearLog);
  }
  
  try answer status_answer(s);
}

static class ClearLog {
  S answer(S s) {
    log.clear();
    ret "OK, cleared RTM log.";
  }
}

static void background() ctex {
  triedStarting = now();
  
  S token = devChannelToken();
  S url = "https://slack.com/api/rtm.start";
  Map postData = litmap("token", token, "no_unreads", "1");
  S data = doPost(postData, url);
  Map map = cast jsonDecode(data);
  //printStructure(map);
  
  S websocketURL = getString(map, "url");
  print("Websocket URL: " + websocketURL);
  assertTrue(nempty(websocketURL));
  
  final ClientEndpointConfig cec = ClientEndpointConfig.Builder.create().build();

  ClientManager client = ClientManager.createClient();
  client.connectToServer(new Endpoint() {
    public void onOpen(Session session, EndpointConfig config) ctex {
      session.addMessageHandler(new MessageHandler.Whole<String>() {
          public void onMessage(String message) {
            incomingMessage(message);
          }
      });
    }
  }, cec, new URI(websocketURL));
  
  started = now();
}

static synchronized void incomingMessage(S msg) {
  print("RTM incoming: " + msg);
  Map map = jsonDecodeMap(msg);
  if (!eq(getString(map, "type"), "reconnect_url")) // ignore those
    log.add(msg);
}