structured upcoming TODO

Author: shariq

firebase.py

@@ -33,19 +33,21 @@ def close(self):
 
 class RemoteThread(threading.Thread):
 
-    def __init__(self, URL, function):
+    def __init__(self, parent, URL, function):
         self.function = function
         self.URL = URL
+        self.parent = parent
         super(RemoteThread, self).__init__()
 
     def run(self):
         try:
             self.sse = ClosableSSEClient(self.URL)
             for msg in self.sse:
                 msg_data = json.loads(msg.data)
-                msg_event = msg.event
                 if msg_data is None:    # keep-alives
                     continue
+                msg_event = msg.event
+                # TODO: update parent cache here
                 self.function((msg.event, msg_data))
         except socket.error:
             pass    # this can happen when we close the stream
@@ -85,7 +87,8 @@ def firebaseURL(URL):
 class subscriber:
 
     def __init__(self, URL, function):
-        self.remote_thread = RemoteThread(firebaseURL(URL), function)
+        self.cache = {}
+        self.remote_thread = RemoteThread(self, firebaseURL(URL), function)
 
     def start(self):
         self.remote_thread.start()