From 02b36cbd2dc30d5565afa920cda077d650b652e9 Mon Sep 17 00:00:00 2001
From: Aras Abbasi <aras.abbasi@googlemail.com>
Date: Mon, 13 May 2024 07:32:08 +0200
Subject: [PATCH] lib: add EventSource Client

PR-URL: https://github.com/nodejs/node/pull/51575
Reviewed-By: Benjamin Gruenbaum <benjamingr@gmail.com>
Reviewed-By: Matthew Aitken <maitken033380023@gmail.com>
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Reviewed-By: Antoine du Hamel <duhamelantoine1995@gmail.com>
---
 .eslintrc.js                                           |  1 +
 doc/api/cli.md                                         | 10 ++++++++++
 doc/node.1                                             |  3 +++
 lib/.eslintrc.yaml                                     |  2 ++
 lib/internal/bootstrap/web/exposed-window-or-worker.js |  3 +++
 lib/internal/process/pre_execution.js                  |  8 ++++++++
 src/node_options.cc                                    |  5 +++++
 src/node_options.h                                     |  1 +
 test/common/globals.js                                 |  1 +
 test/common/index.js                                   |  4 ++++
 test/parallel/test-eventsource-disabled.js             |  6 ++++++
 test/parallel/test-eventsource.js                      |  7 +++++++
 12 files changed, 51 insertions(+)
 create mode 100644 test/parallel/test-eventsource-disabled.js
 create mode 100644 test/parallel/test-eventsource.js

