♻️ Switch de la partie Event Sourcing sur le nouveau schéma + changem…

…ent du séparateur de catégorie (#1217) * ♻️ Refacto requete SQL * 🗃️ Execution de la migration sur un env non prod pour creer la table event_store.event_stream * ✅ Fix tests * ✅ Mise a jour subscribe * ♻️ Remplacer # par | pour separer la category de l'identifiant * 🗃️ Ajout script creation app_views.projection * ♻️ Creation table app_views.projection * 🗃️ Mise a jour script pour preparation de la release * 🗃️ Mise a jour script pour preparation de la release * ✨ Ajout vue pour la partie analytic * ✅ Fix test load aggregate
MTES-MCT · Jul 27, 2023 · 4951a03 · 4951a03
1 parent b0bae9d
commit 4951a03
Show file tree

Hide file tree

Showing 44 changed files with 282 additions and 249 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -33,7 +33,7 @@
     "prepare": "husky install",
     "lint": "eslint ./src --ext .ts,.tsx",
     "format": "prettier '**/*.{ts,tsx,css}' --write",
-    "migrate": "sequelize-cli db:migrate",
+    "migrate": "npm run build:migrations && sequelize-cli db:migrate",
     "migrate:undo": "npm run build:migrations && sequelize-cli db:migrate:undo",
     "seed": "npm run build:migrations && sequelize-cli db:seed:all",
     "start:dev": "docker compose --profile app up -d && until docker exec potentiel_db pg_isready -U potadmindb -d potentiel; do sleep 1; done && npm run migrate && npm run seed && npm run build:packages && concurrently \"ts-node-dev --transpile-only -r tsconfig-paths/register src/index.ts\" \"webpack --config=webpack.config.js --watch\" \"npm run build:css -- --watch\" \"watch 'npm run build:packages' ./packages/**/src/\"",
@@ -178,4 +178,4 @@
   "engines": {
     "node": "^18.0.0"
   }
-}
+}
diff --git a/packages/domain-views/src/common.port.ts b/packages/domain-views/src/common.port.ts
@@ -2,7 +2,7 @@ import { ReadModel } from '@potentiel/core-domain';
 import { Option } from '@potentiel/monads';
 
 export type Find = <TReadModel extends ReadModel>(
-  id: `${TReadModel['type']}#${string}`,
+  id: `${TReadModel['type']}|${string}`,
 ) => Promise<Option<TReadModel>>;
 
 export type ListOptions<TReadModel extends ReadModel> = {
@@ -23,15 +23,15 @@ export type Search = <TReadModel extends ReadModel>(
 ) => Promise<ReadonlyArray<SearchResult<TReadModel>>>;
 
 export type Create = <TReadModel extends ReadModel>(
-  id: `${TReadModel['type']}#${string}`,
+  id: `${TReadModel['type']}|${string}`,
   readModel: Omit<TReadModel, 'type'>,
 ) => Promise<void>;
 
 export type Update = <TReadModel extends ReadModel>(
-  id: `${TReadModel['type']}#${string}`,
+  id: `${TReadModel['type']}|${string}`,
   readModel: Omit<TReadModel, 'type'>,
 ) => Promise<void>;
 
 export type Remove = <TReadModel extends ReadModel>(
-  id: `${TReadModel['type']}#${string}`,
+  id: `${TReadModel['type']}|${string}`,
 ) => Promise<void>;
diff --git a/packages/domain-views/src/gestionnaireRéseau/consulter/consulterGestionnaireRéseau.query.ts b/packages/domain-views/src/gestionnaireRéseau/consulter/consulterGestionnaireRéseau.query.ts
@@ -35,7 +35,7 @@ export const registerConsulterGestionnaireRéseauQuery = ({
     )
       ? convertirEnIdentifiantGestionnaireRéseau(identifiantGestionnaireRéseau).formatter()
       : identifiantGestionnaireRéseau;
-    const key: GestionnaireRéseauReadModelKey = `gestionnaire-réseau#${rawIdentifiantGestionnaireRéseau}`;
+    const key: GestionnaireRéseauReadModelKey = `gestionnaire-réseau|${rawIdentifiantGestionnaireRéseau}`;
     const result = await find<GestionnaireRéseauReadModel>(key);
 
     return result;

diff --git a/packages/domain-views/src/gestionnaireRéseau/gestionnaireRéseau.projector.ts b/packages/domain-views/src/gestionnaireRéseau/gestionnaireRéseau.projector.ts
@@ -20,12 +20,12 @@ export const registerGestionnaireRéseauProjector = ({
   const handler: MessageHandler<ExecuteGestionnaireRéseauProjector> = async (event) => {
     switch (event.type) {
       case 'GestionnaireRéseauAjouté':
-        await create<GestionnaireRéseauReadModel>(`gestionnaire-réseau#${event.payload.codeEIC}`, {
+        await create<GestionnaireRéseauReadModel>(`gestionnaire-réseau|${event.payload.codeEIC}`, {
           ...event.payload,
         });
         break;
       case 'GestionnaireRéseauModifié':
-        await update<GestionnaireRéseauReadModel>(`gestionnaire-réseau#${event.payload.codeEIC}`, {
+        await update<GestionnaireRéseauReadModel>(`gestionnaire-réseau|${event.payload.codeEIC}`, {
           ...event.payload,
         });
     }

diff --git a/packages/domain-views/src/gestionnaireRéseau/gestionnaireRéseau.readModel.ts b/packages/domain-views/src/gestionnaireRéseau/gestionnaireRéseau.readModel.ts
@@ -2,7 +2,7 @@ import { ReadModel } from '@potentiel/core-domain';
 import { RawIdentifiantGestionnaireRéseau } from '@potentiel/domain';
 
 export type GestionnaireRéseauReadModelKey =
-  `gestionnaire-réseau#${RawIdentifiantGestionnaireRéseau}`;
+  `gestionnaire-réseau|${RawIdentifiantGestionnaireRéseau}`;
 
 export type GestionnaireRéseauReadModel = ReadModel<
   'gestionnaire-réseau',

diff --git a/packages/domain-views/src/projet/consulter/consulterProjet.query.ts b/packages/domain-views/src/projet/consulter/consulterProjet.query.ts
@@ -81,7 +81,7 @@ export const registerConsulterProjetQuery = ({
       ? convertirEnIdentifiantProjet(identifiantProjet).formatter()
       : identifiantProjet;
 
-    const key: ProjetReadModelKey = `projet#${rawIdentifiantProjet}`;
+    const key: ProjetReadModelKey = `projet|${rawIdentifiantProjet}`;
     const result = await find<ProjetReadModel>(key);
 
     return {

diff --git a/packages/domain-views/src/projet/project.projector.ts b/packages/domain-views/src/projet/project.projector.ts
@@ -14,7 +14,7 @@ export type ProjetProjectorDependencies = {
 
 export const registerProjetProjector = ({ create, update, find }: ProjetProjectorDependencies) => {
   const handler: MessageHandler<ExecuteProjetProjector> = async (event) => {
-    const key: ProjetReadModelKey = `projet#${
+    const key: ProjetReadModelKey = `projet|${
       event.payload.identifiantProjet as `${string}#${string}#${string}#${string}`
     }`;
     switch (event.type) {

diff --git a/packages/domain-views/src/projet/projet.readModel.ts b/packages/domain-views/src/projet/projet.readModel.ts
@@ -1,7 +1,7 @@
 import { ReadModel } from '@potentiel/core-domain';
 import { RawIdentifiantProjet } from '@potentiel/domain';
 
-export type ProjetReadModelKey = `projet#${RawIdentifiantProjet}`;
+export type ProjetReadModelKey = `projet|${RawIdentifiantProjet}`;
 
 export type ProjetReadModel = ReadModel<
   'projet',

diff --git a/...s/src/raccordement/consulter/consulterAccuséRéceptionDemandeComplèteRaccordement.query.ts b/...s/src/raccordement/consulter/consulterAccuséRéceptionDemandeComplèteRaccordement.query.ts
@@ -49,7 +49,7 @@ export const registerConsulterAccuséRéceptionDemandeComplèteRaccordementQuery
       ? convertirEnRéférenceDossierRaccordement(référenceDossierRaccordement).formatter()
       : référenceDossierRaccordement;
 
-    const key: DossierRaccordementReadModelKey = `dossier-raccordement#${rawIdentifiantProjet}#${rawRéférenceDossierRaccordement}`;
+    const key: DossierRaccordementReadModelKey = `dossier-raccordement|${rawIdentifiantProjet}#${rawRéférenceDossierRaccordement}`;
 
     const dossierRaccordement = await find<LegacyDossierRaccordementReadModel>(key);
 

diff --git a/packages/domain-views/src/raccordement/consulter/consulterDossierRaccordement.query.ts b/packages/domain-views/src/raccordement/consulter/consulterDossierRaccordement.query.ts
@@ -45,7 +45,7 @@ export const registerConsulterDossierRaccordementQuery = ({
     )
       ? convertirEnRéférenceDossierRaccordement(référenceDossierRaccordement).formatter()
       : référenceDossierRaccordement;
-    const key: DossierRaccordementReadModelKey = `dossier-raccordement#${rawIdentifiantProjet}#${rawRéférenceDossierRaccordement}`;
+    const key: DossierRaccordementReadModelKey = `dossier-raccordement|${rawIdentifiantProjet}#${rawRéférenceDossierRaccordement}`;
     const result = await find<LegacyDossierRaccordementReadModel>(key);
 
     if (isNone(result)) {

diff --git a/...views/src/raccordement/consulter/consulterPropositionTechniqueEtFinancièreSignée.query.ts b/...views/src/raccordement/consulter/consulterPropositionTechniqueEtFinancièreSignée.query.ts
@@ -49,7 +49,7 @@ export const registerConsulterPropositionTechniqueEtFinancièreSignéeQuery = ({
       ? convertirEnRéférenceDossierRaccordement(référenceDossierRaccordement).formatter()
       : référenceDossierRaccordement;
 
-    const key: DossierRaccordementReadModelKey = `dossier-raccordement#${rawIdentifiantProjet}#${rawRéférenceDossierRaccordement}`;
+    const key: DossierRaccordementReadModelKey = `dossier-raccordement|${rawIdentifiantProjet}#${rawRéférenceDossierRaccordement}`;
 
     const dossierRaccordement = await find<LegacyDossierRaccordementReadModel>(key);
 

diff --git a/packages/domain-views/src/raccordement/lister/listerDossierRaccordement.query.ts b/packages/domain-views/src/raccordement/lister/listerDossierRaccordement.query.ts
@@ -28,7 +28,7 @@ export const registerListerDossiersRaccordementQuery = ({
     identifiantProjet,
   }) => {
     const result = await find<ListeDossiersRaccordementReadModel>(
-      `liste-dossiers-raccordement#${
+      `liste-dossiers-raccordement|${
         estUnIdentifiantProjet(identifiantProjet)
           ? convertirEnIdentifiantProjet(identifiantProjet).formatter()
           : identifiantProjet