chore(eventsource): update eventsource to v3

Author: jeffladiray

packages/forestadmin-client/package.json

@@ -12,12 +12,13 @@
     "directory": "packages/forestadmin-client"
   },
   "dependencies": {
-    "eventsource": "2.0.2",
+    "eventsource": "3.0.2",
     "json-api-serializer": "^2.6.6",
     "jsonwebtoken": "^9.0.0",
     "object-hash": "^3.0.0",
     "openid-client": "^5.6.4",
-    "superagent": "^8.0.6"
+    "superagent": "^8.0.6",
+    "undici": "^6.0.0"
   },
   "files": [
     "dist/**/*.js",
@@ -36,4 +37,4 @@
     "@types/jsonwebtoken": "^9.0.1",
     "@types/superagent": "^4.1.16"
   }
-}
+}

packages/forestadmin-client/src/events-subscription/index.ts

@@ -1,4 +1,5 @@
-import EventSource from 'eventsource';
+import { EventSource } from 'eventsource';
+import { Agent, fetch } from 'undici';
 
 import {
   BaseEventsSubscriptionService,
@@ -30,10 +31,16 @@ export default class EventsSubscriptionService implements BaseEventsSubscription
     const eventSourceConfig = {
       // forest-secret-key act as the credential
       withCredentials: false,
-      headers: { 'forest-secret-key': this.options.envSecret },
-      https: {
-        rejectUnauthorized: process.env.NODE_TLS_REJECT_UNAUTHORIZED !== '0',
-      },
+      fetch: (input, init) =>
+        fetch(input, {
+          ...init,
+          headers: { ...init.headers, 'forest-secret-key': this.options.envSecret },
+          dispatcher: new Agent({
+            connect: {
+              rejectUnauthorized: false,
+            },
+          }),
+        }),
     };
     const url = new URL('/liana/v4/subscribe-to-events', this.options.forestServerUrl).toString();
 
@@ -44,10 +51,7 @@ export default class EventsSubscriptionService implements BaseEventsSubscription
     eventSource.addEventListener('error', this.onEventError.bind(this));
 
     // Only listen after first open
-    eventSource.once('open', () =>
-      eventSource.addEventListener('open', () => this.onEventOpenAgain()),
-    );
-
+    eventSource.addEventListener('open', () => this.onEventOpenAgain());
     eventSource.addEventListener(ServerEventType.RefreshUsers, async () =>
       this.refreshEventsHandlerService.refreshUsers(),
     );
@@ -64,6 +68,10 @@ export default class EventsSubscriptionService implements BaseEventsSubscription
       this.refreshEventsHandlerService.refreshCustomizations(),
     );
 
+    eventSource.addEventListener('error', error => {
+      this.options.logger('Error', `Server Event - Error: ${error.message}`);
+    });
+
     this.eventSource = eventSource;
   }
 

yarn.lock

@@ -7177,10 +7177,17 @@ events@^3.0.0, events@^3.3.0:
   resolved "https://registry.yarnpkg.com/events/-/events-3.3.0.tgz#31a95ad0a924e2d2c419a813aeb2c4e878ea7400"
   integrity sha512-mQw+2fkQbALzQ7V0MY0IqdnXNOeTtP4r0lN9z7AAawCXgqea7bDii20AYrIBrFd/Hx0M2Ocz6S111CaFkUcb0Q==
 
-[email protected]:
-  version "2.0.2"
-  resolved "https://registry.yarnpkg.com/eventsource/-/eventsource-2.0.2.tgz#76dfcc02930fb2ff339520b6d290da573a9e8508"
-  integrity sha512-IzUmBGPR3+oUG9dUeXynyNmf91/3zUSJg1lCktzKw47OXuhco54U3r9B7O4XX+Rb1Itm9OZ2b0RkTs10bICOxA==
+eventsource-parser@^3.0.0:
+  version "3.0.0"
+  resolved "https://registry.yarnpkg.com/eventsource-parser/-/eventsource-parser-3.0.0.tgz#9303e303ef807d279ee210a17ce80f16300d9f57"
+  integrity sha512-T1C0XCUimhxVQzW4zFipdx0SficT651NnkR0ZSH3yQwh+mFMdLfgjABVi4YtMTtaL4s168593DaoaRLMqryavA==
+
+[email protected]:
+  version "3.0.2"
+  resolved "https://registry.yarnpkg.com/eventsource/-/eventsource-3.0.2.tgz#31904faf2d9a9dbdc410f9599354186e7257b3f7"
+  integrity sha512-YolzkJNxsTL3tCJMWFxpxtG2sCjbZ4LQUBUrkdaJK0ub0p6lmJt+2+1SwhKjLc652lpH9L/79Ptez972H9tphw==
+  dependencies:
+    eventsource-parser "^3.0.0"
 
 excel4node@^1.8.0:
   version "1.8.2"
@@ -15206,6 +15213,11 @@ undici-types@~5.26.4:
   resolved "https://registry.yarnpkg.com/undici-types/-/undici-types-5.26.5.tgz#bcd539893d00b56e964fd2657a4866b221a65617"
   integrity sha512-JlCMO+ehdEIKqlFxk6IfVoAUVmgz7cU7zD/h9XZ0qzeosSHmUJVOzSQvvYSYWXkFXC+IfLKSIffhv0sVZup6pA==
 
+undici@^6.0.0:
+  version "6.21.0"
+  resolved "https://registry.yarnpkg.com/undici/-/undici-6.21.0.tgz#4b3d3afaef984e07b48e7620c34ed8a285ed4cd4"
+  integrity sha512-BUgJXc752Kou3oOIuU1i+yZZypyZRqNPW0vqoMPl8VaoalSfeR0D8/t4iAS3yirs79SSMTxTag+ZC86uswv+Cw==
+
 unified@^9.0.0:
   version "9.2.2"
   resolved "https://registry.yarnpkg.com/unified/-/unified-9.2.2.tgz#67649a1abfc3ab85d2969502902775eb03146975"