fix:remove fields

.github/workflows/notify.yml

@@ -2,8 +2,8 @@ name: Daily Emotion Check-In Notifications
 
 on:
   schedule:
-    - cron: "30 3 * * *"   # 9 AM IST
-    - cron: "15 11 * * *"  # 4:45 PM IST
+    - cron: "30 3 * * *" # 9 AM IST
+    - cron: "15 11 * * *" # 4:45 PM IST
   workflow_dispatch: {}
 
 jobs:
@@ -13,7 +13,7 @@ jobs:
     steps:
       - name: Send morning notification
         run: |
-          curl -X POST "https://yuvabe-ai-yuvabe-app-backend.hf.space/home/notify/all" \
+          curl -X POST "${{secrets.NOTIFY_URL}}" \
             -H "accept: application/json" \
             -H "Content-Type: application/json" \
             -d '{
@@ -31,7 +31,7 @@ jobs:
     steps:
       - name: Send evening notification
         run: |
-          curl -X POST "https://yuvabe-ai-yuvabe-app-backend.hf.space/home/notify/all" \
+          curl -X POST "${{secrets.NOTIFY_URL}}" \
             -H "accept: application/json" \
             -H "Content-Type: application/json" \
             -d '{

alembic/versions/3380d93055a7_delete_posts_comments_likes_table.py

@@ -0,0 +1,74 @@
+"""delete posts,comments,likes table
+
+Revision ID: 3380d93055a7
+Revises: 217db60578fa
+Create Date: 2025-12-06 21:27:45.958044
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+import sqlmodel.sql.sqltypes
+from sqlalchemy.dialects import postgresql
+
+# revision identifiers, used by Alembic.
+revision: str = '3380d93055a7'
+down_revision: Union[str, Sequence[str], None] = '217db60578fa'
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    """Upgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_constraint("likes_post_id_fkey", "likes", type_="foreignkey")
+    op.drop_constraint("comments_post_id_fkey", "comments", type_="foreignkey")
+    op.drop_table("posts")
+    op.drop_table("likes")
+    op.drop_table("comments")
+    op.alter_column('app_version', 'apk_download_link',
+               existing_type=sa.VARCHAR(),
+               nullable=False)
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    """Downgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.alter_column('app_version', 'apk_download_link',
+               existing_type=sa.VARCHAR(),
+               nullable=True)
+    op.create_table('comments',
+    sa.Column('id', sa.UUID(), autoincrement=False, nullable=False),
+    sa.Column('post_id', sa.UUID(), autoincrement=False, nullable=False),
+    sa.Column('user_id', sa.UUID(), autoincrement=False, nullable=False),
+    sa.Column('comment', sa.VARCHAR(), autoincrement=False, nullable=False),
+    sa.Column('created_at', postgresql.TIMESTAMP(), autoincrement=False, nullable=False),
+    sa.ForeignKeyConstraint(['post_id'], ['posts.id'], name=op.f('comments_post_id_fkey'), ondelete='CASCADE'),
+    sa.ForeignKeyConstraint(['user_id'], ['users.id'], name=op.f('comments_user_id_fkey'), ondelete='CASCADE'),
+    sa.PrimaryKeyConstraint('id', name=op.f('comments_pkey'))
+    )
+    op.create_table('likes',
+    sa.Column('id', sa.UUID(), autoincrement=False, nullable=False),
+    sa.Column('post_id', sa.UUID(), autoincrement=False, nullable=False),
+    sa.Column('user_id', sa.UUID(), autoincrement=False, nullable=False),
+    sa.Column('liked_at', postgresql.TIMESTAMP(), autoincrement=False, nullable=False),
+    sa.ForeignKeyConstraint(['post_id'], ['posts.id'], name=op.f('likes_post_id_fkey'), ondelete='CASCADE'),
+    sa.ForeignKeyConstraint(['user_id'], ['users.id'], name=op.f('likes_user_id_fkey'), ondelete='CASCADE'),
+    sa.PrimaryKeyConstraint('id', name=op.f('likes_pkey')),
+    sa.UniqueConstraint('user_id', 'post_id', name=op.f('likes_user_id_post_id_key'), postgresql_include=[], postgresql_nulls_not_distinct=False)
+    )
+    op.create_table('posts',
+    sa.Column('id', sa.UUID(), autoincrement=False, nullable=False),
+    sa.Column('user_id', sa.UUID(), autoincrement=False, nullable=True),
+    sa.Column('type', postgresql.ENUM('BIRTHDAY', 'NOTICE', 'BANNER', 'JOB_REQUEST', name='posttype'), autoincrement=False, nullable=False),
+    sa.Column('category', postgresql.ENUM('TEAM', 'GLOBAL', name='postcategory'), autoincrement=False, nullable=False),
+    sa.Column('caption', sa.VARCHAR(), autoincrement=False, nullable=True),
+    sa.Column('image', sa.VARCHAR(), autoincrement=False, nullable=True),
+    sa.Column('created_at', postgresql.TIMESTAMP(), autoincrement=False, nullable=False),
+    sa.Column('edited_at', postgresql.TIMESTAMP(), autoincrement=False, nullable=False),
+    sa.ForeignKeyConstraint(['user_id'], ['users.id'], name=op.f('posts_user_id_fkey'), ondelete='SET NULL'),
+    sa.PrimaryKeyConstraint('id', name=op.f('posts_pkey'))
+    )
+    # ### end Alembic commands ###

alembic/versions/a34f13019598_drop_platform_model.py

@@ -0,0 +1,35 @@
+"""drop platform model
+
+Revision ID: a34f13019598
+Revises: 3380d93055a7
+Create Date: 2025-12-07 14:22:13.166768
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+import sqlmodel.sql.sqltypes
+
+
+# revision identifiers, used by Alembic.
+revision: str = 'a34f13019598'
+down_revision: Union[str, Sequence[str], None] = '3380d93055a7'
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    """Upgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column('user_devices', 'platform')
+    op.drop_column('user_devices', 'device_model')
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    """Downgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.add_column('user_devices', sa.Column('device_model', sa.VARCHAR(), autoincrement=False, nullable=False))
+    op.add_column('user_devices', sa.Column('platform', sa.VARCHAR(), autoincrement=False, nullable=False))
+    # ### end Alembic commands ###

