import requests
from flask import Flask, request, jsonifyapp = Flask(__name__)HUBSPOT_ACCESS_TOKEN = "your_private_app_access_token"def create_or_update_hubspot_contact(properties):
    """Create or update a HubSpot contact using the email address."""
    email = properties.get("email", "")    if email:
        # Try to update existing contact by email first
        search_resp = requests.post(
            "https://api.hubapi.com/crm/v3/objects/contacts/search",
            headers={
                "Authorization": f"Bearer {HUBSPOT_ACCESS_TOKEN}",
                "Content-Type": "application/json"
            },
            json={
                "filterGroups": [{
                    "filters": [{
                        "propertyName": "email",
                        "operator": "EQ",
                        "value": email
                    }]
                }]
            }
        )
        results = search_resp.json().get("results", [])        if results:
            # Update existing contact
            contact_id = results[0]["id"]
            resp = requests.patch(
                f"https://api.hubapi.com/crm/v3/objects/contacts/{contact_id}",
                headers={
                    "Authorization": f"Bearer {HUBSPOT_ACCESS_TOKEN}",
                    "Content-Type": "application/json"
                },
                json={"properties": properties}
            )
            return resp.json(), "updated"    # Create new contact
    resp = requests.post(
        "https://api.hubapi.com/crm/v3/objects/contacts",
        headers={
            "Authorization": f"Bearer {HUBSPOT_ACCESS_TOKEN}",
            "Content-Type": "application/json"
        },
        json={"properties": properties}
    )
    return resp.json(), "created"@app.route("/browse-ai-webhook", methods=["POST"])
def handle_webhook():
    payload = request.get_json()    # Only process successful task completions
    if payload.get("event") != "taskFinishedSuccessfully":
        return jsonify({"status": "ignored"}), 200    task = payload["task"]
    captured = task.get("capturedTexts", {})    # Map Browse AI fields to HubSpot contact properties
    properties = {
        "email": captured.get("email", ""),
        "firstname": captured.get("first_name", ""),
        "lastname": captured.get("last_name", ""),
        "company": captured.get("company_name", ""),
        "website": captured.get("website", ""),
        "jobtitle": captured.get("job_title", ""),
        "phone": captured.get("phone", ""),
        "hs_lead_status": "NEW",
        "browseai_source": f"Robot {task.get('robotId')}"
    }    # Remove empty values
    properties = {k: v for k, v in properties.items() if v}    result, action = create_or_update_hubspot_contact(properties)
    return jsonify({"status": action, "hubspot_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"
HUBSPOT_ACCESS_TOKEN = "your_hubspot_private_app_token"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_hubspot(tasks):
    """Create HubSpot contacts from Browse AI task results."""
    for task in tasks:
        captured = task.get("capturedTexts", {})
        properties = {
            "email": captured.get("email", ""),
            "lastname": captured.get("last_name", ""),
            "company": captured.get("company_name", ""),
            "website": captured.get("website", ""),
            "hs_lead_status": "NEW"
        }
        properties = {k: v for k, v in properties.items() if v}        requests.post(
            "https://api.hubapi.com/crm/v3/objects/contacts",
            headers={
                "Authorization": f"Bearer {HUBSPOT_ACCESS_TOKEN}",
                "Content-Type": "application/json"
            },
            json={"properties": properties}
        )# Run this script on a schedule (e.g. cron job every hour)

# Batch upsert: create or update contacts by email
requests.post(
    "https://api.hubapi.com/crm/v3/objects/contacts/batch/upsert",
    headers={
        "Authorization": f"Bearer {HUBSPOT_ACCESS_TOKEN}",
        "Content-Type": "application/json"
    },
    json={
        "inputs": [
            {
                "idProperty": "email",
                "id": "[email protected]",
                "properties": {
                    "email": "[email protected]",
                    "firstname": "Jane",
                    "lastname": "Doe",
                    "company": "Acme Inc"
                }
            }
        ]
    }
)