import { client, Events } from 'anchorbrowser';

client.setConfig({ auth: () => process.env.ANCHOR_API_KEY });

async function signalEvent(eventName, data) {
  try {
    const response = await Events.signalEvent({
      path: { event_name: eventName },
      body: { 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 Events.waitForEvent({
      path: { event_name: eventName },
      body: { 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(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(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}")