We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 70eafec commit fd0869cCopy full SHA for fd0869c
http_app/routes/events.py
@@ -5,6 +5,7 @@
5
from pydantic import BaseModel
6
7
from domains.books.events import BookCreatedV1
8
+from domains.books.service import BookService
9
10
router = APIRouter(prefix="/events")
11
@@ -84,4 +85,6 @@ async def submit_event(
84
85
"application/cloudevents+json; charset=UTF-8"
86
] = Header(),
87
) -> None:
- pass
88
+ # A better approach than if/else should be used when we have multiple event types
89
+ if isinstance(event_data, BookCreatedV1):
90
+ await BookService().book_created_event_handler(event_data.data.book_id)
0 commit comments