datocms-listen - npm Package Compare versions

Comparing version 0.1.9 to 0.1.10

dist/subscribeToQuery/index.js

@@ -168,2 +168,3 @@ "use strict";
                             if (eventSource.readyState !== 2) {
+                                stopReconnecting = true;
                                 eventSource.close();
@@ -178,2 +179,13 @@ }
                         });
+                        var statusCheck = setInterval(function () {
+                            if (eventSource.readyState === 2) {
+                                clearInterval(statusCheck);
+                                if (onStatusChange) {
+                                    onStatusChange('closed');
+                                }
+                                if (!stopReconnecting) {
+                                    waitAndReconnect();
+                                }
+                            }
+                        }, 300);
                         eventSource.addEventListener('update', function (event) {
@@ -192,14 +204,4 @@ var updateData = JSON.parse(event.data);
                             eventSource.close();
-                            if (onStatusChange) {
-                                onStatusChange('closed');
-                            }
-                            if (!stopReconnecting) {
-                                waitAndReconnect();
-                            }
                         });
                         eventSource.addEventListener('onerror', function (event) {
-                            eventSource.close();
-                            if (onStatusChange) {
-                                onStatusChange('closed');
-                            }
                             var messageEvent = event;
@@ -209,5 +211,3 @@ if (onError) {
                             }
-                            if (!stopReconnecting) {
-                                waitAndReconnect();
-                            }
+                            eventSource.close();
                         });
@@ -214,0 +214,0 @@ })];

package.json

 {
   "name": "datocms-listen",
-  "version": "0.1.9",
+  "version": "0.1.10",
   "types": "dist/index.d.ts",
@@ -28,3 +28,4 @@ "main": "dist/index.js",
     "ts-jest": "^26.4.1",
-    "typescript": "^4.7.3"
+    "typescript": "^4.7.3",
+    "vite": "^3.1.0"
   },
@@ -36,3 +37,4 @@ "scripts": {
     "test": "jest --coverage",
-    "toc": "doctoc README.md"
+    "toc": "doctoc README.md",
+    "dev": "vite"
   },
@@ -39,0 +41,0 @@ "jest": {

src/subscribeToQuery/index.ts

@@ -209,2 +209,3 @@ export type UpdateData<QueryResult> = {
       if (eventSource.readyState !== 2) {
+        stopReconnecting = true;
         eventSource.close();
@@ -221,2 +222,16 @@ }
 
+    const statusCheck = setInterval(() => {
+      if (eventSource.readyState === 2) {
+        clearInterval(statusCheck);
+
+        if (onStatusChange) {
+          onStatusChange('closed');
+        }
+
+        if (!stopReconnecting) {
+          waitAndReconnect();
+        }
+      }
+    }, 300);
+
     eventSource.addEventListener('update', (event) => {
@@ -241,19 +256,5 @@ const updateData = JSON.parse(
       eventSource.close();
-
-      if (onStatusChange) {
-        onStatusChange('closed');
-      }
-
-      if (!stopReconnecting) {
-        waitAndReconnect();
-      }
     });
 
     eventSource.addEventListener('onerror', (event) => {
-      eventSource.close();
-
-      if (onStatusChange) {
-        onStatusChange('closed');
-      }
-
       const messageEvent = event as MessageEvent;
@@ -264,7 +265,5 @@ if (onError) {
 
-      if (!stopReconnecting) {
-        waitAndReconnect();
-      }
+      eventSource.close();
     });
   });
 }

No alert changes

Improved metrics

Total package byte prevSize

64840

increased by0.32%

Worsened metrics

Dev dependency count

12

increased by9.09%

No dependency changes