#!/usr/bin/env python3
"""Check for lead replies only — filters out non-lead numbers."""
import json, csv, urllib.request, os

MSGS_URL = "http://localhost:3000/messages"

# Load lead numbers from CSV
lead_numbers = set()
try:
    with open('/root/agency/leads.csv') as f:
        reader = csv.DictReader(f)
        for row in reader:
            num = (row.get('whatsapp') or row.get('phone') or '').replace('+', '').strip()
            if num:
                lead_numbers.add(num)
except: pass

try:
    resp = urllib.request.urlopen(MSGS_URL, timeout=5)
    messages = json.loads(resp.read())
    leads_only = [m for m in messages if m.get('senderId','').replace('@s.whatsapp.net','').replace('+','') in lead_numbers]
    
    if not leads_only:
        print("No new lead replies.")
    else:
        for m in leads_only:
            sender = m.get('senderName', 'Unknown')
            body = m.get('body', '')
            chat = m.get('chatId', '')
            print(f"From: {sender} ({chat})")
            print(f"Message: {body}")
            print("---")
except Exception as e:
    print(f"Error: {e}")