♻️ Ajouter validateur dans l'event NotifierCandidature

packages/applications/document-builder/src/candidature/attestation/attestation.saga.ts

@@ -24,6 +24,7 @@ export const register = () => {
         notifiéePar,
       },
     } = event;
+
     switch (event.type) {
       case 'CandidatureNotifiée-V1':
         const candidature = await mediator.send<Candidature.ConsulterCandidatureQuery>({

packages/applications/projectors/src/subscribers/candidature/candidature.projector.ts

@@ -72,7 +72,11 @@ export const register = () => {
               notification: {
                 estNotifiée: true,
                 notifiéeLe: payload.notifiéeLe,
-                notifiéePar: payload.notifiéePar,
+                notifiéePar: {
+                  email: payload.notifiéePar,
+                  fonction: payload.validateur.fonction,
+                  nomComplet: payload.validateur.nomComplet,
+                },
               },
             },
           );

packages/applications/scheduled-tasks/src/candidature/create-events-candidature-notifiée.ts

@@ -5,18 +5,37 @@ import { Candidature } from '@potentiel-domain/candidature';
 import { listProjection } from '@potentiel-infrastructure/pg-projections';
 import { Lauréat } from '@potentiel-domain/laureat';
 import { loadAggregate } from '@potentiel-infrastructure/pg-event-sourcing';
+import { ConsulterUtilisateurQuery } from '@potentiel-domain/utilisateur';
+import { Option } from '@potentiel-libraries/monads';
 
 Candidature.registerCandidaturesUseCases({ loadAggregate });
 
 (async () => {
   console.log('✨ Migration Candidature Notifiée');
+
   const lauréats = await listProjection<Lauréat.LauréatEntity>('lauréat');
   const éliminés = await listProjection<Éliminé.ÉliminéEntity>('éliminé');
   const all = [...lauréats.items, ...éliminés.items];
 
   console.log(`ℹ️ ${all.length} éléments trouvés`);
 
   for (const { identifiantProjet, attestation, notifiéLe, notifiéPar } of all) {
+    console.log(`Get détails on notifiéPar for ${identifiantProjet}`);
+    const utilisateur = await mediator.send<ConsulterUtilisateurQuery>({
+      type: 'Utilisateur.Query.ConsulterUtilisateur',
+      data: {
+        identifiantUtilisateur: notifiéPar,
+      },
+    });
+
+    if (Option.isNone(utilisateur)) {
+      console.warn(`Utilisateur non trouvé`, {
+        identifiantProjet,
+        identifiantUtilisateur: notifiéPar,
+      });
+      return;
+    }
+
     console.log(`Publish NotifierCandidature pour ${identifiantProjet}`);
     await mediator.publish<Candidature.NotifierCandidatureUseCase>({
       type: 'Candidature.UseCase.NotifierCandidature',
@@ -25,6 +44,10 @@ Candidature.registerCandidaturesUseCases({ loadAggregate });
         attestationValue: { format: attestation.format },
         notifiéeLeValue: notifiéLe,
         notifiéeParValue: notifiéPar,
+        validateurValue: {
+          fonction: utilisateur.fonction,
+          nomComplet: utilisateur.nomComplet,
+        },
       },
     });
   }

packages/applications/ssr/src/components/pages/période/notifier/notifierPériode.action.ts

@@ -2,12 +2,15 @@
 
 import * as zod from 'zod';
 import { mediator } from 'mediateur';
+import { notFound } from 'next/navigation';
 
 import { DateTime } from '@potentiel-domain/common';
 import { Candidature } from '@potentiel-domain/candidature';
 import { Période } from '@potentiel-domain/periode';
 import { IdentifiantPériode } from '@potentiel-domain/periode/dist/période';
 import { Routes } from '@potentiel-applications/routes';
+import { ConsulterUtilisateurQuery } from '@potentiel-domain/utilisateur';
+import { Option } from '@potentiel-libraries/monads';
 
 import { FormAction, formAction, FormState } from '@/utils/formAction';
 import { withUtilisateur } from '@/utils/withUtilisateur';
@@ -30,12 +33,27 @@ const action: FormAction<FormState, typeof schema> = async (_, { appelOffre, per
       },
     });
 
+    const utilisateurDetails = await mediator.send<ConsulterUtilisateurQuery>({
+      type: 'Utilisateur.Query.ConsulterUtilisateur',
+      data: {
+        identifiantUtilisateur: utilisateur.identifiantUtilisateur.formatter(),
+      },
+    });
+
+    if (Option.isNone(utilisateurDetails)) {
+      return notFound();
+    }
+
     await mediator.send<Période.NotifierPériodeUseCase>({
       type: 'Période.UseCase.NotifierPériode',
       data: {
         identifiantPériodeValue,
         notifiéeLeValue: DateTime.now().formatter(),
         notifiéeParValue: utilisateur.identifiantUtilisateur.formatter(),
+        validateurValue: {
+          fonction: utilisateurDetails.fonction,
+          nomComplet: utilisateurDetails.nomComplet,
+        },
         identifiantCandidatureValues: candidatures.items.map((candidatures) =>
           candidatures.identifiantProjet.formatter(),
         ),

packages/domain/candidature/src/candidature.entity.ts

@@ -41,7 +41,11 @@ export type CandidatureEntity = Entity<
     notification?: {
       estNotifiée: true;
       notifiéeLe: DateTime.RawType;
-      notifiéePar: Email.RawType;
+      notifiéePar: {
+        email: Email.RawType;
+        fonction: string;
+        nomComplet: string;
+      };
     };
   }
 >;

packages/domain/candidature/src/consulter/consulterCandidature.query.ts

@@ -45,6 +45,10 @@ export type ConsulterCandidatureReadModel = {
   notification?: {
     notifiéeLe: DateTime.ValueType;
     notifiéePar: Email.ValueType;
+    validateur: {
+      fonction: string;
+      nomComplet: string;
+    };
   };
 };
 
@@ -129,6 +133,10 @@ export const mapToReadModel = ({
   ),
   notification: notification && {
     notifiéeLe: DateTime.convertirEnValueType(notification.notifiéeLe),
-    notifiéePar: Email.convertirEnValueType(notification.notifiéePar),
+    notifiéePar: Email.convertirEnValueType(notification.notifiéePar.email),
+    validateur: {
+      fonction: notification.notifiéePar.fonction,
+      nomComplet: notification.notifiéePar.nomComplet,
+    },
   },
 });

packages/domain/candidature/src/notifier/notifierCandidature.behavior.ts

@@ -7,6 +7,10 @@ export type NotifierOptions = {
   identifiantProjet: IdentifiantProjet.ValueType;
   notifiéeLe: DateTime.ValueType;
   notifiéePar: Email.ValueType;
+  validateur: {
+    fonction: string;
+    nomComplet: string;
+  };
   attestation: {
     format: string;
   };
@@ -18,7 +22,10 @@ export type CandidatureNotifiéeEvent = DomainEvent<
     identifiantProjet: IdentifiantProjet.RawType;
     notifiéeLe: DateTime.RawType;
     notifiéePar: Email.RawType;
-
+    validateur: {
+      fonction: string;
+      nomComplet: string;
+    };
     attestation: {
       format: string;
     };
@@ -27,17 +34,25 @@ export type CandidatureNotifiéeEvent = DomainEvent<
 
 export async function notifier(
   this: CandidatureAggregate,
-  { identifiantProjet, notifiéeLe, notifiéePar, attestation: { format } }: NotifierOptions,
+  {
+    identifiantProjet,
+    notifiéeLe,
+    notifiéePar,
+    validateur,
+    attestation: { format },
+  }: NotifierOptions,
 ) {
   if (this.estNotifiée) {
     throw new CandidatureDéjàNotifiéeError(identifiantProjet);
   }
+
   const event: CandidatureNotifiéeEvent = {
     type: 'CandidatureNotifiée-V1',
     payload: {
       identifiantProjet: identifiantProjet.formatter(),
       notifiéeLe: notifiéeLe.formatter(),
       notifiéePar: notifiéePar.formatter(),
+      validateur,
       attestation: {
         format,
       },

packages/domain/candidature/src/notifier/notifierCandidature.command.ts

@@ -11,6 +11,10 @@ export type NotifierCandidatureCommand = Message<
     identifiantProjet: IdentifiantProjet.ValueType;
     notifiéeLe: DateTime.ValueType;
     notifiéePar: Email.ValueType;
+    validateur: {
+      fonction: string;
+      nomComplet: string;
+    };
     attestation: { format: string };
   }
 >;

packages/domain/candidature/src/notifier/notifierCandidature.usecase.ts

@@ -10,6 +10,10 @@ export type NotifierCandidatureUseCase = Message<
     identifiantProjetValue: string;
     notifiéeLeValue: string;
     notifiéeParValue: string;
+    validateurValue: {
+      fonction: string;
+      nomComplet: string;
+    };
     attestationValue: {
       format: string;
     };
@@ -21,6 +25,7 @@ export const registerNotifierCandidatureUseCase = () => {
     identifiantProjetValue,
     notifiéeParValue,
     notifiéeLeValue,
+    validateurValue,
     attestationValue: { format },
   }) => {
     await mediator.send<NotifierCandidatureCommand>({
@@ -29,6 +34,7 @@ export const registerNotifierCandidatureUseCase = () => {
         identifiantProjet: IdentifiantProjet.convertirEnValueType(identifiantProjetValue),
         notifiéeLe: DateTime.convertirEnValueType(notifiéeLeValue),
         notifiéePar: Email.convertirEnValueType(notifiéeParValue),
+        validateur: validateurValue,
         attestation: { format },
       },
     });

packages/domain/lauréat/src/notifier/notifierLauréat.usecase.ts

@@ -11,6 +11,10 @@ export type NotifierLauréatUseCase = Message<
     identifiantProjetValue: string;
     notifiéLeValue: string;
     notifiéParValue: string;
+    validateurValue: {
+      fonction: string;
+      nomComplet: string;
+    };
     attestationValue: {
       format: string;
     };
@@ -22,6 +26,7 @@ export const registerNotifierLauréatUseCase = () => {
     identifiantProjetValue,
     notifiéParValue,
     notifiéLeValue,
+    validateurValue,
     attestationValue: { format },
   }) => {
     await mediator.send<Candidature.NotifierCandidatureUseCase>({
@@ -30,6 +35,7 @@ export const registerNotifierLauréatUseCase = () => {
         identifiantProjetValue,
         notifiéeLeValue: notifiéLeValue,
         notifiéeParValue: notifiéParValue,
+        validateurValue,
         attestationValue: {
           format: 'application/pdf',
         },

packages/domain/période/src/notifier/notifierPériode.command.ts

@@ -16,6 +16,10 @@ export type NotifierPériodeCommand = Message<
     identifiantPériode: IdentifiantPériode.ValueType;
     notifiéeLe: DateTime.ValueType;
     notifiéePar: Email.ValueType;
+    validateur: {
+      fonction: string;
+      nomComplet: string;
+    };
     identifiantCandidatures: ReadonlyArray<IdentifiantProjet.ValueType>;
   }
 >;
@@ -28,6 +32,7 @@ export const registerNotifierPériodeCommand = (loadAggregate: LoadAggregate) =>
     identifiantPériode,
     notifiéeLe,
     notifiéePar,
+    validateur,
     identifiantCandidatures,
   }) => {
     const identifiantLauréats: Array<IdentifiantProjet.ValueType> = [];
@@ -38,12 +43,14 @@ export const registerNotifierPériodeCommand = (loadAggregate: LoadAggregate) =>
 
       try {
         if (candidature.statut?.estClassé()) {
+          // TODO: devrait être appelé dans le usecase NotifierPériode
           await mediator.send<Lauréat.NotifierLauréatUseCase>({
             type: 'Lauréat.UseCase.NotifierLauréat',
             data: {
               identifiantProjetValue: identifiantCandidature.formatter(),
               notifiéLeValue: notifiéeLe.formatter(),
               notifiéParValue: notifiéePar.formatter(),
+              validateurValue: validateur,
               attestationValue: {
                 format: 'application/pdf',
               },
@@ -54,12 +61,14 @@ export const registerNotifierPériodeCommand = (loadAggregate: LoadAggregate) =>
         }
 
         if (candidature.statut?.estÉliminé()) {
+          // TODO: devrait être appelé dans le usecase NotifierPériode
           await mediator.send<Éliminé.NotifierÉliminéUseCase>({
             type: 'Éliminé.UseCase.NotifierÉliminé',
             data: {
               identifiantProjetValue: identifiantCandidature.formatter(),
               notifiéLeValue: notifiéeLe.formatter(),
               notifiéParValue: notifiéePar.formatter(),
+              validateurValue: validateur,
               attestationValue: {
                 format: 'application/pdf',
               },

packages/domain/période/src/notifier/notifierPériode.usecase.ts

@@ -12,6 +12,10 @@ export type NotifierPériodeUseCase = Message<
     identifiantPériodeValue: IdentifiantPériode.RawType;
     notifiéeLeValue: DateTime.RawType;
     notifiéeParValue: Email.RawType;
+    validateurValue: {
+      fonction: string;
+      nomComplet: string;
+    };
     identifiantCandidatureValues: ReadonlyArray<IdentifiantProjet.RawType>;
   }
 >;
@@ -21,6 +25,7 @@ export const registerNotifierPériodeUseCase = () => {
     identifiantPériodeValue,
     notifiéeLeValue,
     notifiéeParValue,
+    validateurValue,
     identifiantCandidatureValues,
   }) => {
     const identifiantPériode = IdentifiantPériode.convertirEnValueType(identifiantPériodeValue);
@@ -31,6 +36,7 @@ export const registerNotifierPériodeUseCase = () => {
         identifiantPériode,
         notifiéeLe: DateTime.convertirEnValueType(notifiéeLeValue),
         notifiéePar: Email.convertirEnValueType(notifiéeParValue),
+        validateur: validateurValue,
         identifiantCandidatures: identifiantCandidatureValues.map((identifiantCandidatureValue) =>
           IdentifiantProjet.convertirEnValueType(identifiantCandidatureValue),
         ),

packages/domain/éliminé/src/notifier/notifierÉliminé.usecase.ts

@@ -11,6 +11,10 @@ export type NotifierÉliminéUseCase = Message<
     identifiantProjetValue: string;
     notifiéLeValue: string;
     notifiéParValue: string;
+    validateurValue: {
+      fonction: string;
+      nomComplet: string;
+    };
     attestationValue: {
       format: string;
     };
@@ -22,6 +26,7 @@ export const registerNotifierÉliminéUseCase = () => {
     identifiantProjetValue,
     notifiéLeValue,
     notifiéParValue,
+    validateurValue,
     attestationValue: { format },
   }) => {
     await mediator.send<Candidature.NotifierCandidatureUseCase>({
@@ -30,6 +35,7 @@ export const registerNotifierÉliminéUseCase = () => {
         identifiantProjetValue,
         notifiéeLeValue: notifiéLeValue,
         notifiéeParValue: notifiéParValue,
+        validateurValue,
         attestationValue: {
           format: 'application/pdf',
         },