Merge pull request #8 from Ifechukwu001/feat/rabbitmq

Fixed to use Faststream for an easier flow

Author: CaptainAril

README.md

@@ -44,5 +44,5 @@ The Swagger documentation for the application is hosted on [Render](https://df-a
 - Run the server locally on port 8000
 
   ```bash
-  uv run manage.py runserver 8000
+  uv run uvicorn src.config.asgi:application --reload --port 8000
   ```

pyproject.toml

@@ -20,6 +20,9 @@ dependencies = [
   "django-ninja>=1.3.0",
   "pyjwt>=2.10.1",
   "pika>=1.3.2",
+  "faststream[rabbit]>=0.5.39",
+  "starlette>=0.46.2",
+  "uvicorn>=0.34.1",
 ]
 
 [dependency-groups]

src/api/services/external/RabbitMQRoutes.py

@@ -0,0 +1 @@
+

src/api/services/external/RabbitMQService.py

@@ -10,7 +10,22 @@
 import os
 
 from django.core.asgi import get_asgi_application
+from faststream.rabbit import RabbitBroker
+from starlette.routing import Mount
+from starlette.applications import Starlette
+
+from src.env import rabbitmq_config
+
+broker = RabbitBroker(host=rabbitmq_config["host"])
+
 
 os.environ.setdefault("DJANGO_SETTINGS_MODULE", "src.config.settings")
 
-application = get_asgi_application()
+application = Starlette(
+    routes=[Mount("/", get_asgi_application())],  # type: ignore
+    on_startup=[broker.start],
+    on_shutdown=[broker.close],
+)
+
+
+from src.api.services.external import RabbitMQRoutes as RabbitMQRoutes  # noqa: E402