import requestsMONDAY_API_TOKEN = "your_monday_api_token"
MONDAY_API_URL = "https://api.monday.com/v2"# Get your boards and columns
query = '{ boards(limit: 10) { id name columns { id title type } } }'resp = requests.post(
    MONDAY_API_URL,
    headers={
        "Authorization": MONDAY_API_TOKEN,
        "Content-Type": "application/json"
    },
    json={"query": query}
)
print(resp.json())

import requests
import json
from flask import Flask, request, jsonifyapp = Flask(__name__)MONDAY_API_TOKEN = "your_monday_api_token"
MONDAY_API_URL = "https://api.monday.com/v2"
BOARD_ID = "your_crm_board_id"def create_monday_item(item_name, column_values):
    """Create an item on a Monday.com board."""
    column_values_str = json.dumps(json.dumps(column_values))    query = f'''
    mutation {{
        create_item(
            board_id: {BOARD_ID},
            item_name: "{item_name}",
            column_values: {column_values_str}
        ) {{
            id
        }}
    }}
    '''    resp = requests.post(
        MONDAY_API_URL,
        headers={
            "Authorization": MONDAY_API_TOKEN,
            "Content-Type": "application/json"
        },
        json={"query": query}
    )
    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", {})    # Item name (the main row label)
    item_name = captured.get("company_name", "") or captured.get("last_name", "New Lead")    # Map Browse AI fields to Monday column values
    # Column IDs depend on your board setup (see Step 2)
    column_values = {
        "email": {"email": captured.get("email", ""), "text": captured.get("email", "")},
        "phone": {"phone": captured.get("phone", ""), "countryShortName": "US"},
        "text0": captured.get("first_name", "") + " " + captured.get("last_name", ""),
        "text1": captured.get("job_title", ""),
        "link": {"url": captured.get("website", ""), "text": captured.get("website", "")}
    }    # Remove columns with empty values
    column_values = {k: v for k, v in column_values.items()
                     if v and v != {"email": "", "text": ""}}    result = create_monday_item(item_name, column_values)
    return jsonify({"status": "created", "result": result}), 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"
MONDAY_API_TOKEN = "your_monday_api_token"
BOARD_ID = "your_crm_board_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_monday(tasks):
    """Create Monday items from Browse AI task results."""
    for task in tasks:
        captured = task.get("capturedTexts", {})
        item_name = captured.get("company_name", "New Lead")
        column_values = {
            "email": {"email": captured.get("email", ""), "text": captured.get("email", "")},
            "text0": captured.get("first_name", "") + " " + captured.get("last_name", "")
        }
        column_values_str = json.dumps(json.dumps(column_values))        query = f'''mutation {{
            create_item(board_id: {BOARD_ID}, item_name: "{item_name}",
                        column_values: {column_values_str}) {{ id }}
        }}'''        requests.post(
            "https://api.monday.com/v2",
            headers={
                "Authorization": MONDAY_API_TOKEN,
                "Content-Type": "application/json"
            },
            json={"query": query}
        )# Run this script on a schedule (e.g. cron job every hour)

# Search for existing items on the board by column value
search_query = f'''{{
    items_page_by_column_values(
        board_id: {BOARD_ID},
        columns: [{{column_id: "email", column_values: ["{email}"]}}],
        limit: 1
    ) {{
        items {{ id name }}
    }}
}}'''