fixed bug in feature store update; added debug logging

Author: pkaeding

ldclient/client.py

@@ -130,7 +130,8 @@ def upsert(self, key, feature):
             self._lock.lock()
             f = self._features.get(key)
             if f is None or f['version'] < feature['version']:
-                self._features[key] = f
+                self._features[key] = feature
+                log.debug("Updated feature {} to version {}".format(key, feature['version']))
         finally:
             self._lock.unlock()
 

ldclient/requests.py

@@ -80,11 +80,13 @@ def stop(self):
     @staticmethod
     def process_message(store, msg):
         payload = json.loads(msg.data)
+        log.debug("Recieved stream event {}".format(msg.event))
         if msg.event == 'put':
             store.init(payload)
         elif msg.event == 'patch':
             key = payload['path'][1:]
             feature = payload['data']
+            log.debug("Updating feature {}".format(key))
             store.upsert(key, feature)
         elif msg.event == 'delete':
             key = payload['path'][1:]