Skip to content

Commit 54ac9f7

Browse files
3189b2d89ea0f8815e27e4399e525208815e7fda
1 parent e6eb994 commit 54ac9f7

6 files changed

Lines changed: 12 additions & 12 deletions

File tree

esm/client/2_update_manager.d.ts.map

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

esm/client/2_update_manager.js

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -512,14 +512,14 @@ _a = UpdateManager, _UpdateManager_c = new WeakMap(), _UpdateManager_updateState
512512
if (update.pts != 0) {
513513
if (checkGap) {
514514
await __classPrivateFieldGet(this, _UpdateManager_instances, "m", _UpdateManager_checkGap).call(this, update.pts, update.pts_count);
515+
if (await __classPrivateFieldGet(this, _UpdateManager_instances, "m", _UpdateManager_needsGetDifference).call(this, update)) {
516+
await this.recoverUpdateGap("needsGetDifference");
517+
}
515518
}
516519
if (localState.pts + update.pts_count > update.pts) {
517520
return;
518521
}
519522
}
520-
if (await __classPrivateFieldGet(this, _UpdateManager_instances, "m", _UpdateManager_needsGetDifference).call(this, update)) {
521-
await this.recoverUpdateGap("needsGetDifference");
522-
}
523523
if (__classPrivateFieldGet(this, _UpdateManager_c, "f").guaranteeUpdateDelivery) {
524524
await __classPrivateFieldGet(this, _UpdateManager_c, "f").storage.setUpdate(_a.MAIN_BOX_ID, update);
525525
}
@@ -861,7 +861,7 @@ _a = UpdateManager, _UpdateManager_c = new WeakMap(), _UpdateManager_updateState
861861
if (!chatIds.size) {
862862
return false;
863863
}
864-
return (await Promise.all(chatIds.values().map((v) => __classPrivateFieldGet(this, _UpdateManager_c, "f").messageStorage.getEntity(v)))).some((v) => !!v);
864+
return (await Promise.all(chatIds.values().map((v) => __classPrivateFieldGet(this, _UpdateManager_c, "f").messageStorage.getEntity(v)))).some((v) => !v);
865865
}, _UpdateManager_collectChatIds = function _UpdateManager_collectChatIds(object) {
866866
const chatIds = new Set();
867867
if (Api.is("messageFwdHeader", object)) {

esm/client/5_client.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1320,7 +1320,7 @@ export class Client extends Composer {
13201320
}
13211321
if (Api.isOfEnum("Update", result) || Api.isOfEnum("Updates", result)) {
13221322
return new Promise((resolve) => {
1323-
__classPrivateFieldGet(this, _Client_updateManager, "f").processUpdates(result, true, null, () => resolve(result));
1323+
__classPrivateFieldGet(this, _Client_updateManager, "f").processUpdates(result, true, Mtproto.is("ping", function_) ? null : function_, () => resolve(result));
13241324
});
13251325
}
13261326
}

script/client/2_update_manager.d.ts.map

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

script/client/2_update_manager.js

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -516,14 +516,14 @@ _a = UpdateManager, _UpdateManager_c = new WeakMap(), _UpdateManager_updateState
516516
if (update.pts != 0) {
517517
if (checkGap) {
518518
await __classPrivateFieldGet(this, _UpdateManager_instances, "m", _UpdateManager_checkGap).call(this, update.pts, update.pts_count);
519+
if (await __classPrivateFieldGet(this, _UpdateManager_instances, "m", _UpdateManager_needsGetDifference).call(this, update)) {
520+
await this.recoverUpdateGap("needsGetDifference");
521+
}
519522
}
520523
if (localState.pts + update.pts_count > update.pts) {
521524
return;
522525
}
523526
}
524-
if (await __classPrivateFieldGet(this, _UpdateManager_instances, "m", _UpdateManager_needsGetDifference).call(this, update)) {
525-
await this.recoverUpdateGap("needsGetDifference");
526-
}
527527
if (__classPrivateFieldGet(this, _UpdateManager_c, "f").guaranteeUpdateDelivery) {
528528
await __classPrivateFieldGet(this, _UpdateManager_c, "f").storage.setUpdate(_a.MAIN_BOX_ID, update);
529529
}
@@ -865,7 +865,7 @@ _a = UpdateManager, _UpdateManager_c = new WeakMap(), _UpdateManager_updateState
865865
if (!chatIds.size) {
866866
return false;
867867
}
868-
return (await Promise.all(chatIds.values().map((v) => __classPrivateFieldGet(this, _UpdateManager_c, "f").messageStorage.getEntity(v)))).some((v) => !!v);
868+
return (await Promise.all(chatIds.values().map((v) => __classPrivateFieldGet(this, _UpdateManager_c, "f").messageStorage.getEntity(v)))).some((v) => !v);
869869
}, _UpdateManager_collectChatIds = function _UpdateManager_collectChatIds(object) {
870870
const chatIds = new Set();
871871
if (_2_tl_js_1.Api.is("messageFwdHeader", object)) {

script/client/5_client.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1324,7 +1324,7 @@ class Client extends Composer {
13241324
}
13251325
if (_2_tl_js_1.Api.isOfEnum("Update", result) || _2_tl_js_1.Api.isOfEnum("Updates", result)) {
13261326
return new Promise((resolve) => {
1327-
__classPrivateFieldGet(this, _Client_updateManager, "f").processUpdates(result, true, null, () => resolve(result));
1327+
__classPrivateFieldGet(this, _Client_updateManager, "f").processUpdates(result, true, _2_tl_js_1.Mtproto.is("ping", function_) ? null : function_, () => resolve(result));
13281328
});
13291329
}
13301330
}

0 commit comments

Comments
 (0)