Receive trigger events on a webhook

from engini import Engini

client = Engini(api_key="eng_…")

created = client.triggers.destinations.create(
    "prod", "https://acme.example/hooks/engini", is_default=True
)
save_secret(created.signing_secret)   # esec_… - shown once
destination_id = created.destination.id

import { Engini } from "@engini/sdk";

const client = new Engini({ apiKey: "eng_…" });

const created = await client.triggers.destinations.create({
  name: "prod",
  url: "https://acme.example/hooks/engini",
  isDefault: true,
});
saveSecret(created.signing_secret);   // esec_… - shown once
const destinationId = created.destination.id;

engini triggers destinations add prod https://acme.example/hooks/engini --default --json
# -> {"id": 7, "name": "prod", ..., "secret": "esec_…", "note": "Shown once ..."}

curl -s -X POST "$BASE/triggers/destinations" -H "$AUTH" -H "Content-Type: application/json" \
  -d '{"name": "prod", "url": "https://acme.example/hooks/engini", "is_default": true}' \
  | jq '{id: .destination.id, signing_secret}'

spec = client.triggers.types.get("monday_item_created")   # config_schema, delivery, payload_schema

trigger = client.triggers.create(
    "monday_item_created",
    connection_id=12,
    listen_columns=["status"],
)
client.triggers.enable(trigger.id)

const spec = await client.triggers.types.get("monday_item_created");

const trigger = await client.triggers.create({
  triggerSlug: "monday_item_created",
  connectionId: 12,
  listenColumns: ["status"],
});
await client.triggers.enable(trigger.id);

engini triggers types get monday_item_created
engini triggers create monday_item_created --connection 12 --listen status --json   # -> {"id": "ti_…", ...}
engini triggers enable ti_DG9q7IlQO0MeghC4IEzP19

TRIGGER_ID=$(curl -s -X POST "$BASE/triggers" -H "$AUTH" -H "Content-Type: application/json" \
  -d '{"trigger_slug": "monday_item_created", "connection_id": 12, "listen_columns": ["status"]}' \
  | jq -r '.id')
curl -s -X POST "$BASE/triggers/$TRIGGER_ID/enable" -H "$AUTH" | jq '{id, status, status_reason}'

import os
from flask import Flask, request
from engini import verify_webhook
from engini.errors import EnginiWebhookSignatureError

app = Flask(__name__)
SECRET = os.environ["ENGINI_SIGNING_SECRET"]   # the whole esec_… string

@app.post("/hooks/engini")
def receive():
    try:
        event = verify_webhook(
            request.get_data(),                        # raw bytes
            request.headers.get("X-Engini-Signature"),
            SECRET,
        )
    except EnginiWebhookSignatureError:
        return "", 400      # a 4xx stops retries - right for a forgery

    event_id = request.headers["X-Engini-Event-Id"]
    if not mark_seen(event_id):                     # e.g. INSERT ... ON CONFLICT DO NOTHING
        return "", 200      # a retry of something you already have

    if event.get("test"):
        return "", 200      # a test event from step 4 - nothing to process

    enqueue(event)          # hand off; do the slow work elsewhere
    return "", 200

import express from "express";
import { verifyWebhook, EnginiWebhookSignatureError } from "@engini/sdk";

const app = express();
const SECRET = process.env.ENGINI_SIGNING_SECRET!;   // the whole esec_… string

// express.raw, not express.json: verification needs the exact bytes.
app.post("/hooks/engini", express.raw({ type: "*/*" }), async (req, res) => {
  let event;
  try {
    event = verifyWebhook(req.body, req.header("X-Engini-Signature"), SECRET);
  } catch (err) {
    if (err instanceof EnginiWebhookSignatureError) return res.sendStatus(400);
    throw err;
  }

  const eventId = req.header("X-Engini-Event-Id")!;
  if (!(await markSeen(eventId))) return res.sendStatus(200);   // already processed

  if ((event as { test?: boolean }).test) return res.sendStatus(200);

  await enqueue(event);   // hand off; do the slow work elsewhere
  res.sendStatus(200);
});

app.listen(8080);