import asyncio
import os
import json
from supabase import create_client
from dotenv import load_dotenv
from api import perform_candidate_analysis

load_dotenv()

SUPABASE_URL = os.environ.get("SUPABASE_URL")
SUPABASE_KEY = os.environ.get("SUPABASE_SERVICE_ROLE_KEY") or os.environ.get("SUPABASE_KEY")
client = create_client(SUPABASE_URL, SUPABASE_KEY)

async def verify():
    res = client.table("applications").select("user_id, job_id").limit(1).execute()
    if not res.data:
        print("No apps found")
        return
        
    c_id = res.data[0]["user_id"]
    j_id = res.data[0]["job_id"]
    
    print(f"Triggering fresh analysis for {c_id} / {j_id}")
    await perform_candidate_analysis(c_id, j_id, force_refresh=True)
    
    print("\nChecking resulting record in DB:")
    final_res = client.table("applications") \
        .select("match_score, skills_match, technical_skills_match, work_experience_match, education_match, certifications_match, project_match") \
        .eq("user_id", c_id).eq("job_id", j_id) \
        .execute()
        
    if final_res.data:
        print(json.dumps(final_res.data[0], indent=2))
    else:
        print("Record not found after update")

if __name__ == "__main__":
    asyncio.run(verify())