Merge pull request #360 from Abh1noob/refactor

Refactor API routes to separate concerns between HTTP handlers and business logic

Author: abhitrueprogrammer

src/app/api/course-list/route.ts

@@ -1,5 +1,5 @@
 import { NextResponse } from "next/server";
-import { connectToDatabase } from "@/lib/mongoose";
+import { connectToDatabase } from "@/lib/database/mongoose";
 import { Course } from "@/db/course";
 
 export const dynamic = "force-dynamic";

src/app/api/paper-by-id/[id]/route.ts

@@ -1,5 +1,5 @@
 import { NextResponse } from "next/server";
-import { connectToDatabase } from "@/lib/mongoose";
+import { connectToDatabase } from "@/lib/database/mongoose";
 import Paper from "@/db/papers";
 import { Types } from "mongoose";
 

src/app/api/papers/count/route.ts

@@ -1,5 +1,5 @@
 import { NextResponse } from "next/server";
-import { connectToDatabase } from "@/lib/mongoose";
+import { connectToDatabase } from "@/lib/database/mongoose";
 import CourseCount from "@/db/course";
 
 export const dynamic = "force-dynamic";

src/app/api/papers/route.ts

@@ -1,7 +1,9 @@
 import { NextResponse, type NextRequest } from "next/server";
-import { connectToDatabase } from "@/lib/mongoose";
+import { connectToDatabase } from "@/lib/database/mongoose";
 import Paper from "@/db/papers";
 import { type IPaper } from "@/interface";
+import { escapeRegExp } from "@/lib/utils/regex";
+import { extractUniqueValues } from "@/lib/utils/paper-aggregation";
 
 export const dynamic = "force-dynamic";
 
@@ -10,10 +12,6 @@ export async function GET(req: NextRequest) {
     await connectToDatabase();
     const url = req.nextUrl.searchParams;
     const subject = url.get("subject");
-    const escapeRegExp = (text: string) => {
-      return text.replace(/[.*+?^${}()|[\]\\]/g, "\\$&");
-    };
-    const escapedSubject = escapeRegExp(subject ?? "");
 
     if (!subject) {
       return NextResponse.json(
@@ -22,42 +20,17 @@ export async function GET(req: NextRequest) {
       );
     }
 
+    const escapedSubject = escapeRegExp(subject);
     const papers: IPaper[] = await Paper.find({
       subject: { $regex: new RegExp(`${escapedSubject}`, "i") },
     });
 
-    if (papers.length === 0) {
-      return NextResponse.json(
-        {
-          papers,
-          unique_years: [],
-          unique_slots: [],
-          unique_exams: [],
-          unique_campuses: [],
-          unique_semesters: [],
-        },
-        { status: 200 },
-      );
-    }
-
-    const unique_years = Array.from(new Set(papers.map((paper) => paper.year)));
-    const unique_slots = Array.from(new Set(papers.map((paper) => paper.slot)));
-    const unique_exams = Array.from(new Set(papers.map((paper) => paper.exam)));
-    const unique_campuses = Array.from(
-      new Set(papers.map((paper) => paper.campus)),
-    );
-    const unique_semesters = Array.from(
-      new Set(papers.map((paper) => paper.semester)),
-    );
+    const uniqueValues = extractUniqueValues(papers);
 
     return NextResponse.json(
       {
         papers,
-        unique_years,
-        unique_slots,
-        unique_exams,
-        unique_campuses,
-        unique_semesters,
+        ...uniqueValues,
       },
       { status: 200 },
     );
@@ -67,4 +40,4 @@ export async function GET(req: NextRequest) {
       { status: 500 },
     );
   }
-}
+}

src/app/api/related-subject/route.ts

@@ -1,7 +1,8 @@
 import { NextResponse, type NextRequest } from "next/server";
-import { connectToDatabase } from "@/lib/mongoose";
+import { connectToDatabase } from "@/lib/database/mongoose";
 import { IRelatedSubject } from "@/interface";
 import RelatedSubject from "@/db/relatedSubjects";
+import { escapeRegExp } from "@/lib/utils/regex";
 
 export const dynamic = "force-dynamic";
 
@@ -10,20 +11,19 @@ export async function GET(req: NextRequest) {
     await connectToDatabase();
     const url = req.nextUrl.searchParams;
     const subject = url.get("subject");
-    const escapeRegExp = (text: string) => {
-      return text.replace(/[.*+?^${}()|[\]\\]/g, "\\$&");
-    };
-    const escapedSubject = escapeRegExp(subject ?? "");
 
     if (!subject) {
       return NextResponse.json(
         { message: "Subject query parameter is required" },
         { status: 400 },
       );
     }
+
+    const escapedSubject = escapeRegExp(subject);
     const subjects: IRelatedSubject[] = await RelatedSubject.find({
       subject: { $regex: new RegExp(`${escapedSubject}`, "i") },
     });
+    
     console.log("realted", subjects);
 
     return NextResponse.json(
@@ -38,4 +38,4 @@ export async function GET(req: NextRequest) {
       { status: 500 },
     );
   }
-}
+}

