part of change_password logic

sapphire/users/api/rest/auth/change_password/__init__.py

@@ -0,0 +1 @@
+from .routers import router

sapphire/users/api/rest/auth/change_password/handlers.py

@@ -0,0 +1,19 @@
+import secrets
+
+import fastapi
+
+from sapphire.users import database
+
+
+async def check_email(
+        request: fastapi.Request,
+        email: str
+):
+    database_service: database.Service = request.app.service.database
+    async with database_service.transaction() as session:
+        user = await database_service.get_user_email(
+            session=session,
+            email=email
+        )
+        if user:
+            secret_code = secrets.token_urlsafe(12)

sapphire/users/api/rest/auth/change_password/routers.py

@@ -0,0 +1,7 @@
+import fastapi
+
+from . import handlers
+
+router = fastapi.APIRouter()
+
+router.add_api_route(path="/", methods=["POST"], endpoint=handlers.check_email)

sapphire/users/api/rest/auth/router.py

@@ -1,6 +1,6 @@
 import fastapi
 
-from . import handlers, oauth2
+from . import change_password, handlers, oauth2
 
 router = fastapi.APIRouter()
 
@@ -9,3 +9,4 @@
 router.add_api_route(methods=["POST"], path="/signup", endpoint=handlers.sign_up)
 router.add_api_route(methods=["POST"], path="/signin", endpoint=handlers.sign_in)
 router.include_router(oauth2.router, prefix="/oauth2")
+router.include_router(change_password.router, prefix="/change_password")

sapphire/users/brocker/__init__.py

@@ -0,0 +1,2 @@
+# from .service import Service, get_service
+from .settings import Settings

sapphire/users/brocker/service.py

@@ -0,0 +1,18 @@
+import uuid
+
+from sapphire.common.broker.models.email import Email
+from sapphire.common.broker.service import BaseBrokerProducerService
+
+
+class Service(BaseBrokerProducerService):
+
+    async def _send_email(
+            self, recipients: list[uuid.UUID], topic: str = "change_password"
+    ):
+        await self.send(topic=topic, message=Email(to=recipients))
+
+    async def send_email_code(self, email: str, code: str):
+        pass
+
+# def get_service() -> Service:
+#     return Service()

sapphire/users/brocker/settings.py

@@ -0,0 +1,5 @@
+from sapphire.common.broker.settings import BaseBrokerProducerSettings
+
+
+class Settings(BaseBrokerProducerSettings):
+    servers: list[str] = ["localhost:9091"]

sapphire/users/database/service.py

@@ -121,6 +121,20 @@ async def update_user_skills(self,
 
         return skills
 
+    async def get_user_email(
+            self,
+            session: AsyncSession,
+            email: str
+    ) -> User:
+        filters = []
+        if email is not Empty:
+            filters.append(User.email == email)
+
+        stmt = select(User).where(*filters)
+        result = await session.execute(stmt)
+        current_email = result.scalar_one_or_none()
+        return current_email
+
 
 def get_service(settings: Settings) -> Service:
     return Service(dsn=str(settings.dsn))