Next.js Integration

npm install @bext/nextjs
# or
bun add @bext/nextjs

import { revalidateTag, revalidatePath } from "@bext/nextjs";

// In a Server Action or Route Handler
export async function updateProduct(id: string) {
  await db.products.update(id, data);

  // Purge all pages tagged with "products"
  await revalidateTag("products");

  // Or purge a specific path
  await revalidatePath(`/products/${id}`);
}

import { publish } from "@bext/nextjs";

export async function POST(request: Request) {
  const order = await createOrder(request);

  // Push to all subscribers on the "orders" topic
  await publish("orders", {
    id: order.id,
    status: "created",
    total: order.total,
  });

  return Response.json(order);
}

import { kv } from "@bext/nextjs";

// Store a value (TTL in seconds)
await kv.set("user:123:preferences", { theme: "dark", lang: "en" }, 86400);

// Retrieve
const prefs = await kv.get<{ theme: string; lang: string }>("user:123:preferences");

// Delete
await kv.delete("user:123:preferences");

// List keys with prefix
const result = await kv.list({ prefix: "user:123:", limit: 100 });
// result.keys: string[]
// result.cursor?: string (for pagination)

import { queue } from "@bext/nextjs";

// Enqueue a job
await queue.push("email-notifications", {
  to: "user@example.com",
  subject: "Order Confirmed",
  template: "order-confirmation",
  data: { orderId: "abc-123" },
});

// In a worker/cron handler — pull and acknowledge
const message = await queue.pull<{ to: string; template: string }>("email-notifications");
if (message) {
  await sendEmail(message.data);
  await queue.ack("email-notifications", message.id);
}

import { unstable_cache } from "@bext/nextjs";

const getProducts = unstable_cache(
  async (category: string) => {
    return db.products.findMany({ where: { category } });
  },
  ["products-by-category"],
  {
    tags: ["products"],
    revalidate: 3600, // seconds
  }
);

// Use in a Server Component
export default async function ProductsPage({ params }) {
  const products = await getProducts(params.category);
  return <ProductList items={products} />;
}

import { tasks } from "@bext/nextjs";

// Register a task
await tasks.register("daily-report", {
  cron: "0 9 * * 1-5",  // 9 AM weekdays
  command: "https://myapp.com/api/cron/daily-report",
});

// List all tasks
const allTasks = await tasks.list();

// Cancel a task
await tasks.cancel("daily-report");