Add admin check to allow events. (#112)

If the user is an admin user the event should be allowed.

Signed-off-by: David Brown <dmlb2000@gmail.com>

pacifica/policy/events/rest.py

@@ -25,6 +25,8 @@ def POST(self, username):
         userinfo = self._user_info_from_kwds(
             network_id=username, recursion_depth=0, recursion_limit=1)
         if event_obj.get('eventType', False) != 'org.pacifica.metadata.ingest':
+            if self._is_admin(userinfo[0]['_id']):
+                return {'status': 'success'}
             raise cherrypy.HTTPError(
                 412,
                 text_type('Precondition Failed: Invalid eventType for {0}').format(

tests/events_test.py

@@ -25,10 +25,20 @@ def test_events_query(self):
         self.assertTrue('status' in ret_data)
         self.assertEqual(ret_data['status'], 'success')
 
+    def test_admins_events_query(self):
+        """Admin get valid events of any type."""
+        valid_query = loads(open(
+            join(dirname(realpath(__file__)), 'test_files', 'events_orm.json')
+        ).read())
+        ret_data = self.get_json_page('/events/dmlb2001', valid_query)
+        self.assertFalse(ret_data is None)
+        self.assertTrue('status' in ret_data)
+        self.assertEqual(ret_data['status'], 'success')
+
     def test_bad_events_query(self):
         """Test posting the queries."""
         invalid_query = {'some': {'random': 'data'}, 'in': ['a', 'hash']}
-        self.getPage('/events/dmlb2001',
+        self.getPage('/events/dmlb2000',
                      self.headers +
                      [('Content-Length', str(len(dumps(invalid_query))))],
                      'POST',

tests/test_files/events_orm.json

@@ -0,0 +1,20 @@
+{
+  "cloudEventsVersion": "0.1",
+  "contentType": "application/json",
+  "data": {
+    "method": "update",
+    "obj_primary_keys": [
+      {
+        "_id": 1234
+      }
+    ],
+    "obj_type": "users"
+  },
+  "eventID": "1852d1bf-e308-4cf8-bc94-3ad045a3b8b5",
+  "eventTime": "2018-04-05T17:31:00Z",
+  "eventType": "org.pacifica.metadata.orm",
+  "extensions": {
+    "comExampleExtension": "value"
+  },
+  "source": "/mycontext"
+}