diff --git a/.eslintrc.js b/.eslintrc.js
index f86f42e8f2e89f..9eaa7e3f47b0e2 100644
--- a/.eslintrc.js
+++ b/.eslintrc.js
@@ -348,6 +348,7 @@ module.exports = {
     Crypto: 'readable',
     CryptoKey: 'readable',
     DecompressionStream: 'readable',
+    EventSource: 'readable',
     fetch: 'readable',
     FormData: 'readable',
     ReadableStream: 'readable',
diff --git a/doc/api/cli.md b/doc/api/cli.md
index 8f32a44ad41314..0b8eb7b0cb2308 100644
--- a/doc/api/cli.md
+++ b/doc/api/cli.md
@@ -898,6 +898,14 @@ CommonJS. This includes the following:
 * Lexical redeclarations of the CommonJS wrapper variables (`require`, `module`,
   `exports`, `__dirname`, `__filename`).
 
+### `--experimental-eventsource`
+
+<!-- YAML
+added: REPLACEME
+-->
+
+Enable exposition of [EventSource Web API][] on the global scope.
+
 ### `--experimental-import-meta-resolve`
 
 <!-- YAML
@@ -2697,6 +2705,7 @@ one is included in the list below.
 * `--experimental-abortcontroller`
 * `--experimental-default-type`
 * `--experimental-detect-module`
+* `--experimental-eventsource`
 * `--experimental-import-meta-resolve`
 * `--experimental-json-modules`
 * `--experimental-loader`
@@ -3172,6 +3181,7 @@ done
 [CustomEvent Web API]: https://dom.spec.whatwg.org/#customevent
 [DEP0025 warning]: deprecations.md#dep0025-requirenodesys
 [ECMAScript module]: esm.md#modules-ecmascript-modules
+[EventSource Web API]: https://html.spec.whatwg.org/multipage/server-sent-events.html#server-sent-events
 [ExperimentalWarning: `vm.measureMemory` is an experimental feature]: vm.md#vmmeasurememoryoptions
 [Fetch API]: https://developer.mozilla.org/en-US/docs/Web/API/Fetch_API
 [File System Permissions]: permissions.md#file-system-permissions
diff --git a/doc/node.1 b/doc/node.1
index 060448e444b8a2..832765abe03dc6 100644
--- a/doc/node.1
+++ b/doc/node.1
@@ -191,6 +191,9 @@ Use this flag to enable ShadowRealm support.
 .It Fl -experimental-test-coverage
 Enable code coverage in the test runner.
 .
+.It Fl -experimental-eventsource
+Enable experimental support for the EventSource Web API.
+.
 .It Fl -experimental-websocket
 Enable experimental support for the WebSocket API.
 .
diff --git a/lib/.eslintrc.yaml b/lib/.eslintrc.yaml
index 0cf84a0da5ee9e..74e867ace62077 100644
--- a/lib/.eslintrc.yaml
+++ b/lib/.eslintrc.yaml
@@ -152,6 +152,8 @@ rules:
       message: Use `const { Crypto } = require('internal/crypto/webcrypto');` instead of the global.
     - name: CryptoKey
       message: Use `const { CryptoKey } = require('internal/crypto/webcrypto');` instead of the global.
+    - name: EventSource
+      message: Use `const { EventSource } = require('internal/deps/undici/undici');` instead of the global.
     - name: fetch
       message: Use `const { fetch } = require('internal/deps/undici/undici');` instead of the global.
     - name: global
diff --git a/lib/internal/bootstrap/web/exposed-window-or-worker.js b/lib/internal/bootstrap/web/exposed-window-or-worker.js
index 2687cdfe8956f9..ed94e8fab89974 100644
--- a/lib/internal/bootstrap/web/exposed-window-or-worker.js
+++ b/lib/internal/bootstrap/web/exposed-window-or-worker.js
@@ -81,6 +81,9 @@ exposeLazyInterfaces(globalThis, 'internal/deps/undici/undici', [
   'FormData', 'Headers', 'Request', 'Response',
 ]);
 
+// https://html.spec.whatwg.org/multipage/server-sent-events.html#server-sent-events.org/
+exposeLazyInterfaces(globalThis, 'internal/deps/undici/undici', ['EventSource']);
+
 // The WebAssembly Web API which relies on Response.
 // https:// webassembly.github.io/spec/web-api/#streaming-modules
 internalBinding('wasm_web_api').setImplementation((streamState, source) => {
diff --git a/lib/internal/process/pre_execution.js b/lib/internal/process/pre_execution.js
index 59308ab817fb86..f7af1519b262df 100644
--- a/lib/internal/process/pre_execution.js
+++ b/lib/internal/process/pre_execution.js
@@ -109,6 +109,7 @@ function prepareExecution(options) {
   setupUndici();
   setupWebCrypto();
   setupCustomEvent();
+  setupEventsource();
   setupCodeCoverage();
   setupDebugEnv();
   // Process initial diagnostic reporting configuration, if present.
@@ -328,6 +329,13 @@ function setupUndici() {
   }
 }
 
+// https://html.spec.whatwg.org/multipage/server-sent-events.html
+function setupEventsource() {
+  if (!getOptionValue('--experimental-eventsource')) {
+    delete globalThis.EventSource;
+  }
+}
+
 // TODO(aduh95): move this to internal/bootstrap/web/* when the CLI flag is
 //               removed.
 function setupWebCrypto() {
diff --git a/src/node_options.cc b/src/node_options.cc
index e94e4dbc959cee..d7365e66f6313d 100644
--- a/src/node_options.cc
+++ b/src/node_options.cc
@@ -406,6 +406,11 @@ EnvironmentOptionsParser::EnvironmentOptionsParser() {
             &EnvironmentOptions::enable_source_maps,
             kAllowedInEnvvar);
   AddOption("--experimental-abortcontroller", "", NoOp{}, kAllowedInEnvvar);
+  AddOption("--experimental-eventsource",
+            "experimental EventSource API",
+            &EnvironmentOptions::experimental_eventsource,
+            kAllowedInEnvvar,
+            false);
   AddOption("--experimental-fetch",
             "experimental Fetch API",
             &EnvironmentOptions::experimental_fetch,
diff --git a/src/node_options.h b/src/node_options.h
index c978c339cbbb38..8806f88290f7cb 100644
--- a/src/node_options.h
+++ b/src/node_options.h
@@ -115,6 +115,7 @@ class EnvironmentOptions : public Options {
   bool require_module = false;
   std::string dns_result_order;
   bool enable_source_maps = false;
+  bool experimental_eventsource = false;
   bool experimental_fetch = true;
   bool experimental_websocket = false;
   bool experimental_global_customevent = true;
diff --git a/test/common/globals.js b/test/common/globals.js
index 8b9b6b34f6abaf..cb7c1629007ecf 100644
--- a/test/common/globals.js
+++ b/test/common/globals.js
@@ -124,6 +124,7 @@ const webIdlExposedWindow = new Set([
   'Request',
   'Response',
   'WebSocket',
+  'EventSource',
 ]);
 
 const nodeGlobals = new Set([
diff --git a/test/common/index.js b/test/common/index.js
index 75f51fb06cc242..d93ef9cfffbb31 100644
--- a/test/common/index.js
+++ b/test/common/index.js
@@ -330,6 +330,10 @@ if (global.structuredClone) {
   knownGlobals.push(global.structuredClone);
 }
 
+if (global.EventSource) {
+  knownGlobals.push(EventSource);
+}
+
 if (global.fetch) {
   knownGlobals.push(fetch);
 }
diff --git a/test/parallel/test-eventsource-disabled.js b/test/parallel/test-eventsource-disabled.js
new file mode 100644
index 00000000000000..ade4f51d99e8a8
--- /dev/null
+++ b/test/parallel/test-eventsource-disabled.js
@@ -0,0 +1,6 @@
+'use strict';
+
+require('../common');
+const assert = require('assert');
+
+assert.strictEqual(typeof EventSource, 'undefined');
diff --git a/test/parallel/test-eventsource.js b/test/parallel/test-eventsource.js
new file mode 100644
index 00000000000000..787195ca19d971
--- /dev/null
+++ b/test/parallel/test-eventsource.js
@@ -0,0 +1,7 @@
+// Flags: --experimental-eventsource
+'use strict';
+
+require('../common');
+const assert = require('assert');
+
+assert.strictEqual(typeof EventSource, 'function');