feat(eventstream-serde-config-resolver): simplify and add tests (#1403)

packages/eventstream-serde-config-resolver/jest.config.js

@@ -0,0 +1,5 @@
+const base = require("../../jest.config.base.js");
+
+module.exports = {
+  ...base,
+};

packages/eventstream-serde-config-resolver/src/EventStreamSerdeConfig.spec.ts

@@ -0,0 +1,19 @@
+import { resolveEventStreamSerdeConfig } from "./EventStreamSerdeConfig";
+
+describe("resolveEventStreamSerdeConfig", () => {
+  const eventStreamSerdeProvider = jest.fn();
+
+  afterEach(() => {
+    jest.clearAllMocks();
+  });
+
+  it("sets value returned by eventStreamSerdeProvider", () => {
+    const mockReturn = "mockReturn";
+    eventStreamSerdeProvider.mockReturnValueOnce(mockReturn);
+
+    const input = { eventStreamSerdeProvider };
+    expect(resolveEventStreamSerdeConfig(input).eventStreamMarshaller).toStrictEqual(mockReturn);
+    expect(eventStreamSerdeProvider).toHaveBeenCalledTimes(1);
+    expect(eventStreamSerdeProvider).toHaveBeenCalledWith(input);
+  });
+});

packages/eventstream-serde-config-resolver/src/EventStreamSerdeConfig.ts

@@ -0,0 +1,18 @@
+import { EventStreamMarshaller, EventStreamSerdeProvider } from "@aws-sdk/types";
+
+export interface EventStreamSerdeInputConfig {}
+
+export interface EventStreamSerdeResolvedConfig {
+  eventStreamMarshaller: EventStreamMarshaller;
+}
+
+interface PreviouslyResolved {
+  eventStreamSerdeProvider: EventStreamSerdeProvider;
+}
+
+export const resolveEventStreamSerdeConfig = <T>(
+  input: T & PreviouslyResolved & EventStreamSerdeInputConfig
+): T & EventStreamSerdeResolvedConfig => ({
+  ...input,
+  eventStreamMarshaller: input.eventStreamSerdeProvider(input),
+});

packages/eventstream-serde-config-resolver/src/index.ts

@@ -1,21 +1 @@
-import { Decoder, Encoder, EventStreamMarshaller, EventStreamSerdeProvider } from "@aws-sdk/types";
-export interface EventStreamSerdeInputConfig {}
-
-export interface EventStreamSerdeResolvedConfig {
-  eventStreamMarshaller: EventStreamMarshaller;
-}
-
-interface PreviouslyResolved {
-  utf8Encoder: Encoder;
-  utf8Decoder: Decoder;
-  eventStreamSerdeProvider: EventStreamSerdeProvider;
-}
-
-export function resolveEventStreamSerdeConfig<T>(
-  input: T & PreviouslyResolved & EventStreamSerdeInputConfig
-): T & EventStreamSerdeResolvedConfig {
-  return {
-    ...input,
-    eventStreamMarshaller: input.eventStreamSerdeProvider({ ...input }),
-  };
-}
+export * from "./EventStreamSerdeConfig";