Forward webhooks to AI agents & CLIs

// Stream webhooks anywhere instantly using Server-Sent Events (SSE)
const HOOQUE_URL = process.env.HOOQUE_URL; // e.g. https://app.hooque.io/queues/cons_agent_webhooks
const TOKEN = process.env.HOOQUE_TOKEN;
const headers = { Authorization: `Bearer ${TOKEN}` };

// Connect an outbound stream — no open ports or tunnels needed!
const streamResp = await fetch(HOOQUE_URL + "/stream", { headers });

for await (const line of readSseLines(streamResp.body)) {
  if (!line.startsWith("data:")) continue;

  const event = JSON.parse(line.slice(5)); // { payload, meta }
  const payload = event.payload;
  const meta = event.meta;

  try {
    // Process the event in your agent script or notebook
    await process_webhook(payload); 
    
    // Ack to remove it from the queue
    await fetch(meta.ackUrl, { method: "POST", headers });
  } catch (err) {
    // Nack to retry later if the script crashes
    await fetch(meta.nackUrl, {
      method: "POST",
      headers: { ...headers, "Content-Type": "application/json" },
      body: JSON.stringify({ reason: String(err) }),
    });
  }
}