src/app/api/request/route.ts

@@ -1,5 +1,5 @@
 import { NextResponse } from "next/server";
-import { connectToDatabase } from "@/lib/mongoose";
+import { connectToDatabase } from "@/lib/database/mongoose";
 import PaperRequest from "@/db/paperRequest";
 
 export async function POST(req: Request) {

src/app/api/selected-papers/route.ts

@@ -1,5 +1,5 @@
 import { NextResponse } from "next/server";
-import { connectToDatabase } from "@/lib/mongoose";
+import { connectToDatabase } from "@/lib/database/mongoose";
 import Paper from "@/db/papers";
 
 export const dynamic = "force-dynamic";

src/app/api/subscribe/route.ts

@@ -1,34 +1,5 @@
 import { NextResponse } from "next/server";
-import { google, sheets_v4 } from "googleapis";
-import { JWT } from "google-auth-library";
-
-const SCOPES = ["https://www.googleapis.com/auth/spreadsheets"];
-const SHEET_ID = process.env.SHEET_ID;
-
-async function getAuth(): Promise<JWT> {
-  return new google.auth.JWT({
-    email: process.env.GOOGLE_CLIENT_EMAIL,
-    key: process.env.GOOGLE_PRIVATE_KEY?.replace(/\\n/g, "\n"),
-    scopes: SCOPES,
-  });
-}
-
-async function appendEmailToSheet(email: string) {
-  const authClient = await getAuth();
-  const sheets: sheets_v4.Sheets = google.sheets({
-    version: "v4",
-    auth: authClient,
-  });
-
-  await sheets.spreadsheets.values.append({
-    spreadsheetId: SHEET_ID,
-    range: "Sheet1!A:A",
-    valueInputOption: "RAW",
-    requestBody: {
-      values: [[email]],
-    },
-  });
-}
+import { appendEmailToSheet } from "@/lib/services/google-sheets";
 
 export async function POST(req: Request) {
   try {
@@ -44,4 +15,4 @@ export async function POST(req: Request) {
     console.error("Error adding email:", error);
     return NextResponse.json({ error: "Failed to add email" }, { status: 500 });
   }
-}
+}

src/app/api/upcoming-papers/route.ts

@@ -1,7 +1,8 @@
 import { NextResponse } from "next/server";
-import { connectToDatabase } from "@/lib/mongoose";
+import { connectToDatabase } from "@/lib/database/mongoose";
 import UpcomingSlot from "@/db/upcoming-slot";
 import UpcomingSubject from "@/db/upcoming-paper";
+import { calculateCorrespondingSlots } from "@/lib/utils/slot-calculation";
 
 export const dynamic = "force-dynamic";
 
@@ -10,6 +11,7 @@ export async function GET() {
     await connectToDatabase();
     const upcomingSlot = await UpcomingSlot.find();
     const slot = upcomingSlot[0]?.slot;
+    
     if (!slot) {
       return NextResponse.json(
         {
@@ -18,16 +20,12 @@ export async function GET() {
         { status: 404 },
       );
     }
-    const nextSlot = String.fromCharCode(slot.charCodeAt(0) + 1);
-    const correspondingSlots = [
-      slot + "1",
-      slot + "2",
-      nextSlot + "1",
-      nextSlot + "2",
-    ];
+
+    const correspondingSlots = calculateCorrespondingSlots(slot);
     const selectedSubjects = await UpcomingSubject.find({
       slots: { $in: correspondingSlots },
     });
+    
     if (selectedSubjects.length === 0) {
       return NextResponse.json(
         {
@@ -49,4 +47,4 @@ export async function GET() {
       { status: 500 },
     );
   }
-}
+}

src/app/api/upload/route.ts

@@ -1,8 +1,8 @@
 import { NextResponse } from "next/server";
-import { connectToDatabase } from "@/lib/mongoose";
+import { connectToDatabase } from "@/lib/database/mongoose";
 import { PaperAdmin } from "@/db/papers";
-import { createPDFfromImages } from "@/lib/pdf";
-import { uploadPDF, uploadThumbnail } from "@/lib/storage";
+import { createPDFfromImages } from "@/lib/storage/pdf";
+import { uploadPDF, uploadThumbnail } from "@/lib/storage/gcp";
 
 export const runtime = "nodejs";