from fastapi import APIRouter, Depends, HTTPException from sqlalchemy.orm import Session from typing import List from app.db.session import get_db from app.models.driver import Driver from app.schemas.driver import Driver as DriverSchema, DriverCreate, DriverUpdate router = APIRouter() @router.post("/", response_model=DriverSchema) def create_driver(driver: DriverCreate, db: Session = Depends(get_db)): db_driver = Driver(**driver.dict()) db.add(db_driver) db.commit() db.refresh(db_driver) return db_driver @router.get("/", response_model=List[DriverSchema]) def read_drivers(skip: int = 0, limit: int = 100, available_only: bool = False, db: Session = Depends(get_db)): query = db.query(Driver) if available_only: query = query.filter(Driver.is_available == True) drivers = query.offset(skip).limit(limit).all() return drivers @router.get("/{driver_id}", response_model=DriverSchema) def read_driver(driver_id: int, db: Session = Depends(get_db)): driver = db.query(Driver).filter(Driver.id == driver_id).first() if driver is None: raise HTTPException(status_code=404, detail="Driver not found") return driver @router.put("/{driver_id}", response_model=DriverSchema) def update_driver(driver_id: int, driver: DriverUpdate, db: Session = Depends(get_db)): db_driver = db.query(Driver).filter(Driver.id == driver_id).first() if db_driver is None: raise HTTPException(status_code=404, detail="Driver not found") update_data = driver.dict(exclude_unset=True) for field, value in update_data.items(): setattr(db_driver, field, value) db.commit() db.refresh(db_driver) return db_driver @router.delete("/{driver_id}") def delete_driver(driver_id: int, db: Session = Depends(get_db)): driver = db.query(Driver).filter(Driver.id == driver_id).first() if driver is None: raise HTTPException(status_code=404, detail="Driver not found") db.delete(driver) db.commit() return {"message": "Driver deleted successfully"}