fix: generate response zod schemas

packages/client-axios/src/index.ts

@@ -64,8 +64,14 @@ export const createClient = (config: Config): Client => {
 
       let { data } = response;
 
-      if (opts.responseType === 'json' && opts.responseTransformer) {
-        data = await opts.responseTransformer(data);
+      if (opts.responseType === 'json') {
+        if (opts.responseValidator) {
+          await opts.responseValidator(data);
+        }
+
+        if (opts.responseTransformer) {
+          data = await opts.responseTransformer(data);
+        }
       }
 
       return {

packages/client-axios/src/types.ts

@@ -83,11 +83,16 @@ export interface Config<ThrowOnError extends boolean = boolean>
    */
   querySerializer?: QuerySerializer | QuerySerializerOptions;
   /**
-   * A function for transforming response data before it's returned to the
-   * caller function. This is an ideal place to post-process server data,
-   * e.g. convert date ISO strings into native Date objects.
+   * A function transforming response data before it's returned. This is useful
+   * for post-processing data, e.g. converting ISO strings into Date objects.
    */
   responseTransformer?: (data: unknown) => Promise<unknown>;
+  /**
+   * A function validating response data. This is useful if you want to ensure
+   * the response conforms to the desired shape, so it can be safely passed to
+   * the transformers and returned to the user.
+   */
+  responseValidator?: (data: unknown) => Promise<unknown>;
   /**
    * Throw an error instead of returning it in the response?
    *
@@ -97,7 +102,7 @@ export interface Config<ThrowOnError extends boolean = boolean>
 }
 
 export interface RequestOptions<
-  ThrowOnError extends boolean = false,
+  ThrowOnError extends boolean = boolean,
   Url extends string = string,
 > extends Config<ThrowOnError> {
   /**

packages/client-fetch/src/index.ts

@@ -106,8 +106,14 @@ export const createClient = (config: Config = {}): Client => {
           : opts.parseAs) ?? 'json';
 
       let data = await response[parseAs]();
-      if (parseAs === 'json' && opts.responseTransformer) {
-        data = await opts.responseTransformer(data);
+      if (parseAs === 'json') {
+        if (opts.responseValidator) {
+          await opts.responseValidator(data);
+        }
+
+        if (opts.responseTransformer) {
+          data = await opts.responseTransformer(data);
+        }
       }
 
       return {

packages/client-fetch/src/types.ts

@@ -88,11 +88,16 @@ export interface Config<ThrowOnError extends boolean = boolean>
    */
   querySerializer?: QuerySerializer | QuerySerializerOptions;
   /**
-   * A function for transforming response data before it's returned to the
-   * caller function. This is an ideal place to post-process server data,
-   * e.g. convert date ISO strings into native Date objects.
+   * A function transforming response data before it's returned. This is useful
+   * for post-processing data, e.g. converting ISO strings into Date objects.
    */
   responseTransformer?: (data: unknown) => Promise<unknown>;
+  /**
+   * A function validating response data. This is useful if you want to ensure
+   * the response conforms to the desired shape, so it can be safely passed to
+   * the transformers and returned to the user.
+   */
+  responseValidator?: (data: unknown) => Promise<unknown>;
   /**
    * Throw an error instead of returning it in the response?
    *

packages/openapi-ts/src/index.ts

@@ -11,7 +11,11 @@ import type { IRContext } from './ir/context';
 import { parseExperimental, parseLegacy } from './openApi';
 import type { ClientPlugins, UserPlugins } from './plugins';
 import { defaultPluginConfigs } from './plugins';
-import type { DefaultPluginConfigs, PluginNames } from './plugins/types';
+import type {
+  DefaultPluginConfigs,
+  PluginContext,
+  PluginNames,
+} from './plugins/types';
 import type { Client } from './types/client';
 import type {
   ClientConfig,
@@ -180,52 +184,99 @@ const getOutput = (userConfig: ClientConfig): Config['output'] => {
   return output;
 };
 
-const getPluginOrder = ({
+const getPluginsConfig = ({
   pluginConfigs,
   userPlugins,
+  userPluginsConfig,
 }: {
   pluginConfigs: DefaultPluginConfigs<ClientPlugins>;
   userPlugins: ReadonlyArray<PluginNames>;
-}): Config['pluginOrder'] => {
+  userPluginsConfig: Config['plugins'];
+}): Pick<Config, 'plugins' | 'pluginOrder'> => {
   const circularReferenceTracker = new Set<PluginNames>();
-  const visitedNodes = new Set<PluginNames>();
+  const pluginOrder = new Set<PluginNames>();
+  const plugins: Config['plugins'] = {};
 
   const dfs = (name: PluginNames) => {
     if (circularReferenceTracker.has(name)) {
       throw new Error(`Circular reference detected at '${name}'`);
     }
 
-    if (!visitedNodes.has(name)) {
+    if (!pluginOrder.has(name)) {
       circularReferenceTracker.add(name);
 
       const pluginConfig = pluginConfigs[name];
-
       if (!pluginConfig) {
         throw new Error(
           `🚫 unknown plugin dependency "${name}" - do you need to register a custom plugin with this name?`,
         );
       }
 
-      for (const dependency of pluginConfig._dependencies || []) {
-        dfs(dependency);
+      const defaultOptions = defaultPluginConfigs[name];
+      const userOptions = userPluginsConfig[name];
+      if (userOptions && defaultOptions) {
+        const nativePluginOption = Object.keys(userOptions).find((key) =>
+          key.startsWith('_'),
+        );
+        if (nativePluginOption) {
+          throw new Error(
+            `🚫 cannot register plugin "${name}" - attempting to override a native plugin option "${nativePluginOption}"`,
+          );
+        }
       }
 
-      for (const dependency of pluginConfig._optionalDependencies || []) {
-        if (userPlugins.includes(dependency)) {
-          dfs(dependency);
-        }
+      const config = {
+        _dependencies: [],
+        ...defaultOptions,
+        ...userOptions,
+      };
+
+      if (config._infer) {
+        const context: PluginContext = {
+          ensureDependency: (dependency) => {
+            if (
+              typeof dependency === 'string' &&
+              !config._dependencies.includes(dependency)
+            ) {
+              config._dependencies = [...config._dependencies, dependency];
+            }
+          },
+          pluginByTag: (tag) => {
+            for (const userPlugin of userPlugins) {
+              const defaultConfig = defaultPluginConfigs[userPlugin];
+              if (
+                defaultConfig &&
+                defaultConfig._tags?.includes(tag) &&
+                userPlugin !== name
+              ) {
+                return userPlugin;
+              }
+            }
+          },
+        };
+        config._infer(config, context);
+      }
+
+      for (const dependency of config._dependencies) {
+        dfs(dependency);
       }
 
       circularReferenceTracker.delete(name);
-      visitedNodes.add(name);
+      pluginOrder.add(name);
+
+      // @ts-expect-error
+      plugins[name] = config;
     }
   };
 
   for (const name of userPlugins) {
     dfs(name);
   }
 
-  return Array.from(visitedNodes);
+  return {
+    pluginOrder: Array.from(pluginOrder),
+    plugins,
+  };
 };
 
 const getPlugins = (
@@ -248,42 +299,14 @@ const getPlugins = (
     })
     .filter(Boolean);
 
-  const pluginOrder = getPluginOrder({
+  return getPluginsConfig({
     pluginConfigs: {
       ...userPluginsConfig,
       ...defaultPluginConfigs,
     },
     userPlugins,
+    userPluginsConfig,
   });
-
-  const plugins = pluginOrder.reduce(
-    (result, name) => {
-      const defaultOptions = defaultPluginConfigs[name];
-      const userOptions = userPluginsConfig[name];
-      if (userOptions && defaultOptions) {
-        const nativePluginOption = Object.keys(userOptions).find((key) =>
-          key.startsWith('_'),
-        );
-        if (nativePluginOption) {
-          throw new Error(
-            `🚫 cannot register plugin "${userOptions.name}" - attempting to override a native plugin option "${nativePluginOption}"`,
-          );
-        }
-      }
-      // @ts-expect-error
-      result[name] = {
-        ...defaultOptions,
-        ...userOptions,
-      };
-      return result;
-    },
-    {} as Config['plugins'],
-  );
-
-  return {
-    pluginOrder,
-    plugins,
-  };
 };
 
 const getSpec = async ({ config }: { config: Config }) => {

packages/openapi-ts/src/ir/operation.ts

@@ -85,9 +85,21 @@ export const statusCodeToGroup = ({
 };
 
 interface OperationResponsesMap {
+  /**
+   * A deduplicated union of all error types. Unknown types are omitted.
+   */
   error?: IRSchemaObject;
+  /**
+   * An object containing a map of status codes for each error type.
+   */
   errors?: IRSchemaObject;
+  /**
+   * A deduplicated union of all response types. Unknown types are omitted.
+   */
   response?: IRSchemaObject;
+  /**
+   * An object containing a map of status codes for each response type.
+   */
   responses?: IRSchemaObject;
 }
 

packages/openapi-ts/src/plugins/@hey-api/sdk/config.ts

@@ -7,7 +7,27 @@ export const defaultConfig: Plugin.Config<Config> = {
   _dependencies: ['@hey-api/typescript'],
   _handler: handler,
   _handlerLegacy: handlerLegacy,
-  _optionalDependencies: ['@hey-api/transformers'],
+  _infer: (config, context) => {
+    if (config.transformer) {
+      if (typeof config.transformer === 'boolean') {
+        config.transformer = context.pluginByTag(
+          'transformer',
+        ) as unknown as typeof config.transformer;
+      }
+
+      context.ensureDependency(config.transformer);
+    }
+
+    if (config.validator) {
+      if (typeof config.validator === 'boolean') {
+        config.validator = context.pluginByTag(
+          'validator',
+        ) as unknown as typeof config.validator;
+      }
+
+      context.ensureDependency(config.validator);
+    }
+  },
   asClass: false,
   auth: true,
   name: '@hey-api/sdk',