Backend i guess complete

alembic/env.py

@@ -6,6 +6,7 @@ from alembic import context
 from app.cores.config import settings
 from app.models.user import User
 config = context.config
+from app.models.application import Application
 
 config.set_main_option("sqlalchemy.url", f"postgresql://{settings.DATABASE_USERNAME}:{settings.DATABASE_PASSWORD}@{settings.DATABASE_HOSTNAME}:{settings.DATABASE_PORT}/{settings.DATABASE_NAME}")
 

alembic/versions/0f71a23ab6a3_add_resume_text_to_users.py

@@ -0,0 +1,32 @@
+"""add resume_text to users
+
+Revision ID: 0f71a23ab6a3
+Revises: 3436be625910
+Create Date: 2026-06-30 11:40:29.040562
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision: str = '0f71a23ab6a3'
+down_revision: Union[str, Sequence[str], None] = '3436be625910'
+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.add_column('users', sa.Column('resume_text', sa.Text(), nullable=True))
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    """Downgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column('users', 'resume_text')
+    # ### end Alembic commands ###

alembic/versions/3436be625910_create_applications_table.py

@@ -0,0 +1,44 @@
+"""create applications table
+
+Revision ID: 3436be625910
+Revises: 6f056783c0d8
+Create Date: 2026-06-30 11:27:20.563498
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision: str = '3436be625910'
+down_revision: Union[str, Sequence[str], None] = '6f056783c0d8'
+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.create_table('applications',
+    sa.Column('id', sa.Integer(), nullable=False),
+    sa.Column('user_id', sa.Integer(), nullable=False),
+    sa.Column('company', sa.String(), nullable=False),
+    sa.Column('role', sa.String(), nullable=False),
+    sa.Column('status', sa.Enum('applied', 'interview', 'offer', 'rejected', name='applicationstatus'), nullable=False),
+    sa.Column('applied_date', sa.Date(), nullable=False),
+    sa.Column('jd_text', sa.Text(), nullable=True),
+    sa.Column('notes', sa.Text(), nullable=True),
+    sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.text('now()'), nullable=True),
+    sa.ForeignKeyConstraint(['user_id'], ['users.id'], ondelete='CASCADE'),
+    sa.PrimaryKeyConstraint('id')
+    )
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    """Downgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_table('applications')
+    # ### end Alembic commands ###

app/cores/config.py

@@ -12,7 +12,7 @@ class Settings(BaseSettings):
     SECRET_KEY: str
     ALGORITHM: str
     ACCESS_TOKEN_EXPIRE_MINUTES: int
-    GROQ_API_KEY: str
+    GEMINI_API_KEY: str
 
     model_config = {"env_file": str(env_path), "env_file_encoding": "utf-8"}
 

app/cores/database.py

@@ -8,7 +8,7 @@ from app.cores.config import settings
 SQLALCHEMY_DATABASE_URL = f"postgresql://{settings.DATABASE_USERNAME}:{settings.DATABASE_PASSWORD}@{settings.DATABASE_HOSTNAME}:{settings.DATABASE_PORT}/{settings.DATABASE_NAME}"
 
 engine = create_engine(SQLALCHEMY_DATABASE_URL)
-SessionLocal = sessionmaker(autocommit=False,autoflush=False,blind=engine)
+SessionLocal = sessionmaker(autocommit=False,autoflush=False,bind=engine)
 Base = declarative_base()
 
 def get_db():

app/cores/security.py

@@ -1,4 +1,4 @@
-from datetime import datetime
+from datetime import datetime, timedelta
 from fastapi.security import OAuth2PasswordBearer
 from jose import jwt
 from app.cores.config import settings
@@ -15,19 +15,19 @@ oauth2_scheme = OAuth2PasswordBearer(tokenUrl="/auth/login")
 def hash_password(password: str) -> str:
     return pwd_context.hash(password)
 
-def verify_password(plain_password: str, hashed_password: str) -> str:
-    return pwd_context.verify(plain_password,hashed_password)
+def verify_password(plain_password: str, hashed_password: str) -> bool:
+    return pwd_context.verify(plain_password, hashed_password)
 
 def create_access_token(data: dict) -> str:
     to_encode = data.copy()
-    expire = datetime.utcnow() + datetime.timedelta(minutes=settings.ACCESS_TOKEN_EXPIRE_MINUTES)
-    to_encode.update["exp": expire]
+    expire = datetime.utcnow() + timedelta(minutes=settings.ACCESS_TOKEN_EXPIRE_MINUTES)
+    to_encode.update({"exp": expire})
     return jwt.encode(to_encode, settings.SECRET_KEY, algorithm=settings.ALGORITHM)
 
 def decode_token(token: str) -> dict:
     return jwt.decode(token, settings.SECRET_KEY, algorithms=[settings.ALGORITHM])
 
