import AnchorBrowser from 'anchorbrowser';

const anchor_client = new AnchorBrowser({apiKey: process.env.ANCHOR_API_KEY});

async function signalEvent(eventName, data) {
  try {
    const response = await anchor_client.events.signal(eventName, { data: data || {} });
    return response;
  } catch (error) {
    throw new Error(`Failed to signal event: ${error.message}`);
  }
}

async function waitForEvent(eventName, timeoutMs = 60000) {
  try {
    const response = await anchor_client.events.waitFor(eventName, { timeoutMs });
    return response;
  } catch (error) {
    if (error.message.includes("408")) return null; // Timeout
    throw new Error(`Failed to wait for event: ${error.message}`);
  }
}

import os
from anchorbrowser import Anchorbrowser

anchor_client = Anchorbrowser(api_key=os.getenv("ANCHOR_API_KEY"))

def signal_event(event_name, data):
    try:
        response = anchor_client.events.signal(event_name, data=data or {})
        return response
    except Exception as error:
        raise Exception(f"Failed to signal event: {error}")

def wait_for_event(event_name, timeout_ms=60000):
    try:
        response = anchor_client.events.wait_for(event_name, timeout_ms=timeout_ms)
        return response
    except Exception as error:
        if "408" in str(error):
            return None  # Timeout
        raise Exception(f"Failed to wait for event: {error}")