allow to send events of other user, if the first one has permissions

Author: javierdallamore

src/eventfabric.py

@@ -54,7 +54,7 @@ def send_event(self, event, requester=requests.post):
         headers = {'content-type': 'application/json'}
         if self.token:
             headers[self.session_header_name] = self.token
-        url = self.endpoint("streams") + "/" + self.username + "/" + event.channel + "/"
+        url = self.endpoint("streams") + "/" + (event.username or self.username) + "/" + event.channel + "/"
         response = requester(url,
                 verify = False,
                 data=json.dumps(event.value),
@@ -71,15 +71,18 @@ class Event(object):
     channel is a string with the name that identifies this kind of events
     username is the logged in username"""
 
-    def __init__(self, value, channel):
-
+    def __init__(self, value, channel, username=None):
         self.value = value
         self.channel = channel
+        self.username = username
 
     @property
     def json(self):
         """return a json representation of the object"""
-        return {"value": self.value, "channel": self.channel}
+        res = {"value": self.value, "channel": self.channel}
+        if self.username is not None:
+            res["username"] = self.username
+        return res
 
     def __str__(self):
         return json.dumps(self.json)

tests/eventfabric_tests.py

@@ -14,9 +14,10 @@
 
 class FakeResponse(object):
     "fake response object"
-    def __init__(self, status_code=200, cookies=None):
+    def __init__(self, status_code=200):
         self.status_code = status_code
-        self.cookies = cookies
+    def json(self):
+        return {"token": "mytoken"}
 
 def fake_post(storage, return_value):
     "build a fake post function"
@@ -38,7 +39,6 @@ def test_client_creation(self):
         self.assertEqual(client.username, USERNAME)
         self.assertEqual(client.password, PASSWORD)
         self.assertEqual(client.root_url, "http://localhost:8080/")
-        self.assertEqual(client.cookies, None)
         self.assertEqual(client.credentials["username"], USERNAME)
         self.assertEqual(client.credentials["password"], PASSWORD)
 
@@ -53,7 +53,7 @@ def test_login(self):
         client = ef.Client(USERNAME, PASSWORD,
                 "http://localhost:8080/")
         storage = []
-        requester = fake_post(storage, FakeResponse(200, "cookies!"))
+        requester = fake_post(storage, FakeResponse(200))
         status, response = client.login(requester)
         args, kwargs = storage.pop()
         endpoint = args[0]
@@ -62,8 +62,6 @@ def test_login(self):
 
         self.assertTrue(status)
         self.assertEqual(response.status_code, 200)
-        self.assertEqual(response.cookies, "cookies!")
-        self.assertEqual(response.cookies, client.cookies)
         self.assertEqual(data_arg, json.dumps(client.credentials))
         self.assertEqual(headers["content-type"], "application/json")
         self.assertEqual(endpoint, "http://localhost:8080/sessions")
@@ -84,7 +82,7 @@ def test_send_event(self):
 
         self.assertTrue(status) 
         self.assertEqual(response.status_code, 201)
-        self.assertEqual(data_arg, json.dumps(event.json))
+        self.assertEqual(data_arg, json.dumps(event.json["value"]))
         self.assertEqual(headers["content-type"], "application/json")
         self.assertEqual(endpoint, "http://localhost:8080/streams/" + USERNAME + "/" + channel + "/")