refactor Telemetry classes to model

Author: chillaq

splitio/engine/telemetry.py

@@ -186,8 +186,8 @@ def pop_latencies(self):
 
     def pop_formatted_stats(self):
         """Get formatted and reset stats."""
-        exceptions = self.pop_exceptions()
-        latencies = self.pop_latencies()
+        exceptions = self.pop_exceptions()['methodExceptions']
+        latencies = self.pop_latencies()['methodLatencies']
         return {
             **{'mE': {'t': exceptions['treatment'],
                       'ts': exceptions['treatments'],
@@ -220,7 +220,7 @@ def get_events_stats(self, type):
 
     def get_last_synchronization(self):
         """Get last sync"""
-        return self._telemetry_storage.get_last_synchronization()
+        return self._telemetry_storage.get_last_synchronization()['lastSynchronizations']
 
     def pop_tags(self):
         """Get and reset http errors."""
@@ -253,8 +253,8 @@ def get_session_length(self):
     def pop_formatted_stats(self):
         """Get formatted and reset stats."""
         last_synchronization = self.get_last_synchronization()
-        http_errors = self.pop_http_errors()
-        http_latencies = self.pop_http_latencies()
+        http_errors = self.pop_http_errors()['httpErrors']
+        http_latencies = self.pop_http_latencies()['httpLatencies']
         return {
             **{'iQ': self.get_impressions_stats('impressionsQueued')},
             **{'iDe': self.get_impressions_stats('impressionsDeduped')},
@@ -291,7 +291,7 @@ def pop_formatted_stats(self):
             **{'sE': [{'e': event['type'],
                        'd': event['data'],
                        't': event['time']
-                      } for event in self.pop_streaming_events()]
+                      } for event in self.pop_streaming_events()['streamingEvents']]
                 },
             **{'sL': self.get_session_length()}
         }