betagouv/service-national-universel

const { ReferentModel } = require("../models");
const { sendTemplate } = require("../brevo");
const { capture } = require("../sentry");
const slack = require("../slack");
const { SENDINBLUE_TEMPLATES } = require("snu-lib");

const diffDays = (date1, date2) => {
  const diffTime = Math.abs(date2 - date1);
  const diffDays = Math.floor(diffTime / (1000 * 60 * 60 * 24));
  return diffDays;
};

exports.handler = async () => {
  try {
    const now = new Date();
    const sixMonthsAgo = now.setMonth(now.getMonth() - 6);
    const cursor = ReferentModel.find({
      role: { $in: ["referent_department", "referent_region"] },
      $or: [{ lastLoginAt: { $lte: sixMonthsAgo } }, { lastLoginAt: null, createdAt: { $lte: sixMonthsAgo } }],
    }).cursor();
    await cursor.eachAsync(async function (ref) {
      const lastLogin = ref.lastLoginAt === null ? ref.createdAt : ref.lastLoginAt;
      const emailTo = [{ name: `${ref.firstName} ${ref.lastName}`, email: ref.email }];
      if (diffDays(lastLogin, sixMonthsAgo) === 0) {
        await sendTemplate(SENDINBLUE_TEMPLATES.referent.DELETE_ACCOUNT_NOTIFICATION_1, { emailTo });
      }
      if (diffDays(lastLogin, sixMonthsAgo) === 7) {
        await sendTemplate(SENDINBLUE_TEMPLATES.referent.DELETE_ACCOUNT_NOTIFICATION_2, { emailTo });
      }
      if (diffDays(lastLogin, sixMonthsAgo) >= 14) {
        await ref.remove();
        slack.info({ title: "Referent deleted", text: `Ref ${ref.email} has been deleted` });
      }
    });
  } catch (e) {
    capture(e);
    slack.error({ title: "Delete inactive refs", text: JSON.stringify(e) });
    throw e;
  }
};