wekan/client/components/notifications/notificationsDrawer.js

import { ReactiveCache } from '/imports/reactiveCache';
import { toggleNotificationsDrawer } from './notifications.js';

Template.notificationsDrawer.onCreated(function() {
  Meteor.subscribe('notificationActivities');
  Meteor.subscribe('notificationCards');
  Meteor.subscribe('notificationUsers');
  Meteor.subscribe('notificationsAttachments');
  Meteor.subscribe('notificationChecklistItems');
  Meteor.subscribe('notificationChecklists');
  Meteor.subscribe('notificationComments');
  Meteor.subscribe('notificationLists');
  Meteor.subscribe('notificationSwimlanes');
});

Template.notificationsDrawer.helpers({
  transformedProfile() {
    return ReactiveCache.getCurrentUser();
  },
  readNotifications() {
    const readNotifications = _.filter(
      ReactiveCache.getCurrentUser().profile.notifications,
      v => !!v.read,
    );
    return readNotifications.length;
  },
});

Template.notificationsDrawer.events({
  'click .all-read'() {
    const notifications = ReactiveCache.getCurrentUser().profile.notifications;
    for (const index in notifications) {
      if (notifications.hasOwnProperty(index) && !notifications[index].read) {
        const update = {};
        update[`profile.notifications.${index}.read`] = Date.now();
        Users.update(Meteor.userId(), { $set: update });
      }
    }
  },
  'click .close'() {
    toggleNotificationsDrawer();
  },
  'click .toggle-read'() {
    Session.set('showReadNotifications', !Session.get('showReadNotifications'));
  },
  'click .remove-read'() {
    const user = ReactiveCache.getCurrentUser();
    for (const notification of user.profile.notifications) {
      if (notification.read) {
        user.removeNotification(notification.activity);
      }
    }
  },
});