a8468dae28
Add a special type of collection just for retrieving group ids, which doesn't incur the overhead of initializing a conversation model along with all its group members.
75 lines
2.7 KiB
JavaScript
75 lines
2.7 KiB
JavaScript
/*
|
|
* vim: ts=4:sw=4:expandtab
|
|
*/
|
|
;(function() {
|
|
'use strict';
|
|
window.Whisper = window.Whisper || {};
|
|
|
|
var GroupCollection = Backbone.Collection.extend({
|
|
database: Whisper.Database,
|
|
storeName: 'conversations',
|
|
model: Backbone.Model,
|
|
fetchGroups: function(number) {
|
|
return new Promise(function(resolve) {
|
|
this.fetch({
|
|
index: {
|
|
name: 'group',
|
|
only: number
|
|
}
|
|
}).always(resolve);
|
|
}.bind(this));
|
|
}
|
|
});
|
|
|
|
Whisper.DeliveryReceipts = new (Backbone.Collection.extend({
|
|
initialize: function() {
|
|
this.on('add', this.onReceipt);
|
|
},
|
|
forMessage: function(conversation, message) {
|
|
var recipients;
|
|
if (conversation.isPrivate()) {
|
|
recipients = [ conversation.id ];
|
|
} else {
|
|
recipients = conversation.get('members') || [];
|
|
}
|
|
var receipts = this.filter(function(receipt) {
|
|
return (receipt.get('timestamp') === message.get('sent_at')) &&
|
|
(recipients.indexOf(receipt.get('source')) > -1);
|
|
});
|
|
this.remove(receipts);
|
|
return receipts;
|
|
},
|
|
onReceipt: function(receipt) {
|
|
var messages = new Whisper.MessageCollection();
|
|
var groups = new GroupCollection();
|
|
Promise.all([
|
|
groups.fetchGroups(receipt.get('source')),
|
|
messages.fetchSentAt(receipt.get('timestamp'))
|
|
]).then(function() {
|
|
var ids = groups.pluck('id');
|
|
ids.push(receipt.get('source'));
|
|
var message = messages.find(function(message) {
|
|
return (!message.isIncoming() &&
|
|
_.contains(ids, message.get('conversationId')));
|
|
});
|
|
if (message) {
|
|
this.remove(receipt);
|
|
var deliveries = message.get('delivered') || 0;
|
|
message.save({
|
|
delivered: deliveries + 1
|
|
}).then(function() {
|
|
// notify frontend listeners
|
|
var conversation = ConversationController.get(
|
|
message.get('conversationId')
|
|
);
|
|
if (conversation) {
|
|
conversation.trigger('newmessage', message);
|
|
}
|
|
});
|
|
// TODO: consider keeping a list of numbers we've
|
|
// successfully delivered to?
|
|
}
|
|
}.bind(this));
|
|
}
|
|
}))();
|
|
})();
|