Limit updates returned from getUpdates to 100

MTKruto · Apr 11, 2024 · ae118d5 · ae118d5
1 parent bd1237d
commit ae118d5
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/client/README.md b/client/README.md
@@ -11,7 +11,7 @@ Deno Deploy, Cloudflare Workers, and more.
 
 ### `connect()` and `authorize()`
 
-The [`Client`] class of this module does not have these methods, since it is
+The `Client` class of this module does not have these methods, since it is
 neither required to make a connection initially, nor to authorize.
 
 ### Telegram API Calls

diff --git a/client_manager.ts b/client_manager.ts
@@ -219,6 +219,7 @@ export class ClientManager {
   }
 
   #polls = new Set<Client>();
+  static #GET_UPDATES_MAX_UPDATES = 100;
   #updateResolvers = new Map<Client, () => void>();
   #getUpdatesControllers = new Map<Client, AbortController>();
   async #getUpdatesInner(id: string, timeoutSeconds: number) {
@@ -235,7 +236,10 @@ export class ClientManager {
     try {
       let updates = this.#updates.get(client);
       if (updates && updates.length) {
-        return updates.splice(0, updates.length);
+        return updates.splice(
+          0,
+          Math.min(ClientManager.#GET_UPDATES_MAX_UPDATES, updates.length),
+        );
       }
 
       controller = new AbortController();
@@ -253,7 +257,10 @@ export class ClientManager {
 
       updates = this.#updates.get(client);
       if (updates && updates.length) {
-        return updates.splice(0, updates.length);
+        return updates.splice(
+          0,
+          Math.min(ClientManager.#GET_UPDATES_MAX_UPDATES, updates.length),
+        );
       } else {
         return [];
       }