import requests
from flask import Flask, request, jsonifyapp = Flask(__name__)# Salesforce credentials
SF_CLIENT_ID = "your_consumer_key"
SF_CLIENT_SECRET = "your_consumer_secret"
SF_USERNAME = "your_salesforce_username"
SF_PASSWORD = "your_password_plus_security_token"def get_salesforce_token():
    """Authenticate with Salesforce using OAuth 2.0 password flow."""
    resp = requests.post("https://login.salesforce.com/services/oauth2/token", data={
        "grant_type": "password",
        "client_id": SF_CLIENT_ID,
        "client_secret": SF_CLIENT_SECRET,
        "username": SF_USERNAME,
        "password": SF_PASSWORD
    })
    auth = resp.json()
    return auth["access_token"], auth["instance_url"]def create_salesforce_record(access_token, instance_url, sobject, data):
    """Create a record in Salesforce."""
    resp = requests.post(
        f"{instance_url}/services/data/v62.0/sobjects/{sobject}/",
        headers={
            "Authorization": f"Bearer {access_token}",
            "Content-Type": "application/json"
        },
        json=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", {})    # Map Browse AI fields to Salesforce Lead fields
    lead_data = {
        "FirstName": captured.get("first_name", ""),
        "LastName": captured.get("last_name", "Unknown"),
        "Company": captured.get("company_name", "Unknown"),
        "Email": captured.get("email", ""),
        "Website": captured.get("website", ""),
        "LeadSource": "Browse AI",
        "Description": f"Auto-imported from Browse AI robot {task.get('robotId')}"
    }    # Authenticate and create the Lead
    access_token, instance_url = get_salesforce_token()
    result = create_salesforce_record(access_token, instance_url, "Lead", lead_data)    return jsonify({"status": "created", "salesforce_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
import json
from datetime import datetime, timedeltaBROWSE_AI_API_KEY = "your_browse_ai_api_key"
ROBOT_ID = "your_robot_id"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_salesforce(tasks, access_token, instance_url):
    """Create Salesforce records from Browse AI task results."""
    for task in tasks:
        captured = task.get("capturedTexts", {})
        lead_data = {
            "LastName": captured.get("last_name", "Unknown"),
            "Company": captured.get("company_name", "Unknown"),
            "Email": captured.get("email", ""),
            "LeadSource": "Browse AI"
        }
        requests.post(
            f"{instance_url}/services/data/v62.0/sobjects/Lead/",
            headers={
                "Authorization": f"Bearer {access_token}",
                "Content-Type": "application/json"
            },
            json=lead_data
        )# Run this script on a schedule (e.g. cron job every hour)

# Upsert: create if new, update if the external ID already exists
requests.patch(
    f"{instance_url}/services/data/v62.0/sobjects/Lead/Browse_AI_Task_ID__c/{task_id}",
    headers={
        "Authorization": f"Bearer {access_token}",
        "Content-Type": "application/json"
    },
    json=lead_data
)