ai_api / src /app /api /cache /entries /route.ts
Yogesh
initial deploy
cd8bd0a
Raw
History Blame Contribute Delete
2.06 kB
import { NextRequest, NextResponse } from "next/server";
import { isAuthenticated } from "@/shared/utils/apiAuth";
import {
listSemanticCacheEntries,
deleteSemanticCacheBySignature,
deleteSemanticCacheByModel,
} from "@/lib/db/semanticCache";
export async function GET(req: NextRequest) {
if (!(await isAuthenticated(req))) {
return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
}
try {
const { searchParams } = new URL(req.url);
const page = Math.max(1, parseInt(searchParams.get("page") || "1", 10));
const limit = Math.min(100, Math.max(1, parseInt(searchParams.get("limit") || "20", 10)));
const search = searchParams.get("search") || "";
const model = searchParams.get("model") || "";
const sortBy = searchParams.get("sortBy") || "created_at";
const sortOrder = searchParams.get("sortOrder") || "desc";
const { entries, total } = listSemanticCacheEntries({ page, limit, search, model, sortBy, sortOrder });
return NextResponse.json({
entries,
pagination: {
page,
limit,
total,
totalPages: Math.ceil(total / limit),
},
});
} catch (error) {
return NextResponse.json({ error: String(error) }, { status: 500 });
}
}
export async function DELETE(req: NextRequest) {
if (!(await isAuthenticated(req))) {
return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
}
try {
const { searchParams } = new URL(req.url);
const signature = searchParams.get("signature");
const model = searchParams.get("model");
if (signature) {
const { deleted } = deleteSemanticCacheBySignature(signature);
return NextResponse.json({ ok: true, deleted });
}
if (model) {
const { deleted } = deleteSemanticCacheByModel(model);
return NextResponse.json({ ok: true, deleted });
}
return NextResponse.json({ error: "Provide signature or model parameter" }, { status: 400 });
} catch (error) {
return NextResponse.json({ error: String(error) }, { status: 500 });
}
}