mirrors/signal-desktop
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages 2 Wiki Activity Actions

Add MessageSender

Browse source 
textsecure.MessageSender takes server url and credentials and returns
a message sending interface configured for that server.

Used a wrapper function to insert a TextSecureServer instance into
sendmessage.js code at runtime. This will result in function duplication
between different MessageSender objects, pending further refactoring to
use prototypal inheritence.

// FREEBIE
This commit is contained in:
lilia 2015-08-28 14:45:44 -07:00
parent 98aa5156b0
commit 9e9d767a30
3 changed files with 775 additions and 766 deletions
Download patch file Download diff file Expand all files Collapse all files

1
js/background.js
View file

@ -102,6 +102,7 @@
messageReceiver.addEventListener('contactsync', onContactSyncComplete); messageReceiver.addEventListener('contactsync', onContactSyncComplete);
window.textsecure.messaging = new textsecure.MessageSender(SERVER_URL, USERNAME, PASSWORD);
if (firstRun === true && textsecure.storage.user.getDeviceId() != '1') { if (firstRun === true && textsecure.storage.user.getDeviceId() != '1') {
textsecure.messaging.sendRequestContactSyncMessage().then(function() { textsecure.messaging.sendRequestContactSyncMessage().then(function() {
textsecure.messaging.sendRequestGroupSyncMessage(); textsecure.messaging.sendRequestGroupSyncMessage();

770
js/libtextsecure.js
View file

@ -39586,441 +39586,445 @@ var TextSecureServer = (function() {
* vim: ts=4:sw=4:expandtab * vim: ts=4:sw=4:expandtab
*/ */
// sendMessage(numbers = [], message = PushMessageContentProto, callback(success/failure map)) // sendMessage(numbers = [], message = PushMessageContentProto, callback(success/failure map))
window.textsecure.messaging = function() { window.textsecure.MessageSender = function(url, username, password) {
'use strict'; 'use strict';
var server = new TextSecureServer(url, username, password);
return (function(TextSecureServer) {
'use strict';
var self = {}; var self = {};
// message == DataMessage or ContentMessage proto // message == DataMessage or ContentMessage proto
function sendMessageToDevices(timestamp, number, deviceObjectList, message) { function sendMessageToDevices(timestamp, number, deviceObjectList, message) {
var relay = deviceObjectList[0].relay; var relay = deviceObjectList[0].relay;
for (var i=1; i < deviceObjectList.length; ++i) { for (var i=1; i < deviceObjectList.length; ++i) {
if (deviceObjectList[i].relay !== relay) { if (deviceObjectList[i].relay !== relay) {
throw new Error("Mismatched relays for number " + number); throw new Error("Mismatched relays for number " + number);
}
} }
} return Promise.all(deviceObjectList.map(function(device) {
return Promise.all(deviceObjectList.map(function(device) { return textsecure.protocol_wrapper.encryptMessageFor(device, message).then(function(encryptedMsg) {
return textsecure.protocol_wrapper.encryptMessageFor(device, message).then(function(encryptedMsg) { return textsecure.protocol_wrapper.getRegistrationId(device.encodedNumber).then(function(registrationId) {
return textsecure.protocol_wrapper.getRegistrationId(device.encodedNumber).then(function(registrationId) { return textsecure.storage.devices.removeTempKeysFromDevice(device.encodedNumber).then(function() {
return textsecure.storage.devices.removeTempKeysFromDevice(device.encodedNumber).then(function() { var json = {
var json = { type: encryptedMsg.type,
type: encryptedMsg.type, destinationDeviceId: textsecure.utils.unencodeNumber(device.encodedNumber)[1],
destinationDeviceId: textsecure.utils.unencodeNumber(device.encodedNumber)[1], destinationRegistrationId: registrationId,
destinationRegistrationId: registrationId, content: encryptedMsg.body,
content: encryptedMsg.body, timestamp: timestamp
timestamp: timestamp };
};
if (device.relay !== undefined) { if (device.relay !== undefined) {
json.relay = device.relay; json.relay = device.relay;
} }
return json; return json;
});
}); });
}); });
})).then(function(jsonData) {
var legacy = (message instanceof textsecure.protobuf.DataMessage);
return TextSecureServer.sendMessages(number, jsonData, legacy);
}); });
})).then(function(jsonData) { }
var legacy = (message instanceof textsecure.protobuf.DataMessage);
return TextSecureServer.sendMessages(number, jsonData, legacy);
});
}
function makeAttachmentPointer(attachment) { function makeAttachmentPointer(attachment) {
var proto = new textsecure.protobuf.AttachmentPointer(); var proto = new textsecure.protobuf.AttachmentPointer();
proto.key = textsecure.crypto.getRandomBytes(64); proto.key = textsecure.crypto.getRandomBytes(64);
var iv = textsecure.crypto.getRandomBytes(16); var iv = textsecure.crypto.getRandomBytes(16);
return textsecure.crypto.encryptAttachment(attachment.data, proto.key, iv).then(function(encryptedBin) { return textsecure.crypto.encryptAttachment(attachment.data, proto.key, iv).then(function(encryptedBin) {
return TextSecureServer.putAttachment(encryptedBin).then(function(id) { return TextSecureServer.putAttachment(encryptedBin).then(function(id) {
proto.id = id; proto.id = id;
proto.contentType = attachment.contentType; proto.contentType = attachment.contentType;
return proto; return proto;
});
});
}
var tryMessageAgain = function(number, encodedMessage, timestamp) {
var proto = textsecure.protobuf.DataMessage.decode(encodedMessage);
return new Promise(function(resolve, reject) {
sendMessageProto(timestamp, [number], proto, function(res) {
if (res.failure.length > 0)
reject(res.failure);
else
resolve();
});
});
};
textsecure.replay.registerFunction(tryMessageAgain, textsecure.replay.Type.SEND_MESSAGE);
var sendMessageProto = function(timestamp, numbers, message, callback) {
var numbersCompleted = 0;
var errors = [];
var successfulNumbers = [];
var numberCompleted = function() {
numbersCompleted++;
if (numbersCompleted >= numbers.length)
callback({success: successfulNumbers, failure: errors});
};
var registerError = function(number, reason, error) {
if (!error) {
error = new Error(reason);
}
error.number = number;
error.reason = reason;
errors[errors.length] = error;
numberCompleted();
};
var reloadDevicesAndSend = function(number, recurse) {
return function() {
return textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devicesForNumber) {
if (devicesForNumber.length == 0)
return registerError(number, "Got empty device list when loading device keys", null);
doSendMessage(number, devicesForNumber, recurse);
}); });
} });
}; }
function getKeysForNumber(number, updateDevices) { var tryMessageAgain = function(number, encodedMessage, timestamp) {
var handleResult = function(response) { var proto = textsecure.protobuf.DataMessage.decode(encodedMessage);
return Promise.all(response.devices.map(function(device) { return new Promise(function(resolve, reject) {
if (updateDevices === undefined || updateDevices.indexOf(device.deviceId) > -1) sendMessageProto(timestamp, [number], proto, function(res) {
return textsecure.storage.devices.saveKeysToDeviceObject({ if (res.failure.length > 0)
encodedNumber: number + "." + device.deviceId, reject(res.failure);
identityKey: response.identityKey, else
preKey: device.preKey.publicKey, resolve();
preKeyId: device.preKey.keyId, });
signedKey: device.signedPreKey.publicKey, });
signedKeyId: device.signedPreKey.keyId, };
signedKeySignature: device.signedPreKey.signature, textsecure.replay.registerFunction(tryMessageAgain, textsecure.replay.Type.SEND_MESSAGE);
registrationId: device.registrationId
}).catch(function(error) { var sendMessageProto = function(timestamp, numbers, message, callback) {
if (error.message === "Identity key changed") { var numbersCompleted = 0;
error = new textsecure.OutgoingIdentityKeyError(number, message.toArrayBuffer(), timestamp, error.identityKey); var errors = [];
registerError(number, "Identity key changed", error); var successfulNumbers = [];
}
throw error; var numberCompleted = function() {
}); numbersCompleted++;
})); if (numbersCompleted >= numbers.length)
callback({success: successfulNumbers, failure: errors});
}; };
if (updateDevices === undefined) { var registerError = function(number, reason, error) {
return TextSecureServer.getKeysForNumber(number).then(handleResult); if (!error) {
} else { error = new Error(reason);
var promises = []; }
for (var i in updateDevices) error.number = number;
promises[promises.length] = TextSecureServer.getKeysForNumber(number, updateDevices[i]).then(handleResult); error.reason = reason;
errors[errors.length] = error;
numberCompleted();
};
return Promise.all(promises); var reloadDevicesAndSend = function(number, recurse) {
return function() {
return textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devicesForNumber) {
if (devicesForNumber.length == 0)
return registerError(number, "Got empty device list when loading device keys", null);
doSendMessage(number, devicesForNumber, recurse);
});
}
};
function getKeysForNumber(number, updateDevices) {
var handleResult = function(response) {
return Promise.all(response.devices.map(function(device) {
if (updateDevices === undefined || updateDevices.indexOf(device.deviceId) > -1)
return textsecure.storage.devices.saveKeysToDeviceObject({
encodedNumber: number + "." + device.deviceId,
identityKey: response.identityKey,
preKey: device.preKey.publicKey,
preKeyId: device.preKey.keyId,
signedKey: device.signedPreKey.publicKey,
signedKeyId: device.signedPreKey.keyId,
signedKeySignature: device.signedPreKey.signature,
registrationId: device.registrationId
}).catch(function(error) {
if (error.message === "Identity key changed") {
error = new textsecure.OutgoingIdentityKeyError(number, message.toArrayBuffer(), timestamp, error.identityKey);
registerError(number, "Identity key changed", error);
}
throw error;
});
}));
};
if (updateDevices === undefined) {
return TextSecureServer.getKeysForNumber(number).then(handleResult);
} else {
var promises = [];
for (var i in updateDevices)
promises[promises.length] = TextSecureServer.getKeysForNumber(number, updateDevices[i]).then(handleResult);
return Promise.all(promises);
}
}
var doSendMessage = function(number, devicesForNumber, recurse) {
return sendMessageToDevices(timestamp, number, devicesForNumber, message).then(function(result) {
successfulNumbers[successfulNumbers.length] = number;
numberCompleted();
}).catch(function(error) {
if (error instanceof Error && error.name == "HTTPError" && (error.code == 410 || error.code == 409)) {
if (!recurse)
return registerError(number, "Hit retry limit attempting to reload device list", error);
var p;
if (error.code == 409) {
p = textsecure.storage.devices.removeDeviceIdsForNumber(number, error.response.extraDevices);
} else {
p = Promise.all(error.response.staleDevices.map(function(deviceId) {
return textsecure.protocol_wrapper.closeOpenSessionForDevice(number + '.' + deviceId);
}));
}
p.then(function() {
var resetDevices = ((error.code == 410) ? error.response.staleDevices : error.response.missingDevices);
getKeysForNumber(number, resetDevices)
.then(reloadDevicesAndSend(number, (error.code == 409)))
.catch(function(error) {
registerError(number, "Failed to reload device keys", error);
});
});
} else {
registerError(number, "Failed to create or send message", error);
}
});
};
numbers.forEach(function(number) {
textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devicesForNumber) {
return Promise.all(devicesForNumber.map(function(device) {
return textsecure.protocol_wrapper.hasOpenSession(device.encodedNumber).then(function(result) {
if (!result)
return getKeysForNumber(number, [parseInt(textsecure.utils.unencodeNumber(device.encodedNumber)[1])]);
});
})).then(function() {
return textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devicesForNumber) {
if (devicesForNumber.length == 0) {
getKeysForNumber(number, [1])
.then(reloadDevicesAndSend(number, true))
.catch(function(error) {
registerError(number, "Failed to retreive new device keys for number " + number, error);
});
} else
doSendMessage(number, devicesForNumber, true);
});
});
});
});
}
var sendIndividualProto = function(number, proto, timestamp) {
return new Promise(function(resolve, reject) {
sendMessageProto(timestamp, [number], proto, function(res) {
if (res.failure.length > 0)
reject(res.failure);
else
resolve();
});
});
}
var sendSyncMessage = function(message, timestamp, destination) {
var myNumber = textsecure.storage.user.getNumber();
var myDevice = textsecure.storage.user.getDeviceId();
if (myDevice != 1) {
var sentMessage = new textsecure.protobuf.SyncMessage.Sent();
sentMessage.timestamp = timestamp;
sentMessage.message = message;
if (destination) {
sentMessage.destination = destination;
}
var syncMessage = new textsecure.protobuf.SyncMessage();
syncMessage.sent = sentMessage;
var contentMessage = new textsecure.protobuf.Content();
contentMessage.syncMessage = syncMessage;
return sendIndividualProto(myNumber, contentMessage, Date.now());
} }
} }
var doSendMessage = function(number, devicesForNumber, recurse) { self.sendRequestGroupSyncMessage = function() {
return sendMessageToDevices(timestamp, number, devicesForNumber, message).then(function(result) { var myNumber = textsecure.storage.user.getNumber();
successfulNumbers[successfulNumbers.length] = number; var myDevice = textsecure.storage.user.getDeviceId();
numberCompleted(); if (myDevice != 1) {
}).catch(function(error) { var request = new textsecure.protobuf.SyncMessage.Request();
if (error instanceof Error && error.name == "HTTPError" && (error.code == 410 || error.code == 409)) { request.type = textsecure.protobuf.SyncMessage.Request.Type.GROUPS;
if (!recurse) var syncMessage = new textsecure.protobuf.SyncMessage();
return registerError(number, "Hit retry limit attempting to reload device list", error); syncMessage.request = request;
var contentMessage = new textsecure.protobuf.Content();
contentMessage.syncMessage = syncMessage;
var p; return sendIndividualProto(myNumber, contentMessage, Date.now());
if (error.code == 409) { }
p = textsecure.storage.devices.removeDeviceIdsForNumber(number, error.response.extraDevices); };
} else { self.sendRequestContactSyncMessage = function() {
p = Promise.all(error.response.staleDevices.map(function(deviceId) { var myNumber = textsecure.storage.user.getNumber();
return textsecure.protocol_wrapper.closeOpenSessionForDevice(number + '.' + deviceId); var myDevice = textsecure.storage.user.getDeviceId();
})); if (myDevice != 1) {
} var request = new textsecure.protobuf.SyncMessage.Request();
request.type = textsecure.protobuf.SyncMessage.Request.Type.CONTACTS;
var syncMessage = new textsecure.protobuf.SyncMessage();
syncMessage.request = request;
var contentMessage = new textsecure.protobuf.Content();
contentMessage.syncMessage = syncMessage;
p.then(function() { return sendIndividualProto(myNumber, contentMessage, Date.now());
var resetDevices = ((error.code == 410) ? error.response.staleDevices : error.response.missingDevices); }
getKeysForNumber(number, resetDevices)
.then(reloadDevicesAndSend(number, (error.code == 409)))
.catch(function(error) {
registerError(number, "Failed to reload device keys", error);
});
});
} else {
registerError(number, "Failed to create or send message", error);
}
});
}; };
numbers.forEach(function(number) { var sendGroupProto = function(numbers, proto, timestamp) {
textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devicesForNumber) { timestamp = timestamp || Date.now();
return Promise.all(devicesForNumber.map(function(device) { var me = textsecure.storage.user.getNumber();
return textsecure.protocol_wrapper.hasOpenSession(device.encodedNumber).then(function(result) { numbers = numbers.filter(function(number) { return number != me; });
if (!result)
return getKeysForNumber(number, [parseInt(textsecure.utils.unencodeNumber(device.encodedNumber)[1])]); return new Promise(function(resolve, reject) {
}); sendMessageProto(timestamp, numbers, proto, function(res) {
})).then(function() { if (res.failure.length > 0)
return textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devicesForNumber) { reject(res.failure);
if (devicesForNumber.length == 0) { else
getKeysForNumber(number, [1]) resolve();
.then(reloadDevicesAndSend(number, true))
.catch(function(error) {
registerError(number, "Failed to retreive new device keys for number " + number, error);
});
} else
doSendMessage(number, devicesForNumber, true);
});
}); });
}).then(function() {
return sendSyncMessage(proto, timestamp);
}); });
});
}
var sendIndividualProto = function(number, proto, timestamp) {
return new Promise(function(resolve, reject) {
sendMessageProto(timestamp, [number], proto, function(res) {
if (res.failure.length > 0)
reject(res.failure);
else
resolve();
});
});
}
var sendSyncMessage = function(message, timestamp, destination) {
var myNumber = textsecure.storage.user.getNumber();
var myDevice = textsecure.storage.user.getDeviceId();
if (myDevice != 1) {
var sentMessage = new textsecure.protobuf.SyncMessage.Sent();
sentMessage.timestamp = timestamp;
sentMessage.message = message;
if (destination) {
sentMessage.destination = destination;
}
var syncMessage = new textsecure.protobuf.SyncMessage();
syncMessage.sent = sentMessage;
var contentMessage = new textsecure.protobuf.Content();
contentMessage.syncMessage = syncMessage;
return sendIndividualProto(myNumber, contentMessage, Date.now());
} }
}
self.sendRequestGroupSyncMessage = function() { self.sendMessageToNumber = function(number, messageText, attachments, timestamp) {
var myNumber = textsecure.storage.user.getNumber(); var proto = new textsecure.protobuf.DataMessage();
var myDevice = textsecure.storage.user.getDeviceId(); proto.body = messageText;
if (myDevice != 1) {
var request = new textsecure.protobuf.SyncMessage.Request();
request.type = textsecure.protobuf.SyncMessage.Request.Type.GROUPS;
var syncMessage = new textsecure.protobuf.SyncMessage();
syncMessage.request = request;
var contentMessage = new textsecure.protobuf.Content();
contentMessage.syncMessage = syncMessage;
return sendIndividualProto(myNumber, contentMessage, Date.now());
}
};
self.sendRequestContactSyncMessage = function() {
var myNumber = textsecure.storage.user.getNumber();
var myDevice = textsecure.storage.user.getDeviceId();
if (myDevice != 1) {
var request = new textsecure.protobuf.SyncMessage.Request();
request.type = textsecure.protobuf.SyncMessage.Request.Type.CONTACTS;
var syncMessage = new textsecure.protobuf.SyncMessage();
syncMessage.request = request;
var contentMessage = new textsecure.protobuf.Content();
contentMessage.syncMessage = syncMessage;
return sendIndividualProto(myNumber, contentMessage, Date.now());
}
};
var sendGroupProto = function(numbers, proto, timestamp) {
timestamp = timestamp || Date.now();
var me = textsecure.storage.user.getNumber();
numbers = numbers.filter(function(number) { return number != me; });
return new Promise(function(resolve, reject) {
sendMessageProto(timestamp, numbers, proto, function(res) {
if (res.failure.length > 0)
reject(res.failure);
else
resolve();
});
}).then(function() {
return sendSyncMessage(proto, timestamp);
});
}
self.sendMessageToNumber = function(number, messageText, attachments, timestamp) {
var proto = new textsecure.protobuf.DataMessage();
proto.body = messageText;
var promises = [];
for (var i in attachments)
promises.push(makeAttachmentPointer(attachments[i]));
return Promise.all(promises).then(function(attachmentsArray) {
proto.attachments = attachmentsArray;
return sendIndividualProto(number, proto, timestamp).then(function() {
return sendSyncMessage(proto, timestamp, number);
});
});
}
self.closeSession = function(number) {
var proto = new textsecure.protobuf.DataMessage();
proto.body = "TERMINATE";
proto.flags = textsecure.protobuf.DataMessage.Flags.END_SESSION;
return sendIndividualProto(number, proto, Date.now()).then(function(res) {
return textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devices) {
return Promise.all(devices.map(function(device) {
return textsecure.protocol_wrapper.closeOpenSessionForDevice(device.encodedNumber);
})).then(function() {
return res;
});
});
});
}
self.sendMessageToGroup = function(groupId, messageText, attachments, timestamp) {
var proto = new textsecure.protobuf.DataMessage();
proto.body = messageText;
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.DELIVER;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
var promises = []; var promises = [];
for (var i in attachments) for (var i in attachments)
promises.push(makeAttachmentPointer(attachments[i])); promises.push(makeAttachmentPointer(attachments[i]));
return Promise.all(promises).then(function(attachmentsArray) { return Promise.all(promises).then(function(attachmentsArray) {
proto.attachments = attachmentsArray; proto.attachments = attachmentsArray;
return sendGroupProto(numbers, proto, timestamp); return sendIndividualProto(number, proto, timestamp).then(function() {
return sendSyncMessage(proto, timestamp, number);
});
}); });
}); }
}
self.createGroup = function(numbers, name, avatar) { self.closeSession = function(number) {
var proto = new textsecure.protobuf.DataMessage(); var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext(); proto.body = "TERMINATE";
proto.flags = textsecure.protobuf.DataMessage.Flags.END_SESSION;
return sendIndividualProto(number, proto, Date.now()).then(function(res) {
return textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devices) {
return Promise.all(devices.map(function(device) {
return textsecure.protocol_wrapper.closeOpenSessionForDevice(device.encodedNumber);
})).then(function() {
return res;
});
});
});
}
return textsecure.storage.groups.createNewGroup(numbers).then(function(group) { self.sendMessageToGroup = function(groupId, messageText, attachments, timestamp) {
proto.group.id = toArrayBuffer(group.id); var proto = new textsecure.protobuf.DataMessage();
var numbers = group.numbers; proto.body = messageText;
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.DELIVER;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
var promises = [];
for (var i in attachments)
promises.push(makeAttachmentPointer(attachments[i]));
return Promise.all(promises).then(function(attachmentsArray) {
proto.attachments = attachmentsArray;
return sendGroupProto(numbers, proto, timestamp);
});
});
}
self.createGroup = function(numbers, name, avatar) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
return textsecure.storage.groups.createNewGroup(numbers).then(function(group) {
proto.group.id = toArrayBuffer(group.id);
var numbers = group.numbers;
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
proto.group.members = numbers;
proto.group.name = name;
if (avatar !== undefined) {
return makeAttachmentPointer(avatar).then(function(attachment) {
proto.group.avatar = attachment;
return sendGroupProto(numbers, proto).then(function() {
return proto.group.id;
});
});
} else {
return sendGroupProto(numbers, proto).then(function() {
return proto.group.id;
});
}
});
}
self.updateGroup = function(groupId, name, avatar, numbers) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE; proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
proto.group.members = numbers;
proto.group.name = name; proto.group.name = name;
if (avatar !== undefined) { return textsecure.storage.groups.addNumbers(groupId, numbers).then(function(numbers) {
return makeAttachmentPointer(avatar).then(function(attachment) { if (numbers === undefined) {
proto.group.avatar = attachment; return Promise.reject(new Error("Unknown Group"));
}
proto.group.members = numbers;
if (avatar !== undefined && avatar !== null) {
return makeAttachmentPointer(avatar).then(function(attachment) {
proto.group.avatar = attachment;
return sendGroupProto(numbers, proto).then(function() {
return proto.group.id;
});
});
} else {
return sendGroupProto(numbers, proto).then(function() { return sendGroupProto(numbers, proto).then(function() {
return proto.group.id; return proto.group.id;
}); });
}); }
} else { });
return sendGroupProto(numbers, proto).then(function() { }
return proto.group.id;
});
}
});
}
self.updateGroup = function(groupId, name, avatar, numbers) { self.addNumberToGroup = function(groupId, number) {
var proto = new textsecure.protobuf.DataMessage(); var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext(); proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
proto.group.id = toArrayBuffer(groupId); return textsecure.storage.groups.addNumbers(groupId, [number]).then(function(numbers) {
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE; if (numbers === undefined)
proto.group.name = name; return Promise.reject(new Error("Unknown Group"));
proto.group.members = numbers;
return textsecure.storage.groups.addNumbers(groupId, numbers).then(function(numbers) { return sendGroupProto(numbers, proto);
if (numbers === undefined) { });
return Promise.reject(new Error("Unknown Group")); }
}
proto.group.members = numbers; self.setGroupName = function(groupId, name) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
proto.group.name = name;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
proto.group.members = numbers;
return sendGroupProto(numbers, proto);
});
}
self.setGroupAvatar = function(groupId, avatar) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
proto.group.members = numbers;
if (avatar !== undefined && avatar !== null) {
return makeAttachmentPointer(avatar).then(function(attachment) { return makeAttachmentPointer(avatar).then(function(attachment) {
proto.group.avatar = attachment; proto.group.avatar = attachment;
return sendGroupProto(numbers, proto).then(function() { return sendGroupProto(numbers, proto);
return proto.group.id;
});
}); });
} else { });
return sendGroupProto(numbers, proto).then(function() { }
return proto.group.id;
self.leaveGroup = function(groupId) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.QUIT;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
return textsecure.storage.groups.deleteGroup(groupId).then(function() {
return sendGroupProto(numbers, proto);
}); });
}
});
}
self.addNumberToGroup = function(groupId, number) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
return textsecure.storage.groups.addNumbers(groupId, [number]).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
proto.group.members = numbers;
return sendGroupProto(numbers, proto);
});
}
self.setGroupName = function(groupId, name) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
proto.group.name = name;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
proto.group.members = numbers;
return sendGroupProto(numbers, proto);
});
}
self.setGroupAvatar = function(groupId, avatar) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
proto.group.members = numbers;
return makeAttachmentPointer(avatar).then(function(attachment) {
proto.group.avatar = attachment;
return sendGroupProto(numbers, proto);
}); });
}); }
}
self.leaveGroup = function(groupId) { return self;
var proto = new textsecure.protobuf.DataMessage(); })(server);
proto.group = new textsecure.protobuf.GroupContext(); };
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.QUIT;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
return textsecure.storage.groups.deleteGroup(groupId).then(function() {
return sendGroupProto(numbers, proto);
});
});
}
return self;
}();
/* /*
* vim: ts=4:sw=4:expandtab * vim: ts=4:sw=4:expandtab

770
libtextsecure/sendmessage.js
View file

@ -2,438 +2,442 @@
* vim: ts=4:sw=4:expandtab * vim: ts=4:sw=4:expandtab
*/ */
// sendMessage(numbers = [], message = PushMessageContentProto, callback(success/failure map)) // sendMessage(numbers = [], message = PushMessageContentProto, callback(success/failure map))
window.textsecure.messaging = function() { window.textsecure.MessageSender = function(url, username, password) {
'use strict'; 'use strict';
var server = new TextSecureServer(url, username, password);
return (function(TextSecureServer) {
'use strict';
var self = {}; var self = {};
// message == DataMessage or ContentMessage proto // message == DataMessage or ContentMessage proto
function sendMessageToDevices(timestamp, number, deviceObjectList, message) { function sendMessageToDevices(timestamp, number, deviceObjectList, message) {
var relay = deviceObjectList[0].relay; var relay = deviceObjectList[0].relay;
for (var i=1; i < deviceObjectList.length; ++i) { for (var i=1; i < deviceObjectList.length; ++i) {
if (deviceObjectList[i].relay !== relay) { if (deviceObjectList[i].relay !== relay) {
throw new Error("Mismatched relays for number " + number); throw new Error("Mismatched relays for number " + number);
}
} }
} return Promise.all(deviceObjectList.map(function(device) {
return Promise.all(deviceObjectList.map(function(device) { return textsecure.protocol_wrapper.encryptMessageFor(device, message).then(function(encryptedMsg) {
return textsecure.protocol_wrapper.encryptMessageFor(device, message).then(function(encryptedMsg) { return textsecure.protocol_wrapper.getRegistrationId(device.encodedNumber).then(function(registrationId) {
return textsecure.protocol_wrapper.getRegistrationId(device.encodedNumber).then(function(registrationId) { return textsecure.storage.devices.removeTempKeysFromDevice(device.encodedNumber).then(function() {
return textsecure.storage.devices.removeTempKeysFromDevice(device.encodedNumber).then(function() { var json = {
var json = { type: encryptedMsg.type,
type: encryptedMsg.type, destinationDeviceId: textsecure.utils.unencodeNumber(device.encodedNumber)[1],
destinationDeviceId: textsecure.utils.unencodeNumber(device.encodedNumber)[1], destinationRegistrationId: registrationId,
destinationRegistrationId: registrationId, content: encryptedMsg.body,
content: encryptedMsg.body, timestamp: timestamp
timestamp: timestamp };
};
if (device.relay !== undefined) { if (device.relay !== undefined) {
json.relay = device.relay; json.relay = device.relay;
} }
return json; return json;
});
}); });
}); });
})).then(function(jsonData) {
var legacy = (message instanceof textsecure.protobuf.DataMessage);
return TextSecureServer.sendMessages(number, jsonData, legacy);
}); });
})).then(function(jsonData) { }
var legacy = (message instanceof textsecure.protobuf.DataMessage);
return TextSecureServer.sendMessages(number, jsonData, legacy);
});
}
function makeAttachmentPointer(attachment) { function makeAttachmentPointer(attachment) {
var proto = new textsecure.protobuf.AttachmentPointer(); var proto = new textsecure.protobuf.AttachmentPointer();
proto.key = textsecure.crypto.getRandomBytes(64); proto.key = textsecure.crypto.getRandomBytes(64);
var iv = textsecure.crypto.getRandomBytes(16); var iv = textsecure.crypto.getRandomBytes(16);
return textsecure.crypto.encryptAttachment(attachment.data, proto.key, iv).then(function(encryptedBin) { return textsecure.crypto.encryptAttachment(attachment.data, proto.key, iv).then(function(encryptedBin) {
return TextSecureServer.putAttachment(encryptedBin).then(function(id) { return TextSecureServer.putAttachment(encryptedBin).then(function(id) {
proto.id = id; proto.id = id;
proto.contentType = attachment.contentType; proto.contentType = attachment.contentType;
return proto; return proto;
});
});
}
var tryMessageAgain = function(number, encodedMessage, timestamp) {
var proto = textsecure.protobuf.DataMessage.decode(encodedMessage);
return new Promise(function(resolve, reject) {
sendMessageProto(timestamp, [number], proto, function(res) {
if (res.failure.length > 0)
reject(res.failure);
else
resolve();
});
});
};
textsecure.replay.registerFunction(tryMessageAgain, textsecure.replay.Type.SEND_MESSAGE);
var sendMessageProto = function(timestamp, numbers, message, callback) {
var numbersCompleted = 0;
var errors = [];
var successfulNumbers = [];
var numberCompleted = function() {
numbersCompleted++;
if (numbersCompleted >= numbers.length)
callback({success: successfulNumbers, failure: errors});
};
var registerError = function(number, reason, error) {
if (!error) {
error = new Error(reason);
}
error.number = number;
error.reason = reason;
errors[errors.length] = error;
numberCompleted();
};
var reloadDevicesAndSend = function(number, recurse) {
return function() {
return textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devicesForNumber) {
if (devicesForNumber.length == 0)
return registerError(number, "Got empty device list when loading device keys", null);
doSendMessage(number, devicesForNumber, recurse);
}); });
} });
}; }
function getKeysForNumber(number, updateDevices) { var tryMessageAgain = function(number, encodedMessage, timestamp) {
var handleResult = function(response) { var proto = textsecure.protobuf.DataMessage.decode(encodedMessage);
return Promise.all(response.devices.map(function(device) { return new Promise(function(resolve, reject) {
if (updateDevices === undefined || updateDevices.indexOf(device.deviceId) > -1) sendMessageProto(timestamp, [number], proto, function(res) {
return textsecure.storage.devices.saveKeysToDeviceObject({ if (res.failure.length > 0)
encodedNumber: number + "." + device.deviceId, reject(res.failure);
identityKey: response.identityKey, else
preKey: device.preKey.publicKey, resolve();
preKeyId: device.preKey.keyId, });
signedKey: device.signedPreKey.publicKey, });
signedKeyId: device.signedPreKey.keyId, };
signedKeySignature: device.signedPreKey.signature, textsecure.replay.registerFunction(tryMessageAgain, textsecure.replay.Type.SEND_MESSAGE);
registrationId: device.registrationId
}).catch(function(error) { var sendMessageProto = function(timestamp, numbers, message, callback) {
if (error.message === "Identity key changed") { var numbersCompleted = 0;
error = new textsecure.OutgoingIdentityKeyError(number, message.toArrayBuffer(), timestamp, error.identityKey); var errors = [];
registerError(number, "Identity key changed", error); var successfulNumbers = [];
}
throw error; var numberCompleted = function() {
}); numbersCompleted++;
})); if (numbersCompleted >= numbers.length)
callback({success: successfulNumbers, failure: errors});
}; };
if (updateDevices === undefined) { var registerError = function(number, reason, error) {
return TextSecureServer.getKeysForNumber(number).then(handleResult); if (!error) {
} else { error = new Error(reason);
var promises = []; }
for (var i in updateDevices) error.number = number;
promises[promises.length] = TextSecureServer.getKeysForNumber(number, updateDevices[i]).then(handleResult); error.reason = reason;
errors[errors.length] = error;
numberCompleted();
};
return Promise.all(promises); var reloadDevicesAndSend = function(number, recurse) {
return function() {
return textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devicesForNumber) {
if (devicesForNumber.length == 0)
return registerError(number, "Got empty device list when loading device keys", null);
doSendMessage(number, devicesForNumber, recurse);
});
}
};
function getKeysForNumber(number, updateDevices) {
var handleResult = function(response) {
return Promise.all(response.devices.map(function(device) {
if (updateDevices === undefined || updateDevices.indexOf(device.deviceId) > -1)
return textsecure.storage.devices.saveKeysToDeviceObject({
encodedNumber: number + "." + device.deviceId,
identityKey: response.identityKey,
preKey: device.preKey.publicKey,
preKeyId: device.preKey.keyId,
signedKey: device.signedPreKey.publicKey,
signedKeyId: device.signedPreKey.keyId,
signedKeySignature: device.signedPreKey.signature,
registrationId: device.registrationId
}).catch(function(error) {
if (error.message === "Identity key changed") {
error = new textsecure.OutgoingIdentityKeyError(number, message.toArrayBuffer(), timestamp, error.identityKey);
registerError(number, "Identity key changed", error);
}
throw error;
});
}));
};
if (updateDevices === undefined) {
return TextSecureServer.getKeysForNumber(number).then(handleResult);
} else {
var promises = [];
for (var i in updateDevices)
promises[promises.length] = TextSecureServer.getKeysForNumber(number, updateDevices[i]).then(handleResult);
return Promise.all(promises);
}
}
var doSendMessage = function(number, devicesForNumber, recurse) {
return sendMessageToDevices(timestamp, number, devicesForNumber, message).then(function(result) {
successfulNumbers[successfulNumbers.length] = number;
numberCompleted();
}).catch(function(error) {
if (error instanceof Error && error.name == "HTTPError" && (error.code == 410 || error.code == 409)) {
if (!recurse)
return registerError(number, "Hit retry limit attempting to reload device list", error);
var p;
if (error.code == 409) {
p = textsecure.storage.devices.removeDeviceIdsForNumber(number, error.response.extraDevices);
} else {
p = Promise.all(error.response.staleDevices.map(function(deviceId) {
return textsecure.protocol_wrapper.closeOpenSessionForDevice(number + '.' + deviceId);
}));
}
p.then(function() {
var resetDevices = ((error.code == 410) ? error.response.staleDevices : error.response.missingDevices);
getKeysForNumber(number, resetDevices)
.then(reloadDevicesAndSend(number, (error.code == 409)))
.catch(function(error) {
registerError(number, "Failed to reload device keys", error);
});
});
} else {
registerError(number, "Failed to create or send message", error);
}
});
};
numbers.forEach(function(number) {
textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devicesForNumber) {
return Promise.all(devicesForNumber.map(function(device) {
return textsecure.protocol_wrapper.hasOpenSession(device.encodedNumber).then(function(result) {
if (!result)
return getKeysForNumber(number, [parseInt(textsecure.utils.unencodeNumber(device.encodedNumber)[1])]);
});
})).then(function() {
return textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devicesForNumber) {
if (devicesForNumber.length == 0) {
getKeysForNumber(number, [1])
.then(reloadDevicesAndSend(number, true))
.catch(function(error) {
registerError(number, "Failed to retreive new device keys for number " + number, error);
});
} else
doSendMessage(number, devicesForNumber, true);
});
});
});
});
}
var sendIndividualProto = function(number, proto, timestamp) {
return new Promise(function(resolve, reject) {
sendMessageProto(timestamp, [number], proto, function(res) {
if (res.failure.length > 0)
reject(res.failure);
else
resolve();
});
});
}
var sendSyncMessage = function(message, timestamp, destination) {
var myNumber = textsecure.storage.user.getNumber();
var myDevice = textsecure.storage.user.getDeviceId();
if (myDevice != 1) {
var sentMessage = new textsecure.protobuf.SyncMessage.Sent();
sentMessage.timestamp = timestamp;
sentMessage.message = message;
if (destination) {
sentMessage.destination = destination;
}
var syncMessage = new textsecure.protobuf.SyncMessage();
syncMessage.sent = sentMessage;
var contentMessage = new textsecure.protobuf.Content();
contentMessage.syncMessage = syncMessage;
return sendIndividualProto(myNumber, contentMessage, Date.now());
} }
} }
var doSendMessage = function(number, devicesForNumber, recurse) { self.sendRequestGroupSyncMessage = function() {
return sendMessageToDevices(timestamp, number, devicesForNumber, message).then(function(result) { var myNumber = textsecure.storage.user.getNumber();
successfulNumbers[successfulNumbers.length] = number; var myDevice = textsecure.storage.user.getDeviceId();
numberCompleted(); if (myDevice != 1) {
}).catch(function(error) { var request = new textsecure.protobuf.SyncMessage.Request();
if (error instanceof Error && error.name == "HTTPError" && (error.code == 410 || error.code == 409)) { request.type = textsecure.protobuf.SyncMessage.Request.Type.GROUPS;
if (!recurse) var syncMessage = new textsecure.protobuf.SyncMessage();
return registerError(number, "Hit retry limit attempting to reload device list", error); syncMessage.request = request;
var contentMessage = new textsecure.protobuf.Content();
contentMessage.syncMessage = syncMessage;
var p; return sendIndividualProto(myNumber, contentMessage, Date.now());
if (error.code == 409) { }
p = textsecure.storage.devices.removeDeviceIdsForNumber(number, error.response.extraDevices); };
} else { self.sendRequestContactSyncMessage = function() {
p = Promise.all(error.response.staleDevices.map(function(deviceId) { var myNumber = textsecure.storage.user.getNumber();
return textsecure.protocol_wrapper.closeOpenSessionForDevice(number + '.' + deviceId); var myDevice = textsecure.storage.user.getDeviceId();
})); if (myDevice != 1) {
} var request = new textsecure.protobuf.SyncMessage.Request();
request.type = textsecure.protobuf.SyncMessage.Request.Type.CONTACTS;
var syncMessage = new textsecure.protobuf.SyncMessage();
syncMessage.request = request;
var contentMessage = new textsecure.protobuf.Content();
contentMessage.syncMessage = syncMessage;
p.then(function() { return sendIndividualProto(myNumber, contentMessage, Date.now());
var resetDevices = ((error.code == 410) ? error.response.staleDevices : error.response.missingDevices); }
getKeysForNumber(number, resetDevices)
.then(reloadDevicesAndSend(number, (error.code == 409)))
.catch(function(error) {
registerError(number, "Failed to reload device keys", error);
});
});
} else {
registerError(number, "Failed to create or send message", error);
}
});
}; };
numbers.forEach(function(number) { var sendGroupProto = function(numbers, proto, timestamp) {
textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devicesForNumber) { timestamp = timestamp || Date.now();
return Promise.all(devicesForNumber.map(function(device) { var me = textsecure.storage.user.getNumber();
return textsecure.protocol_wrapper.hasOpenSession(device.encodedNumber).then(function(result) { numbers = numbers.filter(function(number) { return number != me; });
if (!result)
return getKeysForNumber(number, [parseInt(textsecure.utils.unencodeNumber(device.encodedNumber)[1])]); return new Promise(function(resolve, reject) {
}); sendMessageProto(timestamp, numbers, proto, function(res) {
})).then(function() { if (res.failure.length > 0)
return textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devicesForNumber) { reject(res.failure);
if (devicesForNumber.length == 0) { else
getKeysForNumber(number, [1]) resolve();
.then(reloadDevicesAndSend(number, true))
.catch(function(error) {
registerError(number, "Failed to retreive new device keys for number " + number, error);
});
} else
doSendMessage(number, devicesForNumber, true);
});
}); });
}).then(function() {
return sendSyncMessage(proto, timestamp);
}); });
});
}
var sendIndividualProto = function(number, proto, timestamp) {
return new Promise(function(resolve, reject) {
sendMessageProto(timestamp, [number], proto, function(res) {
if (res.failure.length > 0)
reject(res.failure);
else
resolve();
});
});
}
var sendSyncMessage = function(message, timestamp, destination) {
var myNumber = textsecure.storage.user.getNumber();
var myDevice = textsecure.storage.user.getDeviceId();
if (myDevice != 1) {
var sentMessage = new textsecure.protobuf.SyncMessage.Sent();
sentMessage.timestamp = timestamp;
sentMessage.message = message;
if (destination) {
sentMessage.destination = destination;
}
var syncMessage = new textsecure.protobuf.SyncMessage();
syncMessage.sent = sentMessage;
var contentMessage = new textsecure.protobuf.Content();
contentMessage.syncMessage = syncMessage;
return sendIndividualProto(myNumber, contentMessage, Date.now());
} }
}
self.sendRequestGroupSyncMessage = function() { self.sendMessageToNumber = function(number, messageText, attachments, timestamp) {
var myNumber = textsecure.storage.user.getNumber(); var proto = new textsecure.protobuf.DataMessage();
var myDevice = textsecure.storage.user.getDeviceId(); proto.body = messageText;
if (myDevice != 1) {
var request = new textsecure.protobuf.SyncMessage.Request();
request.type = textsecure.protobuf.SyncMessage.Request.Type.GROUPS;
var syncMessage = new textsecure.protobuf.SyncMessage();
syncMessage.request = request;
var contentMessage = new textsecure.protobuf.Content();
contentMessage.syncMessage = syncMessage;
return sendIndividualProto(myNumber, contentMessage, Date.now());
}
};
self.sendRequestContactSyncMessage = function() {
var myNumber = textsecure.storage.user.getNumber();
var myDevice = textsecure.storage.user.getDeviceId();
if (myDevice != 1) {
var request = new textsecure.protobuf.SyncMessage.Request();
request.type = textsecure.protobuf.SyncMessage.Request.Type.CONTACTS;
var syncMessage = new textsecure.protobuf.SyncMessage();
syncMessage.request = request;
var contentMessage = new textsecure.protobuf.Content();
contentMessage.syncMessage = syncMessage;
return sendIndividualProto(myNumber, contentMessage, Date.now());
}
};
var sendGroupProto = function(numbers, proto, timestamp) {
timestamp = timestamp || Date.now();
var me = textsecure.storage.user.getNumber();
numbers = numbers.filter(function(number) { return number != me; });
return new Promise(function(resolve, reject) {
sendMessageProto(timestamp, numbers, proto, function(res) {
if (res.failure.length > 0)
reject(res.failure);
else
resolve();
});
}).then(function() {
return sendSyncMessage(proto, timestamp);
});
}
self.sendMessageToNumber = function(number, messageText, attachments, timestamp) {
var proto = new textsecure.protobuf.DataMessage();
proto.body = messageText;
var promises = [];
for (var i in attachments)
promises.push(makeAttachmentPointer(attachments[i]));
return Promise.all(promises).then(function(attachmentsArray) {
proto.attachments = attachmentsArray;
return sendIndividualProto(number, proto, timestamp).then(function() {
return sendSyncMessage(proto, timestamp, number);
});
});
}
self.closeSession = function(number) {
var proto = new textsecure.protobuf.DataMessage();
proto.body = "TERMINATE";
proto.flags = textsecure.protobuf.DataMessage.Flags.END_SESSION;
return sendIndividualProto(number, proto, Date.now()).then(function(res) {
return textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devices) {
return Promise.all(devices.map(function(device) {
return textsecure.protocol_wrapper.closeOpenSessionForDevice(device.encodedNumber);
})).then(function() {
return res;
});
});
});
}
self.sendMessageToGroup = function(groupId, messageText, attachments, timestamp) {
var proto = new textsecure.protobuf.DataMessage();
proto.body = messageText;
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.DELIVER;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
var promises = []; var promises = [];
for (var i in attachments) for (var i in attachments)
promises.push(makeAttachmentPointer(attachments[i])); promises.push(makeAttachmentPointer(attachments[i]));
return Promise.all(promises).then(function(attachmentsArray) { return Promise.all(promises).then(function(attachmentsArray) {
proto.attachments = attachmentsArray; proto.attachments = attachmentsArray;
return sendGroupProto(numbers, proto, timestamp); return sendIndividualProto(number, proto, timestamp).then(function() {
return sendSyncMessage(proto, timestamp, number);
});
}); });
}); }
}
self.createGroup = function(numbers, name, avatar) { self.closeSession = function(number) {
var proto = new textsecure.protobuf.DataMessage(); var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext(); proto.body = "TERMINATE";
proto.flags = textsecure.protobuf.DataMessage.Flags.END_SESSION;
return sendIndividualProto(number, proto, Date.now()).then(function(res) {
return textsecure.storage.devices.getDeviceObjectsForNumber(number).then(function(devices) {
return Promise.all(devices.map(function(device) {
return textsecure.protocol_wrapper.closeOpenSessionForDevice(device.encodedNumber);
})).then(function() {
return res;
});
});
});
}
return textsecure.storage.groups.createNewGroup(numbers).then(function(group) { self.sendMessageToGroup = function(groupId, messageText, attachments, timestamp) {
proto.group.id = toArrayBuffer(group.id); var proto = new textsecure.protobuf.DataMessage();
var numbers = group.numbers; proto.body = messageText;
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.DELIVER;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
var promises = [];
for (var i in attachments)
promises.push(makeAttachmentPointer(attachments[i]));
return Promise.all(promises).then(function(attachmentsArray) {
proto.attachments = attachmentsArray;
return sendGroupProto(numbers, proto, timestamp);
});
});
}
self.createGroup = function(numbers, name, avatar) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
return textsecure.storage.groups.createNewGroup(numbers).then(function(group) {
proto.group.id = toArrayBuffer(group.id);
var numbers = group.numbers;
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
proto.group.members = numbers;
proto.group.name = name;
if (avatar !== undefined) {
return makeAttachmentPointer(avatar).then(function(attachment) {
proto.group.avatar = attachment;
return sendGroupProto(numbers, proto).then(function() {
return proto.group.id;
});
});
} else {
return sendGroupProto(numbers, proto).then(function() {
return proto.group.id;
});
}
});
}
self.updateGroup = function(groupId, name, avatar, numbers) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE; proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
proto.group.members = numbers;
proto.group.name = name; proto.group.name = name;
if (avatar !== undefined) { return textsecure.storage.groups.addNumbers(groupId, numbers).then(function(numbers) {
return makeAttachmentPointer(avatar).then(function(attachment) { if (numbers === undefined) {
proto.group.avatar = attachment; return Promise.reject(new Error("Unknown Group"));
}
proto.group.members = numbers;
if (avatar !== undefined && avatar !== null) {
return makeAttachmentPointer(avatar).then(function(attachment) {
proto.group.avatar = attachment;
return sendGroupProto(numbers, proto).then(function() {
return proto.group.id;
});
});
} else {
return sendGroupProto(numbers, proto).then(function() { return sendGroupProto(numbers, proto).then(function() {
return proto.group.id; return proto.group.id;
}); });
}); }
} else { });
return sendGroupProto(numbers, proto).then(function() { }
return proto.group.id;
});
}
});
}
self.updateGroup = function(groupId, name, avatar, numbers) { self.addNumberToGroup = function(groupId, number) {
var proto = new textsecure.protobuf.DataMessage(); var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext(); proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
proto.group.id = toArrayBuffer(groupId); return textsecure.storage.groups.addNumbers(groupId, [number]).then(function(numbers) {
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE; if (numbers === undefined)
proto.group.name = name; return Promise.reject(new Error("Unknown Group"));
proto.group.members = numbers;
return textsecure.storage.groups.addNumbers(groupId, numbers).then(function(numbers) { return sendGroupProto(numbers, proto);
if (numbers === undefined) { });
return Promise.reject(new Error("Unknown Group")); }
}
proto.group.members = numbers; self.setGroupName = function(groupId, name) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
proto.group.name = name;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
proto.group.members = numbers;
return sendGroupProto(numbers, proto);
});
}
self.setGroupAvatar = function(groupId, avatar) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
proto.group.members = numbers;
if (avatar !== undefined && avatar !== null) {
return makeAttachmentPointer(avatar).then(function(attachment) { return makeAttachmentPointer(avatar).then(function(attachment) {
proto.group.avatar = attachment; proto.group.avatar = attachment;
return sendGroupProto(numbers, proto).then(function() { return sendGroupProto(numbers, proto);
return proto.group.id;
});
}); });
} else { });
return sendGroupProto(numbers, proto).then(function() { }
return proto.group.id;
self.leaveGroup = function(groupId) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.QUIT;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
return textsecure.storage.groups.deleteGroup(groupId).then(function() {
return sendGroupProto(numbers, proto);
}); });
}
});
}
self.addNumberToGroup = function(groupId, number) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
return textsecure.storage.groups.addNumbers(groupId, [number]).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
proto.group.members = numbers;
return sendGroupProto(numbers, proto);
});
}
self.setGroupName = function(groupId, name) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
proto.group.name = name;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
proto.group.members = numbers;
return sendGroupProto(numbers, proto);
});
}
self.setGroupAvatar = function(groupId, avatar) {
var proto = new textsecure.protobuf.DataMessage();
proto.group = new textsecure.protobuf.GroupContext();
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.UPDATE;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
proto.group.members = numbers;
return makeAttachmentPointer(avatar).then(function(attachment) {
proto.group.avatar = attachment;
return sendGroupProto(numbers, proto);
}); });
}); }
}
self.leaveGroup = function(groupId) { return self;
var proto = new textsecure.protobuf.DataMessage(); })(server);
proto.group = new textsecure.protobuf.GroupContext(); };
proto.group.id = toArrayBuffer(groupId);
proto.group.type = textsecure.protobuf.GroupContext.Type.QUIT;
return textsecure.storage.groups.getNumbers(groupId).then(function(numbers) {
if (numbers === undefined)
return Promise.reject(new Error("Unknown Group"));
return textsecure.storage.groups.deleteGroup(groupId).then(function() {
return sendGroupProto(numbers, proto);
});
});
}
return self;
}();