Webhook monitoring and alerting metrics, SLOs, incident response

// Worker instrumentation example: structured logs + latency measurement around processing and Ack/Nack
const QUEUE_NEXT_URL =
  process.env.HOOQUE_QUEUE_NEXT_URL ??
  "https://app.hooque.io/queues/cons_webhook_events/next";
const TOKEN = process.env.HOOQUE_TOKEN ?? "hq_tok_replace_me";
const headers = { Authorization: `Bearer ${TOKEN}` };

function log(obj) {
  console.log(JSON.stringify({ ts: new Date().toISOString(), ...obj }));
}

async function processPayload(payload) {
  // TODO: your real work here
  return;
}

while (true) {
  const start = Date.now();
  const resp = await fetch(QUEUE_NEXT_URL, { headers });

  if (resp.status === 204) {
    log({ level: "info", msg: "queue empty" });
    break;
  }
  if (!resp.ok) throw new Error(`Hooque next() failed: ${resp.status}`);

  const payload = await resp.json();
  const meta = JSON.parse(resp.headers.get("X-Hooque-Meta") ?? "{}");

  try {
    await processPayload(payload);
    await fetch(meta.ackUrl, { method: "POST", headers });
    log({ level: "info", msg: "acked", processing_ms: Date.now() - start });
  } catch (err) {
    await fetch(meta.nackUrl, {
      method: "POST",
      headers: { ...headers, "Content-Type": "application/json" },
      body: JSON.stringify({ reason: String(err) }),
    });
    log({ level: "error", msg: "nacked", err: String(err), processing_ms: Date.now() - start });
  }
}

# Worker instrumentation example: structured logs + latency measurement around processing and Ack/Nack
import json
import os
import time
import requests

QUEUE_NEXT_URL = os.getenv(
    "HOOQUE_QUEUE_NEXT_URL",
    "https://app.hooque.io/queues/cons_webhook_events/next",
)
TOKEN = os.getenv("HOOQUE_TOKEN", "hq_tok_replace_me")
headers = {"Authorization": f"Bearer {TOKEN}"}

def log(obj: dict) -> None:
    obj["ts"] = time.strftime("%Y-%m-%dT%H:%M:%SZ", time.gmtime())
    print(json.dumps(obj))

def process_payload(payload: dict) -> None:
    # TODO: your real work here
    return None

while True:
    start = time.time()
    resp = requests.get(QUEUE_NEXT_URL, headers=headers, timeout=30)

    if resp.status_code == 204:
        log({"level": "info", "msg": "queue empty"})
        break
    if resp.status_code >= 400:
        raise RuntimeError(f"Hooque next() failed: {resp.status_code} {resp.text}")

    payload = resp.json()
    meta = json.loads(resp.headers.get("X-Hooque-Meta", "{}"))

    try:
        process_payload(payload)
        requests.post(meta["ackUrl"], headers=headers, timeout=30)
        log({"level": "info", "msg": "acked", "processing_ms": int((time.time() - start) * 1000)})
    except Exception as err:
        requests.post(
            meta["nackUrl"],
            headers={**headers, "Content-Type": "application/json"},
            json={"reason": str(err)},
            timeout=30,
        )
        log({"level": "error", "msg": "nacked", "err": str(err), "processing_ms": int((time.time() - start) * 1000)})