each doc insert as signed payload from client

Aquila-Network · Mar 9, 2021 · 2c5ba42 · 2c5ba42
1 parent bcbf119
commit 2c5ba42
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/src/router.py b/src/router.py
@@ -109,11 +109,12 @@ def insert_docs (docs, database_name):
     # and add CID
 
     for doc_ in docs:
-        if schema.validate_json_docs(database_h["schema"]["validator"], doc_):
-            CID_ = CID.doc2CID(doc_)
+        payload = doc_["payload"]
+        if schema.validate_json_docs(database_h["schema"]["validator"], payload):
+            CID_ = CID.doc2CID(payload)
             cids_.append(CID_)
-            doc_["CID"] = CID_
-            docs_.append(doc_)
+            payload["CID"] = CID_
+            docs_.append(payload)
         else:
             cids_.append(None)