fix: queue build

ufabc-next · Dec 28, 2023 · 8d48086 · 8d48086
1 parent 491b948
commit 8d48086
Show file tree

Hide file tree

Showing 2 changed files with 37 additions and 39 deletions.
diff --git a/apps/queue/src/helpers/resolveProfessors.ts b/apps/queue/src/helpers/resolveProfessors.ts
@@ -19,7 +19,7 @@ export function resolveProfessors(
     return null;
   }
   const isTeacherPresent = (t: Teacher) =>
-    t.name === normalizedName ?? (t.alias || []).includes(normalizedName);
+    t.name === normalizedName || (t.alias || []).includes(normalizedName);
   const foundTeacher = teachers.find((teacher) => isTeacherPresent(teacher));
 
   if (foundTeacher) {

diff --git a/apps/queue/src/jobs/enrollments/updateEnrollments.ts b/apps/queue/src/jobs/enrollments/updateEnrollments.ts
@@ -9,45 +9,44 @@ type UpdateEnrollments = {
 };
 
 function updateEnrollments(data: any) {
-  const data = payload.json;
   logger.info({ msg: 'qual a fitaaaaa', data });
-  // const updateEnrollment = async (enrollment: EnrollmentDocument) => {
-  //   const keys = ['ra', 'year', 'quad', 'disciplina'] as const;
+  const updateEnrollment = async (enrollment: EnrollmentDocument) => {
+    const keys = ['ra', 'year', 'quad', 'disciplina'] as const;
+    const enrollmentModel: any = {};
+    const key = {
+      ra: enrollment.ra,
+      year: enrollment.year,
+      quad: enrollment.quad,
+      disciplina: enrollment.disciplina,
+    };
 
-  //   const key = {
-  //     ra: enrollment.ra,
-  //     year: enrollment.year,
-  //     quad: enrollment.quad,
-  //     disciplina: enrollment.disciplina,
-  //   };
+    // TODO: remove any later
+    const identifier = generateIdentifier(key, keys as any);
 
-  //   // TODO: remove any later
-  //   const identifier = generateIdentifier(key, keys as any);
-
-  //   try {
-  //     const insertOpts = { new: true, upsert: true };
-  //     const {
-  //       ra,
-  //       year,
-  //       quad,
-  //       disciplina,
-  //       identifier: ignored,
-  //       _id,
-  //       ...updateData
-  //     } = enrollment;
-  //     // this piece of code right here is a MASSIVE query
-  //     // for the record: since its inserting it needs to be a document and being a document means
-  //     // it has and _id
-  //     await enrollmentModel.findOneAndUpdate(
-  //       { identifier },
-  //       { $set: updateData },
-  //       insertOpts,
-  //     );
-  //   } catch (error) {
-  //     logger.error(error);
-  //     throw error;
-  //   }
-  // };
+    try {
+      const insertOpts = { new: true, upsert: true };
+      const {
+        ra,
+        year,
+        quad,
+        disciplina,
+        identifier: ignored,
+        _id,
+        ...updateData
+      } = enrollment;
+      // this piece of code right here is a MASSIVE query
+      // for the record: since its inserting it needs to be a document and being a document means
+      // it has and _id
+      await enrollmentModel.findOneAndUpdate(
+        { identifier },
+        { $set: updateData },
+        insertOpts,
+      );
+    } catch (error) {
+      logger.error(error);
+      throw error;
+    }
+  };
 
   return asyncParallelMap(data, updateEnrollment, 10);
 }
@@ -57,14 +56,13 @@ export const updateEnrollmentsQueue = createQueue('Update:Enrollments');
 export const addEnrollmentsToQueue = async (
   payload: Job<UpdateEnrollments>,
 ) => {
-  logger.info({ msg: 'added to queu', payload });
   await updateEnrollmentsQueue.add('Update:Enrollments', payload);
 };
 
 export const updateEnrollmentsWorker = async (job: Job<UpdateEnrollments>) => {
   try {
     const payload = job.data;
-    updateEnrollments(payload).catch((error) => logger.info(error));
+    await updateEnrollments(payload);
   } catch (error) {
     logger.error(
       { error },