Fix database session dependency in auth.py

app/auth.py

@@ -93,38 +93,26 @@ async def login(form_data: OAuth2PasswordRequestForm = Depends()):
 @router.post("/customers/", response_model=dict)
 async def create_customer(
     customer_data: dict,
-    db: Session = Depends(Customer.get_db),
+    db: Session = Depends(get_db),
     current_admin: str = Depends(get_current_admin)
 ):
-    # Generate API key
-    api_key = secrets.token_urlsafe(32)
+    """Create a new customer"""
+    # Check if email already exists
+    existing_customer = db.query(Customer).filter(Customer.email == customer_data["email"]).first()
+    if existing_customer:
+        raise HTTPException(
+            status_code=status.HTTP_400_BAD_REQUEST,
+            detail="Email already registered"
+        )
     
     # Create new customer
     customer = Customer(
         name=customer_data["name"],
         company_name=customer_data["company_name"],
         email=customer_data["email"],
-        api_key=api_key,
-        # Database credentials
-        db_host=customer_data.get("db_host"),
-        db_port=customer_data.get("db_port"),
-        db_name=customer_data.get("db_name"),
-        db_user=customer_data.get("db_user"),
-        db_password=customer_data.get("db_password")
+        api_key=str(secrets.token_urlsafe(32))
     )
     
-    # Validate database connection if credentials are provided
-    if all([customer.db_host, customer.db_port, customer.db_name, customer.db_user, customer.db_password]):
-        try:
-            engine = customer.get_db_engine()
-            with engine.connect() as conn:
-                conn.execute("SELECT 1")
-        except Exception as e:
-            raise HTTPException(
-                status_code=400,
-                detail=f"Invalid database credentials: {str(e)}"
-            )
-    
     db.add(customer)
     db.commit()
     db.refresh(customer)
@@ -134,24 +122,25 @@ async def create_customer(
         "name": customer.name,
         "company_name": customer.company_name,
         "email": customer.email,
-        "api_key": customer.api_key,
-        "db_configured": bool(customer.get_db_url())
+        "api_key": customer.api_key
     }
 
 @router.get("/customers/", response_model=list)
 async def list_customers(
-    db: Session = Depends(Customer.get_db),
+    db: Session = Depends(get_db),
     current_admin: str = Depends(get_current_admin)
 ):
+    """List all customers"""
     customers = db.query(Customer).all()
     return customers
 
 @router.get("/customers/{customer_id}", response_model=dict)
 async def get_customer(
     customer_id: int,
-    db: Session = Depends(Customer.get_db),
+    db: Session = Depends(get_db),
     current_admin: str = Depends(get_current_admin)
 ):
+    """Get customer details"""
     customer = db.query(Customer).filter(Customer.id == customer_id).first()
     if not customer:
         raise HTTPException(status_code=404, detail="Customer not found")
@@ -160,12 +149,14 @@ async def get_customer(
 @router.delete("/customers/{customer_id}")
 async def delete_customer(
     customer_id: int,
-    db: Session = Depends(Customer.get_db),
+    db: Session = Depends(get_db),
     current_admin: str = Depends(get_current_admin)
 ):
+    """Delete a customer"""
     customer = db.query(Customer).filter(Customer.id == customer_id).first()
     if not customer:
         raise HTTPException(status_code=404, detail="Customer not found")
+    
     db.delete(customer)
     db.commit()
     return {"message": "Customer deleted successfully"}