handle add push notification

Author: ManAnRuck

package.json

@@ -32,6 +32,7 @@
     "merge-graphql-schemas": "^1.3.0",
     "mongoose": "^5.0.3",
     "node-fetch": "^2.0.0",
+    "node-gcm": "^0.14.10",
     "passport": "^0.4.0",
     "passport-jwt": "^4.0.0",
     "prettier-eslint": "^8.2.0",

src/graphql/resolvers/Notification.js

@@ -5,9 +5,13 @@ export default {
 
   Mutation: {
     addToken: async (parent, { token, os }, { user }) => {
-      console.log('x');
-      console.log(` ### addToken ### , Token: "${token}, os: "${os}"`);
-      console.log('y');
+      if (!user.pushTokens.some(t => t.token === token)) {
+        user.pushTokens.push({ token, os });
+        user.save();
+      }
+      return {
+        succeeded: true,
+      };
     },
   },
 };

src/index.js

@@ -16,7 +16,7 @@ import webhook from './scripts/webhook';
 // import importAll from './scripts/importAll';
 
 import auth from './express/auth';
-import './services/notifications/apn';
+import pushNotify from './services/notifications';
 
 // Models
 import ProcedureModel from './models/Procedure';
@@ -87,6 +87,19 @@ 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");
+});
+
 // Darf in Production nicht ausführbar sein!
 // app.get('/webhooks/bundestagio/import-all', importAll);
 

src/models/User.js

@@ -5,6 +5,12 @@ import jwt from 'jsonwebtoken';
 const UserSchema = new Schema(
   {
     deviceHash: { type: String, required: true, unique: true },
+    pushTokens: [
+      {
+        token: String,
+        os: String,
+      },
+    ],
   },
   { timestamps: true },
 );

src/services/notifications/apn.js

@@ -1,29 +1,18 @@
 import apn from 'apn';
 
-const options = {
-  token: {
-    key: process.env.APPLE_APN_KEY,
-    keyId: process.env.APPLE_APN_KEY_ID,
-    teamId: process.env.APPLE_TEAMID,
-  },
-  production: false,
-};
+let apnProvider; // eslint-disable-line
 
-const apnProvider = new apn.Provider(options);
+if (!apnProvider) {
+  const options = {
+    token: {
+      key: process.env.APPLE_APN_KEY,
+      keyId: process.env.APPLE_APN_KEY_ID,
+      teamId: process.env.APPLE_TEAMID,
+    },
+    production: false,
+  };
 
-const deviceToken = 'c6a966484866d2d274d4660e9e593ccbc35636894eb08e2b1fb4070396bcaad5';
-
-const note = new apn.Notification();
-
-note.expiry = Math.floor(Date.now() / 1000) + 3600; // Expires 1 hour from now.
-note.badge = 3;
-note.sound = 'ping.aiff';
-note.alert = '\uD83D\uDCE7 \u2709 You have a new message';
-note.payload = { messageFrom: 'John Appleseed' };
-note.topic = 'de.democracy-deutschland.clientapp';
+  apnProvider = new apn.Provider(options);
+}
 
 export default apnProvider;
-
-apnProvider.send(note, deviceToken).then((result) => {
-  console.log('apnProvider.send', result);
-});

src/services/notifications/gcm.js

@@ -0,0 +1,44 @@
+/* eslint no-underscore-dangle: ["error", { "allow": ["_id"] }] */
+
+import _ from 'lodash';
+import apn from 'apn';
+
+import apnProvider from './apn';
+import gcmProvicer from './gcm';
+import UserModel from '../../models/User';
+
+export default async ({ message, user }) => {
+  let userId;
+  if (_.isObject(user)) {
+    userId = user._id;
+  }
+  const userObj = await UserModel.findById(userId);
+  if (userObj) {
+    userObj.pushTokens.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;
+
+        // Hier android und checken ob der case identifier korrekt ist.
+        case 'android':
+          // gcm
+
+          break;
+
+        default:
+          break;
+      }
+    });
+  }
+};

src/services/notifications/index.js

@@ -2848,7 +2848,7 @@ [email protected]:
   version "4.0.1"
   resolved "https://registry.yarnpkg.com/lodash.unescape/-/lodash.unescape-4.0.1.tgz#bf2249886ce514cda112fae9218cdc065211fc9c"
 
-[email protected]:
+[email protected], lodash@^3.10.1:
   version "3.10.1"
   resolved "https://registry.yarnpkg.com/lodash/-/lodash-3.10.1.tgz#5bf45e8e49ba4189e17d482789dfd15bd140b7b6"
 
@@ -3106,6 +3106,14 @@ node-forge@^0.7.1:
   version "0.7.4"
   resolved "https://registry.yarnpkg.com/node-forge/-/node-forge-0.7.4.tgz#8e6e9f563a1e32213aa7508cded22aa791dbf986"
 
+node-gcm@^0.14.10:
+  version "0.14.10"
+  resolved "https://registry.yarnpkg.com/node-gcm/-/node-gcm-0.14.10.tgz#fd1e3357dab1c62115e6e2d342ac249fe05e7360"
+  dependencies:
+    debug "^3.1.0"
+    lodash "^3.10.1"
+    request "2.81.0"
+
 node-pre-gyp@^0.6.39:
   version "0.6.39"
   resolved "https://registry.yarnpkg.com/node-pre-gyp/-/node-pre-gyp-0.6.39.tgz#c00e96860b23c0e1420ac7befc5044e1d78d8649"