add update observable

GreengrassAwareConnection.py

@@ -33,7 +33,7 @@ class GreengrassAwareConnection:
     GROUP_CA_PATH = "./groupCA/"
     OFFLINE_QUEUE_DEPTH = 100
 
-    def __init__(self, host, rootCA, cert, key, thingName):
+    def __init__(self, host, rootCA, cert, key, thingName, stateChangeQueue = None):
         self.logger = logging.getLogger("GreengrassAwareConnection")
         self.logger.setLevel(logging.DEBUG)
         streamHandler = logging.StreamHandler()
@@ -47,6 +47,8 @@ def __init__(self, host, rootCA, cert, key, thingName):
         self.key = key
         self.thingName = thingName
 
+        self.stateChangeQueue = stateChangeQueue
+
         self.backOffCore = ProgressiveBackOffCore()
 
         self.discovered = False
@@ -151,9 +153,13 @@ def memberDeltaHandler(self, payload, responseStatus, token):
         print("\nReceived a Delta Message")
 
         payloadDict = json.loads(payload)
-        deltaMessage = json.dumps(payloadDict["state"])
+        state = payloadDict['state']
+        deltaMessage = json.dumps(deltaMessage)
         print(deltaMessage + "\n")
 
+        if self.stateChangeQueue != None:
+            self.stateChangeQueue.append(state)
+
 
 
     def connectShadow(self):

pentair-control.py

@@ -140,6 +140,8 @@ def update(self, objects):
 frames = ObservableArray()
 state = ObservableDict()
 
+deltas = ObservableArray()
+
 
 if len(inFile) > 0:
     print(f'using {inFile} as source')
@@ -171,7 +173,7 @@ def update(self, objects):
     frames.addObserver(output)
 
 try:
-    iotConnection = GreengrassAwareConnection(host, rootCA, cert, key, thingName)
+    iotConnection = GreengrassAwareConnection(host, rootCA, cert, key, thingName, deltas)
 
     iotConnection.deleteShadow()
 except Exception as e: