// Simple Cloudflare Worker that uses the Cache API
export default {
  async fetch(request, env, ctx) {
    const url = new URL(request.url);
    const cache = caches.default;

    // PUT an item in the cache
    if (url.pathname === "/cache-put") {
      const key = url.searchParams.get("key");
      const value = url.searchParams.get("value");

      if (!key || !value) {
        return new Response("Missing key or value query param", { status: 400 });
      }

      // Create a cache key URL and response to store
      const cacheKey = new Request(`http://cache/${key}`);
      const cacheResponse = new Response(value, {
        headers: { "Cache-Control": "max-age=3600" },
      });

      await cache.put(cacheKey, cacheResponse);
      return new Response(`Cached "${key}" = "${value}"`);
    }

    // GET an item from the cache
    if (url.pathname === "/cache-get") {
      const key = url.searchParams.get("key");

      if (!key) {
        return new Response("Missing key query param", { status: 400 });
      }

      const cacheKey = new Request(`http://cache/${key}`);
      const cachedResponse = await cache.match(cacheKey);

      if (!cachedResponse) {
        return new Response(`Key "${key}" not found in cache`, { status: 404 });
      }

      const value = await cachedResponse.text();
      return new Response(`Found "${key}" = "${value}"`);
    }

    // Default response
    return new Response("Hello from Miniflare Cache Test Worker!");
  },
};

import { Miniflare } from "miniflare";

async function main() {
  console.log("Creating Miniflare instance...\n");

  const mf = new Miniflare({
    modules: true,
    scriptPath: "./src/index.js",
    cache: true, // Enable cache (this is the default)
  });

  try {
    // Test 1: Add items to the cache
    console.log("=== Step 1: Adding items to cache ===");

    const put1 = await mf.dispatchFetch(
      "http://localhost/cache-put?key=greeting&value=hello"
    );
    console.log("PUT greeting:", await put1.text());

    const put2 = await mf.dispatchFetch(
      "http://localhost/cache-put?key=name&value=world"
    );
    console.log("PUT name:", await put2.text());

    const put3 = await mf.dispatchFetch(
      "http://localhost/cache-put?key=number&value=42"
    );
    console.log("PUT number:", await put3.text());

    // Test 2: Verify items are in the cache
    console.log("\n=== Step 2: Verifying items are cached ===");

    const get1 = await mf.dispatchFetch(
      "http://localhost/cache-get?key=greeting"
    );
    console.log("GET greeting:", await get1.text(), `(status: ${get1.status})`);

    const get2 = await mf.dispatchFetch("http://localhost/cache-get?key=name");
    console.log("GET name:", await get2.text(), `(status: ${get2.status})`);

    const get3 = await mf.dispatchFetch(
      "http://localhost/cache-get?key=number"
    );
    console.log("GET number:", await get3.text(), `(status: ${get3.status})`);

    // Test 3: Purge the cache
    console.log("\n=== Step 3: Calling mf.purgeCache() ===");

    const purgedCount = await mf.purgeCache();
    console.log(`purgeCache() returned: ${purgedCount} entries purged`);

    // Test 4: Verify cache is now empty
    console.log("\n=== Step 4: Verifying cache is empty after purge ===");

    const getAfter1 = await mf.dispatchFetch(
      "http://localhost/cache-get?key=greeting"
    );
    console.log(
      "GET greeting after purge:",
      await getAfter1.text(),
      `(status: ${getAfter1.status})`
    );

    const getAfter2 = await mf.dispatchFetch(
      "http://localhost/cache-get?key=name"
    );
    console.log(
      "GET name after purge:",
      await getAfter2.text(),
      `(status: ${getAfter2.status})`
    );

    const getAfter3 = await mf.dispatchFetch(
      "http://localhost/cache-get?key=number"
    );
    console.log(
      "GET number after purge:",
      await getAfter3.text(),
      `(status: ${getAfter3.status})`
    );

    // Summary
    console.log("\n=== Summary ===");
    if (
      getAfter1.status === 404 &&
      getAfter2.status === 404 &&
      getAfter3.status === 404
    ) {
      console.log("SUCCESS: All cache entries were purged!");
    } else {
      console.log("FAILURE: Some cache entries still exist after purge");
    }
  } finally {
    // Clean up
    console.log("\nDisposing Miniflare instance...");
    await mf.dispose();
  }
}

main().catch((err) => {
  console.error("Test failed:", err);
  process.exit(1);
});