Merge pull request #48 from demokratie-live/sprint#9/fix_import_antrag_gesetz

Sprint#9/fix import antrag gesetz

Author: ManAnRuck

src/scripts/webhook.js

@@ -31,36 +31,39 @@ export default async (data) => {
   const update = [];
   await Promise.all(data.map(async (d) => {
     const period = parseInt(d.period, 10);
-    const { type, countBefore, changedIds } = d.types.find(t => t.type === 'Gesetzgebung' || t.type === 'Antrag');
-    const group = groups.find(c => c.period === period);
-    const localGroup = group ? group.types.find(ct => ct.type === type) : null;
-    const localCount = localGroup ? localGroup.count : 0;
-    // Append Changed IDs
-    update.concat(changedIds);
-    // Compare Counts Remote & Local
-    if (countBefore > localCount) {
-      // Find remote Procedure Updates
-      const { data: { procedureUpdates } } = await client.query({
-        query: getProcedureUpdates,
-        variables: { period, type },
-      });
-      // Find local Procedure Updates
-      const localProcedureUpdates = await ProcedureModel.find(
-        { period, type },
-        { procedureId: 1, bioUpdateAt: 1 },
-      );
-      // Compare
-      procedureUpdates.forEach((pu) => {
-        const localData = localProcedureUpdates.find(ld => ld.procedureId === pu.procedureId);
-        if (
-          !localData ||
-          (pu.bioUpdateAt &&
-            new Date(localData.bioUpdateAt).getTime() !== new Date(pu.bioUpdateAt).getTime())
-        ) {
-          update.push(pu.procedureId);
-        }
-      });
-    }
+    const types = d.types.filter(t => t.type === 'Gesetzgebung' || t.type === 'Antrag');
+    await Promise.all(types.map(async (t) => {
+      const { type, countBefore, changedIds } = t;
+      const group = groups.find(c => c.period === period);
+      const localGroup = group ? group.types.find(ct => ct.type === type) : null;
+      const localCount = localGroup ? localGroup.count : 0;
+      // Append Changed IDs
+      update.concat(changedIds);
+      // Compare Counts Remote & Local
+      if (countBefore > localCount) {
+        // Find remote Procedure Updates
+        const { data: { procedureUpdates } } = await client.query({
+          query: getProcedureUpdates,
+          variables: { period, type },
+        });
+        // Find local Procedure Updates
+        const localProcedureUpdates = await ProcedureModel.find(
+          { period, type },
+          { procedureId: 1, bioUpdateAt: 1 },
+        );
+        // Compare
+        procedureUpdates.forEach((pu) => {
+          const localData = localProcedureUpdates.find(ld => ld.procedureId === pu.procedureId);
+          if (
+            !localData ||
+            (pu.bioUpdateAt &&
+              new Date(localData.bioUpdateAt).getTime() !== new Date(pu.bioUpdateAt).getTime())
+          ) {
+            update.push(pu.procedureId);
+          }
+        });
+      }
+    }));
   }));
 
   // Splitt in Chunks & Update