feat: send projet creation email

prisma/migrations/20241210154607_add_email_template/migration.sql

@@ -0,0 +1,10 @@
+-- AlterEnum
+-- This migration adds more than one value to an enum.
+-- With PostgreSQL versions 11 and earlier, this is not possible
+-- in a single migration. This can be worked around by creating
+-- multiple migrations, each migration adding only one value to
+-- the enum.
+
+
+ALTER TYPE "emailType" ADD VALUE 'projetCreationRandomRex';
+ALTER TYPE "emailType" ADD VALUE 'projetCreationFixedRex';

prisma/migrations/20241211100239_change_email_type_for_projet_creation/migration.sql

@@ -0,0 +1,14 @@
+/*
+  Warnings:
+
+  - The values [projetCreationRandomRex,projetCreationFixedRex] on the enum `emailType` will be removed. If these variants are still used in the database, this will fail.
+
+*/
+-- AlterEnum
+BEGIN;
+CREATE TYPE "emailType_new" AS ENUM ('projetCreation', 'projetInvitation', 'projetRequestAccess', 'projetAccessGranted', 'projetAccessDeclined', 'contactMessageSent', 'welcomeMessage');
+ALTER TABLE "email" ALTER COLUMN "type" TYPE "emailType_new" USING ("type"::text::"emailType_new");
+ALTER TYPE "emailType" RENAME TO "emailType_old";
+ALTER TYPE "emailType_new" RENAME TO "emailType";
+DROP TYPE "emailType_old";
+COMMIT;

prisma/schema.prisma

@@ -125,6 +125,7 @@ model user_projet {
 }
 
 enum emailType {
+  projetCreation
   projetInvitation
   projetRequestAccess
   projetAccessGranted

scripts/send-csm-emails.ts

@@ -0,0 +1,17 @@
+import { customCaptureException } from "@/src/lib/sentry/sentryCustomMessage";
+import { EmailService } from "@/src/services/brevo";
+
+const sendCsmEmails = async () => {
+  try {
+    if (process.env.SEND_CSM_EMAILS !== "true") {
+      console.log("L'envoi de mail CSM est désactivé pour cet environnement'.");
+    } else {
+      await new EmailService().sendProjetCreationEmail();
+    }
+  } catch (error) {
+    customCaptureException("Erreur lors du batch d'envoi des mails CSM.", error);
+    process.exit(1);
+  }
+};
+
+sendCsmEmails();

src/helpers/dateUtils.ts

@@ -2,6 +2,8 @@ import type { Attribute } from "@strapi/strapi";
 
 export const FAR_FUTURE = new Date(3024, 0, 0, 1);
 
+export const removeDaysToDate = (date: Date, nbDays: number) => new Date(date.getTime() - nbDays * 24 * 60 * 60 * 1000);
+
 export function monthDateToString(value: Date | null | undefined): string {
   return value ? `${value.getFullYear()}-${("0" + (value.getMonth() + 1)).slice(-2)}` : "";
 }

src/helpers/routes.ts

@@ -6,6 +6,7 @@ export const PFMV_ROUTES = {
   FICHES_DIAGNOSTIC: "/fiches-diagnostic",
   MES_FICHES_SOLUTIONS: "/mon-projet/favoris",
   RETOURS_EXPERIENCE: "/projet",
+  RETOUR_EXPERIENCE: (slug: string) => `${PFMV_ROUTES.RETOURS_EXPERIENCE}/${slug}`,
   CONTACT: "/contact",
   CONTACT_SUCCESS: "/contact/success",
   NEWSLETTER: "/newsletter",
@@ -45,6 +46,8 @@ export const PFMV_ROUTES = {
     `/espace-projet/${projetId}/financement/edit/${estimationId}`,
 };
 
+export const getFullUrl = (route: string): string => `${process.env.NEXT_PUBLIC_URL_SITE}${route}`;
+
 export const GET_AIDES_TERRITOIRES_BY_AIDE_ID_URL = (aideId: number) =>
   `/api/get-aides-territoires-aide-by-aide-id?aideId=${aideId}`;
 

src/lib/prisma/prismaProjetQueries.ts

@@ -1,5 +1,5 @@
 import { prismaClient } from "@/src/lib/prisma/prismaClient";
-import { InvitationStatus, Prisma, projet, RoleProjet, user_projet } from "@prisma/client";
+import { emailType, InvitationStatus, Prisma, projet, RoleProjet, user_projet } from "@prisma/client";
 import { ProjetWithPublicRelations, ProjetWithRelations } from "./prismaCustomTypes";
 import { generateRandomId } from "@/src/helpers/common";
 import { GeoJsonProperties } from "geojson";
@@ -443,3 +443,32 @@ export const updateProjetVisibility = async (
     include: projetIncludes,
   });
 };
+
+export const getProjetsForProjetCreationEmail = async (
+  afterDate: Date,
+  beforeDate: Date,
+): Promise<ProjetWithRelations[]> => {
+  return prismaClient.projet.findMany({
+    where: {
+      deleted_at: null,
+      created_at: {
+        gte: afterDate,
+        lte: beforeDate,
+      },
+      NOT: {
+        users: {
+          some: {
+            role: "ADMIN",
+            email: {
+              some: {
+                type: emailType.projetCreation,
+                email_status: "SUCCESS",
+              },
+            },
+          },
+        },
+      },
+    },
+    include: projetIncludes,
+  });
+};

