formatting

Author: kuhe

packages/util-stream/src/checksum/createChecksumStream.browser.spec.ts

@@ -7,84 +7,87 @@ import { headStream } from "../headStream.browser";
 import { ChecksumStream as ChecksumStreamWeb } from "./ChecksumStream.browser";
 import { createChecksumStream } from "./createChecksumStream.browser";
 
-(typeof ReadableStream === "function" && process.version >= "v18" ? describe : describe.skip)("Checksum streams", () => {
-  /**
-   * Hash "algorithm" that appends all data together.
-   */
-  class Appender implements Checksum {
-    public hash = "";
-    async digest(): Promise<Uint8Array> {
-      return Buffer.from(this.hash);
-    }
-    reset(): void {
-      throw new Error("Function not implemented.");
-    }
-    update(chunk: Uint8Array): void {
-      this.hash += toUtf8(chunk);
+(typeof ReadableStream === "function" && process.version >= "v18" ? describe : describe.skip)(
+  "Checksum streams",
+  () => {
+    /**
+     * Hash "algorithm" that appends all data together.
+     */
+    class Appender implements Checksum {
+      public hash = "";
+      async digest(): Promise<Uint8Array> {
+        return Buffer.from(this.hash);
+      }
+      reset(): void {
+        throw new Error("Function not implemented.");
+      }
+      update(chunk: Uint8Array): void {
+        this.hash += toUtf8(chunk);
+      }
     }
-  }
 
-  const canonicalData = new Uint8Array("abcdefghijklmnopqrstuvwxyz".split("").map((_) => _.charCodeAt(0)));
+    const canonicalData = new Uint8Array("abcdefghijklmnopqrstuvwxyz".split("").map((_) => _.charCodeAt(0)));
 
-  const canonicalUtf8 = toUtf8(canonicalData);
-  const canonicalBase64 = toBase64(canonicalUtf8);
-
-  describe(createChecksumStream.name + " webstreams API", () => {
-    if (typeof ReadableStream !== "function") {
-      // test not applicable to Node.js 16.
-      return;
-    }
+    const canonicalUtf8 = toUtf8(canonicalData);
+    const canonicalBase64 = toBase64(canonicalUtf8);
 
-    const makeStream = () => {
-      return new ReadableStream({
-        start(controller) {
-          canonicalData.forEach((byte) => {
-            controller.enqueue(new Uint8Array([byte]));
-          });
-          controller.close();
-        },
-      });
-    };
+    describe(createChecksumStream.name + " webstreams API", () => {
+      if (typeof ReadableStream !== "function") {
+        // test not applicable to Node.js 16.
+        return;
+      }
 
-    it("should extend a ReadableStream", async () => {
-      const stream = makeStream();
-      const checksumStream = createChecksumStream({
-        expectedChecksum: canonicalBase64,
-        checksum: new Appender(),
-        checksumSourceLocation: "my-header",
-        source: stream,
-      });
+      const makeStream = () => {
+        return new ReadableStream({
+          start(controller) {
+            canonicalData.forEach((byte) => {
+              controller.enqueue(new Uint8Array([byte]));
+            });
+            controller.close();
+          },
+        });
+      };
 
-      expect(checksumStream).toBeInstanceOf(ReadableStream);
-      expect(checksumStream).toBeInstanceOf(ChecksumStreamWeb);
+      it("should extend a ReadableStream", async () => {
+        const stream = makeStream();
+        const checksumStream = createChecksumStream({
+          expectedChecksum: canonicalBase64,
+          checksum: new Appender(),
+          checksumSourceLocation: "my-header",
+          source: stream,
+        });
 
-      const collected = toUtf8(await headStream(checksumStream, Infinity));
-      expect(collected).toEqual(canonicalUtf8);
-      expect(stream.locked).toEqual(true);
+        expect(checksumStream).toBeInstanceOf(ReadableStream);
+        expect(checksumStream).toBeInstanceOf(ChecksumStreamWeb);
 
-      // expectation is that it is resolved.
-      expect(await checksumStream.getReader().closed);
-    });
+        const collected = toUtf8(await headStream(checksumStream, Infinity));
+        expect(collected).toEqual(canonicalUtf8);
+        expect(stream.locked).toEqual(true);
 
-    it("should throw during stream read if the checksum does not match", async () => {
-      const stream = makeStream();
-      const checksumStream = createChecksumStream({
-        expectedChecksum: "different-expected-checksum",
-        checksum: new Appender(),
-        checksumSourceLocation: "my-header",
-        source: stream,
+        // expectation is that it is resolved.
+        expect(await checksumStream.getReader().closed);
       });
 
-      try {
-        toUtf8(await headStream(checksumStream, Infinity));
-        throw new Error("stream was read successfully");
-      } catch (e: unknown) {
-        expect(String(e)).toEqual(
-          `Error: Checksum mismatch: expected "different-expected-checksum" but` +
-            ` received "${canonicalBase64}"` +
-            ` in response header "my-header".`
-        );
-      }
+      it("should throw during stream read if the checksum does not match", async () => {
+        const stream = makeStream();
+        const checksumStream = createChecksumStream({
+          expectedChecksum: "different-expected-checksum",
+          checksum: new Appender(),
+          checksumSourceLocation: "my-header",
+          source: stream,
+        });
+
+        try {
+          toUtf8(await headStream(checksumStream, Infinity));
+          throw new Error("stream was read successfully");
+        } catch (e: unknown) {
+          expect(String(e)).toEqual(
+            `Error: Checksum mismatch: expected "different-expected-checksum" but` +
+              ` received "${canonicalBase64}"` +
+              ` in response header "my-header".`
+          );
+        }
+      });
     });
-  });
-});
+  }
+);