src/chatbot/embedding.py

@@ -9,11 +9,8 @@ MODEL_ID = "onnx-community/embeddinggemma-300m-ONNX"
 
 class EmbeddingModel:
     def __init__(self):
-        print("Loading tokenizer…")
         self.tokenizer = AutoTokenizer.from_pretrained(MODEL_ID)
 
-        print("Downloading ONNX model files…")
-
         self.model_path = hf_hub_download(
             repo_id=MODEL_ID,
             filename="onnx/model.onnx"
@@ -25,7 +22,6 @@ class EmbeddingModel:
 
         model_dir = os.path.dirname(self.model_path)
 
-        print("Creating inference session…")
         self.session = ort.InferenceSession(
             self.model_path,
             providers=["CPUExecutionProvider"],

src/chatbot/router.py

@@ -2,11 +2,13 @@ import os
 import shutil
 import tempfile
 from typing import Optional
+from uuid import UUID
 
 from fastapi import APIRouter, Depends, File, Form, HTTPException, UploadFile
 from sqlalchemy import text
 from sqlmodel.ext.asyncio.session import AsyncSession
 
+from src.auth.utils import get_current_user
 from src.core.database import get_async_session
 from .schemas import ManualTextRequest
 from .service import store_manual_text
@@ -23,7 +25,7 @@ from .service import process_pdf_and_store
 router = APIRouter(prefix="/chatbot", tags=["chatbot"])
 
 @router.post("/tokenize", response_model=TokenizeResponse)
-async def tokenize_text(payload: TokenizeRequest):
+async def tokenize_text(payload: TokenizeRequest,user_id: UUID = Depends(get_current_user)):
     try:
         encoded = embedding_model.tokenizer(
             payload.text,
@@ -44,7 +46,7 @@ async def tokenize_text(payload: TokenizeRequest):
 
 @router.post("/semantic-search", response_model=list[SemanticSearchResult])
 async def semantic_search(
-    payload: SemanticSearchRequest, session: AsyncSession = Depends(get_async_session)
+    payload: SemanticSearchRequest, session: AsyncSession = Depends(get_async_session), user_id: UUID = Depends(get_current_user)
 ):
 
     if len(payload.embedding) == 0:

src/core/__init__.py

@@ -1,7 +1,6 @@
 from src.auth import models as auth_models
 from src.chatbot import models as chatbot_models
 from src.core import models as core_models
-from src.feed import models as feed_models
 from src.home import models as home_models
 from src.profile import models as profile_models
 from src.wellbeing import models as wellbeing_models

src/core/models.py

@@ -26,6 +26,11 @@ class Emotion(str, Enum):
     ANXIOUS = "anxious"
     SAD = "sad"
     FRUSTRATED = "frustrated"
+    
+class AppVersion(SQLModel, table=True):
+    __tablename__ = "app_version"
+    version: str = Field(primary_key=True)
+    apk_download_link: str
 
 class Users(SQLModel, table=True):
     __tablename__ = "users"

src/core/router.py

@@ -0,0 +1,30 @@
+from fastapi import APIRouter, Depends
+from sqlmodel.ext.asyncio.session import AsyncSession
+from sqlmodel import select
+
+from src.core.database import get_async_session
+from src.core.schemas import BaseResponse
+from src.core.models import AppVersion
+from .schemas import AppConfigResponse
+
+router = APIRouter(prefix="/app", tags=["AppConfig"])
+
+
+@router.get("/config", response_model=BaseResponse[AppConfigResponse])
+async def get_app_config(
+    session: AsyncSession = Depends(get_async_session),
+):
+    result = await session.exec(select(AppVersion))
+    row = result.first()
+
+    min_version = row.version if row else "0.0.0"
+    apk_url = row.apk_download_link if row else ""
+
+    return BaseResponse(
+        status_code=200,
+        data=AppConfigResponse(
+            version=min_version,
+            apk_download_link=apk_url
+        )
+    )
+

src/core/schemas.py

@@ -1,5 +1,5 @@
 from typing import Generic, TypeVar
-
+from sqlmodel import SQLModel
 from pydantic import BaseModel
 
 T = TypeVar("T")
@@ -8,3 +8,7 @@ T = TypeVar("T")
 class BaseResponse(BaseModel, Generic[T]):
     status_code: int
     data: T
+
+class AppConfigResponse(SQLModel):
+    version: str
+    apk_download_link: str

src/home/router.py

@@ -26,7 +26,8 @@ async def fetch_home_data(
 
 @router.post("/emotion", response_model=BaseResponse[EmotionLogResponse])
 async def create_or_update_emotion(
-    data: EmotionLogCreate, session: AsyncSession = Depends(get_async_session)
+    data: EmotionLogCreate, session: AsyncSession = Depends(get_async_session),
+    user_id: str = Depends(get_current_user),
 ):
     record = await add_or_update_emotion(data, session)
     return {

src/main.py

@@ -10,6 +10,7 @@ from src.notifications.router import router as notifications_router
 from src.payslip.router import router as payslip_router
 from src.profile.router import router as profile
 from src.journaling.router import router as journal
+from src.core.router import router as app_config
 from fastapi.staticfiles import StaticFiles
 
 
@@ -23,7 +24,7 @@ async def on_startup():
 
 app.include_router(home_router, prefix="/home", tags=["Home"])
 
-# init_db()
+app.include_router(app_config)
 
 app.include_router(profile)
 

src/notifications/schemas.py

@@ -1,6 +1,4 @@
 from pydantic import BaseModel
 
 class RegisterDeviceRequest(BaseModel):
-    device_token: str
-    platform: str
-    device_model: str
+    device_token: str

src/notifications/service.py

@@ -18,8 +18,6 @@ async def register_device(
     device = result.scalar_one_or_none()
 
     if device:
-        device.platform = body.platform
-        device.device_model = body.device_model
         device.last_seen = datetime.utcnow()
         device.updated_at = datetime.utcnow()
 
@@ -31,8 +29,6 @@ async def register_device(
     new_device = UserDevices(
         user_id=user_id,
         device_token=body.device_token,
-        platform=body.platform,
-        device_model=body.device_model,
     )
 
     session.add(new_device)
@@ -40,9 +36,11 @@ async def register_device(
     await session.refresh(new_device)
     return new_device
 
+
 from sqlalchemy import select
 from src.profile.models import UserDevices
 
+
 async def get_user_device_tokens(session, user_id):
     stmt = select(UserDevices.device_token).where(UserDevices.user_id == user_id)
     rows = (await session.execute(stmt)).all()

src/payslip/router.py

@@ -1,5 +1,5 @@
 # src/payslip/router.py
-from fastapi import APIRouter, Depends, HTTPException, Request
+from fastapi import APIRouter, Depends, HTTPException
 from fastapi.responses import HTMLResponse
 from urllib.parse import urlencode
 import uuid
@@ -18,6 +18,8 @@ from src.payslip.googleservice import (
 )
 from src.payslip.utils import get_current_user_model
 from src.payslip.models import PayslipRequest, PayslipStatus
+from src.payslip.utils import encrypt_token
+
 
 router = APIRouter(prefix="/payslips", tags=["Payslips & Gmail"])
 
@@ -27,11 +29,6 @@ async def gmail_connect_url(user_id: uuid.UUID):
     """
     Returns the Google OAuth URL for the frontend to open in InAppBrowser.
     """
-
-    print("\n🚀 GOOGLE CONNECT URL CALLED")
-    print("Using redirect URI:", settings.GOOGLE_REDIRECT_URI)
-    print("Client ID:", settings.GOOGLE_CLIENT_ID)
-
     params = {
         "client_id": settings.GOOGLE_CLIENT_ID,
         "redirect_uri": settings.GOOGLE_REDIRECT_URI,
@@ -41,102 +38,65 @@ async def gmail_connect_url(user_id: uuid.UUID):
         "prompt": "consent",
         "state": str(user_id),
     }
-
-    url = f"{settings.AUTH_BASE}?{urlencode(params)}"
-
-    print("Generated Google URL:", url)
-
-    return {"auth_url": url}
+    return {"auth_url": f"{settings.AUTH_BASE}?{urlencode(params)}"}
 
 
 @router.get("/gmail/callback")
 async def gmail_callback(
-    request: Request,  # ⬅ REQUIRED to read URL + headers
-    code: str,
-    state: str,
-    session: AsyncSession = Depends(get_async_session)
+    code: str, state: str, session: AsyncSession = Depends(get_async_session)
 ):
-
     from fastapi.responses import RedirectResponse
 
-    print("\n🔔 CALLBACK HIT")
-    print("➡ URL seen by backend:", request.url)
-    print("➡ Headers:", dict(request.headers))
-    print("➡ Query params:", request.query_params)
-
     user_id = uuid.UUID(state)
-    print("➡ Extracted user_id from state:", user_id)
-
-    # LOAD USER
     user = await session.get(Users, user_id)
-    print("➡ User found:", user.email_id if user else "None")
 
     if not user:
-        print("❌ User not found")
         return RedirectResponse(
             "yuvabe://gmail/callback?success=false&error=user_not_found&message=No such user exists"
         )
 
-    # EXCHANGE CODE
     try:
-        print("➡ Exchanging code for tokens...")
         token_data = exchange_code_for_tokens(code)
-        print("➡ Token Data:", token_data)
-
         google_email = extract_email_from_id_token(token_data["id_token"])
-        print("➡ Email from Google:", google_email)
-
-    except Exception as e:
-        print("❌ OAuth Code Exchange Failed:", e)
+    except Exception:
         return RedirectResponse(
             "yuvabe://gmail/callback?success=false&error=invalid_code&message=OAuth code exchange failed"
         )
 
-    # EMAIL MISMATCH
+    # --- GMAIL MISMATCH ERROR ---
     if google_email.lower() != user.email_id.lower():
-        print("❌ Email mismatch! Google:", google_email, "| App:", user.email_id)
         return RedirectResponse(
             "yuvabe://gmail/callback?success=false&error=email_mismatch&message=Google account does not match registered email"
         )
 
-    # GET REFRESH TOKEN
     refresh_token = token_data.get("refresh_token")
-    print("➡ Refresh Token:", refresh_token)
-
     if not refresh_token:
-        print("❌ Google DID NOT send refresh token")
         return RedirectResponse(
             "yuvabe://gmail/callback?success=false&error=no_refresh_token&message=No refresh token returned from Google"
         )
 
-    # SAVE TOKEN
     q = (
         select(PayslipRequest)
         .where(PayslipRequest.user_id == user_id)
         .order_by(PayslipRequest.requested_at.desc())
     )
     existing = (await session.execute(q)).scalar_one_or_none()
-    print("➡ Existing request:", existing)
 
     if existing:
-        existing.refresh_token = refresh_token
+        existing.refresh_token = encrypt_token(refresh_token)
         session.add(existing)
-        print("➡ Updated existing request with token")
     else:
         session.add(
             PayslipRequest(
                 user_id=user_id,
-                refresh_token=refresh_token,
+                refresh_token=encrypt_token(refresh_token),
                 status=PayslipStatus.PENDING,
             )
         )
-        print("➡ Created new PayslipRequest row")
 
     await session.commit()
-    print("➡ DB Commit Successful!")
 
-    # SUCCESS REDIRECT
-    print("🎉 SUCCESS — Gmail Connected!")
+    # --- SUCCESS MESSAGE ---
     return RedirectResponse(
         "yuvabe://gmail/callback?success=true&message=gmail_connected_successfully"
     )
@@ -148,14 +108,17 @@ async def request_payslip(
     session: AsyncSession = Depends(get_async_session),
     user: Users = Depends(get_current_user_model),
 ):
-    print("\n📩 PAYSLIP REQUEST HIT")
-    print("➡ User:", user.email_id)
-    print("➡ Payload:", payload)
-
+    """
+    User hits this when pressing "Request Payslip" in the app.
+    We:
+      - enforce 1 request per day
+      - compute period
+      - validate join date
+      - load refresh_token from payslip_requests table
+      - send email
+      - update or create row in payslip_requests
+    """
     entry = await process_payslip_request(session, user, payload)
-
-    print("➡ Payslip Entry Created:", entry)
-
     return {
         "status": entry.status,
         "requested_at": entry.requested_at,

src/payslip/service.py

@@ -15,6 +15,9 @@ from src.payslip.googleservice import (
     send_gmail,
 )
 
+from src.payslip.utils import decrypt_token
+from src.payslip.utils import encrypt_token
+
 
 async def user_team_name(session: AsyncSession, user_id):
     """Return user's team name."""
@@ -95,7 +98,7 @@ async def process_payslip_request(
     # 4. Get refresh_token from latest payslip row (DB)
     latest = await get_latest_payslip_row(session, user.id)
 
-    refresh_token = latest.refresh_token if latest else None
+    refresh_token = decrypt_token(latest.refresh_token) if latest else None
 
     if not refresh_token:
         # No token stored yet
@@ -134,7 +137,7 @@ async def process_payslip_request(
         latest.status = PayslipStatus.SENT
         latest.requested_at = now
         latest.error_message = None
-        latest.refresh_token = refresh_token  # keep token
+        latest.refresh_token = encrypt_token(refresh_token)  # keep token
         session.add(latest)
         await session.commit()
         await session.refresh(latest)

src/payslip/utils.py

@@ -13,6 +13,23 @@ from src.core.database import get_async_session
 from src.core.models import Users
 from src.core.config import settings
 
+
+from cryptography.fernet import Fernet
+from src.core.config import settings
+
+
+fernet = Fernet(settings.FERNET_KEY.encode())
+
+
+def encrypt_token(token: str) -> str:
+    """Encrypts a refresh token before saving to DB."""
+    return fernet.encrypt(token.encode()).decode()
+
+
+def decrypt_token(token: str) -> str:
+    """Decrypts a stored refresh token when needed."""
+    return fernet.decrypt(token.encode()).decode()
+
 bearer_scheme = HTTPBearer()
 
 SECRET_KEY = settings.SECRET_KEY

src/profile/models.py

@@ -63,6 +63,4 @@ class UserDevices(SQLModel, table=True):
     )
     device_token: str
     last_seen: datetime = Field(default_factory=datetime.now)
-    device_model: str
-    platform: str
     updated_at: datetime = Field(default_factory=datetime.now)

src/profile/utils.py

@@ -12,17 +12,27 @@ from datetime import date
 from typing import Tuple, Optional, List
 from sqlmodel import select
 from sqlmodel.ext.asyncio.session import AsyncSession
-from src.core.models import UserTeamsRole, Roles, Users, Teams  # adjust import path if differs
+from src.core.models import (
+    UserTeamsRole,
+    Roles,
+    Users,
+    Teams,
+)  # adjust import path if differs
 from src.core.config import settings  # for FCM key if needed
 import httpx
-import math
 
-def calculate_days(from_date: date, to_date: date, include_weekends: bool = True) -> int:
+
+def calculate_days(
+    from_date: date, to_date: date, include_weekends: bool = True
+) -> int:
     """Calculate inclusive days. If you want to exclude weekends, add logic."""
     delta = (to_date - from_date).days + 1
     return max(0, delta)
 
-async def find_mentor_and_lead(session: AsyncSession, user_id) -> Tuple[Optional[dict], Optional[dict]]:
+
+async def find_mentor_and_lead(
+    session: AsyncSession, user_id
+) -> Tuple[Optional[dict], Optional[dict]]:
     """
     Return (mentor_user, lead_user) as dicts or None.
     Uses your existing UserTeamsRole and Roles tables to find role members in same team.
@@ -34,41 +44,51 @@ async def find_mentor_and_lead(session: AsyncSession, user_id) -> Tuple[Optional
         return None, None
 
     # 2) find Mentor role id
-    mentor_role = (await session.exec(select(Roles).where(Roles.name == "Mentor"))).first()
-    lead_role = (await session.exec(select(Roles).where(Roles.name == "Team Lead"))).first()
+    mentor_role = (
+        await session.exec(select(Roles).where(Roles.name == "Mentor"))
+    ).first()
+    lead_role = (
+        await session.exec(select(Roles).where(Roles.name == "Team Lead"))
+    ).first()
 
     mentor_user = None
     lead_user = None
 
     if mentor_role:
-        mentor_user = (await session.exec(
-            select(Users)
-            .join(UserTeamsRole)
-            .where(UserTeamsRole.team_id == user_team.team_id)
-            .where(UserTeamsRole.role_id == mentor_role.id)
-        )).first()
+        mentor_user = (
+            await session.exec(
+                select(Users)
+                .join(UserTeamsRole)
+                .where(UserTeamsRole.team_id == user_team.team_id)
+                .where(UserTeamsRole.role_id == mentor_role.id)
+            )
+        ).first()
 
     if lead_role:
-        lead_user = (await session.exec(
-            select(Users)
-            .join(UserTeamsRole)
-            .where(UserTeamsRole.team_id == user_team.team_id)
-            .where(UserTeamsRole.role_id == lead_role.id)
-        )).first()
+        lead_user = (
+            await session.exec(
+                select(Users)
+                .join(UserTeamsRole)
+                .where(UserTeamsRole.team_id == user_team.team_id)
+                .where(UserTeamsRole.role_id == lead_role.id)
+            )
+        ).first()
 
     return mentor_user, lead_user
 
 
-
 async def get_tokens_for_user(session: AsyncSession, user_id) -> list[str]:
     user = await session.get(Users, user_id)
     if not user:
         return []
     return user.device_tokens or []
 
+
 # Simple FCM send using legacy HTTP API (server key).
 # In production prefer FCM HTTP v1 (OAuth) or firebase-admin SDK.
-async def send_push_to_tokens(tokens: list[str], title: str, body: str, data: dict = None):
+async def send_push_to_tokens(
+    tokens: list[str], title: str, body: str, data: dict = None
+):
     if not tokens:
         return
 
@@ -97,8 +117,6 @@ async def send_push_to_tokens(tokens: list[str], title: str, body: str, data: di
             print("FCM send failed:", r.status_code, r.text)
 
 
-
-
 SMTP_HOST = settings.EMAIL_SERVER
 SMTP_PORT = settings.EMAIL_PORT
 SMTP_USER = settings.EMAIL_USERNAME