fix(task): add mattermost notifications bot

Author: Mihoub2

src/api/auth/auth.middlewares.js

@@ -46,6 +46,10 @@ export const signup = async (req, res, next) => {
   const { firstName, lastName, email } = body;
   agenda.now('send welcome email', { user: { firstName, lastName, email } });
   agenda.now('send user creation notification email', { user: { firstName, lastName } });
+  agenda.now(
+    'send mattermost notification',
+    { message: `:tada: Un nouvel utilisateur a été créé !\n**Nom :** ${firstName} ${lastName}\n**Email :** ${email}` },
+  );
   res.status(201).json({ message: 'Compte crée.' });
   return next();
 };

src/api/jobs/jobs.routes.js

@@ -15,7 +15,8 @@ function getDateXDaysAfter(x) {
   return new Date(Date.now() + x * 24 * 60 * 60 * 1000);
 }
 
-const SKIP_JOBS = ['send welcome email', 'send confirmed email', 'send signin email', 'send recovery email', 'send contact email'];
+const SKIP_JOBS = ['send mattermost notification',
+  'send welcome email', 'send confirmed email', 'send signin email', 'send recovery email', 'send contact email'];
 
 router.route('/jobs')
   .get([

src/jobs/index.js

@@ -1,19 +1,19 @@
-import os from "os";
-import { Agenda } from "agenda";
-import config from "../config";
-import logger from "../services/logger.service";
-import { db } from "../services/mongo.service";
-import askForEmailRevalidation from "./ask-for-email-validation";
+import os from 'os';
+import { Agenda } from 'agenda';
+import config from '../config';
+import logger from '../services/logger.service';
+import { db } from '../services/mongo.service';
+import askForEmailRevalidation from './ask-for-email-validation';
 import {
   sendAccountConfirmedEmail,
   sendAuthenticationEmail,
   sendContactEmail,
   sendNewUserNotificationEmail,
   sendPasswordRecoveryEmail,
   sendWelcomeEmail,
-} from "./emails";
-import reindex from "./indexer";
-import updateKeyNumbers from "./key-numbers";
+} from './emails';
+import reindex from './indexer';
+import updateKeyNumbers from './key-numbers';
 import {
   exportFrEsrAnnelisPaysageEtablissements,
   exportFrEsrPaysageFonctionsGourvernance,
@@ -22,118 +22,126 @@ import {
   exportFrEsrPrizes,
   exportFrEsrStructureIdentifiers,
   exportFrEsrStructureWebsites,
-} from "./opendata";
-import { monitorSiren, monitorSiret } from "./sirene";
-import synchronizeAnnuaireCollection from "./synchronize/annuaire-collection";
-import synchronizeCuriexploreActors from "./synchronize/curiexplore-actors";
-import synchronizeFrEsrReferentielGeographique from "./synchronize/fr-esr-referentiel-geographique";
-import deletePassedGouvernancePersonnalInformation from "./treatments/delete-passed-gouvernance-personal-infos";
-import { setStructureStatus, setIdentifierStatus } from "./treatments/set-statuses";
-import dedupLegalCategorySirene from "./dedup-legal-category-sirene";
+} from './opendata';
+import { monitorSiren, monitorSiret } from './sirene';
+import synchronizeAnnuaireCollection from './synchronize/annuaire-collection';
+import synchronizeCuriexploreActors from './synchronize/curiexplore-actors';
+import synchronizeFrEsrReferentielGeographique from './synchronize/fr-esr-referentiel-geographique';
+import deletePassedGouvernancePersonnalInformation from './treatments/delete-passed-gouvernance-personal-infos';
+import { setStructureStatus, setIdentifierStatus } from './treatments/set-statuses';
+import dedupLegalCategorySirene from './dedup-legal-category-sirene';
+import { sendMattermostNotification } from './send-mattermost-notification';
 
 const { taskName } = config.sirene;
 
 const agenda = new Agenda()
-  .mongo(db, "_jobs")
+  .mongo(db, '_jobs')
   .name(`worker-${os.hostname}-${process.pid}`)
-  .processEvery("30 seconds");
+  .processEvery('30 seconds');
 
 agenda.define(
-  "send user creation notification email",
+  'send user creation notification email',
   { shouldSaveResult: true },
   sendNewUserNotificationEmail,
 );
 agenda.define(
-  "send welcome email",
+  'send welcome email',
   { shouldSaveResult: true },
   sendWelcomeEmail,
 );
 agenda.define(
-  "send confirmed email",
+  'send confirmed email',
   { shouldSaveResult: true },
   sendAccountConfirmedEmail,
 );
 agenda.define(
-  "send signin email",
+  'send signin email',
   { shouldSaveResult: true },
   sendAuthenticationEmail,
 );
 agenda.define(
-  "send recovery email",
+  'send recovery email',
   { shouldSaveResult: true },
   sendPasswordRecoveryEmail,
 );
 agenda.define(
-  "send contact email",
+  'send contact email',
   { shouldSaveResult: true },
   sendContactEmail,
 );
 agenda.define(
-  "update key numbers",
+  'send mattermost notification',
+  { shouldSaveResult: true },
+  sendMattermostNotification,
+);
+
+agenda.define(
+  'update key numbers',
   {
     shouldSaveResult: true,
     lockLifetime: 1000 * 60 * 60 * 5,
   },
   updateKeyNumbers,
 );
-agenda.define("reindex", { shouldSaveResult: true }, reindex);
+agenda.define('reindex', { shouldSaveResult: true }, reindex);
 agenda.define(
-  "export fr-esr-paysage_prix",
+  'export fr-esr-paysage_prix',
   { shouldSaveResult: true },
   exportFrEsrPrizes,
 );
 agenda.define(
-  "export fr-esr-paysage_structures_identifiants",
+  'export fr-esr-paysage_structures_identifiants',
   { shouldSaveResult: true },
   exportFrEsrStructureIdentifiers,
 );
 agenda.define(
-  "export fr-esr-paysage_personnes_identifiants",
+  'export fr-esr-paysage_personnes_identifiants',
   { shouldSaveResult: true },
   exportFrEsrPersonIdentifiers,
 );
 agenda.define(
-  "export fr-esr-paysage-fonctions-gourvernance",
+  'export fr-esr-paysage-fonctions-gourvernance',
   { shouldSaveResult: true },
   exportFrEsrPaysageFonctionsGourvernance,
 );
+
 agenda.define(
-  "export fr-esr-annelis-paysage-etablissements",
+  'export fr-esr-annelis-paysage-etablissements',
   { shouldSaveResult: true },
   exportFrEsrAnnelisPaysageEtablissements,
 );
 agenda.define(
-  "export fr-esr-paysage_structures_websites",
+  'export fr-esr-paysage_structures_websites',
   { shouldSaveResult: true },
   exportFrEsrStructureWebsites,
 );
 agenda.define(
-  "export fr_esr_paysage_laureat_all",
+  'export fr_esr_paysage_laureat_all',
   { shouldSaveResult: true },
   exportFrEsrPaysageLaureatAll,
 );
 agenda.define(
-  "synchronize fr-esr-referentiel-geographique",
+  'synchronize fr-esr-referentiel-geographique',
   { shouldSaveResult: true },
   synchronizeFrEsrReferentielGeographique,
 );
 agenda.define(
-  "synchronize curiexplore actors",
+  'synchronize curiexplore actors',
   { shouldSaveResult: true },
   synchronizeCuriexploreActors,
 );
 agenda.define(
-  "ask for email revalidation with otp",
+  'ask for email revalidation with otp',
   { shouldSaveResult: true },
   askForEmailRevalidation,
 );
 agenda.define(
-  "delete passed gouvernance personal info",
+  'delete passed gouvernance personal info',
   { shouldSaveResult: true },
   deletePassedGouvernancePersonnalInformation,
 );
 agenda.define(
-  "synchronize governance collection",
+  'synchronize governance collection',
   { shouldSaveResult: true },
   synchronizeAnnuaireCollection,
 );
@@ -148,7 +156,7 @@ agenda.define(
   setIdentifierStatus,
 );
 agenda.define(
-  "check de double catégories juridiques pour une unité légale",
+  'check de double catégories juridiques pour une unité légale',
   { shouldSaveResult: true },
   dedupLegalCategorySirene,
 );
@@ -170,18 +178,18 @@ agenda.define(
 );
 
 agenda
-  .on("ready", () => {
-    logger.info("Agenda connected to mongodb");
+  .on('ready', () => {
+    logger.info('Agenda connected to mongodb');
   })
-  .on("error", () => {
-    logger.info("Agenda connexion to mongodb failed");
+  .on('error', () => {
+    logger.info('Agenda connexion to mongodb failed');
   });
 
-agenda.on("complete", async (job) => {
-  if (job.attrs?.type !== "single") return null;
+agenda.on('complete', async (job) => {
+  if (job.attrs?.type !== 'single') return null;
 
-  const keepFailureFields = job.attrs.failedAt &&
-    job.attrs.failedAt === job.attrs.lastFinishedAt;
+  const keepFailureFields = job.attrs.failedAt
+    && job.attrs.failedAt === job.attrs.lastFinishedAt;
 
   const {
     _id,
@@ -197,20 +205,20 @@ agenda.on("complete", async (job) => {
     ...rest
   } = job.attrs;
 
-  return db.collection("_jobs").insertOne({
+  return db.collection('_jobs').insertOne({
     ...(keepFailureFields ? { failedAt, failReason, failCount } : {}),
     ...rest,
-    type: "normal",
+    type: 'normal',
   });
 });
 
 async function graceful() {
-  logger.info("Gracefully stopping agenda");
+  logger.info('Gracefully stopping agenda');
   await agenda.stop();
   process.exit(0);
 }
 
-process.on("SIGTERM", graceful);
-process.on("SIGINT", graceful);
+process.on('SIGTERM', graceful);
+process.on('SIGINT', graceful);
 
 export default agenda;

src/jobs/send-mattermost-notification.js

@@ -0,0 +1,24 @@
+export const sendMattermostNotification = async (job) => {
+  const { message } = job.attrs.data;
+  const MATTERMOST_WEBHOOK_URL = process.env.MM_WEBHOOK_URL;
+  const MATTERMOST_CHANNEL = process.env.MM_CHANNEL;
+  const { BOT_ICON_URL } = process.env;
+
+  if (!MATTERMOST_WEBHOOK_URL || !MATTERMOST_CHANNEL) return;
+
+  try {
+    await fetch(MATTERMOST_WEBHOOK_URL, {
+      method: 'POST',
+      headers: { 'Content-Type': 'application/json' },
+      body: JSON.stringify({
+        channel: MATTERMOST_CHANNEL,
+        text: message,
+        username: 'Bot-Anic le robot paysagiste',
+        icon_url: BOT_ICON_URL,
+      }),
+    });
+  } catch (error) {
+    // eslint-disable-next-line no-console
+    console.error('Error sending Mattermost notification', error);
+  }
+};