Gql notifications backend

.env.template

@@ -27,3 +27,5 @@ AWS_SECRET_ACCESS_KEY=_
 GOOGLE_CLIENT_ID=_
 GOOGLE_CLIENT_SECRET=_
 SESSION_SECRET=_
+
+SENDGRID_API_KEY=_

.gitignore

@@ -27,3 +27,5 @@ generated-types/
 # others
 *.cert
 *.key
+
+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",
@@ -55,7 +57,9 @@
     "keyv": "^5.5.3",
     "lodash": "^4.17.21",
     "mongodb": "^6.20.0",
-    "mongoose": "^8.19.1",
+    "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,39 @@ export const getBookmarkedClasses = async (
 
   return classes.map(formatClass);
 };
+
+export const getMonitoredClasses = async (
+  monitoredClasses:
+    | UserModule.MonitoredClassInput[]
+    | UserModule.MonitoredClass[]
+) => {
+  const filters = monitoredClasses.map((mc) => {
+    const c = mc.class;
+    return {
+      year: c.year,
+      semester: c.semester,
+      sessionId: c.sessionId ?? "1",
+      subject: c.subject,
+      courseNumber: c.courseNumber,
+      number: c.number,
+    };
+  });
+
+  const docs = await ClassModel.find({ $or: filters }).lean();
+  const classKey = (c: any) =>
+    `${c.year}-${c.semester}-${c.sessionId ?? "1"}-${c.subject}-${c.courseNumber}-${c.number}`;
+  const docsByKey = new Map(docs.map((d) => [classKey(d), d]));
+
+  return monitoredClasses
+    .map((mc) => {
+      const key = classKey(mc.class);
+      const doc = docsByKey.get(key);
+      if (!doc) return null;
+
+      return {
+        class: formatClass(doc),
+        thresholds: mc.thresholds,
+      };
+    })
+    .filter(Boolean);
+};

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/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"
   }