Add unit tests for Node support

CHANGELOG.md

@@ -12,8 +12,9 @@
 ## Unreleased
 
 * 👓 Align with [spec version `ae5e0cb`](https://github.com/whatwg/streams/tree/ae5e0cb41e9f72cdd97f3a6d47bc674c1f4049d1/) ([#33](https://github.com/MattiasBuelens/web-streams-polyfill/pull/33))
-* 💅 Accept polyfilled `AbortSignal`s. ([#36](https://github.com/MattiasBuelens/web-streams-polyfill/pull/36))
-* 💅 Polyfill `DOMException` if necessary. ([#37](https://github.com/MattiasBuelens/web-streams-polyfill/pull/37))
+* 🐛 Fix support for non-browser environments, such as Node.
+  * Accept polyfilled `AbortSignal`s. ([#36](https://github.com/MattiasBuelens/web-streams-polyfill/pull/36))
+  * Polyfill `DOMException` if necessary. ([#37](https://github.com/MattiasBuelens/web-streams-polyfill/pull/37))
 
 ## v2.0.4 (2019-08-01)
 

CONTRIBUTING.md

@@ -11,6 +11,7 @@
 - `npm test` runs the two test suites:
   - `npm run test:wpt` runs the [Web Platform Tests for Streams][wpt-streams] against the generated JavaScript bundle, to verify that the polyfill's run-time behavior matches the specification.
   - `npm run test:types` runs the TypeScript compiler against some reference code that uses the generated type definitions, to verify that the code successfully passes the type check.
+  - `npm run test:unit` runs a few unit tests in a Node environment, to verify that the polyfill also works without a browser environment.
 
 ## Miscellaneous
 

etc/web-streams-polyfill.api.md

@@ -36,16 +36,6 @@ export class CountQueuingStrategy implements QueuingStrategy<any> {
     size(): 1;
 }
 
-// Warning: (ae-forgotten-export) The symbol "DOMExceptionClass" needs to be exported by the entry point polyfill.d.ts
-// 
-// @public (undocumented)
-export type DOMException = DOMExceptionClass;
-
-// Warning: (ae-forgotten-export) The symbol "DOMExceptionConstructor" needs to be exported by the entry point polyfill.d.ts
-// 
-// @public (undocumented)
-export const DOMException: DOMExceptionConstructor;
-
 // @public (undocumented)
 export interface PipeOptions {
     // (undocumented)

package.json

@@ -7,10 +7,11 @@
   "module": "dist/polyfill.mjs",
   "types": "dist/types/polyfill.d.ts",
   "scripts": {
-    "test": "npm run test:types && npm run test:wpt",
+    "test": "npm run test:types && npm run test:unit && npm run test:wpt",
     "test:wpt": "node --expose_gc ./test/run-web-platform-tests.js",
     "pretest:wpt": "git submodule update --init --recursive",
     "test:types": "tsc -p ./test/types/tsconfig.json",
+    "test:unit": "jasmine --config=test/unit/jasmine.json",
     "lint": "eslint \"src/**/*.ts\"",
     "build": "npm run build:bundle && npm run build:types",
     "build:bundle": "rollup -c",
@@ -50,6 +51,7 @@
     "@typescript-eslint/eslint-plugin": "^1.13.0",
     "@typescript-eslint/parser": "^1.13.0",
     "eslint": "^6.1.0",
+    "jasmine": "^3.5.0",
     "micromatch": "^4.0.2",
     "rollup": "^1.18.0",
     "rollup-plugin-inject": "^3.0.1",

src/ponyfill.ts

@@ -22,7 +22,6 @@ import ByteLengthQueuingStrategy from './lib/byte-length-queuing-strategy';
 import CountQueuingStrategy from './lib/count-queuing-strategy';
 import { Transformer, TransformStream, TransformStreamDefaultControllerType } from './lib/transform-stream';
 import { AbortSignal } from './lib/abort-signal';
-import { DOMException } from './stub/dom-exception';
 
 export {
   ReadableStream,
@@ -50,6 +49,5 @@ export {
   Transformer,
   TransformStreamDefaultControllerType as TransformStreamDefaultController,
 
-  AbortSignal,
-  DOMException
+  AbortSignal
 };

src/stub/native.ts

@@ -1,2 +1,2 @@
 /// <reference lib="dom" />
-export let NativeDOMException: typeof DOMException | undefined = typeof DOMException !== 'undefined' ? DOMException : undefined;
+export const NativeDOMException: typeof DOMException | undefined = typeof DOMException !== 'undefined' ? DOMException : undefined;

test/.eslintrc.json

@@ -0,0 +1,6 @@
+{
+  "extends": ["../.eslintrc.json"],
+  "rules": {
+    "@typescript-eslint/no-var-requires": "off"
+  }
+}

test/unit/.eslintrc.json

@@ -0,0 +1,6 @@
+{
+  "extends": ["../.eslintrc.json"],
+  "env": {
+    "jasmine": true
+  }
+}

test/unit/jasmine.json

@@ -0,0 +1,9 @@
+{
+  "spec_dir": "test/unit/",
+  "spec_files": [
+    "**/*[sS]pec.js"
+  ],
+  "helpers": [
+    "helpers/**/*.js"
+  ]
+}

test/unit/readable-stream/basic.spec.js

@@ -0,0 +1,57 @@
+const { ReadableStream, WritableStream } = require('../../../');
+const { FakeAbortSignal } = require('../util/fake-abort-signal');
+
+describe('ReadableStream', () => {
+  describe('constructor', () => {
+    it('constructs with no arguments', () => {
+      const rs = new ReadableStream();
+      expect(rs instanceof ReadableStream).toBe(true);
+    });
+  });
+
+  describe('getReader', () => {
+    it('reads chunks from underlying source', async () => {
+      const rs = new ReadableStream({
+        start(c) {
+          c.enqueue('a');
+          c.enqueue('b');
+          c.close();
+        }
+      });
+      const reader = rs.getReader();
+      expect(await reader.read()).toEqual({ done: false, value: 'a' });
+      expect(await reader.read()).toEqual({ done: false, value: 'b' });
+      expect(await reader.read()).toEqual({ done: true, value: undefined });
+    });
+  });
+
+  describe('pipeTo', () => {
+    it('accepts an abort signal', async () => {
+      const rs = new ReadableStream({
+        start(c) {
+          c.enqueue('a');
+          c.close();
+        }
+      });
+      const ws = new WritableStream();
+      const signal = new FakeAbortSignal(false);
+      await rs.pipeTo(ws, { signal });
+    });
+    it('rejects with an AbortError when aborted', async () => {
+      const rs = new ReadableStream({
+        start(c) {
+          c.enqueue('a');
+          c.close();
+        }
+      });
+      const ws = new WritableStream();
+      const signal = new FakeAbortSignal(true);
+      try {
+        await rs.pipeTo(ws, { signal });
+        fail('should have rejected');
+      } catch (e) {
+        expect(e.name).toBe('AbortError');
+      }
+    });
+  });
+});

test/unit/util/fake-abort-signal.js

@@ -0,0 +1,17 @@
+class FakeAbortSignal {
+  constructor(aborted) {
+    this.aborted = aborted;
+  }
+
+  addEventListener(type, listener) {
+    return;
+  }
+
+  removeEventListener(type, listener) {
+    return;
+  }
+}
+
+module.exports = {
+  FakeAbortSignal
+};