Implémente les méthodes d'adaptateur permettant de sauvegarder le `ha…

…sh` du SIRET d'un service
betagouv · Nov 7, 2024 · b3a9b92 · b3a9b92
1 parent 686b513
commit b3a9b92
Show file tree

Hide file tree

Showing 2 changed files with 34 additions and 13 deletions.
diff --git a/src/adaptateurs/adaptateurPersistanceMemoire.js b/src/adaptateurs/adaptateurPersistanceMemoire.js
@@ -18,8 +18,18 @@ const nouvelAdaptateur = (
     donnees[nomTable] = donnees[nomTable].filter((e) => e.id !== id);
   };
 
-  const ajouteService = async (id, donneesService, nomServiceHash) => {
-    donnees.services.push({ id, donnees: donneesService, nomServiceHash });
+  const ajouteService = async (
+    id,
+    donneesService,
+    nomServiceHash,
+    siretHash
+  ) => {
+    donnees.services.push({
+      id,
+      donnees: donneesService,
+      nomServiceHash,
+      siretHash,
+    });
   };
 
   const ajouteUtilisateur = async (id, donneesUtilisateur, emailHash) => {
@@ -72,9 +82,14 @@ const nouvelAdaptateur = (
     );
   };
 
-  const metsAJourService = async (id, donneesService, nomServiceHash) => {
+  const metsAJourService = async (
+    id,
+    donneesService,
+    nomServiceHash,
+    siretHash
+  ) => {
     const s = await service(id);
-    Object.assign(s, { nomServiceHash, donnees: donneesService });
+    Object.assign(s, { nomServiceHash, siretHash, donnees: donneesService });
   };
 
   const sauvegardeAutorisation = async (id, donneesAutorisation) => {
@@ -84,11 +99,11 @@ const nouvelAdaptateur = (
     else Object.assign(dejaConnue, { ...donneesAutorisation });
   };
 
-  const sauvegardeService = (id, donneesService, nomServiceHash) => {
+  const sauvegardeService = (id, donneesService, nomServiceHash, siretHash) => {
     const dejaConnu = donnees.services.find((s) => s.id === id) !== undefined;
     return dejaConnu
-      ? metsAJourService(id, donneesService, nomServiceHash)
-      : ajouteService(id, donneesService, nomServiceHash);
+      ? metsAJourService(id, donneesService, nomServiceHash, siretHash)
+      : ajouteService(id, donneesService, nomServiceHash, siretHash);
   };
 
   const supprimeService = (...params) =>

diff --git a/src/adaptateurs/adaptateurPostgres.js b/src/adaptateurs/adaptateurPostgres.js
@@ -76,8 +76,13 @@ const nouvelAdaptateur = (env) => {
   const supprimeEnregistrement = (nomTable, id) =>
     knex(nomTable).where({ id }).del();
 
-  const ajouteService = async (id, donnees, nomServiceHash) =>
-    knex('services').insert({ id, donnees, nom_service_hash: nomServiceHash });
+  const ajouteService = async (id, donnees, nomServiceHash, siretHash) =>
+    knex('services').insert({
+      id,
+      donnees,
+      nom_service_hash: nomServiceHash,
+      siret_hash: siretHash,
+    });
 
   const ajouteUtilisateur = (id, donnees, emailHash) =>
     knex('utilisateurs').insert({
@@ -177,14 +182,15 @@ const nouvelAdaptateur = (env) => {
     return avecPMapPourChaqueElement(Promise.resolve(ids), service);
   };
 
-  const metsAJourService = (id, donnees, nomServiceHash) =>
+  const metsAJourService = (id, donnees, nomServiceHash, siretHash) =>
     knex('services')
       .where({ id })
       .first()
       .then(() =>
         knex('services').where({ id }).update({
           donnees,
           nom_service_hash: nomServiceHash,
+          siret_hash: siretHash,
         })
       );
 
@@ -278,7 +284,7 @@ const nouvelAdaptateur = (env) => {
       .whereRaw("(donnees->>'estProprietaire')::boolean=true")
       .then(([{ count }]) => parseInt(count, 10));
 
-  const sauvegardeService = (id, donneesService, nomServiceHash) => {
+  const sauvegardeService = (id, donneesService, nomServiceHash, siretHash) => {
     const testExistence = knex('services')
       .where('id', id)
       .select({ id: 'id' })
@@ -287,8 +293,8 @@ const nouvelAdaptateur = (env) => {
 
     return testExistence.then((dejaConnu) =>
       dejaConnu
-        ? metsAJourService(id, donneesService, nomServiceHash)
-        : ajouteService(id, donneesService, nomServiceHash)
+        ? metsAJourService(id, donneesService, nomServiceHash, siretHash)
+        : ajouteService(id, donneesService, nomServiceHash, siretHash)
     );
   };