Add jobs API with Azure DB persistence

Author: lakshyashishir

backend/app/api/routes/jobs.py

@@ -0,0 +1,55 @@
+from fastapi import APIRouter, Depends, HTTPException
+from sqlalchemy import select
+from sqlalchemy.ext.asyncio import AsyncSession
+
+from app.database import get_db
+from app.db_models import JobDB
+from app.models import Job, JobCreate, new_id, utc_now_iso
+
+router = APIRouter(tags=["jobs"])
+
+
+def _to_model(db_job: JobDB) -> Job:
+    return Job(
+        id=db_job.id,
+        title=db_job.title,
+        budget=db_job.budget,
+        skill=db_job.skill,
+        description=db_job.description or "",
+        urgent=db_job.urgent,
+        location=db_job.location or "",
+        posted_at=db_job.posted_at.isoformat(),
+    )
+
+
+@router.get("/jobs")
+async def list_jobs(db: AsyncSession = Depends(get_db)) -> list[Job]:
+    result = await db.execute(select(JobDB).order_by(JobDB.posted_at.desc()))
+    return [_to_model(j) for j in result.scalars().all()]
+
+
+@router.post("/jobs", status_code=201)
+async def create_job(payload: JobCreate, db: AsyncSession = Depends(get_db)) -> Job:
+    db_job = JobDB(
+        id=new_id("job"),
+        title=payload.title,
+        budget=payload.budget,
+        skill=payload.skill,
+        description=payload.description,
+        urgent=payload.urgent,
+        location=payload.location,
+    )
+    db.add(db_job)
+    await db.commit()
+    await db.refresh(db_job)
+    return _to_model(db_job)
+
+
+@router.delete("/jobs/{job_id}", status_code=204)
+async def delete_job(job_id: str, db: AsyncSession = Depends(get_db)):
+    result = await db.execute(select(JobDB).where(JobDB.id == job_id))
+    db_job = result.scalar_one_or_none()
+    if not db_job:
+        raise HTTPException(status_code=404, detail="Job not found")
+    await db.delete(db_job)
+    await db.commit()

backend/app/db_models.py

@@ -6,6 +6,23 @@
 from app.database import Base
 
 
+class JobDB(Base):
+    __tablename__ = "jobs"
+
+    id: Mapped[str] = mapped_column(String(50), primary_key=True)
+    title: Mapped[str] = mapped_column(String(200), nullable=False)
+    budget: Mapped[str] = mapped_column(String(100), nullable=False)
+    skill: Mapped[str] = mapped_column(String(100), nullable=False)
+    description: Mapped[str] = mapped_column(Text, default="")
+    urgent: Mapped[bool] = mapped_column(Boolean, default=False)
+    location: Mapped[str] = mapped_column(String(200), default="")
+    posted_at: Mapped[datetime] = mapped_column(
+        DateTime(timezone=True),
+        default=lambda: datetime.now(timezone.utc),
+        nullable=False,
+    )
+
+
 class WorkerDB(Base):
     __tablename__ = "workers"
 

backend/app/main.py

@@ -5,6 +5,7 @@
 
 from app.api.routes.call import router as call_router
 from app.api.routes.health import router as health_router
+from app.api.routes.jobs import router as jobs_router
 from app.api.routes.karma import router as karma_router
 from app.api.routes.sessions import router as sessions_router
 from app.api.routes.speech import router as speech_router
@@ -34,4 +35,5 @@ async def lifespan(app: FastAPI):
 app.include_router(sessions_router, prefix="/api")
 app.include_router(speech_router, prefix="/api")
 app.include_router(call_router, prefix="/api")
+app.include_router(jobs_router, prefix="/api")
 app.include_router(karma_router, prefix="/api")

backend/app/models.py

@@ -225,6 +225,28 @@ class IntegrityEventResponse(BaseModel):
     pause_reason: Optional[Literal["multiface", "face_absent", "face_change"]] = None
 
 
+class JobCreate(BaseModel):
+    title: str = Field(min_length=3, max_length=200)
+    budget: str = Field(min_length=1, max_length=100)
+    skill: str = Field(min_length=2, max_length=100)
+    description: str = Field(default="", max_length=1000)
+    urgent: bool = False
+    location: str = Field(default="", max_length=200)
+
+
+class Job(BaseModel):
+    model_config = ConfigDict(extra="ignore")
+
+    id: str
+    title: str
+    budget: str
+    skill: str
+    description: str = ""
+    urgent: bool = False
+    location: str = ""
+    posted_at: str
+
+
 def utc_now_iso() -> str:
     return datetime.now(timezone.utc).isoformat()
 

backend/scripts/__init__.py

@@ -66,14 +66,22 @@ const DEMO_WORKERS = [
   },
 ];
 
