import { z } from 'zod'; import { uuid } from '@/lib/crypto'; import { fetchAccount } from '@/lib/load'; import { getQueryFilters, parseRequest } from '@/lib/request'; import { json, unauthorized } from '@/lib/response'; import { pagingParams, searchParams } from '@/lib/schema'; import { canCreateTeamWebsite, canCreateWebsite } from '@/permissions'; import { createWebsite, getWebsiteCount } from '@/queries/prisma'; import { getAllUserWebsitesIncludingTeamOwner, getUserWebsites } from '@/queries/prisma/website'; const CLOUD_WEBSITE_LIMIT = 3; export async function GET(request: Request) { const schema = z.object({ ...pagingParams, ...searchParams, includeTeams: z.string().optional(), }); const { auth, query, error } = await parseRequest(request, schema); if (error) { return error(); } const userId = auth.user.id; const filters = await getQueryFilters(query); if (query.includeTeams) { return json(await getAllUserWebsitesIncludingTeamOwner(userId, filters)); } return json(await getUserWebsites(userId, filters)); } export async function POST(request: Request) { const schema = z.object({ name: z.string().max(100), domain: z.string().max(500), teamId: z.uuid().nullable().optional(), id: z.uuid().nullable().optional(), }); const { auth, body, error } = await parseRequest(request, schema); if (error) { return error(); } const { id, name, domain, teamId } = body; if (process.env.CLOUD_MODE && !teamId) { const account = await fetchAccount(auth.user.id); if (!account?.hasSubscription) { const count = await getWebsiteCount(auth.user.id); if (count >= CLOUD_WEBSITE_LIMIT) { return unauthorized({ message: 'Website limit reached.' }); } } } if ((teamId && !(await canCreateTeamWebsite(auth, teamId))) || !(await canCreateWebsite(auth))) { return unauthorized(); } const data: any = { id: id ?? uuid(), createdBy: auth.user.id, name, domain, teamId, }; if (!teamId) { data.userId = auth.user.id; } const website = await createWebsite(data); return json(website); }