chore(deps): upgrade to eventsource v3

Author: kamilmysliwiec

integration/nest-application/sse/e2e/express.spec.ts

@@ -1,7 +1,7 @@
 import { NestExpressApplication } from '@nestjs/platform-express';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
-import * as EventSource from 'eventsource';
+import { EventSource } from 'eventsource';
 import { AppModule } from '../src/app.module';
 
 describe('Sse (Express Application)', () => {
@@ -20,7 +20,14 @@ describe('Sse (Express Application)', () => {
       const url = await app.getUrl();
 
       eventSource = new EventSource(url + '/sse', {
-        headers: { connection: 'keep-alive' },
+        fetch: (input, init) =>
+          fetch(input, {
+            ...init,
+            headers: {
+              ...init.headers,
+              connection: 'keep-alive',
+            },
+          }),
       });
     });
 
@@ -57,7 +64,14 @@ describe('Sse (Express Application)', () => {
       const url = await app.getUrl();
 
       eventSource = new EventSource(url + '/sse', {
-        headers: { connection: 'keep-alive' },
+        fetch: (input, init) =>
+          fetch(input, {
+            ...init,
+            headers: {
+              ...init.headers,
+              connection: 'keep-alive',
+            },
+          }),
       });
     });
 

integration/nest-application/sse/e2e/fastify.spec.ts

@@ -4,7 +4,7 @@ import {
 } from '@nestjs/platform-fastify';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
-import * as EventSource from 'eventsource';
+import { EventSource } from 'eventsource';
 import { AppModule } from '../src/app.module';
 
 describe('Sse (Fastify Application)', () => {
@@ -25,7 +25,14 @@ describe('Sse (Fastify Application)', () => {
       const url = await app.getUrl();
 
       eventSource = new EventSource(url + '/sse', {
-        headers: { connection: 'keep-alive' },
+        fetch: (input, init) =>
+          fetch(input, {
+            ...init,
+            headers: {
+              ...init.headers,
+              connection: 'keep-alive',
+            },
+          }),
       });
     });
 
@@ -64,7 +71,14 @@ describe('Sse (Fastify Application)', () => {
       const url = await app.getUrl();
 
       eventSource = new EventSource(url + '/sse', {
-        headers: { connection: 'keep-alive' },
+        fetch: (input, init) =>
+          fetch(input, {
+            ...init,
+            headers: {
+              ...init.headers,
+              connection: 'keep-alive',
+            },
+          }),
       });
     });
 

integration/websockets/e2e/gateway.spec.ts

@@ -1,7 +1,7 @@
 import { INestApplication } from '@nestjs/common';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
-import * as EventSource from 'eventsource';
+import { EventSource } from 'eventsource';
 import { io } from 'socket.io-client';
 import { AppController as LongConnectionController } from '../../nest-application/sse/src/app.controller';
 import { ApplicationGateway } from '../src/app.gateway';

package-lock.json

@@ -130,13 +130,13 @@
     "eslint-config-prettier": "9.1.0",
     "eslint-plugin-import": "2.31.0",
     "eslint-plugin-prettier": "5.2.1",
-    "eventsource": "2.0.2",
+    "eventsource": "3.0.2",
     "fancy-log": "2.0.0",
     "fastify": "5.2.1",
     "globals": "15.12.0",
     "graphql": "16.9.0",
-    "graphql-tools": "9.0.8",
     "graphql-subscriptions": "2.0.0",
+    "graphql-tools": "9.0.8",
     "gulp": "5.0.0",
     "gulp-clang-format": "1.0.27",
     "gulp-clean": "0.4.0",

package.json

@@ -1,5 +1,5 @@
 import { expect } from 'chai';
-import * as EventSource from 'eventsource';
+import { EventSource } from 'eventsource';
 import { createServer, OutgoingHttpHeaders } from 'http';
 import { AddressInfo } from 'net';
 import { Writable } from 'stream';