database.py

from supabase import create_client
import os

supabase = create_client(os.getenv("SUPABASE_URL", ""), os.getenv("SUPABASE_KEY", ""))

def save_lead(data: dict):
    return supabase.table("leads").insert(data).execute()

def get_pending_leads():
    return supabase.table("leads").select("*").eq("status", "pending").execute().data

def update_lead_status(lead_id: int, status: str):
    return supabase.table("leads").update({"status": status}).eq("id", lead_id).execute()