admin panel progress

src/app/api/setupDB/route.ts

@@ -0,0 +1,75 @@
+'use server'
+
+import { cookies } from "next/headers";
+
+import { APIError} from "@/util/api/error"
+import { UserAuth, parseBasicAuth, getAssociatedUser } from "@/util/api/user"
+import { Auth, Post, Tag, User } from "@/model/Models";
+import { Project } from "@/model/Project";
+import { DBState } from "@/model/DBState";
+import Sequelize, { DataTypes } from "@sequelize/core";
+import { SqliteColumnsDescription, SqliteDialect } from "@sequelize/sqlite3";
+
+
+async function trySetup(request:Request){
+
+    const sequelize = await new Sequelize({
+        dialect: SqliteDialect,
+        storage: 'db.sqlite'
+    })
+    const queryInterface = sequelize.queryInterface
+    // await User.sync();
+    await Auth.sync();
+    await User.sync();
+    await Project.sync()
+    await Tag.sync();
+    await Post.sync();
+    await DBState.sync();
+
+    const version = await (await DBState.findAll()).sort((a,b)=> ((a.version > b.version) ? 1 : -1)).map(a=>a.version)[0];
+
+    await Project.findOne({where: {
+        readableIdentifier: 'blog'
+    }}).then(e=> e ? e : Project.create({name:'General Blog',readableIdentifier:'blog'}));
+    await User.findOne({where: {
+        username: 'admin'
+    }}).then(e=> e ? e : User.create({username: 'admin', password: 'changeme', perms: {isAdmin: true}}));
+    
+
+    switch(version){
+        case 1:
+            break;
+        default:
+            const postsRows:SqliteColumnsDescription = await queryInterface.describeTable('Posts').then(t=>t);
+            
+            if (!postsRows['project_id']) queryInterface.addColumn('Posts','project_id',{type: DataTypes.INTEGER, acceptsNull:()=>false,defaultValue:1})
+            break;
+    }
+
+    return new Response(
+        JSON.stringify(
+        {
+            test: await queryInterface.describeTable('Posts').then(t=>t)
+        }),
+        { 
+            status: 200, 
+            headers:{
+                "Content-Type": "text/JSON" 
+            } 
+        }
+    ); 
+}
+
+export async function GET(request:Request){
+    try{
+        return await trySetup(request);      
+    }
+    catch(e){
+        if (e instanceof APIError){
+            return new Response(e.info.responseText,{status:e.info.status});
+        }
+        else{
+            throw e;
+        }
+    }
+}