Clone payloads.

Author: James Dalessio

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

@@ -22,6 +22,7 @@ def test_queue (self):
     time.sleep(2)
     channel.broadcast('m', 3)
     channel.broadcast('m', 4)
+    time.sleep(.5)
     if not listener.wait(2).payload in [3, 4]:
       raise Exception
     if not listener.wait(2).payload in [3, 4]:
@@ -78,3 +79,17 @@ def test_listener_timeout (self):
     except self.exp_sdk.NetworkError:
       return
     raise Exception
+
+  def test_cloning (self):
+    self.consumer_credentials['enable_network'] = True
+    exp = self.exp_sdk.start(**self.consumer_credentials)
+    channel = exp.get_channel('hi', consumer=True);
+    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