Matrix-Mirrors/forked-synapse
1
0
Fork 0
mirror of https://mau.dev/maunium/synapse.git synced 2024-10-01 01:36:05 -04:00
Code Issues Packages Projects Releases Wiki Activity

Prevent EventStreamService from knowing too much about the EventHandlerService by changing the contract to just be a single initialSync response callback. Leave it up the handler to deal with splitting out information from /initialSync.

Browse Source
This commit is contained in:
Kegan Dougal 2014-11-03 09:44:20 +00:00
parent f21960ec9d
commit 5ab9929cbb
2 changed files with 20 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
webclient/components/matrix/event-handler-service.js
View File

@ -613,9 +613,27 @@ function(matrixService, $rootScope, $q, $timeout, mPresence, notificationService
}
},
handleInitialSyncDone: function(initialSyncData) {
handleInitialSyncDone: function(response) {
console.log("# handleInitialSyncDone");
initialSyncDeferred.resolve(initialSyncData);
var rooms = response.data.rooms;
for (var i = 0; i < rooms.length; ++i) {
var room = rooms[i];
this.initRoom(room);
if ("messages" in room) {
this.handleRoomMessages(room.room_id, room.messages, false);
}
if ("state" in room) {
this.handleEvents(room.state, false, true);
}
}
var presence = response.data.presence;
this.handleEvents(presence, false);
initialSyncDeferred.resolve(response);
},
// Returns a promise that resolves when the initialSync request has been processed

19
webclient/components/matrix/event-stream-service.js
View File

@ -109,25 +109,6 @@ angular.module('eventStreamService', [])
// without requiring to make an additional request
matrixService.initialSync(30, false).then(
function(response) {
var rooms = response.data.rooms;
for (var i = 0; i < rooms.length; ++i) {
var room = rooms[i];
eventHandlerService.initRoom(room);
if ("messages" in room) {
eventHandlerService.handleRoomMessages(room.room_id, room.messages, false);
}
if ("state" in room) {
eventHandlerService.handleEvents(room.state, false, true);
}
}
var presence = response.data.presence;
eventHandlerService.handleEvents(presence, false);
// Initial sync is done
eventHandlerService.handleInitialSyncDone(response);
// Start event streaming from that point