Update app.py

app.py

@@ -1,90 +1,19 @@
-from fastapi import FastAPI, HTTPException, Depends
+from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
-from fastapi.security import OAuth2PasswordRequestForm
-from pydantic import BaseModel, EmailStr
-from jose import jwt, JWTError
-from passlib.context import CryptContext
-from motor.motor_asyncio import AsyncIOMotorClient
-import certifi
-import datetime
-import os
+from app.api.routes import router as api_router
 
-# Environment variables
-SECRET_KEY = os.getenv("SECRET_KEY", "your-secret-key")
-ALGORITHM = "HS256"
-ACCESS_TOKEN_EXPIRE_MINUTES = 30
-MONGO_URI = os.getenv("MONGO_URI")
-
-if not MONGO_URI:
-    raise RuntimeError("MONGO_URI not set!")
-
-# Database connection
-client = AsyncIOMotorClient(MONGO_URI, tls=True, tlsCAFile=certifi.where())
-db = client["cps_db"]
-users_collection = db["users"]
-
-# App setup
 app = FastAPI()
+
 app.add_middleware(
     CORSMiddleware,
-    allow_origins=["*"],  # 🔐 Replace with frontend domain in prod
+    allow_origins=["*"],
     allow_credentials=True,
     allow_methods=["*"],
     allow_headers=["*"],
 )
 
-# Hashing setup
-pwd_context = CryptContext(schemes=["bcrypt"], deprecated="auto")
-
-def hash_password(password: str) -> str:
-    return pwd_context.hash(password)
-
-def verify_password(plain: str, hashed: str) -> bool:
-    return pwd_context.verify(plain, hashed)
-
-# JWT generation
-def create_access_token(data: dict, expires_delta: datetime.timedelta = None):
-    to_encode = data.copy()
-    expire = datetime.datetime.utcnow() + (expires_delta or datetime.timedelta(minutes=ACCESS_TOKEN_EXPIRE_MINUTES))
-    to_encode.update({"exp": expire})
-    return jwt.encode(to_encode, SECRET_KEY, algorithm=ALGORITHM)
-
-# Pydantic models
-class SignupForm(BaseModel):
-    email: EmailStr
-    password: str
-
-class TokenResponse(BaseModel):
-    access_token: str
-    token_type: str
-
-# Routes
-@app.post("/signup")
-async def signup(data: SignupForm):
-    email = data.email.lower().strip()
-    existing = await users_collection.find_one({"email": email})
-    if existing:
-        raise HTTPException(status_code=409, detail="Email already exists")
-    
-    hashed_pw = hash_password(data.password)
-    user_doc = {
-        "email": email,
-        "password": hashed_pw,
-        "created_at": datetime.datetime.utcnow()
-    }
-    await users_collection.insert_one(user_doc)
-    return {"success": True, "message": "Account created"}
-
-@app.post("/login", response_model=TokenResponse)
-async def login(form_data: OAuth2PasswordRequestForm = Depends()):
-    email = form_data.username.lower().strip()
-    user = await users_collection.find_one({"email": email})
-    if not user or not verify_password(form_data.password, user["password"]):
-        raise HTTPException(status_code=401, detail="Invalid credentials")
-
-    access_token = create_access_token(data={"sub": user["email"]})
-    return {"access_token": access_token, "token_type": "bearer"}
+app.include_router(api_router)
 
 @app.get("/")
 def root():
-    return {"message": "🚀 FastAPI MongoDB with JWT & timestamps is running"}
+    return {"message": "🚀 FastAPI MongoDB with JWT & bcrypt is running"}