@mtcute/core - npm Package Compare versions

Comparing version 0.3.0 to 0.4.0

cjs/network/mtproto-session.js

@@ -108,4 +108,6 @@ "use strict";
         this.queuedResendReq.length = 0;
+        this.queuedCancelReq.length = 0;
         this.getStateSchedule.clear();
         this.chains.clear();
+        this.chainsPendingFails.clear();
     }
@@ -112,0 +114,0 @@ enqueueRpc(rpc, force) {

cjs/network/network-manager.js

@@ -248,3 +248,3 @@ "use strict";
             systemVersion: '1.0',
-            appVersion: '0.3.0',
+            appVersion: '0.4.0',
             systemLangCode: 'en',
@@ -251,0 +251,0 @@ langPack: '',

cjs/storage/abstract.d.ts

@@ -76,3 +76,3 @@ import { mtp, tl } from '@mtcute/tl';
      */
-    reset(withAuthKeys?: boolean): void;
+    reset(withAuthKeys?: boolean): MaybeAsync<void>;
     /**
@@ -79,0 +79,0 @@ * Set default datacenter to use with this session.

cjs/storage/json-file.d.ts

@@ -17,3 +17,3 @@ import { JsonMemoryStorage } from './json.js';
     private readonly _safe;
-    private readonly _cleanup;
+    private readonly _cleanupUnregister?;
     constructor(filename: string, params?: {
@@ -41,5 +41,4 @@ /**
     save(): Promise<void>;
-    private _processExitHandled;
     private _onProcessExit;
     destroy(): void;
 }

cjs/storage/json-file.js

@@ -29,4 +29,4 @@ "use strict";
 const fs = __importStar(require("fs"));
+const index_js_1 = require("../utils/index.js");
 const json_js_1 = require("./json.js");
-const EVENTS = ['exit', 'SIGINT', 'SIGUSR1', 'SIGUSR2', 'uncaughtException', 'SIGTERM'];
 /**
@@ -47,9 +47,6 @@ * mtcute storage that stores data in a JSON file.
         super();
-        this._processExitHandled = false;
         this._filename = filename;
         this._safe = params?.safe ?? true;
-        this._cleanup = params?.cleanup ?? true;
-        if (this._cleanup) {
-            this._onProcessExit = this._onProcessExit.bind(this);
-            EVENTS.forEach((event) => process.on(event, this._onProcessExit));
+        if (params?.cleanup !== false) {
+            this._cleanupUnregister = (0, index_js_1.beforeExit)(() => this._onProcessExit());
         }
@@ -83,5 +80,2 @@ }
         // on exit handler must be synchronous, thus we use sync methods here
-        if (this._processExitHandled)
-            return;
-        this._processExitHandled = true;
         try {
@@ -99,5 +93,3 @@ fs.writeFileSync(this._filename, this._saveJson());
     destroy() {
-        if (this._cleanup) {
-            EVENTS.forEach((event) => process.off(event, this._onProcessExit));
-        }
+        this._cleanupUnregister?.();
     }
@@ -104,0 +96,0 @@ }

cjs/utils/index.d.ts

@@ -19,2 +19,3 @@ export * from './async-lock.js';
 export * from './peer-utils.js';
+export * from './platform/exit-hook.js';
 export * from './sorted-array.js';
@@ -21,0 +22,0 @@ export * from './string-session.js';

cjs/utils/index.js

@@ -35,2 +35,3 @@ "use strict";
 __exportStar(require("./peer-utils.js"), exports);
+__exportStar(require("./platform/exit-hook.js"), exports);
 __exportStar(require("./sorted-array.js"), exports);
@@ -37,0 +38,0 @@ __exportStar(require("./string-session.js"), exports);

esm/network/mtproto-session.js

@@ -102,4 +102,6 @@ import Long from 'long';
         this.queuedResendReq.length = 0;
+        this.queuedCancelReq.length = 0;
         this.getStateSchedule.clear();
         this.chains.clear();
+        this.chainsPendingFails.clear();
     }
@@ -106,0 +108,0 @@ enqueueRpc(rpc, force) {

esm/network/network-manager.js

@@ -244,3 +244,3 @@ import { tl } from '@mtcute/tl';
             systemVersion: '1.0',
-            appVersion: '0.3.0',
+            appVersion: '0.4.0',
             systemLangCode: 'en',
@@ -247,0 +247,0 @@ langPack: '',

esm/storage/abstract.d.ts

@@ -76,3 +76,3 @@ import { mtp, tl } from '@mtcute/tl';
      */
-    reset(withAuthKeys?: boolean): void;
+    reset(withAuthKeys?: boolean): MaybeAsync<void>;
     /**
@@ -79,0 +79,0 @@ * Set default datacenter to use with this session.

esm/storage/json-file.d.ts

@@ -17,3 +17,3 @@ import { JsonMemoryStorage } from './json.js';
     private readonly _safe;
-    private readonly _cleanup;
+    private readonly _cleanupUnregister?;
     constructor(filename: string, params?: {
@@ -41,5 +41,4 @@ /**
     save(): Promise<void>;
-    private _processExitHandled;
     private _onProcessExit;
     destroy(): void;
 }

esm/storage/json-file.js

 // eslint-disable-next-line no-restricted-imports
 import * as fs from 'fs';
+import { beforeExit } from '../utils/index.js';
 import { JsonMemoryStorage } from './json.js';
-const EVENTS = ['exit', 'SIGINT', 'SIGUSR1', 'SIGUSR2', 'uncaughtException', 'SIGTERM'];
 /**
@@ -20,9 +20,6 @@ * mtcute storage that stores data in a JSON file.
         super();
-        this._processExitHandled = false;
         this._filename = filename;
         this._safe = params?.safe ?? true;
-        this._cleanup = params?.cleanup ?? true;
-        if (this._cleanup) {
-            this._onProcessExit = this._onProcessExit.bind(this);
-            EVENTS.forEach((event) => process.on(event, this._onProcessExit));
+        if (params?.cleanup !== false) {
+            this._cleanupUnregister = beforeExit(() => this._onProcessExit());
         }
@@ -56,5 +53,2 @@ }
         // on exit handler must be synchronous, thus we use sync methods here
-        if (this._processExitHandled)
-            return;
-        this._processExitHandled = true;
         try {
@@ -72,7 +66,5 @@ fs.writeFileSync(this._filename, this._saveJson());
     destroy() {
-        if (this._cleanup) {
-            EVENTS.forEach((event) => process.off(event, this._onProcessExit));
-        }
+        this._cleanupUnregister?.();
     }
 }
 //# sourceMappingURL=json-file.js.map

esm/utils/index.d.ts

@@ -19,2 +19,3 @@ export * from './async-lock.js';
 export * from './peer-utils.js';
+export * from './platform/exit-hook.js';
 export * from './sorted-array.js';
@@ -21,0 +22,0 @@ export * from './string-session.js';

esm/utils/index.js

@@ -19,2 +19,3 @@ export * from './async-lock.js';
 export * from './peer-utils.js';
+export * from './platform/exit-hook.js';
 export * from './sorted-array.js';
@@ -21,0 +22,0 @@ export * from './string-session.js';

package.json

 {
   "name": "@mtcute/core",
-  "version": "0.3.0",
+  "version": "0.4.0",
   "description": "Core functions and base MTProto client",
@@ -19,2 +19,4 @@ "author": "Alina Sireneva <[e-mail]>",
     "./cjs/utils/platform/random.js": "./cjs/utils/platform/random.web.js",
+    "./esm/utils/platform/exit-hook.js": "./esm/utils/platform/exit-hook.web.js",
+    "./cjs/utils/platform/exit-hook.js": "./cjs/utils/platform/exit-hook.web.js",
     "./esm/storage/json-file.js": false,
@@ -24,5 +26,5 @@ "./cjs/storage/json-file.js": false
   "dependencies": {
-    "@mtcute/tl": "^167.0.1",
-    "@mtcute/tl-runtime": "^0.3.0",
-    "@mtcute/wasm": "^0.3.0",
+    "@mtcute/tl": "^169.0.0",
+    "@mtcute/tl-runtime": "^0.4.0",
+    "@mtcute/wasm": "^0.4.0",
     "@types/events": "3.0.0",
@@ -29,0 +31,0 @@ "events": "3.2.0",

No alert changes

Improved metrics

Total package byte prevSize

3147888

increased by0.43%

Number of package files

754

increased by1.62%

Lines of code

29320

increased by0.49%

Dependency changes

• + Added@mtcute/tl@169.0.0(transitive)

• + Added@mtcute/tl-runtime@0.4.0(transitive)

• + Added@mtcute/wasm@0.4.0(transitive)

• - Removed@mtcute/tl@167.0.1(transitive)

• - Removed@mtcute/tl-runtime@0.3.0(transitive)

• - Removed@mtcute/wasm@0.3.0(transitive)

• Updated@mtcute/tl@^169.0.0

• Updated@mtcute/tl-runtime@^0.4.0

• Updated@mtcute/wasm@^0.4.0