Update identity key after a send error tells us it has changed

FREEBIE

js/models/conversations.js

@@ -46,6 +46,7 @@
         });
 
         this.messageCollection.on('change:errors', this.handleMessageError, this);
+        this.messageCollection.on('send-error', this.onMessageError, this);
 
         this.on('change:avatar', this.updateAvatarUrl);
         this.on('destroy', this.revokeAvatarUrl);
@@ -55,6 +56,9 @@
         return this.id === this.ourNumber;
     },
 
+    onMessageError: function() {
+        this.updateVerified();
+    },
     updateVerified: function() {
         if (this.isPrivate()) {
             return Promise.all([

js/models/messages.js

@@ -211,15 +211,6 @@
                 }
                 this.save({sent: true, expirationStartTimestamp: now});
                 this.sendSyncMessage();
-
-                // var error = new Error('OutgoingIdentityKeyError');
-                // error.name = 'OutgoingIdentityKeyError';
-                // error.number = result.successfulNumbers[0];
-                // throw error;
-
-                // var error = new Error('OutgoingMessageError');
-                // error.name = 'OutgoingMessageError';
-                // throw error;
             }.bind(this)).catch(function(result) {
                 var now = Date.now();
                 this.trigger('done');
@@ -227,19 +218,36 @@
                     this.set({dataMessage: result.dataMessage});
                 }
 
+                var promises = [];
+
                 if (result instanceof Error) {
                     this.saveErrors(result);
                     if (result.name === 'SignedPreKeyRotationError') {
-                        getAccountManager().rotateSignedPreKey();
+                        return getAccountManager().rotateSignedPreKey();
+                    }
+                    else if (result.name === 'OutgoingIdentityKeyError') {
+                        promises.push(textsecure.storage.protocol.saveIdentity(
+                            result.number, result.identityKey, false
+                        ));
                     }
                 } else {
                     this.saveErrors(result.errors);
                     if (result.successfulNumbers.length > 0) {
                         this.set({sent: true, expirationStartTimestamp: now});
-                        this.sendSyncMessage();
+                        promises.push(this.sendSyncMessage());
                     }
+                    promises = promises.concat(_.map(result.errors, function(error) {
+                        if (error.name === 'OutgoingIdentityKeyError') {
+                            return textsecure.storage.protocol.saveIdentity(
+                                error.number, error.identityKey, false
+                            );
+                        }
+                    }));
                 }
 
+                return Promise.all(promises).then(function() {
+                    this.trigger('send-error', this.get('errors'));
+                }.bind(this));
             }.bind(this));
         },