feat(main.py): Store events in eventhistory collection

Any event must be stored to eventhistory collection

Signed-off-by: Denys Fedoryshchenko <[email protected]>

api/main.py

@@ -37,6 +37,7 @@
     PublishEvent,
     parse_node_obj,
     KernelVersion,
+    EventHistory,
 )
 from .auth import Authentication
 from .db import Database
@@ -486,6 +487,13 @@ async def delete_group(group_id: str,
 
     await db.delete_by_id(UserGroup, group_id)
 
+# -----------------------------------------------------------------------------
+# EventHistory
+def _get_eventhistory(evdict):
+    """Get EventHistory object from dictionary"""
+    evhist = EventHistory()
+    evhist.data = evdict
+    return evhist
 
 # -----------------------------------------------------------------------------
 # Nodes
@@ -650,6 +658,8 @@ async def post_node(node: Node,
     if data.get('owner', None):
         attributes['owner'] = data['owner']
     await pubsub.publish_cloudevent('node', data, attributes)
+    evhist = _get_eventhistory(data)
+    await db.create(evhist)
     return obj
 
 
@@ -695,6 +705,8 @@ async def put_node(node_id: str, node: Node,
     if data.get('owner', None):
         attributes['owner'] = data['owner']
     await pubsub.publish_cloudevent('node', data, attributes)
+    evhist = _get_eventhistory(data)
+    await db.create(evhist)
     return obj
 
 
@@ -735,6 +747,8 @@ async def put_nodes(
     if data.get('owner', None):
         attributes['owner'] = data['owner']
     await pubsub.publish_cloudevent('node', data, attributes)
+    evhist = _get_eventhistory(data)
+    await db.create(evhist)
     return obj_list