Webhooks

# pip install standardwebhooks flask
import logging
import os
import threading

from flask import Flask, abort, request
from standardwebhooks import Webhook

log = logging.getLogger(__name__)
app = Flask(__name__)
wh = Webhook(os.environ["SOUNDPIECE_WEBHOOK_SECRET"])
seen_webhook_ids = set()  # in production, keep these in your database


@app.post("/webhooks/soundpiece")
def handle():
    try:
        payload = wh.verify(request.get_data(), request.headers)
    except Exception:
        abort(403)

    webhook_id = request.headers["webhook-id"]  # retries reuse the same id
    if webhook_id not in seen_webhook_ids:
        seen_webhook_ids.add(webhook_id)
        # Process in the background (or hand it to your job queue) so we answer in time.
        threading.Thread(target=handle_result, args=(payload,)).start()
    return "", 200


def handle_result(payload):
    (op,) = payload.values()  # the same object you'd poll, e.g. payload["song"]
    if op["status"] == "ready":
        outputs = op.get("outputs") or [op["output"]]  # a list, or a single output
        for output in outputs:
            ...  # download from output["url"] promptly; it expires at output["expires_at"]
    else:
        log.error("soundpiece operation %s failed: %s", op["id"], op["error"])

// npm install standardwebhooks express
import express from "express";
import { Webhook } from "standardwebhooks";

const app = express();
app.use(express.raw({ type: "application/json" }));
const wh = new Webhook(process.env.SOUNDPIECE_WEBHOOK_SECRET);
const seenWebhookIds = new Set(); // in production, keep these in your database

app.post("/webhooks/soundpiece", (req, res) => {
  let payload;
  try {
    payload = wh.verify(req.body, req.headers);
  } catch {
    return res.status(403).end();
  }
  res.status(200).end(); // answer first, then do the work

  const webhookId = req.headers["webhook-id"]; // retries reuse the same id
  if (seenWebhookIds.has(webhookId)) return;
  seenWebhookIds.add(webhookId);
  handleResult(payload).catch((error) => console.error("webhook processing failed:", error));
});

async function handleResult(payload) {
  const [op] = Object.values(payload); // the same object you'd poll, e.g. payload.song
  if (op.status === "ready") {
    const outputs = op.outputs ?? [op.output]; // a list, or a single output
    for (const output of outputs) {
      // download from output.url promptly; it expires at output.expires_at
    }
  } else {
    console.error(`soundpiece operation ${op.id} failed:`, op.error);
  }
}

app.listen(3000);