payment endpoint added for user

api/sources/user/data_sources/payment.py

@@ -0,0 +1,18 @@
+from dotenv import load_dotenv
+
+from core.constants import Tables
+from core.interface.supabase_client import supabase_config, async_supabase_client
+
+load_dotenv()
+
+
+class PaymentDataSource:
+
+    @staticmethod
+    async def update_payment_status(status: bool, _id: int):
+        supabase = await async_supabase_client(supabase_config)
+        response = await supabase.table(Tables.PAYMENTS) \
+            .update({'status': status}) \
+            .eq('id', _id) \
+            .execute()
+        return response.data[0]['id']

api/sources/user/request_params/payment.py

@@ -0,0 +1,6 @@
+from pydantic import BaseModel, Field
+
+
+class UpdatePaymentStatusRequest(BaseModel):
+    status: bool = Field(..., description="payment status")
+    id: int = Field(..., description="payment id")

api/v1/user_endpoints/payment.py

@@ -0,0 +1,13 @@
+from fastapi import APIRouter, Depends
+
+from api.sources.user.data_sources.payment import PaymentDataSource
+from api.sources.user.request_params.payment import UpdatePaymentStatusRequest
+from core.depends.oauth import get_current_user
+
+router = APIRouter(prefix='/payment')
+
+
+@router.post("/update")
+async def update_payment_status(request: UpdatePaymentStatusRequest, current_user: dict = Depends(get_current_user)):
+    await PaymentDataSource.update_payment_status(status=request.status, _id=request.id)
+    return {"result": True}

api/v1/user_router.py

@@ -1,5 +1,5 @@
 from fastapi import APIRouter
-from api.v1.user_endpoints import chat, auth, user, brand
+from api.v1.user_endpoints import chat, auth, user, brand, payment
 
 user_router = APIRouter(prefix='/user')
 
@@ -7,3 +7,4 @@ user_router.include_router(chat.router)
 user_router.include_router(auth.router)
 user_router.include_router(user.router)
 user_router.include_router(brand.router)
+user_router.include_router(payment.router)