From 5c1fa0cf9cbe4301082b6cad343d42ef4c414c0d Mon Sep 17 00:00:00 2001
From: ud2 <sjx233@qq.com>
Date: Mon, 25 Mar 2024 22:31:13 +0800
Subject: fix(ext/fetch): do not truncate field value in `EventSource` (#22368)

Depends on #22493. Closes #22367.
---
 tests/integration/js_unit_tests.rs |  1 +
 tests/unit/event_source_test.ts    | 27 +++++++++++++++++++++++++++
 2 files changed, 28 insertions(+)
 create mode 100644 tests/unit/event_source_test.ts

(limited to 'tests')

diff --git a/tests/integration/js_unit_tests.rs b/tests/integration/js_unit_tests.rs
index d96af78d8..2bf78034e 100644
--- a/tests/integration/js_unit_tests.rs
+++ b/tests/integration/js_unit_tests.rs
@@ -30,6 +30,7 @@ util::unit_test_factory!(
     error_stack_test,
     error_test,
     esnext_test,
+    event_source_test,
     event_target_test,
     event_test,
     fetch_test,
diff --git a/tests/unit/event_source_test.ts b/tests/unit/event_source_test.ts
new file mode 100644
index 000000000..242c12d6e
--- /dev/null
+++ b/tests/unit/event_source_test.ts
@@ -0,0 +1,27 @@
+// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license.
+import { assertStrictEquals } from "./test_util.ts";
+
+Deno.test(
+  { permissions: { net: ["127.0.0.1"] } },
+  async function eventSourceColonInMessage() {
+    const portDeferred = Promise.withResolvers<number>();
+
+    await using _server = Deno.serve({
+      handler: () =>
+        new Response('data: {"key":"value"}\n\n', {
+          headers: { "content-type": "text/event-stream" },
+        }),
+      onListen: ({ port }) => portDeferred.resolve(port),
+      hostname: "127.0.0.1",
+      port: 0,
+    });
+
+    const port = await portDeferred.promise;
+    const eventSource = new EventSource(`http://127.0.0.1:${port}/`);
+    const event = await new Promise<MessageEvent>((resolve) =>
+      eventSource.onmessage = resolve
+    );
+    eventSource.close();
+    assertStrictEquals(event.data, '{"key":"value"}');
+  },
+);
-- 
cgit v1.2.3