next-connect

import type { NextApiRequest, NextApiResponse } from "next"; import { createRouter } from "next-connect"; // Mock dependencies for a runnable example const getUser = (id: string) => ({ id, name: `User ${id}`, email: `${id}@example.com` }); const updateUser = async (data: any) => ({ ...data, updatedAt: new Date().toISOString() }); class ForbiddenError extends Error { statusCode: number; constructor(message: string) { super(message); this.name = 'ForbiddenError'; this.statusCode = 403; } } const router = createRouter<NextApiRequest, NextApiResponse>(); router .use(async (req, res, next) => { const start = Date.now(); // Simulate authentication or logging console.log(`Incoming request to ${req.url}`); await next(); // call next in chain const end = Date.now(); console.log(`Request to ${req.url} took ${end - start}ms`); }) .get((req, res) => { const { id } = req.query; if (typeof id !== 'string') { res.status(400).json({ message: 'Invalid user ID' }); return; } const user = getUser(id); res.json({ user }); }) .put(async (req, res) => { // Simulate user context (e.g., from session/token) const currentUser = { id: 'currentUserId123' }; // Mock current user const { id } = req.query; if (typeof id !== 'string') { throw new Error('Invalid user ID for update'); } // Example authorization check if (currentUser.id !== id) { throw new ForbiddenError("You can't update other user's profile"); } const updatedUser = await updateUser({ id, ...req.body }); res.json({ user: updatedUser }); }); export default router.handler({ onError: (err, req, res) => { console.error(err.stack); // Log the error for debugging const statusCode = (err as ForbiddenError).statusCode || 500; res.status(statusCode).end(err.message || "Something broke!"); }, onNoMatch: (req, res) => { res.status(404).end(`Route ${req.method} ${req.url} not found`); }, });