From 9802cf07bdf8caa10f9c0658cc10f944b95f4258 Mon Sep 17 00:00:00 2001
From: Kenneth Myhra <kennethmyhra@gmail.com>
Date: Sun, 7 Apr 2024 13:02:12 +0200
Subject: [PATCH] Tests/LibWeb: Add test to prove we can pipe through a
 transform stream

---
 .../Streams/ReadableStream-pipeThrough.txt    |  3 +
 .../Streams/ReadableStream-pipeThrough.html   | 57 +++++++++++++++++++
 2 files changed, 60 insertions(+)
 create mode 100644 Tests/LibWeb/Text/expected/Streams/ReadableStream-pipeThrough.txt
 create mode 100644 Tests/LibWeb/Text/input/Streams/ReadableStream-pipeThrough.html

diff --git a/Tests/LibWeb/Text/expected/Streams/ReadableStream-pipeThrough.txt b/Tests/LibWeb/Text/expected/Streams/ReadableStream-pipeThrough.txt
new file mode 100644
index 00000000000..5a7ddc3fd27
--- /dev/null
+++ b/Tests/LibWeb/Text/expected/Streams/ReadableStream-pipeThrough.txt
@@ -0,0 +1,3 @@
+WELL,
+HELLO
+FRIENDS!
diff --git a/Tests/LibWeb/Text/input/Streams/ReadableStream-pipeThrough.html b/Tests/LibWeb/Text/input/Streams/ReadableStream-pipeThrough.html
new file mode 100644
index 00000000000..dbb55131ee1
--- /dev/null
+++ b/Tests/LibWeb/Text/input/Streams/ReadableStream-pipeThrough.html
@@ -0,0 +1,57 @@
+<script src="../include.js"></script>
+<script>
+    const CHUNK1 =  "well,";
+    const CHUNK2 =  "hello";
+    const CHUNK3 =  "friends!";
+
+    asyncTest((done) => {
+        const transformStream = new TransformStream({
+            transform(chunk, controller) {
+                controller.enqueue(
+                    new TextDecoder("utf-8")
+                        .decode(chunk)
+                        .toUpperCase()
+                );
+            }
+        });
+
+        const stream = new ReadableStream({
+            start(controller) {
+                pullCount = 0;
+            },
+
+            pull(controller) {
+                const textEncoder = new TextEncoder();
+
+                ++pullCount;
+
+                if (pullCount == 1) {
+                    controller.enqueue(textEncoder.encode(CHUNK1));
+                } else if (pullCount == 2) {
+                    controller.enqueue(textEncoder.encode(CHUNK2));
+                } else if (pullCount == 3) {
+                    controller.enqueue(textEncoder.encode(CHUNK3));
+                } else {
+                    controller.close();
+                }
+            },
+
+            cancel() {},
+        });
+
+
+        const reader = transformStream.readable.getReader();
+        reader.read().then(function processText({done, value}) {
+            if (done)
+                return;
+
+            println(value);
+            reader.read().then(processText);
+        }).then(() => {
+            done();
+        });
+
+        stream.pipeThrough(transformStream);
+
+    });
+</script>