mirrors/vector-im-hydrogen-web
1
0
Fork 0
mirror of https://github.com/vector-im/hydrogen-web.git synced 2024-12-23 19:45:05 +01:00
Code Issues Projects Releases Wiki Activity

Store more events from backfill

Browse Source
This commit is contained in:
Danila Fedorin 2021-09-14 15:40:15 -07:00
parent b2b5690739
commit df273c5e2c
1 changed files with 16 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/matrix/room/timeline/persistence/GapWriter.js
View File

@ -47,28 +47,30 @@ export class GapWriter {
} }
nonOverlappingEvents.push(...remainingEvents.slice(0, duplicateEventIndex)); nonOverlappingEvents.push(...remainingEvents.slice(0, duplicateEventIndex));
if (!expectedOverlappingEventId || duplicateEventId === expectedOverlappingEventId) { if (!expectedOverlappingEventId || duplicateEventId === expectedOverlappingEventId) {
// TODO: check here that the neighbourEvent is at the correct edge of it's fragment // Only link fragment if this is the first overlapping fragment we discover.
// get neighbour fragment to link it up later on // TODO is this sufficient? Might we get "out of order" fragments from events?
const neighbourEvent = await txn.timelineEvents.getByEventId(this._roomId, duplicateEventId); if (!neighbourFragmentEntry) {
if (neighbourEvent.fragmentId === fragmentEntry.fragmentId) { // TODO: check here that the neighbourEvent is at the correct edge of it's fragment
log.log("hit #160, prevent fragment linking to itself", log.level.Warn); // get neighbour fragment to link it up later on
} else { const neighbourEvent = await txn.timelineEvents.getByEventId(this._roomId, duplicateEventId);
const neighbourFragment = await txn.timelineFragments.get(this._roomId, neighbourEvent.fragmentId); const neighbourFragment = await txn.timelineFragments.get(this._roomId, neighbourEvent.fragmentId);
neighbourFragmentEntry = fragmentEntry.createNeighbourEntry(neighbourFragment); neighbourFragmentEntry = fragmentEntry.createNeighbourEntry(neighbourFragment);
} }
// trim overlapping events
remainingEvents = null;
} else {
// we've hit https://github.com/matrix-org/synapse/issues/7164,
// e.g. the event id we found is already in our store but it is not
// the adjacent fragment id. Ignore the event, but keep processing the ones after.
remainingEvents = remainingEvents.slice(duplicateEventIndex + 1);
} }
// If more events remain, or if this wasn't the expected overlapping event,
// we've hit https://github.com/matrix-org/synapse/issues/7164,
// e.g. the event id we found is already in our store but it is not
// the adjacent fragment id. Ignore the event, but keep processing the ones after.
remainingEvents = remainingEvents.slice(duplicateEventIndex + 1);
} else { } else {
nonOverlappingEvents.push(...remainingEvents); nonOverlappingEvents.push(...remainingEvents);
remainingEvents = null; remainingEvents = null;
} }
} }
if (neighbourFragmentEntry?.fragmentId === fragmentEntry.fragmentId) {
log.log("hit #160, prevent fragment linking to itself", log.level.Warn);
neighbourFragmentEntry = null;
}
return {nonOverlappingEvents, neighbourFragmentEntry}; return {nonOverlappingEvents, neighbourFragmentEntry};
} }