Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-12-21 20:55:00 -05:00
Code Issues Packages Projects Releases Wiki Activity

Do a smart update of the recents from the events stream rather than hammering initialSync each time

Browse Source
This commit is contained in:
Emmanuel ROHEE 2014-08-28 16:38:00 +02:00
parent 62dfa3c741
commit b09e531159
1 changed files with 21 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
webclient/recents/recents-controller.js
View File

@ -25,13 +25,24 @@ angular.module('RecentsController', ['matrixService', 'eventHandlerService'])
// in order to highlight a specific room in the list // in order to highlight a specific room in the list
$scope.recentsSelectedRoomID; $scope.recentsSelectedRoomID;
// Refresh the list on matrix invitation and message event var listenToEventStream = function() {
$scope.$on(eventHandlerService.MEMBER_EVENT, function(ngEvent, event, isLive) { // Refresh the list on matrix invitation and message event
refresh(); $scope.$on(eventHandlerService.MEMBER_EVENT, function(ngEvent, event, isLive) {
}); var config = matrixService.config();
$scope.$on(eventHandlerService.MSG_EVENT, function(ngEvent, event, isLive) { if (event.state_key === config.user_id && event.content.membership === "invite") {
refresh(); console.log("Invited to room " + event.room_id);
}); // FIXME push membership to top level key to match /im/sync
event.membership = event.content.membership;
// FIXME bodge a nicer name than the room ID for this invite.
event.room_display_name = event.user_id + "'s room";
$scope.rooms[event.room_id] = event;
}
});
$scope.$on(eventHandlerService.MSG_EVENT, function(ngEvent, event, isLive) {
$scope.rooms[event.room_id].lastMsg = event;
});
};
var refresh = function() { var refresh = function() {
// List all rooms joined or been invited to // List all rooms joined or been invited to
@ -56,6 +67,9 @@ angular.module('RecentsController', ['matrixService', 'eventHandlerService'])
for (var i = 0; i < presence.length; ++i) { for (var i = 0; i < presence.length; ++i) {
eventHandlerService.handleEvent(presence[i], false); eventHandlerService.handleEvent(presence[i], false);
} }
// From now, update recents from the stream
listenToEventStream();
}, },
function(error) { function(error) {
$scope.feedback = "Failure: " + error.data; $scope.feedback = "Failure: " + error.data;