queue implementation for user registration and email verification update to user-service

Author: CaptainAril

pyproject.toml

@@ -22,7 +22,8 @@ dependencies = [
   "pika>=1.3.2",
   "faststream[rabbit]>=0.5.39",
   "starlette>=0.46.2",
-  "uvicorn>=0.34.1",
+  "django-extensions>=4.1",
+  "uvicorn>=0.34.2",
 ]
 
 [dependency-groups]

src/api/services/AuthService.py

@@ -1,6 +1,7 @@
 from typing import Annotated
 
 from src.utils.svcs import Service
+from src.config.asgi import broker
 from src.utils.logger import Logger
 from src.api.typing.JWT import JWTSuccess
 from src.api.typing.UserExists import UserExists
@@ -60,6 +61,11 @@ async def register(self, req: CreateUserRequest) -> UserExists:
 
         created_user = await UserRepository.add(req)
 
+        user_data = {"id": created_user.id, "email": created_user.email}
+        queue = "create-user"
+
+        await broker.publish(message=user_data, queue=queue, persist=True)
+
         await self.otp_service.send_otp(created_user.id)
 
         user = self.utility_service.sanitize_user_object(created_user)
@@ -120,6 +126,10 @@ async def validate_email(self, req: AuthenticateUserOtp) -> bool:
         await UserRepository.update_by_user(
             user, {"is_active": True, "is_enabled": True, "is_validated": True}
         )
+        user_data = {"id": user.id, "email": user.email}
+        queue = "validate-user"
+        await broker.publish(message=user_data, queue=queue, persist=True)
+
         return True
 
     async def login(self, req: AuthenticateUserRequest) -> UserSuccess:

src/config/apps.py

@@ -13,6 +13,7 @@
 
 THIRD_PARTY_APPS = [
     "corsheaders",
+    "django_extensions",
 ]
 
 INSTALLED_APPS = [