37 lines
1.6 KiB
TypeScript
37 lines
1.6 KiB
TypeScript
import { and, eq, sql } from "drizzle-orm";
|
|
import useDatabase from "~/composables/useDatabase";
|
|
import { campaignMembersTable, campaignTable } from "~/db/schema";
|
|
import { decryptURI } from "#shared/general.util";
|
|
|
|
export default defineEventHandler(async (e) => {
|
|
const link = getRouterParam(e, "link");
|
|
if(!link) return setResponseStatus(e, 400);
|
|
|
|
const id = decryptURI(decodeURIComponent(link), 'campaign');
|
|
|
|
if(!id) return sendRedirect(e, `/campaign`);
|
|
|
|
const session = await getUserSession(e);
|
|
if(!session || !session.user) return sendRedirect(e, `/user/login`);
|
|
|
|
const db = useDatabase();
|
|
try
|
|
{
|
|
const campaign = db.select({ owner: campaignTable.owner }).from(campaignTable).where(and(eq(campaignTable.id, sql.placeholder('id')), eq(campaignTable.link, sql.placeholder('link')))).get({ id, link: decodeURIComponent(link) });
|
|
|
|
if(!campaign) return setResponseStatus(e, 404);
|
|
if(campaign && campaign.owner === session.user.id) return sendRedirect(e, `/campaign/${id}`);
|
|
|
|
const members = db.select({ id: campaignMembersTable.user }).from(campaignMembersTable).where(and(eq(campaignMembersTable.id, sql.placeholder('id')), eq(campaignMembersTable.user, sql.placeholder('user')))).get({ id: id, user: session.user.id });
|
|
|
|
if(members) return sendRedirect(e, `/campaign/${id}`);
|
|
|
|
db.insert(campaignMembersTable).values({ id, rights: 'player', user: session.user!.id }).run();
|
|
|
|
return sendRedirect(e, `/campaign/${id}`);
|
|
}
|
|
catch(_e)
|
|
{
|
|
return sendRedirect(e, `/campaign`);
|
|
}
|
|
}) |