Real Estate Property Monitoring

curl -X POST https://api.supacrawler.com/api/v1/watch \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "url": "https://realty-site.com/austin-condos",
    "frequency": "hourly",
    "selector": ".property-price, .listing-card",
    "notify_email": "[email protected]",
    "notification_preference": "changes_only"
  }'

import requests
import os

# Step 1: Create property monitoring with webhook
def setup_property_monitoring_with_crm():
    """Setup property monitoring that feeds directly into CRM"""
    
    api_key = os.environ['SUPACRAWLER_API_KEY']
    
    # Monitor high-value properties for your CRM
    property_monitors = [
        {
            "url": "https://luxury-homes.com/beverly-hills-estates",
            "market": "Beverly Hills Luxury",
            "webhook_url": "https://your-crm.com/api/supacrawler-webhook"
        },
        {
            "url": "https://investment-properties.com/multi-family-deals", 
            "market": "Investment Properties",
            "webhook_url": "https://your-crm.com/api/supacrawler-webhook"
        }
    ]
    
    for monitor_config in property_monitors:
        # Create Supacrawler watch job
        response = requests.post("https://api.supacrawler.com/api/v1/watch",
            headers={
                "Authorization": f"Bearer {api_key}",
                "Content-Type": "application/json"
            },
            json={
                "url": monitor_config["url"],
                "frequency": "hourly",
                "selector": ".property-card, .new-listing, .price-change",
                "notification_preference": "changes_only",
                
                # CRM integration via webhook
                "webhook_url": monitor_config["webhook_url"],
                "webhook_headers": {
                    "X-Market": monitor_config["market"],
                    "X-Source": "property-monitoring",
                    "Authorization": "Bearer YOUR_CRM_API_KEY"
                },
                
                # Include rich data for CRM
                "include_image": True,
                "include_html": True,
                "full_page": False
            }
        )
        
        result = response.json()
        if result.get('success'):
            print(f"✅ {monitor_config['market']}: {result['watch_id']}")
        else:
            print(f"❌ Failed: {result.get('error')}")

# Step 2: CRM webhook handler
from flask import Flask, request, jsonify

app = Flask(__name__)

@app.route('/api/supacrawler-webhook', methods=['POST'])
def handle_property_alert():
    """Process Supacrawler property alerts into CRM leads"""
    
    data = request.json
    
    # Extract property details from Supacrawler data
    property_info = {
        'source_url': data.get('url'),
        'change_type': data.get('change_type', 'unknown'),
        'screenshot_url': data.get('screenshot_url'),
        'market': data.get('headers', {}).get('X-Market', 'Unknown'),
        'detected_at': data.get('timestamp'),
        'changes': data.get('changes', [])
    }
    
    # Determine lead priority based on change type
    if any('price' in change.lower() for change in property_info['changes']):
        priority = 'high'
        lead_type = 'price_reduction'
    elif any('new' in change.lower() for change in property_info['changes']):
        priority = 'urgent'
        lead_type = 'new_listing'
    else:
        priority = 'normal'
        lead_type = 'market_update'
    
    # Create CRM lead
    crm_lead = {
        'source': 'property_monitoring',
        'lead_type': lead_type,
        'priority': priority,
        'property_url': property_info['source_url'],
        'market': property_info['market'],
        'screenshot_evidence': property_info['screenshot_url'],
        'notes': f"Automated alert: {', '.join(property_info['changes'])}",
        'follow_up_date': property_info['detected_at']
    }
    
    # Send to CRM
    crm_response = create_crm_lead(crm_lead)
    
    return jsonify({
        'status': 'processed',
        'crm_lead_id': crm_response.get('id'),
        'priority': priority
    })

def create_crm_lead(lead_data):
    """Create lead in CRM system"""
    return requests.post('https://your-crm.com/api/leads', 
        headers={'Authorization': 'Bearer YOUR_CRM_API_KEY'},
        json=lead_data
    )

# Step 3: Run the setup
setup_property_monitoring_with_crm()