🐛 Fix release (status, event emiiter, ...)

MTES-MCT · Oct 9, 2023 · d9d7240 · d9d7240
1 parent e9953e5
commit d9d7240
Show file tree

Hide file tree

Showing 17 changed files with 105 additions and 79 deletions.
diff --git a/packages/domain-views/src/projet/lauréat/abandon/abandon.projector.ts b/packages/domain-views/src/projet/lauréat/abandon/abandon.projector.ts
@@ -66,12 +66,12 @@ export const registerAbandonProjector = ({
             statut: 'rejeté',
           });
           break;
-        case 'ConfirmationAbandonDemandé-V1':
+        case 'ConfirmationAbandonDemandée-V1':
           await upsert<AbandonReadModel>(`abandon|${payload.identifiantProjet}`, {
             ...abandonToUpsert,
-            confirmationDemandéLe: payload.confirmationDemandéLe,
-            confirmationDemandéRéponseSignéeFormat: payload.réponseSignée.format,
-            statut: 'confirmation-demandé',
+            confirmationDemandéeLe: payload.confirmationDemandéeLe,
+            confirmationDemandéeRéponseSignéeFormat: payload.réponseSignée.format,
+            statut: 'confirmation-demandée',
           });
           break;
         case 'AbandonConfirmé-V1':

diff --git a/packages/domain-views/src/projet/lauréat/abandon/abandon.readmodel.ts b/packages/domain-views/src/projet/lauréat/abandon/abandon.readmodel.ts
@@ -27,8 +27,8 @@ export type AbandonReadModel = ReadModel<
     rejetRéponseSignéeFormat?: string;
     rejetRejetéLe?: string;
 
-    confirmationDemandéLe?: string;
-    confirmationDemandéRéponseSignéeFormat?: string;
+    confirmationDemandéeLe?: string;
+    confirmationDemandéeRéponseSignéeFormat?: string;
     confirmationConfirméLe?: string;
   }
 >;

