1 files changed, 31 insertions, 0 deletions
diff --git a/src/beer-duke.js b/src/beer-duke.js
new file mode 100644
index 0000000..8178836
--- /dev/null
+++ b/src/beer-duke.js
@@ -0,0 +1,31 @@
+import angular from 'angular';
+
+function run() {
+  function onConnect() {
+    // Once a connection has been made, make a subscription and send a message.
+    console.log("onConnect");
+    client.subscribe("/World");
+    let message = new Paho.MQTT.Message("Hello");
+    message.destinationName = "/World";
+    client.send(message);
+  }
+
+  function onConnectionLost(responseObject) {
+    if (responseObject.errorCode !== 0)
+      console.log("onConnectionLost:" + responseObject.errorMessage);
+  }
+
+  function onMessageArrived(message) {
+    console.log("onMessageArrived:" + message.payloadString);
+    client.disconnect();
+  }
+
+  //let client = new Paho.MQTT.Client("trygvis.io", 9001, "/", "clientId");
+  let client = new Paho.MQTT.Client("wss://trygvis.io:9001/", "clientId");
+  client.onConnectionLost = onConnectionLost;
+  client.onMessageArrived = onMessageArrived;
+  client.connect({onSuccess: onConnect});
+}
+
+angular.module('BeerDuke', [])
+  .run(run);