feat(api): merci victor

packages/api/migrations/20230928101239-add-bop-to-fonjep-versements.js

@@ -1,29 +1,28 @@
 const { default: fonjepService } = require("../build/src/modules/providers/fonjep/fonjep.service");
-const { default: fonjepJoiner } = require("../build/src/modules/providers/fonjep/joiners/fonjepJoiner");
 
 module.exports = {
     async up(db) {
-        const fullGrants = await fonjepJoiner.getAllFullGrants();
+        const result = await db
+            .collection("fonjepSubvention")
+            .aggregate([
+                { $match: {} },
+                {
+                    $group: {
+                        _id: "$data.Dispositif.FinanceurCode",
+                        subs: { $addToSet: "$indexedInformations.code_poste" },
+                    },
+                },
+            ])
+            .toArray();
 
-        const versementsGroupByFinanceurCode = fullGrants.reduce((acc, curr) => {
-            const financeurCode = curr.data.Dispositif.FinanceurCode;
-            if (!acc[financeurCode]) acc[financeurCode] = curr.payments;
-            else acc[financeurCode].push(...curr.payments);
-            return acc;
-        }, {});
-
-        for (const [versements, code] of versementsGroupByFinanceurCode) {
-            const bop = fonjepService.getBopFromFounderCode(code);
-            console.log(`start update versements with bop ${bop}`);
+        for (const obj of result) {
+            const bop = fonjepService.getBopFromFounderCode(obj._id);
             await db
                 .collection("fonjepVersement")
                 .updateMany(
-                    { _id: { $in: versements.map(versement => versement._id) } },
+                    { "indexedInformations.code_poste": { $in: obj.subs } },
                     { $set: { "indexedInformations.bop": bop } },
                 );
-            console.log(`end update versements with bop ${bop}`);
         }
-
-        throw new Error("end mig");
     },
 };

packages/api/src/modules/providers/fonjep/joiners/fonjepJoiner.ts

@@ -33,7 +33,7 @@ export class FonjepJoiner {
     }
 
     public getAllFullGrants() {
-        return this.applicationCollection.aggregate([{ $match: {} }, ...this.joinPipeline]).toArray();
+        return this.applicationCollection.aggregate([{ $match: {} }, ...this.joinPipeline]);
     }
 
     public getFullFonjepGrantsBySiret(siret: Siret) {