Building & syncing a product catalog

import { CheckoutIntents } from "checkout-intents";
import express from "express";
import { upsertProduct, deleteProduct } from "./catalog";

const app = express();
const client = new CheckoutIntents();
const WEBHOOK_SECRET = process.env.RYE_HMAC_SECRET_KEY!;

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

app.post("/webhook", (req, res) => {
  const signatureHeader = req.headers["x-rye-signature"] as string;
  if (!signatureHeader) return res.status(401).send("Unauthorized");

  const event = client.events.unwrap(
    req.body.toString(),
    signatureHeader,
    WEBHOOK_SECRET,
  );

  // Handle the verification challenge during endpoint setup
  if (event.type === "webhook_endpoint.verification_challenge") {
    return res.json({ challenge: event.source.id });
  }

  // Acknowledge immediately, then process in the background
  res.status(200).send("OK");

  switch (event.type) {
    case "product.updated":
      // `data` is a full Product snapshot — write it straight to your DB
      void upsertProduct(event.data);
      break;
    case "product.removed":
      // No `data` — the product is gone. Remove it by id.
      void deleteProduct(event.source.id);
      break;
  }
});

app.listen(3000, () => console.log("Listening on port 3000"));

import os
from flask import Flask, request, jsonify
from checkout_intents import CheckoutIntents
from catalog import upsert_product, delete_product

app = Flask(__name__)
client = CheckoutIntents()
WEBHOOK_SECRET = os.environ["RYE_HMAC_SECRET_KEY"]


@app.route("/webhook", methods=["POST"])
def webhook():
    signature_header = request.headers.get("x-rye-signature")
    if not signature_header:
        return "Unauthorized", 401

    event = client.events.unwrap(
        request.get_data(), signature_header, WEBHOOK_SECRET
    )

    # Handle the verification challenge during endpoint setup
    if event.type == "webhook_endpoint.verification_challenge":
        return jsonify({"challenge": event.source.id})

    if event.type == "product.updated":
        # `data` is a full Product snapshot — write it straight to your DB
        upsert_product(event.data)
    elif event.type == "product.removed":
        # No `data` — the product is gone. Remove it by id.
        delete_product(event.source.id)

    return "OK", 200

import { CheckoutIntents } from "checkout-intents";
import { upsertProduct } from "./catalog";

const client = new CheckoutIntents({ apiKey: process.env.RYE_API_KEY });

const PRODUCT_URLS = [
  "https://flybyjing.com/products/saucetrio",
  // ...the URLs you collected from the Catalog tab
];

for (const url of PRODUCT_URLS) {
  const product = await client.products.lookup({ url });
  await upsertProduct(product);
  console.log(`Backfilled ${product.name}`);
}

import os
from checkout_intents import CheckoutIntents
from catalog import upsert_product

client = CheckoutIntents(api_key=os.environ["RYE_API_KEY"])

PRODUCT_URLS = [
    "https://flybyjing.com/products/saucetrio",
    # ...the URLs you collected from the Catalog tab
]

for url in PRODUCT_URLS:
    product = client.products.lookup(url=url)
    upsert_product(product)
    print(f"Backfilled {product.name}")

import { CheckoutIntents } from "checkout-intents";
import { allProducts, upsertProduct, deleteProduct } from "./catalog";

const client = new CheckoutIntents({ apiKey: process.env.RYE_API_KEY });

// Schedule this to run once per 24h (e.g. node-cron "0 3 * * *").
export async function reconcileCatalog() {
  for (const { id, url } of await allProducts()) {
    try {
      const product = await client.products.lookup({ url });
      await upsertProduct(product);
    } catch (err) {
      if (err instanceof CheckoutIntents.NotFoundError) {
        // Product no longer exists in Rye's catalog — drop it.
        await deleteProduct(id);
      } else {
        throw err; // transient error — let it retry next run
      }
    }
    await new Promise((r) => setTimeout(r, 100)); // ~10 req/s rate limit
  }
}

import os
import time
from checkout_intents import CheckoutIntents
from checkout_intents import NotFoundError
from catalog import all_products, upsert_product, delete_product

client = CheckoutIntents(api_key=os.environ["RYE_API_KEY"])


# Schedule this to run once per 24h (e.g. a cron entry "0 3 * * *").
def reconcile_catalog():
    for product in all_products():
        try:
            fresh = client.products.lookup(url=product["url"])
            upsert_product(fresh)
        except NotFoundError:
            # Product no longer exists in Rye's catalog — drop it.
            delete_product(product["id"])
        time.sleep(0.1)  # ~10 req/s rate limit