Refactor domain scheduling and management

app/[domain]/page.tsx

@@ -3,6 +3,7 @@ import type { Metadata } from "next";
 import { notFound, redirect } from "next/navigation";
 import { DomainReportView } from "@/components/domain/domain-report-view";
 import { DomainSsrAnalytics } from "@/components/domain/domain-ssr-analytics";
+import { updateLastAccessed } from "@/lib/db/repos/domains";
 import { normalizeDomainInput } from "@/lib/domain";
 import { toRegistrableDomain } from "@/lib/domain-server";
 import { makeQueryClient } from "@/trpc/query-client";
@@ -11,8 +12,6 @@ import { trpc } from "@/trpc/server";
 import "country-flag-icons/3x2/flags.css";
 import "mapbox-gl/dist/mapbox-gl.css";
 
-export const experimental_ppr = true;
-
 export async function generateMetadata({
   params,
 }: {
@@ -48,6 +47,9 @@ export default async function DomainPage({
     redirect(`/${encodeURIComponent(normalized)}`);
   }
 
+  // Update access timestamp for pruning stale domains (fire-and-forget)
+  updateLastAccessed(normalized).catch(() => {});
+
   // Minimal prefetch: registration only, let sections stream progressively
   const queryClient = makeQueryClient();
   await queryClient.prefetchQuery(

app/api/cron/queue-cleanup/route.ts

@@ -0,0 +1,51 @@
+import { NextResponse } from "next/server";
+import { cleanupOrphanedQueueEntries } from "@/lib/schedule";
+
+export const dynamic = "force-dynamic";
+
+export async function GET(request: Request) {
+  // Verify Vercel cron secret
+  const authHeader = request.headers.get("authorization");
+  const expectedAuth = process.env.CRON_SECRET
+    ? `Bearer ${process.env.CRON_SECRET}`
+    : null;
+
+  if (!expectedAuth) {
+    return NextResponse.json(
+      { error: "CRON_SECRET not configured" },
+      { status: 500 },
+    );
+  }
+
+  if (authHeader !== expectedAuth) {
+    return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
+  }
+
+  try {
+    const startedAt = Date.now();
+    const result = await cleanupOrphanedQueueEntries();
+
+    console.info(
+      `[queue-cleanup] ok removed=${result.removed} checked=${result.checked} ${Date.now() - startedAt}ms`,
+    );
+
+    return NextResponse.json({
+      success: true,
+      removed: result.removed,
+      checked: result.checked,
+      durationMs: Date.now() - startedAt,
+    });
+  } catch (err) {
+    console.error(
+      "[queue-cleanup] cron failed",
+      err instanceof Error ? err : new Error(String(err)),
+    );
+    return NextResponse.json(
+      {
+        error: "Internal error",
+        message: err instanceof Error ? err.message : "unknown",
+      },
+      { status: 500 },
+    );
+  }
+}

drizzle/0004_flat_masque.sql

@@ -0,0 +1,3 @@
+ALTER TABLE "domains" ADD COLUMN "last_accessed_at" timestamp with time zone;--> statement-breakpoint
+ALTER TABLE "domains" ADD COLUMN "change_frequency" integer DEFAULT 0;--> statement-breakpoint
+CREATE INDEX "i_domains_last_accessed" ON "domains" USING btree ("last_accessed_at");