Brand directories

directory.js

const base = 'https://new.wasmenia.com';/** One page of a directory: Saudi brands with an SVG logo, newest first. */export async function directoryPage(page = 1) {  const url = new URL('/api/v1/brands', base);  url.searchParams.set('country', 'SA');  url.searchParams.set('has', 'svg');  url.searchParams.set('limit', '24'); // up to 50  url.searchParams.set('page', String(page));  const res = await fetch(url, {    headers: { Authorization: `Bearer ${process.env.WASMENIA_API_KEY}` },  });  if (!res.ok) throw new Error(`HTTP ${res.status}`);  const { total, pageCount, items } = await res.json();  // pageCount is 0 when nothing matches.  return { total, pageCount, items };}

refresh.js

// Once a day: re-read what changed since the last run, newest change first.const base = 'https://new.wasmenia.com';const headers = { Authorization: `Bearer ${process.env.WASMENIA_API_KEY}` };export async function refresh(since /* Date of the last run */) {  for (let page = 1; page <= 500; page++) {    const list = await fetch(`${base}/api/v1/brands?sort=updated&limit=50&page=${page}`, { headers });    if (!list.ok) throw new Error(`HTTP ${list.status}`);    const { items, pageCount } = await list.json();    for (const card of items) {      if (!(await db.records.has(card.slug))) continue; // never opened: nothing to refresh      const res = await fetch(`${base}/api/v1/brands/${card.slug}`, { headers }); // a pull      if (res.status === 402) return; // the month's pulls are used: try after X-Quota-Reset      if (res.status === 404) { await db.records.delete(card.slug); continue; }      if (!res.ok) throw new Error(`HTTP ${res.status}`);      const brand = await res.json();      // A renamed brand answers under its new slug (308, followed by fetch).      if (brand.slug !== card.slug) await db.records.rename(card.slug, brand.slug);      await db.records.put(brand.slug, brand);      if (new Date(brand.updatedAt) < since) return; // older than the last run: done    }    if (page >= pageCount) return;  }}