From 923d68a0fa8f014f28a31b0156ccd0b00e08ed90 Mon Sep 17 00:00:00 2001 From: Michael Telatynski <7t3chguy@gmail.com> Date: Thu, 15 Jul 2021 17:46:46 +0100 Subject: [PATCH] Fix EventIndex handling events twice It awaits the decryption in onRoomTimeline as well as subscribing to EVent.decrypted --- src/indexing/EventIndex.ts | 14 -------------- 1 file changed, 14 deletions(-) diff --git a/src/indexing/EventIndex.ts b/src/indexing/EventIndex.ts index a5827fc599..a7142010f2 100644 --- a/src/indexing/EventIndex.ts +++ b/src/indexing/EventIndex.ts @@ -67,7 +67,6 @@ export default class EventIndex extends EventEmitter { client.on('sync', this.onSync); client.on('Room.timeline', this.onRoomTimeline); - client.on('Event.decrypted', this.onEventDecrypted); client.on('Room.timelineReset', this.onTimelineReset); client.on('Room.redaction', this.onRedaction); client.on('RoomState.events', this.onRoomStateEvent); @@ -82,7 +81,6 @@ export default class EventIndex extends EventEmitter { client.removeListener('sync', this.onSync); client.removeListener('Room.timeline', this.onRoomTimeline); - client.removeListener('Event.decrypted', this.onEventDecrypted); client.removeListener('Room.timelineReset', this.onTimelineReset); client.removeListener('Room.redaction', this.onRedaction); client.removeListener('RoomState.events', this.onRoomStateEvent); @@ -221,18 +219,6 @@ export default class EventIndex extends EventEmitter { } }; - /* - * The Event.decrypted listener. - * - * Checks if the event was marked for addition in the Room.timeline - * listener, if so queues it up to be added to the index. - */ - private onEventDecrypted = async (ev: MatrixEvent, err: Error) => { - // If the event isn't in our live event set, ignore it. - if (err) return; - await this.addLiveEventToIndex(ev); - }; - /* * The Room.redaction listener. *