File size: 1,775 Bytes
867b17d |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 |
import { auth } from '@/app/(auth)/auth';
import { getChatById, getVotesByChatId, voteMessage } from '@/lib/db/queries';
import { ChatSDKError } from '@/lib/errors';
export async function GET(request: Request) {
const { searchParams } = new URL(request.url);
const chatId = searchParams.get('chatId');
if (!chatId) {
return new ChatSDKError(
'bad_request:api',
'Parameter chatId is required.',
).toResponse();
}
const session = await auth();
if (!session?.user) {
return new ChatSDKError('unauthorized:vote').toResponse();
}
const chat = await getChatById({ id: chatId });
if (!chat) {
return new ChatSDKError('not_found:chat').toResponse();
}
if (chat.userId !== session.user.id) {
return new ChatSDKError('forbidden:vote').toResponse();
}
const votes = await getVotesByChatId({ id: chatId });
return Response.json(votes, { status: 200 });
}
export async function PATCH(request: Request) {
const {
chatId,
messageId,
type,
}: { chatId: string; messageId: string; type: 'up' | 'down' } =
await request.json();
if (!chatId || !messageId || !type) {
return new ChatSDKError(
'bad_request:api',
'Parameters chatId, messageId, and type are required.',
).toResponse();
}
const session = await auth();
if (!session?.user) {
return new ChatSDKError('unauthorized:vote').toResponse();
}
const chat = await getChatById({ id: chatId });
if (!chat) {
return new ChatSDKError('not_found:vote').toResponse();
}
if (chat.userId !== session.user.id) {
return new ChatSDKError('forbidden:vote').toResponse();
}
await voteMessage({
chatId,
messageId,
type: type,
});
return new Response('Message voted', { status: 200 });
}
|