fire Push notifications

Author: ManAnRuck

src/index.js

@@ -16,7 +16,7 @@ import webhook from './scripts/webhook';
 // import importAll from './scripts/importAll';
 
 import auth from './express/auth';
-import pushNotify from './services/notifications';
+// import pushNotify from './services/notifications';
 
 // Models
 import ProcedureModel from './models/Procedure';
@@ -87,18 +87,18 @@ app.post('/webhooks/bundestagio/update', async (req, res) => {
   }
 });
 
-app.get('/push-test', async (req, res) => {
-  const { message } = req.query;
-  const users = await UserModel.find();
-  users.forEach((user) => {
-    pushNotify({
-      title: 'test',
-      message: message || 'Test push notification to all users',
-      user,
-    });
-  });
-  res.send("push's send");
-});
+// app.get('/push-test', async (req, res) => {
+//   const { message } = req.query;
+//   const users = await UserModel.find();
+//   users.forEach((user) => {
+//     pushNotify({
+//       title: 'test',
+//       message: message || 'Test push notification to all users',
+//       user,
+//     });
+//   });
+//   res.send("push's send");
+// });
 
 // Darf in Production nicht ausführbar sein!
 // app.get('/webhooks/bundestagio/import-all', importAll);

src/scripts/import.js

@@ -4,6 +4,8 @@ import createClient from '../graphql/client';
 import Procedure from '../models/Procedure';
 import getProcedures from '../graphql/queries/getProcedures';
 
+import { procedureUpdate, newPreperation, newVote } from '../services/notifications/index';
+
 const deputiesNumber = {
   8: 518,
   9: 519,
@@ -67,6 +69,12 @@ export default async (procedureIds) => {
 
       newBIoProcedure.submissionDate = newBIoProcedure.history[0].date;
     }
+
+    const oldProcedure = await Procedure.find(
+      { procedureId: newBIoProcedure.procedureId },
+      { _id: 1 },
+    ).limit(1);
+
     return Procedure.findOneAndUpdate(
       { procedureId: newBIoProcedure.procedureId },
       _(newBIoProcedure)
@@ -75,8 +83,24 @@ export default async (procedureIds) => {
       {
         upsert: true,
       },
-    );
+    ).then(() => {
+      /**
+       * PUSH NOTIFICATIONS
+       */
+      // New Procedures
+      if (!oldProcedure.length) {
+        newPreperation({ procedureId: newBIoProcedure.procedureId });
+      } else {
+        // Updated Procedures
+        procedureUpdate({ procedureId: newBIoProcedure.procedureId });
+        if (newBIoProcedure.currentStatus === 'Beschlussempfehlung liegt vor') {
+          // moved to Vote Procedures
+          newVote({ procedureId: newBIoProcedure.procedureId });
+        }
+      }
+    });
   });
+
   const result = await Promise.all(promises);
 
   return result.length;

src/services/notifications/index.js

@@ -7,6 +7,87 @@ import gcm from 'node-gcm';
 import apnProvider from './apn';
 import gcmProvider from './gcm';
 import UserModel from '../../models/User';
+import ProcedureModel from '../../models/Procedure';
+
+const sendNotifications = ({ tokenObjects, message }) => {
+  const androidNotificationTokens = [];
+  tokenObjects.forEach(({ token, os }) => {
+    switch (os) {
+      case 'ios':
+        {
+          const note = new apn.Notification();
+
+          note.alert = message;
+          // note.payload = { messageFrom: 'John Appleseed' };
+          note.topic = 'de.democracy-deutschland.clientapp';
+
+          apnProvider.send(note, token).then((result) => {
+            console.log('apnProvider.send', result);
+          });
+        }
+        break;
+
+      case 'android':
+        // Prepare android notifications
+        androidNotificationTokens.push(token);
+        break;
+
+      default:
+        break;
+    }
+  });
+  // send bulk send android notifications
+  if (androidNotificationTokens.length > 0) {
+    const gcmMessage = new gcm.Message({
+      notification: {
+        body: message,
+      },
+    });
+    gcmProvider.send(
+      gcmMessage,
+      { registrationTokens: androidNotificationTokens },
+      (err, response) => {
+        if (err) console.error('gcmProvider', err);
+        else console.log('gcmProvider', response);
+      },
+    );
+  }
+};
+
+const newVote = async ({ procedureId }) => {
+  const procedure = await ProcedureModel.findOne({ procedureId });
+  const users = await UserModel.find({
+    'notificationSettings.enabled': true,
+    'notificationSettings.newVote': true,
+  });
+  const tokenObjects = users.reduce((array, { pushTokens }) => [...array, ...pushTokens], []);
+  sendNotifications({ tokenObjects, message: `Jetzt Abstimmen!\n${procedure.title}` });
+};
+// newVote({ procedureId: 231079 });
+
+const newPreperation = async ({ procedureId }) => {
+  const procedure = await ProcedureModel.findOne({ procedureId });
+  const users = await UserModel.find({
+    'notificationSettings.enabled': true,
+    'notificationSettings.newPreperation': true,
+  });
+  const tokenObjects = users.reduce((array, { pushTokens }) => [...array, ...pushTokens], []);
+  sendNotifications({ tokenObjects, message: `Neue Gesetzesinitiative!\n${procedure.title}` });
+};
+// newPreperation({ procedureId: 231079 });
+
+const procedureUpdate = async ({ procedureId }) => {
+  const procedure = await ProcedureModel.findOne({ procedureId });
+  const users = await UserModel.find({
+    'notificationSettings.enabled': true,
+    'notificationSettings.procedures': procedure._id,
+  });
+  const tokenObjects = users.reduce((array, { pushTokens }) => [...array, ...pushTokens], []);
+  sendNotifications({ tokenObjects, message: `Update!\n${procedure.title}` });
+};
+// procedureUpdate({ procedureId: 231079 });
+
+export { procedureUpdate, newVote, newPreperation };
 
 export default async ({ message, user }) => {
   let userId;