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

add param to emitUpdateForEntry

Browse source
This commit is contained in:
RMidhunSuresh 2022-01-13 19:20:37 +05:30
parent 239d16747d
commit 2c4610c132
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/matrix/room/timeline/Timeline.js
View file

@ -141,7 +141,7 @@ export class Timeline {
// redactingEntry might be a PendingEventEntry or an EventEntry, so don't assume pendingEvent // redactingEntry might be a PendingEventEntry or an EventEntry, so don't assume pendingEvent
const relatedTxnId = pee.redactingEntry.pendingEvent?.relatedTxnId; const relatedTxnId = pee.redactingEntry.pendingEvent?.relatedTxnId;
this._findAndUpdateEntryById(relatedTxnId, pee.redactingEntry.relatedEventId, updateOrFalse); this._findAndUpdateEntryById(relatedTxnId, pee.redactingEntry.relatedEventId, updateOrFalse);
pee.redactingEntry.contextForEntries?.forEach(e => this._emitUpdateForEntry(e)); pee.redactingEntry.contextForEntries?.forEach(e => this._emitUpdateForEntry(e, "contextEntry"));
} }
} }
@ -235,7 +235,7 @@ export class Timeline {
this._contextEntriesNotInTimeline.set(entry.id, entry); this._contextEntriesNotInTimeline.set(entry.id, entry);
} }
// Since this entry changed, all dependent entries should be updated // Since this entry changed, all dependent entries should be updated
entry.contextForEntries?.forEach(e => this._emitUpdateForEntry(e)); entry.contextForEntries?.forEach(e => this._emitUpdateForEntry(e, "contextEntry"));
} catch (err) { } catch (err) {
if (err.name === "CompareError") { if (err.name === "CompareError") {
// see FragmentIdComparer, if the replacing entry is on a fragment // see FragmentIdComparer, if the replacing entry is on a fragment
@ -295,17 +295,17 @@ export class Timeline {
if (fetchedEntry) { if (fetchedEntry) {
fetchedEntry.contextForEntries.forEach(e => { fetchedEntry.contextForEntries.forEach(e => {
e.setContextEntry(entry); e.setContextEntry(entry);
this._emitUpdateForEntry(e); this._emitUpdateForEntry(e, "contextEntry");
}); });
this._contextEntriesNotInTimeline.delete(entry.id); this._contextEntriesNotInTimeline.delete(entry.id);
} }
} }
} }
_emitUpdateForEntry(entry) { _emitUpdateForEntry(entry, param) {
const txnId = entry.isPending ? entry.id : null; const txnId = entry.isPending ? entry.id : null;
const eventId = entry.isPending ? null : entry.id; const eventId = entry.isPending ? null : entry.id;
this._findAndUpdateEntryById(txnId, eventId, () => true); this._findAndUpdateEntryById(txnId, eventId, () => param);
} }
/** /**
@ -333,7 +333,7 @@ export class Timeline {
} }
if (contextEvent) { if (contextEvent) {
entry.setContextEntry(contextEvent); entry.setContextEntry(contextEvent);
this._emitUpdateForEntry(entry); this._emitUpdateForEntry(entry, "contextEntry");
} }
} }
} }