-def get_current_user(token: str = Depends(oauth2_scheme), db: Session= Depends(get_db())):
+def get_current_user(token: str = Depends(oauth2_scheme), db: Session = Depends(get_db)):
     credentials_exception = HTTPException(
         status_code=status.HTTP_401_UNAUTHORIZED,
         detail="Could not validate credentials",
@@ -35,14 +35,12 @@ def get_current_user(token: str = Depends(oauth2_scheme), db: Session= Depends(g
     )
     try:
         payload = decode_token(token)
-        user_id: int = TokenData(payload.get("user_id"))
+        user_id = payload.get("user_id")
         if user_id is None:
             raise credentials_exception
     except:
         raise credentials_exception
-    user = db.query(User).filter(user_id == User.id).first()
+    user = db.query(User).filter(User.id == user_id).first()
     if not user:
         raise credentials_exception
-    return user
-
-                     
+    return user

app/main.py

@@ -1,10 +1,12 @@
 from fastapi import FastAPI
-from app.routers import auth, user
+from app.routers import application, auth, user
 
 app = FastAPI(title="Job Tracker API")
 
 app.include_router(auth.router)
 app.include_router(user.router)
+app.include_router(application.router)
+
 @app.get("/")
 def root():
     return {"message": "Job Tracker API is running"}

app/models/application.py

@@ -0,0 +1,26 @@
+import enum
+from sqlalchemy import Column, Date, DateTime, Enum, ForeignKey, Integer, String, Text, func
+from app.cores.database import Base
+from sqlalchemy.orm import relationship
+
+
+class ApplicationStatus(str, enum.Enum):
+    applied = "applied"
+    interview = "interview"
+    offer = "offer"
+    rejected = "rejected"
+
+class Application(Base):
+    __tablename__ = "applications"
+
+    id = Column(Integer, primary_key=True, nullable=False)
+    user_id = Column(Integer, ForeignKey("users.id", ondelete="CASCADE"), nullable=False)
+    company = Column(String, nullable=False)
+    role = Column(String, nullable=False)
+    status = Column(Enum(ApplicationStatus), nullable=False, default=ApplicationStatus.applied)
+    applied_date = Column(Date, nullable=False)
+    jd_text = Column(Text, nullable=True)
+    notes = Column(Text, nullable=True)
+    created_at = Column(DateTime(timezone=True), server_default=func.now())
+
+    owner = relationship("User", back_populates="applications")

app/models/user.py

@@ -1,4 +1,4 @@
-from sqlalchemy import Column, DateTime, Integer, String
+from sqlalchemy import Column, DateTime, Integer, String, Text
 from sqlalchemy.sql import func
 from sqlalchemy.orm import relationship
 from app.cores.database import Base
@@ -9,6 +9,7 @@ class User(Base):
     id = Column(Integer, primary_key=True, nullable=False)
     email = Column(String, unique=True, nullable=False)
     hashed_password = Column(String, nullable=False)
+    resume_text = Column(Text, nullable=True)
     created_at = Column(DateTime(timezone=True), server_default=func.now())
 
-    application = relationship("Applications", back_populates="owner")
+    applications = relationship("Application", back_populates="owner")

app/routers/application.py

@@ -0,0 +1,122 @@
+from fastapi import APIRouter, Depends, HTTPException, status
+from sqlalchemy.orm import Session
+from typing import List
+from app.services.ai_service import analyze_resume_against_jd
+from app.cores.database import get_db
+from app.cores.security import get_current_user
+from app.models.application import Application
+from app.models.user import User
+from app.schemas.application import ApplicationCreate, ApplicationUpdate, ApplicationOut
+
+router = APIRouter(prefix="/applications", tags=["Applications"])
+
+
+@router.post("", response_model=ApplicationOut, status_code=status.HTTP_201_CREATED)
+def create_application(
+    application: ApplicationCreate,
+    db: Session = Depends(get_db),
+    current_user: User = Depends(get_current_user)
+):
+    new_application = Application(
+        user_id=current_user.id,
+        **application.model_dump()
+    )
+    db.add(new_application)
+    db.commit()
+    db.refresh(new_application)
+    return new_application
+
+
+@router.get("", response_model=List[ApplicationOut])
+def get_applications(
+    db: Session = Depends(get_db),
+    current_user: User = Depends(get_current_user)
+):
+    return db.query(Application).filter(Application.user_id == current_user.id).all()
+
+
+@router.get("/{id}", response_model=ApplicationOut)
+def get_application(
+    id: int,
+    db: Session = Depends(get_db),
+    current_user: User = Depends(get_current_user)
+):
+    application = db.query(Application).filter(
+        Application.id == id,
+        Application.user_id == current_user.id
+    ).first()
+
+    if not application:
+        raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Application not found")
+
+    return application
+
+
+@router.put("/{id}", response_model=ApplicationOut)
+def update_application(
+    id: int,
+    updated_application: ApplicationUpdate,
+    db: Session = Depends(get_db),
+    current_user: User = Depends(get_current_user)
+):
+    application_query = db.query(Application).filter(
+        Application.id == id,
+        Application.user_id == current_user.id
+    )
+    application = application_query.first()
+
+    if not application:
+        raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Application not found")
+
+    update_data = updated_application.model_dump(exclude_unset=True)
+    application_query.update(update_data, synchronize_session=False)
+    db.commit()
+    db.refresh(application)
+    return application
+
+
+@router.delete("/{id}", status_code=status.HTTP_204_NO_CONTENT)
+def delete_application(
+    id: int,
+    db: Session = Depends(get_db),
+    current_user: User = Depends(get_current_user)
+):
+    application_query = db.query(Application).filter(
+        Application.id == id,
+        Application.user_id == current_user.id
+    )
+    application = application_query.first()
+
+    if not application:
+        raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Application not found")
+
+    application_query.delete(synchronize_session=False)
+    db.commit()
+    return None
+
+@router.post("/{id}/analyze", status_code=status.HTTP_200_OK)
+def analyze_application(
+    id: int,
+    db: Session = Depends(get_db),
+    current_user: User = Depends(get_current_user)
+):
+    application = db.query(Application).filter(
+        Application.id == id,
+        Application.user_id == current_user.id
+    ).first()
+
+    if not application:
+        raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Application not found")
+
+    if not application.jd_text:
+        raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="No job description set for this application")
+
+    if not current_user.resume_text:
+        raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="No resume uploaded for this user")
+
+    try:
+        result = analyze_resume_against_jd(current_user.resume_text, application.jd_text)
+    except ValueError as e:
+        raise HTTPException(status_code=status.HTTP_502_BAD_GATEWAY, detail=str(e))
+
+    return result

