Function withAutoragCache

src/api/utils/cache.ts:371–407

(
  pipeline: string,
  searchRequest: unknown,
  ctx: { waitUntil: (p: Promise<unknown>) => void },
  fetcher: () => Promise<T>,
)

 * so any change to query / filters / ranking options invalidates automatically.
 */
export async function withAutoragCache<T>(
  pipeline: string,
  searchRequest: unknown,
  ctx: { waitUntil: (p: Promise<unknown>) => void },
  fetcher: () => Promise<T>,
): Promise<T> {
  const keyHash = await sha256Hex(
    JSON.stringify({ pipeline, request: searchRequest }),
  );
  const cacheRequest = buildAutoragCacheRequest(pipeline, keyHash);
  const cache = caches.default;

  try {
    const cached = await cache.match(cacheRequest);
    if (cached) {
      return (await cached.json()) as T;
    }
  } catch (error) {
    console.warn("AutoRAG cache lookup failed:", error);
  }

  const answer = await fetcher();

  try {
    const response = new Response(JSON.stringify(answer), {
      headers: {
        "Content-Type": "application/json",
        "Cache-Control": `public, max-age=${AUTORAG_CACHE_TTL}`,
      },
    });
    ctx.waitUntil(cache.put(cacheRequest, response));
  } catch (error) {
    console.warn("AutoRAG cache write failed:", error);
  }

  return answer;
}