import requests
from flask import Flask, request, jsonifyapp = Flask(__name__)ATTIO_ACCESS_TOKEN = "your_attio_access_token"
ATTIO_API_URL = "https://api.attio.com/v2"def assert_person(person_data):
    """Create or find a Person record in Attio (upsert by email)."""
    resp = requests.put(
        f"{ATTIO_API_URL}/objects/people/records",
        headers={
            "Authorization": f"Bearer {ATTIO_ACCESS_TOKEN}",
            "Content-Type": "application/json"
        },
        json={
            "data": {
                "values": person_data
            },
            "matching_attribute": "email_addresses"
        }
    )
    return resp.json()def assert_company(company_data):
    """Create or find a Company record in Attio (upsert by domain)."""
    resp = requests.put(
        f"{ATTIO_API_URL}/objects/companies/records",
        headers={
            "Authorization": f"Bearer {ATTIO_ACCESS_TOKEN}",
            "Content-Type": "application/json"
        },
        json={
            "data": {
                "values": company_data
            },
            "matching_attribute": "domains"
        }
    )
    return resp.json()@app.route("/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", {})    results = {}    # Create or find the company first (if we have domain/name)
    website = captured.get("website", "")
    company_name = captured.get("company_name", "")
    if website or company_name:
        company_data = {}
        if company_name:
            company_data["name"] = [{"value": company_name}]
        if website:
            # Extract domain from URL
            domain = website.replace("https://", "").replace("http://", "").split("/")[0]
            company_data["domains"] = [{"domain": domain}]
        results["company"] = assert_company(company_data)    # Create or find the person
    email = captured.get("email", "")
    if email:
        person_data = {
            "email_addresses": [{"email_address": email}]
        }
        first_name = captured.get("first_name", "")
        last_name = captured.get("last_name", "")
        if first_name or last_name:
            person_data["name"] = [{"first_name": first_name, "last_name": last_name}]
        if captured.get("phone"):
            person_data["phone_numbers"] = [{"phone_number": captured["phone"]}]
        if captured.get("job_title"):
            person_data["job_title"] = [{"value": captured["job_title"]}]        results["person"] = assert_person(person_data)    return jsonify({"status": "success", "results": results}), 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"
ATTIO_ACCESS_TOKEN = "your_attio_access_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_attio(tasks):
    """Assert Person records in Attio from Browse AI task results."""
    for task in tasks:
        captured = task.get("capturedTexts", {})
        email = captured.get("email", "")
        if not email:
            continue        person_data = {
            "email_addresses": [{"email_address": email}],
            "name": [{"first_name": captured.get("first_name", ""),
                      "last_name": captured.get("last_name", "")}]
        }        requests.put(
            "https://api.attio.com/v2/objects/people/records",
            headers={
                "Authorization": f"Bearer {ATTIO_ACCESS_TOKEN}",
                "Content-Type": "application/json"
            },
            json={
                "data": {"values": person_data},
                "matching_attribute": "email_addresses"
            }
        )# Run this script on a schedule (e.g. cron job every hour)