/* * vim: ts=4:sw=4:expandtab */ 'use strict'; ;(function() { /********************** *** Device Storage *** **********************/ window.textsecure = window.textsecure || {}; window.textsecure.storage = window.textsecure.storage || {}; window.textsecure.storage.devices = { getStaleDeviceIdsForNumber: function(number) { return textsecure.storage.protocol.getDeviceIds(number).then(function(deviceIds) { if (deviceIds.length === 0) { return [1]; } var updateDevices = []; return Promise.all(deviceIds.map(function(deviceId) { var address = new libsignal.SignalProtocolAddress(number, deviceId).toString(); return textsecure.protocol_wrapper.hasOpenSession(address).then(function(hasSession) { if (!hasSession) { updateDevices.push(deviceId); } }); })).then(function() { return updateDevices; }); }); }, getDeviceObjectsForNumber: function(number) { return textsecure.storage.protocol.loadIdentityKey(number).then(function(identityKey) { if (identityKey === undefined) { return []; } return textsecure.storage.protocol.getDeviceIds(number).then(function(deviceIds) { return Promise.all(deviceIds.map(function(deviceId) { var address = new libsignal.SignalProtocolAddress(number, deviceId).toString(); return textsecure.protocol_wrapper.getRegistrationId(address).then(function(registrationId) { return { encodedNumber : address, registrationId : registrationId }; }); })); }); }); }, removeDeviceIdsForNumber: function(number, deviceIdsToRemove) { var promise = Promise.resolve(); for (var j in deviceIdsToRemove) { promise = promise.then(function() { var encodedNumber = number + "." + deviceIdsToRemove[j]; return textsecure.storage.protocol.removeSession(encodedNumber); }); } return promise; } }; })();