diff --git a/Gruntfile.js b/Gruntfile.js index 7b070cb19..78b954a72 100644 --- a/Gruntfile.js +++ b/Gruntfile.js @@ -111,6 +111,7 @@ module.exports = function(grunt) { '!js/views/conversation_search_view.js', '!js/views/debug_log_view.js', '!js/views/message_view.js', + '!js/models/conversations.js', '!js/WebAudioRecorderMp3.js', '!libtextsecure/message_receiver.js', '_locales/**/*' diff --git a/js/models/conversations.js b/js/models/conversations.js index e2bcc7d60..6b582ecb9 100644 --- a/js/models/conversations.js +++ b/js/models/conversations.js @@ -1,612 +1,610 @@ -/* eslint-disable */ - -/* global Signal: false */ /* global storage: false */ /* global textsecure: false */ /* global Whisper: false */ +/* global Backbone: false */ +/* global _: false */ +/* global ConversationController: false */ +/* global libphonenumber: false */ +/* global wrapDeferred: false */ +/* global dcodeIO: false */ +/* global libsignal: false */ + +/* eslint-disable more/no-then */ +// eslint-disable-next-line func-names (function () { 'use strict'; - window.Whisper = window.Whisper || {}; - - const { Attachment, Message } = window.Signal.Types; - const { upgradeMessageSchema, loadAttachmentData } = window.Signal.Migrations; - - // TODO: Factor out private and group subclasses of Conversation - - var COLORS = [ - 'red', - 'pink', - 'purple', - 'deep_purple', - 'indigo', - 'blue', - 'light_blue', - 'cyan', - 'teal', - 'green', - 'light_green', - 'orange', - 'deep_orange', - 'amber', - 'blue_grey', - ]; - - function constantTimeEqualArrayBuffers(ab1, ab2) { - if (!(ab1 instanceof ArrayBuffer && ab2 instanceof ArrayBuffer)) { - return false; - } - if (ab1.byteLength !== ab2.byteLength) { - return false; - } - var result = 0; - var ta1 = new Uint8Array(ab1); - var ta2 = new Uint8Array(ab2); - for (var i = 0; i < ab1.byteLength; ++i) { - result = result | ta1[i] ^ ta2[i]; - } - return result === 0; + + window.Whisper = window.Whisper || {}; + + const { Message } = window.Signal.Types; + const { upgradeMessageSchema, loadAttachmentData } = window.Signal.Migrations; + + // TODO: Factor out private and group subclasses of Conversation + + const COLORS = [ + 'red', + 'pink', + 'purple', + 'deep_purple', + 'indigo', + 'blue', + 'light_blue', + 'cyan', + 'teal', + 'green', + 'light_green', + 'orange', + 'deep_orange', + 'amber', + 'blue_grey', + ]; + + function constantTimeEqualArrayBuffers(ab1, ab2) { + if (!(ab1 instanceof ArrayBuffer && ab2 instanceof ArrayBuffer)) { + return false; } + if (ab1.byteLength !== ab2.byteLength) { + return false; + } + let result = 0; + const ta1 = new Uint8Array(ab1); + const ta2 = new Uint8Array(ab2); + for (let i = 0; i < ab1.byteLength; i += 1) { + // eslint-disable-next-line no-bitwise + result |= ta1[i] ^ ta2[i]; + } + return result === 0; + } Whisper.Conversation = Backbone.Model.extend({ database: Whisper.Database, storeName: 'conversations', - defaults: function() { - return { - unreadCount: 0, - verified: textsecure.storage.protocol.VerifiedStatus.DEFAULT - }; + defaults() { + return { + unreadCount: 0, + verified: textsecure.storage.protocol.VerifiedStatus.DEFAULT, + }; }, - idForLogging: function() { - if (this.isPrivate()) { - return this.id; - } + idForLogging() { + if (this.isPrivate()) { + return this.id; + } - return 'group(' + this.id + ')'; + return `group(${this.id})`; }, - handleMessageError: function(message, errors) { - this.trigger('messageError', message, errors); + handleMessageError(message, errors) { + this.trigger('messageError', message, errors); }, - initialize: function() { - this.ourNumber = textsecure.storage.user.getNumber(); - this.verifiedEnum = textsecure.storage.protocol.VerifiedStatus; + initialize() { + this.ourNumber = textsecure.storage.user.getNumber(); + this.verifiedEnum = textsecure.storage.protocol.VerifiedStatus; - // This may be overridden by ConversationController.getOrCreate, and signify - // our first save to the database. Or first fetch from the database. - this.initialPromise = Promise.resolve(); + // This may be overridden by ConversationController.getOrCreate, and signify + // our first save to the database. Or first fetch from the database. + this.initialPromise = Promise.resolve(); - this.contactCollection = new Backbone.Collection(); - var collator = new Intl.Collator(); - this.contactCollection.comparator = function(left, right) { - left = left.getTitle().toLowerCase(); - right = right.getTitle().toLowerCase(); - return collator.compare(left, right); - }; - this.messageCollection = new Whisper.MessageCollection([], { - conversation: this - }); + this.contactCollection = new Backbone.Collection(); + const collator = new Intl.Collator(); + this.contactCollection.comparator = (left, right) => { + const leftLower = left.getTitle().toLowerCase(); + const rightLower = right.getTitle().toLowerCase(); + return collator.compare(leftLower, rightLower); + }; + this.messageCollection = new Whisper.MessageCollection([], { + conversation: this, + }); - this.messageCollection.on('change:errors', this.handleMessageError, this); - this.messageCollection.on('send-error', this.onMessageError, this); + this.messageCollection.on('change:errors', this.handleMessageError, this); + this.messageCollection.on('send-error', this.onMessageError, this); - this.on('change:avatar', this.updateAvatarUrl); - this.on('change:profileAvatar', this.updateAvatarUrl); - this.on('change:profileKey', this.onChangeProfileKey); - this.on('destroy', this.revokeAvatarUrl); + this.on('change:avatar', this.updateAvatarUrl); + this.on('change:profileAvatar', this.updateAvatarUrl); + this.on('change:profileKey', this.onChangeProfileKey); + this.on('destroy', this.revokeAvatarUrl); }, - isMe: function() { - return this.id === this.ourNumber; + isMe() { + return this.id === this.ourNumber; }, - onMessageError: function() { - this.updateVerified(); + onMessageError() { + this.updateVerified(); }, - safeGetVerified: function() { - return textsecure.storage.protocol.getVerified(this.id).catch(function() { - return textsecure.storage.protocol.VerifiedStatus.DEFAULT; - }); + safeGetVerified() { + const promise = textsecure.storage.protocol.getVerified(this.id); + return promise.catch(() => textsecure.storage.protocol.VerifiedStatus.DEFAULT); }, - updateVerified: function() { - if (this.isPrivate()) { - return Promise.all([ - this.safeGetVerified(), - this.initialPromise, - ]).then(function(results) { - var trust = results[0]; - // we don't return here because we don't need to wait for this to finish - this.save({verified: trust}); - }.bind(this)); - } else { - return this.fetchContacts().then(function() { - return Promise.all(this.contactCollection.map(function(contact) { - if (!contact.isMe()) { - return contact.updateVerified(); - } - }.bind(this))); - }.bind(this)).then(this.onMemberVerifiedChange.bind(this)); - } - }, - setVerifiedDefault: function(options) { - var DEFAULT = this.verifiedEnum.DEFAULT; - return this.queueJob(function() { - return this._setVerified(DEFAULT, options); - }.bind(this)); - }, - setVerified: function(options) { - var VERIFIED = this.verifiedEnum.VERIFIED; - return this.queueJob(function() { - return this._setVerified(VERIFIED, options); - }.bind(this)); - }, - setUnverified: function(options) { - var UNVERIFIED = this.verifiedEnum.UNVERIFIED; - return this.queueJob(function() { - return this._setVerified(UNVERIFIED, options); - }.bind(this)); - }, - _setVerified: function(verified, options) { - options = options || {}; - _.defaults(options, {viaSyncMessage: false, viaContactSync: false, key: null}); - - var DEFAULT = this.verifiedEnum.DEFAULT; - var VERIFIED = this.verifiedEnum.VERIFIED; - var UNVERIFIED = this.verifiedEnum.UNVERIFIED; - - if (!this.isPrivate()) { - throw new Error('You cannot verify a group conversation. ' + - 'You must verify individual contacts.'); - } + updateVerified() { + if (this.isPrivate()) { + return Promise.all([ + this.safeGetVerified(), + this.initialPromise, + ]).then((results) => { + const trust = results[0]; + // we don't return here because we don't need to wait for this to finish + this.save({ verified: trust }); + }); + } + const promise = this.fetchContacts(); - var beginningVerified = this.get('verified'); - var promise; - if (options.viaSyncMessage) { - // handle the incoming key from the sync messages - need different - // behavior if that key doesn't match the current key - promise = textsecure.storage.protocol.processVerifiedMessage( - this.id, verified, options.key - ); - } else { - promise = textsecure.storage.protocol.setVerified( - this.id, verified - ); + return promise.then(() => Promise.all(this.contactCollection.map((contact) => { + if (!contact.isMe()) { + return contact.updateVerified(); } - - var keychange; - return promise.then(function(updatedKey) { - keychange = updatedKey; - return new Promise(function(resolve) { - return this.save({verified: verified}).always(resolve); - }.bind(this)); - }.bind(this)).then(function() { - // Three situations result in a verification notice in the conversation: - // 1) The message came from an explicit verification in another client (not - // a contact sync) - // 2) The verification value received by the contact sync is different - // from what we have on record (and it's not a transition to UNVERIFIED) - // 3) Our local verification status is VERIFIED and it hasn't changed, - // but the key did change (Key1/VERIFIED to Key2/VERIFIED - but we don't - // want to show DEFAULT->DEFAULT or UNVERIFIED->UNVERIFIED) - if (!options.viaContactSync - || (beginningVerified !== verified && verified !== UNVERIFIED) - || (keychange && verified === VERIFIED)) { - - this.addVerifiedChange(this.id, verified === VERIFIED, {local: !options.viaSyncMessage}); - } - if (!options.viaSyncMessage) { - return this.sendVerifySyncMessage(this.id, verified); - } - }.bind(this)); + return Promise.resolve(); + }))).then(this.onMemberVerifiedChange.bind(this)); }, - sendVerifySyncMessage: function(number, state) { - return textsecure.storage.protocol.loadIdentityKey(number).then(function(key) { - return textsecure.messaging.syncVerification(number, state, key); - }); + setVerifiedDefault(options) { + const { DEFAULT } = this.verifiedEnum; + return this.queueJob(() => this._setVerified(DEFAULT, options)); + }, + setVerified(options) { + const { VERIFIED } = this.verifiedEnum; + return this.queueJob(() => this._setVerified(VERIFIED, options)); }, - getIdentityKeys: function() { - var lookup = {}; + setUnverified(options) { + const { UNVERIFIED } = this.verifiedEnum; + return this.queueJob(() => this._setVerified(UNVERIFIED, options)); + }, + _setVerified(verified, providedOptions) { + const options = providedOptions || {}; + _.defaults(options, { viaSyncMessage: false, viaContactSync: false, key: null }); - if (this.isPrivate()) { - return textsecure.storage.protocol.loadIdentityKey(this.id).then(function(key) { - lookup[this.id] = key; - return lookup; - }.bind(this)).catch(function(error) { - console.log( - 'getIdentityKeys error for conversation', - this.idForLogging(), - error && error.stack ? error.stack : error - ); - return lookup; - }.bind(this)); - } else { - return Promise.all(this.contactCollection.map(function(contact) { - return textsecure.storage.protocol.loadIdentityKey(contact.id).then(function(key) { - lookup[contact.id] = key; - }).catch(function(error) { - console.log( - 'getIdentityKeys error for group member', - contact.idForLogging(), - error && error.stack ? error.stack : error - ); - }); - })).then(function() { - return lookup; - }); + const { + VERIFIED, + UNVERIFIED, + } = this.verifiedEnum; + + if (!this.isPrivate()) { + throw new Error('You cannot verify a group conversation. ' + + 'You must verify individual contacts.'); + } + + const beginningVerified = this.get('verified'); + let promise; + if (options.viaSyncMessage) { + // handle the incoming key from the sync messages - need different + // behavior if that key doesn't match the current key + promise = textsecure.storage.protocol.processVerifiedMessage( + this.id, + verified, + options.key + ); + } else { + promise = textsecure.storage.protocol.setVerified(this.id, verified); + } + + let keychange; + return promise.then((updatedKey) => { + keychange = updatedKey; + return new Promise((resolve => this.save({ verified }).always(resolve))); + }).then(() => { + // Three situations result in a verification notice in the conversation: + // 1) The message came from an explicit verification in another client (not + // a contact sync) + // 2) The verification value received by the contact sync is different + // from what we have on record (and it's not a transition to UNVERIFIED) + // 3) Our local verification status is VERIFIED and it hasn't changed, + // but the key did change (Key1/VERIFIED to Key2/VERIFIED - but we don't + // want to show DEFAULT->DEFAULT or UNVERIFIED->UNVERIFIED) + if (!options.viaContactSync || + (beginningVerified !== verified && verified !== UNVERIFIED) || + (keychange && verified === VERIFIED)) { + return this.addVerifiedChange( + this.id, + verified === VERIFIED, + { local: !options.viaSyncMessage } + ); } + if (!options.viaSyncMessage) { + return this.sendVerifySyncMessage(this.id, verified); + } + return Promise.resolve(); + }); }, - replay: function(error, message) { - var replayable = new textsecure.ReplayableError(error); - return replayable.replay(message.attributes).catch(function(error) { + sendVerifySyncMessage(number, state) { + const promise = textsecure.storage.protocol.loadIdentityKey(number); + return promise.then(key => textsecure.messaging.syncVerification( + number, + state, + key + )); + }, + getIdentityKeys() { + const lookup = {}; + + if (this.isPrivate()) { + return textsecure.storage.protocol.loadIdentityKey(this.id).then((key) => { + lookup[this.id] = key; + return lookup; + }).catch((error) => { + console.log( + 'getIdentityKeys error for conversation', + this.idForLogging(), + error && error.stack ? error.stack : error + ); + return lookup; + }); + } + const promises = this.contactCollection.map(contact => + textsecure.storage.protocol.loadIdentityKey(contact.id).then( + (key) => { + lookup[contact.id] = key; + }, + (error) => { console.log( - 'replay error:', - error && error.stack ? error.stack : error + 'getIdentityKeys error for group member', + contact.idForLogging(), + error && error.stack ? error.stack : error ); - }); + } + )); + + return Promise.all(promises).then(() => lookup); + }, + replay(error, message) { + const replayable = new textsecure.ReplayableError(error); + return replayable.replay(message.attributes).catch((e) => { + console.log( + 'replay error:', + e && e.stack ? e.stack : e + ); + }); }, - decryptOldIncomingKeyErrors: function() { - // We want to run just once per conversation - if (this.get('decryptedOldIncomingKeyErrors')) { - return Promise.resolve(); + decryptOldIncomingKeyErrors() { + // We want to run just once per conversation + if (this.get('decryptedOldIncomingKeyErrors')) { + return Promise.resolve(); + } + console.log('decryptOldIncomingKeyErrors start for', this.idForLogging()); + + const messages = this.messageCollection.filter((message) => { + const errors = message.get('errors'); + if (!errors || !errors[0]) { + return false; } - console.log('decryptOldIncomingKeyErrors start for', this.idForLogging()); + const error = _.find(errors, e => e.name === 'IncomingIdentityKeyError'); - var messages = this.messageCollection.filter(function(message) { - var errors = message.get('errors'); - if (!errors || !errors[0]) { - return false; - } - var error = _.find(errors, function(error) { - return error.name === 'IncomingIdentityKeyError'; - }); + return Boolean(error); + }); - return Boolean(error); + const markComplete = () => { + console.log('decryptOldIncomingKeyErrors complete for', this.idForLogging()); + return new Promise((resolve) => { + this.save({ decryptedOldIncomingKeyErrors: true }).always(resolve); }); + }; + + if (!messages.length) { + return markComplete(); + } + + console.log( + 'decryptOldIncomingKeyErrors found', + messages.length, + 'messages to process' + ); + const safeDelete = message => new Promise((resolve) => { + message.destroy().always(resolve); + }); - var markComplete = function() { - console.log('decryptOldIncomingKeyErrors complete for', this.idForLogging()); - return new Promise(function(resolve) { - this.save({decryptedOldIncomingKeyErrors: true}).always(resolve); - }.bind(this)); - }.bind(this); + const promise = this.getIdentityKeys(); + return promise.then(lookup => Promise.all(_.map(messages, (message) => { + const source = message.get('source'); + const error = _.find( + message.get('errors'), + e => e.name === 'IncomingIdentityKeyError' + ); - if (!messages.length) { - return markComplete(); + const key = lookup[source]; + if (!key) { + return Promise.resolve(); } - console.log('decryptOldIncomingKeyErrors found', messages.length, 'messages to process'); - var safeDelete = function(message) { - return new Promise(function(resolve) { - message.destroy().always(resolve); - }); - }; + if (constantTimeEqualArrayBuffers(key, error.identityKey)) { + return this.replay(error, message).then(() => safeDelete(message)); + } - return this.getIdentityKeys().then(function(lookup) { - return Promise.all(_.map(messages, function(message) { - var source = message.get('source'); - var error = _.find(message.get('errors'), function(error) { - return error.name === 'IncomingIdentityKeyError'; - }); - - var key = lookup[source]; - if (!key) { - return; - } - - if (constantTimeEqualArrayBuffers(key, error.identityKey)) { - return this.replay(error, message).then(function() { - return safeDelete(message); - }); - } - }.bind(this))); - }.bind(this)).catch(function(error) { - console.log( - 'decryptOldIncomingKeyErrors error:', - error && error.stack ? error.stack : error - ); - }).then(markComplete); + return Promise.resolve(); + }))).catch((error) => { + console.log( + 'decryptOldIncomingKeyErrors error:', + error && error.stack ? error.stack : error + ); + }).then(markComplete); }, - isVerified: function() { - if (this.isPrivate()) { - return this.get('verified') === this.verifiedEnum.VERIFIED; - } else { - if (!this.contactCollection.length) { - return false; - } + isVerified() { + if (this.isPrivate()) { + return this.get('verified') === this.verifiedEnum.VERIFIED; + } + if (!this.contactCollection.length) { + return false; + } - return this.contactCollection.every(function(contact) { - if (contact.isMe()) { - return true; - } else { - return contact.isVerified(); - } - }.bind(this)); + return this.contactCollection.every((contact) => { + if (contact.isMe()) { + return true; } + return contact.isVerified(); + }); }, - isUnverified: function() { - if (this.isPrivate()) { - var verified = this.get('verified'); - return verified !== this.verifiedEnum.VERIFIED && verified !== this.verifiedEnum.DEFAULT; - } else { - if (!this.contactCollection.length) { - return true; - } + isUnverified() { + if (this.isPrivate()) { + const verified = this.get('verified'); + return verified !== this.verifiedEnum.VERIFIED && + verified !== this.verifiedEnum.DEFAULT; + } + if (!this.contactCollection.length) { + return true; + } - return this.contactCollection.any(function(contact) { - if (contact.isMe()) { - return false; - } else { - return contact.isUnverified(); - } - }.bind(this)); + return this.contactCollection.any((contact) => { + if (contact.isMe()) { + return false; } + return contact.isUnverified(); + }); }, - getUnverified: function() { - if (this.isPrivate()) { - return this.isUnverified() ? new Backbone.Collection([this]) : new Backbone.Collection(); - } else { - return new Backbone.Collection(this.contactCollection.filter(function(contact) { - if (contact.isMe()) { - return false; - } else { - return contact.isUnverified(); - } - }.bind(this))); + getUnverified() { + if (this.isPrivate()) { + return this.isUnverified() + ? new Backbone.Collection([this]) + : new Backbone.Collection(); + } + return new Backbone.Collection(this.contactCollection.filter((contact) => { + if (contact.isMe()) { + return false; } + return contact.isUnverified(); + })); }, - setApproved: function() { - if (!this.isPrivate()) { - throw new Error('You cannot set a group conversation as trusted. ' + + setApproved() { + if (!this.isPrivate()) { + throw new Error('You cannot set a group conversation as trusted. ' + 'You must set individual contacts as trusted.'); - } + } - return textsecure.storage.protocol.setApproval(this.id, true); + return textsecure.storage.protocol.setApproval(this.id, true); }, - safeIsUntrusted: function() { - return textsecure.storage.protocol.isUntrusted(this.id).catch(function() { - return false; - }); + safeIsUntrusted() { + return textsecure.storage.protocol.isUntrusted(this.id).catch(() => false); }, - isUntrusted: function() { - if (this.isPrivate()) { - return this.safeIsUntrusted(); - } else { - if (!this.contactCollection.length) { - return Promise.resolve(false); - } + isUntrusted() { + if (this.isPrivate()) { + return this.safeIsUntrusted(); + } + if (!this.contactCollection.length) { + return Promise.resolve(false); + } - return Promise.all(this.contactCollection.map(function(contact) { - if (contact.isMe()) { - return false; - } else { - return contact.safeIsUntrusted(); - } - }.bind(this))).then(function(results) { - return _.any(results, function(result) { - return result; - }); - }); + return Promise.all(this.contactCollection.map((contact) => { + if (contact.isMe()) { + return false; } - }, - getUntrusted: function() { - // This is a bit ugly because isUntrusted() is async. Could do the work to cache - // it locally, but we really only need it for this call. - if (this.isPrivate()) { - return this.isUntrusted().then(function(untrusted) { - if (untrusted) { - return new Backbone.Collection([this]); - } + return contact.safeIsUntrusted(); + })).then(results => _.any(results, result => result)); + }, + getUntrusted() { + // This is a bit ugly because isUntrusted() is async. Could do the work to cache + // it locally, but we really only need it for this call. + if (this.isPrivate()) { + return this.isUntrusted().then((untrusted) => { + if (untrusted) { + return new Backbone.Collection([this]); + } - return new Backbone.Collection(); - }.bind(this)); - } else { - return Promise.all(this.contactCollection.map(function(contact) { - if (contact.isMe()) { - return [false, contact]; - } else { - return Promise.all([contact.isUntrusted(), contact]); - } - }.bind(this))).then(function(results) { - results = _.filter(results, function(result) { - var untrusted = result[0]; - return untrusted; - }); - return new Backbone.Collection(_.map(results, function(result) { - var contact = result[1]; - return contact; - })); - }.bind(this)); + return new Backbone.Collection(); + }); + } + return Promise.all(this.contactCollection.map((contact) => { + if (contact.isMe()) { + return [false, contact]; } + return Promise.all([contact.isUntrusted(), contact]); + })).then((results) => { + const filtered = _.filter(results, (result) => { + const untrusted = result[0]; + return untrusted; + }); + return new Backbone.Collection(_.map(filtered, (result) => { + const contact = result[1]; + return contact; + })); + }); }, - onMemberVerifiedChange: function() { - // If the verified state of a member changes, our aggregate state changes. - // We trigger both events to replicate the behavior of Backbone.Model.set() - this.trigger('change:verified'); - this.trigger('change'); + onMemberVerifiedChange() { + // If the verified state of a member changes, our aggregate state changes. + // We trigger both events to replicate the behavior of Backbone.Model.set() + this.trigger('change:verified'); + this.trigger('change'); }, - toggleVerified: function() { - if (this.isVerified()) { - return this.setVerifiedDefault(); - } else { - return this.setVerified(); - } + toggleVerified() { + if (this.isVerified()) { + return this.setVerifiedDefault(); + } + return this.setVerified(); + }, + + addKeyChange(id) { + console.log( + 'adding key change advisory for', + this.idForLogging(), + id, + this.get('timestamp') + ); + + const timestamp = Date.now(); + const message = new Whisper.Message({ + conversationId: this.id, + type: 'keychange', + sent_at: this.get('timestamp'), + received_at: timestamp, + key_changed: id, + unread: 1, + }); + message.save().then(this.trigger.bind(this, 'newmessage', message)); }, + addVerifiedChange(id, verified, providedOptions) { + const options = providedOptions || {}; + _.defaults(options, { local: true }); - addKeyChange: function(id) { - console.log( - 'adding key change advisory for', - this.idForLogging(), - id, - this.get('timestamp') - ); + if (this.isMe()) { + console.log('refusing to add verified change advisory for our own number'); + return; + } + + const lastMessage = this.get('timestamp') || Date.now(); + + console.log( + 'adding verified change advisory for', + this.idForLogging(), + id, + lastMessage + ); + + const timestamp = Date.now(); + const message = new Whisper.Message({ + conversationId: this.id, + type: 'verified-change', + sent_at: lastMessage, + received_at: timestamp, + verifiedChanged: id, + verified, + local: options.local, + unread: 1, + }); + message.save().then(this.trigger.bind(this, 'newmessage', message)); - var timestamp = Date.now(); - var message = new Whisper.Message({ - conversationId : this.id, - type : 'keychange', - sent_at : this.get('timestamp'), - received_at : timestamp, - key_changed : id, - unread : 1 + if (this.isPrivate()) { + ConversationController.getAllGroupsInvolvingId(id).then((groups) => { + _.forEach(groups, (group) => { + group.addVerifiedChange(id, verified, options); + }); }); - message.save().then(this.trigger.bind(this,'newmessage', message)); + } }, - addVerifiedChange: function(id, verified, options) { - options = options || {}; - _.defaults(options, {local: true}); - - if (this.isMe()) { - console.log('refusing to add verified change advisory for our own number'); - return; - } - - var lastMessage = this.get('timestamp') || Date.now(); - console.log( - 'adding verified change advisory for', - this.idForLogging(), - id, - lastMessage - ); - - var timestamp = Date.now(); - var message = new Whisper.Message({ - conversationId : this.id, - type : 'verified-change', - sent_at : lastMessage, - received_at : timestamp, - verifiedChanged : id, - verified : verified, - local : options.local, - unread : 1 - }); - message.save().then(this.trigger.bind(this,'newmessage', message)); + onReadMessage(message) { + if (this.messageCollection.get(message.id)) { + this.messageCollection.get(message.id).fetch(); + } - if (this.isPrivate()) { - ConversationController.getAllGroupsInvolvingId(id).then(function(groups) { - _.forEach(groups, function(group) { - group.addVerifiedChange(id, verified, options); - }); - }); - } - }, + // We mark as read everything older than this message - to clean up old stuff + // still marked unread in the database. If the user generally doesn't read in + // the desktop app, so the desktop app only gets read syncs, we can very + // easily end up with messages never marked as read (our previous early read + // sync handling, read syncs never sent because app was offline) + + // We queue it because we often get a whole lot of read syncs at once, and + // their markRead calls could very easily overlap given the async pull from DB. + + // Lastly, we don't send read syncs for any message marked read due to a read + // sync. That's a notification explosion we don't need. + return this.queueJob(() => this.markRead( + message.get('received_at'), + { sendReadReceipts: false } + )); + }, + + getUnread() { + const conversationId = this.id; + const unreadMessages = new Whisper.MessageCollection(); + return new Promise((resolve => unreadMessages.fetch({ + index: { + // 'unread' index + name: 'unread', + lower: [conversationId], + upper: [conversationId, Number.MAX_VALUE], + }, + }).always(() => { + resolve(unreadMessages); + }))); + }, + + validate(attributes) { + const required = ['id', 'type']; + const missing = _.filter(required, attr => !attributes[attr]); + if (missing.length) { return `Conversation must have ${missing}`; } + + if (attributes.type !== 'private' && attributes.type !== 'group') { + return `Invalid conversation type: ${attributes.type}`; + } - onReadMessage: function(message) { - if (this.messageCollection.get(message.id)) { - this.messageCollection.get(message.id).fetch(); - } + const error = this.validateNumber(); + if (error) { + return error; + } - // We mark as read everything older than this message - to clean up old stuff - // still marked unread in the database. If the user generally doesn't read in - // the desktop app, so the desktop app only gets read syncs, we can very - // easily end up with messages never marked as read (our previous early read - // sync handling, read syncs never sent because app was offline) - - // We queue it because we often get a whole lot of read syncs at once, and - // their markRead calls could very easily overlap given the async pull from DB. - - // Lastly, we don't send read syncs for any message marked read due to a read - // sync. That's a notification explosion we don't need. - return this.queueJob(function() { - return this.markRead(message.get('received_at'), {sendReadReceipts: false}); - }.bind(this)); - }, - - getUnread: function() { - var conversationId = this.id; - var unreadMessages = new Whisper.MessageCollection(); - return new Promise(function(resolve) { - return unreadMessages.fetch({ - index: { - // 'unread' index - name : 'unread', - lower : [conversationId], - upper : [conversationId, Number.MAX_VALUE], - } - }).always(function() { - resolve(unreadMessages); - }); - }); + this.updateTokens(); + return null; }, - validate: function(attributes, options) { - var required = ['id', 'type']; - var missing = _.filter(required, function(attr) { return !attributes[attr]; }); - if (missing.length) { return "Conversation must have " + missing; } - - if (attributes.type !== 'private' && attributes.type !== 'group') { - return "Invalid conversation type: " + attributes.type; + validateNumber() { + if (this.isPrivate()) { + const regionCode = storage.get('regionCode'); + const number = libphonenumber.util.parseNumber(this.id, regionCode); + if (number.isValidNumber) { + this.set({ id: number.e164 }); + return null; } - var error = this.validateNumber(); - if (error) { return error; } - - this.updateTokens(); - }, + return number.error || 'Invalid phone number'; + } - validateNumber: function() { - if (this.isPrivate()) { - var regionCode = storage.get('regionCode'); - var number = libphonenumber.util.parseNumber(this.id, regionCode); - if (number.isValidNumber) { - this.set({ id: number.e164 }); - } else { - return number.error || "Invalid phone number"; - } - } + throw new Error('Cannot validate the number of a group!'); }, - updateTokens: function() { - var tokens = []; - var name = this.get('name'); - if (typeof name === 'string') { - tokens.push(name.toLowerCase()); - tokens = tokens.concat(name.trim().toLowerCase().split(/[\s\-_\(\)\+]+/)); - } - if (this.isPrivate()) { - var regionCode = storage.get('regionCode'); - var number = libphonenumber.util.parseNumber(this.id, regionCode); - tokens.push( - number.nationalNumber, - number.countryCode + number.nationalNumber - ); - } - this.set({tokens: tokens}); + updateTokens() { + let tokens = []; + const name = this.get('name'); + if (typeof name === 'string') { + tokens.push(name.toLowerCase()); + tokens = tokens.concat(name.trim().toLowerCase().split(/[\s\-_()+]+/)); + } + if (this.isPrivate()) { + const regionCode = storage.get('regionCode'); + const number = libphonenumber.util.parseNumber(this.id, regionCode); + tokens.push( + number.nationalNumber, + number.countryCode + number.nationalNumber + ); + } + this.set({ tokens }); }, - queueJob: function(callback) { - var previous = this.pending || Promise.resolve(); + queueJob(callback) { + const previous = this.pending || Promise.resolve(); - var taskWithTimeout = textsecure.createTaskWithTimeout( - callback, - 'conversation ' + this.idForLogging() - ); + const taskWithTimeout = textsecure.createTaskWithTimeout( + callback, + `conversation ${this.idForLogging()}` + ); - var current = this.pending = previous.then(taskWithTimeout, taskWithTimeout); + this.pending = previous.then(taskWithTimeout, taskWithTimeout); + const current = this.pending; - current.then(function() { - if (this.pending === current) { - delete this.pending; - } - }.bind(this)); + current.then(() => { + if (this.pending === current) { + delete this.pending; + } + }); - return current; + return current; }, - getRecipients: function() { - if (this.isPrivate()) { - return [ this.id ]; - } else { - var me = textsecure.storage.user.getNumber(); - return _.without(this.get('members'), me); - } + getRecipients() { + if (this.isPrivate()) { + return [this.id]; + } + const me = textsecure.storage.user.getNumber(); + return _.without(this.get('members'), me); }, - /* jshint ignore:start */ - /* eslint-enable */ sendMessage(body, attachments) { this.queueJob(async () => { const now = Date.now(); @@ -675,7 +673,7 @@ await collection.fetchConversation(this.id, 1); const lastMessage = collection.at(0); - const lastMessageUpdate = Signal.Types.Conversation.createLastMessageUpdate({ + const lastMessageUpdate = window.Signal.Types.Conversation.createLastMessageUpdate({ currentLastMessageText: this.get('lastMessage') || null, currentTimestamp: this.get('timestamp') || null, lastMessage: lastMessage ? lastMessage.toJSON() : null, @@ -689,549 +687,571 @@ this.save(); } }, - /* jshint ignore:end */ - /* eslint-disable */ - updateExpirationTimer: function(expireTimer, source, received_at, options) { - options = options || {}; - _.defaults(options, {fromSync: false}); + updateExpirationTimer( + providedExpireTimer, + providedSource, + receivedAt, + providedOptions + ) { + const options = providedOptions || {}; + let expireTimer = providedExpireTimer; + let source = providedSource; - if (!expireTimer) { - expireTimer = null; - } - if (this.get('expireTimer') === expireTimer - || (!expireTimer && !this.get('expireTimer'))) { + _.defaults(options, { fromSync: false }); + + if (!expireTimer) { + expireTimer = null; + } + if (this.get('expireTimer') === expireTimer || + (!expireTimer && !this.get('expireTimer'))) { + return Promise.resolve(); + } + + console.log( + 'Updating expireTimer for conversation', + this.idForLogging(), + 'to', + expireTimer, + 'via', + source + ); + source = source || textsecure.storage.user.getNumber(); + const timestamp = receivedAt || Date.now(); + + const message = this.messageCollection.add({ + conversationId: this.id, + type: receivedAt ? 'incoming' : 'outgoing', + sent_at: timestamp, + received_at: timestamp, + flags: textsecure.protobuf.DataMessage.Flags.EXPIRATION_TIMER_UPDATE, + expirationTimerUpdate: { + expireTimer, + source, + fromSync: options.fromSync, + }, + }); + if (this.isPrivate()) { + message.set({ destination: this.id }); + } + if (message.isOutgoing()) { + message.set({ recipients: this.getRecipients() }); + } - return; + return Promise.all([ + wrapDeferred(message.save()), + wrapDeferred(this.save({ expireTimer })), + ]).then(() => { + if (message.isIncoming()) { + return message; } - console.log( - 'Updating expireTimer for conversation', - this.idForLogging(), - 'to', - expireTimer, - 'via', - source - ); - source = source || textsecure.storage.user.getNumber(); - var timestamp = received_at || Date.now(); - - var message = this.messageCollection.add({ - conversationId : this.id, - type : received_at ? 'incoming' : 'outgoing', - sent_at : timestamp, - received_at : timestamp, - flags : textsecure.protobuf.DataMessage.Flags.EXPIRATION_TIMER_UPDATE, - expirationTimerUpdate : { - expireTimer : expireTimer, - source : source, - fromSync : options.fromSync, - } - }); - if (this.isPrivate()) { - message.set({destination: this.id}); + // change was made locally, send it to the number/group + let sendFunc; + if (this.get('type') === 'private') { + sendFunc = textsecure.messaging.sendExpirationTimerUpdateToNumber; + } else { + sendFunc = textsecure.messaging.sendExpirationTimerUpdateToGroup; } - if (message.isOutgoing()) { - message.set({recipients: this.getRecipients() }); + let profileKey; + if (this.get('profileSharing')) { + profileKey = storage.get('profileKey'); } + const promise = sendFunc( + this.get('id'), + this.get('expireTimer'), + message.get('sent_at'), + profileKey + ); - return Promise.all([ - wrapDeferred(message.save()), - wrapDeferred(this.save({ expireTimer: expireTimer })), - ]).then(function() { - if (message.isIncoming()) { - return message; - } - - // change was made locally, send it to the number/group - var sendFunc; - if (this.get('type') == 'private') { - sendFunc = textsecure.messaging.sendExpirationTimerUpdateToNumber; - } - else { - sendFunc = textsecure.messaging.sendExpirationTimerUpdateToGroup; - } - var profileKey; - if (this.get('profileSharing')) { - profileKey = storage.get('profileKey'); - } - var promise = sendFunc(this.get('id'), - this.get('expireTimer'), - message.get('sent_at'), - profileKey - ); - - return message.send(promise).then(function() { - return message; - }); - }.bind(this)); + return message.send(promise).then(() => message); + }); }, - isSearchable: function() { - return !this.get('left') || !!this.get('lastMessage'); + isSearchable() { + return !this.get('left') || !!this.get('lastMessage'); }, - endSession: function() { - if (this.isPrivate()) { - var now = Date.now(); - var message = this.messageCollection.create({ - conversationId : this.id, - type : 'outgoing', - sent_at : now, - received_at : now, - destination : this.id, - recipients : this.getRecipients(), - flags : textsecure.protobuf.DataMessage.Flags.END_SESSION - }); - message.send(textsecure.messaging.resetSession(this.id, now)); - } - + endSession() { + if (this.isPrivate()) { + const now = Date.now(); + const message = this.messageCollection.create({ + conversationId: this.id, + type: 'outgoing', + sent_at: now, + received_at: now, + destination: this.id, + recipients: this.getRecipients(), + flags: textsecure.protobuf.DataMessage.Flags.END_SESSION, + }); + message.send(textsecure.messaging.resetSession(this.id, now)); + } }, - updateGroup: function(group_update) { - if (this.isPrivate()) { - throw new Error("Called update group on private conversation"); - } - if (group_update === undefined) { - group_update = this.pick(['name', 'avatar', 'members']); - } - var now = Date.now(); - var message = this.messageCollection.create({ - conversationId : this.id, - type : 'outgoing', - sent_at : now, - received_at : now, - group_update : group_update + updateGroup(providedGroupUpdate) { + let groupUpdate = providedGroupUpdate; + + if (this.isPrivate()) { + throw new Error('Called update group on private conversation'); + } + if (groupUpdate === undefined) { + groupUpdate = this.pick(['name', 'avatar', 'members']); + } + const now = Date.now(); + const message = this.messageCollection.create({ + conversationId: this.id, + type: 'outgoing', + sent_at: now, + received_at: now, + group_update: groupUpdate, + }); + message.send(textsecure.messaging.updateGroup( + this.id, + this.get('name'), + this.get('avatar'), + this.get('members') + )); + }, + + leaveGroup() { + const now = Date.now(); + if (this.get('type') === 'group') { + this.save({ left: true }); + const message = this.messageCollection.create({ + group_update: { left: 'You' }, + conversationId: this.id, + type: 'outgoing', + sent_at: now, + received_at: now, }); - message.send(textsecure.messaging.updateGroup( - this.id, - this.get('name'), - this.get('avatar'), - this.get('members') - )); + message.send(textsecure.messaging.leaveGroup(this.id)); + } }, - leaveGroup: function() { - var now = Date.now(); - if (this.get('type') === 'group') { - this.save({left: true}); - var message = this.messageCollection.create({ - group_update: { left: 'You' }, - conversationId : this.id, - type : 'outgoing', - sent_at : now, - received_at : now - }); - message.send(textsecure.messaging.leaveGroup(this.id)); - } - }, + markRead(newestUnreadDate, providedOptions) { + const options = providedOptions || {}; + _.defaults(options, { sendReadReceipts: true }); - markRead: function(newestUnreadDate, options) { - options = options || {}; - _.defaults(options, {sendReadReceipts: true}); + const conversationId = this.id; + Whisper.Notifications.remove(Whisper.Notifications.where({ + conversationId, + })); - var conversationId = this.id; - Whisper.Notifications.remove(Whisper.Notifications.where({ - conversationId: conversationId - })); + return this.getUnread().then((providedUnreadMessages) => { + let unreadMessages = providedUnreadMessages; - return this.getUnread().then(function(unreadMessages) { - var promises = []; - var oldUnread = unreadMessages.filter(function(message) { - return message.get('received_at') <= newestUnreadDate; - }); + const promises = []; + const oldUnread = unreadMessages.filter(message => + message.get('received_at') <= newestUnreadDate); - var read = _.map(oldUnread, function(m) { - if (this.messageCollection.get(m.id)) { - m = this.messageCollection.get(m.id); - } else { - console.log('Marked a message as read in the database, but ' + - 'it was not in messageCollection.'); - } - promises.push(m.markRead()); - var errors = m.get('errors'); - return { - sender : m.get('source'), - timestamp : m.get('sent_at'), - hasErrors : Boolean(errors && errors.length) - }; - }.bind(this)); - - // Some messages we're marking read are local notifications with no sender - read = _.filter(read, function(m) { - return Boolean(m.sender); - }); - unreadMessages = unreadMessages.filter(function(m) { - return Boolean(m.isIncoming()); - }); + let read = _.map(oldUnread, (providedM) => { + let m = providedM; - var unreadCount = unreadMessages.length - read.length; - var promise = new Promise(function(resolve, reject) { - this.save({ unreadCount: unreadCount }).then(resolve, reject); - }.bind(this)); - promises.push(promise); - - // If a message has errors, we don't want to send anything out about it. - // read syncs - let's wait for a client that really understands the message - // to mark it read. we'll mark our local error read locally, though. - // read receipts - here we can run into infinite loops, where each time the - // conversation is viewed, another error message shows up for the contact - read = read.filter(function(item) { - return !item.hasErrors; - }); + if (this.messageCollection.get(m.id)) { + m = this.messageCollection.get(m.id); + } else { + console.log('Marked a message as read in the database, but ' + + 'it was not in messageCollection.'); + } + promises.push(m.markRead()); + const errors = m.get('errors'); + return { + sender: m.get('source'), + timestamp: m.get('sent_at'), + hasErrors: Boolean(errors && errors.length), + }; + }); - if (read.length && options.sendReadReceipts) { - console.log('Sending', read.length, 'read receipts'); - promises.push(textsecure.messaging.syncReadMessages(read)); + // Some messages we're marking read are local notifications with no sender + read = _.filter(read, m => Boolean(m.sender)); + unreadMessages = unreadMessages.filter(m => Boolean(m.isIncoming())); - if (storage.get('read-receipt-setting')) { - _.each(_.groupBy(read, 'sender'), function(receipts, sender) { - var timestamps = _.map(receipts, 'timestamp'); - promises.push(textsecure.messaging.sendReadReceipts(sender, timestamps)); - }); - } - } + const unreadCount = unreadMessages.length - read.length; + const promise = new Promise(((resolve, reject) => { + this.save({ unreadCount }).then(resolve, reject); + })); + promises.push(promise); + + // If a message has errors, we don't want to send anything out about it. + // read syncs - let's wait for a client that really understands the message + // to mark it read. we'll mark our local error read locally, though. + // read receipts - here we can run into infinite loops, where each time the + // conversation is viewed, another error message shows up for the contact + read = read.filter(item => !item.hasErrors); + + if (read.length && options.sendReadReceipts) { + console.log('Sending', read.length, 'read receipts'); + promises.push(textsecure.messaging.syncReadMessages(read)); + + if (storage.get('read-receipt-setting')) { + _.each(_.groupBy(read, 'sender'), (receipts, sender) => { + const timestamps = _.map(receipts, 'timestamp'); + promises.push(textsecure.messaging.sendReadReceipts(sender, timestamps)); + }); + } + } - return Promise.all(promises); - }.bind(this)); + return Promise.all(promises); + }); }, - onChangeProfileKey: function() { - if (this.isPrivate()) { - this.getProfiles(); - } + onChangeProfileKey() { + if (this.isPrivate()) { + this.getProfiles(); + } }, - getProfiles: function() { - // request all conversation members' keys - var ids = []; - if (this.isPrivate()) { - ids = [this.id]; - } else { - ids = this.get('members'); - } - return Promise.all(_.map(ids, this.getProfile)); + getProfiles() { + // request all conversation members' keys + let ids = []; + if (this.isPrivate()) { + ids = [this.id]; + } else { + ids = this.get('members'); + } + return Promise.all(_.map(ids, this.getProfile)); }, - getProfile: function(id) { - if (!textsecure.messaging) { - var message = 'Conversation.getProfile: textsecure.messaging not available'; - return Promise.reject(new Error(message)); - } + getProfile(id) { + if (!textsecure.messaging) { + const message = 'Conversation.getProfile: textsecure.messaging not available'; + return Promise.reject(new Error(message)); + } - return textsecure.messaging.getProfile(id).then(function(profile) { - var identityKey = dcodeIO.ByteBuffer.wrap(profile.identityKey, 'base64').toArrayBuffer(); - - return textsecure.storage.protocol.saveIdentity( - id + '.1', identityKey, false - ).then(function(changed) { - if (changed) { - // save identity will close all sessions except for .1, so we - // must close that one manually. - var address = new libsignal.SignalProtocolAddress(id, 1); - console.log('closing session for', address.toString()); - var sessionCipher = new libsignal.SessionCipher(textsecure.storage.protocol, address); - return sessionCipher.closeOpenSessionForDevice(); - } - }).then(function() { - var c = ConversationController.get(id); - return Promise.all([ - c.setProfileName(profile.name), - c.setProfileAvatar(profile.avatar) - ]).then(function() { - // success - return new Promise(function(resolve, reject) { - c.save().then(resolve, reject); - }); - }, function(e) { - // fail - if (e.name === 'ProfileDecryptError') { - // probably the profile key has changed. - console.log( - 'decryptProfile error:', - id, - profile, - e && e.stack ? e.stack : e - ); - } - }); - }.bind(this)); - }.bind(this)).catch(function(error) { - console.log( - 'getProfile error:', - error && error.stack ? error.stack : error + return textsecure.messaging.getProfile(id).then((profile) => { + const identityKey = dcodeIO.ByteBuffer.wrap( + profile.identityKey, + 'base64' + ).toArrayBuffer(); + + return textsecure.storage.protocol.saveIdentity( + `${id}.1`, + identityKey, + false + ).then((changed) => { + if (changed) { + // save identity will close all sessions except for .1, so we + // must close that one manually. + const address = new libsignal.SignalProtocolAddress(id, 1); + console.log('closing session for', address.toString()); + const sessionCipher = new libsignal.SessionCipher( + textsecure.storage.protocol, + address ); + return sessionCipher.closeOpenSessionForDevice(); + } + return Promise.resolve(); + }).then(() => { + const c = ConversationController.get(id); + return Promise.all([ + c.setProfileName(profile.name), + c.setProfileAvatar(profile.avatar), + ]).then( + // success + () => new Promise((resolve, reject) => { + c.save().then(resolve, reject); + }), + // fail + (e) => { + if (e.name === 'ProfileDecryptError') { + // probably the profile key has changed. + console.log( + 'decryptProfile error:', + id, + profile, + e && e.stack ? e.stack : e + ); + } + } + ); }); + }).catch((error) => { + console.log( + 'getProfile error:', + error && error.stack ? error.stack : error + ); + }); }, - setProfileName: function(encryptedName) { - var key = this.get('profileKey'); - if (!key) { return; } + setProfileName(encryptedName) { + const key = this.get('profileKey'); + if (!key) { + return Promise.resolve(); + } try { // decode - var data = dcodeIO.ByteBuffer.wrap(encryptedName, 'base64').toArrayBuffer(); + const data = dcodeIO.ByteBuffer.wrap(encryptedName, 'base64').toArrayBuffer(); // decrypt - return textsecure.crypto.decryptProfileName(data, key).then(function(decrypted) { - + return textsecure.crypto.decryptProfileName(data, key).then((decrypted) => { // encode - var name = dcodeIO.ByteBuffer.wrap(decrypted).toString('utf8'); + const name = dcodeIO.ByteBuffer.wrap(decrypted).toString('utf8'); // set - this.set({profileName: name}); - }.bind(this)); - } - catch (e) { + this.set({ profileName: name }); + }); + } catch (e) { return Promise.reject(e); } }, - setProfileAvatar: function(avatarPath) { - if (!avatarPath) { return; } - return textsecure.messaging.getAvatar(avatarPath).then(function(avatar) { - var key = this.get('profileKey'); - if (!key) { return; } + setProfileAvatar(avatarPath) { + if (!avatarPath) { + return Promise.resolve(); + } + + return textsecure.messaging.getAvatar(avatarPath).then((avatar) => { + const key = this.get('profileKey'); + if (!key) { + return Promise.resolve(); + } // decrypt - return textsecure.crypto.decryptProfile(avatar, key).then(function(decrypted) { + return textsecure.crypto.decryptProfile(avatar, key).then((decrypted) => { // set this.set({ profileAvatar: { data: decrypted, contentType: 'image/jpeg', - size: decrypted.byteLength - } + size: decrypted.byteLength, + }, }); - }.bind(this)); - }.bind(this)); + }); + }); }, - setProfileKey: function(key) { - return new Promise(function(resolve, reject) { + setProfileKey(key) { + return new Promise(((resolve, reject) => { if (!constantTimeEqualArrayBuffers(this.get('profileKey'), key)) { - this.save({profileKey: key}).then(resolve, reject); + this.save({ profileKey: key }).then(resolve, reject); } else { resolve(); } - }.bind(this)); + })); }, - fetchMessages: function() { - if (!this.id) { - return Promise.reject('This conversation has no id!'); - } - return this.messageCollection.fetchConversation(this.id, null, this.get('unreadCount')); + fetchMessages() { + if (!this.id) { + return Promise.reject(new Error('This conversation has no id!')); + } + return this.messageCollection.fetchConversation( + this.id, + null, + this.get('unreadCount') + ); }, - hasMember: function(number) { - return _.contains(this.get('members'), number); + hasMember(number) { + return _.contains(this.get('members'), number); }, - fetchContacts: function(options) { - if (this.isPrivate()) { - this.contactCollection.reset([this]); - return Promise.resolve(); - } else { - var members = this.get('members') || []; - var promises = members.map(function(number) { - return ConversationController.getOrCreateAndWait(number, 'private'); - }); + fetchContacts() { + if (this.isPrivate()) { + this.contactCollection.reset([this]); + return Promise.resolve(); + } + const members = this.get('members') || []; + const promises = members.map(number => + ConversationController.getOrCreateAndWait(number, 'private')); - return Promise.all(promises).then(function(contacts) { - _.forEach(contacts, function(contact) { - this.listenTo(contact, 'change:verified', this.onMemberVerifiedChange); - }.bind(this)); + return Promise.all(promises).then((contacts) => { + _.forEach(contacts, (contact) => { + this.listenTo(contact, 'change:verified', this.onMemberVerifiedChange); + }); - this.contactCollection.reset(contacts); - }.bind(this)); - } + this.contactCollection.reset(contacts); + }); }, - destroyMessages: function() { - this.messageCollection.fetch({ - index: { - // 'conversation' index on [conversationId, received_at] - name : 'conversation', - lower : [this.id], - upper : [this.id, Number.MAX_VALUE], - } - }).then(function() { - var models = this.messageCollection.models; - this.messageCollection.reset([]); - _.each(models, function(message) { - message.destroy(); - }); - this.save({ - lastMessage: null, - timestamp: null, - active_at: null, - }); - }.bind(this)); + destroyMessages() { + this.messageCollection.fetch({ + index: { + // 'conversation' index on [conversationId, received_at] + name: 'conversation', + lower: [this.id], + upper: [this.id, Number.MAX_VALUE], + }, + }).then(() => { + const { models } = this.messageCollection; + this.messageCollection.reset([]); + _.each(models, (message) => { + message.destroy(); + }); + this.save({ + lastMessage: null, + timestamp: null, + active_at: null, + }); + }); }, - getName: function() { - if (this.isPrivate()) { - return this.get('name'); - } else { - return this.get('name') || 'Unknown group'; - } + getName() { + if (this.isPrivate()) { + return this.get('name'); + } + return this.get('name') || 'Unknown group'; }, - getTitle: function() { - if (this.isPrivate()) { - return this.get('name') || this.getNumber(); - } else { - return this.get('name') || 'Unknown group'; - } + getTitle() { + if (this.isPrivate()) { + return this.get('name') || this.getNumber(); + } + return this.get('name') || 'Unknown group'; }, - getProfileName: function() { - if (this.isPrivate() && !this.get('name')) { - return this.get('profileName'); - } + getProfileName() { + if (this.isPrivate() && !this.get('name')) { + return this.get('profileName'); + } + return null; }, - getDisplayName: function() { - if (!this.isPrivate()) { - return this.getTitle(); - } + getDisplayName() { + if (!this.isPrivate()) { + return this.getTitle(); + } - var name = this.get('name'); - if (name) { - return name; - } + const name = this.get('name'); + if (name) { + return name; + } - var profileName = this.get('profileName'); - if (profileName) { - return this.getNumber() + ' ~' + profileName; - } + const profileName = this.get('profileName'); + if (profileName) { + return `${this.getNumber()} ~${profileName}`; + } - return this.getNumber(); + return this.getNumber(); }, - getNumber: function() { - if (!this.isPrivate()) { - return ''; - } - var number = this.id; - try { - var parsedNumber = libphonenumber.parse(number); - var regionCode = libphonenumber.getRegionCodeForNumber(parsedNumber); - if (regionCode === storage.get('regionCode')) { - return libphonenumber.format(parsedNumber, libphonenumber.PhoneNumberFormat.NATIONAL); - } else { - return libphonenumber.format(parsedNumber, libphonenumber.PhoneNumberFormat.INTERNATIONAL); - } - } catch (e) { - return number; + getNumber() { + if (!this.isPrivate()) { + return ''; + } + const number = this.id; + try { + const parsedNumber = libphonenumber.parse(number); + const regionCode = libphonenumber.getRegionCodeForNumber(parsedNumber); + if (regionCode === storage.get('regionCode')) { + return libphonenumber.format( + parsedNumber, + libphonenumber.PhoneNumberFormat.NATIONAL + ); } + return libphonenumber.format( + parsedNumber, + libphonenumber.PhoneNumberFormat.INTERNATIONAL + ); + } catch (e) { + return number; + } }, - isPrivate: function() { - return this.get('type') === 'private'; + isPrivate() { + return this.get('type') === 'private'; }, - revokeAvatarUrl: function() { - if (this.avatarUrl) { - URL.revokeObjectURL(this.avatarUrl); - this.avatarUrl = null; - } + revokeAvatarUrl() { + if (this.avatarUrl) { + URL.revokeObjectURL(this.avatarUrl); + this.avatarUrl = null; + } }, - updateAvatarUrl: function(silent) { - this.revokeAvatarUrl(); - var avatar = this.get('avatar') || this.get('profileAvatar'); - if (avatar) { - this.avatarUrl = URL.createObjectURL( - new Blob([avatar.data], {type: avatar.contentType}) - ); - } else { - this.avatarUrl = null; - } - if (!silent) { - this.trigger('change'); - } + updateAvatarUrl(silent) { + this.revokeAvatarUrl(); + const avatar = this.get('avatar') || this.get('profileAvatar'); + if (avatar) { + this.avatarUrl = URL.createObjectURL(new Blob( + [avatar.data], + { type: avatar.contentType } + )); + } else { + this.avatarUrl = null; + } + if (!silent) { + this.trigger('change'); + } }, - getColor: function() { - var title = this.get('name'); - var color = this.get('color'); - if (!color) { - if (this.isPrivate()) { - if (title) { - color = COLORS[Math.abs(this.hashCode()) % 15]; - } else { - color = 'grey'; - } - } else { - color = 'default'; - } + getColor() { + const title = this.get('name'); + let color = this.get('color'); + if (!color) { + if (this.isPrivate()) { + if (title) { + color = COLORS[Math.abs(this.hashCode()) % 15]; + } else { + color = 'grey'; + } + } else { + color = 'default'; } - return color; + } + return color; }, - getAvatar: function() { - if (this.avatarUrl === undefined) { - this.updateAvatarUrl(true); - } + getAvatar() { + if (this.avatarUrl === undefined) { + this.updateAvatarUrl(true); + } - var title = this.get('name'); - var color = this.getColor(); + const title = this.get('name'); + const color = this.getColor(); - if (this.avatarUrl) { - return { url: this.avatarUrl, color: color }; - } else if (this.isPrivate()) { - return { - color: color, - content: title ? title.trim()[0] : '#' - }; + if (this.avatarUrl) { + return { url: this.avatarUrl, color }; + } else if (this.isPrivate()) { + return { + color, + content: title ? title.trim()[0] : '#', + }; + } + return { url: 'images/group_default.png', color }; + }, + + getNotificationIcon() { + return new Promise(((resolve) => { + const avatar = this.getAvatar(); + if (avatar.url) { + resolve(avatar.url); } else { - return { url: 'images/group_default.png', color: color }; + resolve(new Whisper.IdenticonSVGView(avatar).getDataUrl()); } + })); }, - getNotificationIcon: function() { - return new Promise(function(resolve) { - var avatar = this.getAvatar(); - if (avatar.url) { - resolve(avatar.url); - } else { - resolve(new Whisper.IdenticonSVGView(avatar).getDataUrl()); - } - }.bind(this)); + notify(message) { + if (!message.isIncoming()) { + return Promise.resolve(); + } + const conversationId = this.id; + + return ConversationController.getOrCreateAndWait(message.get('source'), 'private') + .then(sender => sender.getNotificationIcon().then((iconUrl) => { + console.log('adding notification'); + Whisper.Notifications.add({ + title: sender.getTitle(), + message: message.getNotificationText(), + iconUrl, + imageUrl: message.getImageUrl(), + conversationId, + messageId: message.id, + }); + })); }, - - notify: function(message) { - if (!message.isIncoming()) { - return Promise.resolve(); + hashCode() { + if (this.hash === undefined) { + const string = this.getTitle() || ''; + if (string.length === 0) { + return 0; } - var conversationId = this.id; - - return ConversationController.getOrCreateAndWait(message.get('source'), 'private') - .then(function(sender) { - return sender.getNotificationIcon().then(function(iconUrl) { - console.log('adding notification'); - Whisper.Notifications.add({ - title : sender.getTitle(), - message : message.getNotificationText(), - iconUrl : iconUrl, - imageUrl : message.getImageUrl(), - conversationId : conversationId, - messageId : message.id - }); - }); - }); - }, - hashCode: function() { - if (this.hash === undefined) { - var string = this.getTitle() || ''; - if (string.length === 0) { - return 0; - } - var hash = 0; - for (var i = 0; i < string.length; i++) { - hash = ((hash<<5)-hash) + string.charCodeAt(i); - hash = hash & hash; // Convert to 32bit integer - } - - this.hash = hash; + let hash = 0; + for (let i = 0; i < string.length; i += 1) { + // eslint-disable-next-line no-bitwise + hash = ((hash << 5) - hash) + string.charCodeAt(i); + // eslint-disable-next-line no-bitwise + hash &= hash; // Convert to 32bit integer } - return this.hash; - } + + this.hash = hash; + } + return this.hash; + }, }); Whisper.ConversationCollection = Backbone.Collection.extend({ @@ -1239,59 +1259,58 @@ storeName: 'conversations', model: Whisper.Conversation, - comparator: function(m) { + comparator(m) { return -m.get('timestamp'); }, - destroyAll: function () { - return Promise.all(this.models.map(function(m) { - return new Promise(function(resolve, reject) { - m.destroy().then(resolve).fail(reject); - }); - })); + destroyAll() { + return Promise.all(this.models.map(m => new Promise(((resolve, reject) => { + m.destroy().then(resolve).fail(reject); + })))); }, - search: function(query) { - query = query.trim().toLowerCase(); - if (query.length > 0) { - query = query.replace(/[-.\(\)]*/g,'').replace(/^\+(\d*)$/, '$1'); - var lastCharCode = query.charCodeAt(query.length - 1); - var nextChar = String.fromCharCode(lastCharCode + 1); - var upper = query.slice(0, -1) + nextChar; - return new Promise(function(resolve) { - this.fetch({ - index: { - name: 'search', // 'search' index on tokens array - lower: query, - upper: upper, - excludeUpper: true - } - }).always(resolve); - }.bind(this)); - } + search(providedQuery) { + let query = providedQuery.trim().toLowerCase(); + if (query.length > 0) { + query = query.replace(/[-.()]*/g, '').replace(/^\+(\d*)$/, '$1'); + const lastCharCode = query.charCodeAt(query.length - 1); + const nextChar = String.fromCharCode(lastCharCode + 1); + const upper = query.slice(0, -1) + nextChar; + return new Promise(((resolve) => { + this.fetch({ + index: { + name: 'search', // 'search' index on tokens array + lower: query, + upper, + excludeUpper: true, + }, + }).always(resolve); + })); + } + return Promise.resolve(); + }, + + fetchAlphabetical() { + return new Promise(((resolve) => { + this.fetch({ + index: { + name: 'search', // 'search' index on tokens array + }, + limit: 100, + }).always(resolve); + })); + }, + + fetchGroups(number) { + return new Promise(((resolve) => { + this.fetch({ + index: { + name: 'group', + only: number, + }, + }).always(resolve); + })); }, - - fetchAlphabetical: function() { - return new Promise(function(resolve) { - this.fetch({ - index: { - name: 'search', // 'search' index on tokens array - }, - limit: 100 - }).always(resolve); - }.bind(this)); - }, - - fetchGroups: function(number) { - return new Promise(function(resolve) { - this.fetch({ - index: { - name: 'group', - only: number - } - }).always(resolve); - }.bind(this)); - } }); Whisper.Conversation.COLORS = COLORS.concat(['grey', 'default']).join(' '); @@ -1301,15 +1320,15 @@ database: Whisper.Database, storeName: 'conversations', model: Whisper.Conversation, - fetchGroups: function(number) { - return new Promise(function(resolve) { - this.fetch({ - index: { - name: 'group', - only: number - } - }).always(resolve); - }.bind(this)); - } + fetchGroups(number) { + return new Promise(((resolve) => { + this.fetch({ + index: { + name: 'group', + only: number, + }, + }).always(resolve); + })); + }, }); -})(); +}());