api/sources/agent/data_sources/payment.py

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 add_payment(payment_json: dict) -> int:
        supabase = await async_supabase_client(supabase_config)
        response = await supabase.table(Tables.PAYMENTS) \
            .insert(payment_json) \
            .execute()
        return response.data[0]['id']