feat: restore applications anonymization standalone job (#1731)

* feat: restore applications anonymization standalone job

* fix: typo

Author: kevbarns

server/src/jobs/anonymization/anonymizeApplicantAndApplications.ts

@@ -77,7 +77,7 @@ const anonymize = async () => {
 }
 
 export const anonymizeApplicantsAndApplications = async function () {
-  logger.info("[START] Anonymisation des candidatures de plus de deux (2) ans")
+  logger.info("[START] Anonymisation des candidats & leurs candidatures de plus de deux (2) ans")
   try {
     const [anonymizedApplication, anonymizedApplicant] = await anonymize()
 
@@ -89,5 +89,5 @@ export const anonymizeApplicantsAndApplications = async function () {
     await notifyToSlack({ subject: "ANONYMISATION CANDIDATS & CANDIDATURES", message: `ECHEC anonymisation des candidats & candidatures`, error: true })
     throw err
   }
-  logger.info("[END] Anonymisation des candidatures de plus de deux (2) ans")
+  logger.info("[END] Anonymisation des candidats & leurs candidatures de plus de deux (2) ans")
 }

server/src/jobs/anonymization/anonymizeApplications.ts

@@ -0,0 +1,57 @@
+import { logger } from "../../common/logger"
+import { getDbCollection } from "../../common/utils/mongodbUtils"
+import { notifyToSlack } from "../../common/utils/slackUtils"
+
+const anonymize = async () => {
+  logger.info(`Début anonymisation`)
+
+  const period = new Date()
+  period.setFullYear(period.getFullYear() - 2)
+
+  const matchCondition = { created_at: { $lte: period } }
+
+  await getDbCollection("applications")
+    .aggregate([
+      {
+        $match: matchCondition,
+      },
+      {
+        $project: {
+          company_recruitment_intention: 1,
+          company_feedback_date: 1,
+          company_siret: 1,
+          company_naf: 1,
+          job_origin: 1,
+          job_id: 1,
+          caller: 1,
+          created_at: 1,
+          applicant_id: 1,
+        },
+      },
+      {
+        $merge: "anonymizedapplications",
+      },
+    ])
+    .toArray()
+
+  const res = await getDbCollection("applications").deleteMany(matchCondition)
+
+  return res.deletedCount
+}
+
+export const anonymizeApplications = async function () {
+  try {
+    logger.info("[START] Anonymisation des candidatures de plus de deux (2) ans")
+
+    const anonymizedApplicationCount = await anonymize()
+
+    await notifyToSlack({
+      subject: "ANONYMISATION CANDIDATURES",
+      message: `Anonymisation des candidatures de plus de deux (2) an terminée. ${anonymizedApplicationCount} candidature(s) anonymisée(s).`,
+    })
+  } catch (err: any) {
+    await notifyToSlack({ subject: "ANONYMISATION CANDIDATURES", message: `ECHEC anonymisation des candidatures`, error: true })
+    throw err
+  }
+  logger.info("[END] Anonymisation des candidatures de plus de deux (2) ans")
+}

server/src/jobs/jobs.ts

@@ -10,6 +10,7 @@ import { getDatabase } from "../common/utils/mongodbUtils"
 import config from "../config"
 
 import { anonymizeApplicantsAndApplications } from "./anonymization/anonymizeApplicantAndApplications"
+import { anonymizeApplications } from "./anonymization/anonymizeApplications"
 import anonymizeAppointments from "./anonymization/anonymizeAppointments"
 import anonymizeIndividual from "./anonymization/anonymizeIndividual"
 import { anonimizeUsersWithAccounts } from "./anonymization/anonymizeUserRecruteurs"
@@ -150,10 +151,6 @@ export async function setupJobProcessor() {
             cron_string: "5 0 * * *",
             handler: () => updateBrevoBlockedEmails({}),
           },
-          "Anonymise les candidatures de plus de deux an": {
-            cron_string: "10 0 * * *",
-            handler: anonymizeApplicantsAndApplications,
-          },
           "Géolocation de masse des sociétés issues de l'algo": {
             cron_string: "0 5 * * 6",
             handler: () => updateGeoLocations({}),
@@ -166,10 +163,6 @@ export async function setupJobProcessor() {
             cron_string: "0 5 * * 7",
             handler: () => updateLbaCompanies({ useAlgoFile: true, clearMongo: true }),
           },
-          "Anonimisation des utilisateurs n'ayant effectué aucun rendez-vous de plus de 2 ans": {
-            cron_string: "5 1 * * *",
-            handler: anonymizeUsers,
-          },
           "Contrôle quotidien des candidatures": {
             cron_string: "0 10-19/1 * * 1-5",
             handler: config.env === "production" ? () => controlApplications() : () => Promise.resolve(0),
@@ -178,11 +171,23 @@ export async function setupJobProcessor() {
             cron_string: "0 11-19/2 * * 1-5",
             handler: config.env === "production" ? () => controlAppointments() : () => Promise.resolve(0),
           },
-          "Anonymisation des user recruteurs de plus de 2 ans": {
+          "Anonymisation des candidatures de plus de deux (2) ans": {
+            cron_string: "15 0 * * *",
+            handler: anonymizeApplications,
+          },
+          "Anonymisation des candidats & leurs candidatures de plus de deux (2) ans": {
+            cron_string: "10 0 * * *",
+            handler: anonymizeApplicantsAndApplications,
+          },
+          "Anonimisation des utilisateurs RDVA de plus de deux (2) ans": {
+            cron_string: "5 1 * * *",
+            handler: anonymizeUsers,
+          },
+          "Anonymisation des user recruteurs de plus de deux (2) ans": {
             cron_string: "0 1 * * *",
             handler: anonimizeUsersWithAccounts,
           },
-          "Anonymisation des appointments de plus de 2 ans": {
+          "Anonymisation des appointments de plus de deux (2) ans": {
             cron_string: "30 1 * * *",
             handler: anonymizeAppointments,
           },