db pytest runs for post and get single did

pkgs/clan-cli/clan_cli/webui/sql_models.py

@@ -35,7 +35,7 @@ class Entity(Base):
     producers = relationship("Producer", back_populates="entity")
     consumers = relationship("Consumer", back_populates="entity")
     repository = relationship("Repository", back_populates="entity")
-
+    #TODO maby refactor to repositories
 
 class ProducerAbstract(Base):
     __abstract__ = True

pkgs/clan-cli/tests/test_db_api.py

@@ -3,6 +3,43 @@ import json
 from api import TestClient
 
 
+default_entity_did_url = "entity_did=did%3Asov%3Atest%3A1234"
+default_entity_did = "did:sov:test:1234"
+
+def assert_extra_info(infos, request_body, response) -> None:
+    for info in infos:
+        assert info in response.keys()
+        #TODO maybe check the content of the extra info ...
+        response.pop(info)
+    assert response == request_body
+
+
+def make_test_post_and_get(api, request_body, paramter, get_request=default_entity_did_url, apiversion="v1") -> None:
+    #test post
+    response = api.post(f"/api/{apiversion}/create_{paramter}", 
+                data=json.dumps(request_body),
+                headers={"Content-Type": "application/json"})
+    assert response.status_code == 200
+    if paramter == "repository":
+        assert_extra_info(["time_created"], request_body, response.json())
+    elif paramter == "consumer":
+        assert_extra_info(["id"], request_body, response.json())
+    elif paramter == "entity":
+        assert_extra_info(["consumers", "producers", "repository"], request_body, response.json())
+    else:
+        assert response.json() == request_body
+    #test get
+    response = api.get(f"api/{apiversion}/get_{paramter}?{get_request}&skip=0&limit=100")
+    assert response.status_code == 200
+    if paramter == "repository":
+        assert_extra_info(["time_created"], request_body, response.json()[0])
+    elif paramter == "consumer":
+        assert_extra_info(["id"], request_body, response.json()[0])
+    elif paramter == "entity":
+        assert_extra_info(["consumers", "producers", "repository"], request_body, response.json())
+    else:
+        assert response.json() == [request_body]
+
 
 #########################
 #                       #
@@ -19,15 +56,68 @@ def test_producer(api: TestClient) -> None:
                     "other": {
                         "test": "test"
                     },
-                    "entity_did": "did:sov:test:1234"
+                    "entity_did": default_entity_did
                     }
-    #test post
+    paramter = "producer"
-    response = api.post(f"/api/v1/create_producer", 
+    #get_request = "entity_did=did%3Asov%3Atest%3A1234"
-                data=json.dumps(request_body),
+    make_test_post_and_get(api, request_body, paramter)
-                headers={"Content-Type": "application/json"})
+
-    assert response.status_code == 200
+
-    assert response.json() == request_body
+#########################
-    #test get
+#                       #
-    response = api.get(f"api/v1/get_producer?entity_did=did%3Asov%3Atest%3A1234&skip=0&limit=100")
+#       Consumer        #
-    assert response.status_code == 200
+#                       #
-    assert response.json() == [request_body]
+#########################
+def test_consumer(api: TestClient) -> None:
+    request_body = {
+                    "entity_did": default_entity_did,
+                    "producer_uuid": "8e285c0c-4e40-430a-a477-26b3b81e30df",
+                    "other": {
+                        "test": "test"
+                    }
+                }
+    paramter = "consumer"
+    #get_request = "entity_did=did%3Asov%3Atest%3A1234"
+    make_test_post_and_get(api, request_body, paramter)
+
+
+#########################
+#                       #
+#       REPOSITORY      #
+#                       #
+#########################
+def test_repository(api: TestClient) -> None:
+    request_body = {
+                "uuid": "8e285c0c-4e40-430a-a477-26b3b81e30df",
+                "service_name": "Carlo'\''s Printing",
+                "service_type": "3D Printing",
+                "endpoint_url": "http://127.0.0.1:8000",
+                "status": "unknown",
+                "other": {
+                    "test": "test"
+                },
+                "entity_did": default_entity_did
+                }
+    paramter = "repository"
+    #get_request = "entity_did=did%3Asov%3Atest%3A1234"
+    make_test_post_and_get(api, request_body, paramter)
+
+
+#########################
+#                       #
+#        Entity         #
+#                       #
+#########################
+def test_entity(api: TestClient) -> None:
+    request_body = {
+                "did": default_entity_did,
+                "name": "C1",
+                "ip": "127.0.0.1",
+                "attached": False,
+                "other": {
+                    "test": "test"
+                }
+                }
+    paramter = "entity"
+    #get_request = "entity_did=did%3Asov%3Atest%3A1234"
+    make_test_post_and_get(api, request_body, paramter)