import requests
from flask import Flask, request, jsonifyapp = Flask(__name__)CLOSE_API_KEY = "your_close_api_key"
CLOSE_API_URL = "https://api.close.com/api/v1"def create_close_lead(lead_data):
    """Create a lead in Close CRM."""
    resp = requests.post(
        f"{CLOSE_API_URL}/lead/",
        auth=(CLOSE_API_KEY, ""),
        json=lead_data
    )
    return resp.json()def search_lead_by_email(email):
    """Search for an existing lead by contact email."""
    resp = requests.get(
        f"{CLOSE_API_URL}/lead/",
        auth=(CLOSE_API_KEY, ""),
        params={"query": f"email:{email}"}
    )
    data = resp.json()
    leads = data.get("data", [])
    if leads:
        return leads[0]["id"]
    return [email protected]("/browse-ai-webhook", methods=["POST"])
def handle_webhook():
    payload = request.get_json()    if payload.get("event") != "taskFinishedSuccessfully":
        return jsonify({"status": "ignored"}), 200    task = payload["task"]
    captured = task.get("capturedTexts", {})    email = captured.get("email", "")    # Check if lead already exists
    existing_lead_id = None
    if email:
        existing_lead_id = search_lead_by_email(email)    if existing_lead_id:
        return jsonify({"status": "exists", "lead_id": existing_lead_id}), 200    # Build lead data with nested contact
    lead_data = {
        "name": captured.get("company_name", "") or f"{captured.get('first_name', '')} {captured.get('last_name', '')}".strip() or "Unknown",
        "url": captured.get("website", ""),
        "contacts": [{
            "name": f"{captured.get('first_name', '')} {captured.get('last_name', '')}".strip(),
            "title": captured.get("job_title", ""),
            "emails": [{"email": email, "type": "office"}] if email else [],
            "phones": [{"phone": captured.get("phone", ""), "type": "office"}] if captured.get("phone") else []
        }],
        "custom.cf_lead_source": "Browse AI"
    }    result = create_close_lead(lead_data)
    return jsonify({"status": "created", "lead_id": result.get("id")}), 200if __name__ == "__main__":
    app.run(host="0.0.0.0", port=5000)

curl -X POST "https://api.browse.ai/v2/robots/YOUR_ROBOT_ID/webhooks" \
  -H "Authorization: Bearer YOUR_BROWSE_AI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "url": "https://yourdomain.com/browse-ai-webhook",
    "events": ["taskFinishedSuccessfully"]
  }'

import requests
from datetime import datetime, timedeltaBROWSE_AI_API_KEY = "your_browse_ai_api_key"
ROBOT_ID = "your_robot_id"
CLOSE_API_KEY = "your_close_api_key"def get_recent_tasks(since_hours=1):
    """Fetch tasks completed in the last N hours."""
    resp = requests.get(
        f"https://api.browse.ai/v2/robots/{ROBOT_ID}/tasks",
        headers={"Authorization": f"Bearer {BROWSE_AI_API_KEY}"},
        params={"pageSize": 100}
    )
    tasks = resp.json().get("result", {}).get("robotTasks", {}).get("items", [])    cutoff = datetime.utcnow() - timedelta(hours=since_hours)
    return [t for t in tasks if t.get("status") == "successful"
            and datetime.fromisoformat(t["finishedAt"].replace("Z","")) > cutoff]def sync_to_close(tasks):
    """Create Close leads from Browse AI task results."""
    for task in tasks:
        captured = task.get("capturedTexts", {})
        lead_data = {
            "name": captured.get("company_name", "Unknown"),
            "contacts": [{
                "name": f"{captured.get('first_name', '')} {captured.get('last_name', '')}".strip(),
                "emails": [{"email": captured.get("email", ""), "type": "office"}] if captured.get("email") else [],
                "phones": [{"phone": captured.get("phone", ""), "type": "office"}] if captured.get("phone") else []
            }]
        }        requests.post(
            "https://api.close.com/api/v1/lead/",
            auth=(CLOSE_API_KEY, ""),
            json=lead_data
        )# Run this script on a schedule (e.g. cron job every hour)

# Search for existing lead by email
resp = requests.get(
    "https://api.close.com/api/v1/lead/",
    auth=(CLOSE_API_KEY, ""),
    params={"query": "email:[email protected]"}
)
existing = resp.json().get("data", [])
if existing:
    lead_id = existing[0]["id"]
    # Update instead of creating