Merge pull request #11 from Ifechukwu001/fix/rabbitmq

Changed params to use url

Author: Ifechukwu001

.env.example

@@ -28,4 +28,5 @@ JWT_ISSUER=xxx
 # time in minutes
 OTP_LIFETIME=10
 
-RABBITMQ_HOST=localhost
+# amqp://username:password@host[:port]/
+RABBITMQ_URL=amqp://guest:guest@localhost:5672/

pyproject.toml

@@ -19,7 +19,6 @@ dependencies = [
   "pydantic[email]>=2.10.6",
   "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",

src/config/asgi.py

@@ -16,7 +16,7 @@
 
 from src.env import rabbitmq_config
 
-broker = RabbitBroker(host=rabbitmq_config["host"])
+broker = RabbitBroker(rabbitmq_config["url"])
 
 
 os.environ.setdefault("DJANGO_SETTINGS_MODULE", "src.config.settings")

src/env.py

@@ -51,7 +51,7 @@ class OTP(TypedDict):
 
 
 class RabbitMQ(TypedDict):
-    host: str
+    url: str
 
 
 env = Env()
@@ -104,6 +104,6 @@ class RabbitMQ(TypedDict):
 
 otp: OTP = {"lifetime": get_env_int("OTP_LIFETIME")}
 
-rabbitmq_config: RabbitMQ = {"host": get_env_str("RABBITMQ_HOST")}
+rabbitmq_config: RabbitMQ = {"url": get_env_str("RABBITMQ_URL")}
 
 __all__ = ["app", "cache", "db", "env", "jwt_config", "log", "otp", "rabbitmq_config"]