from client import BrowseAnythingClient

# Initialize client
client = BrowseAnythingClient()

# Create a task with natural language
task = client.create_task("""
    Go to https://news.ycombinator.com
    Extract the top 5 stories with title, points, and URL.
    Return as JSON.
""")

# Wait for completion
result = client.wait_for_completion(task.id)

print(result.result)  # Your extracted data
print(f"Completed in {result.execution_time_ms}ms")

from client import BrowseAnythingClient

client = BrowseAnythingClient(
    api_key="ba_live_xxx",                                    # Or set BROWSE_ANYTHING_API_KEY env var
    base_url="https://platform.browseanything.io/api/v1",     # Default endpoint
    timeout=30                                                 # Request timeout in seconds
)

task = client.create_task(
    prompt="Your instructions here",
    metadata={"custom": "data"},   # Optional: attach metadata
    proxy_location="us",           # Optional: us, eu, etc.
    max_steps=50                   # Optional: limit agent steps
)

# Get current status
task = client.get_task(task_id)

# Possible statuses:
# - TaskStatus.PENDING
# - TaskStatus.RUNNING
# - TaskStatus.WAITING_FOR_INPUT
# - TaskStatus.COMPLETED
# - TaskStatus.FAILED
# - TaskStatus.CANCELLED

result = client.wait_for_completion(
    task_id,
    poll_interval=2.0,    # Check every 2 seconds
    timeout=300,          # Max 5 minutes
    on_status_change=lambda t: print(f"Status: {t.status}")
)

# Get screenshot as bytes
screenshot_bytes = client.get_screenshot(task_id)

# Save to file
with open("screenshot.png", "wb") as f:
    f.write(screenshot_bytes)

task = client.get_task(task_id)

if task.status == TaskStatus.WAITING_FOR_INPUT:
    print(f"Agent asks: {task.human_input_request}")
    response = input("Your answer: ")
    client.submit_input(task_id, response)

client.cancel_task(task_id)

from client import BrowseAnythingClient, BrowseAnythingError

client = BrowseAnythingClient()

try:
    task = client.create_task("Go to example.com and extract...")
    result = client.wait_for_completion(task.id, timeout=60)
    print(result.result)
except BrowseAnythingError as e:
    print(f"Task failed: {e}")

import concurrent.futures

urls = ["https://site1.com", "https://site2.com", "https://site3.com"]

def process_url(url):
    client = BrowseAnythingClient()
    task = client.create_task(f"Go to {url} and extract the title")
    return client.wait_for_completion(task.id)

# Process in parallel
with concurrent.futures.ThreadPoolExecutor(max_workers=3) as executor:
    results = list(executor.map(process_url, urls))

import time
from client import BrowseAnythingClient

client = BrowseAnythingClient()
last_value = None

while True:
    task = client.create_task("Go to example.com and get the current price")
    result = client.wait_for_completion(task.id)
    
    if result.result != last_value:
        print(f"Change detected! {last_value} -> {result.result}")
        last_value = result.result
    
    time.sleep(300)  # Check every 5 minutes

# Configure via Browse Anything dashboard or API
# Events: task.created, task.completed, task.failed, task.waiting_for_input

# Example Flask handler
@app.route('/webhook', methods=['POST'])
def handle_webhook():
    event = request.json['event']
    task = request.json['task']
    
    if event == 'task.completed':
        process_result(task['result'])
    
    return {'received': True}

# Specific and structured
"""
Go to https://example.com/products
Find the first 5 products in the "Electronics" category.
For each product extract:
- Name
- Price (as number without currency symbol)
- Rating (if available)
Return as a JSON array.
"""

# Clear actions and expectations
"""
1. Go to https://login.example.com
2. Enter username "testuser" in the username field
3. Enter password "testpass" in the password field
4. Click the Login button
5. After login, capture the welcome message shown
"""

# Too vague
"Get stuff from website"

# No structure specified
"Scrape all products"  # What fields? What format?

# Missing context
"Click the blue button"  # Which one? Where?

result = client.wait_for_completion(task_id, timeout=600)  # 10 minutes

import time
for url in urls:
    process(url)
    time.sleep(1)  # 1 second between tasks

task = client.create_task("""
    ...extract data...
    Return only the first 50 results.
    Summarize instead of full content if needed.
""")