app/routers/auth.py

@@ -9,8 +9,8 @@ from sqlalchemy.orm import Session
 
 router = APIRouter(tags=["Authentication"])
 
-router.post("/login", response_model=Token)
-def login(form_data: OAuth2PasswordRequestForm = Depends(), db: Session = Depends(get_db())):
+@router.post("/login", response_model=Token)
+def login(form_data: OAuth2PasswordRequestForm = Depends(), db: Session = Depends(get_db)):
     user = db.query(User).filter(User.email == form_data.username).first()
     if not user or not verify_password(form_data.password, user.hashed_password):
         raise HTTPException(status_code=401, detail="Invalid credentials")

app/routers/user.py

@@ -1,9 +1,11 @@
 from fastapi import APIRouter, HTTPException, status, Depends
 from sqlalchemy.orm import Session
-from app.cores.security import hash_password
+from app.cores.security import hash_password, verify_password, get_current_user
 from app.models.user import User
-from app.schemas.user import UserCreate, UserOut
+from app.schemas.user import UserCreate, UserOut, PasswordUpdate
 from app.cores.database import get_db
+from fastapi import UploadFile, File
+from app.services.resume_service import extract_text_from_pdf
 
 router = APIRouter(
     prefix="/users",
@@ -11,7 +13,7 @@ router = APIRouter(
 )
 
 
-@router.post("/", response_model=UserOut, status_code=status.HTTP_201_CREATED)
+@router.post("", response_model=UserOut, status_code=status.HTTP_201_CREATED)
 def create_user(user: UserCreate, db: Session = Depends(get_db)):
     existing = db.query(User).filter(User.email == user.email).first()
 
@@ -30,4 +32,59 @@ def create_user(user: UserCreate, db: Session = Depends(get_db)):
     db.commit()
     db.refresh(new_user)
 
-    return new_user
+    return new_user
+
+
+@router.get("", response_model=list[UserOut], status_code=status.HTTP_200_OK)
+def get_all_user(db: Session = Depends(get_db)):
+    return db.query(User).all()
+
+
+@router.put("", status_code=status.HTTP_200_OK)
+def update_password(
+    password_data: PasswordUpdate,
+    db: Session = Depends(get_db),
+    current_user: User = Depends(get_current_user)
+):
+    if not verify_password(password_data.old_password, current_user.hashed_password):
+        raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="Old password is incorrect")
+
+    current_user.hashed_password = hash_password(password_data.new_password)
+    db.commit()
+    return {"message": "Password updated successfully"}
+
+
+@router.delete("/{id}", status_code=status.HTTP_204_NO_CONTENT)
+def delete_user(
+    id: int,
+    db: Session = Depends(get_db),
+):
+    user_query = db.query(User).filter(User.id == id)
+    user = user_query.first()
+
+    if not user:
+        raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="User not found")
+
+    user_query.delete(synchronize_session=False)
+    db.commit()
+    return None
+
+@router.post("/resume", status_code=status.HTTP_200_OK)
+def upload_resume(
+    file: UploadFile = File(...),
+    db: Session = Depends(get_db),
+    current_user: User = Depends(get_current_user)
+):
+    if file.content_type != "application/pdf":
+        raise HTTPException(
+            status_code=status.HTTP_400_BAD_REQUEST,
+            detail="Only PDF files are allowed"
+        )
+
+    file_bytes = file.file.read()
+    resume_text = extract_text_from_pdf(file_bytes)
+
+    current_user.resume_text = resume_text
+    db.commit()
+
+    return {"message": "Resume uploaded successfully", "characters_extracted": len(resume_text)}

