wkwk

<!DOCTYPE html>

<html>
<body>
<script type="text/javascript" src="{{url('assets/js/jquery-1.11.2.min.js')}}"></script>
<script type="text/javascript" src="{{url('assets/js/mqttws31.js')}}"></script>
<!-- <script type="text/javascript" src="mqttws31.js"></script> -->
<script type="text/javascript">

  // Create a client instance
  //client = new Paho.MQTT.Client("host", port,"client_id");
  client = new Paho.MQTT.Client("m10.cloudmqtt.com", 32111, "web_" + parseInt(Math.random() * 100, 10));

  // set callback handlers
  client.onConnectionLost = onConnectionLost;
  client.onMessageArrived = onMessageArrived;
  var options = {
    useSSL: true,
    userName: "yqffttwm",
    password: "eNj5k4a6eN5h",
    onSuccess:onConnect,
    onFailure:doFail
  }

  // connect the client
  client.connect(options);

  // called when the client connects
  function onConnect() {
    // Once a connection has been made, make a subscription and send a message.
    console.log("onConnect");
    client.subscribe("/chat");
    client.subscribe("/typing");
    client.subscribe("/deltyping");
  }

  function doFail(e){
    console.log(e);
  }

  // called when the client loses its connection
  function onConnectionLost(responseObject) {
    if (responseObject.errorCode !== 0) {
      console.log("onConnectionLost:"+responseObject.errorMessage);
    }
  }

  // called when a message arrives
  function onMessageArrived(message) {
    switch(message.destinationName){
       case "/chat":
       var user = JSON.parse(message.payloadString);
       $("#chat-div").append("<b>"+user.username+"</b> : "+user.msg+"<br>");
       $("#"+user.types).remove();
       break;
      case "/typing":
      var user = JSON.parse(message.payloadString);
       $("#typing-div").append("<span id='"+user.types+"'>"+user.text+"<br></span>");
       break;
        case "/deltyping":
        console.log(message.payloadString);
       $(message.payloadString).remove();
       break;
    }
  }