-const JOBS = [
-  { id: 1, title: "Bridal Lehenga Embroidery", budget: "Rs. 2000-4000", skill: "Embroidery", postedAgo: "2h", urgent: true },
-  { id: 2, title: "10 Suit Alterations (Corporate)", budget: "Rs. 1500", skill: "Alterations", postedAgo: "5h", urgent: false },
-  { id: 3, title: "Pattern Making - SS25 Collection", budget: "Rs. 5000-8000", skill: "Pattern Making", postedAgo: "1d", urgent: false },
-  { id: 4, title: "Leather Jacket Repair and Restoration", budget: "Rs. 800-1200", skill: "Leather Work", postedAgo: "3h", urgent: true },
-  { id: 5, title: "Children's School Uniform x 30 pcs", budget: "Rs. 600-800", skill: "Children's Wear", postedAgo: "2d", urgent: false },
+const FALLBACK_JOBS = [
+  { id: "f1", title: "Bridal Lehenga Embroidery", budget: "Rs. 2000-4000", skill: "Embroidery", posted_at: new Date(Date.now() - 2 * 3600000).toISOString(), urgent: true },
+  { id: "f2", title: "10 Suit Alterations (Corporate)", budget: "Rs. 1500", skill: "Alterations", posted_at: new Date(Date.now() - 5 * 3600000).toISOString(), urgent: false },
+  { id: "f3", title: "Leather Jacket Repair and Restoration", budget: "Rs. 800-1200", skill: "Leather Work", posted_at: new Date(Date.now() - 3 * 3600000).toISOString(), urgent: true },
 ];
 
+function postedAgo(isoString) {
+  const diff = Date.now() - new Date(isoString).getTime();
+  const mins = Math.floor(diff / 60000);
+  if (mins < 2) return "just now";
+  if (mins < 60) return `${mins}m`;
+  const hrs = Math.floor(mins / 60);
+  if (hrs < 24) return `${hrs}h`;
+  return `${Math.floor(hrs / 24)}d`;
+}
+
 const inputStyle = {
   width: "100%",
   padding: "10px 12px",
@@ -402,7 +410,7 @@ function JobCard({ job, copy, skillLabel }) {
       <div style={{ display: "flex", alignItems: "center", gap: 10, flexWrap: "wrap" }}>
         <span style={{ fontSize: 11, padding: "5px 10px", borderRadius: 999, background: palette.soft, color: palette.primary, fontWeight: 700 }}>{skillLabel(job.skill)}</span>
         <span style={{ fontSize: 13, color: palette.text, fontWeight: 700, marginLeft: "auto" }}>{job.budget}</span>
-        <span style={{ fontSize: 12, color: palette.muted }}>{job.postedAgo}</span>
+        <span style={{ fontSize: 12, color: palette.muted }}>{job.posted_at ? postedAgo(job.posted_at) : (job.postedAgo || "")}</span>
       </div>
     </article>
   );
@@ -479,11 +487,18 @@ export default function WorkersBoardPage() {
   const [selectedWorker, setSelectedWorker] = useState(null);
   const [activeTab, setActiveTab] = useState("tailors");
   const [postForm, setPostForm] = useState({ title: "", skill: "Alterations", budget: "", description: "" });
-  const [postedJobs, setPostedJobs] = useState(JOBS);
+  const [postedJobs, setPostedJobs] = useState([]);
   const [jobPosted, setJobPosted] = useState(false);
 
   const skillLabel = (skill) => copy.skillLabels[skill] || skill;
 
+  // Fetch jobs from API
+  useEffect(() => {
+    screeningApi.listJobs()
+      .then((jobs) => setPostedJobs(jobs && jobs.length > 0 ? jobs : FALLBACK_JOBS))
+      .catch(() => setPostedJobs(FALLBACK_JOBS));
+  }, []);
+
   // Fetch real workers from API
   useEffect(() => {
     screeningApi.listWorkers()
@@ -526,10 +541,14 @@ export default function WorkersBoardPage() {
 
   const handlePostJob = () => {
     if (!postForm.title || !postForm.description) return;
-    setPostedJobs((prev) => [{ id: Date.now(), title: postForm.title, budget: postForm.budget || copy.openBudget, skill: postForm.skill, postedAgo: copy.justNow, urgent: false }, ...prev]);
+    const optimistic = { id: `opt_${Date.now()}`, title: postForm.title, budget: postForm.budget || copy.openBudget, skill: postForm.skill, posted_at: new Date().toISOString(), urgent: false };
+    setPostedJobs((prev) => [optimistic, ...prev]);
     setJobPosted(true);
     setPostForm({ title: "", skill: "Alterations", budget: "", description: "" });
     setTimeout(() => setJobPosted(false), 3000);
+    screeningApi.createJob({ title: optimistic.title, budget: optimistic.budget, skill: optimistic.skill, description: postForm.description })
+      .then((created) => setPostedJobs((prev) => prev.map((j) => j.id === optimistic.id ? created : j)))
+      .catch(() => {});
   };
 
   const totalKarma = Object.values(karmaMap);

backend/scripts/seed_demo.py

@@ -55,4 +55,8 @@ export const screeningApi = {
     (await client.get("/review/queue")).data,
   submitReviewDecision: async (sessionId, payload) =>
     (await client.post(`/review/${sessionId}/decision`, payload)).data,
+
+  // Jobs
+  listJobs: async () => (await client.get("/jobs")).data,
+  createJob: async (payload) => (await client.post("/jobs", payload)).data,
 };