chore: feature detection for gzip and endpoint override

Author: kuhe

.changeset/silent-rockets-turn.md

@@ -0,0 +1,7 @@
+---
+"@smithy/middleware-compression": minor
+"@smithy/middleware-endpoint": minor
+"@smithy/core": minor
+---
+
+feature detection for custom endpoint and gzip

packages/core/src/index.ts

@@ -4,4 +4,5 @@ export * from "./util-identity-and-auth";
 export * from "./getSmithyContext";
 export * from "./normalizeProvider";
 export * from "./protocols/requestBuilder";
+export * from "./setFeature";
 export { createPaginator } from "./pagination/createPaginator";

packages/middleware-compression/package.json

@@ -15,6 +15,7 @@
   "main": "./dist-cjs/index.js",
   "module": "./dist-es/index.js",
   "dependencies": {
+    "@smithy/core": "workspace:^",
     "@smithy/is-array-buffer": "workspace:^",
     "@smithy/node-config-provider": "workspace:^",
     "@smithy/protocol-http": "workspace:^",

packages/middleware-compression/src/compressionMiddleware.ts

@@ -1,3 +1,4 @@
+import { setFeature } from "@smithy/core";
 import { HttpRequest } from "@smithy/protocol-http";
 import {
   AbsoluteLocation,
@@ -6,6 +7,7 @@ import {
   BuildHandlerOptions,
   BuildHandlerOutput,
   BuildMiddleware,
+  HandlerExecutionContext,
   MetadataBearer,
 } from "@smithy/types";
 
@@ -39,7 +41,10 @@ export const compressionMiddleware =
     config: CompressionResolvedConfig & CompressionPreviouslyResolved,
     middlewareConfig: CompressionMiddlewareConfig
   ): BuildMiddleware<any, any> =>
-  <Output extends MetadataBearer>(next: BuildHandler<any, Output>): BuildHandler<any, Output> =>
+  <Output extends MetadataBearer>(
+    next: BuildHandler<any, Output>,
+    context: HandlerExecutionContext
+  ): BuildHandler<any, Output> =>
   async (args: BuildHandlerArguments<any>): Promise<BuildHandlerOutput<Output>> => {
     if (!HttpRequest.isInstance(args.request)) {
       return next(args);
@@ -88,6 +93,10 @@ export const compressionMiddleware =
             updatedHeaders = { ...headers, "content-encoding": algorithm };
           }
 
+          if (headers["content-encoding"].includes("gzip")) {
+            setFeature(context, "GZIP_REQUEST_COMPRESSION", "L");
+          }
+
           // We've matched on one supported algorithm in the
           // priority-ordered list, so we're finished.
           break;

packages/middleware-endpoint/package.json

@@ -23,6 +23,7 @@
   },
   "license": "Apache-2.0",
   "dependencies": {
+    "@smithy/core": "workspace:^",
     "@smithy/middleware-serde": "workspace:^",
     "@smithy/node-config-provider": "workspace:^",
     "@smithy/shared-ini-file-loader": "workspace:^",

packages/middleware-endpoint/src/endpointMiddleware.ts

@@ -1,3 +1,4 @@
+import { setFeature } from "@smithy/core";
 import {
   AuthScheme,
   EndpointParameters,
@@ -38,6 +39,10 @@ export const endpointMiddleware = <T extends EndpointParameters>({
       context: HandlerExecutionContext
     ): SerializeHandler<any, Output> =>
     async (args: SerializeHandlerArguments<any>): Promise<SerializeHandlerOutput<Output>> => {
+      if (config.endpoint) {
+        setFeature(context, "ENDPOINT_OVERRIDE", "N");
+      }
+
       const endpoint: EndpointV2 = await getEndpointFromInstructions(
         args.input,
         {