Merge pull request #10 from demokratie-live/sprint#5/Webhook-vorbereiten

Webhook

Author: ulfgebhardt

scripts/import.js

@@ -10,13 +10,21 @@ export default gql`
       currentStatus
       abstract
       tags
+      subjectGroups
       history {
         assignment
+        initiator
         decision {
           tenor
         }
         date
       }
+      importantDocuments {
+        editor
+        type
+        url
+        number
+      }
     }
   }
 `;

src/graphql/queries/getProcedures.js

@@ -12,6 +12,8 @@ import constants from './config/constants';
 import typeDefs from './graphql/schemas';
 import resolvers from './graphql/resolvers';
 
+import importProcedures from './scripts/import';
+
 // Models
 import ProcedureModel from './models/Procedure';
 
@@ -52,6 +54,21 @@ app.use(constants.GRAPHQL_PATH, (req, res, next) => {
   })(req, res, next);
 });
 
+app.post('/webhooks/bundestagio/update', async (req, res) => {
+  const { procedureIds } = req.body;
+  try {
+    res.send({
+      updated: await importProcedures(procedureIds),
+      succeeded: true,
+    });
+  } catch (error) {
+    res.send({
+      error,
+      succeeded: false,
+    });
+  }
+});
+
 const graphqlServer = createServer(app);
 
 graphqlServer.listen(constants.PORT, (err) => {

src/index.js

@@ -0,0 +1,44 @@
+import ProgressBar from 'cli-progress'; // eslint-disable-line
+import program from 'commander'; // eslint-disable-line
+
+import client from '../graphql/client';
+import Procedure from '../models/Procedure';
+import getProcedures from '../graphql/queries/getProcedures';
+
+const PAGE_SIZE = 20;
+
+export default async (procedureIds) => {
+  // Start Importing
+  const { data: { procedures } } = await client.query({
+    query: getProcedures,
+    variables: { pageSize: PAGE_SIZE, IDs: procedureIds },
+  });
+  // Start Inserting
+  const promises = await procedures.map(async (bIoProcedure) => {
+    const newBIoProcedure = { ...bIoProcedure };
+    if (bIoProcedure && bIoProcedure.history) {
+      const [lastHistory] = newBIoProcedure.history.slice(-1);
+      const btWithDecisions = bIoProcedure.history.filter(({ assignment, initiator }) => assignment === 'BT' && initiator === '2. Beratung');
+      if (btWithDecisions.length > 0) {
+        newBIoProcedure.voteDate = new Date(btWithDecisions.pop().date);
+      } else if (newBIoProcedure.currentStatus === 'Zurückgezogen') {
+        newBIoProcedure.voteDate = lastHistory.date;
+      }
+
+      newBIoProcedure.lastUpdateDate = lastHistory.date;
+
+      newBIoProcedure.submissionDate = newBIoProcedure.history[0].date;
+    }
+    return Procedure.findOneAndUpdate(
+      { procedureId: newBIoProcedure.procedureId },
+      newBIoProcedure,
+      {
+        upsert: true,
+      },
+    );
+  });
+  const result = await Promise.all(promises);
+
+  return result.length;
+  // Imported everything!
+};