PMPR-42 : GET /notes - récupère les notes

routes/(apps)/notes/api/notes.ts

@@ -0,0 +1,39 @@
+import { Handlers } from "$fresh/server.ts";
+import { db } from "../../../../databases/db.ts";
+import { notes } from "../../../../databases/schema.ts";
+import { eq } from "npm:drizzle-orm";
+
+export const handler: Handlers = {
+  // #42 GET /notes
+  async GET(request) {
+    try {
+      const url = new URL(request.url);
+      const numEtudParam = url.searchParams.get("numEtud");
+      const idModule = url.searchParams.get("idModule");
+
+      let query = db.select().from(notes).$dynamic();
+
+      if (numEtudParam) {
+        const numEtud = parseInt(numEtudParam);
+        if (isNaN(numEtud)) {
+          return new Response("Paramètre numEtud invalide", { status: 400 });
+        }
+        query = query.where(eq(notes.numEtud, numEtud));
+      }
+
+      if (idModule) {
+        query = query.where(eq(notes.idModule, idModule));
+      }
+
+      const result = await query;
+
+      return new Response(JSON.stringify(result), {
+        status: 200,
+        headers: { "Content-Type": "application/json" },
+      });
+    } catch (error) {
+      console.error("Error fetching notes:", error);
+      return new Response("Failed to fetch data", { status: 500 });
+    }
+  },
+};

routes/(apps)/students/api/students.ts

@@ -1,57 +1,122 @@
 import { FreshContext, Handlers } from "$fresh/server.ts";
 import { db } from "$root/databases/db.ts";
-import { students } from "$root/databases/schema.ts";
+import { promotions, students } from "$root/databases/schema.ts";
 import { AuthenticatedState } from "$root/defaults/interfaces.ts";
