resolve conflicts manually as gitbutler seems to have issues with conflicts

Author: james-elicx

.changeset/friendly-experts-eat.md

@@ -0,0 +1,5 @@
+---
+"@opennextjs/cloudflare": patch
+---
+
+fix deduplication for memory queue and add some log

.changeset/purple-penguins-hide.md

@@ -0,0 +1,5 @@
+---
+"@opennextjs/cloudflare": patch
+---
+
+feat: add a sharded SQLite Durable object implementation for the tag cache

.changeset/smart-bugs-play.md

@@ -0,0 +1,5 @@
+---
+"@opennextjs/cloudflare": patch
+---
+
+feat: durable object de-duping revalidation queue

.changeset/ten-mice-clean.md

@@ -0,0 +1,5 @@
+---
+"@opennextjs/cloudflare": patch
+---
+
+Implement next mode for d1 tag cache that will reduce write

examples/common/apps.ts

@@ -12,6 +12,9 @@ const apps = [
   "app-pages-router",
   "app-router",
   "pages-router",
+  // overrides
+  "d1-tag-next",
+  "memory-queue",
   // bugs
   "gh-119",
   "gh-219",

examples/common/config-e2e.ts

@@ -13,6 +13,8 @@ export function configurePlaywright(
     isWorker = true,
     // Tests with multiple browsers
     multipleBrowsers = false,
+    // Whether to run tests in single file in parallel
+    parallel = true,
   } = {}
 ) {
   const port = getAppPort(app, { isWorker });
@@ -60,7 +62,7 @@ export function configurePlaywright(
     /* ignore runtime specific tests */
     testIgnore: isWorker ? "*next.spec.ts" : "*cloudflare.spec.ts",
     /* Run tests in files in parallel */
-    fullyParallel: true,
+    fullyParallel: parallel,
     /* Fail the build on CI if you accidentally left test.only in the source code. */
     forbidOnly: isCI,
     /* Retry on CI only */

examples/e2e/app-router/app/methods/get/dynamic-segments/[slug]/route.ts

@@ -0,0 +1,4 @@
+export async function GET(request: Request, { params }: { params: Promise<{ slug: string }> }) {
+  const { slug } = await params;
+  return Response.json({ slug });
+}

examples/e2e/app-router/app/methods/get/query/route.ts

@@ -0,0 +1,10 @@
+import type { NextRequest } from "next/server";
+
+export function GET(request: NextRequest) {
+  const searchParams = request.nextUrl.searchParams;
+  const query = searchParams.get("query");
+  if (query === "OpenNext is awesome!") {
+    return Response.json({ query });
+  }
+  return new Response("Internal Server Error", { status: 500 });
+}

examples/e2e/app-router/app/methods/get/redirect/route.ts

@@ -0,0 +1,5 @@
+import { redirect } from "next/navigation";
+
+export async function GET(request: Request) {
+  redirect("https://nextjs.org/");
+}

examples/e2e/app-router/app/methods/get/revalidate/route.ts

@@ -0,0 +1,10 @@
+export const revalidate = 5;
+
+async function getTime() {
+  return new Date().toISOString();
+}
+
+export async function GET() {
+  const time = await getTime();
+  return Response.json({ time });
+}