Monitor crowd-sourced data pod

.gitignore

@@ -1,29 +1,20 @@
-*.pyc
 *.DS_Store
 *.log
-venv*
 *.dump
 *.rdb
-.vagrant
-.idea
 .env*
 !.env.template
-vagrant/data/data.tar.gz
-build/postgres-data
-build/requirements.txt
-.sass-cache/
 postgres-data.tar.gz
 bt_main.sql
-/.vscode
-node_modules/
-build/docker-compose.yml
-config.statuspage.json
+.vscode
+node_modules
 *.cert
 *.key
 dist/
 db/
+data/
 mdb.archive
 bt_seed.sql
 bt_seed.sql.gz
 .turbo
-generated-types/
+generated-types

apps/backend/package.json

@@ -41,6 +41,8 @@
     "@keyv/redis": "^4.0.2",
     "@repo/common": "*",
     "@repo/sis-api": "*",
+    "@repo/shared": "*",
+    "@types/papaparse": "^5.3.15",
     "compression": "^1.7.5",
     "connect-redis": "^7.1.1",
     "cors": "^2.8.5",

apps/backend/src/bootstrap/loaders/apollo.ts

@@ -63,6 +63,26 @@ export default async (redis: RedisClientType) => {
     // TODO(production): Disable introspection in production
     introspection: true,
     cache: new RedisCache(redis),
+    formatError: (formattedError) => {
+      // Return BAD_USER_INPUT errors as 400s
+      if (formattedError.extensions?.code === "BAD_USER_INPUT") {
+        return {
+          ...formattedError,
+          extensions: {
+            ...formattedError.extensions,
+            http: { status: 400 },
+          },
+        };
+      }
+      // Return other errors as internal server errors
+      return {
+        message: formattedError.message,
+        extensions: {
+          code: "INTERNAL_SERVER_ERROR",
+          http: { status: 500 },
+        },
+      };
+    },
   });
 
   await server.start();

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

@@ -13,6 +13,7 @@ export interface ClassRelationships {
   primarySection: null;
   sections: null;
   gradeDistribution: null;
+  aggregatedRatings: null;
 }
 
 export type IntermediateClass = Omit<
@@ -46,6 +47,7 @@ export const formatClass = (_class: ClassType) => {
     term: null,
     primarySection: null,
     sections: null,
+    aggregatedRatings: null,
 
     description: _class.classDescription,
     gradingBasis: _class.gradingBasis?.description as ClassGradingBasis,

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

@@ -3,6 +3,7 @@ import { GraphQLError, GraphQLScalarType, Kind } from "graphql";
 import { getCourse } from "../course/controller";
 import { CourseModule } from "../course/generated-types/module-types";
 import { getGradeDistributionByClass } from "../grade-distribution/controller";
+import { getClassAggregatedRatings } from "../rating/controller";
 import { getTerm } from "../term/controller";
 import { TermModule } from "../term/generated-types/module-types";
 import {
@@ -146,6 +147,20 @@ const resolvers: ClassModule.Resolvers = {
 
       return gradeDistribution;
     },
+
+    aggregatedRatings: async (
+      parent: IntermediateClass | ClassModule.Class
+    ) => {
+      const aggregatedRatings = await getClassAggregatedRatings(
+        parent.subject,
+        parent.courseNumber,
+        parent.semester,
+        parent.year,
+        parent.number
+      );
+
+      return aggregatedRatings;
+    },
   },
 
   Section: {

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

@@ -36,6 +36,7 @@ export default gql`
     sections: [Section!]!
     term: Term!
     gradeDistribution: GradeDistribution!
+    aggregatedRatings: AggregatedRatings!
 
     "Attributes"
     gradingBasis: ClassGradingBasis!

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

@@ -1,6 +1,7 @@
 import { GraphQLError, GraphQLScalarType, Kind } from "graphql";
 
 import { getGradeDistributionByCourse } from "../grade-distribution/controller";
+import { getCourseAggregatedRatings } from "../rating/controller";
 import {
   getAssociatedCourses,
   getClassesByCourse,
@@ -90,6 +91,17 @@ const resolvers: CourseModule.Resolvers = {
 
       return gradeDistribution;
     },
+
+    aggregatedRatings: async (
+      parent: IntermediateCourse | CourseModule.Course
+    ) => {
+      const aggregatedRatings = await getCourseAggregatedRatings(
+        parent.subject,
+        parent.number
+      );
+
+      return aggregatedRatings;
+    },
   },
 
   // @ts-expect-error - Not sure how to type properly

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

@@ -17,6 +17,7 @@ export default gql`
     classes: [Class!]!
     crossListing: [Course!]!
     requiredCourses: [Course!]!
+    aggregatedRatings: AggregatedRatings!
 
     "Attributes"
     requirements: String

apps/backend/src/modules/index.ts

@@ -6,6 +6,7 @@ import Common from "./common";
 import Course from "./course";
 import Enrollment from "./enrollment";
 import GradeDistribution from "./grade-distribution";
+import Rating from "./rating";
 import Schedule from "./schedule";
 import Term from "./term";
 import User from "./user";
@@ -20,6 +21,7 @@ const modules = [
   Course,
   Class,
   Enrollment,
+  Rating,
 ];
 
 export const resolvers = merge(modules.map((module) => module.resolver));