Arsharth/hydrogen-web
1
0
Fork 0
forked from mystiq/hydrogen-web
Code Issues Pull requests Projects Releases Packages Wiki Activity

small changes

Browse source
This commit is contained in:
Bruno Windels 2019-02-06 22:06:47 +00:00
parent d6857a1ede
commit 511e91a699
2 changed files with 11 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/room/persister.js
View file

@ -19,12 +19,6 @@ class RoomPersister {
} }
async persistSync(roomResponse, txn) { async persistSync(roomResponse, txn) {
// persist state
const state = roomResponse.state;
if (state.events) {
const promises = state.events.map((event) => txn.state.setStateEventAt(this._lastSortKey, event));
await Promise.all(promises);
}
let nextKey; let nextKey;
const timeline = roomResponse.timeline; const timeline = roomResponse.timeline;
@ -34,6 +28,7 @@ class RoomPersister {
txn.timeline.appendGap(this._roomId, nextKey, {prev_batch: timeline.prev_batch}); txn.timeline.appendGap(this._roomId, nextKey, {prev_batch: timeline.prev_batch});
} }
nextKey = this._lastSortKey.nextKey(); nextKey = this._lastSortKey.nextKey();
const startOfChunkSortKey = nextKey;
if (timeline.events) { if (timeline.events) {
for(const event of timeline.events) { for(const event of timeline.events) {
@ -43,5 +38,14 @@ class RoomPersister {
} }
// what happens here when the txn fails? // what happens here when the txn fails?
this._lastSortKey = nextKey; this._lastSortKey = nextKey;
// persist state
const state = roomResponse.state;
if (state.events) {
const promises = state.events.map((event) => {
txn.state.setStateEventAt(startOfChunkSortKey, event)
});
await Promise.all(promises);
}
} }
} }

2
src/sync.js
View file

@ -75,7 +75,7 @@ export class Sync {
parseRooms(response.rooms, async (roomId, roomResponse, membership) => { parseRooms(response.rooms, async (roomId, roomResponse, membership) => {
let room = session.getRoom(roomId); let room = session.getRoom(roomId);
if (!room) { if (!room) {
room = session.createRoom(roomId, txn); room = session.createRoom(roomId);
} }
room.applySync(roomResponse, membership, txn); room.applySync(roomResponse, membership, txn);
}); });