Merge pull request #28 from ScalaInc/release-1.0.6

Clone event payloads to prevent cross reference

Author: adamgallowayscala

exp_sdk/network.py

@@ -19,8 +19,8 @@ def __init__(self, sdk, message):
     self.time = int(time.time())
 
   @property
-  def payload(self):
-    return self._message['payload']
+  def payload (self):
+    return json.loads(json.dumps(self._message['payload']))
 
   def respond(self, response):
     self._sdk.api.post('/api/networks/current/responses', {'id': self._message['id'], 'channel': self._message['channel'], 'payload': response })

tests/test_network.py

@@ -18,6 +18,7 @@ def test_queue (self):
     channel = self.exp.get_channel(self.generate_name())
     listener = channel.listen('m', max_age=1)
     channel.broadcast('m', 1)
+    time.sleep(.1)
     channel.broadcast('m', 2)
     time.sleep(2)
     channel.broadcast('m', 3)
@@ -30,6 +31,18 @@ def test_queue (self):
       raise Exception
 
 
+  def test_cloning (self):
+    channel = self.exp.get_channel(self.generate_name())
+    listener1 = channel.listen('hi')
+    listener2 = channel.listen('hi');
+    channel.broadcast('hi', {});
+    
+    broadcast = listener1.wait(5)
+    broadcast.payload['a'] = 1
+    broadcast2 = listener2.wait(5)
+    if 'a' in broadcast.payload and broadcast.payload['a'] == 1:
+      raise Exception
+
 
 
 class Test2 (utils.Base):
@@ -78,3 +91,4 @@ def test_listener_timeout (self):
     except self.exp_sdk.NetworkError:
       return
     raise Exception
+