8c59862e3d
Fixed the global counting of unread messages. This makes the "unreadCount" variable in storage to stay in sync with the sum of unread messages in each conversation. To achieve this, the controller_view updates the global variable whenever messages are received or read.
76 lines
2.5 KiB
JavaScript
76 lines
2.5 KiB
JavaScript
/*global $, Whisper, Backbone, textsecure, extension*/
|
|
/*
|
|
* vim: ts=4:sw=4:expandtab
|
|
*/
|
|
|
|
// This script should only be included in background.html
|
|
(function () {
|
|
'use strict';
|
|
|
|
window.Whisper = window.Whisper || {};
|
|
|
|
var conversations = new Whisper.ConversationCollection();
|
|
var inboxCollection = new (Backbone.Collection.extend({
|
|
initialize: function() {
|
|
this.on('change:active_at', this.sort);
|
|
this.on('change:unreadCount', this.updateUnreadCount);
|
|
|
|
this.listenTo(conversations, 'add change:active_at', this.addActive);
|
|
},
|
|
comparator: function(model) {
|
|
return -model.get('active_at');
|
|
},
|
|
addActive: function(model) {
|
|
if (model.get('active_at')) {
|
|
this.add(model);
|
|
} else {
|
|
this.remove(model);
|
|
}
|
|
},
|
|
updateUnreadCount: function(model, count) {
|
|
var prev = model.previous('unreadCount') || 0;
|
|
var newUnreadCount = storage.get("unreadCount", 0) - (prev - count);
|
|
setUnreadCount(newUnreadCount);
|
|
storage.remove("unreadCount");
|
|
storage.put("unreadCount", newUnreadCount);
|
|
}
|
|
}))();
|
|
|
|
window.getInboxCollection = function() {
|
|
return inboxCollection;
|
|
};
|
|
|
|
window.ConversationController = {
|
|
get: function(id) {
|
|
return conversations.get(id);
|
|
},
|
|
create: function(attrs) {
|
|
if (typeof attrs !== 'object') {
|
|
throw new Error('ConversationController.create requires an object, got', attrs);
|
|
}
|
|
var conversation = conversations.add(attrs, {merge: true});
|
|
return conversation;
|
|
},
|
|
findOrCreatePrivateById: function(id) {
|
|
var conversation = conversations.add({ id: id, type: 'private' });
|
|
return new Promise(function(resolve, reject) {
|
|
conversation.fetch().then(function() {
|
|
resolve(conversation);
|
|
}).fail(function() {
|
|
var saved = conversation.save(); // false or indexedDBRequest
|
|
if (saved) {
|
|
saved.then(function() {
|
|
resolve(conversation);
|
|
}).fail(reject);
|
|
} else {
|
|
reject();
|
|
}
|
|
});
|
|
});
|
|
},
|
|
updateInbox: function() {
|
|
conversations.fetchActive();
|
|
}
|
|
};
|
|
})();
|