Idempotency

import { randomUUID } from "crypto";

function generateIdempotencyKey(): string {
  // UUID v4 is 36 characters and uses only allowed symbols
  return randomUUID();
}

async function submitVerification(payload: object) {
  const key = generateIdempotencyKey();

  // Persist key before calling the API so you can retry after a crash
  await db.save({ key, status: "pending", payload });

  const res = await fetch("https://masterid.me/api/public/v1/verifications", {
    method: "POST",
    headers: {
      "X-API-Key": process.env.MASTERID_API_KEY!,
      "X-API-Secret": process.env.MASTERID_API_SECRET!,
      "Content-Type": "application/json",
      "Idempotency-Key": key,
    },
    body: JSON.stringify(payload),
  });

  const body = await res.json();

  if (res.ok) {
    await db.update(key, {
      status: body.status === 202 ? "processing" : "completed",
      sessionId: body.data?.sessionId,
    });
  }

  return { res, body, key };
}

// Retry later using the same key and body
async function retryVerification(key: string) {
  const record = await db.find(key);
  if (!record) throw new Error("Unknown key");
  return submitVerificationWithKey(record.payload, key);
}

async function submitVerificationWithKey(payload: object, key: string) {
  const res = await fetch("https://masterid.me/api/public/v1/verifications", {
    method: "POST",
    headers: {
      "X-API-Key": process.env.MASTERID_API_KEY!,
      "X-API-Secret": process.env.MASTERID_API_SECRET!,
      "Content-Type": "application/json",
      "Idempotency-Key": key,
    },
    body: JSON.stringify(payload),
  });
  const body = await res.json();
  return { res, body, key };
}

import os
import uuid
import json
import requests

BASE_URL = "https://masterid.me/api/public/v1"


def generate_idempotency_key() -> str:
    # UUID4 is 36 characters and uses only allowed symbols
    return str(uuid.uuid4())


def submit_verification(payload: dict):
    key = generate_idempotency_key()

    # Persist key before calling the API so you can retry after a crash
    db.save({"key": key, "status": "pending", "payload": payload})

    headers = {
        "X-API-Key": os.environ["MASTERID_API_KEY"],
        "X-API-Secret": os.environ["MASTERID_API_SECRET"],
        "Content-Type": "application/json",
        "Idempotency-Key": key,
    }

    res = requests.post(
        f"{BASE_URL}/verifications",
        headers=headers,
        data=json.dumps(payload),
    )
    body = res.json() if res.text else {}

    if res.ok:
        db.update(
            key,
            {
                "status": "processing" if res.status_code == 202 else "completed",
                "session_id": body.get("data", {}).get("sessionId"),
            },
        )

    return res, body, key


def retry_verification(key: str):
    record = db.find(key)
    if not record:
        raise ValueError("Unknown key")
    return submit_verification_with_key(record["payload"], key)


def submit_verification_with_key(payload: dict, key: str):
    headers = {
        "X-API-Key": os.environ["MASTERID_API_KEY"],
        "X-API-Secret": os.environ["MASTERID_API_SECRET"],
        "Content-Type": "application/json",
        "Idempotency-Key": key,
    }
    res = requests.post(
        f"{BASE_URL}/verifications",
        headers=headers,
        data=json.dumps(payload),
    )
    body = res.json() if res.text else {}
    return res, body, key