r4sas/tweb-i2p
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix infinite loop with updates

Browse Source
This commit is contained in:
Eduard Kuzmenko 2021-03-13 17:08:34 +04:00
parent c201135016
commit 692aa02c54
1 changed files with 25 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/lib/appManagers/appMessagesManager.ts
View File

@ -156,7 +156,7 @@ export class AppMessagesManager {
public newMessagesToHandle: {[peerId: string]: number[]} = {}; public newMessagesToHandle: {[peerId: string]: number[]} = {};
public newDialogsHandlePromise = 0; public newDialogsHandlePromise = 0;
public newDialogsToHandle: {[peerId: string]: {reload: true} | Dialog} = {}; public newDialogsToHandle: {[peerId: string]: {reload: true} | Dialog} = {};
public newUpdatesAfterReloadToHandle: {[peerId: string]: any[]} = {}; public newUpdatesAfterReloadToHandle: {[peerId: string]: Set<any>} = {};
private notificationsHandlePromise = 0; private notificationsHandlePromise = 0;
private notificationsToHandle: {[peerId: string]: { private notificationsToHandle: {[peerId: string]: {
@ -3756,13 +3756,31 @@ export class AppMessagesManager {
const storage = this.getMessagesStorage(peerId); const storage = this.getMessagesStorage(peerId);
const foundDialog = this.getDialogByPeerId(peerId); const foundDialog = this.getDialogByPeerId(peerId);
if(!foundDialog.length && (peerId > 0 || !appChatsManager.getChat(-peerId).pFlags.left)) { if(!foundDialog.length) {
this.newDialogsToHandle[peerId] = {reload: true}; let good = true;
this.scheduleHandleNewDialogs(); if(peerId < 0) {
if(this.newUpdatesAfterReloadToHandle[peerId] === undefined) { const chat = appChatsManager.getChat(-peerId);
this.newUpdatesAfterReloadToHandle[peerId] = []; if(chat._ === 'channelForbidden'
|| chat._ === 'chatForbidden'
|| (chat as Chat.chat).pFlags.left
|| (chat as Chat.chat).pFlags.kicked
|| (chat as Chat.chat).pFlags.deactivated) {
good = false;
}
} }
this.newUpdatesAfterReloadToHandle[peerId].push(update);
if(good) {
const set = this.newUpdatesAfterReloadToHandle[peerId] ?? (this.newUpdatesAfterReloadToHandle[peerId] = new Set());
if(set.has(update)) {
this.log.error('here we go again', peerId);
break;
}
this.newDialogsToHandle[peerId] = {reload: true};
this.scheduleHandleNewDialogs();
this.newUpdatesAfterReloadToHandle[peerId].add(update);
}
break; break;
} }