OpenCloud
/
element-web
mirror of https://github.com/vector-im/element-web
1
0
Fork 0
Code Issues Releases Wiki Activity

EventIndex: Use property initializer style for the bound callbacks.

pull/21833/head
Damir Jelić 2019-11-20 12:30:03 +01:00
parent 27d1e4fbbe
commit 2f5b0a9652
1 changed files with 12 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
src/indexing/EventIndex.js
View File

@ -31,19 +31,6 @@ export default class EventIndex {
this._eventsPerCrawl = 100; this._eventsPerCrawl = 100;
this._crawler = null; this._crawler = null;
this.liveEventsForIndex = new Set(); this.liveEventsForIndex = new Set();
this.boundOnSync = async (state, prevState, data) => {
await this.onSync(state, prevState, data);
};
this.boundOnRoomTimeline = async ( ev, room, toStartOfTimeline, removed,
data) => {
await this.onRoomTimeline(ev, room, toStartOfTimeline, removed, data);
};
this.boundOnEventDecrypted = async (ev, err) => {
await this.onEventDecrypted(ev, err);
};
this.boundOnTimelineReset = async (room, timelineSet,
resetAllTimelines) => await this.onTimelineReset(room);
} }
async init() { async init() {
@ -56,23 +43,23 @@ export default class EventIndex {
registerListeners() { registerListeners() {
const client = MatrixClientPeg.get(); const client = MatrixClientPeg.get();
client.on('sync', this.boundOnSync); client.on('sync', this.onSync);
client.on('Room.timeline', this.boundOnRoomTimeline); client.on('Room.timeline', this.onRoomTimeline);
client.on('Event.decrypted', this.boundOnEventDecrypted); client.on('Event.decrypted', this.onEventDecrypted);
client.on('Room.timelineReset', this.boundOnTimelineReset); client.on('Room.timelineReset', this.onTimelineReset);
} }
removeListeners() { removeListeners() {
const client = MatrixClientPeg.get(); const client = MatrixClientPeg.get();
if (client === null) return; if (client === null) return;
client.removeListener('sync', this.boundOnSync); client.removeListener('sync', this.onSync);
client.removeListener('Room.timeline', this.boundOnRoomTimeline); client.removeListener('Room.timeline', this.onRoomTimeline);
client.removeListener('Event.decrypted', this.boundOnEventDecrypted); client.removeListener('Event.decrypted', this.onEventDecrypted);
client.removeListener('Room.timelineReset', this.boundOnTimelineReset); client.removeListener('Room.timelineReset', this.onTimelineReset);
} }
async onSync(state, prevState, data) { onSync = async (state, prevState, data) => {
const indexManager = PlatformPeg.get().getEventIndexingManager(); const indexManager = PlatformPeg.get().getEventIndexingManager();
if (prevState === null && state === "PREPARED") { if (prevState === null && state === "PREPARED") {
@ -146,7 +133,7 @@ export default class EventIndex {
} }
} }
async onRoomTimeline(ev, room, toStartOfTimeline, removed, data) { onRoomTimeline = async (ev, room, toStartOfTimeline, removed, data) => {
// We only index encrypted rooms locally. // We only index encrypted rooms locally.
if (!MatrixClientPeg.get().isRoomEncrypted(room.roomId)) return; if (!MatrixClientPeg.get().isRoomEncrypted(room.roomId)) return;
@ -169,7 +156,7 @@ export default class EventIndex {
} }
} }
async onEventDecrypted(ev, err) { onEventDecrypted = async (ev, err) => {
const eventId = ev.getId(); const eventId = ev.getId();
// If the event isn't in our live event set, ignore it. // If the event isn't in our live event set, ignore it.
@ -377,7 +364,7 @@ export default class EventIndex {
console.log("EventIndex: Stopping crawler function"); console.log("EventIndex: Stopping crawler function");
} }
async onTimelineReset(room) { onTimelineReset = async (room, timelineSet, resetAllTimelines) => {
if (room === null) return; if (room === null) return;
const indexManager = PlatformPeg.get().getEventIndexingManager(); const indexManager = PlatformPeg.get().getEventIndexingManager();