Merge pull request #41 from demokratie-live/sprint#7/push-notifications

Sprint#7/push notifications

Author: ManAnRuck

.env.example

@@ -0,0 +1,7 @@
+SECRET_KEY=
+AUTH_JWT_SECRET=
+ENGINE_API_KEY=
+APPLE_TEAMID=
+APPLE_APN_KEY_ID=
+APPLE_APN_KEY=
+NOTIFICATION_ANDROID_SERVER_KEY=

.gitignore

@@ -1,4 +1,5 @@
 node_modules/
 *.env
 *.log
-/dist/*
+/dist/*
+AuthKey_*.p8

package.json

@@ -13,6 +13,7 @@
     "serve": "node dist/index.js"
   },
   "dependencies": {
+    "apn": "^2.2.0",
     "apollo-cache-inmemory": "^1.1.7",
     "apollo-client": "^2.2.3",
     "apollo-engine": "^0.8.8",
@@ -31,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/config/constants.js

@@ -6,4 +6,5 @@ export default {
   GRAPHIQL_PATH: '/graphiql',
   GRAPHQL_PATH: '/graphql',
   BUNDESTAGIO_SERVER_URL: process.env.BUNDESTAGIO_SERVER_URL || 'http://localhost:3100/graphql',
+  NOTIFICATION_ANDROID_SERVER_KEY: process.env.NOTIFICATION_ANDROID_SERVER_KEY || false,
 };

src/graphql/queries/getAllProcedures.js

@@ -10,6 +10,7 @@ export default gql`
       currentStatus
       abstract
       tags
+      bioUpdateAt
       subjectGroups
       history {
         assignment

src/graphql/queries/getProcedureUpdates.js

@@ -4,7 +4,7 @@ export default gql`
   query procedureUpdates($period: [Int!], $type: [String!]) {
     procedureUpdates(period: $period, type: $type) {
       procedureId
-      updatedAt
+      bioUpdateAt
     }
   }
 `;

src/graphql/queries/getProcedures.js

@@ -11,6 +11,7 @@ export default gql`
       abstract
       tags
       subjectGroups
+      bioUpdateAt
       history {
         assignment
         initiator

src/graphql/resolvers/Notification.js

@@ -0,0 +1,87 @@
+/* eslint no-underscore-dangle: ["error", { "allow": ["_id"] }] */
+/* eslint no-param-reassign: 0 */
+
+import _ from 'lodash';
+import Activity from './Activity';
+
+export default {
+  Query: {
+    notificationSettings: async (parent, args, { user }) => {
+      if (!user) {
+        throw new Error('no Auth');
+      }
+      return user.notificationSettings;
+    },
+  },
+
+  Mutation: {
+    addToken: async (parent, { token, os }, { user }) => {
+      if (!user) {
+        throw new Error('no Auth');
+      }
+      if (!user.pushTokens.some(t => t.token === token)) {
+        user.pushTokens.push({ token, os });
+        user.save();
+      }
+      return {
+        succeeded: true,
+      };
+    },
+
+    updateNotificationSettings: async (
+      parent,
+      {
+        enabled, disableUntil, procedures, tags, newVote, newPreperation,
+      },
+      { user },
+    ) => {
+      if (!user) {
+        throw new Error('no Auth');
+      }
+      user.notificationSettings = {
+        ...user.notificationSettings,
+        ..._.omitBy(
+          {
+            enabled,
+            disableUntil,
+            procedures,
+            tags,
+            newVote,
+            newPreperation,
+          },
+          _.isNil,
+        ),
+      };
+      await user.save();
+      return user.notificationSettings;
+    },
+
+    toggleNotification: async (
+      parent,
+      { procedureId },
+      { user, ProcedureModel, ActivityModel },
+    ) => {
+      if (!user) {
+        throw new Error('no Auth');
+      }
+      const procedure = await ProcedureModel.findOne({ procedureId });
+      await Activity.Mutation.increaseActivity(
+        parent,
+        { procedureId },
+        { ProcedureModel, ActivityModel, user },
+      );
+
+      const index = user.notificationSettings.procedures.indexOf(procedure._id);
+      let notify;
+      if (index > -1) {
+        notify = false;
+        user.notificationSettings.procedures.splice(index, 1);
+      } else {
+        notify = true;
+        user.notificationSettings.procedures.push(procedure._id);
+      }
+      await user.save();
+      return { ...procedure.toObject(), notify };
+    },
+  },
+};

src/graphql/resolvers/Procedure.js

@@ -123,8 +123,13 @@ export default {
         .then(finishedVotings => [...activeVotings, ...finishedVotings]);
     },
 
-    procedure: async (parent, { id }, { ProcedureModel }) =>
-      ProcedureModel.findOne({ procedureId: id }),
+    procedure: async (parent, { id }, { user, ProcedureModel }) => {
+      const procedure = await ProcedureModel.findOne({ procedureId: id });
+      return {
+        ...procedure.toObject(),
+        notify: !!(user && user.notificationSettings.procedures.indexOf(procedure._id) > -1),
+      };
+    },
 
     searchProcedures: (parent, { term }, { ProcedureModel }) =>
       ProcedureModel.find(
@@ -140,6 +145,20 @@ export default {
         },
         { score: { $meta: 'textScore' } },
       ).sort({ score: { $meta: 'textScore' } }),
+
+    notifiedProcedures: async (parent, args, { user, ProcedureModel }) => {
+      if (!user) {
+        throw new Error('no Auth');
+      }
+      const procedures = await ProcedureModel.find({
+        _id: { $in: user.notificationSettings.procedures },
+      });
+
+      return procedures.map(procedure => ({
+        ...procedure.toObject(),
+        notify: true,
+      }));
+    },
   },
 
   Procedure: {

src/graphql/schemas/Notification.js

@@ -0,0 +1,35 @@
+export default `
+
+  type TokenResult {
+      succeeded: Boolean
+  }
+
+  type NotificationSettings {
+    enabled: Boolean
+    newVote: Boolean
+    newPreperation: Boolean
+    disableUntil: Date
+    procedures: [String]
+    tags: [String]
+  }
+
+  type Query {
+    notificationSettings: NotificationSettings
+  }
+
+  type Mutation {
+    addToken(token: String!, os: String!): TokenResult
+    
+    updateNotificationSettings(
+      enabled: Boolean,
+      newVote: Boolean,
+      newPreperation: Boolean, 
+      disableUntil: Date, 
+      procedures: [String], 
+      tags: [String]
+    ): NotificationSettings
+
+    toggleNotification(procedureId: String!): Procedure
+  }
+
+  `;