src/services/brevo/index.ts

@@ -4,10 +4,15 @@ import { brevoSendEmail } from "./brevo-api";
 import { ResponseAction } from "@/src/actions/actions-types";
 import { getOldestProjectAdmin } from "@/src/lib/prisma/prisma-user-projet-queries";
 import { captureError } from "@/src/lib/sentry/sentryCustomMessage";
-import { UserProjetWithRelations, UserWithCollectivite } from "@/src/lib/prisma/prismaCustomTypes";
+import { ProjetWithRelations, UserProjetWithRelations, UserWithCollectivite } from "@/src/lib/prisma/prismaCustomTypes";
 import { getPrimaryCollectiviteForUser } from "@/src/helpers/user";
-import { PFMV_ROUTES } from "@/src/helpers/routes";
+import { getFullUrl, PFMV_ROUTES } from "@/src/helpers/routes";
 import { ContactFormData } from "@/src/forms/contact/contact-form-schema";
+import { getProjetsForProjetCreationEmail } from "@/src/lib/prisma/prismaProjetQueries";
+import { removeDaysToDate } from "@/src/helpers/dateUtils";
+import { getRetoursExperiences } from "@/src/lib/strapi/queries/retoursExperienceQueries";
+import { RetourExperienceResponse } from "@/src/components/ficheSolution/type";
+import shuffle from "lodash/shuffle";
 
 interface Templates {
   templateId: number;
@@ -24,6 +29,44 @@ export type EmailProjetPartageConfig = {
   destinationMail: string;
 };
 
+export type EmailProjetCreationParam = {
+  nomUtilisateur: string;
+  nomProjet: string;
+  rex1Titre?: string;
+  rex1Url?: string;
+  rex2Titre?: string;
+  rex2Url?: string;
+  rex3Titre?: string;
+  rex3Url?: string;
+  rex4Titre?: string;
+  rex4Url?: string;
+};
+
+const computeProjetCreationEmailParam = (
+  projet: ProjetWithRelations,
+  rexExamples: RetourExperienceResponse[],
+): EmailProjetCreationParam => {
+  if (rexExamples.length < 3) {
+    return {
+      nomProjet: projet.nom,
+      nomUtilisateur: projet.creator.nom || "",
+    };
+  } else {
+    return {
+      nomProjet: projet.nom,
+      nomUtilisateur: projet.creator.nom || "",
+      rex1Titre: rexExamples[0].attributes.titre,
+      rex1Url: getFullUrl(PFMV_ROUTES.RETOUR_EXPERIENCE(rexExamples[0].attributes.slug)),
+      rex2Titre: rexExamples[1].attributes.titre,
+      rex2Url: getFullUrl(PFMV_ROUTES.RETOUR_EXPERIENCE(rexExamples[1].attributes.slug)),
+      rex3Titre: rexExamples[2].attributes.titre,
+      rex3Url: getFullUrl(PFMV_ROUTES.RETOUR_EXPERIENCE(rexExamples[2].attributes.slug)),
+      rex4Titre: rexExamples[3]?.attributes.titre,
+      ...(rexExamples[3] && { rex4Url: getFullUrl(PFMV_ROUTES.RETOUR_EXPERIENCE(rexExamples[3]?.attributes.slug)) }),
+    };
+  }
+};
+
 export class EmailService {
   private readonly templates: Record<emailType, Templates>;
 
@@ -47,6 +90,9 @@ export class EmailService {
       welcomeMessage: {
         templateId: 52,
       },
+      projetCreation: {
+        templateId: 54,
+      },
     };
   }
 
@@ -79,8 +125,7 @@ export class EmailService {
 
       const data = await response.json();
 
-      let email = null;
-      email = await this.updateEmailStatus(dbEmail.id, emailStatus.SUCCESS, data.messageId);
+      const email = await this.updateEmailStatus(dbEmail.id, emailStatus.SUCCESS, data.messageId);
 
       return { type: "success", message: "EMAIL_SENT", email };
     } catch (error) {
@@ -173,4 +218,30 @@ export class EmailService {
       extra: data,
     });
   }
+
+  async sendProjetCreationEmail(lastSyncDate?: Date) {
+    const projets = await getProjetsForProjetCreationEmail(
+      removeDaysToDate(lastSyncDate || new Date(), 3),
+      removeDaysToDate(new Date(), 1),
+    );
+    console.log(`Nb de mails de création de projet à envoyer : ${projets.length}`);
+    const allRex = await getRetoursExperiences();
+    const shuffledRex = shuffle(allRex);
+    return await Promise.all(
+      projets.map(async (projet) => {
+        const rexExamples = shuffledRex
+          // @ts-ignore
+          .filter((rex) => rex.attributes.types_espaces?.includes(projet.type_espace))
+          .slice(0, 4);
+        const emailParams = computeProjetCreationEmailParam(projet, rexExamples);
+        return await this.sendEmail({
+          to: projet.creator.email,
+          emailType: emailType.projetCreation,
+          params: emailParams,
+          extra: emailParams,
+          userProjetId: projet.users.find((up) => up.role === "ADMIN")?.id,
+        });
+      }),
+    );
+  }
 }