from uuid import UUID from fastapi import APIRouter, HTTPException, Depends from fastapi_pagination import Page from fastapi_pagination.ext.sqlmodel import paginate from db import SessionDep from transaction.models import TransactionCreate, TransactionRead, TransactionUpdate from transaction.resource import TransactionResource from user.manager import get_current_user router = APIRouter() @router.post("") def create_transaction(transaction: TransactionCreate, session: SessionDep, current_user=Depends(get_current_user)) -> TransactionRead: result = TransactionResource.create(transaction, session) return result @router.get("") def read_transactions(session: SessionDep, current_user=Depends(get_current_user)) -> Page[TransactionRead]: return paginate(session, TransactionResource.list()) @router.get("/{transaction_id}") def read_transaction(transaction_id: UUID, session: SessionDep, current_user=Depends(get_current_user)) -> TransactionRead: transaction = TransactionResource.get(session, transaction_id) if not transaction: raise HTTPException(status_code=404, detail="Transaction not found") return transaction @router.put("/{transaction_id}") def update_transaction(transaction_id: UUID, transaction: TransactionUpdate, session: SessionDep, current_user=Depends(get_current_user)) -> TransactionRead: db_transaction = TransactionResource.get(session, transaction_id) if not db_transaction: raise HTTPException(status_code=404, detail="Transaction not found") transaction_data = transaction.model_dump(exclude_unset=True) transaction = TransactionResource.update(session, db_transaction, transaction_data) return transaction @router.delete("/{transaction_id}") def delete_transaction(transaction_id: UUID, session: SessionDep, current_user=Depends(get_current_user)): transaction = TransactionResource.get(session, transaction_id) if not transaction: raise HTTPException(status_code=404, detail="Transaction not found") TransactionResource.delete(session, transaction) return {"ok": True}