Skip to content

Commit 8d9eb39

Browse files
committed
fix imports
1 parent d47ba1a commit 8d9eb39

File tree

2 files changed

+8
-7
lines changed

2 files changed

+8
-7
lines changed

src/jobs/sirene/fetcher.js

+1-1
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,7 @@ export const fetchSirenDataById = async (sirenId) => {
133133
}
134134
};
135135

136-
const fetchSiretDataById = async (siretId) => {
136+
export const fetchSiretDataById = async (siretId) => {
137137
const structure = {
138138
siren: siretId.slice(0, 9),
139139
siret: siretId,

src/jobs/sirene/index.js

+7-6
Original file line numberDiff line numberDiff line change
@@ -32,15 +32,16 @@ export default async function monitorSiren(job) {
3232
updatesInSirene.some((update) => update.siret === siret),
3333
);
3434
console.log(stockToBeUpdated?.length, stockToBeUpdated);
35-
const stockUpdates = stockToBeUpdated.map((stockElement) => {
36-
const siretData = fetchSiretDataById(stockElement.siret);
37-
const sireneData = fetchSirenDataById(stockElement.siren);
38-
return {
35+
const stockUpdates = [];
36+
for (const stockElement of stockToBeUpdated) {
37+
const siretData = await fetchSiretDataById(stockElement.siret);
38+
const sireneData = await fetchSirenDataById(stockElement.siren);
39+
stockUpdates.push({
3940
...stockElement,
4041
siretData,
4142
sireneData,
42-
};
43-
});
43+
});
44+
}
4445

4546
const ok = await db.collection("_siren").insertMany(stockUpdates);
4647
return { status: ok ? "success" : "failed", lastExecution: now };

0 commit comments

Comments
 (0)