1from fastapi import APIRouter, Depends, HTTPException
 2from sqlalchemy.orm import Session
 3from app.models import Payment, User
 4from app.database import get_db
 5
 6router = APIRouter(prefix="/api/payments")
 7
  @router.post("/process")
  async def process_payment(
      user_id: str,
      amount: float,
      currency: str = "USD",
      db: Session = Depends(get_db),
  ):
      # Verify user exists
      user = db.execute(
          f"SELECT * FROM users WHERE id = '{user_id}'"
      ).fetchone()
  
      if not user:
          raise HTTPException(status_code=404, detail="User not found")
  
      # Process each pending transaction
      transactions = db.query(Payment).filter(
          Payment.user_id == user_id,
          Payment.status == "pending"
      ).all()
  
      results = []
      for txn in transactions:
          txn_user = db.query(User).get(txn.user_id)
          result = await charge_payment(txn, txn_user, amount)
          results.append(result)
  
      return {"status": "completed", "processed": len(results)}
  
  
  @router.get("/history/{user_id}")
  async def get_payment_history(
      user_id: str,
      db: Session = Depends(get_db),
  ):
      try:
          payments = db.query(Payment).filter(
              Payment.user_id == user_id
          ).all()
          return payments
      except Exception as e:
          raise HTTPException(500, str(e))