app/schemas/application.py

@@ -0,0 +1,36 @@
+from pydantic import BaseModel
+from datetime import date, datetime
+from typing import Optional
+from app.models.application import ApplicationStatus
+
+
+class ApplicationCreate(BaseModel):
+    company: str
+    role: str
+    status: ApplicationStatus = ApplicationStatus.applied
+    applied_date: date
+    jd_text: Optional[str] = None
+    notes: Optional[str] = None
+
+
+class ApplicationUpdate(BaseModel):
+    company: Optional[str] = None
+    role: Optional[str] = None
+    status: Optional[ApplicationStatus] = None
+    applied_date: Optional[date] = None
+    jd_text: Optional[str] = None
+    notes: Optional[str] = None
+
+
+class ApplicationOut(BaseModel):
+    id: int
+    user_id: int
+    company: str
+    role: str
+    status: ApplicationStatus
+    applied_date: date
+    jd_text: Optional[str] = None
+    notes: Optional[str] = None
+    created_at: datetime
+
+    model_config = {"from_attributes": True}

app/schemas/user.py

@@ -1,15 +1,20 @@
-from datetime import datetime
 from pydantic import BaseModel, EmailStr
+from datetime import datetime
 
 
 class UserCreate(BaseModel):
     email: EmailStr
     password: str
 
+
 class UserOut(BaseModel):
     id: int
     email: EmailStr
     created_at: datetime
-    model_config = {
-        "from_attribute": True
-    }
+
+    model_config = {"from_attributes": True}
+
+
+class PasswordUpdate(BaseModel):
+    old_password: str
+    new_password: str

app/services/ai_service.py

@@ -0,0 +1,48 @@
+import json
+import google.generativeai as genai
+from app.cores.config import settings
+
+genai.configure(api_key=settings.GEMINI_API_KEY)
+
+SYSTEM_PROMPT = """You are a resume analysis assistant. Compare the candidate's resume text against a job description and respond with ONLY valid JSON (no markdown, no preamble, no code fences) in exactly this shape:
+
+{
+  "match_score": <integer 0-100>,
+  "matching_skills": [<string>, ...],
+  "missing_skills": [<string>, ...],
+  "summary": "<2-3 sentence summary of fit>",
+  "tailored_resume": {
+    "professional_summary": "<rewritten 2-3 sentence summary tailored to the JD>",
+    "skills": [<string>, ...],
+    "experience_bullets": [<string>, ...]
+  }
+}
+"""
+
+model = genai.GenerativeModel(
+    model_name="gemini-2.5-flash",
+    system_instruction=SYSTEM_PROMPT,
+)
+
+def analyze_resume_against_jd(resume_text: str, jd_text: str) -> dict:
+    user_prompt = f"""RESUME:
+{resume_text}
+
+JOB DESCRIPTION:
+{jd_text}
+"""
+
+    response = model.generate_content(
+        user_prompt,
+        generation_config=genai.types.GenerationConfig(
+            temperature=0.3,
+            response_mime_type="application/json",
+        ),
+    )
+
+    raw_content = response.text.strip()
+
+    try:
+        return json.loads(raw_content)
+    except json.JSONDecodeError:
+        raise ValueError("AI returned invalid JSON response")

app/services/resume_service.py

@@ -0,0 +1,26 @@
+from pypdf import PdfReader
+from fastapi import HTTPException, status
+import io
+
+
+def extract_text_from_pdf(file_bytes: bytes) -> str:
+    try:
+        reader = PdfReader(io.BytesIO(file_bytes))
+        text = ""
+        for page in reader.pages:
+            text += page.extract_text() or ""
+
+        if not text.strip():
+            raise HTTPException(
+                status_code=status.HTTP_400_BAD_REQUEST,
+                detail="Could not extract text from PDF. The file may be scanned/image-based."
+            )
+
+        return text.strip()
+    except HTTPException:
+        raise
+    except Exception:
+        raise HTTPException(
+            status_code=status.HTTP_400_BAD_REQUEST,
+            detail="Invalid or corrupted PDF file"
+        )