Fix issues with uploads

client/2_update_manager.ts

@@ -134,6 +134,9 @@ export class UpdateManager {
   }
 
   async fetchState(source: string) {
+    if (this.#c.cdn) {
+      return;
+    }
     let state = await this.#c.invoke({ _: "updates.getState" });
     const difference = await this.#c.invoke({ ...state, _: "updates.getDifference" });
     if (is("updates.difference", difference)) {
@@ -436,6 +439,9 @@ export class UpdateManager {
 
   #processUpdatesQueue = new Queue("UpdateManager/processUpdates");
   processUpdates(updates: Api.Update | Api.Updates, checkGap: boolean, call: Api.AnyObject | null = null, callback?: () => void) {
+    if (this.#c.cdn) {
+      return;
+    }
     this.#processUpdatesQueue.add(() => this.#processUpdates(updates, checkGap, call).then(callback));
   }
 
@@ -629,6 +635,9 @@ export class UpdateManager {
     return localState;
   }
   async recoverUpdateGap(source: string) {
+    if (this.#c.cdn) {
+      return;
+    }
     this.#LrecoverUpdateGap.debug(`recovering from update gap [${source}]`);
 
     this.#c.setConnectionState("updating");
@@ -793,6 +802,9 @@ export class UpdateManager {
   }
 
   setUpdateHandler(handler: UpdateHandler) {
+    if (this.#c.cdn) {
+      return;
+    }
     this.#updateHandler = handler;
   }
 }

client/5_client.ts

@@ -537,7 +537,7 @@ export class Client<C extends Context = Context> extends Composer<C> {
     });
 
     return {
-      invoke: client.invoke,
+      invoke: client.invoke.bind(client),
       connect: async () => {
         await client.connect();
 

connection/1_connection_tcp.ts

@@ -80,12 +80,10 @@ export class ConnectionTCP implements Connection {
           this.#canRead = false;
           break;
         } catch (err) {
-          if (!this.connected) {
-            this.stateChangeHandler?.(false);
-            this.#rejectRead();
-          } else {
-            L.error(err);
-          }
+          this.#canRead = false;
+          this.stateChangeHandler?.(false);
+          this.#rejectRead();
+          L.error(err);
         }
       } while (this.connected);
       this.stateChangeHandler?.(false);