sync_contacts.py

import requests
import json
import re


def validate_phone(number):
    """
    Validate and normalize Indian phone number.
    Returns normalized format like "+91 99999 99999" or None if invalid.
    """
    # Remove all spaces, dashes, dots
    cleaned = re.sub(r'[\s\-\.]', '', number)
    
    # Check various formats
    if re.match(r'^\+91\d{10}$', cleaned):
        # +919999999999 -> +91 99999 99999
        digits = cleaned[3:]
    elif re.match(r'^91\d{10}$', cleaned):
        # 919999999999 -> +91 99999 99999
        digits = cleaned[2:]
    elif re.match(r'^0\d{10}$', cleaned):
        # 09999999999 -> +91 99999 99999
        digits = cleaned[1:]
    elif re.match(r'^\d{10}$', cleaned):
        # 9999999999 -> +91 99999 99999
        digits = cleaned
    else:
        return None
    
    # Format as "+91 XXXXX XXXXX"
    return f"+91 {digits[:5]} {digits[5:]}"


def parse_phones(phones_csv=None, phones_file=None):
    """
    Parse phone numbers from comma-separated string or file.
    Returns list of raw phone strings.
    """
    phones = []
    
    if phones_csv:
        phones = [p.strip() for p in phones_csv.split(',') if p.strip()]
    elif phones_file:
        with open(phones_file, 'r') as f:
            phones = [line.strip() for line in f if line.strip()]
    
    return phones


def build_contacts(phones):
    """
    Build contacts array in Zomato format.
    Returns tuple: (contacts_list, errors_list)
    """
    contacts = []
    errors = []
    
    for i, phone in enumerate(phones):
        normalized = validate_phone(phone)
        if not normalized:
            errors.append(f"Invalid: '{phone}' - Use format: +919999999999, 9999999999, or 09999999999")
            continue
        
        # Extract just digits for name
        digits = re.sub(r'\D', '', normalized)[-10:]
        
        contacts.append({
            "phone_numbers": [normalized],
            "name": f"poc_contact_{digits}",
            "id": str(i + 1)
        })
    
    return contacts, errors


def sync_contacts(zomato_token, phones_csv=None, phones_file=None, proxies=None):
    """
    Sync contacts to Zomato.
    
    Args:
        zomato_token: X-Zomato-Access-Token
        phones_csv: Comma separated phone numbers (e.g. "9999999999,8888888888")
        phones_file: Path to text file with one phone per line
    
    Returns dict with success status and synced contacts.
    """
    if not phones_csv and not phones_file:
        return {'success': False, 'error': 'Provide phones_csv or phones_file'}
    
    if phones_csv and phones_file:
        return {'success': False, 'error': 'Provide only one: phones_csv OR phones_file'}
    
    # Parse phones
    phones = parse_phones(phones_csv, phones_file)
    if not phones:
        return {'success': False, 'error': 'No phone numbers provided'}
    
    # Build contacts
    contacts, errors = build_contacts(phones)
    
    if errors:
        return {
            'success': False,
            'error': 'Invalid phone numbers',
            'validation_errors': errors,
            'examples': ['+919999999999', '9999999999', '09876543210']
        }
    
    if not contacts:
        return {'success': False, 'error': 'No valid contacts to sync'}
    
    url = "https://api.zomato.com/gw/user-preference/recommendation/sync-contacts"
    
    headers = {
        "Accept": "image/webp",
        "Accept-Encoding": "gzip, deflate, br",
        "Content-Type": "application/json; charset=utf-8",
        "Host": "api.zomato.com",
        "X-Zomato-Access-Token": zomato_token,
        "X-Zomato-API-Key": "7749b19667964b87a3efc739e254ada2",
        "X-Zomato-App-Version": "931",
        "X-Zomato-App-Version-Code": "1710019310",
        "X-Zomato-Client-Id": "5276d7f1-910b-4243-92ea-d27e758ad02b"
    }

    
    payload = {
        "flow_type": "revamped_flow",
        "contacts_access_level": "full_access",
        "contacts": contacts,
        "location": {
            "city_id": 11111,
            "place": {
                "delivery_subzone_id": 11111
            }
        }
    }
    
    try:
        response = requests.post(url, json=payload, headers=headers, proxies=proxies, verify=True if not proxies else False)
        success = response.status_code >= 200 and response.status_code < 300
        
        return {
            'success': success,
            'status_code': response.status_code,
            'response': response.json() if response.text else None
        }
    except Exception as e:
        return {
            'success': False,
            'error': str(e)
        }