From 8ff52582cea9ed19a8025877d5f300cc49cc07de Mon Sep 17 00:00:00 2001
From: Kenneth Myhra <kennethmyhra@gmail.com>
Date: Sat, 6 Apr 2024 19:12:03 +0200
Subject: [PATCH] Tests/LibWeb: Add test to prove we can pipe to a
 WriteableStream

This proves our ability to pipe the current ReadableStream to a given
WriteableStream.
---
 .../Streams/ReadableStream-pipeTo.txt         |  3 ++
 .../input/Streams/ReadableStream-pipeTo.html  | 47 +++++++++++++++++++
 2 files changed, 50 insertions(+)
 create mode 100644 Tests/LibWeb/Text/expected/Streams/ReadableStream-pipeTo.txt
 create mode 100644 Tests/LibWeb/Text/input/Streams/ReadableStream-pipeTo.html

diff --git a/Tests/LibWeb/Text/expected/Streams/ReadableStream-pipeTo.txt b/Tests/LibWeb/Text/expected/Streams/ReadableStream-pipeTo.txt
new file mode 100644
index 00000000000..c0ed8252941
--- /dev/null
+++ b/Tests/LibWeb/Text/expected/Streams/ReadableStream-pipeTo.txt
@@ -0,0 +1,3 @@
+abcdefghijklmnopqrstuvwxyz
+ABCDEFGHIJKLMNOPQRSTUVWXYZ
+0123456789!@#$%^&*()-=_+,<
diff --git a/Tests/LibWeb/Text/input/Streams/ReadableStream-pipeTo.html b/Tests/LibWeb/Text/input/Streams/ReadableStream-pipeTo.html
new file mode 100644
index 00000000000..f689398566d
--- /dev/null
+++ b/Tests/LibWeb/Text/input/Streams/ReadableStream-pipeTo.html
@@ -0,0 +1,47 @@
+<script src="../include.js"></script>
+<script>
+    const CHUNK1 =  "abcdefghijklmnopqrstuvwxyz";
+    const CHUNK2 =  "ABCDEFGHIJKLMNOPQRSTUVWXYZ";
+    const CHUNK3 =  "0123456789!@#$%^&*()-=_+,<";
+
+    asyncTest(done => {
+        const writableStream = new WritableStream(
+            {
+                write(chunk) {
+                    return new Promise((resolve) => {
+                        const textDecoder = new TextDecoder("utf-8");
+                        println(textDecoder.decode(new Uint8Array(chunk)));
+                        resolve();
+                    });
+                }
+            }
+        );
+        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() {},
+        });
+
+        stream.pipeTo(writableStream).then(() => {
+            done();
+        });
+    });
+</script>