georgs #23

Closed
Ghost wants to merge 50 commits from georgs into main
3 changed files with 57 additions and 53 deletions
Showing only changes of commit ebfdf29f7b - Show all commits

View File

@@ -1,8 +1,9 @@
from typing import Generator from typing import Generator
from sqlalchemy import create_engine from sqlalchemy import create_engine
# from sqlalchemy.ext.declarative import declarative_base # from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import Session, sessionmaker, declarative_base from sqlalchemy.orm import Session, declarative_base, sessionmaker
URL = "sqlite:///./sql_app.db" URL = "sqlite:///./sql_app.db"

View File

@@ -37,6 +37,7 @@ class Entity(Base):
repository = relationship("Repository", back_populates="entity") repository = relationship("Repository", back_populates="entity")
# TODO maby refactor to repositories # TODO maby refactor to repositories
class ProducerAbstract(Base): class ProducerAbstract(Base):
__abstract__ = True __abstract__ = True

View File

@@ -1,11 +1,11 @@
import pytest
import json import json
from api import TestClient
from api import TestClient
default_entity_did_url = "entity_did=did%3Asov%3Atest%3A1234" default_entity_did_url = "entity_did=did%3Asov%3Atest%3A1234"
default_entity_did = "did:sov:test:1234" default_entity_did = "did:sov:test:1234"
def assert_extra_info(infos, request_body, response) -> None: def assert_extra_info(infos, request_body, response) -> None:
for info in infos: for info in infos:
assert info in response.keys() assert info in response.keys()
@@ -14,29 +14,39 @@ def assert_extra_info(infos, request_body, response) -> None:
assert response == request_body assert response == request_body
def make_test_post_and_get(api, request_body, paramter, get_request=default_entity_did_url, apiversion="v1") -> None: def make_test_post_and_get(
api, request_body, paramter, get_request=default_entity_did_url, apiversion="v1"
) -> None:
# test post # test post
response = api.post(f"/api/{apiversion}/create_{paramter}", response = api.post(
f"/api/{apiversion}/create_{paramter}",
data=json.dumps(request_body), data=json.dumps(request_body),
headers={"Content-Type": "application/json"}) headers={"Content-Type": "application/json"},
)
assert response.status_code == 200 assert response.status_code == 200
if paramter == "repository": if paramter == "repository":
assert_extra_info(["time_created"], request_body, response.json()) assert_extra_info(["time_created"], request_body, response.json())
elif paramter == "consumer": elif paramter == "consumer":
assert_extra_info(["id"], request_body, response.json()) assert_extra_info(["id"], request_body, response.json())
elif paramter == "entity": elif paramter == "entity":
assert_extra_info(["consumers", "producers", "repository"], request_body, response.json()) assert_extra_info(
["consumers", "producers", "repository"], request_body, response.json()
)
else: else:
assert response.json() == request_body assert response.json() == request_body
# test get # test get
response = api.get(f"api/{apiversion}/get_{paramter}?{get_request}&skip=0&limit=100") response = api.get(
f"api/{apiversion}/get_{paramter}?{get_request}&skip=0&limit=100"
)
assert response.status_code == 200 assert response.status_code == 200
if paramter == "repository": if paramter == "repository":
assert_extra_info(["time_created"], request_body, response.json()[0]) assert_extra_info(["time_created"], request_body, response.json()[0])
elif paramter == "consumer": elif paramter == "consumer":
assert_extra_info(["id"], request_body, response.json()[0]) assert_extra_info(["id"], request_body, response.json()[0])
elif paramter == "entity": elif paramter == "entity":
assert_extra_info(["consumers", "producers", "repository"], request_body, response.json()) assert_extra_info(
["consumers", "producers", "repository"], request_body, response.json()
)
else: else:
assert response.json() == [request_body] assert response.json() == [request_body]
@@ -49,14 +59,12 @@ def make_test_post_and_get(api, request_body, paramter, get_request=default_enti
def test_producer(api: TestClient) -> None: def test_producer(api: TestClient) -> None:
request_body = { request_body = {
"uuid": "8e285c0c-4e40-430a-a477-26b3b81e30df", "uuid": "8e285c0c-4e40-430a-a477-26b3b81e30df",
"service_name": "Carlo'\''s Printing", "service_name": "Carlo'''s Printing",
"service_type": "3D Printing", "service_type": "3D Printing",
"endpoint_url": "http://127.0.0.1:8000", "endpoint_url": "http://127.0.0.1:8000",
"status": "unknown", "status": "unknown",
"other": { "other": {"test": "test"},
"test": "test" "entity_did": default_entity_did,
},
"entity_did": default_entity_did
} }
paramter = "producer" paramter = "producer"
# get_request = "entity_did=did%3Asov%3Atest%3A1234" # get_request = "entity_did=did%3Asov%3Atest%3A1234"
@@ -72,9 +80,7 @@ def test_consumer(api: TestClient) -> None:
request_body = { request_body = {
"entity_did": default_entity_did, "entity_did": default_entity_did,
"producer_uuid": "8e285c0c-4e40-430a-a477-26b3b81e30df", "producer_uuid": "8e285c0c-4e40-430a-a477-26b3b81e30df",
"other": { "other": {"test": "test"},
"test": "test"
}
} }
paramter = "consumer" paramter = "consumer"
# get_request = "entity_did=did%3Asov%3Atest%3A1234" # get_request = "entity_did=did%3Asov%3Atest%3A1234"
@@ -89,14 +95,12 @@ def test_consumer(api: TestClient) -> None:
def test_repository(api: TestClient) -> None: def test_repository(api: TestClient) -> None:
request_body = { request_body = {
"uuid": "8e285c0c-4e40-430a-a477-26b3b81e30df", "uuid": "8e285c0c-4e40-430a-a477-26b3b81e30df",
"service_name": "Carlo'\''s Printing", "service_name": "Carlo'''s Printing",
"service_type": "3D Printing", "service_type": "3D Printing",
"endpoint_url": "http://127.0.0.1:8000", "endpoint_url": "http://127.0.0.1:8000",
"status": "unknown", "status": "unknown",
"other": { "other": {"test": "test"},
"test": "test" "entity_did": default_entity_did,
},
"entity_did": default_entity_did
} }
paramter = "repository" paramter = "repository"
# get_request = "entity_did=did%3Asov%3Atest%3A1234" # get_request = "entity_did=did%3Asov%3Atest%3A1234"
@@ -114,9 +118,7 @@ def test_entity(api: TestClient) -> None:
"name": "C1", "name": "C1",
"ip": "127.0.0.1", "ip": "127.0.0.1",
"attached": False, "attached": False,
"other": { "other": {"test": "test"},
"test": "test"
}
} }
paramter = "entity" paramter = "entity"
# get_request = "entity_did=did%3Asov%3Atest%3A1234" # get_request = "entity_did=did%3Asov%3Atest%3A1234"