Refactored /api/tickets /api/training

src/pages/api/tickets/[id].ts

@@ -1,14 +1,13 @@
 // Next.js API route support: https://nextjs.org/docs/api-routes/introduction
 import type { NextApiRequest, NextApiResponse } from "next";
-import {app} from "@/firebase";
+import client from "@/lib/mongodb";
-import {getFirestore, getDoc, doc, deleteDoc, setDoc} from "firebase/firestore";
 import { withIronSessionApiRoute } from "iron-session/next";
 import { sessionOptions } from "@/lib/session";
 import { Ticket, TicketTypeLabel, TicketStatusLabel } from "@/interfaces/ticket";
 import moment from "moment";
 import { sendEmail } from "@/email";
 
-const db = getFirestore(app);
+const db = client.db(process.env.MONGODB_DB);
 
 export default withIronSessionApiRoute(handler, sessionOptions);
 
@@ -28,10 +27,10 @@ async function get(req: NextApiRequest, res: NextApiResponse) {
 
 	const { id } = req.query as { id: string };
 
-	const snapshot = await getDoc(doc(db, "tickets", id));
+	const snapshot = await db.collection("tickets").findOne({ id: id });
 
-	if (snapshot.exists()) {
+	if (snapshot) {
-		res.status(200).json({...snapshot.data(), id: snapshot.id});
+		res.status(200).json({ ...snapshot });
 	} else {
 		res.status(404).json(undefined);
 	}
@@ -44,13 +43,10 @@ async function del(req: NextApiRequest, res: NextApiResponse) {
 	}
 
 	const { id } = req.query as { id: string };
-
-	const snapshot = await getDoc(doc(db, "tickets", id));
-	const data = snapshot.data() as Ticket;
-
 	const user = req.session.user;
+
 	if (user.type === "admin" || user.type === "developer") {
-		await deleteDoc(snapshot.ref);
+		await db.collection("tickets").deleteOne({ id: id });
 		res.status(200).json({ ok: true });
 		return;
 	}
@@ -67,15 +63,17 @@ async function patch(req: NextApiRequest, res: NextApiResponse) {
 	const { id } = req.query as { id: string };
 	const body = req.body as Ticket;
 
-	const snapshot = await getDoc(doc(db, "tickets", id));
+	const data = await db.collection("tickets").updateOne(
+		{ id: id },
+		{ $set: body },
+		{ upsert: true }
+	);
 
 	const user = req.session.user;
 	if (user.type === "admin" || user.type === "developer") {
-		const data = snapshot.data() as Ticket;
-		await setDoc(snapshot.ref, body, {merge: true});
 		try {
 			// send email if the status actually changed to completed
-			if (data.status !== req.body.status && req.body.status === "completed") {
+			if (body.status !== req.body.status && req.body.status === "completed") {
 				await sendEmail(
 					"ticketStatusCompleted",
 					{
@@ -88,8 +86,8 @@ async function patch(req: NextApiRequest, res: NextApiResponse) {
 						description: body.description,
 						environment: process.env.ENVIRONMENT,
 					},
-					[data.reporter.email],
+					[body.reporter.email],
-					`Ticket ${id}: ${data.subject}`,
+					`Ticket ${id}: ${body.subject}`,
 				);
 			}
 		} catch (err) {

src/pages/api/tickets/index.ts

@@ -1,16 +1,15 @@
 // Next.js API route support: https://nextjs.org/docs/api-routes/introduction
 import { sendEmail } from "@/email";
-import {app} from "@/firebase";
 import { Ticket, TicketTypeLabel, TicketWithCorporate } from "@/interfaces/ticket";
 import { sessionOptions } from "@/lib/session";
-import {collection, doc, getDocs, getFirestore, setDoc, where, query} from "firebase/firestore";
+import client from "@/lib/mongodb";
 import { withIronSessionApiRoute } from "iron-session/next";
 import moment from "moment";
 import type { NextApiRequest, NextApiResponse } from "next";
 import ShortUniqueId from "short-unique-id";
 import { Group, CorporateUser } from "@/interfaces/user";
 
-const db = getFirestore(app);
+const db = client.db(process.env.MONGODB_DB);
 
 export default withIronSessionApiRoute(handler, sessionOptions);
 
@@ -37,31 +36,24 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
 }
 
 async function get(req: NextApiRequest, res: NextApiResponse) {
-	const snapshot = await getDocs(collection(db, "tickets"));
+	const docs = await db.collection("tickets").find<Ticket>({}).toArray();
-
-	const docs = snapshot.docs.map((doc) => ({
-		id: doc.id,
-		...doc.data(),
-	})) as Ticket[];
 
 	// fetch all groups for these users
-
 	const reporters = [...new Set(docs.map((d) => d.reporter.id).filter((id) => id))];
 
-	const groupsSnapshot = await getDocs(query(collection(db, "groups"), where("participants", "array-contains-any", reporters)));
+	const groups = await db.collection("groups").find<Group>({
-	const groups = groupsSnapshot.docs.map((doc) => doc.data()) as Group[];
+		participants: { $in: reporters }
+	}).toArray();
 
 	// based on the admin of each group, verify if it exists and it's of type corporate
 	const groupsAdmins = [...new Set(groups.map((g) => g.admin).filter((id) => id))];
-	const adminsSnapshot =
+	const admins = groupsAdmins.length > 0
-		groupsAdmins.length > 0
+		? await db.collection("users").find<CorporateUser>({ id: { $in: groupsAdmins }, type: "corporate" }).toArray()
-			? await getDocs(query(collection(db, "users"), where("id", "in", groupsAdmins), where("type", "==", "corporate")))
+		: [];
-			: {docs: []};
-	const admins = adminsSnapshot.docs.map((doc) => doc.data());
 
 	const docsWithAdmins = docs.map((d) => {
 		const group = groups.find((g) => g.participants.includes(d.reporter.id));
-		const admin = admins.find((a) => a.id === group?.admin) as CorporateUser;
+		const admin = admins.find((a) => a.id === group?.admin);
 
 		if (admin) {
 			return {
@@ -81,7 +73,11 @@ async function post(req: NextApiRequest, res: NextApiResponse) {
 
 	const shortUID = new ShortUniqueId();
 	const id = body.id || shortUID.randomUUID(8);
-	await setDoc(doc(db, "tickets", id), body);
+	await db.collection("tickets").updateOne(
+		{ id: id },
+		{ $set: { ...body, id: id } }
+	);
+
 	res.status(200).json({ ok: true });
 
 	try {

src/pages/api/training/[id].ts

@@ -1,10 +1,9 @@
 import { sessionOptions } from "@/lib/session";
-import {app} from "@/firebase";
+import client from "@/lib/mongodb";
-import { collection, doc, getDoc, getDocs, getFirestore, query } from "firebase/firestore";
 import { withIronSessionApiRoute } from "iron-session/next";
 import { NextApiRequest, NextApiResponse } from "next";
 
-const db = getFirestore(app);
+const db = client.db(process.env.MONGODB_DB);
 
 export default withIronSessionApiRoute(handler, sessionOptions);
 
@@ -26,14 +25,9 @@ async function get(req: NextApiRequest, res: NextApiResponse) {
         return res.status(400).json({ message: 'Invalid ID' });
       }
 
-      const docRef = doc(db, "training", id);
+      const doc = await db.collection("training").findOne({ id: id });
-      const docSnap = await getDoc(docRef);
+      if (doc) {
-
+        res.status(200).json(doc);
-      if (docSnap.exists()) {
-        res.status(200).json({
-          id: docSnap.id,
-          ...docSnap.data(),
-        });
       } else {
         res.status(404).json({ message: 'Document not found' });
       }

src/pages/api/training/index.ts

@@ -1,11 +1,10 @@
 import { sessionOptions } from "@/lib/session";
 import axios from "axios";
-import { app } from "@/firebase";
+import client from "@/lib/mongodb";
-import { collection, doc, getDoc, getDocs, getFirestore, query } from "firebase/firestore";
 import { withIronSessionApiRoute } from "iron-session/next";
 import { NextApiRequest, NextApiResponse } from "next";
 
-const db = getFirestore(app);
+const db = client.db(process.env.MONGODB_DB);
 
 export default withIronSessionApiRoute(handler, sessionOptions);
 
@@ -34,15 +33,8 @@ async function post(req: NextApiRequest, res: NextApiResponse) {
 
 async function get(req: NextApiRequest, res: NextApiResponse) {
     try {
-        const q = query(collection(db, "training"));
+        const snapshot = await db.collection("training").find({}).toArray();
-        const snapshot = await getDocs(q);
+        res.status(200).json(snapshot);
-
-        res.status(200).json(
-            snapshot.docs.map((doc) => ({
-                id: doc.id,
-                ...doc.data(),
-            }))
-        );
     } catch (error) {
         console.error('Error fetching data:', error);
         res.status(500).json({ message: 'An unexpected error occurred' });

src/pages/api/training/user/[user].ts

@@ -1,11 +1,10 @@
 // Next.js API route support: https://nextjs.org/docs/api-routes/introduction
 import type {NextApiRequest, NextApiResponse} from "next";
-import {app} from "@/firebase";
+import client from "@/lib/mongodb";
-import {getFirestore, collection, getDocs, query, where, doc, setDoc, addDoc} from "firebase/firestore";
 import {withIronSessionApiRoute} from "iron-session/next";
 import {sessionOptions} from "@/lib/session";
 
-const db = getFirestore(app);
+const db = client.db(process.env.MONGODB_DB);
 
 export default withIronSessionApiRoute(handler, sessionOptions);
 
@@ -16,14 +15,6 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
 	}
 
 	const {user} = req.query;
-	const q = query(collection(db, "training"), where("user", "==", user));
+	const snapshot = await db.collection("training").find({ user: user }).toArray();
-
+	res.status(200).json(snapshot);
-	const snapshot = await getDocs(q);
-
-	res.status(200).json(
-		snapshot.docs.map((doc) => ({
-			id: doc.id,
-			...doc.data(),
-		})),
-	);
 }

src/pages/api/training/walkthrough/index.ts

@@ -1,10 +1,9 @@
 import { sessionOptions } from "@/lib/session";
-import { app } from "@/firebase";
+import client from "@/lib/mongodb";
-import { collection, doc, documentId, getDoc, getDocs, getFirestore, query, where } from "firebase/firestore";
 import { withIronSessionApiRoute } from "iron-session/next";
 import { NextApiRequest, NextApiResponse } from "next";
 
-const db = getFirestore(app);
+const db = client.db(process.env.MONGODB_DB);
 
 export default withIronSessionApiRoute(handler, sessionOptions);
 
@@ -25,18 +24,11 @@ async function get(req: NextApiRequest, res: NextApiResponse) {
             return res.status(400).json({ message: 'Invalid or missing ids!' });
         }
 
-        const walkthroughCollection = collection(db, 'walkthrough');
+        const docs = await db.collection('walkthrough').find({
+            id: { $in: ids }
+        }).toArray();
 
-        const q = query(walkthroughCollection, where(documentId(), 'in', ids));
+        res.status(200).json(docs);
-
-        const querySnapshot = await getDocs(q);
-
-        const documents = querySnapshot.docs.map(doc => ({
-            id: doc.id,
-            ...doc.data()
-        }));
-
-        res.status(200).json(documents);
     } catch (error) {
         console.error('Error fetching data:', error);
         res.status(500).json({ message: 'An unexpected error occurred' });