diff --git a/src/adaptateurs/adaptateurPersistanceMemoire.js b/src/adaptateurs/adaptateurPersistanceMemoire.js index 597090355..71a42ebda 100644 --- 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 index af213583d..eed7275da 100644 --- 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,7 +182,7 @@ 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() @@ -185,6 +190,7 @@ const nouvelAdaptateur = (env) => { 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) ); };