import os
from supabase import create_client
from dotenv import load_dotenv

load_dotenv('/workspaces/govbridge/.env')
sb = create_client(os.getenv('SUPABASE_URL'), os.getenv('SUPABASE_KEY'))

res = sb.table('schemes').select('id, title').execute()
for r in res.data:
    if "PIB:" in r['title'] or "Press Release" in r.get('category', ''):
        sb.table('schemes').update({'is_verified': False, 'benefits': '', 'eligibility_text': ''}).eq('id', r['id']).execute()

print("Reset PIB records for re-enrichment")