// EXPENSIVE: Staged item reads count against rate limits
const { items } = await webflow.collections.items.listItems(collectionId);

// FREE: CDN-cached live item reads have no rate limits
const { items } = await webflow.collections.items.listItemsLive(collectionId);

// EXPENSIVE: 1000 items = 1000 API calls
for (const item of items) {
  await webflow.collections.items.createItem(collectionId, { fieldData: item });
}

// CHEAP: 1000 items = 10 API calls (100 per batch)
for (let i = 0; i < items.length; i += 100) {
  await webflow.collections.items.createItemsBulk(collectionId, {
    items: items.slice(i, i + 100).map(item => ({ fieldData: item })),
  });
}

import { LRUCache } from "lru-cache";

const schemaCache = new LRUCache<string, any>({
  max: 50,
  ttl: 60 * 60 * 1000, // 1 hour — schemas change very rarely
});

async function getCollectionSchema(siteId: string) {
  const key = `schema:${siteId}`;
  let schema = schemaCache.get(key);

  if (!schema) {
    const { collections } = await webflow.collections.list(siteId);
    schema = collections;
    schemaCache.set(key, schema);
  }

  return schema;
}

class WebflowUsageTracker {
  private calls = new Map<string, number>();
  private startTime = Date.now();

  track(operation: string) {
    const count = this.calls.get(operation) || 0;
    this.calls.set(operation, count + 1);
  }

  getReport() {
    const totalCalls = Array.from(this.calls.values()).reduce((a, b) => a + b, 0);
    const elapsedMinutes = (Date.now() - this.startTime) / 60000;
    const callsPerMinute = totalCalls / elapsedMinutes;

    return {
      totalCalls,
      callsPerMinute: callsPerMinute.toFixed(1),
      byOperation: Object.fromEntries(this.calls),
      topOperations: Array.from(this.calls.entries())
        .sort((a, b) => b[1] - a[1])
        .slice(0, 5),
    };
  }

  reset() {
    this.calls.clear();
    this.startTime = Date.now();
  }
}

const tracker = new WebflowUsageTracker();

// Wrap your client to auto-track
function trackedCall<T>(operation: string, fn: () => Promise<T>): Promise<T> {
  tracker.track(operation);
  return fn();
}

// Usage
const items = await trackedCall("listItemsLive", () =>
  webflow.collections.items.listItemsLive(collectionId)
);

// Periodic report
setInterval(() => {
  console.log("API Usage:", tracker.getReport());
  tracker.reset();
}, 60 * 60 * 1000); // Hourly

// EXPENSIVE: Polling every minute = 1,440 calls/day per collection
setInterval(async () => {
  const { items } = await webflow.collections.items.listItems(collectionId);
  await processChanges(items);
}, 60 * 1000);

// CHEAP: Webhook-driven = only called when something changes
// Register webhook: collection_item_changed
// Your webhook handler:
app.post("/webhooks/webflow", async (req, res) => {
  const event = req.body;
  if (event.triggerType === "collection_item_changed") {
    await processChanges([event.payload]);
  }
  res.status(200).send();
});

// Estimate which plan you need based on usage
function recommendPlan(usage: {
  cmsItems: number;
  monthlyApiCalls: number;
  ecommerceProducts: number;
}) {
  // CMS items determine minimum site plan
  if (usage.cmsItems > 10000) return { site: "Enterprise", reason: "CMS item limit" };
  if (usage.cmsItems > 2000) return { site: "CMS or Business", reason: "CMS item limit" };
  if (usage.cmsItems > 50) return { site: "Basic", reason: "CMS item limit" };

  // High API volume may need higher rate limits
  if (usage.monthlyApiCalls > 100000) return { site: "Business+", reason: "Rate limits" };

  // Ecommerce products
  if (usage.ecommerceProducts > 1000) return { ecommerce: "Advanced", reason: "Product limit" };
  if (usage.ecommerceProducts > 500) return { ecommerce: "Plus", reason: "Product limit" };

  return { site: "Basic", reason: "Sufficient for usage" };
}