feat: move stream-collector-web into fetch-http-handler

Author: AllanZhengYP

package.json

@@ -15,7 +15,7 @@
     "build:smithy-client": "yarn build:crypto-dependencies && lerna run --scope '@aws-sdk/client-rds-data' --include-dependencies pretest",
     "build:all": "yarn build:crypto-dependencies && lerna run pretest --include-dependencies --include-dependents",
     "pretest:all": "yarn build:all",
-    "test:all": "jest --coverage --passWithNoTests && lerna run test --scope @aws-sdk/stream-collector-web --scope @aws-sdk/hash-blob-browser",
+    "test:all": "jest --coverage --passWithNoTests && lerna run test --scope @aws-sdk/fetch-http-handler --scope @aws-sdk/hash-blob-browser",
     "test:functional": "jest --config tests/functional/jest.config.js --passWithNoTests",
     "test:integration": "cucumber-js --fail-fast",
     "test:protocols": "yarn build:protocols && lerna run test --scope '@aws-sdk/aws-*'"

packages/fetch-http-handler/jest.config.js

@@ -1,5 +1,6 @@
 const base = require("../../jest.config.base.js");
 
 module.exports = {
-  ...base
+  ...base,
+  testPathIgnorePatterns: ["/node_modules/", "stream-collector.spec.js"]
 };

packages/stream-collector-web/karma.conf.js renamed to packages/fetch-http-handler/karma.conf.js

@@ -2,7 +2,7 @@ process.env.CHROME_BIN = require("puppeteer").executablePath();
 module.exports = function (config) {
   config.set({
     frameworks: ["jasmine", "karma-typescript"],
-    files: ["src/**/*.ts"],
+    files: ["src/stream-collector*.ts"],
     exclude: ["**/*.d.ts"],
     preprocessors: {
       "**/*.ts": "karma-typescript"

packages/fetch-http-handler/package.json

@@ -5,7 +5,7 @@
   "scripts": {
     "prepublishOnly": "tsc",
     "pretest": "tsc -p tsconfig.test.json",
-    "test": "jest --coverage"
+    "test": "jest --coverage && karma start karma.conf.js"
   },
   "author": {
     "name": "AWS SDK for JavaScript Team",
@@ -23,8 +23,13 @@
   "devDependencies": {
     "@aws-sdk/abort-controller": "1.0.0-beta.4",
     "@types/jest": "^25.1.4",
-    "@types/node": "^10.0.0",
-    "jest": "^25.1.0",
+    "jasmine-core": "^3.5.0",
+    "karma": "^4.4.1",
+    "karma-chrome-launcher": "^3.1.0",
+    "karma-jasmine": "^3.1.1",
+    "karma-typescript": "^4.1.1",
+    "puppeteer": "^3.0.1",
+    "source-map": "^0.7.3",
     "typescript": "~3.8.3"
   }
 }

packages/fetch-http-handler/src/index.ts

@@ -1 +1,2 @@
 export * from "./fetch-http-handler";
+export * from "./stream-collector";

packages/stream-collector-web/src/index.spec.ts renamed to packages/fetch-http-handler/src/stream-collector.spec.ts

@@ -1,4 +1,4 @@
-import { streamCollector } from "./index";
+import { streamCollector } from "./stream-collector";
 
 describe("streamCollector", () => {
   it("returns a Uint8Array from a blob", done => {

packages/stream-collector-web/src/index.ts renamed to packages/fetch-http-handler/src/stream-collector.ts

@@ -5,7 +5,7 @@ import { fromBase64 } from "@aws-sdk/util-base64-browser";
 export const streamCollector: StreamCollector = (
   stream: Blob | ReadableStream
 ): Promise<Uint8Array> => {
-  if(stream instanceof Blob) {
+  if (stream instanceof Blob) {
     return collectBlob(stream);
   }
 
@@ -22,9 +22,9 @@ async function collectStream(stream: ReadableStream): Promise<Uint8Array> {
   let res = new Uint8Array(0);
   const reader = stream.getReader();
   let isDone = false;
-  while(!isDone) {
+  while (!isDone) {
     const { done, value } = await reader.read();
-    if(value) {
+    if (value) {
       const prior = res;
       res = new Uint8Array(prior.length + value.length);
       res.set(prior);
@@ -53,4 +53,4 @@ function readToBase64(blob: Blob): Promise<string> {
     // reader.readAsArrayBuffer is not always available
     reader.readAsDataURL(blob);
   });
-}
+}