signal-desktop/js/models/blockedNumbers.js

/* global storage, _, ConversationController */

// eslint-disable-next-line func-names
(function() {
  'use strict';

  const BLOCKED_NUMBERS_ID = 'blocked';
  const BLOCKED_UUIDS_ID = 'blocked-uuids';
  const BLOCKED_GROUPS_ID = 'blocked-groups';

  storage.isBlocked = number => {
    const numbers = storage.get(BLOCKED_NUMBERS_ID, []);

    return _.include(numbers, number);
  };
  storage.addBlockedNumber = number => {
    const numbers = storage.get(BLOCKED_NUMBERS_ID, []);
    if (_.include(numbers, number)) {
      return;
    }

    window.log.info('adding', number, 'to blocked list');
    storage.put(BLOCKED_NUMBERS_ID, numbers.concat(number));
  };
  storage.removeBlockedNumber = number => {
    const numbers = storage.get(BLOCKED_NUMBERS_ID, []);
    if (!_.include(numbers, number)) {
      return;
    }

    window.log.info('removing', number, 'from blocked list');
    storage.put(BLOCKED_NUMBERS_ID, _.without(numbers, number));
  };

  storage.isUuidBlocked = uuid => {
    const uuids = storage.get(BLOCKED_UUIDS_ID, []);

    return _.include(uuids, uuid);
  };
  storage.addBlockedUuid = uuid => {
    const uuids = storage.get(BLOCKED_UUIDS_ID, []);
    if (_.include(uuids, uuid)) {
      return;
    }

    window.log.info('adding', uuid, 'to blocked list');
    storage.put(BLOCKED_UUIDS_ID, uuids.concat(uuid));
  };
  storage.removeBlockedUuid = uuid => {
    const numbers = storage.get(BLOCKED_UUIDS_ID, []);
    if (!_.include(numbers, uuid)) {
      return;
    }

    window.log.info('removing', uuid, 'from blocked list');
    storage.put(BLOCKED_NUMBERS_ID, _.without(numbers, uuid));
  };

  storage.isGroupBlocked = groupId => {
    const groupIds = storage.get(BLOCKED_GROUPS_ID, []);

    return _.include(groupIds, groupId);
  };
  storage.addBlockedGroup = groupId => {
    const groupIds = storage.get(BLOCKED_GROUPS_ID, []);
    if (_.include(groupIds, groupId)) {
      return;
    }

    window.log.info(`adding groupId(${groupId}) to blocked list`);
    storage.put(BLOCKED_GROUPS_ID, groupIds.concat(groupId));
  };
  storage.removeBlockedGroup = groupId => {
    const groupIds = storage.get(BLOCKED_GROUPS_ID, []);
    if (!_.include(groupIds, groupId)) {
      return;
    }

    window.log.info(`removing group(${groupId} from blocked list`);
    storage.put(BLOCKED_GROUPS_ID, _.without(groupIds, groupId));
  };

  /**
   * Optimistically adds a conversation to our local block list.
   * @param {string} id
   */
  storage.blockIdentifier = id => {
    const conv = ConversationController.get(id);
    if (conv) {
      const uuid = conv.get('uuid');
      if (uuid) {
        storage.addBlockedUuid(uuid);
      }
      const e164 = conv.get('e164');
      if (e164) {
        storage.addBlockedNumber(e164);
      }
      const groupId = conv.get('groupId');
      if (groupId) {
        storage.addBlockedGroup(groupId);
      }
    }
  };

  /**
   * Optimistically removes a conversation from our local block list.
   * @param {string} id
   */
  storage.unblockIdentifier = id => {
    const conv = ConversationController.get(id);
    if (conv) {
      const uuid = conv.get('uuid');
      if (uuid) {
        storage.removeBlockedUuid(uuid);
      }
      const e164 = conv.get('e164');
      if (e164) {
        storage.removeBlockedNumber(e164);
      }
      const groupId = conv.get('groupId');
      if (groupId) {
        storage.removeBlockedGroup(groupId);
      }
    }
  };
})();