db set up, enroll api built

.bruno/bruno.json

@@ -0,0 +1,10 @@
+{
+  "version": "1",
+  "name": "XIVPlan+DB",
+  "type": "collection",
+  "ignore": [".git"],
+  "presets": {
+    "requestType": "http",
+    "requestUrl": "http://localhost:14014/api"
+  }
+}

.bruno/collection.bru

@@ -0,0 +1,3 @@
+auth {
+  mode: none
+}

.bruno/enroll user.bru

@@ -0,0 +1,24 @@
+meta {
+  name: enroll user
+  type: http
+  seq: 1
+}
+
+post {
+  url: http://localhost:14014/api/enroll
+  body: json
+  auth: inherit
+}
+
+body:json {
+  {
+    "name": "test",
+    "pin": "1234",
+    "email": ""
+  }
+}
+
+settings {
+  encodeUrl: true
+  timeout: 0
+}

config.example.ts

@@ -9,7 +9,7 @@ export const config = {
     port: 3306,
     username: '',
     password: '',
-    name: 'xivplan-db',
+    name: 'xivplan',
   },
 };
 

db/initialize.ts

@@ -22,7 +22,8 @@ await dbClient.execute(`
     email varchar(255) NULL,
     deleteCode varchar(20) NULL,
     PRIMARY KEY (id),
-    UNIQUE KEY users_id_UNIQUE (id)
+    UNIQUE KEY users_id_UNIQUE (id),
+    UNIQUE KEY users_name_UNIQUE (name)
   ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
 `);
 console.log('Table created');

deno.json

@@ -25,6 +25,7 @@
     "@mysql": "https://deno.land/x/mysql@v2.12.1/mod.ts",
     "@nanoid": "https://deno.land/x/nanoid@v3.0.0/mod.ts",
     "@std/http": "jsr:@std/http@1.0.15",
-    "~config": "./config.ts"
+    "~config": "./config.ts",
+    "db/": "./db/"
   }
 }

mod.ts

@@ -3,6 +3,8 @@ import { STATUS_CODE, STATUS_TEXT, StatusCode } from '@std/http';
 
 import config from '~config';
 
+import dbClient from 'db/client.ts';
+
 // Using custom alphabet to exclude - and _
 const alphabet = '0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz';
 const nanoid = customAlphabet(alphabet, 20);
@@ -11,14 +13,41 @@ const genericResponse = (status: StatusCode, customText = '') =>
   new Response(customText || STATUS_TEXT[status], { status: status, statusText: STATUS_TEXT[status] });
 
 Deno.serve({ port: config.api.port }, async (req) => {
-  const [urlPath, tempQ] = req.url.split('?');
-  const path = (urlPath.split('api/')[1] ?? '').toLowerCase().trim();
+  const urlPath = req.url.split('?')[0] ?? '';
+  const path = (urlPath.split('api')[1] ?? '').toLowerCase().trim();
   console.log(urlPath, path);
 
   if (req.method === 'GET') {
     // handle all gets
-  } else if (path === '/auth') {
-    return new Response(nanoid());
+  } else if (req.method === 'POST' && path === '/enroll') {
+    const body = await req.json();
+
+    let readFailure = false;
+    const userNameMatches = await dbClient.query('SELECT name FROM users WHERE name = ?', [body.name]).catch(() => {
+      readFailure = true;
+    });
+    if (readFailure) return genericResponse(STATUS_CODE.InternalServerError, "Couldn't read DB.");
+
+    if (userNameMatches.length === 0) {
+      if (body.name.length < 4 || body.name.length > 20) return genericResponse(STATUS_CODE.BadRequest, `Name too ${body.name.length < 4 ? 'short' : 'long'}.`);
+      if (body.pin.length < 4 || body.pin.length > 20) return genericResponse(STATUS_CODE.BadRequest, `PIN too ${body.pin.length < 4 ? 'short' : 'long'}.`);
+      if (body.email.length > 20) return genericResponse(STATUS_CODE.BadRequest, `Email too long.`);
+
+      const userId = nanoid();
+
+      let writeFailure = false;
+      await dbClient.execute('INSERT INTO users(id,name,pin,email) values(?,?,?,?)', [userId, body.name, body.pin, body.email]).catch(() => {
+        writeFailure = true;
+      });
+
+      if (writeFailure) {
+        return genericResponse(STATUS_CODE.InternalServerError, "Couldn't write DB.");
+      } else {
+        return genericResponse(STATUS_CODE.OK, JSON.stringify({ userId }));
+      }
+    } else {
+      return genericResponse(STATUS_CODE.BadRequest, 'Username Taken.');
+    }
   } else {
     // handle auth then all other shiz
   }