49 lines
1.1 KiB
TypeScript
49 lines
1.1 KiB
TypeScript
|
import { NextResponse } from "next/server";
|
||
|
|
|
||
|
|
import { fetchCache, setCache } from "@/_lib/redis";
|
||
|
|
import { db } from "@/_lib/db";
|
||
|
|
import { votes } from "@/_lib/schema";
|
||
|
|
import { eq } from "drizzle-orm";
|
||
|
|
|
||
|
|
export const runtime = "edge";
|
||
|
|
|
||
|
|
export async function GET(
|
||
|
|
request: Request,
|
||
|
|
{ params }: { params: { roomId: string } }
|
||
|
|
) {
|
||
|
|
if (!params.roomId) {
|
||
|
|
return new NextResponse("RoomId Missing!", {
|
||
|
|
status: 400,
|
||
|
|
statusText: "BAD REQUEST!",
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
const cachedResult = await fetchCache<
|
||
|
|
{
|
||
|
|
id: string;
|
||
|
|
value: string;
|
||
|
|
created_at: Date;
|
||
|
|
userId: string;
|
||
|
|
roomId: string;
|
||
|
|
}[]
|
||
|
|
>(`kv_votes_${params.roomId}`);
|
||
|
|
|
||
|
|
if (cachedResult) {
|
||
|
|
return NextResponse.json(cachedResult, {
|
||
|
|
status: 200,
|
||
|
|
statusText: "SUCCESS!",
|
||
|
|
});
|
||
|
|
} else {
|
||
|
|
const votesByRoomId = await db.query.votes.findMany({
|
||
|
|
where: eq(votes.roomId, params.roomId),
|
||
|
|
});
|
||
|
|
|
||
|
|
await setCache(`kv_votes_${params.roomId}`, votesByRoomId);
|
||
|
|
|
||
|
|
return NextResponse.json(votesByRoomId, {
|
||
|
|
status: 200,
|
||
|
|
statusText: "SUCCESS!",
|
||
|
|
});
|
||
|
|
}
|
||
|
|
}
|