Event triggers

URL="${SKYVERN_TRIGGER_URL:?Set SKYVERN_TRIGGER_URL to the endpoint URL from Studio}"
BODY='{"order":{"id":"ord_123","customer":{"email":"buyer@example.com"}}}'
TS="$(date +%s)"
EVENT_ID="evt_${TS}_$RANDOM"
SIG="$(
  printf 'v1:%s:%s:%s' "$TS" "$EVENT_ID" "$BODY" |
    python3 -c 'import hashlib, hmac, os, sys
print(hmac.new(os.environ["SKYVERN_TRIGGER_SECRET"].encode("utf-8"),
               sys.stdin.buffer.read(), hashlib.sha256).hexdigest())'
)"

curl -sS -X POST "$URL" \
  -H 'Content-Type: application/json' \
  -H "X-Skyvern-Timestamp: $TS" \
  -H "X-Skyvern-Event-Id: $EVENT_ID" \
  -H "X-Skyvern-Signature: v1=$SIG" \
  --data-binary "$BODY"

import hashlib, hmac, json, os, time, urllib.request, uuid

url = os.environ["SKYVERN_TRIGGER_URL"]
body = json.dumps(
    {"order": {"id": "ord_123", "customer": {"email": "buyer@example.com"}}},
    separators=(",", ":"),
).encode("utf-8")
timestamp = str(int(time.time()))
event_id = f"evt_{uuid.uuid4()}"
signature = hmac.new(
    os.environ["SKYVERN_TRIGGER_SECRET"].encode("utf-8"),
    f"v1:{timestamp}:{event_id}:".encode("utf-8") + body,
    hashlib.sha256,
).hexdigest()

request = urllib.request.Request(url, data=body, method="POST", headers={
    "Content-Type": "application/json",
    "X-Skyvern-Timestamp": timestamp,
    "X-Skyvern-Event-Id": event_id,
    "X-Skyvern-Signature": f"v1={signature}",
})
with urllib.request.urlopen(request) as response:
    print(response.status, response.read().decode())

import crypto from "node:crypto";

const url = process.env.SKYVERN_TRIGGER_URL;
const secret = process.env.SKYVERN_TRIGGER_SECRET;
if (!url || !secret) throw new Error("Set SKYVERN_TRIGGER_URL and SKYVERN_TRIGGER_SECRET");

const body = Buffer.from(JSON.stringify({
  order: { id: "ord_123", customer: { email: "buyer@example.com" } },
}), "utf8");
const timestamp = Math.floor(Date.now() / 1000).toString();
const eventId = `evt_${crypto.randomUUID()}`;
const signature = crypto
  .createHmac("sha256", Buffer.from(secret, "utf8"))
  .update(Buffer.from(`v1:${timestamp}:${eventId}:`, "utf8"))
  .update(body)
  .digest("hex");

const response = await fetch(url, {
  method: "POST",
  headers: {
    "Content-Type": "application/json",
    "X-Skyvern-Timestamp": timestamp,
    "X-Skyvern-Event-Id": eventId,
    "X-Skyvern-Signature": `v1=${signature}`,
  },
  body,
});
console.log(response.status, await response.text());