use mongodb

src/lib/server/db.ts

@@ -1,31 +1,14 @@
-import knex from "knex";
-import type { Knex } from "knex";
 import { env } from "$env/dynamic/private";
 import { building } from "$app/environment";
+import { MongoClient } from "mongodb";
+import type { Db } from "mongodb";
 
-export let db: Knex;
+export let db: Db;
 
 if (!building) {
-	db = knex({
-		client: "pg",
-		connection: {
-			host: String(env.DB_HOST),
-			port: Number(env.DB_PORT),
-			user: String(env.DB_USERNAME),
-			password: String(env.DB_PASSWORD),
-			database: "website"
-		}
-	})
+	const client = new MongoClient(env.DB_URL);
 
-	if (! await db.schema.hasTable("Announcements")) {
-		await db.schema.createTable("Announcements", (table) => {
-			table.increments("id");
-			table.specificType("title", "varchar").notNullable();
-			table.string("severity").notNullable();
-			table.string("author").notNullable();
-			table.string("link").nullable();
-			table.bigInteger("created").notNullable();
-			table.timestamps(true, true, true);
-		});
-	}
+	await client.connect();
+
+	db = client.db("website");
 }

src/routes/+page.server.ts

@@ -5,7 +5,9 @@ import { db } from "$lib/server/db";
 
 export const load: PageServerLoad = async () => {
 
-	const data = await db("Announcements").select("*");
+	const collection = db.collection("announcements");
+
+	const data = await collection.find({}, { projection: { _id: 0 } }).toArray();
 
 	if (data.length !== 0 || data[0] !== undefined) {
 

src/routes/admin/announcements/+page.server.ts

@@ -4,6 +4,8 @@ import { fail } from "@sveltejs/kit";
 import { db } from "$lib/server/db";
 import dayjs from "dayjs";
 
+const collection = db.collection("announcements");
+
 export const actions: Actions = {
 	add: async ({ request, locals }) => {
 		if (!await locals.getSession()) {
@@ -24,14 +26,12 @@ export const actions: Actions = {
 				const now = Math.floor(Date.now() / 1000);
 				const data = {
 					...Object.fromEntries(formData.entries()),
-					created: now,
-					createdAt: dayjs.unix(now).toISOString(),
-					updatedAt: dayjs.unix(now).toISOString()
+					created: now
 				};
-	
-				await db.delete("*").from("Announcements");
+
+				await collection.deleteMany({});
 		
-				await db("Announcements").insert(data);
+				await collection.insertOne(data);
 		
 				return { addSuccess: true, addMessage: "Your announcement has been posted." };
 			}
@@ -43,7 +43,7 @@ export const actions: Actions = {
 			return fail(401, { deleteError: true, deleteMessage: "You must be logged in to delete an announcement." });
 		} else {
 
-			await db.delete("*").from("Announcements");
+			await collection.deleteMany({});
 
 			return { deleteSuccess: true, deleteMessage: "Your announcement has been deleted." };
 		}