add advisor email notification case

Author: tpicaud

back/src/domains/establishment/use-cases/notifications/NotifyEstablishmentUsersAndBeneficiariesThatEstablishmentIsBanned.ts

@@ -10,6 +10,7 @@ import {
   withSiretSchema,
 } from "shared";
 import { agencyWithRightToAgencyDto } from "../../../../utils/agency";
+import type { ConventionFtUserAdvisorEntity } from "../../../core/authentication/ft-connect/dto/FtConnect.dto";
 import type { SaveNotificationAndRelatedEvent } from "../../../core/notifications/helpers/Notification";
 import type { TimeGateway } from "../../../core/time-gateway/ports/TimeGateway";
 import type { UnitOfWork } from "../../../core/unit-of-work/ports/UnitOfWork";
@@ -188,6 +189,34 @@ const notifyValidatorsAndPreValidators = async (
     if (!agency)
       throw errors.agency.notFound({ agencyId: convention.agencyId });
 
+    const ftUserAdvisor: ConventionFtUserAdvisorEntity | undefined =
+      await uow.conventionFranceTravailAdvisorRepository.getByConventionId(
+        convention.id,
+      );
+
+    if (ftUserAdvisor?.advisor) {
+      await saveNotificationAndRelatedEvent(uow, {
+        kind: "email",
+        templatedContent: {
+          kind: "ESTABLISHMENT_BANNED_NOTIFICATION_TO_VALIDATOR_AND_PREVALIDATOR",
+          recipients: [ftUserAdvisor.advisor.email],
+          params: {
+            businessName: bannedEstablishment.establishment.name,
+            beneficiaryFirstName: convention.signatories.beneficiary.firstName,
+            beneficiaryLastName: convention.signatories.beneficiary.lastName,
+            immersionBaseUrl: immersionBaseUrl,
+            conventionId: convention.id,
+          },
+        },
+        followedIds: {
+          establishmentSiret: bannedEstablishment.establishment.siret,
+          conventionId: convention.id,
+        },
+      });
+
+      return;
+    }
+
     const agencyWithUserEmailNotificationActivated =
       await agencyWithRightToAgencyDto(uow, agency);
 

back/src/domains/establishment/use-cases/notifications/NotifyEstablishmentUsersAndBeneficiariesThatEstablishmentIsBanned.unit.test.ts

@@ -14,6 +14,8 @@ import {
   type ExpectSavedNotificationsAndEvents,
   makeExpectSavedNotificationsAndEvents,
 } from "../../../../utils/makeExpectSavedNotificationAndEvent.helpers";
+import type { FtConnectImmersionAdvisorDto } from "../../../core/authentication/ft-connect/dto/FtConnectAdvisor.dto";
+import type { FtConnectUserDto } from "../../../core/authentication/ft-connect/dto/FtConnectUserDto";
 import {
   makeSaveNotificationAndRelatedEvent,
   type SaveNotificationAndRelatedEvent,
@@ -483,7 +485,52 @@ describe("NotifyEstablishmentUsersAndBeneficiariesThatEstablishmentIsBanned", ()
     });
 
     it("sends email only to FT advisor when present", async () => {
-      uow.conventionRepository.setConventions([validatedConvention]);
+      const ftConnectedBeneficiary: FtConnectUserDto = {
+        firstName: "Jean",
+        lastName: "Bénéficiaire",
+        isJobseeker: true,
+        peExternalId: "beneficiary-external-id",
+        email: "jean@beneficiaire.com",
+        birthdate: "2000-02-02",
+      };
+      const ftConnectImmersionAdvisor: FtConnectImmersionAdvisorDto = {
+        email: "jean@advisor.com",
+        firstName: "Jean",
+        lastName: "Advisor",
+        type: "PLACEMENT",
+      };
+
+      const conventionWithFtConnectUsers: ConventionDto = {
+        ...validatedConvention,
+        internshipKind: "immersion",
+        signatories: {
+          ...validatedConvention.signatories,
+          beneficiary: {
+            ...validatedConvention.signatories.beneficiary,
+            ...ftConnectedBeneficiary,
+          },
+        },
+        validators: {
+          ...validatedConvention.validators,
+          agencyCounsellor: {
+            firstname: ftConnectImmersionAdvisor.firstName,
+            lastname: ftConnectImmersionAdvisor.lastName,
+          },
+        },
+      };
+
+      uow.conventionRepository.setConventions([conventionWithFtConnectUsers]);
+      uow.conventionFranceTravailAdvisorRepository.ftConnectedUsers = {
+        [ftConnectedBeneficiary.peExternalId]: {
+          advisor: ftConnectImmersionAdvisor,
+          user: ftConnectedBeneficiary,
+        },
+      };
+      uow.conventionFranceTravailAdvisorRepository.conventionFranceTravailUsers =
+        {
+          [conventionWithFtConnectUsers.id]:
+            ftConnectedBeneficiary.peExternalId,
+        };
 
       await notifyEstablishmentUsersAndBeneficiariesThatEstablishmentIsBanned.execute(
         { siret },
@@ -503,22 +550,19 @@ describe("NotifyEstablishmentUsersAndBeneficiariesThatEstablishmentIsBanned", ()
           },
           {
             kind: "ESTABLISHMENT_BANNED_NOTIFICATION_TO_VALIDATOR_AND_PREVALIDATOR",
-            recipients: [agency.contactEmail],
+            recipients: [ftConnectImmersionAdvisor.email],
             params: {
               businessName,
-              conventionId: validatedConvention.id,
+              conventionId: conventionWithFtConnectUsers.id,
               beneficiaryFirstName:
-                validatedConvention.signatories.beneficiary.firstName,
+                conventionWithFtConnectUsers.signatories.beneficiary.firstName,
               beneficiaryLastName:
-                validatedConvention.signatories.beneficiary.lastName,
+                conventionWithFtConnectUsers.signatories.beneficiary.lastName,
               immersionBaseUrl,
             },
           },
         ],
       });
-      throw new Error(
-        "Use repo when conventionFranceTravailAdvisorRepository is updated",
-      );
     });
 
     it("sends email to agency validators when convention is validated and agency has no refersToAgency", async () => {