clearUserCache.ts

"use server";

import { initContext, cacheKeyForPage } from "@/lib/chatHistory";
import { updateTag } from "next/cache";
import { getPagesList } from "@/lib/docs";
import { isCloudflare } from "@/lib/detectCloudflare";
import { headers } from "next/headers";
import { withServerActionInstrumentation } from "@sentry/nextjs";

export async function clearUserCacheAction() {
  return withServerActionInstrumentation(
    "clearUserCacheAction", // Action name for Sentry
    {
      headers: await headers(), // Connect client and server traces
      recordResponse: true, // Include response data
    },
    async () => {
      const ctx = await initContext();
      if (!ctx.userId) return;

      const pagesList = await getPagesList();
      for (const lang of pagesList) {
        for (const page of lang.pages) {
          updateTag(
            cacheKeyForPage({ lang: lang.id, page: page.slug }, ctx.userId)
          );
        }
      }

      if (isCloudflare()) {
        const cache = await caches.open("chatHistory");
        for (const lang of pagesList) {
          for (const page of lang.pages) {
            await cache.delete(
              cacheKeyForPage({ lang: lang.id, page: page.slug }, ctx.userId)
            );
          }
        }
      }
    }
  );
}