#474 Start/stop notifications processing

src/App.vue

@@ -90,6 +90,12 @@ export default {
       return this.$store.state.auth.currentUser.displayName ? this.$store.state.auth.currentUser.displayName : this.$store.state.auth.currentUser.email;
     },
   },
+  created() {
+    this.$store.dispatch('services/bind');
+  },
+  destroyed() {
+    this.$store.dispatch('services/unbind');
+  },
   methods: {
     signOut() {
       auth().signOut();

src/store.js

@@ -5,6 +5,7 @@ Vue.use(Vuex);
 
 // Vuex modules
 import auth from '@/store/auth';
+import services from '@/store/services';
 import exerciseCollection from '@/store/exercise/collection';
 import exerciseCreateJourney from '@/store/exercise/createJourney';
 import exerciseDocument from '@/store/exercise/document';
@@ -23,6 +24,7 @@ const store = new Vuex.Store({
   strict: process.env.NODE_ENV !== 'production',
   modules: {
     auth,
+    services,
     exerciseCollection,
     exerciseCreateJourney,
     exerciseDocument,

src/store/services.js

@@ -0,0 +1,29 @@
+import { firestore } from '@/firebase';
+import { firestoreAction } from 'vuexfire';
+import vuexfireSerialize from '@/helpers/vuexfireSerialize';
+
+export default {
+  namespaced: true,
+  actions: {
+    bind: firestoreAction(({ bindFirestoreRef }) => {
+      const firestoreRef = firestore.doc('settings/services');
+      return bindFirestoreRef('record', firestoreRef, { serialize: vuexfireSerialize });
+    }),
+    unbind: firestoreAction(({ unbindFirestoreRef }) => {
+      return unbindFirestoreRef('record');
+    }),
+    notificationsStart() {
+      return firestore.doc('settings/services').update({
+        'notifications.isProcessing': true,
+      });
+    },
+    notificationsStop() {
+      return firestore.doc('settings/services').update({
+        'notifications.isProcessing': false,
+      });
+    },
+  },
+  state: {
+    record: null,
+  },
+};

src/views/NotificationsList.vue

@@ -152,7 +152,6 @@ export default {
         },
       ],
       activeTab: 'queue',
-      processing: false,
     };
   },
   computed: {
@@ -169,24 +168,20 @@ export default {
       return this.currentView === 'sent';
     },
     isProcessing() {
-      return this.processing;
+      const services = this.$store.state.services.record;
+      return services && services.notifications && services.notifications.isProcessing;
     },
   },
   created() {
     this.$store.dispatch('notifications/bindQueue');
     this.$store.dispatch('notifications/bindSent');
   },
   methods: {
-    showTab(tab) {
-      this.currentView = tab;
-    },
     startProcessing() {
-      this.processing = !this.processing;
-      console.log('start processing');
+      this.$store.dispatch('services/notificationsStart');
     },
     stopProcessing() {
-      this.processing = !this.processing;
-      console.log('stop processing');
+      this.$store.dispatch('services/notificationsStop');
     },
   },
 };