Beginning campaign UI and WS to get player state.

server/routes/campaign/join/[link].get.ts

@@ -0,0 +1,37 @@
+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`);
+    }
+})

server/routes/ws/campaign/[id].ts

@@ -0,0 +1,22 @@
+export default defineWebSocketHandler({
+    message(peer, message) {
+        
+    },
+    open(peer) {
+        const id = new URL(peer.request.url).pathname.split('/').slice(-1)[0];
+        if(!id) return peer.close();
+        peer.subscribe(`campaigns/${id}`);
+        peer.publish(`campaigns/${id}`, true);
+
+
+    },
+    close(peer, details) {
+        const id = new URL(peer.request.url).pathname.split('/').slice(-1)[0];
+        if(!id) return peer.close();
+        peer.publish(`campaigns/${id}`, false);
+        peer.unsubscribe(`campaigns/${id}`);
+    },
+    error(peer, error) {
+        console.error(error);
+    }
+})