diff --git a/.../domain-views/src/projet/lauréat/abandon/consulter/consulterRéponseSignéeAbandon.query.ts b/.../domain-views/src/projet/lauréat/abandon/consulter/consulterRéponseSignéeAbandon.query.ts
@@ -56,14 +56,14 @@ export const registerConsulterRéponseAbandonSignéeQuery = ({
         ? abandon.accordAccordéLe
         : type === 'abandon-rejeté'
         ? abandon.rejetRejetéLe
-        : abandon.confirmationDemandéLe;
+        : abandon.confirmationDemandéeLe;
 
     const format =
       type === 'abandon-accordé'
         ? abandon.accordRéponseSignéeFormat
         : type === 'abandon-rejeté'
         ? abandon.rejetRéponseSignéeFormat
-        : abandon.confirmationDemandéRéponseSignéeFormat;
+        : abandon.confirmationDemandéeRéponseSignéeFormat;
 
     if (!date || !format) {
       return none;

diff --git a/packages/domain-views/src/projet/lauréat/lauréat.setup.ts b/packages/domain-views/src/projet/lauréat/lauréat.setup.ts
@@ -74,7 +74,7 @@ export const setupLauréatViews = async (dependencies: LauréatDependencies) =>
         'AbandonAnnulé-V1',
         'AbandonConfirmé-V1',
         'AbandonRejeté-V1',
-        'ConfirmationAbandonDemandé-V1',
+        'ConfirmationAbandonDemandée-V1',
         'RebuildTriggered',
       ],
       eventHandler: async (event: AbandonEvent | RebuildTriggered) => {

diff --git a/packages/domain/src/projet/lauréat/abandon/abandon.aggregate.ts b/packages/domain/src/projet/lauréat/abandon/abandon.aggregate.ts
@@ -5,7 +5,7 @@ import {
   AbandonEvent,
   AbandonAccordéEvent,
   AbandonRejetéEvent,
-  ConfirmationAbandonDemandéEvent,
+  ConfirmationAbandonDemandéeEvent,
   AbandonConfirméEvent,
 } from './abandon.event';
 import { StatutAbandon } from './abandon.valueType';
@@ -23,6 +23,11 @@ type LoadAggregateFactoryDependencies = { loadAggregate: LoadAggregate };
 
 export type Abandon = {
   getStatut: () => StatutAbandon;
+  estAccordé: () => boolean;
+  estRejeté: () => boolean;
+  estEnAttenteConfirmation: () => boolean;
+  estConfirmé: () => boolean;
+  estEnCours: () => boolean;
   demande: {
     raison: string;
     piéceJustificative?: {
@@ -54,7 +59,23 @@ export type Abandon = {
 };
 
 const getDefaultAggregate = (): Abandon => ({
-  getStatut: function () {
+  estAccordé() {
+    return this.getStatut() === 'accordé';
+  },
+  estEnCours() {
+    const statusEnCours: Array<StatutAbandon> = ['confirmation-demandée', 'confirmé', 'demandé'];
+    return statusEnCours.includes(this.getStatut());
+  },
+  estRejeté() {
+    return this.getStatut() === 'rejeté';
+  },
+  estEnAttenteConfirmation() {
+    return this.getStatut() === 'confirmation-demandée';
+  },
+  estConfirmé() {
+    return this.getStatut() === 'confirmé';
+  },
+  getStatut() {
     if (this.annuléLe) {
       return 'annulé';
     }
@@ -67,7 +88,7 @@ const getDefaultAggregate = (): Abandon => ({
     }
 
     if (this.demande.confirmation && !this.demande.confirmation.confirméLe) {
-      return 'confirmation-demandé';
+      return 'confirmation-demandée';
     }
 
     if (this.demande.confirmation && this.demande.confirmation.confirméLe) {
@@ -97,8 +118,8 @@ const abandonAggregateFactory: AggregateFactory<Abandon, AbandonEvent> = (events
         return updateAvecRejet(aggregate, payload);
       case 'AbandonAccordé-V1':
         return updateAvecAcceptation(aggregate, payload);
-      case 'ConfirmationAbandonDemandé-V1':
-        return updateAvecConfirmationAbandonDemandé(aggregate, payload);
+      case 'ConfirmationAbandonDemandée-V1':
+        return updateAvecConfirmationAbandonDemandée(aggregate, payload);
       case 'AbandonConfirmé-V1':
         return updateAvecAbandonConfirmé(aggregate, payload);
       case 'AbandonAnnulé-V1':
@@ -169,17 +190,17 @@ const updateAvecAcceptation = (aggregate: Abandon, payload: AbandonAccordéEvent
   return newAggregate;
 };
 
-const updateAvecConfirmationAbandonDemandé = (
+const updateAvecConfirmationAbandonDemandée = (
   aggregate: Abandon,
-  payload: ConfirmationAbandonDemandéEvent['payload'],
+  payload: ConfirmationAbandonDemandéeEvent['payload'],
 ) => {
-  const { confirmationDemandéLe, réponseSignée } = payload;
+  const { confirmationDemandéeLe, réponseSignée } = payload;
   let newAggregate: Abandon = {
     ...aggregate,
   };
 
   newAggregate.demande.confirmation = {
-    demandéLe: convertirEnDateTime(confirmationDemandéLe),
+    demandéLe: convertirEnDateTime(confirmationDemandéeLe),
     réponseSignée,
   };
 

diff --git a/packages/domain/src/projet/lauréat/abandon/abandon.error.ts b/packages/domain/src/projet/lauréat/abandon/abandon.error.ts
@@ -41,3 +41,9 @@ export class AucuneDemandeConfirmationAbandonError extends InvalidOperationError
     super(`Aucune demande de confirmation d'abandon en attente`);
   }
 }
+
+export class DemandeEnAttenteConfirmationError extends InvalidOperationError {
+  constructor() {
+    super(`L'abandon est en attente de confirmation`);
+  }
+}
diff --git a/packages/domain/src/projet/lauréat/abandon/abandon.event.ts b/packages/domain/src/projet/lauréat/abandon/abandon.event.ts
@@ -49,11 +49,11 @@ export type AbandonAccordéEvent = DomainEvent<
   }
 >;
 
-export type ConfirmationAbandonDemandéEvent = DomainEvent<
-  'ConfirmationAbandonDemandé-V1',
+export type ConfirmationAbandonDemandéeEvent = DomainEvent<
+  'ConfirmationAbandonDemandée-V1',
   {
-    confirmationDemandéLe: string;
-    confirmationDemandéPar: RawIdentifiantUtilisateur;
+    confirmationDemandéeLe: string;
+    confirmationDemandéePar: RawIdentifiantUtilisateur;
     identifiantProjet: RawIdentifiantProjet;
     réponseSignée: {
       format: string;
@@ -75,5 +75,5 @@ export type AbandonEvent =
   | AbandonAnnuléEvent
   | AbandonRejetéEvent
   | AbandonAccordéEvent
-  | ConfirmationAbandonDemandéEvent
+  | ConfirmationAbandonDemandéeEvent
   | AbandonConfirméEvent;
diff --git a/packages/domain/src/projet/lauréat/abandon/abandon.valueType.ts b/packages/domain/src/projet/lauréat/abandon/abandon.valueType.ts
@@ -36,7 +36,7 @@ export type RéponseSignée =
 export type StatutAbandon =
   | 'demandé'
   | 'rejeté'
-  | 'confirmation-demandé'
+  | 'confirmation-demandée'
   | 'confirmé'
   | 'accordé'
   | 'annulé';

diff --git a/packages/domain/src/projet/lauréat/abandon/accorder/accorderAbandon.command.ts b/packages/domain/src/projet/lauréat/abandon/accorder/accorderAbandon.command.ts
@@ -11,6 +11,7 @@ import {
   AbandonDéjàAccordéError,
   AbandonDéjàRejetéError,
   DemandeAbandonInconnuErreur,
+  DemandeEnAttenteConfirmationError,
 } from '../abandon.error';
 import { IdentifiantUtilisateurValueType } from '../../../../domain.valueType';
 
@@ -48,14 +49,18 @@ export const registerAccorderAbandonCommand = ({
       throw new DemandeAbandonInconnuErreur();
     }
 
-    if (abandon.getStatut() === 'accordé') {
+    if (abandon.estAccordé()) {
       throw new AbandonDéjàAccordéError();
     }
 
-    if (abandon.getStatut() === 'rejeté') {
+    if (abandon.estRejeté()) {
       throw new AbandonDéjàRejetéError();
     }
 
+    if (abandon.estEnAttenteConfirmation()) {
+      throw new DemandeEnAttenteConfirmationError();
+    }
+
     await enregistrerRéponseSignée({
       identifiantProjet,
       réponseSignée,

diff --git a/packages/domain/src/projet/lauréat/abandon/annuler/annulerAbandon.command.ts b/packages/domain/src/projet/lauréat/abandon/annuler/annulerAbandon.command.ts
@@ -38,7 +38,7 @@ export const registerAnnulerAbandonCommand = ({
       throw new DemandeAbandonInconnuErreur();
     }
 
-    if (abandon.getStatut() === 'accordé') {
+    if (abandon.estAccordé()) {
       throw new AbandonDéjàAccordéError();
     }
 

diff --git a/packages/domain/src/projet/lauréat/abandon/confirmer/confirmerAbandon.command.ts b/packages/domain/src/projet/lauréat/abandon/confirmer/confirmerAbandon.command.ts
@@ -41,7 +41,7 @@ export const registerConfirmerAbandonCommand = ({
       throw new DemandeAbandonInconnuErreur();
     }
 
-    if (abandon.getStatut() !== 'confirmation-demandé') {
+    if (!abandon.estEnAttenteConfirmation()) {
       throw new AucuneDemandeConfirmationAbandonError();
     }
 

diff --git a/packages/domain/src/projet/lauréat/abandon/demander/demanderAbandon.command.ts b/packages/domain/src/projet/lauréat/abandon/demander/demanderAbandon.command.ts
@@ -7,7 +7,7 @@ import { isSome } from '@potentiel/monads';
 import { AbandonDemandéEvent } from '../abandon.event';
 import { EnregistrerPiéceJustificativeAbandonPort } from '../abandon.port';
 import { DateTimeValueType } from '../../../../common.valueType';
-import { DemandeAbandonEnCoursErreur } from '../abandon.error';
+import { AbandonDéjàAccordéError, DemandeAbandonEnCoursErreur } from '../abandon.error';
 import { IdentifiantUtilisateurValueType } from '../../../../utilisateur/utilisateur.valueType';
 
 export type DemanderAbandonCommand = Message<
@@ -44,8 +44,14 @@ export const registerDemanderAbandonCommand = ({
   }) => {
     const abandon = await loadAbandonAggregate(identifiantProjet);
 
-    if (isSome(abandon) && abandon.getStatut() !== 'annulé') {
-      throw new DemandeAbandonEnCoursErreur();
+    if (isSome(abandon)) {
+      if (abandon.estAccordé()) {
+        throw new AbandonDéjàAccordéError();
+      }
+
+      if (abandon.estEnCours()) {
+        throw new DemandeAbandonEnCoursErreur();
+      }
     }
 
     if (piéceJustificative) {

diff --git a/packages/domain/src/projet/lauréat/abandon/demander/demanderConfirmationAbandon.command.ts b/packages/domain/src/projet/lauréat/abandon/demander/demanderConfirmationAbandon.command.ts
@@ -3,7 +3,7 @@ import { IdentifiantProjetValueType } from '../../../projet.valueType';
 import { createAbandonAggregateId, loadAbandonAggregateFactory } from '../abandon.aggregate';
 import { LoadAggregate, Publish } from '@potentiel/core-domain';
 import { isNone } from '@potentiel/monads';
-import { ConfirmationAbandonDemandéEvent } from '../abandon.event';
+import { ConfirmationAbandonDemandéeEvent } from '../abandon.event';
 import { DateTimeValueType } from '../../../../common.valueType';
 import {
   AbandonDéjàAccordéError,
@@ -50,19 +50,20 @@ export const registerDemanderConfirmationAbandonCommand = ({
       throw new DemandeAbandonInconnuErreur();
     }
 
-    const status = abandon.getStatut();
+    if (abandon.estAccordé()) {
+      throw new AbandonDéjàAccordéError();
+    }
+
+    if (abandon.estRejeté()) {
+      throw new AbandonDéjàRejetéError();
+    }
+
+    if (abandon.estEnAttenteConfirmation()) {
+      throw new ConfirmationAbandonDéjàDemandéError();
+    }
 
-    if (status !== 'demandé') {
-      switch (status) {
-        case 'accordé':
-          throw new AbandonDéjàAccordéError();
-        case 'rejeté':
-          throw new AbandonDéjàRejetéError();
-        case 'confirmé':
-          throw new AbandonDéjàConfirméError();
-        case 'confirmation-demandé':
-          throw new ConfirmationAbandonDéjàDemandéError();
-      }
+    if (abandon.estConfirmé()) {
+      throw new AbandonDéjàConfirméError();
     }
 
     await enregistrerRéponseSignée({
@@ -71,15 +72,15 @@ export const registerDemanderConfirmationAbandonCommand = ({
       dateDocumentRéponseSignée: dateDemandeConfirmationAbandon,
     });
 
-    const event: ConfirmationAbandonDemandéEvent = {
-      type: 'ConfirmationAbandonDemandé-V1',
+    const event: ConfirmationAbandonDemandéeEvent = {
+      type: 'ConfirmationAbandonDemandée-V1',
       payload: {
         identifiantProjet: identifiantProjet.formatter(),
         réponseSignée: {
           format: réponseSignée.format,
         },
-        confirmationDemandéLe: dateDemandeConfirmationAbandon.formatter(),
-        confirmationDemandéPar: confirmationDemandéePar.formatter(),
+        confirmationDemandéeLe: dateDemandeConfirmationAbandon.formatter(),
+        confirmationDemandéePar: confirmationDemandéePar.formatter(),
       },
     };
 

diff --git a/packages/domain/src/projet/lauréat/abandon/rejeter/rejeterAbandon.command.ts b/packages/domain/src/projet/lauréat/abandon/rejeter/rejeterAbandon.command.ts
@@ -11,6 +11,7 @@ import {
   AbandonDéjàAccordéError,
   AbandonDéjàRejetéError,
   DemandeAbandonInconnuErreur,
+  DemandeEnAttenteConfirmationError,
 } from '../abandon.error';
 import { IdentifiantUtilisateurValueType } from '../../../../utilisateur/utilisateur.valueType';
 
@@ -48,14 +49,18 @@ export const registerRejeterAbandonCommand = ({
       throw new DemandeAbandonInconnuErreur();
     }
 
-    if (abandon.getStatut() === 'accordé') {
+    if (abandon.estAccordé()) {
       throw new AbandonDéjàAccordéError();
     }
 
-    if (abandon.getStatut() === 'rejeté') {
+    if (abandon.estRejeté()) {
       throw new AbandonDéjàRejetéError();
     }
 
+    if (abandon.estEnAttenteConfirmation()) {
+      throw new DemandeEnAttenteConfirmationError();
+    }
+
     await enregistrerRéponseSignée({
       identifiantProjet,
       réponseSignée,

diff --git a/packages/libraries/pg-event-sourcing/src/subscribe/eventStreamEmitter.ts b/packages/libraries/pg-event-sourcing/src/subscribe/eventStreamEmitter.ts
@@ -51,7 +51,11 @@ export class EventStreamEmitter extends EventEmitter {
           return;
         }
 
-        this.emit(this.#getChannelName(event.type), event);
+        if (
+          notification.channel === `${this.#subscriber.streamCategory}|${this.#subscriber.name}`
+        ) {
+          this.emit(this.#getChannelName(event.type), event);
+        }
       } catch (error) {
         getLogger().error(new NotificationPayloadParseError(), {
           error,

diff --git a/packages/libraries/pg-projections/src/listProjection.ts b/packages/libraries/pg-projections/src/listProjection.ts
@@ -41,8 +41,9 @@ export const listProjection = async <TReadModel extends ReadModel>({
 
   const totalResult = pagination
     ? await executeSelect<{ totalItems: string }>(
-        'select count(key) as "totalItems" from domain_views.projection where key like $1',
+        `select count(key) as "totalItems" from domain_views.projection where key like $1 ${whereClause}`,
         `${type}|%`,
+        ...(where ? Object.values(where) : []),
       )
     : [{ totalItems: result.length.toString() }];