Upload 11 files

__init__.py

@@ -0,0 +1 @@
+# This makes this directory a Python package

api/__init__.py

@@ -0,0 +1 @@
+# This makes this directory a Python package

api/routes.py

@@ -0,0 +1,34 @@
+from fastapi import APIRouter, HTTPException, Depends
+from fastapi.security import OAuth2PasswordRequestForm
+from app.models.schemas import SignupForm, TokenResponse
+from app.db.mongo import users_collection
+from app.core.security import hash_password, verify_password, create_access_token
+from datetime import datetime
+
+router = APIRouter()
+
+@router.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.utcnow()
+    }
+    await users_collection.insert_one(user_doc)
+    return {"success": True, "message": "Account created"}
+
+@router.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.py

@@ -0,0 +1,19 @@
+from fastapi import FastAPI
+from fastapi.middleware.cors import CORSMiddleware
+from app.api.routes import router as api_router
+
+app = FastAPI()
+
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+
+app.include_router(api_router)
+
+@app.get("/")
+def root():
+    return {"message": "🚀 FastAPI MongoDB with JWT & bcrypt is running"}

core/__init__.py

@@ -0,0 +1 @@
+# This makes this directory a Python package

core/config.py

@@ -0,0 +1,9 @@
+import os
+
+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!")

core/security.py

@@ -0,0 +1,18 @@
+from datetime import datetime, timedelta
+from passlib.context import CryptContext
+from jose import jwt
+from app.core.config import SECRET_KEY, ALGORITHM, ACCESS_TOKEN_EXPIRE_MINUTES
+
+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)
+
+def create_access_token(data: dict, expires_delta: timedelta = None):
+    to_encode = data.copy()
+    expire = datetime.utcnow() + (expires_delta or timedelta(minutes=ACCESS_TOKEN_EXPIRE_MINUTES))
+    to_encode.update({"exp": expire})
+    return jwt.encode(to_encode, SECRET_KEY, algorithm=ALGORITHM)

db/__init__.py

@@ -0,0 +1 @@
+# This makes this directory a Python package

db/mongo.py

@@ -0,0 +1,7 @@
+import certifi
+from motor.motor_asyncio import AsyncIOMotorClient
+from app.core.config import MONGO_URI
+
+client = AsyncIOMotorClient(MONGO_URI, tls=True, tlsCAFile=certifi.where())
+db = client["cps_db"]
+users_collection = db["users"]

models/__init__.py

@@ -0,0 +1 @@
+# This makes this directory a Python package

models/schemas.py

@@ -0,0 +1,9 @@
+from pydantic import BaseModel, EmailStr
+
+class SignupForm(BaseModel):
+    email: EmailStr
+    password: str
+
+class TokenResponse(BaseModel):
+    access_token: str
+    token_type: str