habitica/website/client-old/js/controllers/notificationCtrl.js

'use strict';

habitrpg.controller('NotificationCtrl',
  ['$scope', '$rootScope', 'Shared', 'Content', 'User', 'Guide', 'Notification', 'Analytics', 'Achievement', 'Social', 'Tasks', '$modal',
  function ($scope, $rootScope, Shared, Content, User, Guide, Notification, Analytics, Achievement, Social, Tasks, $modal) {
    var isRunningYesterdailies = false;

    $rootScope.$watch('user', function (after, before) {
      runYesterDailies();
    });

    $rootScope.$on('userUpdated', function (after, before) {
      runYesterDailies();
    });

    function runYesterDailies() {
      if (isRunningYesterdailies) return;

      var userLastCron = moment(User.user.lastCron).local();
      var userDayStart = moment().startOf('day').add({ hours: User.user.preferences.dayStart });

      if (!User.user.needsCron) return;
      var dailys = User.user.dailys;

      if (!$rootScope.appLoaded) return;

      isRunningYesterdailies = true;

      var yesterDay = moment().subtract('1', 'day').startOf('day').add({ hours: User.user.preferences.dayStart });
      var yesterDailies = [];
      dailys.forEach(function (task) {
        if (task && task.group.approval && task.group.approval.requested) return;
        if (task.completed) return;
        var shouldDo = Shared.shouldDo(yesterDay, task);

        if (task.yesterDaily && shouldDo) yesterDailies.push(task);
      });

      if (yesterDailies.length === 0) {
        User.runCron().then(function () {
          isRunningYesterdailies = false;
          handleUserNotifications(User.user);
        });
        return;
      };

      var modalScope = $rootScope.$new();
      modalScope.obj = User.user;
      modalScope.taskList = yesterDailies;
      modalScope.list = {
        showCompleted: false,
        type: 'daily',
      };
      modalScope.processingYesterdailies = true;

      $scope.yesterDailiesModalOpen = true;
      $modal.open({
        templateUrl: 'modals/yesterDailies.html',
        scope: modalScope,
        backdrop: 'static',
        controller: ['$scope', 'Tasks', 'User', '$rootScope', function ($scope, Tasks, User, $rootScope) {
          $rootScope.$on('task:scored', function (event, data) {
            var task = data.task;
            var indexOfTask = _.findIndex($scope.taskList, function (taskInList) {
              return taskInList._id === task._id;
            });
            if (!$scope.taskList[indexOfTask]) return;
            $scope.taskList[indexOfTask].group.approval.requested = task.group.approval.requested;
            if ($scope.taskList[indexOfTask].group.approval.requested) return;
            $scope.taskList[indexOfTask].completed = task.completed;
          });

          $scope.ageDailies = function () {
            User.runCron()
              .then(function () {
                isRunningYesterdailies = false;
                handleUserNotifications(User.user);
              });
          };
        }],
      });
    }

    $rootScope.$watch('user.stats.hp', function (after, before) {
      if (after <= 0){
        $rootScope.playSound('Death');
        $rootScope.openModal('death', {keyboard:false, backdrop:'static'});
      } else if (after <= 30 && !User.user.flags.warnedLowHealth) {
        $rootScope.openModal('lowHealth', {keyboard:false, backdrop:'static', controller:'UserCtrl', track:'Health Warning'});
      }
      if (after == before) return;
      if (User.user.stats.lvl == 0) return;
      Notification.hp(after - before, 'hp');
      $rootScope.$broadcast('syncPartyRequest', {
        type: 'user_update',
        user: User.user,
      }); // Sync party to update members
      if (after < 0) $rootScope.playSound('Minus_Habit');
    });

    $rootScope.$watch('user.stats.exp', function(after, before) {
      if (after == before) return;
      if (User.user.stats.lvl == 0) return;
      Notification.exp(after - before);
    });

    $rootScope.$watch('user.stats.gp', function(after, before) {
      if (after == before) return;
      if (User.user.stats.lvl == 0) return;
      var money = after - before;
      var bonus;
      if (User.user._tmp) {
        bonus = User.user._tmp.streakBonus || 0;
      }
      Notification.gp(money, bonus || 0);

      //Append Bonus

      if ((money > 0) && !!bonus) {
        if (bonus < 0.01) bonus = 0.01;
        Notification.text("+ " + Notification.coins(bonus) + ' ' + window.env.t('streakCoins'));
        delete User.user._tmp.streakBonus;
      }
    });

    $rootScope.$watch('user.stats.mp', function(after,before) {
       if (after == before) return;
       if (!User.user.flags.classSelected || User.user.preferences.disableClasses) return;
       var mana = after - before;
       Notification.mp(mana);
    });

    // Levels that already display modals and should not trigger generic Level Up
    var unlockLevels = {
      '3': 'drop system',
      '10': 'class system',
      '50': 'Orb of Rebirth'
    }

    $rootScope.$watch('user.stats.lvl', function(after, before) {
      if (after <= before) return;
      Notification.lvl();
      $rootScope.playSound('Level_Up');
      if (User.user._tmp && User.user._tmp.drop && (User.user._tmp.drop.type === 'Quest')) return;
      if (unlockLevels['' + after]) return;
      if (!User.user.preferences.suppressModals.levelUp) $rootScope.openModal('levelUp', {controller:'UserCtrl', size:'sm'});
    });

    $rootScope.$watch('!user.flags.classSelected && user.stats.lvl >= 10', function(after, before){
      if(after){
        $rootScope.openModal('chooseClass', {controller:'UserCtrl', keyboard:false, backdrop:'static'});
      }
    });

    // Avoid showing the same notiication more than once
    var lastShownNotifications = [];

    function transferGroupNotification(notification) {
      if (!User.user.groupNotifications) User.user.groupNotifications = [];
      User.user.groupNotifications.push(notification);
    }

    var alreadyReadNotification = [];

    function handleUserNotifications (after) {
      if (!after || after.length === 0) return;

      var notificationsToRead = [];
      var scoreTaskNotification = [];

      User.user.groupNotifications = []; // Flush group notifictions

      after.forEach(function (notification) {
        if (lastShownNotifications.indexOf(notification.id) !== -1) {
          return;
        }

        // Some notifications are not marked read here, so we need to fix this system
        // to handle notifications differently
        if (['GROUP_TASK_APPROVED', 'GROUP_TASK_APPROVAL'].indexOf(notification.type) === -1) {
          lastShownNotifications.push(notification.id);
          if (lastShownNotifications.length > 10) {
            lastShownNotifications.splice(0, 9);
          }
        }

        var markAsRead = true;

        switch (notification.type) {
          case 'GUILD_PROMPT':
            if (notification.data.textVariant === -1) {
              $rootScope.openModal('testing');
            } else {
              $rootScope.openModal('testingVariant');
            }
            break;
          case 'DROPS_ENABLED':
            $rootScope.openModal('dropsEnabled');
            break;
          case 'REBIRTH_ENABLED':
            $rootScope.openModal('rebirthEnabled');
            break;
          case 'WON_CHALLENGE':
            User.sync().then( function() {
              Achievement.displayAchievement('wonChallenge');
            });
            break;
          case 'STREAK_ACHIEVEMENT':
            Notification.streak(User.user.achievements.streak);
            $rootScope.playSound('Achievement_Unlocked');
            if (!User.user.preferences.suppressModals.streak) {
              Achievement.displayAchievement('streak', {size: 'md'});
            }
            break;
          case 'ULTIMATE_GEAR_ACHIEVEMENT':
            $rootScope.playSound('Achievement_Unlocked');
            Achievement.displayAchievement('ultimateGear', {size: 'md'});
            break;
          case 'REBIRTH_ACHIEVEMENT':
            $rootScope.playSound('Achievement_Unlocked');
            Achievement.displayAchievement('rebirth');
            break;
          case 'GUILD_JOINED_ACHIEVEMENT':
            $rootScope.playSound('Achievement_Unlocked');
            Achievement.displayAchievement('joinedGuild', {size: 'md'});
            break;
          case 'CHALLENGE_JOINED_ACHIEVEMENT':
            $rootScope.playSound('Achievement_Unlocked');
            Achievement.displayAchievement('joinedChallenge', {size: 'md'});
            break;
          case 'INVITED_FRIEND_ACHIEVEMENT':
            $rootScope.playSound('Achievement_Unlocked');
            Achievement.displayAchievement('invitedFriend', {size: 'md'});
            break;
          case 'NEW_CONTRIBUTOR_LEVEL':
            $rootScope.playSound('Achievement_Unlocked');
            Achievement.displayAchievement('contributor', {size: 'md'});
            break;
          case 'CRON':
            if (notification.data) {
              if (notification.data.hp) Notification.hp(notification.data.hp, 'hp');
              if (notification.data.mp) Notification.mp(notification.data.mp);
            }
            break;
          case 'GROUP_TASK_APPROVAL':
            transferGroupNotification(notification);
            markAsRead = false;
            break;
          case 'GROUP_TASK_APPROVED':
            transferGroupNotification(notification);
            markAsRead = false;
            break;
          case 'SCORED_TASK':
            // Search if it is a read notification
            for (var i = 0; i < alreadyReadNotification.length; i++) {
              if (alreadyReadNotification[i] == notification.id) {
                markAsRead = false; // Do not let it be read again
                break;
              }
            }

            // Only process the notification if it is an unread notification
            if (markAsRead) {
              scoreTaskNotification.push(notification);

              // Add to array of read notifications
              alreadyReadNotification.push(notification.id);
            }
            break;
          case 'LOGIN_INCENTIVE':
            Notification.showLoginIncentive(User.user, notification.data, Social.loadWidgets);
            break;
          default:
            if (notification.data.headerText && notification.data.bodyText) {
              var modalScope = $rootScope.$new();
              modalScope.data = notification.data;
              $rootScope.openModal('generic', {scope: modalScope});
            }
            else {
              markAsRead = false; // If the notification is not implemented, skip it
            }
            break;
        }

        if (markAsRead) notificationsToRead.push(notification.id);
      });

      var userReadNotifsPromise = User.readNotifications(notificationsToRead);

      if (userReadNotifsPromise) {
        userReadNotifsPromise.then(function () {

          // Only run this code for scoring approved tasks
          if (scoreTaskNotification.length > 0) {
            var approvedTasks = [];
            for (var i = 0; i < scoreTaskNotification.length; i++) {
              // Array with all approved tasks
              approvedTasks.push({
                params: {
                  task: scoreTaskNotification[i].data.scoreTask,
                  direction: "up"
                }
              });

              // Show notification of task approved
              Notification.markdown(scoreTaskNotification[i].data.message);
            }

            // Score approved tasks
            User.bulkScore(approvedTasks);
          }
        });
      }

      User.user.notifications = []; // reset the notifications
    }

    // Since we don't use localStorage anymore, notifications for achievements and new contributor levels
    // are now stored in user.notifications.
    $rootScope.$watchCollection('userNotifications', function (after) {
      if (!User.user._wrapped) return;
      if (User.user.needsCron) return;
      handleUserNotifications(after);
    });

    // var handleUserNotificationsOnFirstSync = _.once(function () {
    //   handleUserNotifications($rootScope.userNotifications);
    // });
    // $rootScope.$on('userUpdated', handleUserNotificationsOnFirstSync);

    // TODO what about this?
    $rootScope.$watch('user.achievements', function(){
      $rootScope.playSound('Achievement_Unlocked');
    }, true);

    $rootScope.$watch('user.flags.armoireEmpty', function(after,before){
      if (after == before || after == false) return;
      $rootScope.openModal('armoireEmpty');
    });

    // Completed quest modal
    $scope.$watch('user.party.quest.completed', function(after, before){
      if (!after) return;
      $rootScope.openModal('questCompleted', {controller:'InventoryCtrl'});
    });

    // Quest invitation modal
    $scope.$watch('user.party.quest.RSVPNeeded && !user.party.quest.completed', function(after, before){
      if (after != true) return;
      $rootScope.openModal('questInvitation', {controller:'PartyCtrl'});
    });

    $rootScope.$on('responseError500', function(ev, error){
      Notification.error(error);
    });
    $rootScope.$on('responseError', function(ev, error){
      Notification.error(error, true);
    });

    $rootScope.$on('responseText', function(ev, error){
      Notification.text(error);
    });

    // Show new-stuff modal on load
    if (User.user.flags.newStuff)
      $rootScope.openModal('newStuff', {size:'lg'});
  }
]);