add api tests

Author: pgorecki

pyproject.toml

@@ -25,6 +25,8 @@ freezegun = "^1.1.0"
 SQLAlchemy-Utils = "^0.38.3"
 pre-commit = "^2.20.0"
 click = "8.0.4"
+httpx = "^0.23.1"
+requests = "^2.28.1"
 
 [tool.poetry.dev-dependencies]
 poethepoet = "^0.10.0"

src/api/tests/test_catalog.py

@@ -0,0 +1,62 @@
+from modules.catalog.application.command import CreateListingDraftCommand
+from seedwork.domain.value_objects import Money
+
+
+def test_empty_catalog_list(api_client):
+    response = api_client.get("/catalog")
+    assert response.status_code == 200
+    assert response.json() == {"data": []}
+
+
+def test_catalog_list_with_one_item(api, api_client):
+    # arrange
+    catalog_module = api.container.catalog_module()
+    with catalog_module.unit_of_work():
+        command_result = catalog_module.execute_command(
+            CreateListingDraftCommand(
+                title="Foo", description="Bar", ask_price=Money(10), seller_id="abcd"
+            )
+        )
+
+    # act
+    response = api_client.get("/catalog")
+
+    # assert
+    assert response.status_code == 200
+    response_data = response.json()["data"]
+    assert len(response_data) == 1
+    assert response.json() == {
+        "data": [
+            {
+                "id": str(command_result.result),
+                "title": "Foo",
+                "description": "Bar",
+                "ask_price_amount": 10.0,
+                "ask_price_currency": "USD",
+            }
+        ]
+    }
+
+
+def test_catalog_list_with_two_items(api, api_client):
+    # arrange
+    catalog_module = api.container.catalog_module()
+    with catalog_module.unit_of_work():
+        catalog_module.execute_command(
+            CreateListingDraftCommand(
+                title="Foo #1", description="Bar", ask_price=Money(10), seller_id="abcd"
+            )
+        )
+        catalog_module.execute_command(
+            CreateListingDraftCommand(
+                title="Foo #2", description="Bar", ask_price=Money(10), seller_id="abcd"
+            )
+        )
+
+    # act
+    response = api_client.get("/catalog")
+
+    # assert
+    assert response.status_code == 200
+    response_data = response.json()["data"]
+    assert len(response_data) == 2

src/api/tests/test_common.py

@@ -0,0 +1,15 @@
+from fastapi.testclient import TestClient
+
+from api.main import app
+
+client = TestClient(app)
+
+
+def test_homepage_returns_200():
+    response = client.get("/")
+    assert response.status_code == 200
+
+
+def test_docs_page_returns_200():
+    response = client.get("/docs")
+    assert response.status_code == 200

src/conftest.py

@@ -1,7 +1,9 @@
 import pytest
+from fastapi.testclient import TestClient
 from sqlalchemy import create_engine
 from sqlalchemy.orm import Session
 
+from api.main import app
 from config.api_config import ApiConfig
 from seedwork.infrastructure.database import Base
 
@@ -14,7 +16,6 @@ def engine():
     with engine.begin() as connection:
         Base.metadata.drop_all(connection)
         Base.metadata.create_all(connection)
-
         return engine
 
 
@@ -23,3 +24,14 @@ def db_session(engine):
 
     with Session(engine) as session:
         yield session
+
+
+@pytest.fixture
+def api(engine):
+    return app
+
+
+@pytest.fixture
+def api_client(api):
+    client = TestClient(api)
+    return client

src/seedwork/tests/application/test_decorators.py

@@ -1,7 +1,7 @@
 from dataclasses import dataclass
 
 from seedwork.application.commands import Command
-from seedwork.application.decorators import command_handler, registry
+from seedwork.application.decorators import command_handler, query_handler, registry
 from seedwork.application.queries import Query
 
 
@@ -45,9 +45,9 @@ def test_query_handler_decorator_registers_query_handler():
     class FooQuery(Query):
         ...
 
-    @command_handler
-    def foo_query_handler(command: FooQuery):
+    @query_handler
+    def foo_query_handler(query: FooQuery):
         ...
 
-    assert registry.get_command_handler_for(FooQuery) == foo_query_handler
-    assert registry.get_command_handler_parameters_for(FooQuery) == {}
+    assert registry.get_query_handler_for(FooQuery) == foo_query_handler
+    assert registry.get_query_handler_parameters_for(FooQuery) == {}