Webhooks

(async () => {
  const url = "https://api.edenai.run/v3/universal-ai/async";
  const headers = {
    Authorization: "Bearer YOUR_API_KEY",
    "Content-Type": "application/json",
  };
  const payload = {
    model: "ocr/ocr_async/amazon",
    input: { file: "YOUR_FILE_UUID_OR_URL" },
    webhook_receiver: "https://your-server.com/webhooks/edenai",
    user_webhook_parameters: { internal_ref: "order-42" },
  };
  const response = await fetch(url, {
    method: "POST",
    headers,
    body: JSON.stringify(payload),
  });
  console.log(await response.json()); // Contains the job ID
})();

const express = require("express");
const crypto = require("crypto");
const stringify = require("safe-stable-stringify");
const fs = require("fs");

const app = express();
const EDENAI_PUBLIC_KEY = fs.readFileSync("edenai_webhook_rsa.pub.pem", "utf8");

function verifySignature(rawBody, signatureHex) {
  const payload = JSON.parse(rawBody.toString("utf8"));
  const canonical = stringify(payload, null, 2); // sorted keys + 2-space indent
  const hashHex = crypto.createHash("sha256").update(canonical, "utf8").digest("hex");
  const verifier = crypto.createVerify("RSA-SHA256");
  verifier.update(hashHex, "utf8");
  verifier.end();
  try {
    return verifier.verify(EDENAI_PUBLIC_KEY, Buffer.from(signatureHex, "hex"));
  } catch {
    return false;
  }
}

app.use("/webhooks/edenai", express.raw({ type: "application/json" }));

app.post("/webhooks/edenai", (req, res) => {
  const signature = req.header("X-Edenai-Signature") || "";
  if (!verifySignature(req.body, signature)) {
    return res.status(401).send("Invalid Eden AI webhook signature");
  }
  const payload = JSON.parse(req.body.toString("utf8"));
  if (payload.status === "success") {
    console.log(`Job ${payload.job_id} completed:`, payload.output);
  } else {
    console.log(`Job ${payload.job_id} failed: ${payload.error.message}`);
  }
  res.status(200).json({ received: true });
});

app.listen(3000);