import requests
from flask import Flask, request, jsonifyapp = Flask(__name__)PIPEDRIVE_API_TOKEN = "your_pipedrive_api_token"
PIPEDRIVE_API_URL = "https://api.pipedrive.com/v1"def create_organization(name):
    """Create an organization in Pipedrive and return its ID."""
    resp = requests.post(
        f"{PIPEDRIVE_API_URL}/organizations",
        params={"api_token": PIPEDRIVE_API_TOKEN},
        json={"name": name}
    )
    data = resp.json()
    if data.get("success"):
        return data["data"]["id"]
    return Nonedef search_person_by_email(email):
    """Search for an existing person by email."""
    resp = requests.get(
        f"{PIPEDRIVE_API_URL}/persons/search",
        params={
            "api_token": PIPEDRIVE_API_TOKEN,
            "term": email,
            "fields": "email"
        }
    )
    data = resp.json()
    items = data.get("data", {}).get("items", [])
    if items:
        return items[0]["item"]["id"]
    return Nonedef create_or_update_person(person_data, existing_id=None):
    """Create a new person or update an existing one."""
    if existing_id:
        resp = requests.put(
            f"{PIPEDRIVE_API_URL}/persons/{existing_id}",
            params={"api_token": PIPEDRIVE_API_TOKEN},
            json=person_data
        )
    else:
        resp = requests.post(
            f"{PIPEDRIVE_API_URL}/persons",
            params={"api_token": PIPEDRIVE_API_TOKEN},
            json=person_data
        )
    return resp.json()@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", {})    # Create organization first (if company name is available)
    org_id = None
    company_name = captured.get("company_name", "")
    if company_name:
        org_id = create_organization(company_name)    # Build person data
    person_data = {
        "name": f"{captured.get('first_name', '')} {captured.get('last_name', '')}".strip() or "Unknown",
        "email": [captured.get("email", "")],
        "phone": [captured.get("phone", "")],
    }
    if org_id:
        person_data["org_id"] = org_id    # Remove empty values from lists
    person_data["email"] = [e for e in person_data["email"] if e]
    person_data["phone"] = [p for p in person_data["phone"] if p]    # Check for existing person by email
    existing_id = None
    if person_data["email"]:
        existing_id = search_person_by_email(person_data["email"][0])    result = create_or_update_person(person_data, existing_id)    action = "updated" if existing_id else "created"
    return jsonify({"status": action, "pipedrive_id": result.get("data", {}).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"
PIPEDRIVE_API_TOKEN = "your_pipedrive_api_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_pipedrive(tasks):
    """Create Pipedrive persons from Browse AI task results."""
    for task in tasks:
        captured = task.get("capturedTexts", {})
        person_data = {
            "name": f"{captured.get('first_name', '')} {captured.get('last_name', '')}".strip() or "Unknown",
            "email": [captured.get("email", "")],
            "phone": [captured.get("phone", "")],
        }
        person_data["email"] = [e for e in person_data["email"] if e]
        person_data["phone"] = [p for p in person_data["phone"] if p]        requests.post(
            "https://api.pipedrive.com/v1/persons",
            params={"api_token": PIPEDRIVE_API_TOKEN},
            json=person_data
        )# Run this script on a schedule (e.g. cron job every hour)

# Search for a person by email before creating
resp = requests.get(
    "https://api.pipedrive.com/v1/persons/search",
    params={
        "api_token": PIPEDRIVE_API_TOKEN,
        "term": "[email protected]",
        "fields": "email"
    }
)
results = resp.json().get("data", {}).get("items", [])
if results:
    # Person exists, update instead of creating
    person_id = results[0]["item"]["id"]

# Create a deal linked to a person and organization
deal_data = {
    "title": f"Browse AI Lead - {captured.get('company_name', 'Unknown')}",
    "person_id": person_id,
    "org_id": org_id,
    "stage_id": 1  # Your pipeline's first stage ID
}requests.post(
    "https://api.pipedrive.com/v1/deals",
    params={"api_token": PIPEDRIVE_API_TOKEN},
    json=deal_data
)