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

Only call room-specific gap filling hooks once

Browse source
This commit is contained in:
Danila Fedorin 2021-09-09 11:12:04 -07:00
parent 889f4dd104
commit 5b868a9064
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/matrix/room/Room.js
View file

@ -110,17 +110,18 @@ export class Room extends BaseRoom {
} }
} }
async fetchContext(eventId, log = null) { async _fetchContext(eventId, log = null) {
const response = await this._hsApi.context(this._roomId, eventId, {}, {log}).response(); const response = await this._hsApi.context(this._roomId, eventId, {}, {log}).response();
let contextEvent = null; let contextEvent = null;
await this._fetchEvents(async (txn, gapWriter) => { await this._fetchEvents(async (txn, gapWriter) => {
// Just in case we somehow receive remote echoes during event fetch // Just in case we somehow receive remote echoes during event fetch
const beforeExtra = await this._writeGapFill(response.events_before, txn, log); // Keep events in order just in case.
const afterExtra = await this._writeGapFill(response.events_after, txn, log); const allEvents = response.events_before.slice().reverse();
beforeExtra.push(...afterExtra); allEvents.push(response.event, ...response.events_after);
const extraGapFillChanges = await this._writeGapFill(allEvents, txn, log);
const gapResult = await gapWriter.writeContext(response, txn, log); const gapResult = await gapWriter.writeContext(response, txn, log);
contextEvent = gapResult.contextEvent; contextEvent = gapResult.contextEvent;
return { extraGapFillChanges: beforeExtra, gapResult }; return { extraGapFillChanges, gapResult };
}, log); }, log);
return contextEvent; return contextEvent;
} }