-import { eq } from "npm:drizzle-orm";
+import { eq, lt } from "npm:drizzle-orm";
+
+async function getItself(
+  userId: string,
+): Promise<{ student: Student | null; promo: Promotion | null }> {
+  const student = await db
+    .select()
+    .from(students)
+    .where(eq(students.userId, userId))
+    .limit(1)
+    .then((rows) => rows[0] ?? null);
+
+  if (!student) {
+    return { student: null, promo: null };
+  }
+
+  const promo = await db
+    .select()
+    .from(promotions)
+    .where(eq(promotions.id, student.promotionId!))
+    .limit(1)
+    .then((rows) => rows[0] ?? null);
+
+  return { student, promo };
+}
+
+async function getAll(): Promise<
+  { students: Student[]; promos: Promotion[] }
+> {
+  const rows = await db
+    .select({
+      userId: students.userId,
+      firstName: students.firstName,
+      lastName: students.lastName,
+      mail: students.mail,
+      promotionId: students.promotionId,
+    })
+    .from(students)
+    .innerJoin(promotions, eq(students.promotionId, promotions.id))
+    .where(lt(promotions.current, 6));
+
+  const promos = await db
+    .select()
+    .from(promotions)
+    .where(lt(promotions.current, 6));
+
+  return { students: rows as Student[], promos };
+}
+
+async function addStudents(
+  studentList: Student[],
+  promoId: number,
+): Promise<void> {
+  for (const student of studentList) {
+    await db
+      .insert(students)
+      .values({
+        userId: student.userId,
+        firstName: student.firstName,
+        lastName: student.lastName,
+        mail: student.mail,
+        promotionId: promoId,
+      })
+      .onConflictDoNothing();
+  }
+}
 
 export const handler: Handlers<null, AuthenticatedState> = {
-  // #7 GET /students
   async GET(
-    request: Request,
+    _request: Request,
     context: FreshContext<AuthenticatedState>,
   ): Promise<Response> {
-    if (context.state.session.eduPersonPrimaryAffiliation !== "employee") {
+    if (context.state.session.eduPersonPrimaryAffiliation == "student") {
-      return new Response(JSON.stringify([]), {
+      return new Response(
-        headers: { "content-type": "application/json" },
+        JSON.stringify(await getItself(context.state.session.uid)),
-      });
+        { headers: { "content-type": "application/json" } },
+      );
     }
 
-    const url = new URL(request.url);
+    return new Response(
-    const idPromo = url.searchParams.get("idPromo");
+      JSON.stringify(await getAll()),
-
+      { headers: { "content-type": "application/json" } },
-    const rows = idPromo
+    );
-      ? await db.select().from(students).where(eq(students.idPromo, idPromo))
-      : await db.select().from(students);
-
-    return new Response(JSON.stringify(rows), {
-      headers: { "content-type": "application/json" },
-    });
   },
 
-  // #8 POST /students
   async POST(
     request: Request,
-    context: FreshContext<AuthenticatedState>,
+    _context: FreshContext<AuthenticatedState>,
   ): Promise<Response> {
-    if (context.state.session.eduPersonPrimaryAffiliation !== "employee") {
+    const { students: studentList, promo }: {
-      return new Response(null, { status: 403 });
+      students: Student[];
-    }
+      promo: string;
+    } = await request.json();
 
-    const body: { numEtud: number; nom: string; prenom: string; idPromo: string } =
+    if (!promo || !promo.match(/^\d{4}-\dA$/) || !Array.isArray(studentList)) {
-      await request.json();
-
-    if (!body.nom || !body.prenom || !body.idPromo) {
       return new Response(null, { status: 400 });
     }
 
-    const [created] = await db
+    const { endyear, current } = promo.match(
-      .insert(students)
+      /^(?<endyear>\d{4})-(?<current>\d)A$/,
-      .values({ nom: body.nom, prenom: body.prenom, idPromo: body.idPromo })
+    )?.groups!;
-      .returning();
 
-    return new Response(JSON.stringify(created), {
+    await db
-      status: 201,
+      .insert(promotions)
-      headers: { "content-type": "application/json" },
+      .values({ endyear: Number(endyear), current: Number(current) })
-    });
+      .onConflictDoNothing();
+
+    const promo_row = await db
+      .select()
+      .from(promotions)
+      .where(eq(promotions.endyear, Number(endyear)))
+      .then((rows) => rows.find((r) => r.current === Number(current))!);
+
+    await addStudents(studentList, promo_row.id);
+
+    return new Response(null, { status: 201 });
   },
 };

routes/(apps)/students/api/students/import-csv.ts

@@ -1,64 +0,0 @@
-import { FreshContext, Handlers } from "$fresh/server.ts";
-import { db } from "$root/databases/db.ts";
-import { students } from "$root/databases/schema.ts";
-import { AuthenticatedState } from "$root/defaults/interfaces.ts";
-
-// #9 POST /students/import-csv
-export const handler: Handlers<null, AuthenticatedState> = {
-  async POST(
-    request: Request,
-    context: FreshContext<AuthenticatedState>,
-  ): Promise<Response> {
-    if (context.state.session.eduPersonPrimaryAffiliation !== "employee") {
-      return new Response(null, { status: 403 });
-    }
-
-    const formData = await request.formData();
-    const file = formData.get("file") as File | null;
-    const idPromo = formData.get("idPromo") as string | null;
-
-    if (!file || !idPromo) {
-      return new Response(null, { status: 400 });
-    }
-
-    const text = await file.text();
-    const lines = text.trim().split("\n");
-
-    let imported = 0;
-    const errors: { line: number; message: string }[] = [];
-
-    for (let i = 0; i < lines.length; i++) {
-      const lineNum = i + 1;
-      const cols = lines[i].split(",").map((c) => c.trim());
-
-      const [numEtudStr, nom, prenom] = cols;
-
-      if (!numEtudStr) {
-        errors.push({ line: lineNum, message: "Numéro étudiant manquant" });
-        continue;
-      }
-
-      const numEtud = Number(numEtudStr);
-      if (isNaN(numEtud)) {
-        errors.push({ line: lineNum, message: "Numéro étudiant invalide" });
-        continue;
-      }
-
-      if (!nom || !prenom) {
-        errors.push({ line: lineNum, message: "Nom ou prénom manquant" });
-        continue;
-      }
-
-      await db
-        .insert(students)
-        .values({ nom, prenom, idPromo })
-        .onConflictDoNothing();
-
-      imported++;
-    }
-
-    return new Response(JSON.stringify({ imported, errors }), {
-      headers: { "content-type": "application/json" },
-    });
-  },
-};