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}`);
}
}