Files
stats/packages/sdks/nextjs/createNextRouteHandler.ts
2025-11-17 21:55:15 +01:00

73 lines
2.0 KiB
TypeScript

import { createHash } from 'node:crypto';
// adding .js next/script import fixes an issues
// with esm and nextjs (when using pages dir)
import { NextResponse } from 'next/server.js';
type CreateNextRouteHandlerOptions = {
apiUrl?: string;
};
export function createNextRouteHandler(
options?: CreateNextRouteHandlerOptions,
) {
return async function POST(req: Request) {
const apiUrl = options?.apiUrl ?? 'https://api.openpanel.dev';
const headers = new Headers();
const ip =
req.headers.get('cf-connecting-ip') ??
req.headers.get('x-forwarded-for')?.split(',')[0] ??
req.headers.get('x-vercel-forwarded-for');
headers.set('Content-Type', 'application/json');
headers.set('User-Agent', req.headers.get('user-agent') ?? '');
if (ip) {
headers.set('openpanel-client-ip', ip);
}
try {
const res = await fetch(`${apiUrl}/track`, {
method: 'POST',
headers,
body: JSON.stringify(await req.json()),
});
return NextResponse.json(await res.text(), { status: res.status });
} catch (e) {
return NextResponse.json(e);
}
};
}
export function createScriptHandler() {
return async function GET(req: Request) {
if (!req.url.endsWith('op1.js')) {
return NextResponse.json({ error: 'Not found' }, { status: 404 });
}
const scriptUrl = 'https://openpanel.dev/op1.js';
try {
const res = await fetch(scriptUrl, {
// @ts-expect-error
next: { revalidate: 86400 },
});
const text = await res.text();
const etag = `"${createHash('md5').update(text).digest('hex')}"`;
return new NextResponse(text, {
headers: {
'Content-Type': 'text/javascript',
'Cache-Control':
'public, max-age=86400, stale-while-revalidate=86400',
ETag: etag,
},
});
} catch (e) {
return NextResponse.json(
{
error: 'Failed to fetch script',
message: e instanceof Error ? e.message : String(e),
},
{ status: 500 },
);
}
};
}