import requests
from flask import Flask, request, jsonifyapp = Flask(__name__)# Zoho OAuth credentials
ZOHO_CLIENT_ID = "your_client_id"
ZOHO_CLIENT_SECRET = "your_client_secret"
ZOHO_REFRESH_TOKEN = "your_refresh_token"
ZOHO_ACCOUNTS_URL = "https://accounts.zoho.com"  # Change for your data center
ZOHO_API_URL = "https://www.zohoapis.com/crm/v2"  # Change for your data centerdef get_zoho_access_token():
    """Get a fresh access token using the refresh token."""
    resp = requests.post(f"{ZOHO_ACCOUNTS_URL}/oauth/v2/token", params={
        "refresh_token": ZOHO_REFRESH_TOKEN,
        "client_id": ZOHO_CLIENT_ID,
        "client_secret": ZOHO_CLIENT_SECRET,
        "grant_type": "refresh_token"
    })
    return resp.json()["access_token"]def create_zoho_record(module, data, access_token):
    """Create a record in a Zoho CRM module."""
    resp = requests.post(
        f"{ZOHO_API_URL}/{module}",
        headers={
            "Authorization": f"Zoho-oauthtoken {access_token}",
            "Content-Type": "application/json"
        },
        json={"data": [data]}
    )
    return resp.json()def upsert_zoho_record(module, data, duplicate_check_fields, access_token):
    """Create or update a record using duplicate check fields."""
    resp = requests.post(
        f"{ZOHO_API_URL}/{module}/upsert",
        headers={
            "Authorization": f"Zoho-oauthtoken {access_token}",
            "Content-Type": "application/json"
        },
        json={
            "data": [data],
            "duplicate_check_fields": duplicate_check_fields
        }
    )
    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 Zoho CRM Lead fields
    lead_data = {
        "First_Name": captured.get("first_name", ""),
        "Last_Name": captured.get("last_name", "") or "Unknown",
        "Company": captured.get("company_name", "") or "Unknown",
        "Email": captured.get("email", ""),
        "Phone": captured.get("phone", ""),
        "Website": captured.get("website", ""),
        "Designation": captured.get("job_title", ""),
        "Lead_Source": "Browse AI",
        "Description": f"Auto-imported from Browse AI robot {task.get('robotId')}"
    }    # Remove empty values
    lead_data = {k: v for k, v in lead_data.items() if v}    # Get access token and upsert the lead (deduplicating by email)
    access_token = get_zoho_access_token()
    result = upsert_zoho_record("Leads", lead_data, ["Email"], access_token)    return jsonify({"status": "success", "result": result}), 200if __name__ == "__main__":
    app.run(host="0.0.0.0", port=5000)

# Exchange grant token for access + refresh tokens (run once)
import requestsresp = requests.post("https://accounts.zoho.com/oauth/v2/token", params={
    "code": "YOUR_GRANT_TOKEN",  # From Zoho API Console Self Client
    "client_id": "YOUR_CLIENT_ID",
    "client_secret": "YOUR_CLIENT_SECRET",
    "grant_type": "authorization_code"
})tokens = resp.json()
print(f"Access Token: {tokens['access_token']}")
print(f"Refresh Token: {tokens['refresh_token']}")
# Save the refresh token securely. It does not expire.

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"
ZOHO_REFRESH_TOKEN = "your_refresh_token"
ZOHO_CLIENT_ID = "your_client_id"
ZOHO_CLIENT_SECRET = "your_client_secret"def get_zoho_access_token():
    resp = requests.post("https://accounts.zoho.com/oauth/v2/token", params={
        "refresh_token": ZOHO_REFRESH_TOKEN,
        "client_id": ZOHO_CLIENT_ID,
        "client_secret": ZOHO_CLIENT_SECRET,
        "grant_type": "refresh_token"
    })
    return resp.json()["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_zoho(tasks):
    """Upsert Zoho CRM leads from Browse AI task results."""
    access_token = get_zoho_access_token()
    records = []    for task in tasks:
        captured = task.get("capturedTexts", {})
        records.append({
            "Last_Name": captured.get("last_name", "") or "Unknown",
            "Company": captured.get("company_name", "") or "Unknown",
            "Email": captured.get("email", ""),
            "Phone": captured.get("phone", ""),
            "Lead_Source": "Browse AI"
        })    # Zoho supports batch upsert of up to 100 records per request
    if records:
        requests.post(
            "https://www.zohoapis.com/crm/v2/Leads/upsert",
            headers={
                "Authorization": f"Zoho-oauthtoken {access_token}",
                "Content-Type": "application/json"
            },
            json={
                "data": records,
                "duplicate_check_fields": ["Email"]
            }
        )# Run this script on a schedule (e.g. cron job every hour)

# Upsert: create if new, update if Email matches an existing lead
requests.post(
    "https://www.zohoapis.com/crm/v2/Leads/upsert",
    headers={
        "Authorization": f"Zoho-oauthtoken {access_token}",
        "Content-Type": "application/json"
    },
    json={
        "data": [lead_data],
        "duplicate_check_fields": ["Email"]
    }
)