Campaign REST API

server/api/campaign/[id]/join.post.ts

@@ -0,0 +1,37 @@
+import { and, eq, sql } from "drizzle-orm";
+import { campaignMembersTable, campaignTable } from "~/db/schema";
+
+export default defineEventHandler(async (e) => {
+    const _id = getRouterParam(e, "id");
+    if(!_id)
+    {
+        setResponseStatus(e, 400);
+        return;
+    }
+    const id = parseInt(_id, 10);
+
+    const session = await getUserSession(e);
+    if(!session || !session.user)
+    {
+        setResponseStatus(e, 401);
+        return;
+    }
+
+    const db = useDatabase();
+    try
+    {
+        const campaign = db.select({ owner: campaignTable.owner }).from(campaignTable).where(and(eq(campaignTable.id, sql.placeholder('id')))).get({ id: id });
+        if(campaign && campaign.owner === session.user.id)      return setResponseStatus(e, 403);
+
+        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 setResponseStatus(e, 403);
+
+        db.insert(campaignMembersTable).values({ id, rights: 'player', user: session.user!.id });
+        
+        return setResponseStatus(e, 200);
+    }
+    catch(_e)
+    {
+        return setResponseStatus(e, 500);
+    }
+});

server/api/campaign/[id]/leave.post.ts

@@ -0,0 +1,35 @@
+import { and, eq, sql } from "drizzle-orm";
+import { campaignMembersTable, campaignTable } from "~/db/schema";
+
+export default defineEventHandler(async (e) => {
+    const id = getRouterParam(e, "id");
+    if(!id)
+    {
+        setResponseStatus(e, 400);
+        return;
+    }
+
+    const session = await getUserSession(e);
+    if(!session || !session.user)
+    {
+        setResponseStatus(e, 401);
+        return;
+    }
+
+    const db = useDatabase();
+    try
+    {
+        const campaign = db.select({ owner: campaignTable.owner }).from(campaignTable).where(and(eq(campaignTable.id, sql.placeholder('id')))).get({ id: parseInt(id, 10) });
+
+        if(campaign && campaign.owner === session.user.id)      return setResponseStatus(e, 403);
+
+        const deleted = db.delete(campaignMembersTable).where(and(eq(campaignMembersTable.id, parseInt(id, 10)), eq(campaignMembersTable.user, session.user.id))).returning({ id: campaignMembersTable.id }).get();
+        
+        if(deleted)     return setResponseStatus(e, 200);
+        else            return setResponseStatus(e, 404);
+    }
+    catch(_e)
+    {
+        return setResponseStatus(e, 500);
+    }
+});