enrollment notifications

.gitignore

@@ -27,3 +27,9 @@ generated-types/
 # others
 *.cert
 *.key
+
+apps/frontend/tsconfig.node.tsbuildinfo
+apps/frontend/tsconfig.tsbuildinfo
+apps/frontend/vite.config.d.ts
+apps/frontend/vite.config.js
+prod-backup.gz

apps/backend/package.json

@@ -41,6 +41,8 @@
     "@repo/common": "*",
     "@repo/shared": "*",
     "@repo/sis-api": "*",
+    "@types/node-cron": "^3.0.11",
+    "@types/nodemailer": "^7.0.2",
     "compression": "^1.8.1",
     "connect-redis": "^9.0.0",
     "cors": "^2.8.5",
@@ -54,8 +56,10 @@
     "helmet": "^8.1.0",
     "keyv": "^5.5.3",
     "lodash": "^4.17.21",
-    "mongodb": "^6.20.0",
-    "mongoose": "^8.19.1",
+    "mongodb": "^6.18.0",
+    "mongoose": "^8.17.0",
+    "node-cron": "^4.2.1",
+    "nodemailer": "^7.0.7",
     "papaparse": "^5.5.3",
     "passport": "^0.7.0",
     "passport-google-oauth20": "^2.0.0",

apps/backend/src/modules/user/controller.ts

@@ -79,3 +79,33 @@ export const getBookmarkedClasses = async (
 
   return classes.map(formatClass);
 };
+
+export const getMonitoredClasses = async (
+  monitoredClasses:
+    | UserModule.MonitoredClassInput[]
+    | UserModule.MonitoredClass[]
+) => {
+  const classes = [];
+
+  for (const monitoredClass of monitoredClasses) {
+    const classData = monitoredClass.class;
+
+    const _class = await ClassModel.findOne({
+      year: classData.year,
+      semester: classData.semester,
+      sessionId: classData.sessionId ? classData.sessionId : "1",
+      subject: classData.subject,
+      courseNumber: classData.courseNumber,
+      number: classData.number,
+    }).lean();
+
+    if (!_class) continue;
+
+    classes.push({
+      class: formatClass(_class),
+      thresholds: monitoredClass.thresholds,
+    });
+  }
+
+  return classes;
+};

apps/backend/src/modules/user/formatter.ts

@@ -5,6 +5,7 @@ import { UserModule } from "./generated-types/module-types";
 interface UserRelationships {
   bookmarkedCourses: UserModule.BookmarkedCourseInput[];
   bookmarkedClasses: UserModule.BookmarkedClassInput[];
+  monitoredClasses: UserModule.MonitoredClassInput[];
 }
 
 export type IntermediateUser = Omit<UserModule.User, keyof UserRelationships> &
@@ -21,5 +22,7 @@ export const formatUser = (user: UserType) => {
     bookmarkedClasses: user.bookmarkedClasses,
     majors: user.majors ? user.majors : [],
     minors: user.minors ? user.minors : [],
+    monitoredClasses: user.monitoredClasses,
+    notificationsOn: user.notificationsOn,
   } as IntermediateUser;
 };

apps/backend/src/modules/user/resolver.ts

@@ -1,6 +1,7 @@
 import {
   getBookmarkedClasses,
   getBookmarkedCourses,
+  getMonitoredClasses,
   getUser,
   updateUser,
 } from "./controller";
@@ -40,6 +41,21 @@ const resolvers: UserModule.Resolvers = {
 
       return courses as unknown as UserModule.Course[];
     },
+
+    monitoredClasses: async (parent: UserModule.User | IntermediateUser) => {
+      if (
+        parent.monitoredClasses[0] &&
+        (parent.monitoredClasses[0] as UserModule.MonitoredClass).class
+      ) {
+        return parent.monitoredClasses as UserModule.MonitoredClass[];
+      }
+
+      const monitoredClasses = await getMonitoredClasses(
+        parent.monitoredClasses
+      );
+
+      return monitoredClasses as unknown as UserModule.MonitoredClass[];
+    },
   },
 
   Mutation: {

apps/backend/src/modules/user/typedefs/user.ts

@@ -1,6 +1,11 @@
 import { gql } from "graphql-tag";
 
 const typedef = gql`
+  type MonitoredClass {
+    class: Class!
+    thresholds: [Float]!
+  }
+
   type User @cacheControl(scope: PRIVATE) {
     _id: ID!
     email: String!
@@ -11,6 +16,8 @@ const typedef = gql`
     bookmarkedClasses: [Class!]!
     majors: [String!]!
     minors: [String!]!
+    monitoredClasses: [MonitoredClass!]!
+    notificationsOn: Boolean!
   }
 
   type Query {
@@ -31,11 +38,41 @@ const typedef = gql`
     number: ClassNumber!
   }
 
+  input MonitoredClassRefInput {
+    year: Int!
+    semester: Semester!
+    sessionId: SessionIdentifier
+    subject: String!
+    courseNumber: CourseNumber!
+    number: ClassNumber!
+  }
+
+  input MonitoredClassInput {
+    class: MonitoredClassRefInput!
+    thresholds: [Float!]!
+  }
+
+  input MonitoredClassRefInput {
+    year: Int!
+    semester: Semester!
+    sessionId: SessionIdentifier
+    subject: String!
+    courseNumber: CourseNumber!
+    number: ClassNumber!
+  }
+
+  input MonitoredClassInput {
+    class: MonitoredClassRefInput!
+    thresholds: [Float!]!
+  }
+
   input UpdateUserInput {
     bookmarkedClasses: [BookmarkedClassInput!]
     bookmarkedCourses: [BookmarkedCourseInput!]
     majors: [String!]
     minors: [String!]
+    monitoredClasses: [MonitoredClassInput!]
+    notificationsOn: Boolean!
   }
 
   type Mutation {

apps/backend/src/services/email.ts

@@ -0,0 +1,3 @@
+// Connects to an SMTP server or email provider.
+// Formats and sends the email to a user.
+// Handles retries or errors if sending fails.

apps/datapuller/package.json

@@ -19,6 +19,7 @@
     "@repo/sis-api": "*",
     "dotenv": "^17.2.3",
     "luxon": "^3.7.2",
+    "@sendgrid/mail": "^8.1.4",
     "papaparse": "^5.5.3",
     "tslog": "^4.10.2"
   }

apps/datapuller/src/main.ts

@@ -3,6 +3,7 @@ import { parseArgs } from "node:util";
 import classesPuller from "./pullers/classes";
 import coursesPuller from "./pullers/courses";
 import enrollmentHistoriesPuller from "./pullers/enrollment";
+import enrollmentChecksPuller from "./pullers/enrollment-checks";
 import gradeDistributionsPuller from "./pullers/grade-distributions";
 import sectionsPuller from "./pullers/sections";
 import termsPuller from "./pullers/terms";
@@ -26,6 +27,7 @@ const pullerMap: {
   "grades-recent": gradeDistributionsPuller.recentPastTerms,
   "grades-last-five-years": gradeDistributionsPuller.lastFiveYearsTerms,
   enrollments: enrollmentHistoriesPuller.updateEnrollmentHistories,
+  "enrollment-checks": enrollmentChecksPuller.checkEnrollmentThresholds,
   "terms-all": termsPuller.allTerms,
   "terms-nearby": termsPuller.nearbyTerms,
 } as const;