feat: implement CRUD operations for users and posts; add tests and coverage reporting

papi.py

@@ -2,9 +2,8 @@
 from fastapi import FastAPI, Depends
 import uvicorn
 from sqlalchemy import create_engine, Column, Integer,String, ForeignKey
-from sqlalchemy.ext.declarative import declarative_base
 from sqlalchemy.engine import URL
-from sqlalchemy.orm import sessionmaker, Session
+from sqlalchemy.orm import sessionmaker, Session, declarative_base
 
 
 
@@ -30,6 +29,7 @@ class User(Base):
     email = Column(String, unique=True, index=True)
     password = Column(String)
 
+
 class Post(Base):
     __tablename__ = "posts"
     id = Column(Integer, primary_key=True, index=True)
@@ -50,10 +50,11 @@ async def root():
 @app.get("/users")
 async def get_users(db: Session = Depends(get_db)):
     return db.query(User).all()
-    #return [{"id":"asdf1234"}]
+
 @app.get("/users/{id}")
-async def get_user(id: str):
-    return {"id": id}
+async def get_user(id: str,db: Session = Depends(get_db)):
+    db_user = db.query(User).filter(User.id == id).first()
+    return db_user
 
 @app.post("/users")
 async def create_user(user: dict,db: Session = Depends(get_db)):
@@ -64,6 +65,30 @@ async def create_user(user: dict,db: Session = Depends(get_db)):
     db.refresh(db_user)
     return {"message":"User created successfully","user":db_user}
 
+@app.put("/users/{id}")
+async def update_user(id: str, user: dict,db: Session = Depends(get_db)):
+    db_user = db.query(User).filter(User.id == id).first()
+    if "name" in user:
+        db_user.name = user["name"]
+    if "email" in user:
+        db_user.email = user["email"]
+    if "password" in user:
+        db_user.password = user["password"]
+    db.commit()
+    db.refresh(db_user)
+    return {"message":"User updated successfully","user":db_user}
+
+
+
+@app.delete("/users/{id}")
+async def delete_user(id: str, db: Session = Depends(get_db)):
+    db_user = db.query(User).filter(User.id == id).first()
+    db.delete(db_user)
+    db.commit()
+    return {"message":"User deleted successfully","user":db_user}
+
+
+
 @app.get("/posts")
 async def get_posts(db: Session = Depends(get_db)):
     return db.query(Post).all()
@@ -93,18 +118,13 @@ async def update_post(id: str, post: dict,db: Session = Depends(get_db)):
     return {"message":"Post updated successfully","post":db_post}
 
 @app.delete("/posts/{id}")
-async def delete_post(id: str, post: dict,db: Session = Depends(get_db)):
+async def delete_post(id: str, db: Session = Depends(get_db)):
     db_post = db.query(Post).filter(Post.id == id).first()
     db.delete(db_post)
     db.commit()
     return {"message":"Post deleted successfully","post":db_post}
 
 
-@app.get("/hello/{name}")
-async def say_hello(name: str):
-    return {"message": f"Hello {name}"}
-
-
 
 if __name__ == "__main__":
     uvicorn.run("papi:app", host="0.0.0.0", port=8912, reload=True, log_level="debug",