ApexDev Academy — Modern Software Engineering & AI Educational Portal

// src/app/actions/enrollment.ts - Idempotent Course Enrollment Server Action
"use server";
import { revalidatePath } from "next/cache";

export async function enrollStudentInCourse(courseId: string, studentId: string) {
  // 1. Verify student eligibility and existing enrollment
  const existingEnrollment = await db.enrollment.findUnique({
    where: { studentId_courseId: { studentId, courseId } },
  });

  if (existingEnrollment) {
    return { success: true, message: "Already enrolled in this course." };
  }

  // 2. Atomic enrollment transaction with initial progress zero-state
  await db.$transaction([
    db.enrollment.create({
      data: {
        studentId,
        courseId,
        enrolledAt: new Date(),
        progressPercent: 0,
        status: "ACTIVE",
      },
    }),
    db.course.update({
      where: { id: courseId },
      data: { activeLearnersCount: { increment: 1 } },
    }),
  ]);

  revalidatePath(`/catalog/${courseId}`);
  revalidatePath("/dashboard");
  return { success: true };
}

// src/lib/peerReview.ts - Algorithmic Peer Review Assignment
export async function assignPeerReviews(submissionId: string, cohortId: string) {
  // Fetch 2 active peers from the same cohort who haven't reviewed this submission
  const candidatePeers = await db.student.findMany({
    where: {
      cohortId,
      submissions: { some: { status: "COMPLETED" } },
    },
    take: 2,
    orderBy: { pendingReviewCount: "asc" },
  });

  return Promise.all(
    candidatePeers.map((peer) =>
      db.reviewAssignment.create({
        data: {
          submissionId,
          reviewerId: peer.id,
          deadline: new Date(Date.now() + 48 * 60 * 60 * 1000), // 48h deadline
        },
      })
    )
  );
}