chore: move logging of input/request to serde

Author: trivikr

packages/middleware-logger/src/loggerMiddleware.ts

@@ -26,9 +26,6 @@ export const loggerMiddleware = () => <Output extends MetadataBearer = MetadataB
   } = response;
 
   if (typeof logger.debug === "function") {
-    logger.debug({
-      httpRequest: args.request,
-    });
     logger.debug({
       httpResponse: response.response,
     });
@@ -37,7 +34,6 @@ export const loggerMiddleware = () => <Output extends MetadataBearer = MetadataB
   if (typeof logger.info === "function") {
     logger.info({
       $metadata,
-      input: inputFilterSensitiveLog(args.input),
       output: outputFilterSensitiveLog(outputWithoutMetadata),
     });
   }

packages/middleware-serde/src/serializerMiddleware.ts

@@ -1,23 +1,40 @@
 import {
   EndpointBearer,
+  HandlerExecutionContext,
   RequestSerializer,
   SerializeHandler,
   SerializeHandlerArguments,
   SerializeHandlerOutput,
   SerializeMiddleware,
 } from "@aws-sdk/types";
 
-export function serializerMiddleware<Input extends object, Output extends object, RuntimeUtils extends EndpointBearer>(
+export const serializerMiddleware = <Input extends object, Output extends object, RuntimeUtils extends EndpointBearer>(
   options: RuntimeUtils,
   serializer: RequestSerializer<any, RuntimeUtils>
-): SerializeMiddleware<Input, Output> {
-  return (next: SerializeHandler<Input, Output>): SerializeHandler<Input, Output> => async (
-    args: SerializeHandlerArguments<Input>
-  ): Promise<SerializeHandlerOutput<Output>> => {
-    const request = await serializer(args.input, options);
-    return next({
-      ...args,
-      request,
+): SerializeMiddleware<Input, Output> => (
+  next: SerializeHandler<Input, Output>,
+  context: HandlerExecutionContext
+): SerializeHandler<Input, Output> => async (
+  args: SerializeHandlerArguments<Input>
+): Promise<SerializeHandlerOutput<Output>> => {
+  const { logger, inputFilterSensitiveLog } = context;
+
+  if (typeof logger?.info === "function") {
+    logger.info({
+      input: inputFilterSensitiveLog(args.input),
     });
-  };
-}
+  }
+
+  const request = await serializer(args.input, options);
+
+  if (typeof logger?.debug === "function") {
+    logger.debug({
+      httpRequest: request,
+    });
+  }
+
+  return next({
+    ...args,
+    request,
+  });
+};