Subscriptions

Helpers/OpenT2T-Wink-Helper/js/index.js

@@ -3,6 +3,9 @@
 var https = require('https');
 var q = require('q');
 
+
+
+
 //this is our base, we refactor these options in each method
 
 var protocolVal = 'https:';
@@ -191,7 +194,69 @@ module.exports =
     //make our Promise and give it back to the caller
     return deferred.promise;
 
-   }   
+   } ,
+
+   getSubscription:function()
+   {
+
+     var deferred = q.defer();   // q will help us with returning a promise
+
+    var options = 
+    {
+        protocol: protocolVal,
+        host: hostVal,
+        path: apiPath     
+    };
+
+    //the headers to make our call
+    options.headers = 
+    {
+        'Authorization': 'Bearer ' + accessToken,
+        'Content-Type': 'application/json',
+        'Accept': 'application/json', 
+    }
+
+    //our HTTPS call 
+    var req = https.get(options, (res) => {
+       var body = ' '; //holds the chunks of data
+        res.on('data', (chunk) => 
+        {
+          body += chunk; 
+        });
+        res.on('end', () => 
+        {
+            try
+            {    
+            //parse the JSON response and give back the pubnub details
+             var results = JSON.parse(body.toString());
+            deferred.resolve(results.data.subscription);
+
+            } catch(err)
+            {
+             deferred.reject(err);
+            }
+
+        });
+        res.on('error', (e) => {
+            deferred.reject(e);
+        }); });
+
+    req.on('error', (e) => {
+        console.log('problem with request:');
+        deferred.reject(e);
+    });
+
+    req.end();   
+
+    //make our Promise and give it back to the caller
+    return deferred.promise;   
+
+
+
+
+
+
+   }
 
 
 }

Helpers/OpenT2T-Wink-Helper/js/package.json

@@ -5,6 +5,7 @@
     "dependencies": {
         "request":"2.72.0",
         "q":"1.4.1"
+
     },
     "devDependencies": { 
     },

org.OpenT2T.Sample.SuperPopular.Doorbell/Wink Doorbell/js/package.json

@@ -8,7 +8,8 @@
     "devDependencies": {
         "optimist": "0.6.1",
         "opent2t-onboarding-winkhub": "*",
-        "q": "1.4.1"
+        "q": "1.4.1",
+        "pubnub":"3.15.2"
     },
     "author": "",
     "license": "MIT"

org.OpenT2T.Sample.SuperPopular.Doorbell/Wink Doorbell/js/thingTranslator.js

@@ -62,6 +62,32 @@ module.exports = {
 
     isButtonPressed: function() {
         console.log('getting if doorbell Pressed');
+
+
+        wh.getSubscription().then(result => {
+        var PubNubkey =  result.pubnub.subscribe_key;
+        var PubNubchannel =  result.pubnub.channel;
+
+        console.log("key is " + PubNubkey);
+        var pubnub = require("pubnub")({
+            ssl           : true,  // <- enable TLS Tunneling over TCP
+            subscribe_key : PubNubkey
+        });
+
+        pubnub.subscribe({
+        channel  : PubNubchannel,
+   	    message : function(message) {
+        console.log( " > doorbell");
+        console.log( " > ", message);
+        }
+    });
+    }).catch(error => {
+        console.log(error.message);
+        throw error;
+    });;
+
+
+
         return logPromise(wh.getLastReading('button_pressed')); 
     },   
 

org.OpenT2T.Sample.SuperPopular.SmokeDetector/Wink Smoke Detector/js/package.json

@@ -9,7 +9,8 @@
         "async": "~1.5.2",
         "optimist": "0.6.1",
         "opent2t-onboarding-winkhub": "*",
-        "q": "1.4.1"
+        "q": "1.4.1",
+        "pubnub":"3.15.2"
     },
     "author": "",
     "license": "MIT"

org.OpenT2T.Sample.SuperPopular.SmokeDetector/Wink Smoke Detector/js/thingTranslator.js

@@ -63,6 +63,29 @@ module.exports = {
 
     getSmokeDetected: function() {
         console.log('checking for smoke:');
+
+    wh.getSubscription().then(result => {
+        //get details
+        var PubNubkey =  result.pubnub.subscribe_key;
+        var PubNubchannel =  result.pubnub.channel;
+
+        console.log("key is " + PubNubkey);
+        var pubnub = require("pubnub")({
+            ssl           : true,  // <- enable TLS Tunneling over TCP
+            subscribe_key : PubNubkey
+        });
+        //call this whenever a change happens
+        pubnub.subscribe({
+        channel  : PubNubchannel,
+   	    message : function(message) {
+        console.log( " > Smoke State Changed!");
+        console.log( " > ", message);
+        }
+    });
+    }).catch(error => {
+        console.log(error.message);
+        throw error;
+    });;
 
         return logPromise(wh.getLastReading('smoke_detected')); 
     },