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 { 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 { 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
  }
}