phase1

Author: ruiichen

backend/typescript/graphql/index.ts

@@ -21,6 +21,8 @@ import adminCommentResolvers from "./resolvers/adminCommentsResolvers";
 import adminCommentType from "./types/adminCommentsType";
 import reviewPageType from "./types/reviewPageType";
 import reviewPageResolvers from "./resolvers/reviewPageResolvers";
+import applicantRecordType from "./types/applicantRecordType";
+import applicantRecordResolvers from "./resolvers/applicantRecordResolvers";
 
 const query = gql`
   type Query {
@@ -45,6 +47,7 @@ const executableSchema = makeExecutableSchema({
     reviewDashboardType,
     adminCommentType,
     reviewPageType,
+    applicantRecordType,
   ],
   resolvers: merge(
     authResolvers,
@@ -54,6 +57,7 @@ const executableSchema = makeExecutableSchema({
     reviewDashboardResolvers,
     adminCommentResolvers,
     reviewPageResolvers,
+    applicantRecordResolvers,
   ),
 });
 

backend/typescript/graphql/resolvers/applicantRecordResolvers.ts

@@ -0,0 +1,21 @@
+import ApplicantRecordService from "../../services/implementations/applicantRecordService";
+import { getErrorMessage } from "../../utilities/errorUtils";
+
+const applicantRecordService = new ApplicantRecordService();
+
+const applicantRecordResolvers = {
+  Mutation: {
+    populateApplicantRecord: async (
+      _parent: undefined,
+      args: { term: string },
+    ): Promise<void> => {
+      try {
+        await applicantRecordService.populateApplicantRecord(args.term);
+      } catch (error) {
+        throw new Error(getErrorMessage(error));
+      }
+    },
+  },
+};
+
+export default applicantRecordResolvers;

backend/typescript/graphql/types/applicantRecordType.ts

@@ -0,0 +1,11 @@
+import { gql } from "apollo-server-express";
+
+const applicantRecordType = gql`
+  scalar None
+
+  extend type Mutation {
+    populateApplicantRecord(term: String!): None
+  }
+`;
+
+export default applicantRecordType;

backend/typescript/models/applicantRecord.model.ts

@@ -9,7 +9,7 @@ import {
   Model,
   Table,
 } from "sequelize-typescript";
-import { NonAttribute } from "sequelize";
+import { NonAttribute, DataTypes } from "sequelize";
 import {
   ApplicantRecordExtraInfo,
   ApplicationStatus,
@@ -22,7 +22,8 @@ import ReviewedApplicantRecord from "./reviewedApplicantRecord.model";
 @Table({ tableName: "applicant_records" })
 export default class ApplicantRecord extends Model {
   @Column({
-    type: DataType.STRING,
+    type: DataTypes.UUID,
+    defaultValue: DataTypes.UUIDV4,
     primaryKey: true,
     unique: true,
     autoIncrement: true,

backend/typescript/server.ts

@@ -50,17 +50,19 @@ sequelize.authenticate();
 //   databaseURL: "https://uw-blueprint.firebaseio.com",
 // });
 
-admin.initializeApp({
-  credential: admin.credential.cert({
-    projectId: process.env.FIREBASE_PROJECT_ID,
-    privateKey: process.env.FIREBASE_SVC_ACCOUNT_PRIVATE_KEY?.replace(
-      /\\n/g,
-      "\n",
-    ),
-    clientEmail: process.env.FIREBASE_SVC_ACCOUNT_CLIENT_EMAIL,
-  }),
-  databaseURL: "https://uw-blueprint.firebaseio.com",
-});
+if (!admin.apps.length) {
+  admin.initializeApp({
+    credential: admin.credential.cert({
+      projectId: process.env.FIREBASE_PROJECT_ID,
+      privateKey: process.env.FIREBASE_SVC_ACCOUNT_PRIVATE_KEY?.replace(
+        /\\n/g,
+        "\n",
+      ),
+      clientEmail: process.env.FIREBASE_SVC_ACCOUNT_CLIENT_EMAIL,
+    }),
+    databaseURL: "https://uw-blueprint.firebaseio.com",
+  });
+}
 const db = admin.database();
 const ref = db.ref("studentApplications");
 

backend/typescript/services/implementations/applicantRecordService.ts

@@ -0,0 +1,82 @@
+import * as admin from "firebase-admin";
+import IApplicantRecordService from "../interfaces/IApplicantRecordService";
+import Applicant from "../../models/applicant.model";
+import ApplicantRecord from "../../models/applicantRecord.model";
+import { getErrorMessage } from "../../utilities/errorUtils";
+import logger from "../../utilities/logger";
+
+const Logger = logger(__filename);
+
+if (!admin.apps.length) {
+  admin.initializeApp({
+    credential: admin.credential.cert({
+      projectId: process.env.FIREBASE_PROJECT_ID,
+      privateKey: process.env.FIREBASE_SVC_ACCOUNT_PRIVATE_KEY?.replace(
+        /\\n/g,
+        "\n",
+      ),
+      clientEmail: process.env.FIREBASE_SVC_ACCOUNT_CLIENT_EMAIL,
+    }),
+    databaseURL: "https://uw-blueprint.firebaseio.com",
+  });
+}
+
+const db = admin.database();
+const studentApplicationsRef = db.ref("studentApplications");
+
+class ApplicantRecordService implements IApplicantRecordService {
+  /* eslint-disable class-methods-use-this */
+  async populateApplicantRecord(term: string): Promise<void> {
+    try {
+      const snapshot = await studentApplicationsRef
+        .orderByChild("term")
+        .equalTo(term)
+        .once("value");
+
+      const rawData = snapshot.val() as Record<string, any>;
+
+      const applicantsToCreate = Object.values(rawData).map((app: any) => {
+        const shortAnswers = Array.isArray(app.shortAnswerQuestions)
+          ? app.shortAnswerQuestions.map((q: any) => {
+              if (typeof q === "string") return q;
+              return JSON.stringify(q); // fallback
+            })
+          : [];
+
+        return {
+          academicOrCoop: app.academicOrCoop ?? "",
+          academicYear: app.academicYear ?? "",
+          email: app.email ?? "",
+          firstName: app.firstName ?? "",
+          lastName: app.lastName ?? "",
+          heardFrom: app.heardFrom ?? "",
+          locationPreference: app.locationPreference ?? "",
+          program: app.program ?? "",
+          pronouns: app.pronouns ?? "",
+          resumeUrl: app.resumeUrl ?? "",
+          timesApplied:
+            typeof app.timesApplied === "number" ? app.timesApplied : 0,
+          shortAnswerQuestions: shortAnswers,
+          term: app.term ?? term,
+          submittedAt: app.submittedAt
+            ? new Date(app.submittedAt)
+            : new Date(app.timestamp ?? Date.now()),
+        };
+      });
+
+      const createdApplicants = await Applicant.bulkCreate(applicantsToCreate, {
+        validate: true,
+        returning: true, // IMPORTANT
+      });
+
+      console.log(createdApplicants);
+    } catch (error: unknown) {
+      Logger.error(
+        `Failed to get dashboard. Reason = ${getErrorMessage(error)}`,
+      );
+      throw error;
+    }
+  }
+}
+
+export default ApplicantRecordService;

backend/typescript/services/interfaces/IApplicantRecordService.ts

@@ -0,0 +1,9 @@
+interface IApplicantRecordService {
+  /**
+   * Given a term, fetch all application data from Firebase and populate the database accordingly.
+   * @param term is the term we would like to populate
+   */
+  populateApplicantRecord(term: string): Promise<void>;
+}
+
+export default IApplicantRecordService;