feat(smithy-client): use collectBody from smithy-client

clients/client-accessanalyzer/src/protocols/Aws_restJson1.ts

@@ -1,6 +1,7 @@
 // smithy-typescript generated code
 import {
   _json,
+  collectBody,
   decorateServiceException as __decorateServiceException,
   expectBoolean as __expectBoolean,
   expectNonNull as __expectNonNull,
@@ -15,7 +16,6 @@ import {
   withBaseException,
 } from "@aws-sdk/smithy-client";
 import { ResponseMetadata as __ResponseMetadata } from "@aws-sdk/types";
-import { Uint8ArrayBlobAdapter as __Uint8ArrayBlobAdapter } from "@aws-sdk/util-stream";
 import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http";
 import { Endpoint as __Endpoint, SerdeContext as __SerdeContext } from "@smithy/types";
 import { v4 as generateIdempotencyToken } from "uuid";
@@ -3323,17 +3323,6 @@ const deserializeMetadata = (output: __HttpResponse): __ResponseMetadata => ({
   cfId: output.headers["x-amz-cf-id"],
 });
 
-// Collect low-level response body stream to Uint8Array.
-const collectBody = async (
-  streamBody: any = new Uint8Array(),
-  context: __SerdeContext
-): Promise<__Uint8ArrayBlobAdapter> => {
-  if (streamBody instanceof Uint8Array) {
-    return __Uint8ArrayBlobAdapter.mutate(streamBody);
-  }
-  return __Uint8ArrayBlobAdapter.mutate(await context.streamCollector(streamBody)) || new __Uint8ArrayBlobAdapter();
-};
-
 // Encode Uint8Array data into string with utf-8.
 const collectBodyString = (streamBody: any, context: __SerdeContext): Promise<string> =>
   collectBody(streamBody, context).then((body) => context.utf8Encoder(body));

clients/client-account/src/protocols/Aws_restJson1.ts

@@ -1,6 +1,7 @@
 // smithy-typescript generated code
 import {
   _json,
+  collectBody,
   decorateServiceException as __decorateServiceException,
   expectNonNull as __expectNonNull,
   expectObject as __expectObject,
@@ -10,7 +11,6 @@ import {
   withBaseException,
 } from "@aws-sdk/smithy-client";
 import { ResponseMetadata as __ResponseMetadata } from "@aws-sdk/types";
-import { Uint8ArrayBlobAdapter as __Uint8ArrayBlobAdapter } from "@aws-sdk/util-stream";
 import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http";
 import { Endpoint as __Endpoint, SerdeContext as __SerdeContext } from "@smithy/types";
 
@@ -968,17 +968,6 @@ const deserializeMetadata = (output: __HttpResponse): __ResponseMetadata => ({
   cfId: output.headers["x-amz-cf-id"],
 });
 
-// Collect low-level response body stream to Uint8Array.
-const collectBody = async (
-  streamBody: any = new Uint8Array(),
-  context: __SerdeContext
-): Promise<__Uint8ArrayBlobAdapter> => {
-  if (streamBody instanceof Uint8Array) {
-    return __Uint8ArrayBlobAdapter.mutate(streamBody);
-  }
-  return __Uint8ArrayBlobAdapter.mutate(await context.streamCollector(streamBody)) || new __Uint8ArrayBlobAdapter();
-};
-
 // Encode Uint8Array data into string with utf-8.
 const collectBodyString = (streamBody: any, context: __SerdeContext): Promise<string> =>
   collectBody(streamBody, context).then((body) => context.utf8Encoder(body));

clients/client-acm-pca/src/protocols/Aws_json1_1.ts

@@ -1,6 +1,7 @@
 // smithy-typescript generated code
 import {
   _json,
+  collectBody,
   decorateServiceException as __decorateServiceException,
   expectNonNull as __expectNonNull,
   expectNumber as __expectNumber,
@@ -10,7 +11,6 @@ import {
   withBaseException,
 } from "@aws-sdk/smithy-client";
 import { HeaderBag as __HeaderBag, ResponseMetadata as __ResponseMetadata } from "@aws-sdk/types";
-import { Uint8ArrayBlobAdapter as __Uint8ArrayBlobAdapter } from "@aws-sdk/util-stream";
 import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http";
 import { Endpoint as __Endpoint, SerdeContext as __SerdeContext } from "@smithy/types";
 
@@ -2377,17 +2377,6 @@ const deserializeMetadata = (output: __HttpResponse): __ResponseMetadata => ({
   cfId: output.headers["x-amz-cf-id"],
 });
 
-// Collect low-level response body stream to Uint8Array.
-const collectBody = async (
-  streamBody: any = new Uint8Array(),
-  context: __SerdeContext
-): Promise<__Uint8ArrayBlobAdapter> => {
-  if (streamBody instanceof Uint8Array) {
-    return __Uint8ArrayBlobAdapter.mutate(streamBody);
-  }
-  return __Uint8ArrayBlobAdapter.mutate(await context.streamCollector(streamBody)) || new __Uint8ArrayBlobAdapter();
-};
-
 // Encode Uint8Array data into string with utf-8.
 const collectBodyString = (streamBody: any, context: __SerdeContext): Promise<string> =>
   collectBody(streamBody, context).then((body) => context.utf8Encoder(body));

clients/client-acm/src/protocols/Aws_json1_1.ts

@@ -1,6 +1,7 @@
 // smithy-typescript generated code
 import {
   _json,
+  collectBody,
   decorateServiceException as __decorateServiceException,
   expectBoolean as __expectBoolean,
   expectNonNull as __expectNonNull,
@@ -11,7 +12,6 @@ import {
   withBaseException,
 } from "@aws-sdk/smithy-client";
 import { HeaderBag as __HeaderBag, ResponseMetadata as __ResponseMetadata } from "@aws-sdk/types";
-import { Uint8ArrayBlobAdapter as __Uint8ArrayBlobAdapter } from "@aws-sdk/util-stream";
 import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http";
 import { Endpoint as __Endpoint, SerdeContext as __SerdeContext } from "@smithy/types";
 
@@ -1599,17 +1599,6 @@ const deserializeMetadata = (output: __HttpResponse): __ResponseMetadata => ({
   cfId: output.headers["x-amz-cf-id"],
 });
 
-// Collect low-level response body stream to Uint8Array.
-const collectBody = async (
-  streamBody: any = new Uint8Array(),
-  context: __SerdeContext
-): Promise<__Uint8ArrayBlobAdapter> => {
-  if (streamBody instanceof Uint8Array) {
-    return __Uint8ArrayBlobAdapter.mutate(streamBody);
-  }
-  return __Uint8ArrayBlobAdapter.mutate(await context.streamCollector(streamBody)) || new __Uint8ArrayBlobAdapter();
-};
-
 // Encode Uint8Array data into string with utf-8.
 const collectBodyString = (streamBody: any, context: __SerdeContext): Promise<string> =>
   collectBody(streamBody, context).then((body) => context.utf8Encoder(body));

clients/client-alexa-for-business/src/protocols/Aws_json1_1.ts

@@ -1,6 +1,7 @@
 // smithy-typescript generated code
 import {
   _json,
+  collectBody,
   decorateServiceException as __decorateServiceException,
   expectInt32 as __expectInt32,
   expectNonNull as __expectNonNull,
@@ -11,7 +12,6 @@ import {
   withBaseException,
 } from "@aws-sdk/smithy-client";
 import { HeaderBag as __HeaderBag, ResponseMetadata as __ResponseMetadata } from "@aws-sdk/types";
-import { Uint8ArrayBlobAdapter as __Uint8ArrayBlobAdapter } from "@aws-sdk/util-stream";
 import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http";
 import { Endpoint as __Endpoint, SerdeContext as __SerdeContext } from "@smithy/types";
 import { v4 as generateIdempotencyToken } from "uuid";
@@ -7152,17 +7152,6 @@ const deserializeMetadata = (output: __HttpResponse): __ResponseMetadata => ({
   cfId: output.headers["x-amz-cf-id"],
 });
 
-// Collect low-level response body stream to Uint8Array.
-const collectBody = async (
-  streamBody: any = new Uint8Array(),
-  context: __SerdeContext
-): Promise<__Uint8ArrayBlobAdapter> => {
-  if (streamBody instanceof Uint8Array) {
-    return __Uint8ArrayBlobAdapter.mutate(streamBody);
-  }
-  return __Uint8ArrayBlobAdapter.mutate(await context.streamCollector(streamBody)) || new __Uint8ArrayBlobAdapter();
-};
-
 // Encode Uint8Array data into string with utf-8.
 const collectBodyString = (streamBody: any, context: __SerdeContext): Promise<string> =>
   collectBody(streamBody, context).then((body) => context.utf8Encoder(body));

clients/client-amp/src/protocols/Aws_restJson1.ts

@@ -1,6 +1,7 @@
 // smithy-typescript generated code
 import {
   _json,
+  collectBody,
   decorateServiceException as __decorateServiceException,
   expectNonNull as __expectNonNull,
   expectNumber as __expectNumber,
@@ -15,7 +16,6 @@ import {
   withBaseException,
 } from "@aws-sdk/smithy-client";
 import { ResponseMetadata as __ResponseMetadata } from "@aws-sdk/types";
-import { Uint8ArrayBlobAdapter as __Uint8ArrayBlobAdapter } from "@aws-sdk/util-stream";
 import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http";
 import { Endpoint as __Endpoint, SerdeContext as __SerdeContext } from "@smithy/types";
 import { v4 as generateIdempotencyToken } from "uuid";
@@ -2264,17 +2264,6 @@ const deserializeMetadata = (output: __HttpResponse): __ResponseMetadata => ({
   cfId: output.headers["x-amz-cf-id"],
 });
 
-// Collect low-level response body stream to Uint8Array.
-const collectBody = async (
-  streamBody: any = new Uint8Array(),
-  context: __SerdeContext
-): Promise<__Uint8ArrayBlobAdapter> => {
-  if (streamBody instanceof Uint8Array) {
-    return __Uint8ArrayBlobAdapter.mutate(streamBody);
-  }
-  return __Uint8ArrayBlobAdapter.mutate(await context.streamCollector(streamBody)) || new __Uint8ArrayBlobAdapter();
-};
-
 // Encode Uint8Array data into string with utf-8.
 const collectBodyString = (streamBody: any, context: __SerdeContext): Promise<string> =>
   collectBody(streamBody, context).then((body) => context.utf8Encoder(body));

clients/client-amplify/src/protocols/Aws_restJson1.ts

@@ -1,6 +1,7 @@
 // smithy-typescript generated code
 import {
   _json,
+  collectBody,
   decorateServiceException as __decorateServiceException,
   expectBoolean as __expectBoolean,
   expectNonNull as __expectNonNull,
@@ -15,7 +16,6 @@ import {
   withBaseException,
 } from "@aws-sdk/smithy-client";
 import { ResponseMetadata as __ResponseMetadata } from "@aws-sdk/types";
-import { Uint8ArrayBlobAdapter as __Uint8ArrayBlobAdapter } from "@aws-sdk/util-stream";
 import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http";
 import { Endpoint as __Endpoint, SerdeContext as __SerdeContext } from "@smithy/types";
 
@@ -3778,17 +3778,6 @@ const deserializeMetadata = (output: __HttpResponse): __ResponseMetadata => ({
   cfId: output.headers["x-amz-cf-id"],
 });
 
-// Collect low-level response body stream to Uint8Array.
-const collectBody = async (
-  streamBody: any = new Uint8Array(),
-  context: __SerdeContext
-): Promise<__Uint8ArrayBlobAdapter> => {
-  if (streamBody instanceof Uint8Array) {
-    return __Uint8ArrayBlobAdapter.mutate(streamBody);
-  }
-  return __Uint8ArrayBlobAdapter.mutate(await context.streamCollector(streamBody)) || new __Uint8ArrayBlobAdapter();
-};
-
 // Encode Uint8Array data into string with utf-8.
 const collectBodyString = (streamBody: any, context: __SerdeContext): Promise<string> =>
   collectBody(streamBody, context).then((body) => context.utf8Encoder(body));

clients/client-amplifybackend/src/protocols/Aws_restJson1.ts

@@ -1,6 +1,7 @@
 // smithy-typescript generated code
 import {
   _json,
+  collectBody,
   decorateServiceException as __decorateServiceException,
   expectBoolean as __expectBoolean,
   expectNonNull as __expectNonNull,
@@ -14,7 +15,6 @@ import {
   withBaseException,
 } from "@aws-sdk/smithy-client";
 import { ResponseMetadata as __ResponseMetadata } from "@aws-sdk/types";
-import { Uint8ArrayBlobAdapter as __Uint8ArrayBlobAdapter } from "@aws-sdk/util-stream";
 import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http";
 import { Endpoint as __Endpoint, SerdeContext as __SerdeContext } from "@smithy/types";
 
@@ -3892,17 +3892,6 @@ const deserializeMetadata = (output: __HttpResponse): __ResponseMetadata => ({
   cfId: output.headers["x-amz-cf-id"],
 });
 
-// Collect low-level response body stream to Uint8Array.
-const collectBody = async (
-  streamBody: any = new Uint8Array(),
-  context: __SerdeContext
-): Promise<__Uint8ArrayBlobAdapter> => {
-  if (streamBody instanceof Uint8Array) {
-    return __Uint8ArrayBlobAdapter.mutate(streamBody);
-  }
-  return __Uint8ArrayBlobAdapter.mutate(await context.streamCollector(streamBody)) || new __Uint8ArrayBlobAdapter();
-};
-
 // Encode Uint8Array data into string with utf-8.
 const collectBodyString = (streamBody: any, context: __SerdeContext): Promise<string> =>
   collectBody(streamBody, context).then((body) => context.utf8Encoder(body));

clients/client-amplifyuibuilder/src/protocols/Aws_restJson1.ts

@@ -1,6 +1,7 @@
 // smithy-typescript generated code
 import {
   _json,
+  collectBody,
   decorateServiceException as __decorateServiceException,
   expectBoolean as __expectBoolean,
   expectInt32 as __expectInt32,
@@ -18,7 +19,6 @@ import {
   withBaseException,
 } from "@aws-sdk/smithy-client";
 import { ResponseMetadata as __ResponseMetadata } from "@aws-sdk/types";
-import { Uint8ArrayBlobAdapter as __Uint8ArrayBlobAdapter } from "@aws-sdk/util-stream";
 import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http";
 import { Endpoint as __Endpoint, SerdeContext as __SerdeContext } from "@smithy/types";
 import { v4 as generateIdempotencyToken } from "uuid";
@@ -3706,17 +3706,6 @@ const deserializeMetadata = (output: __HttpResponse): __ResponseMetadata => ({
   cfId: output.headers["x-amz-cf-id"],
 });
 
-// Collect low-level response body stream to Uint8Array.
-const collectBody = async (
-  streamBody: any = new Uint8Array(),
-  context: __SerdeContext
-): Promise<__Uint8ArrayBlobAdapter> => {
-  if (streamBody instanceof Uint8Array) {
-    return __Uint8ArrayBlobAdapter.mutate(streamBody);
-  }
-  return __Uint8ArrayBlobAdapter.mutate(await context.streamCollector(streamBody)) || new __Uint8ArrayBlobAdapter();
-};
-
 // Encode Uint8Array data into string with utf-8.
 const collectBodyString = (streamBody: any, context: __SerdeContext): Promise<string> =>
   collectBody(streamBody, context).then((body) => context.utf8Encoder(body));

clients/client-api-gateway/package.json

@@ -50,6 +50,7 @@
     "@aws-sdk/util-defaults-mode-node": "*",
     "@aws-sdk/util-endpoints": "*",
     "@aws-sdk/util-retry": "*",
+    "@aws-sdk/util-stream": "*",
     "@aws-sdk/util-user-agent-browser": "*",
     "@aws-sdk/util-user-agent-node": "*",
     "@aws-sdk/util-utf8": "*",

clients/client-api-gateway/src/protocols/Aws_restJson1.ts

@@ -1,6 +1,7 @@
 // smithy-typescript generated code
 import {
   _json,
+  collectBody,
   convertMap,
   decorateServiceException as __decorateServiceException,
   expectBoolean as __expectBoolean,
@@ -20,7 +21,6 @@ import {
   withBaseException,
 } from "@aws-sdk/smithy-client";
 import { ResponseMetadata as __ResponseMetadata } from "@aws-sdk/types";
-import { Uint8ArrayBlobAdapter as __Uint8ArrayBlobAdapter } from "@aws-sdk/util-stream";
 import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http";
 import { Endpoint as __Endpoint, SerdeContext as __SerdeContext } from "@smithy/types";
 
@@ -12172,17 +12172,6 @@ const deserializeMetadata = (output: __HttpResponse): __ResponseMetadata => ({
   cfId: output.headers["x-amz-cf-id"],
 });
 
-// Collect low-level response body stream to Uint8Array.
-const collectBody = async (
-  streamBody: any = new Uint8Array(),
-  context: __SerdeContext
-): Promise<__Uint8ArrayBlobAdapter> => {
-  if (streamBody instanceof Uint8Array) {
-    return __Uint8ArrayBlobAdapter.mutate(streamBody);
-  }
-  return __Uint8ArrayBlobAdapter.mutate(await context.streamCollector(streamBody)) || new __Uint8ArrayBlobAdapter();
-};
-
 // Encode Uint8Array data into string with utf-8.
 const collectBodyString = (streamBody: any, context: __SerdeContext): Promise<string> =>
   collectBody(streamBody, context).then((body) => context.utf8Encoder(body));

clients/client-apigatewaymanagementapi/src/protocols/Aws_restJson1.ts

@@ -1,6 +1,7 @@
 // smithy-typescript generated code
 import {
   _json,
+  collectBody,
   decorateServiceException as __decorateServiceException,
   expectNonNull as __expectNonNull,
   expectObject as __expectObject,
@@ -12,7 +13,6 @@ import {
   withBaseException,
 } from "@aws-sdk/smithy-client";
 import { ResponseMetadata as __ResponseMetadata } from "@aws-sdk/types";
-import { Uint8ArrayBlobAdapter as __Uint8ArrayBlobAdapter } from "@aws-sdk/util-stream";
 import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@smithy/protocol-http";
 import { Endpoint as __Endpoint, SerdeContext as __SerdeContext } from "@smithy/types";
 
@@ -369,17 +369,6 @@ const deserializeMetadata = (output: __HttpResponse): __ResponseMetadata => ({
   cfId: output.headers["x-amz-cf-id"],
 });
 
-// Collect low-level response body stream to Uint8Array.
-const collectBody = async (
-  streamBody: any = new Uint8Array(),
-  context: __SerdeContext
-): Promise<__Uint8ArrayBlobAdapter> => {
-  if (streamBody instanceof Uint8Array) {
-    return __Uint8ArrayBlobAdapter.mutate(streamBody);
-  }
-  return __Uint8ArrayBlobAdapter.mutate(await context.streamCollector(streamBody)) || new __Uint8ArrayBlobAdapter();
-};
-
 // Encode Uint8Array data into string with utf-8.
 const collectBodyString = (streamBody: any, context: __SerdeContext): Promise<string> =>
   collectBody(streamBody, context).then((body) => context.utf8Encoder(body));

clients/client-apigatewayv2/package.json

@@ -49,6 +49,7 @@
     "@aws-sdk/util-defaults-mode-node": "*",
     "@aws-sdk/util-endpoints": "*",
     "@aws-sdk/util-retry": "*",
+    "@aws-sdk/util-stream": "*",
     "@aws-sdk/util-user-agent-browser": "*",
     "@aws-sdk/util-user-agent-node": "*",
     "@aws-sdk/util-utf8": "*",