Test the event input endpoint

Author: febus982

tests/http_app/routes/test_events.py

@@ -3,6 +3,7 @@
 from httpx import AsyncClient
 
 from domains.books.entities.cloudevent_base import BaseEvent
+from domains.books.entities.events import BookCreatedV1
 
 
 class FakeEvent(BaseEvent):
@@ -32,3 +33,43 @@ async def test_event_schema_list_returns_data_from_registry(testapp):
             response = await ac.get("/events/dataschemas")
     assert response.status_code == 200
     assert response.json() == ["test_event"]
+
+
+async def test_event_returns_204(testapp):
+    fake_event = BookCreatedV1(
+        data={"book_id": 0, "title": "string", "author_name": "string"},
+    )
+    async with AsyncClient(app=testapp, base_url="http://test") as ac:
+        response = await ac.post(
+            "/events/",
+            headers={"content-type": "application/cloudevents+json; charset=UTF-8"},
+            content=fake_event.model_dump_json(),
+        )
+    assert response.status_code == 204
+
+
+async def test_malformed_event_returns_422(testapp):
+    fake_event = BookCreatedV1(
+        data={"book_id": 0, "title": "string", "author_name": "string"},
+    )
+    fake_event.dataschema = None
+    async with AsyncClient(app=testapp, base_url="http://test") as ac:
+        response = await ac.post(
+            "/events/",
+            headers={"content-type": "application/cloudevents+json; charset=UTF-8"},
+            content=fake_event.model_dump_json(),
+        )
+    assert response.status_code == 422
+
+
+async def test_wrong_content_type_returns_422(testapp):
+    fake_event = BookCreatedV1(
+        data={"book_id": 0, "title": "string", "author_name": "string"},
+    )
+    async with AsyncClient(app=testapp, base_url="http://test") as ac:
+        response = await ac.post(
+            "/events/",
+            headers={"content-type": "application/json"},
+            content=fake_event.model_dump_json(),
+        )
+    assert response.status_code == 422