main.py

from fastapi import Depends, FastAPI
from fastapi.middleware.cors import CORSMiddleware
from model import Products
from database import session , engine
import database_model
from sqlalchemy.orm import Session

app=FastAPI()
app.add_middleware(
    CORSMiddleware,
    allow_origins=["http://localhost:3000"],
    allow_credentials=True,
    allow_methods=["*"],    
    allow_headers=["*"],
)

database_model.Base.metadata.create_all(bind=engine)

# Root endpoint
@app.get("/")
def greet():
    return "Welcome to NRK Productions"


products=[
    Products(id=1,name="Laptop",description="A high performance laptop",price=1200.00,quantity=10),
    Products(id=2, name="Smartphone", description="A latest model smartphone", price=800.00, quantity=25),
    Products(id=3, name="Headphones", description="Noise-cancelling headphones", price=150.00, quantity=50),
    Products(id=4, name="Monitor", description="4K UHD Monitor", price=400.00, quantity=15),
    Products(id=5, name="Keyboard", description="Mechanical keyboard", price=100.00, quantity=30)
]

def get_db():
    db=session()
    try:
        yield db
    finally:
        db.close()


# Initialize database with sample products
def initdb():
    db=session()

    count=db.query(database_model.Product).count()
    if count==0:
        for product in products:
            db.add(database_model.Product(**product.model_dump()))
        db.commit()
initdb()



# Get all products
@app.get("/products")
def get_all_products(db: Session = Depends(get_db)):
    
    db_products=db.query(database_model.Product).all()
    return db_products



# Get product by ID
@app.get("/products/{product_id}")
def get_product_by_id(product_id:int, db: Session = Depends(get_db)):

    db_products=db.query(database_model.Product).filter(database_model.Product.id==product_id).first()
    if db_products:
        return db_products
    return "Product not found"




# Add a new product
@app.post("/products")
def add_products(product:Products,db: Session = Depends(get_db)):

    db_product= database_model.Product(**product.model_dump())
    db.add(db_product)
    db.commit()
    return products

# Update an existing product
@app.put("/products/{product_id}")
def update_product(product_id:int, updated_product:Products, db: Session = Depends(get_db)):
     db_products=db.query(database_model.Product).filter(database_model.Product.id==product_id).first()
     if db_products:
        db_products.name=updated_product.name
        db_products.description=updated_product.description
        db_products.price=updated_product.price
        db_products.quantity=updated_product.quantity
        db.commit()
        return "Product updated successfully"
     else:
        return "Product not found"




# Delete a product
@app.delete("/products/{product_id}")
def delete_product(product_id:int,db: Session = Depends(get_db)):
    db_products=db.query(database_model.Product).filter(database_model.Product.id==product_id).first()
    if db_products:
        db.delete(db_products)
        db.commit()
        return "Product deleted successfully"
    else:
        return "Product not found"