Get told when a job closes

curl https://api.jobspipe.dev/v1/monitors \
  -H "Authorization: Bearer jp_live_your_key_here" \
  -H "Content-Type: application/json" \
  -d '{
    "type": "job",
    "ids": ["4464825573", "8739185002", "no-such-job"],
    "webhook_id": "0f8b6c1e-3a52-4d7e-9c41-2b8f7a6d5e30",
    "expires_in_days": 90
  }'

import requests

HEADERS = {"Authorization": "Bearer jp_live_your_key_here"}

monitor = requests.post(
    "https://api.jobspipe.dev/v1/monitors",
    headers=HEADERS,
    json={
        "type": "job",
        "ids": ["4464825573", "8739185002", "no-such-job"],
        "webhook_id": "0f8b6c1e-3a52-4d7e-9c41-2b8f7a6d5e30",
        "expires_in_days": 90,
    },
).json()

for job in monitor["already_closed"]:
    take_down(job["id"])

const headers = {
  Authorization: "Bearer jp_live_your_key_here",
  "Content-Type": "application/json",
};

const monitor = await fetch("https://api.jobspipe.dev/v1/monitors", {
  method: "POST",
  headers,
  body: JSON.stringify({
    type: "job",
    ids: ["4464825573", "8739185002", "no-such-job"],
    webhook_id: "0f8b6c1e-3a52-4d7e-9c41-2b8f7a6d5e30",
    expires_in_days: 90,
  }),
}).then((r) => r.json());

for (const job of monitor.already_closed) takeDown(job.id);

import hashlib, hmac, json, time
from flask import Flask, request, abort

app = Flask(__name__)
SECRET = b"whsec_your_signing_secret"

@app.post("/hooks/jobspipe")
def jobspipe_hook():
    raw = request.get_data()
    ts = request.headers.get("X-JobsPipe-Timestamp", "0")
    sig = request.headers.get("X-JobsPipe-Signature", "")
    expected = hmac.new(SECRET, ts.encode() + b"." + raw, hashlib.sha256).hexdigest()
    if abs(time.time() - int(ts)) > 300 or not hmac.compare_digest(expected, sig):
        abort(401)
    event = json.loads(raw)
    if event["event"] == "job.closed":
        take_down(event["id"])
    return "", 204

import express from "express";
import { createHmac, timingSafeEqual } from "node:crypto";

const app = express();
const SECRET = "whsec_your_signing_secret";

app.post("/hooks/jobspipe", express.raw({ type: "application/json" }), (req, res) => {
  const raw = req.body.toString("utf8");
  const ts = req.get("X-JobsPipe-Timestamp") ?? "0";
  const sig = req.get("X-JobsPipe-Signature") ?? "";
  const expected = createHmac("sha256", SECRET).update(`${ts}.${raw}`).digest("hex");
  const valid =
    Math.abs(Date.now() / 1000 - Number(ts)) <= 300 &&
    expected.length === sig.length &&
    timingSafeEqual(Buffer.from(expected), Buffer.from(sig));
  if (!valid) return res.sendStatus(401);

  const event = JSON.parse(raw);
  if (event.event === "job.closed") takeDown(event.id);
  res.sendStatus(204);
});