signal-desktop/js/models/messages.js

/* global
  _,
  Backbone,
  storage,
  filesize,
  ConversationController,
  MessageController,
  getAccountManager,
  i18n,
  Signal,
  textsecure,
  Whisper
*/

/* eslint-disable more/no-then */

// eslint-disable-next-line func-names
(function() {
  window.Whisper = window.Whisper || {};

  const {
    Message: TypedMessage,
    Attachment,
    MIME,
    Contact,
    PhoneNumber,
    Errors,
  } = Signal.Types;
  const {
    deleteExternalMessageFiles,
    getAbsoluteAttachmentPath,
    loadAttachmentData,
    loadQuoteData,
    loadPreviewData,
    loadStickerData,
    upgradeMessageSchema,
  } = window.Signal.Migrations;
  const {
    copyStickerToAttachments,
    deletePackReference,
    savePackMetadata,
    getStickerPackStatus,
  } = window.Signal.Stickers;
  const { GoogleChrome } = window.Signal.Util;

  const { addStickerPackReference, getMessageBySender } = window.Signal.Data;
  const { bytesFromString } = window.Signal.Crypto;
  const PLACEHOLDER_CONTACT = {
    title: i18n('unknownContact'),
  };

  window.AccountCache = Object.create(null);
  window.AccountJobs = Object.create(null);

  window.doesAccountCheckJobExist = number =>
    Boolean(window.AccountJobs[number]);
  window.checkForSignalAccount = number => {
    if (window.AccountJobs[number]) {
      return window.AccountJobs[number];
    }

    let job;
    if (textsecure.messaging) {
      // eslint-disable-next-line more/no-then
      job = textsecure.messaging
        .getProfile(number)
        .then(() => {
          window.AccountCache[number] = true;
        })
        .catch(() => {
          window.AccountCache[number] = false;
        });
    } else {
      // We're offline!
      job = Promise.resolve().then(() => {
        window.AccountCache[number] = false;
      });
    }

    window.AccountJobs[number] = job;

    return job;
  };

  window.isSignalAccountCheckComplete = number =>
    window.AccountCache[number] !== undefined;
  window.hasSignalAccount = number => window.AccountCache[number];

  const includesAny = (haystack, ...needles) =>
    needles.some(needle => haystack.includes(needle));

  window.Whisper.Message = Backbone.Model.extend({
    initialize(attributes) {
      if (_.isObject(attributes)) {
        this.set(
          TypedMessage.initializeSchemaVersion({
            message: attributes,
            logger: window.log,
          })
        );
      }

      this.CURRENT_PROTOCOL_VERSION =
        textsecure.protobuf.DataMessage.ProtocolVersion.CURRENT;
      this.INITIAL_PROTOCOL_VERSION =
        textsecure.protobuf.DataMessage.ProtocolVersion.INITIAL;
      this.OUR_NUMBER = textsecure.storage.user.getNumber();
      this.OUR_UUID = textsecure.storage.user.getUuid();

      this.on('destroy', this.onDestroy);
      this.on('change:expirationStartTimestamp', this.setToExpire);
      this.on('change:expireTimer', this.setToExpire);
      this.on('unload', this.unload);
      this.on('expired', this.onExpired);
      this.setToExpire();

      this.on('change', this.notifyRedux);
    },

    notifyRedux() {
      const { messageChanged } = window.reduxActions.conversations;

      if (messageChanged) {
        const conversationId = this.get('conversationId');
        // Note: The clone is important for triggering a re-run of selectors
        messageChanged(this.id, conversationId, this.getReduxData());
      }
    },

    getReduxData() {
      const contact = this.getPropsForEmbeddedContact();

      return {
        ...this.attributes,
        // We need this in the reducer to detect if the message's height has changed
        hasSignalAccount: contact ? Boolean(contact.signalAccount) : null,
      };
    },

    isNormalBubble() {
      return (
        !this.isCallHistory() &&
        !this.isEndSession() &&
        !this.isExpirationTimerUpdate() &&
        !this.isGroupUpdate() &&
        !this.isGroupV2Change() &&
        !this.isKeyChange() &&
        !this.isMessageHistoryUnsynced() &&
        !this.isProfileChange() &&
        !this.isUnsupportedMessage() &&
        !this.isVerifiedChange()
      );
    },

    // Top-level prop generation for the message bubble
    getPropsForBubble() {
      if (this.isUnsupportedMessage()) {
        return {
          type: 'unsupportedMessage',
          data: this.getPropsForUnsupportedMessage(),
        };
      }
      if (this.isGroupV2Change()) {
        return {
          type: 'groupV2Change',
          data: this.getPropsForGroupV2Change(),
        };
      }
      if (this.isMessageHistoryUnsynced()) {
        return {
          type: 'linkNotification',
          data: null,
        };
      }
      if (this.isExpirationTimerUpdate()) {
        return {
          type: 'timerNotification',
          data: this.getPropsForTimerNotification(),
        };
      }
      if (this.isKeyChange()) {
        return {
          type: 'safetyNumberNotification',
          data: this.getPropsForSafetyNumberNotification(),
        };
      }
      if (this.isVerifiedChange()) {
        return {
          type: 'verificationNotification',
          data: this.getPropsForVerificationNotification(),
        };
      }
      if (this.isGroupUpdate()) {
        return {
          type: 'groupNotification',
          data: this.getPropsForGroupNotification(),
        };
      }
      if (this.isEndSession()) {
        return {
          type: 'resetSessionNotification',
          data: this.getPropsForResetSessionNotification(),
        };
      }
      if (this.isCallHistory()) {
        return {
          type: 'callHistory',
          data: this.getPropsForCallHistory(),
        };
      }
      if (this.isProfileChange()) {
        return {
          type: 'profileChange',
          data: this.getPropsForProfileChange(),
        };
      }

      return {
        type: 'message',
        data: this.getPropsForMessage(),
      };
    },

    // Other top-level prop-generation
    getPropsForSearchResult() {
      const sourceId = this.getContactId();
      const from = this.findAndFormatContact(sourceId);
      const convo = this.getConversation();
      const to = this.findAndFormatContact(convo.get('id'));

      return {
        from,
        to,

        isSelected: this.isSelected,

        id: this.id,
        conversationId: this.get('conversationId'),
        sentAt: this.get('sent_at'),
        snippet: this.get('snippet'),
      };
    },
    getPropsForMessageDetail() {
      const newIdentity = i18n('newIdentity');
      const OUTGOING_KEY_ERROR = 'OutgoingIdentityKeyError';

      const unidentifiedLookup = (
        this.get('unidentifiedDeliveries') || []
      ).reduce((accumulator, identifier) => {
        // eslint-disable-next-line no-param-reassign
        accumulator[
          ConversationController.getConversationId(identifier)
        ] = true;
        return accumulator;
      }, Object.create(null));

      // We include numbers we didn't successfully send to so we can display errors.
      // Older messages don't have the recipients included on the message, so we fall
      //   back to the conversation's current recipients
      const conversationIds = this.isIncoming()
        ? [this.getContactId()]
        : _.union(
            (this.get('sent_to') || []).map(id =>
              ConversationController.getConversationId(id)
            ),
            (
              this.get('recipients') || this.getConversation().getRecipients()
            ).map(id => ConversationController.getConversationId(id))
          );

      // This will make the error message for outgoing key errors a bit nicer
      const allErrors = (this.get('errors') || []).map(error => {
        if (error.name === OUTGOING_KEY_ERROR) {
          // eslint-disable-next-line no-param-reassign
          error.message = newIdentity;
        }

        return error;
      });

      // If an error has a specific number it's associated with, we'll show it next to
      //   that contact. Otherwise, it will be a standalone entry.
      const errors = _.reject(allErrors, error =>
        Boolean(error.identifer || error.number)
      );
      const errorsGroupedById = _.groupBy(allErrors, 'number');
      const finalContacts = (conversationIds || []).map(id => {
        const errorsForContact = errorsGroupedById[id];
        const isOutgoingKeyError = Boolean(
          _.find(errorsForContact, error => error.name === OUTGOING_KEY_ERROR)
        );
        const isUnidentifiedDelivery =
          storage.get('unidentifiedDeliveryIndicators') &&
          this.isUnidentifiedDelivery(id, unidentifiedLookup);

        return {
          ...this.findAndFormatContact(id),

          status: this.getStatus(id),
          errors: errorsForContact,
          isOutgoingKeyError,
          isUnidentifiedDelivery,
          onSendAnyway: () =>
            this.trigger('force-send', { contactId: id, messageId: this.id }),
          onShowSafetyNumber: () => this.trigger('show-identity', id),
        };
      });

      // The prefix created here ensures that contacts with errors are listed
      //   first; otherwise it's alphabetical
      const sortedContacts = _.sortBy(
        finalContacts,
        contact => `${contact.errors ? '0' : '1'}${contact.title}`
      );

      return {
        sentAt: this.get('sent_at'),
        receivedAt: this.get('received_at'),
        message: {
          ...this.getPropsForMessage(),
          disableMenu: true,
          disableScroll: true,
          // To ensure that group avatar doesn't show up
          conversationType: 'direct',
          downloadNewVersion: () => {
            this.trigger('download-new-version');
          },
          deleteMessage: messageId => {
            this.trigger('delete', messageId);
          },
          showVisualAttachment: options => {
            this.trigger('show-visual-attachment', options);
          },
          displayTapToViewMessage: messageId => {
            this.trigger('display-tap-to-view-message', messageId);
          },
          openLink: url => {
            this.trigger('navigate-to', url);
          },
          reactWith: emoji => {
            this.trigger('react-with', emoji);
          },
        },
        errors,
        contacts: sortedContacts,
      };
    },

    // Bucketing messages
    isUnsupportedMessage() {
      const versionAtReceive = this.get('supportedVersionAtReceive');
      const requiredVersion = this.get('requiredProtocolVersion');

      return (
        _.isNumber(versionAtReceive) &&
        _.isNumber(requiredVersion) &&
        versionAtReceive < requiredVersion
      );
    },
    isGroupV2Change() {
      return Boolean(this.get('groupV2Change'));
    },
    isExpirationTimerUpdate() {
      const flag =
        textsecure.protobuf.DataMessage.Flags.EXPIRATION_TIMER_UPDATE;
      // eslint-disable-next-line no-bitwise
      return Boolean(this.get('flags') & flag);
    },
    isKeyChange() {
      return this.get('type') === 'keychange';
    },
    isVerifiedChange() {
      return this.get('type') === 'verified-change';
    },
    isMessageHistoryUnsynced() {
      return this.get('type') === 'message-history-unsynced';
    },
    isGroupUpdate() {
      return !!this.get('group_update');
    },
    isEndSession() {
      const flag = textsecure.protobuf.DataMessage.Flags.END_SESSION;
      // eslint-disable-next-line no-bitwise
      return !!(this.get('flags') & flag);
    },
    isCallHistory() {
      return this.get('type') === 'call-history';
    },
    isProfileChange() {
      return this.get('type') === 'profile-change';
    },

    // Props for each message type
    getPropsForUnsupportedMessage() {
      const requiredVersion = this.get('requiredProtocolVersion');
      const canProcessNow = this.CURRENT_PROTOCOL_VERSION >= requiredVersion;
      const sourceId = this.getContactId();

      return {
        canProcessNow,
        contact: this.findAndFormatContact(sourceId),
      };
    },
    getPropsForGroupV2Change() {
      const { protobuf } = window.textsecure;

      return {
        AccessControlEnum: protobuf.AccessControl.AccessRequired,
        RoleEnum: protobuf.Member.Role,
        ourConversationId: window.ConversationController.getOurConversationId(),
        change: this.get('groupV2Change'),
      };
    },
    getPropsForTimerNotification() {
      const timerUpdate = this.get('expirationTimerUpdate');
      if (!timerUpdate) {
        return null;
      }

      const { expireTimer, fromSync, source, sourceUuid } = timerUpdate;
      const timespan = Whisper.ExpirationTimerOptions.getName(expireTimer || 0);
      const disabled = !expireTimer;

      const sourceId = ConversationController.ensureContactIds({
        e164: source,
        uuid: sourceUuid,
      });
      const ourId = ConversationController.getOurConversationId();
      const formattedContact = this.findAndFormatContact(sourceId);

      const basicProps = {
        ...formattedContact,
        type: 'fromOther',
        timespan,
        disabled,
      };

      if (fromSync) {
        return {
          ...basicProps,
          type: 'fromSync',
        };
      }
      if (sourceId && sourceId === ourId) {
        return {
          ...basicProps,
          type: 'fromMe',
        };
      }
      if (!sourceId) {
        return {
          ...basicProps,
          type: 'fromMember',
        };
      }

      return basicProps;
    },
    getPropsForSafetyNumberNotification() {
      const conversation = this.getConversation();
      const isGroup = conversation && !conversation.isPrivate();
      const identifier = this.get('key_changed');

      return {
        isGroup,
        contact: this.findAndFormatContact(identifier),
      };
    },
    getPropsForVerificationNotification() {
      const type = this.get('verified') ? 'markVerified' : 'markNotVerified';
      const isLocal = this.get('local');
      const identifier = this.get('verifiedChanged');

      return {
        type,
        isLocal,
        contact: this.findAndFormatContact(identifier),
      };
    },
    getPropsForGroupNotification() {
      const groupUpdate = this.get('group_update');
      const changes = [];

      if (
        !groupUpdate.avatarUpdated &&
        !groupUpdate.left &&
        !groupUpdate.joined &&
        !groupUpdate.name
      ) {
        changes.push({
          type: 'general',
        });
      }

      if (groupUpdate.joined) {
        changes.push({
          type: 'add',
          contacts: _.map(
            Array.isArray(groupUpdate.joined)
              ? groupUpdate.joined
              : [groupUpdate.joined],
            identifier => this.findAndFormatContact(identifier)
          ),
        });
      }

      if (groupUpdate.left === 'You') {
        changes.push({
          type: 'remove',
          isMe: true,
        });
      } else if (groupUpdate.left) {
        changes.push({
          type: 'remove',
          contacts: _.map(
            Array.isArray(groupUpdate.left)
              ? groupUpdate.left
              : [groupUpdate.left],
            identifier => this.findAndFormatContact(identifier)
          ),
        });
      }

      if (groupUpdate.name) {
        changes.push({
          type: 'name',
          newName: groupUpdate.name,
        });
      }

      if (groupUpdate.avatarUpdated) {
        changes.push({
          type: 'avatar',
        });
      }

      const sourceId = this.getContactId();
      const from = this.findAndFormatContact(sourceId);

      return {
        from,
        changes,
      };
    },
    getPropsForResetSessionNotification() {
      // It doesn't need anything right now!
      return {};
    },
    getPropsForCallHistory() {
      return {
        callHistoryDetails: this.get('callHistoryDetails'),
      };
    },
    getPropsForProfileChange() {
      const change = this.get('profileChange');
      const changedId = this.get('changedId');

      return {
        changedContact: this.findAndFormatContact(changedId),
        change,
      };
    },

    getAttachmentsForMessage() {
      const sticker = this.get('sticker');
      if (sticker && sticker.data) {
        const { data } = sticker;

        // We don't show anything if we're still loading a sticker
        if (data.pending || !data.path) {
          return [];
        }

        return [
          {
            ...data,
            url: getAbsoluteAttachmentPath(data.path),
          },
        ];
      }

      const attachments = this.get('attachments') || [];
      return attachments
        .filter(attachment => !attachment.error)
        .map(attachment => this.getPropsForAttachment(attachment));
    },
    getPropsForMessage() {
      const sourceId = this.getContactId();
      const contact = this.findAndFormatContact(sourceId);
      const contactModel = this.findContact(sourceId);

      const authorColor = contactModel ? contactModel.getColor() : null;
      const authorAvatarPath = contactModel
        ? contactModel.getAvatarPath()
        : null;

      const expirationLength = this.get('expireTimer') * 1000;
      const expireTimerStart = this.get('expirationStartTimestamp');
      const expirationTimestamp =
        expirationLength && expireTimerStart
          ? expireTimerStart + expirationLength
          : null;

      const conversation = this.getConversation();
      const isGroup = conversation && !conversation.isPrivate();
      const conversationAccepted = Boolean(
        conversation && conversation.getAccepted()
      );
      const sticker = this.get('sticker');

      const isTapToView = this.isTapToView();

      const reactions = (this.get('reactions') || []).map(re => {
        const c = this.findAndFormatContact(re.fromId);

        return {
          emoji: re.emoji,
          timestamp: re.timestamp,
          from: c,
        };
      });

      const selectedReaction = (
        (this.get('reactions') || []).find(
          re => re.fromId === ConversationController.getOurConversationId()
        ) || {}
      ).emoji;

      return {
        text: this.createNonBreakingLastSeparator(this.get('body')),
        textPending: this.get('bodyPending'),
        id: this.id,
        conversationId: this.get('conversationId'),
        conversationAccepted,
        isSticker: Boolean(sticker),
        direction: this.isIncoming() ? 'incoming' : 'outgoing',
        timestamp: this.get('sent_at'),
        status: this.getMessagePropStatus(),
        contact: this.getPropsForEmbeddedContact(),
        canReply: this.canReply(),
        authorTitle: contact.title,
        authorColor,
        authorName: contact.name,
        authorProfileName: contact.profileName,
        authorPhoneNumber: contact.phoneNumber,
        conversationType: isGroup ? 'group' : 'direct',
        attachments: this.getAttachmentsForMessage(),
        previews: this.getPropsForPreview(),
        quote: this.getPropsForQuote(),
        authorAvatarPath,
        isExpired: this.hasExpired,
        expirationLength,
        expirationTimestamp,
        reactions,
        selectedReaction,

        isTapToView,
        isTapToViewExpired: isTapToView && this.get('isErased'),
        isTapToViewError:
          isTapToView && this.isIncoming() && this.get('isTapToViewInvalid'),

        deletedForEveryone: this.get('deletedForEveryone') || false,
      };
    },

    // Dependencies of prop-generation functions
    findAndFormatContact(identifier) {
      if (!identifier) {
        return PLACEHOLDER_CONTACT;
      }

      const contactModel = this.findContact(identifier);
      if (contactModel) {
        return contactModel.format();
      }

      const { format, isValidNumber } = PhoneNumber;
      const regionCode = storage.get('regionCode');

      if (!isValidNumber(identifier, { regionCode })) {
        return PLACEHOLDER_CONTACT;
      }

      const phoneNumber = format(identifier, {
        ourRegionCode: regionCode,
      });

      return {
        title: phoneNumber,
        phoneNumber,
      };
    },
    findContact(identifier) {
      return ConversationController.get(identifier);
    },
    getConversation() {
      return ConversationController.get(this.get('conversationId'));
    },
    createNonBreakingLastSeparator(text) {
      if (!text) {
        return null;
      }

      const nbsp = '\xa0';
      const regex = /(\S)( +)(\S+\s*)$/;
      return text.replace(regex, (match, start, spaces, end) => {
        const newSpaces =
          end.length < 12
            ? _.reduce(spaces, accumulator => accumulator + nbsp, '')
            : spaces;
        return `${start}${newSpaces}${end}`;
      });
    },
    isIncoming() {
      return this.get('type') === 'incoming';
    },
    getMessagePropStatus() {
      const sent = this.get('sent');
      const sentTo = this.get('sent_to') || [];

      if (this.hasErrors()) {
        if (sent || sentTo.length > 0) {
          return 'partial-sent';
        }
        return 'error';
      }
      if (!this.isOutgoing()) {
        return null;
      }

      const readBy = this.get('read_by') || [];
      if (storage.get('read-receipt-setting') && readBy.length > 0) {
        return 'read';
      }
      const delivered = this.get('delivered');
      const deliveredTo = this.get('delivered_to') || [];
      if (delivered || deliveredTo.length > 0) {
        return 'delivered';
      }
      if (sent || sentTo.length > 0) {
        return 'sent';
      }

      return 'sending';
    },
    getPropsForEmbeddedContact() {
      const contacts = this.get('contact');
      if (!contacts || !contacts.length) {
        return null;
      }

      const regionCode = storage.get('regionCode');
      const { contactSelector } = Contact;
      const contact = contacts[0];
      const firstNumber =
        contact.number && contact.number[0] && contact.number[0].value;

      // Would be nice to do this before render, on initial load of message
      if (!window.isSignalAccountCheckComplete(firstNumber)) {
        window.checkForSignalAccount(firstNumber).then(() => {
          this.trigger('change', this);
        });
      }

      return contactSelector(contact, {
        regionCode,
        getAbsoluteAttachmentPath,
        signalAccount: window.hasSignalAccount(firstNumber)
          ? firstNumber
          : null,
      });
    },
    getPropsForAttachment(attachment) {
      if (!attachment) {
        return null;
      }

      const { path, pending, flags, size, screenshot, thumbnail } = attachment;

      return {
        ...attachment,
        fileSize: size ? filesize(size) : null,
        isVoiceMessage:
          flags &&
          // eslint-disable-next-line no-bitwise
          flags & textsecure.protobuf.AttachmentPointer.Flags.VOICE_MESSAGE,
        pending,
        url: path ? getAbsoluteAttachmentPath(path) : null,
        screenshot: screenshot
          ? {
              ...screenshot,
              url: getAbsoluteAttachmentPath(screenshot.path),
            }
          : null,
        thumbnail: thumbnail
          ? {
              ...thumbnail,
              url: getAbsoluteAttachmentPath(thumbnail.path),
            }
          : null,
      };
    },
    getPropsForPreview() {
      const previews = this.get('preview') || [];

      return previews.map(preview => ({
        ...preview,
        isStickerPack: window.Signal.LinkPreviews.isStickerPack(preview.url),
        domain: window.Signal.LinkPreviews.getDomain(preview.url),
        image: preview.image ? this.getPropsForAttachment(preview.image) : null,
      }));
    },
    getPropsForQuote() {
      const quote = this.get('quote');
      if (!quote) {
        return null;
      }

      const { format } = PhoneNumber;
      const regionCode = storage.get('regionCode');

      const {
        author,
        authorUuid,
        id: sentAt,
        referencedMessageNotFound,
      } = quote;
      const contact =
        (author || authorUuid) &&
        ConversationController.get(
          ConversationController.ensureContactIds({
            e164: author,
            uuid: authorUuid,
          })
        );
      const authorColor = contact ? contact.getColor() : 'grey';

      const authorPhoneNumber = format(author, {
        ourRegionCode: regionCode,
      });
      const authorProfileName = contact ? contact.getProfileName() : null;
      const authorName = contact ? contact.get('name') : null;
      const authorTitle = contact ? contact.getTitle() : null;
      const isFromMe = contact ? contact.isMe() : false;
      const firstAttachment = quote.attachments && quote.attachments[0];

      return {
        text: this.createNonBreakingLastSeparator(quote.text),
        attachment: firstAttachment
          ? this.processQuoteAttachment(firstAttachment)
          : null,
        isFromMe,
        sentAt,
        authorId: author,
        authorPhoneNumber,
        authorProfileName,
        authorTitle,
        authorName,
        authorColor,
        referencedMessageNotFound,
        onClick: () => this.trigger('scroll-to-message'),
      };
    },
    getStatus(identifier) {
      const conversation = ConversationController.get(identifier);

      if (!conversation) {
        return null;
      }

      const e164 = conversation.get('e164');
      const uuid = conversation.get('uuid');
      const conversationId = conversation.get('id');

      const readBy = this.get('read_by') || [];
      if (includesAny(readBy, conversationId, e164, uuid)) {
        return 'read';
      }
      const deliveredTo = this.get('delivered_to') || [];
      if (includesAny(deliveredTo, conversationId, e164, uuid)) {
        return 'delivered';
      }
      const sentTo = this.get('sent_to') || [];
      if (includesAny(sentTo, conversationId, e164, uuid)) {
        return 'sent';
      }

      return null;
    },
    processQuoteAttachment(attachment) {
      const { thumbnail } = attachment;
      const path =
        thumbnail &&
        thumbnail.path &&
        getAbsoluteAttachmentPath(thumbnail.path);
      const objectUrl = thumbnail && thumbnail.objectUrl;

      const thumbnailWithObjectUrl =
        !path && !objectUrl
          ? null
          : { ...(attachment.thumbnail || {}), objectUrl: path || objectUrl };

      return {
        ...attachment,
        isVoiceMessage: Signal.Types.Attachment.isVoiceMessage(attachment),
        thumbnail: thumbnailWithObjectUrl,
      };
    },

    getNotificationData() /* : { text: string, emoji?: string } */ {
      if (this.isUnsupportedMessage()) {
        return { text: i18n('message--getDescription--unsupported-message') };
      }

      if (this.isProfileChange()) {
        const change = this.get('profileChange');
        const changedId = this.get('changedId');
        const changedContact = this.findAndFormatContact(changedId);

        return {
          text: Signal.Util.getStringForProfileChange(
            change,
            changedContact,
            i18n
          ),
        };
      }

      if (this.isGroupV2Change()) {
        const { protobuf } = window.textsecure;
        const change = this.get('groupV2Change');

        const lines = window.Signal.GroupChange.renderChange(change, {
          AccessControlEnum: protobuf.AccessControl.AccessRequired,
          i18n: window.i18n,
          ourConversationId: window.ConversationController.getOurConversationId(),
          renderContact: conversationId => {
            const conversation = window.ConversationController.get(
              conversationId
            );
            return conversation
              ? conversation.getTitle()
              : window.i18n('unknownUser');
          },
          renderString: (key, i18n, placeholders) => i18n(key, placeholders),
          RoleEnum: protobuf.Member.Role,
        });

        return { text: lines.join(' ') };
      }

      const attachments = this.get('attachments') || [];

      if (this.isTapToView()) {
        if (this.isErased()) {
          return { text: i18n('message--getDescription--disappearing-media') };
        }

        if (Attachment.isImage(attachments)) {
          return {
            text: i18n('message--getDescription--disappearing-photo'),
            emoji: '📷',
          };
        }
        if (Attachment.isVideo(attachments)) {
          return {
            text: i18n('message--getDescription--disappearing-video'),
            emoji: '🎥',
          };
        }
        // There should be an image or video attachment, but we have a fallback just in
        //   case.
        return { text: i18n('mediaMessage'), emoji: '📎' };
      }

      if (this.isGroupUpdate()) {
        const groupUpdate = this.get('group_update');
        const fromContact = this.getContact();
        const messages = [];

        if (groupUpdate.left === 'You') {
          return { text: i18n('youLeftTheGroup') };
        }
        if (groupUpdate.left) {
          return {
            text: i18n('leftTheGroup', [
              this.getNameForNumber(groupUpdate.left),
            ]),
          };
        }

        if (!fromContact) {
          return { text: '' };
        }

        if (fromContact.isMe()) {
          messages.push(i18n('youUpdatedTheGroup'));
        } else {
          messages.push(i18n('updatedTheGroup', [fromContact.getTitle()]));
        }

        if (groupUpdate.joined && groupUpdate.joined.length) {
          const joinedContacts = _.map(groupUpdate.joined, item =>
            ConversationController.getOrCreate(item, 'private')
          );
          const joinedWithoutMe = joinedContacts.filter(
            contact => !contact.isMe()
          );

          if (joinedContacts.length > 1) {
            messages.push(
              i18n('multipleJoinedTheGroup', [
                _.map(joinedWithoutMe, contact => contact.getTitle()).join(
                  ', '
                ),
              ])
            );

            if (joinedWithoutMe.length < joinedContacts.length) {
              messages.push(i18n('youJoinedTheGroup'));
            }
          } else {
            const joinedContact = ConversationController.getOrCreate(
              groupUpdate.joined[0],
              'private'
            );
            if (joinedContact.isMe()) {
              messages.push(i18n('youJoinedTheGroup'));
            } else {
              messages.push(
                i18n('joinedTheGroup', [joinedContacts[0].getTitle()])
              );
            }
          }
        }

        if (groupUpdate.name) {
          messages.push(i18n('titleIsNow', [groupUpdate.name]));
        }
        if (groupUpdate.avatarUpdated) {
          messages.push(i18n('updatedGroupAvatar'));
        }

        return { text: messages.join(' ') };
      }
      if (this.isEndSession()) {
        return { text: i18n('sessionEnded') };
      }
      if (this.isIncoming() && this.hasErrors()) {
        return { text: i18n('incomingError') };
      }

      const body = (this.get('body') || '').trim();

      if (attachments.length) {
        // This should never happen but we want to be extra-careful.
        const attachment = attachments[0] || {};
        const { contentType } = attachment;

        if (contentType === MIME.IMAGE_GIF) {
          return {
            text: body || i18n('message--getNotificationText--gif'),
            emoji: '🎡',
          };
        }
        if (Attachment.isImage(attachments)) {
          return {
            text: body || i18n('message--getNotificationText--photo'),
            emoji: '📷',
          };
        }
        if (Attachment.isVideo(attachments)) {
          return {
            text: body || i18n('message--getNotificationText--video'),
            emoji: '🎥',
          };
        }
        if (Attachment.isVoiceMessage(attachment)) {
          return {
            text: body || i18n('message--getNotificationText--voice-message'),
            emoji: '🎤',
          };
        }
        if (Attachment.isAudio(attachments)) {
          return {
            text: body || i18n('message--getNotificationText--audio-message'),
            emoji: '🔈',
          };
        }
        return {
          text: body || i18n('message--getNotificationText--file'),
          emoji: '📎',
        };
      }

      const stickerData = this.get('sticker');
      if (stickerData) {
        const sticker = Signal.Stickers.getSticker(
          stickerData.packId,
          stickerData.stickerId
        );
        const { emoji } = sticker || {};
        if (!emoji) {
          window.log.warn('Unable to get emoji for sticker');
        }
        return {
          text: i18n('message--getNotificationText--stickers'),
          emoji,
        };
      }

      if (this.isCallHistory()) {
        return {
          text: window.Signal.Components.getCallingNotificationText(
            this.get('callHistoryDetails'),
            window.i18n
          ),
        };
      }
      if (this.isExpirationTimerUpdate()) {
        const { expireTimer } = this.get('expirationTimerUpdate');
        if (!expireTimer) {
          return { text: i18n('disappearingMessagesDisabled') };
        }

        return {
          text: i18n('timerSetTo', [
            Whisper.ExpirationTimerOptions.getAbbreviated(expireTimer || 0),
          ]),
        };
      }

      if (this.isKeyChange()) {
        const identifier = this.get('key_changed');
        const conversation = this.findContact(identifier);
        return {
          text: i18n('safetyNumberChangedGroup', [
            conversation ? conversation.getTitle() : null,
          ]),
        };
      }
      const contacts = this.get('contact');
      if (contacts && contacts.length) {
        return { text: Contact.getName(contacts[0]), emoji: '👤' };
      }

      if (body) {
        return { text: body };
      }

      return { text: '' };
    },

    getNotificationText() /* : string */ {
      const { text, emoji } = this.getNotificationData();

      // Linux emoji support is mixed, so we disable it. (Note that this doesn't touch
      //   the `text`, which can contain emoji.)
      const shouldIncludeEmoji = Boolean(emoji) && !Signal.OS.isLinux();
      if (shouldIncludeEmoji) {
        return i18n('message--getNotificationText--text-with-emoji', {
          text,
          emoji,
        });
      }
      return text;
    },

    // General
    idForLogging() {
      const source = this.getSource();
      const device = this.getSourceDevice();
      const timestamp = this.get('sent_at');

      return `${source}.${device} ${timestamp}`;
    },
    defaults() {
      return {
        timestamp: new Date().getTime(),
        attachments: [],
      };
    },
    validate(attributes) {
      const required = ['conversationId', 'received_at', 'sent_at'];
      const missing = _.filter(required, attr => !attributes[attr]);
      if (missing.length) {
        window.log.warn(`Message missing attributes: ${missing}`);
      }
    },
    isUnread() {
      return !!this.get('unread');
    },
    merge(model) {
      const attributes = model.attributes || model;
      this.set(attributes);
    },
    getNameForNumber(number) {
      const conversation = ConversationController.get(number);
      if (!conversation) {
        return number;
      }
      return conversation.getTitle();
    },
    onDestroy() {
      this.cleanup();
    },
    async cleanup() {
      const { messageDeleted } = window.reduxActions.conversations;
      messageDeleted(this.id, this.get('conversationId'));
      MessageController.unregister(this.id);
      this.unload();
      await this.deleteData();
    },
    async deleteData() {
      await deleteExternalMessageFiles(this.attributes);

      const sticker = this.get('sticker');
      if (!sticker) {
        return;
      }

      const { packId } = sticker;
      if (packId) {
        await deletePackReference(this.id, packId);
      }
    },
    isTapToView() {
      return Boolean(this.get('isViewOnce') || this.get('messageTimer'));
    },
    isValidTapToView() {
      const body = this.get('body');
      if (body) {
        return false;
      }

      const attachments = this.get('attachments');
      if (!attachments || attachments.length !== 1) {
        return false;
      }

      const firstAttachment = attachments[0];
      if (
        !GoogleChrome.isImageTypeSupported(firstAttachment.contentType) &&
        !GoogleChrome.isVideoTypeSupported(firstAttachment.contentType)
      ) {
        return false;
      }

      const quote = this.get('quote');
      const sticker = this.get('sticker');
      const contact = this.get('contact');
      const preview = this.get('preview');

      if (
        quote ||
        sticker ||
        (contact && contact.length > 0) ||
        (preview && preview.length > 0)
      ) {
        return false;
      }

      return true;
    },
    async markViewed(options) {
      const { fromSync } = options || {};

      if (!this.isValidTapToView()) {
        window.log.warn(
          `markViewed: Message ${this.idForLogging()} is not a valid tap to view message!`
        );
        return;
      }
      if (this.isErased()) {
        window.log.warn(
          `markViewed: Message ${this.idForLogging()} is already erased!`
        );
        return;
      }

      if (this.get('unread')) {
        await this.markRead();
      }

      await this.eraseContents();

      if (!fromSync) {
        const sender = this.getSource();
        const senderUuid = this.getSourceUuid();
        const timestamp = this.get('sent_at');
        const ourNumber = textsecure.storage.user.getNumber();
        const ourUuid = textsecure.storage.user.getUuid();
        const { wrap, sendOptions } = ConversationController.prepareForSend(
          ourNumber || ourUuid,
          {
            syncMessage: true,
          }
        );

        await wrap(
          textsecure.messaging.syncViewOnceOpen(
            sender,
            senderUuid,
            timestamp,
            sendOptions
          )
        );
      }
    },
    isErased() {
      return Boolean(this.get('isErased'));
    },
    async eraseContents(additionalProperties = {}, shouldPersist = true) {
      if (this.get('isErased')) {
        return;
      }

      window.log.info(`Erasing data for message ${this.idForLogging()}`);

      try {
        await this.deleteData();
      } catch (error) {
        window.log.error(
          `Error erasing data for message ${this.idForLogging()}:`,
          error && error.stack ? error.stack : error
        );
      }

      this.set({
        isErased: true,
        body: '',
        attachments: [],
        quote: null,
        contact: [],
        sticker: null,
        preview: [],
        ...additionalProperties,
      });
      this.trigger('content-changed');

      if (shouldPersist) {
        await window.Signal.Data.saveMessage(this.attributes, {
          Message: Whisper.Message,
        });
      }
    },
    isEmpty() {
      // Core message types - we check for all four because they can each stand alone
      const hasBody = Boolean(this.get('body'));
      const hasAttachment = (this.get('attachments') || []).length > 0;
      const hasEmbeddedContact = (this.get('contact') || []).length > 0;
      const isSticker = Boolean(this.get('sticker'));

      // Rendered sync messages
      const isCallHistory = this.isCallHistory();
      const isGroupUpdate = this.isGroupUpdate();
      const isGroupV2Change = this.isGroupV2Change();
      const isEndSession = this.isEndSession();
      const isExpirationTimerUpdate = this.isExpirationTimerUpdate();
      const isVerifiedChange = this.isVerifiedChange();

      // Placeholder messages
      const isUnsupportedMessage = this.isUnsupportedMessage();
      const isTapToView = this.isTapToView();

      // Errors
      const hasErrors = this.hasErrors();

      // Locally-generated notifications
      const isKeyChange = this.isKeyChange();
      const isMessageHistoryUnsynced = this.isMessageHistoryUnsynced();
      const isProfileChange = this.isProfileChange();

      // Note: not all of these message types go through message.handleDataMessage

      const hasSomethingToDisplay =
        // Core message types
        hasBody ||
        hasAttachment ||
        hasEmbeddedContact ||
        isSticker ||
        // Rendered sync messages
        isCallHistory ||
        isGroupUpdate ||
        isGroupV2Change ||
        isEndSession ||
        isExpirationTimerUpdate ||
        isVerifiedChange ||
        // Placeholder messages
        isUnsupportedMessage ||
        isTapToView ||
        // Errors
        hasErrors ||
        // Locally-generated notifications
        isKeyChange ||
        isMessageHistoryUnsynced ||
        isProfileChange;

      return !hasSomethingToDisplay;
    },
    unload() {
      if (this.quotedMessage) {
        this.quotedMessage = null;
      }
    },
    onExpired() {
      this.hasExpired = true;
    },
    isUnidentifiedDelivery(contactId, lookup) {
      if (this.isIncoming()) {
        return this.get('unidentifiedDeliveryReceived');
      }

      return Boolean(lookup[contactId]);
    },
    getSource() {
      if (this.isIncoming()) {
        return this.get('source');
      }

      return this.OUR_NUMBER;
    },
    getSourceDevice() {
      if (this.isIncoming()) {
        return this.get('sourceDevice');
      }

      return window.textsecure.storage.user.getDeviceId();
    },
    getSourceUuid() {
      if (this.isIncoming()) {
        return this.get('sourceUuid');
      }

      return this.OUR_UUID;
    },
    getContactId() {
      const source = this.getSource();
      const sourceUuid = this.getSourceUuid();

      if (!source && !sourceUuid) {
        return ConversationController.getOurConversationId();
      }

      return ConversationController.ensureContactIds({
        e164: source,
        uuid: sourceUuid,
      });
    },
    getContact() {
      const id = this.getContactId();
      return ConversationController.get(id);
    },
    isOutgoing() {
      return this.get('type') === 'outgoing';
    },
    hasErrors() {
      return _.size(this.get('errors')) > 0;
    },
    async saveErrors(providedErrors, options = {}) {
      const { skipSave } = options;

      let errors = providedErrors;

      if (!(errors instanceof Array)) {
        errors = [errors];
      }
      errors.forEach(e => {
        window.log.error(
          'Message.saveErrors:',
          e && e.reason ? e.reason : null,
          e && e.stack ? e.stack : e
        );
      });
      errors = errors.map(e => {
        if (
          e.constructor === Error ||
          e.constructor === TypeError ||
          e.constructor === ReferenceError
        ) {
          return _.pick(e, 'name', 'message', 'code', 'number', 'reason');
        }
        return e;
      });
      errors = errors.concat(this.get('errors') || []);

      this.set({ errors });

      if (!skipSave) {
        await window.Signal.Data.saveMessage(this.attributes, {
          Message: Whisper.Message,
        });
      }
    },
    async markRead(readAt, options = {}) {
      const { skipSave } = options;

      this.unset('unread');

      if (this.get('expireTimer') && !this.get('expirationStartTimestamp')) {
        const expirationStartTimestamp = Math.min(
          Date.now(),
          readAt || Date.now()
        );
        this.set({ expirationStartTimestamp });
      }

      Whisper.Notifications.removeBy({ messageId: this.id });

      if (!skipSave) {
        await window.Signal.Data.saveMessage(this.attributes, {
          Message: Whisper.Message,
        });
      }
    },
    isExpiring() {
      return this.get('expireTimer') && this.get('expirationStartTimestamp');
    },
    isExpired() {
      return this.msTilExpire() <= 0;
    },
    msTilExpire() {
      if (!this.isExpiring()) {
        return Infinity;
      }
      const now = Date.now();
      const start = this.get('expirationStartTimestamp');
      const delta = this.get('expireTimer') * 1000;
      let msFromNow = start + delta - now;
      if (msFromNow < 0) {
        msFromNow = 0;
      }
      return msFromNow;
    },
    async setToExpire(force = false, options) {
      const { skipSave } = options || {};

      if (this.isExpiring() && (force || !this.get('expires_at'))) {
        const start = this.get('expirationStartTimestamp');
        const delta = this.get('expireTimer') * 1000;
        const expiresAt = start + delta;

        this.set({ expires_at: expiresAt });
        const id = this.get('id');
        if (id && !skipSave) {
          await window.Signal.Data.saveMessage(this.attributes, {
            Message: Whisper.Message,
          });
        }

        window.log.info('Set message expiration', {
          expiresAt,
          sentAt: this.get('sent_at'),
        });
      }
    },
    getIncomingContact() {
      if (!this.isIncoming()) {
        return null;
      }
      const source = this.get('source');
      if (!source) {
        return null;
      }

      return ConversationController.getOrCreate(source, 'private');
    },
    getQuoteContact() {
      const quote = this.get('quote');
      if (!quote) {
        return null;
      }
      const { author } = quote;
      if (!author) {
        return null;
      }

      return ConversationController.get(author);
    },

    // Send infrastructure
    // One caller today: event handler for the 'Retry Send' entry in triple-dot menu
    async retrySend() {
      if (!textsecure.messaging) {
        window.log.error('retrySend: Cannot retry since we are offline!');
        return null;
      }

      this.set({ errors: null });

      const conversation = this.getConversation();
      const intendedRecipients = (this.get('recipients') || [])
        .map(identifier => ConversationController.getConversationId(identifier))
        .filter(Boolean);
      const successfulRecipients = (this.get('sent_to') || [])
        .map(identifier => ConversationController.getConversationId(identifier))
        .filter(Boolean);
      const currentRecipients = conversation
        .getRecipients()
        .map(identifier => ConversationController.getConversationId(identifier))
        .filter(Boolean);

      const profileKey = conversation.get('profileSharing')
        ? storage.get('profileKey')
        : null;

      // Determine retry recipients and get their most up-to-date addressing information
      let recipients = _.intersection(intendedRecipients, currentRecipients);
      recipients = _.without(recipients, successfulRecipients).map(id => {
        const c = ConversationController.get(id);
        return c.getSendTarget();
      });

      if (!recipients.length) {
        window.log.warn('retrySend: Nobody to send to!');

        return window.Signal.Data.saveMessage(this.attributes, {
          Message: Whisper.Message,
        });
      }

      const attachmentsWithData = await Promise.all(
        (this.get('attachments') || []).map(loadAttachmentData)
      );
      const { body, attachments } = Whisper.Message.getLongMessageAttachment({
        body: this.get('body'),
        attachments: attachmentsWithData,
        now: this.get('sent_at'),
      });

      const quoteWithData = await loadQuoteData(this.get('quote'));
      const previewWithData = await loadPreviewData(this.get('preview'));
      const stickerWithData = await loadStickerData(this.get('sticker'));

      // Special-case the self-send case - we send only a sync message
      if (
        recipients.length === 1 &&
        (recipients[0] === this.OUR_NUMBER || recipients[0] === this.OUR_UUID)
      ) {
        const [identifier] = recipients;
        const dataMessage = await textsecure.messaging.getMessageProto(
          identifier,
          body,
          attachments,
          quoteWithData,
          previewWithData,
          stickerWithData,
          null,
          this.get('sent_at'),
          this.get('expireTimer'),
          profileKey
        );
        return this.sendSyncMessageOnly(dataMessage);
      }

      let promise;
      const options = conversation.getSendOptions();

      if (conversation.isPrivate()) {
        const [identifer] = recipients;
        promise = textsecure.messaging.sendMessageToIdentifier(
          identifer,
          body,
          attachments,
          quoteWithData,
          previewWithData,
          stickerWithData,
          null,
          this.get('sent_at'),
          this.get('expireTimer'),
          profileKey,
          options
        );
      } else {
        // Because this is a partial group send, we manually construct the request like
        //   sendMessageToGroup does.

        const groupV2 = conversation.getGroupV2Info();

        promise = textsecure.messaging.sendMessage(
          {
            recipients,
            body,
            timestamp: this.get('sent_at'),
            attachments,
            quote: quoteWithData,
            preview: previewWithData,
            sticker: stickerWithData,
            expireTimer: this.get('expireTimer'),
            profileKey,
            groupV2,
            group: groupV2
              ? null
              : {
                  id: this.getConversation().get('groupId'),
                  type: textsecure.protobuf.GroupContext.Type.DELIVER,
                },
          },
          options
        );
      }

      return this.send(conversation.wrapSend(promise));
    },
    isReplayableError(e) {
      return (
        e.name === 'MessageError' ||
        e.name === 'OutgoingMessageError' ||
        e.name === 'SendMessageNetworkError' ||
        e.name === 'SignedPreKeyRotationError' ||
        e.name === 'OutgoingIdentityKeyError'
      );
    },
    canReply() {
      const isAccepted = this.getConversation().getAccepted();
      const errors = this.get('errors');
      const isOutgoing = this.get('type') === 'outgoing';
      const numDelivered = this.get('delivered');

      // Case 1: We cannot reply if we have accepted the message request
      if (!isAccepted) {
        return false;
      }

      // Case 2: We cannot reply if this message is deleted for everyone
      if (this.get('deletedForEveryone')) {
        return false;
      }

      // Case 3: We can reply if this is outgoing and delievered to at least one recipient
      if (isOutgoing && numDelivered > 0) {
        return true;
      }

      // Case 4: We can reply if there are no errors
      if (!errors || (errors && errors.length === 0)) {
        return true;
      }

      // Case 5: default
      return false;
    },

    // Called when the user ran into an error with a specific user, wants to send to them
    //   One caller today: ConversationView.forceSend()
    async resend(identifier) {
      const error = this.removeOutgoingErrors(identifier);
      if (!error) {
        window.log.warn('resend: requested number was not present in errors');
        return null;
      }

      const profileKey = null;
      const attachmentsWithData = await Promise.all(
        (this.get('attachments') || []).map(loadAttachmentData)
      );
      const { body, attachments } = Whisper.Message.getLongMessageAttachment({
        body: this.get('body'),
        attachments: attachmentsWithData,
        now: this.get('sent_at'),
      });

      const quoteWithData = await loadQuoteData(this.get('quote'));
      const previewWithData = await loadPreviewData(this.get('preview'));
      const stickerWithData = await loadStickerData(this.get('sticker'));

      // Special-case the self-send case - we send only a sync message
      if (identifier === this.OUR_NUMBER || identifier === this.OUR_UUID) {
        const dataMessage = await textsecure.messaging.getMessageProto(
          identifier,
          body,
          attachments,
          quoteWithData,
          previewWithData,
          stickerWithData,
          null,
          this.get('sent_at'),
          this.get('expireTimer'),
          profileKey
        );
        return this.sendSyncMessageOnly(dataMessage);
      }

      const { wrap, sendOptions } = ConversationController.prepareForSend(
        identifier
      );
      const promise = textsecure.messaging.sendMessageToIdentifier(
        identifier,
        body,
        attachments,
        quoteWithData,
        previewWithData,
        stickerWithData,
        null,
        this.get('sent_at'),
        this.get('expireTimer'),
        profileKey,
        sendOptions
      );

      return this.send(wrap(promise));
    },
    removeOutgoingErrors(incomingIdentifier) {
      const incomingConversationId = ConversationController.getConversationId(
        incomingIdentifier
      );
      const errors = _.partition(
        this.get('errors'),
        e =>
          ConversationController.getConversationId(e.identifer || e.number) ===
            incomingConversationId &&
          (e.name === 'MessageError' ||
            e.name === 'OutgoingMessageError' ||
            e.name === 'SendMessageNetworkError' ||
            e.name === 'SignedPreKeyRotationError' ||
            e.name === 'OutgoingIdentityKeyError')
      );
      this.set({ errors: errors[1] });
      return errors[0][0];
    },

    send(promise) {
      this.trigger('pending');
      return promise
        .then(async result => {
          this.trigger('done');

          // This is used by sendSyncMessage, then set to null
          if (result.dataMessage) {
            this.set({ dataMessage: result.dataMessage });
          }

          const sentTo = this.get('sent_to') || [];
          this.set({
            sent_to: _.union(sentTo, result.successfulIdentifiers),
            sent: true,
            expirationStartTimestamp: Date.now(),
            unidentifiedDeliveries: result.unidentifiedDeliveries,
          });

          await window.Signal.Data.saveMessage(this.attributes, {
            Message: Whisper.Message,
          });

          this.trigger('sent', this);
          this.sendSyncMessage();
        })
        .catch(result => {
          this.trigger('done');

          if (result.dataMessage) {
            this.set({ dataMessage: result.dataMessage });
          }

          let promises = [];

          // If we successfully sent to a user, we can remove our unregistered flag.
          result.successfulIdentifiers.forEach(identifier => {
            const c = ConversationController.get(identifier);
            if (c && c.isEverUnregistered()) {
              c.setRegistered();
            }
          });

          if (result instanceof Error) {
            this.saveErrors(result);
            if (result.name === 'SignedPreKeyRotationError') {
              promises.push(getAccountManager().rotateSignedPreKey());
            } else if (result.name === 'OutgoingIdentityKeyError') {
              const c = ConversationController.get(result.number);
              promises.push(c.getProfiles());
            }
          } else {
            if (result.successfulIdentifiers.length > 0) {
              const sentTo = this.get('sent_to') || [];

              // If we just found out that we couldn't send to a user because they are no
              //   longer registered, we will update our unregistered flag. In groups we
              //   will not event try to send to them for 6 hours. And we will never try
              //   to fetch them on startup again.
              // The way to discover registration once more is:
              //   1) any attempt to send to them in 1:1 conversation
              //   2) the six-hour time period has passed and we send in a group again
              const unregisteredUserErrors = _.filter(
                result.errors,
                error => error.name === 'UnregisteredUserError'
              );
              unregisteredUserErrors.forEach(error => {
                const c = ConversationController.get(error.identifier);
                if (c) {
                  c.setUnregistered();
                }
              });

              // In groups, we don't treat unregistered users as a user-visible
              //   error. The message will look successful, but the details
              //   screen will show that we didn't send to these unregistered users.
              const filteredErrors = _.reject(
                result.errors,
                error => error.name === 'UnregisteredUserError'
              );

              // We don't start the expiration timer if there are real errors
              //   left after filtering out all of the unregistered user errors.
              const expirationStartTimestamp = filteredErrors.length
                ? null
                : Date.now();

              this.saveErrors(filteredErrors);

              this.set({
                sent_to: _.union(sentTo, result.successfulIdentifiers),
                sent: true,
                expirationStartTimestamp,
                unidentifiedDeliveries: result.unidentifiedDeliveries,
              });
              promises.push(this.sendSyncMessage());
            } else {
              this.saveErrors(result.errors);
            }
            promises = promises.concat(
              _.map(result.errors, error => {
                if (error.name === 'OutgoingIdentityKeyError') {
                  const c = ConversationController.get(
                    error.identifer || error.number
                  );
                  promises.push(c.getProfiles());
                }
              })
            );
          }

          this.trigger('send-error', this.get('errors'));

          return Promise.all(promises);
        });
    },

    async sendSyncMessageOnly(dataMessage) {
      const conv = this.getConversation();
      this.set({ dataMessage });

      try {
        this.set({
          // These are the same as a normal send()
          sent_to: [conv.getSendTarget()],
          sent: true,
          expirationStartTimestamp: Date.now(),
        });
        const result = await this.sendSyncMessage();
        this.set({
          // We have to do this afterward, since we didn't have a previous send!
          unidentifiedDeliveries: result ? result.unidentifiedDeliveries : null,

          // These are unique to a Note to Self message - immediately read/delivered
          delivered_to: [ConversationController.getOurConversationId()],
          read_by: [ConversationController.getOurConversationId()],
        });
      } catch (result) {
        const errors = (result && result.errors) || [
          new Error('Unknown error'),
        ];
        this.set({ errors });
      } finally {
        await window.Signal.Data.saveMessage(this.attributes, {
          Message: Whisper.Message,
        });
        this.trigger('done');

        const errors = this.get('errors');
        if (errors) {
          this.trigger('send-error', errors);
        } else {
          this.trigger('sent');
        }
      }
    },

    sendSyncMessage() {
      const ourNumber = textsecure.storage.user.getNumber();
      const ourUuid = textsecure.storage.user.getUuid();
      const { wrap, sendOptions } = ConversationController.prepareForSend(
        ourUuid || ourNumber,
        {
          syncMessage: true,
        }
      );

      this.syncPromise = this.syncPromise || Promise.resolve();
      const next = () => {
        const dataMessage = this.get('dataMessage');
        if (!dataMessage) {
          return Promise.resolve();
        }
        const isUpdate = Boolean(this.get('synced'));
        const conv = this.getConversation();

        return wrap(
          textsecure.messaging.sendSyncMessage(
            dataMessage,
            this.get('sent_at'),
            conv.get('e164'),
            conv.get('uuid'),
            this.get('expirationStartTimestamp'),
            this.get('sent_to'),
            this.get('unidentifiedDeliveries'),
            isUpdate,
            sendOptions
          )
        ).then(result => {
          this.set({
            synced: true,
            dataMessage: null,
          });
          return window.Signal.Data.saveMessage(this.attributes, {
            Message: Whisper.Message,
          }).then(() => result);
        });
      };

      this.syncPromise = this.syncPromise.then(next, next);

      return this.syncPromise;
    },

    // Receive logic
    async queueAttachmentDownloads() {
      const attachmentsToQueue = this.get('attachments') || [];
      const messageId = this.id;
      let count = 0;
      let bodyPending;

      window.log.info(
        `Queueing ${
          attachmentsToQueue.length
        } attachment downloads for message ${this.idForLogging()}`
      );

      const [longMessageAttachments, normalAttachments] = _.partition(
        attachmentsToQueue,
        attachment =>
          attachment.contentType === Whisper.Message.LONG_MESSAGE_CONTENT_TYPE
      );

      if (longMessageAttachments.length > 1) {
        window.log.error(
          `Received more than one long message attachment in message ${this.idForLogging()}`
        );
      }

      window.log.info(
        `Queueing ${
          longMessageAttachments.length
        } long message attachment downloads for message ${this.idForLogging()}`
      );

      if (longMessageAttachments.length > 0) {
        count += 1;
        bodyPending = true;
        await window.Signal.AttachmentDownloads.addJob(
          longMessageAttachments[0],
          {
            messageId,
            type: 'long-message',
            index: 0,
          }
        );
      }

      window.log.info(
        `Queueing ${
          normalAttachments.length
        } normal attachment downloads for message ${this.idForLogging()}`
      );
      const attachments = await Promise.all(
        normalAttachments.map((attachment, index) => {
          count += 1;
          return window.Signal.AttachmentDownloads.addJob(attachment, {
            messageId,
            type: 'attachment',
            index,
          });
        })
      );

      const previewsToQueue = this.get('preview') || [];
      window.log.info(
        `Queueing ${
          previewsToQueue.length
        } preview attachment downloads for message ${this.idForLogging()}`
      );
      const preview = await Promise.all(
        previewsToQueue.map(async (item, index) => {
          if (!item.image) {
            return item;
          }

          count += 1;
          return {
            ...item,
            image: await window.Signal.AttachmentDownloads.addJob(item.image, {
              messageId,
              type: 'preview',
              index,
            }),
          };
        })
      );

      const contactsToQueue = this.get('contact') || [];
      window.log.info(
        `Queueing ${
          contactsToQueue.length
        } contact attachment downloads for message ${this.idForLogging()}`
      );
      const contact = await Promise.all(
        contactsToQueue.map(async (item, index) => {
          if (!item.avatar || !item.avatar.avatar) {
            return item;
          }

          count += 1;
          return {
            ...item,
            avatar: {
              ...item.avatar,
              avatar: await window.Signal.AttachmentDownloads.addJob(
                item.avatar.avatar,
                {
                  messageId,
                  type: 'contact',
                  index,
                }
              ),
            },
          };
        })
      );

      let quote = this.get('quote');
      const quoteAttachmentsToQueue =
        quote && quote.attachments ? quote.attachments : [];
      window.log.info(
        `Queueing ${
          quoteAttachmentsToQueue.length
        } quote attachment downloads for message ${this.idForLogging()}`
      );
      if (quoteAttachmentsToQueue.length > 0) {
        quote = {
          ...quote,
          attachments: await Promise.all(
            (quote.attachments || []).map(async (item, index) => {
              // If we already have a path, then we copied this image from the quoted
              //    message and we don't need to download the attachment.
              if (!item.thumbnail || item.thumbnail.path) {
                return item;
              }

              count += 1;
              return {
                ...item,
                thumbnail: await window.Signal.AttachmentDownloads.addJob(
                  item.thumbnail,
                  {
                    messageId,
                    type: 'quote',
                    index,
                  }
                ),
              };
            })
          ),
        };
      }

      let sticker = this.get('sticker');
      if (sticker) {
        window.log.info(
          `Queueing sticker download for message ${this.idForLogging()}`
        );
        count += 1;
        const { packId, stickerId, packKey } = sticker;

        const status = getStickerPackStatus(packId);
        let data;

        if (status && (status === 'downloaded' || status === 'installed')) {
          try {
            const copiedSticker = await copyStickerToAttachments(
              packId,
              stickerId
            );
            data = {
              ...copiedSticker,
              contentType: 'image/webp',
            };
          } catch (error) {
            window.log.error(
              `Problem copying sticker (${packId}, ${stickerId}) to attachments:`,
              error && error.stack ? error.stack : error
            );
          }
        }
        if (!data) {
          data = await window.Signal.AttachmentDownloads.addJob(sticker.data, {
            messageId,
            type: 'sticker',
            index: 0,
          });
        }
        if (!status) {
          // Save the packId/packKey for future download/install
          savePackMetadata(packId, packKey, { messageId });
        } else {
          await addStickerPackReference(messageId, packId);
        }

        sticker = {
          ...sticker,
          packId,
          data,
        };
      }

      window.log.info(
        `Queued ${count} total attachment downloads for message ${this.idForLogging()}`
      );

      if (count > 0) {
        this.set({
          bodyPending,
          attachments,
          preview,
          contact,
          quote,
          sticker,
        });

        return true;
      }

      return false;
    },

    async copyFromQuotedMessage(message) {
      const { quote } = message;
      if (!quote) {
        return message;
      }

      const { attachments, id, author, authorUuid } = quote;
      const firstAttachment = attachments[0];
      const authorConversationId = ConversationController.ensureContactIds({
        e164: author,
        uuid: authorUuid,
      });

      const collection = await window.Signal.Data.getMessagesBySentAt(id, {
        MessageCollection: Whisper.MessageCollection,
      });
      const found = collection.find(item => {
        const messageAuthorId = item.getContactId();

        return authorConversationId === messageAuthorId;
      });

      if (!found) {
        quote.referencedMessageNotFound = true;
        return message;
      }
      if (found.isTapToView()) {
        quote.text = null;
        quote.attachments = [
          {
            contentType: 'image/jpeg',
          },
        ];

        return message;
      }

      const queryMessage = MessageController.register(found.id, found);
      quote.text = queryMessage.get('body');
      if (firstAttachment) {
        firstAttachment.thumbnail = null;
      }

      if (
        !firstAttachment ||
        (!GoogleChrome.isImageTypeSupported(firstAttachment.contentType) &&
          !GoogleChrome.isVideoTypeSupported(firstAttachment.contentType))
      ) {
        return message;
      }

      try {
        if (
          queryMessage.get('schemaVersion') <
          TypedMessage.VERSION_NEEDED_FOR_DISPLAY
        ) {
          const upgradedMessage = await upgradeMessageSchema(
            queryMessage.attributes
          );
          queryMessage.set(upgradedMessage);
          await window.Signal.Data.saveMessage(upgradedMessage, {
            Message: Whisper.Message,
          });
        }
      } catch (error) {
        window.log.error(
          'Problem upgrading message quoted message from database',
          Errors.toLogFormat(error)
        );
        return message;
      }

      const queryAttachments = queryMessage.get('attachments') || [];
      if (queryAttachments.length > 0) {
        const queryFirst = queryAttachments[0];
        const { thumbnail } = queryFirst;

        if (thumbnail && thumbnail.path) {
          firstAttachment.thumbnail = {
            ...thumbnail,
            copied: true,
          };
        }
      }

      const queryPreview = queryMessage.get('preview') || [];
      if (queryPreview.length > 0) {
        const queryFirst = queryPreview[0];
        const { image } = queryFirst;

        if (image && image.path) {
          firstAttachment.thumbnail = {
            ...image,
            copied: true,
          };
        }
      }

      const sticker = queryMessage.get('sticker');
      if (sticker && sticker.data && sticker.data.path) {
        firstAttachment.thumbnail = {
          ...sticker.data,
          copied: true,
        };
      }

      return message;
    },

    handleDataMessage(initialMessage, confirm, options = {}) {
      const { data } = options;

      // This function is called from the background script in a few scenarios:
      //   1. on an incoming message
      //   2. on a sent message sync'd from another device
      //   3. in rare cases, an incoming message can be retried, though it will
      //      still go through one of the previous two codepaths
      const message = this;
      const source = message.get('source');
      const sourceUuid = message.get('sourceUuid');
      const type = message.get('type');
      const conversationId = message.get('conversationId');
      const GROUP_TYPES = textsecure.protobuf.GroupContext.Type;

      const conversation = ConversationController.get(conversationId);
      return conversation.queueJob(async () => {
        window.log.info(
          `Starting handleDataMessage for message ${message.idForLogging()} in conversation ${conversation.idForLogging()}`
        );

        // First, check for duplicates. If we find one, stop processing here.
        const existingMessage = await getMessageBySender(this.attributes, {
          Message: Whisper.Message,
        });
        const isUpdate = Boolean(data && data.isRecipientUpdate);

        if (existingMessage && type === 'incoming') {
          window.log.warn('Received duplicate message', this.idForLogging());
          confirm();
          return;
        }
        if (type === 'outgoing') {
          if (isUpdate && existingMessage) {
            window.log.info(
              `handleDataMessage: Updating message ${message.idForLogging()} with received transcript`
            );

            let sentTo = [];
            let unidentifiedDeliveries = [];
            if (Array.isArray(data.unidentifiedStatus)) {
              sentTo = data.unidentifiedStatus.map(item => item.destination);

              const unidentified = _.filter(data.unidentifiedStatus, item =>
                Boolean(item.unidentified)
              );
              unidentifiedDeliveries = unidentified.map(
                item => item.destination
              );
            }

            const toUpdate = MessageController.register(
              existingMessage.id,
              existingMessage
            );
            toUpdate.set({
              sent_to: _.union(toUpdate.get('sent_to'), sentTo),
              unidentifiedDeliveries: _.union(
                toUpdate.get('unidentifiedDeliveries'),
                unidentifiedDeliveries
              ),
            });
            await window.Signal.Data.saveMessage(toUpdate.attributes, {
              Message: Whisper.Message,
            });

            confirm();
            return;
          }
          if (isUpdate) {
            window.log.warn(
              `handleDataMessage: Received update transcript, but no existing entry for message ${message.idForLogging()}. Dropping.`
            );

            confirm();
            return;
          }
          if (existingMessage) {
            window.log.warn(
              `handleDataMessage: Received duplicate transcript for message ${message.idForLogging()}, but it was not an update transcript. Dropping.`
            );

            confirm();
            return;
          }
        }

        const existingRevision = conversation.get('revision');
        const isGroupV2 = Boolean(initialMessage.groupV2);
        const isV2GroupUpdate =
          initialMessage.groupV2 &&
          (!existingRevision ||
            initialMessage.groupV2.revision > existingRevision);

        // GroupV2
        if (isGroupV2) {
          conversation.maybeRepairGroupV2(
            _.pick(initialMessage.groupV2, [
              'masterKey',
              'secretParams',
              'publicParams',
            ])
          );
        }

        if (isV2GroupUpdate) {
          const { revision, groupChange } = initialMessage.groupV2;
          try {
            await window.Signal.Groups.maybeUpdateGroup({
              conversation,
              groupChangeBase64: groupChange,
              newRevision: revision,
              receivedAt: message.get('received_at'),
              sentAt: message.get('sent_at'),
            });
          } catch (error) {
            const errorText = error && error.stack ? error.stack : error;
            window.log.error(
              `handleDataMessage: Failed to process group update for ${conversation.idForLogging()} as part of message ${message.idForLogging()}: ${errorText}`
            );
            throw error;
          }
        }

        const ourConversationId = ConversationController.getOurConversationId();
        const senderId = ConversationController.ensureContactIds({
          e164: source,
          uuid: sourceUuid,
        });
        const isV1GroupUpdate =
          initialMessage.group &&
          initialMessage.group.type !==
            textsecure.protobuf.GroupContext.Type.DELIVER;

        // Drop an incoming GroupV2 message if we or the sender are not part of the group
        //   after applying the message's associated group chnages.
        if (
          type === 'incoming' &&
          !conversation.isPrivate() &&
          isGroupV2 &&
          (conversation.get('left') ||
            !conversation.hasMember(ourConversationId) ||
            !conversation.hasMember(senderId))
        ) {
          window.log.warn(
            `Received message destined for group ${conversation.idForLogging()}, which we or the sender are not a part of. Dropping.`
          );
          confirm();
          return;
        }

        // We drop incoming messages for v1 groups we already know about, which we're not
        //   a part of, except for group updates. Because group v1 updates haven't been
        //   applied by this point.
        if (
          type === 'incoming' &&
          !conversation.isPrivate() &&
          !isGroupV2 &&
          !isV1GroupUpdate &&
          (conversation.get('left') ||
            !conversation.hasMember(ourConversationId))
        ) {
          window.log.warn(
            `Received message destined for group ${conversation.idForLogging()}, which we're not a part of. Dropping.`
          );
          confirm();
          return;
        }

        // Send delivery receipts, but only for incoming sealed sender messages
        // and not for messages from unaccepted conversations
        if (
          type === 'incoming' &&
          this.get('unidentifiedDeliveryReceived') &&
          !this.hasErrors() &&
          conversation.getAccepted()
        ) {
          // Note: We both queue and batch because we want to wait until we are done
          //   processing incoming messages to start sending outgoing delivery receipts.
          //   The queue can be paused easily.
          Whisper.deliveryReceiptQueue.add(() => {
            Whisper.deliveryReceiptBatcher.add({
              source,
              sourceUuid,
              timestamp: this.get('sent_at'),
            });
          });
        }

        const withQuoteReference = await this.copyFromQuotedMessage(
          initialMessage
        );
        const dataMessage = await upgradeMessageSchema(withQuoteReference);

        try {
          const now = new Date().getTime();

          const urls = window.Signal.LinkPreviews.findLinks(dataMessage.body);
          const incomingPreview = dataMessage.preview || [];
          const preview = incomingPreview.filter(
            item =>
              (item.image || item.title) &&
              urls.includes(item.url) &&
              window.Signal.LinkPreviews.isLinkSafeToPreview(item.url)
          );
          if (preview.length < incomingPreview.length) {
            window.log.info(
              `${message.idForLogging()}: Eliminated ${preview.length -
                incomingPreview.length} previews with invalid urls'`
            );
          }

          message.set({
            id: window.getGuid(),
            attachments: dataMessage.attachments,
            body: dataMessage.body,
            contact: dataMessage.contact,
            conversationId: conversation.id,
            decrypted_at: now,
            errors: [],
            flags: dataMessage.flags,
            hasAttachments: dataMessage.hasAttachments,
            hasFileAttachments: dataMessage.hasFileAttachments,
            hasVisualMediaAttachments: dataMessage.hasVisualMediaAttachments,
            isViewOnce: Boolean(dataMessage.isViewOnce),
            preview,
            requiredProtocolVersion:
              dataMessage.requiredProtocolVersion ||
              this.INITIAL_PROTOCOL_VERSION,
            supportedVersionAtReceive: this.CURRENT_PROTOCOL_VERSION,
            quote: dataMessage.quote,
            schemaVersion: dataMessage.schemaVersion,
            sticker: dataMessage.sticker,
          });

          const isSupported = !message.isUnsupportedMessage();
          if (!isSupported) {
            await message.eraseContents();
          }

          if (isSupported) {
            let attributes = {
              ...conversation.attributes,
            };

            // GroupV1
            if (!isGroupV2 && dataMessage.group) {
              const pendingGroupUpdate = [];
              const memberConversations = await Promise.all(
                dataMessage.group.membersE164.map(e164 =>
                  ConversationController.getOrCreateAndWait(e164, 'private')
                )
              );
              const members = memberConversations.map(c => c.get('id'));
              attributes = {
                ...attributes,
                type: 'group',
                groupId: dataMessage.group.id,
              };
              if (dataMessage.group.type === GROUP_TYPES.UPDATE) {
                attributes = {
                  ...attributes,
                  name: dataMessage.group.name,
                  members: _.union(members, conversation.get('members')),
                };

                if (dataMessage.group.name !== conversation.get('name')) {
                  pendingGroupUpdate.push(['name', dataMessage.group.name]);
                }

                const avatarAttachment = dataMessage.group.avatar;

                let downloadedAvatar;
                let hash;
                if (avatarAttachment) {
                  try {
                    downloadedAvatar = await window.Signal.Util.downloadAttachment(
                      avatarAttachment
                    );

                    if (downloadedAvatar) {
                      const loadedAttachment = await Signal.Migrations.loadAttachmentData(
                        downloadedAvatar
                      );

                      hash = await Signal.Types.Conversation.computeHash(
                        loadedAttachment.data
                      );
                    }
                  } catch (err) {
                    window.log.info(
                      'handleDataMessage: group avatar download failed'
                    );
                  }
                }

                const existingAvatar = conversation.get('avatar');

                if (
                  // Avatar added
                  (!existingAvatar && avatarAttachment) ||
                  // Avatar changed
                  (existingAvatar && existingAvatar.hash !== hash) ||
                  // Avatar removed
                  (existingAvatar && !avatarAttachment)
                ) {
                  // Removes existing avatar from disk
                  if (existingAvatar && existingAvatar.path) {
                    await Signal.Migrations.deleteAttachmentData(
                      existingAvatar.path
                    );
                  }

                  let avatar = null;
                  if (downloadedAvatar && avatarAttachment !== null) {
                    const onDiskAttachment = await window.Signal.Types.Attachment.migrateDataToFileSystem(
                      downloadedAvatar,
                      {
                        writeNewAttachmentData:
                          window.Signal.Migrations.writeNewAttachmentData,
                      }
                    );
                    avatar = {
                      ...onDiskAttachment,
                      hash,
                    };
                  }

                  attributes.avatar = avatar;

                  pendingGroupUpdate.push(['avatarUpdated', true]);
                } else {
                  window.log.info(
                    'handleDataMessage: Group avatar hash matched; not replacing group avatar'
                  );
                }

                const difference = _.difference(
                  members,
                  conversation.get('members')
                );
                if (difference.length > 0) {
                  // Because GroupV1 groups are based on e164 only
                  const e164s = difference.map(id => {
                    const c = ConversationController.get(id);
                    return c ? c.get('e164') : null;
                  });
                  pendingGroupUpdate.push(['joined', e164s]);
                }
                if (conversation.get('left')) {
                  window.log.warn('re-added to a left group');
                  attributes.left = false;
                  conversation.set({ addedBy: message.getContactId() });
                }
              } else if (dataMessage.group.type === GROUP_TYPES.QUIT) {
                const sender = ConversationController.get(senderId);
                const inGroup = Boolean(
                  sender &&
                    (conversation.get('members') || []).includes(sender.id)
                );
                if (!inGroup) {
                  const senderString = sender ? sender.idForLogging() : null;
                  window.log.info(
                    `Got 'left' message from someone not in group: ${senderString}. Dropping.`
                  );
                  return;
                }

                if (sender.isMe()) {
                  attributes.left = true;
                  pendingGroupUpdate.push(['left', 'You']);
                } else {
                  pendingGroupUpdate.push(['left', sender.get('id')]);
                }
                attributes.members = _.without(
                  conversation.get('members'),
                  sender.get('id')
                );
              }

              if (pendingGroupUpdate.length) {
                const groupUpdate = pendingGroupUpdate.reduce(
                  (acc, [key, value]) => {
                    acc[key] = value;
                    return acc;
                  },
                  {}
                );
                message.set({ group_update: groupUpdate });
              }
            }

            // Drop empty messages after. This needs to happen after the initial
            // message.set call and after GroupV1 processing to make sure all possible
            // properties are set before we determine that a message is empty.
            if (message.isEmpty()) {
              window.log.info(
                `handleDataMessage: Dropping empty message ${message.idForLogging()} in conversation ${conversation.idForLogging()}`
              );
              confirm();
              return;
            }

            if (type === 'outgoing') {
              const receipts = Whisper.DeliveryReceipts.forMessage(
                conversation,
                message
              );
              receipts.forEach(receipt =>
                message.set({
                  delivered: (message.get('delivered') || 0) + 1,
                  delivered_to: _.union(message.get('delivered_to') || [], [
                    receipt.get('deliveredTo'),
                  ]),
                })
              );
            }

            attributes.active_at = now;
            conversation.set(attributes);

            if (dataMessage.expireTimer) {
              message.set({ expireTimer: dataMessage.expireTimer });
            }

            if (!isGroupV2) {
              if (message.isExpirationTimerUpdate()) {
                message.set({
                  expirationTimerUpdate: {
                    source,
                    sourceUuid,
                    expireTimer: dataMessage.expireTimer,
                  },
                });
                conversation.set({ expireTimer: dataMessage.expireTimer });
              }

              // NOTE: Remove once the above calls this.model.updateExpirationTimer()
              const { expireTimer } = dataMessage;
              const shouldLogExpireTimerChange =
                message.isExpirationTimerUpdate() || expireTimer;
              if (shouldLogExpireTimerChange) {
                window.log.info("Update conversation 'expireTimer'", {
                  id: conversation.idForLogging(),
                  expireTimer,
                  source: 'handleDataMessage',
                });
              }

              if (!message.isEndSession()) {
                if (dataMessage.expireTimer) {
                  if (
                    dataMessage.expireTimer !== conversation.get('expireTimer')
                  ) {
                    conversation.updateExpirationTimer(
                      dataMessage.expireTimer,
                      source,
                      message.get('received_at'),
                      {
                        fromGroupUpdate: message.isGroupUpdate(),
                      }
                    );
                  }
                } else if (
                  conversation.get('expireTimer') &&
                  // We only turn off timers if it's not a group update
                  !message.isGroupUpdate()
                ) {
                  conversation.updateExpirationTimer(
                    null,
                    source,
                    message.get('received_at')
                  );
                }
              }
            }

            if (type === 'incoming') {
              const readSync = Whisper.ReadSyncs.forMessage(message);
              if (readSync) {
                if (
                  message.get('expireTimer') &&
                  !message.get('expirationStartTimestamp')
                ) {
                  message.set(
                    'expirationStartTimestamp',
                    Math.min(readSync.get('read_at'), Date.now())
                  );
                }
              }
              if (readSync || message.isExpirationTimerUpdate()) {
                message.unset('unread');
                // This is primarily to allow the conversation to mark all older
                // messages as read, as is done when we receive a read sync for
                // a message we already know about.
                const c = message.getConversation();
                if (c) {
                  c.onReadMessage(message);
                }
              } else {
                conversation.set({
                  unreadCount: conversation.get('unreadCount') + 1,
                  isArchived: false,
                });
              }
            }

            if (type === 'outgoing') {
              const reads = Whisper.ReadReceipts.forMessage(
                conversation,
                message
              );
              if (reads.length) {
                const readBy = reads.map(receipt => receipt.get('reader'));
                message.set({
                  read_by: _.union(message.get('read_by'), readBy),
                });
              }

              // A sync'd message to ourself is automatically considered read/delivered
              if (conversation.isMe()) {
                message.set({
                  read_by: conversation.getRecipients(),
                  delivered_to: conversation.getRecipients(),
                });
              }

              message.set({ recipients: conversation.getRecipients() });
            }

            if (dataMessage.profileKey) {
              const profileKey = dataMessage.profileKey.toString('base64');
              if (
                source === textsecure.storage.user.getNumber() ||
                sourceUuid === textsecure.storage.user.getUuid()
              ) {
                conversation.set({ profileSharing: true });
              } else if (conversation.isPrivate()) {
                conversation.setProfileKey(profileKey);
              } else {
                const localId = ConversationController.ensureContactIds({
                  e164: source,
                  uuid: sourceUuid,
                });
                ConversationController.get(localId).setProfileKey(profileKey);
              }
            }

            if (message.isTapToView() && type === 'outgoing') {
              await message.eraseContents();
            }

            if (
              type === 'incoming' &&
              message.isTapToView() &&
              !message.isValidTapToView()
            ) {
              window.log.warn(
                `Received tap to view message ${message.idForLogging()} with invalid data. Erasing contents.`
              );
              message.set({
                isTapToViewInvalid: true,
              });
              await message.eraseContents();
            }
            // Check for out-of-order view syncs
            if (type === 'incoming' && message.isTapToView()) {
              const viewSync = Whisper.ViewSyncs.forMessage(message);
              if (viewSync) {
                await message.markViewed({ fromSync: true });
              }
            }
          }

          const conversationTimestamp = conversation.get('timestamp');
          if (
            !conversationTimestamp ||
            message.get('sent_at') > conversationTimestamp
          ) {
            conversation.set({
              lastMessage: message.getNotificationText(),
              timestamp: message.get('sent_at'),
            });
          }

          MessageController.register(message.id, message);
          conversation.incrementMessageCount();
          window.Signal.Data.updateConversation(conversation.attributes);

          // Only queue attachments for downloads if this is an outgoing message
          // or we've accepted the conversation
          if (this.getConversation().getAccepted() || message.isOutgoing()) {
            await message.queueAttachmentDownloads();
          }

          // Does this message have any pending, previously-received associated reactions?
          const reactions = Whisper.Reactions.forMessage(message);
          reactions.forEach(reaction => {
            message.handleReaction(reaction, false);
          });

          // Does this message have any pending, previously-received associated
          // delete for everyone messages?
          const deletes = Whisper.Deletes.forMessage(message);
          deletes.forEach(del => {
            window.Signal.Util.deleteForEveryone(message, del, false);
          });

          await window.Signal.Data.saveMessage(message.attributes, {
            Message: Whisper.Message,
            forceSave: true,
          });

          conversation.trigger('newmessage', message);

          if (message.get('unread')) {
            await conversation.notify(message);
          }

          // Increment the sent message count if this is an outgoing message
          if (type === 'outgoing') {
            conversation.incrementSentMessageCount();
          }

          Whisper.events.trigger('incrementProgress');
          confirm();
        } catch (error) {
          const errorForLog = error && error.stack ? error.stack : error;
          window.log.error(
            'handleDataMessage',
            message.idForLogging(),
            'error:',
            errorForLog
          );
          throw error;
        }
      });
    },

    async handleReaction(reaction, shouldPersist = true) {
      if (this.get('deletedForEveryone')) {
        return;
      }

      const reactions = this.get('reactions') || [];
      const messageId = this.idForLogging();
      const count = reactions.length;

      if (reaction.get('remove')) {
        window.log.info('Removing reaction for message', messageId);
        const newReactions = reactions.filter(
          re =>
            re.emoji !== reaction.get('emoji') ||
            re.fromId !== reaction.get('fromId')
        );
        this.set({ reactions: newReactions });
      } else {
        window.log.info('Adding reaction for message', messageId);
        const newReactions = reactions.filter(
          re => re.fromId !== reaction.get('fromId')
        );
        newReactions.push(reaction.toJSON());
        this.set({ reactions: newReactions });

        const conversation = ConversationController.get(
          this.get('conversationId')
        );

        // Only notify for reactions to our own messages
        if (conversation && this.isOutgoing() && !reaction.get('fromSync')) {
          conversation.notify(this, reaction);
        }
      }

      const newCount = this.get('reactions').length;
      window.log.info(
        `Done processing reaction for message ${messageId}. Went from ${count} to ${newCount} reactions.`
      );

      if (shouldPersist) {
        await window.Signal.Data.saveMessage(this.attributes, {
          Message: Whisper.Message,
        });
      }
    },

    async handleDeleteForEveryone(del, shouldPersist = true) {
      window.log.info('Handling DOE.', {
        fromId: del.get('fromId'),
        targetSentTimestamp: del.get('targetSentTimestamp'),
        messageServerTimestamp: this.get('serverTimestamp'),
        deleteServerTimestamp: del.get('serverTimestamp'),
      });

      // Remove any notifications for this message
      Whisper.Notifications.removeBy({ messageId: this.get('id') });

      // Erase the contents of this message
      await this.eraseContents(
        { deletedForEveryone: true, reactions: [] },
        shouldPersist
      );

      // Update the conversation's last message in case this was the last message
      this.getConversation().updateLastMessage();
    },
  });

  // Receive will be enabled before we enable send
  Whisper.Message.LONG_MESSAGE_CONTENT_TYPE = 'text/x-signal-plain';

  Whisper.Message.getLongMessageAttachment = ({ body, attachments, now }) => {
    if (!body || body.length <= 2048) {
      return {
        body,
        attachments,
      };
    }

    const data = bytesFromString(body);
    const attachment = {
      contentType: Whisper.Message.LONG_MESSAGE_CONTENT_TYPE,
      fileName: `long-message-${now}.txt`,
      data,
      size: data.byteLength,
    };

    return {
      body: body.slice(0, 2048),
      attachments: [attachment, ...attachments],
    };
  };

  Whisper.Message.updateTimers = () => {
    Whisper.ExpiringMessagesListener.update();
    Whisper.TapToViewMessagesListener.update();
  };

  Whisper.MessageCollection = Backbone.Collection.extend({
    model: Whisper.Message,
    comparator(left, right) {
      if (left.get('received_at') === right.get('received_at')) {
        return (left.get('sent_at') || 0) - (right.get('sent_at') || 0);
      }

      return (left.get('received_at') || 0) - (right.get('received_at') || 0);
    },
  });
})();