050118999b
Curator- and Incoming-endpoints now return only the requested record and no additional surrounding structures.
111 lines
3.3 KiB
Python
111 lines
3.3 KiB
Python
from __future__ import annotations
|
|
|
|
import pytest
|
|
|
|
from dump_things_service import (
|
|
HTTP_200_OK,
|
|
HTTP_404_NOT_FOUND,
|
|
)
|
|
|
|
delete_record = {
|
|
'schema_type': 'abc:Person',
|
|
'pid': 'abc:delete-me',
|
|
'given_name': 'Detlef',
|
|
}
|
|
|
|
|
|
@pytest.mark.parametrize('paginate', ('', 'p/'))
|
|
@pytest.mark.parametrize('class_name', ('', 'Person'))
|
|
def test_read_curated_records(
|
|
fastapi_client_simple,
|
|
paginate,
|
|
class_name,
|
|
):
|
|
test_client, _ = fastapi_client_simple
|
|
|
|
response = test_client.get(
|
|
f'/collection_1/curated/records/{paginate}{class_name}',
|
|
headers={'x-dumpthings-token': 'token_1_xxxxx'},
|
|
)
|
|
assert response.status_code == HTTP_200_OK
|
|
json_object = response.json()
|
|
|
|
if 'items' in json_object:
|
|
assert len(json_object['items']) == 3
|
|
else:
|
|
assert len(json_object) == 3
|
|
|
|
for pattern, count in (('%25wolf%25', 1), ('%25cura%25', 2)):
|
|
test_client, _ = fastapi_client_simple
|
|
response = test_client.get(
|
|
f'/collection_8/curated/records/{paginate}{class_name}?matching={pattern}',
|
|
headers={'x-dumpthings-token': 'token_1_xxxxx'},
|
|
)
|
|
assert response.status_code == HTTP_200_OK
|
|
json_object = response.json()
|
|
if 'items' in json_object:
|
|
assert len(json_object['items']) == count
|
|
else:
|
|
assert len(json_object) == count
|
|
|
|
|
|
pytest.mark.parametrize(
|
|
'pid',
|
|
('abc:mode_test', 'abc:some_timee@x.com', 'abc:curated'),
|
|
)
|
|
def test_read_curated_records_by_pid(fastapi_client_simple):
|
|
test_client, _ = fastapi_client_simple
|
|
|
|
response = test_client.get(
|
|
'/no_such_collection/curated/records/',
|
|
headers={'x-dumpthings-token': 'token_1_xxxxx'},
|
|
)
|
|
assert response.status_code == HTTP_404_NOT_FOUND
|
|
|
|
|
|
def test_unknown_collection(fastapi_client_simple):
|
|
test_client, _ = fastapi_client_simple
|
|
|
|
response = test_client.get(
|
|
'/no_such_collection/curated/records/',
|
|
headers={'x-dumpthings-token': 'token_1_xxxxx'},
|
|
)
|
|
assert response.status_code == HTTP_404_NOT_FOUND
|
|
|
|
|
|
def test_curated_delete(fastapi_client_simple):
|
|
test_client, _ = fastapi_client_simple
|
|
|
|
response = test_client.post(
|
|
'/collection_8/curated/record/Person',
|
|
headers={'x-dumpthings-token': 'token_1_xxxxx'},
|
|
json=delete_record,
|
|
)
|
|
assert response.status_code == HTTP_200_OK
|
|
|
|
response = test_client.get(
|
|
'/collection_8/curated/record?pid=abc:delete-me',
|
|
headers={'x-dumpthings-token': 'token_1_xxxxx'},
|
|
)
|
|
assert response.status_code == HTTP_200_OK
|
|
assert response.json()['pid'] == 'abc:delete-me'
|
|
|
|
response = test_client.delete(
|
|
'/collection_8/curated/record?pid=abc:delete-me',
|
|
headers={'x-dumpthings-token': 'token_1_xxxxx'},
|
|
)
|
|
assert response.status_code == HTTP_200_OK
|
|
assert response.json() is True
|
|
|
|
response = test_client.get(
|
|
'/collection_8/curated/record?pid=abc:delete-me',
|
|
headers={'x-dumpthings-token': 'token_1_xxxxx'},
|
|
)
|
|
assert response.status_code == HTTP_200_OK
|
|
assert response.json() is None
|
|
|
|
response = test_client.delete(
|
|
'/collection_8/curated/record?pid=abc:delete-me',
|
|
headers={'x-dumpthings-token': 'token_1_xxxxx'},
|
|
)
|
|
assert response.status_code == HTTP_404_NOT_FOUND
|