Add AuthService for user authentication and session management

src/services/__init__.py

@@ -1,7 +1,10 @@
-from ._ai_voice_service import AIVoiceService
+from ._auth_service import AuthService
+from ._user_service import UserService
 from ._ai_text_service import AITextService
+from ._ai_voice_service import AIVoiceService
 from ._pinecone_service import PineconeService
 
-__all__ = ["AIVoiceService", "AITextService", "PineconeService"]
+__all__ = ["AIVoiceService", "AITextService", "PineconeService", "AuthService", "UserService"]
+
 __version__ = "0.1.0"
 __author__ = "Ramanjit Singh"

src/services/_auth_service.py

@@ -0,0 +1,62 @@
+from fastapi import HTTPException
+from datetime import datetime, timedelta
+
+from src.utils import JWTUtil, BcryptUtil
+from src.schemas import UserSignInSchema, UserSignUpSchema, SessionCreateSchema
+
+from ._user_service import UserService
+from ._session_service import SessionService
+
+class AuthService:
+    def __init__(self):
+        self._jwt_util = JWTUtil()
+        self._user_service = UserService()
+        self._session_service = SessionService()
+
+    async def sign_up(self, user: UserSignUpSchema):
+        existing_user = await self._user_service.list_users(filter_by={"email": user.email})
+        if existing_user:
+            raise HTTPException(409, "User already exists")
+
+        return await self._user_service.create_user(user)
+
+    async def sign_in(self, user: UserSignInSchema):
+        existing_user = await self._user_service.list_users(filter_by={"email": user.email})
+        if not existing_user:
+            raise HTTPException(404, "Invalid credentials")
+
+        if not BcryptUtil.compare_password(
+            existing_user[0].hashed_password, user.password
+        ):
+            raise HTTPException(404, "Invalid credentials")
+
+        token_payload = {
+            "user_id": str(existing_user[0].id),
+            "email": existing_user[0].email,
+        }
+
+        expiration_minutes = 60
+
+        token = self._jwt_util.generate_jwt(token_payload, expiration_minutes)
+
+        await self._session_service.create_session(
+            SessionCreateSchema(
+                user_id=existing_user[0].id,
+                token=token,
+                device_ipv4_address="127.0.0.1",
+                expired_at=datetime.now() + timedelta(minutes=expiration_minutes),
+            )
+        )
+        return token
+    
+    async def sign_out(self, token: str):
+        session = await self._session_service.get_session_by_token(token)
+
+        expired_session = SessionCreateSchema(
+            user_id=session.user_id,
+            token=session.token,
+            device_ipv4_address=session.device_ipv4_address,
+            expired_at=datetime.now(),
+        )
+
+        await self._session_service.update_session(session.id, expired_session)