feat: dashboard

.env.example

@@ -1,10 +1,15 @@
 DISCORD_TOKEN='TOKEN'
 DISCORD_TOKEN_DEV='DEV_TOKEN'
+DISCORD_CLIENT_ID='CLIENT_ID'
+DISCORD_CLIENT_SECRET='CLIENT_SECRET'
+WEBSITE_URL='http://localhost:3000'
+NEXT_PUBLIC_API_URL='http://localhost:18103'
 
 MYSQL_ADDRESS='YOUR_MYSQL_SERVER_ADDRESS'
 MYSQL_PORT='YOUR_MYSQL_SERVER_PORT'
 MYSQL_USER='YOUR_MYSQL_USER'
 MYSQL_PASSWORD='YOUR_MYSQL_PASSWORD'
 MYSQL_DATABASE='YOUR_DATABASE_NAME'
 
+JWT_SECRET='YOUR_JWT_SECRET'
 AUTH="AUTH_KEY_FOR_API"

api/package.json

@@ -10,12 +10,14 @@
         "cors": "^2.8.5",
         "cron": "^3.1.7",
         "express": "^4.19.2",
+        "jsonwebtoken": "^9.0.2",
         "mysql2": "^3.10.3"
     },
     "devDependencies": {
         "@types/bun": "latest",
         "@types/cors": "^2.8.17",
         "@types/express": "^4.17.21",
+        "@types/jsonwebtoken": "^9.0.7",
         "dotenv-cli": "^7.4.2"
     }
 }

api/src/db/init.ts

@@ -44,6 +44,17 @@ export async function initTables() {
 			xp INT NOT NULL
 		)
 	`;
+    const createOauthUsersTable = `
+      CREATE TABLE IF NOT EXISTS oauth_users (
+        id VARCHAR(255) NOT NULL PRIMARY KEY,
+        name VARCHAR(255) NOT NULL,
+        username VARCHAR(255) NOT NULL,
+        avatar VARCHAR(255) NOT NULL,
+        access_token VARCHAR(255) NOT NULL,
+        refresh_token VARCHAR(255) NOT NULL,
+        expires_at TIMESTAMP NOT NULL
+      )
+    `;
 
     pool.query(createGuildsTable, (err) => {
         if (err) {
@@ -76,4 +87,12 @@ export async function initTables() {
             console.log("Tracking table created");
         }
     });
+
+    pool.query(createOauthUsersTable, (err) => {
+        if (err) {
+            console.error("Error creating OAuth users table:", err);
+        } else {
+            console.log("OAuth users table created");
+        }
+    });
 }

api/src/db/queries/oauth-users.ts

@@ -0,0 +1,67 @@
+import type { QueryError } from "mysql2";
+
+import { pool } from "..";
+
+export interface OAuthUser {
+    id: string;
+    name: string;
+    username: string;
+    avatar: string;
+    access_token: string;
+    refresh_token: string;
+    expires_at: Date;
+}
+
+export function getOAuthUser(
+    id: string
+): Promise<[QueryError, null] | [null, OAuthUser]> {
+    return new Promise((resolve, reject) => {
+        pool.query(
+            "SELECT * FROM oauth_users WHERE id = ?",
+            [id],
+            (err, results) => {
+                if (err) {
+                    reject([err, null]);
+                } else {
+                    resolve([null, (results as OAuthUser[])[0]]);
+                }
+            }
+        );
+    });
+}
+
+export function updateOAuthUser(
+    oauthUser: Partial<OAuthUser>
+): Promise<[QueryError, false] | [null, true]> {
+    return new Promise((resolve, reject) => {
+        pool.query(
+            `
+			INSERT INTO oauth_users (id, name, username, avatar, access_token, refresh_token, expires_at)
+			VALUES (?, ?, ?, ?, ?, ?, ?)
+			ON DUPLICATE KEY UPDATE
+          name = VALUES(name),
+          username = VALUES(username),
+          avatar = VALUES(avatar),
+          access_token = VALUES(access_token),
+          refresh_token = VALUES(refresh_token),
+          expires_at = VALUES(expires_at)
+			`,
+            [
+                oauthUser.id,
+                oauthUser.name,
+                oauthUser.username,
+                oauthUser.avatar,
+                oauthUser.access_token,
+                oauthUser.refresh_token,
+                oauthUser.expires_at,
+            ],
+            (err) => {
+                if (err) {
+                    reject([err, false]);
+                } else {
+                    resolve([null, true]);
+                }
+            }
+        );
+    });
+}