!752
//1002612 // javax.websocket + implementation (tyrus)
!1002664 // JDK 7 tyrus

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

p {
  S token = loadSecretTextFile("#1002653", "slack-token.txt");
if (token == null)
token = devChannelToken();
token = token.trim();
  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));
  
  // open websocket
  
  //final CountDownLatch messageLatch = new CountDownLatch(1);

  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>() {

          @Override
          public void onMessage(String message) {
              System.out.println("Received message: " + message);
              //messageLatch.countDown();
          }
      });
      //session.getBasicRemote().sendText(SENT_MESSAGE);
    }
  }, cec, new URI(websocketURL));
  //messageLatch.await(100, TimeUnit.SECONDS);
}