fix: improved reconnecting

packages/core/src/network/persistent-connection.ts

@@ -5,7 +5,7 @@ import type { IPacketCodec, ITelegramConnection, TelegramTransport } from './tra
 
 import { FramedReader, FramedWriter } from '@fuman/io'
 
-import { PersistentConnection as FumanPersistentConnection } from '@fuman/net'
+import { ConnectionClosedError, PersistentConnection as FumanPersistentConnection } from '@fuman/net'
 import { Emitter, timers } from '@fuman/utils'
 
 export interface PersistentConnectionParams {
@@ -140,7 +140,7 @@ export abstract class PersistentConnection {
         }
     }
 
-    private async _onClose() {
+    private _onClose(): void {
         this.log.debug('connection closed')
         this._updateLogPrefix()
 
@@ -149,9 +149,12 @@ export abstract class PersistentConnection {
         this.onClosed()
     }
 
-    private async _onError(err: Error) {
+    private _onError(err: Error) {
         this._updateLogPrefix()
-        this.handleError(err)
+
+        if (!(err instanceof ConnectionClosedError)) {
+            this.handleError(err)
+        }
 
         return 'reconnect' as const
     }
@@ -231,7 +234,17 @@ export abstract class PersistentConnection {
 
         if (this._writer) {
             this._rescheduleInactivity()
-            await this._writer.write(data)
+            try {
+                await this._writer.write(data)
+            } catch (e: unknown) {
+                if (e instanceof ConnectionClosedError) {
+                    this.log.debug('connection closed while sending, reconnecting')
+                    this._fuman.reconnect(true)
+                    this._sendOnceConnected.push(data)
+                } else {
+                    throw e
+                }
+            }
         } else {
             this._sendOnceConnected.push(data)
         }

packages/core/src/network/session-connection.ts

@@ -10,8 +10,8 @@ import { Deferred, Emitter, timers, u8 } from '@fuman/utils'
 import { tl } from '@mtcute/tl'
 import { TlBinaryReader, TlBinaryWriter, TlSerializationCounter } from '@mtcute/tl-runtime'
 import Long from 'long'
-import { MtArgumentError, MtcuteError, MtTimeoutError } from '../types/index.js'
 
+import { MtArgumentError, MtcuteError, MtTimeoutError } from '../types/index.js'
 import { createAesIgeForMessageOld } from '../utils/crypto/mtproto.js'
 import {
     EarlyTimer,