@kubb/core - npm Package Compare versions

Comparing version 5.0.0-beta.37 to 5.0.0-beta.38

dist/index.cjs

 Object.defineProperty(exports, Symbol.toStringTag, { value: "Module" });
-const require_KubbDriver = require("./KubbDriver-CXoKVRxI.cjs");
+const require_KubbDriver = require("./KubbDriver-BYBUfOZ8.cjs");
 let node_fs_promises = require("node:fs/promises");
@@ -389,5 +389,6 @@ let node_path = require("node:path");
 /**
-* Defines a reporter. Returns the reporter unchanged at runtime. It exists for type inference and
-* to mark the value as a reporter, mirroring {@link defineLogger}. Wiring the reporter onto the
-* run's events is the host's job, so the reporter only ever deals with a {@link GenerationResult}.
+* Defines a reporter. When the definition has a `flush`, the returned reporter buffers each value
+* `report` returns and hands the array to `flush` once, then clears it. Without a `flush`, nothing
+* is buffered. Wiring the reporter onto the run's events is the host's job, so the reporter only
+* ever deals with a {@link GenerationResult}.
 *
@@ -401,5 +402,7 @@ * @example
 *   report(result) {
-*     const status = Diagnostics.hasError(result.diagnostics) ? 'failed' : 'success'
-*     process.stdout.write(`${JSON.stringify({ status, diagnostics: result.diagnostics }, null, 2)}\n`)
+*     return { status: Diagnostics.hasError(result.diagnostics) ? 'failed' : 'success', diagnostics: result.diagnostics }
 *   },
+*   flush(context, reports) {
+*     process.stdout.write(`${JSON.stringify(reports, null, 2)}\n`)
+*   },
 * })
@@ -409,3 +412,18 @@ * ```
 function createReporter(reporter) {
-	return reporter;
+	const flush = reporter.flush;
+	if (!flush) return {
+		name: reporter.name,
+		report: reporter.report
+	};
+	const reports = [];
+	return {
+		name: reporter.name,
+		async report(result, context) {
+			reports.push(await reporter.report(result, context));
+		},
+		async flush(context) {
+			await flush(context, reports);
+			reports.length = 0;
+		}
+	};
 }
@@ -412,0 +430,0 @@ //#endregion

dist/index.d.ts

 import { t as __name } from "./chunk-C0LytTxp.js";
-import { $ as Exclude, A as KubbFileProcessingUpdate, At as Parser, B as KubbLifecycleStartContext, Bt as RendererFactory, C as InputPath, Ct as LoggerContext, D as KubbConfigEndContext, Dt as FileProcessor, E as KubbBuildStartContext, Et as defineLogger, F as KubbGenerationStartContext, Ft as ReporterName, G as UserConfig, Gt as AdapterFactoryOptions, H as KubbSuccessContext, Ht as Storage, I as KubbHookEndContext, It as UserReporter, J as Generator, Jt as diagnosticCode, K as createKubb, Kt as AdapterSource, L as KubbHookStartContext, Lt as createReporter, M as KubbFilesProcessingStartContext, Mt as GenerationResult, N as KubbFilesProcessingUpdateContext, Nt as Reporter, O as KubbDiagnosticContext, Ot as FileProcessorHooks, P as KubbGenerationEndContext, Pt as ReporterContext, Q as FileManager, R as KubbHooks, Rt as DevtoolsOptions, S as InputData, St as Logger, T as KubbBuildEndContext, Tt as UserLogger, U as KubbWarnContext, Ut as createStorage, V as KubbPluginsEndContext, Vt as createRenderer, W as PossibleConfig, Wt as Adapter, X as defineGenerator, Xt as AsyncEventEmitter, Y as GeneratorContext, Yt as logLevel, Z as KubbDriver, _ as isUpdateDiagnostic, _t as ResolverFileParams, a as DiagnosticKind, at as NormalizedPlugin, b as CLIOptions, bt as Middleware, c as Diagnostics, ct as Plugin, d as ProblemDiagnostic, dt as BannerMeta, et as Group, f as SerializedDiagnostic, ft as ResolveBannerContext, g as isProblemDiagnostic, gt as ResolverContext, h as isPerformanceDiagnostic, ht as Resolver, i as DiagnosticError, it as KubbPluginStartContext, j as KubbFilesProcessingEndContext, jt as defineParser, k as KubbErrorContext, kt as ParsedFile, l as PerformanceDiagnostic, lt as PluginFactoryOptions, m as diagnosticCatalog, mt as ResolveOptionsContext, n as DiagnosticByCode, nt as KubbPluginEndContext, o as DiagnosticLocation, ot as Output, p as UpdateDiagnostic, pt as ResolveBannerFile, q as isInputPath, qt as createAdapter, r as DiagnosticDoc, rt as KubbPluginSetupContext, s as DiagnosticSeverity, st as Override, t as Diagnostic, tt as Include, u as ProblemCode, ut as definePlugin, v as narrowDiagnostic, vt as ResolverPathParams, w as Kubb, wt as LoggerOptions, x as Config, xt as defineMiddleware, y as BuildOutput, yt as defineResolver, z as KubbInfoContext, zt as Renderer } from "./diagnostics-B0ONXReg.js";
+import { $ as Exclude, A as KubbFileProcessingUpdate, At as Parser, B as KubbLifecycleStartContext, Bt as RendererFactory, C as InputPath, Ct as LoggerContext, D as KubbConfigEndContext, Dt as FileProcessor, E as KubbBuildStartContext, Et as defineLogger, F as KubbGenerationStartContext, Ft as ReporterName, G as UserConfig, Gt as AdapterFactoryOptions, H as KubbSuccessContext, Ht as Storage, I as KubbHookEndContext, It as UserReporter, J as Generator, Jt as diagnosticCode, K as createKubb, Kt as AdapterSource, L as KubbHookStartContext, Lt as createReporter, M as KubbFilesProcessingStartContext, Mt as GenerationResult, N as KubbFilesProcessingUpdateContext, Nt as Reporter, O as KubbDiagnosticContext, Ot as FileProcessorHooks, P as KubbGenerationEndContext, Pt as ReporterContext, Q as FileManager, R as KubbHooks, Rt as DevtoolsOptions, S as InputData, St as Logger, T as KubbBuildEndContext, Tt as UserLogger, U as KubbWarnContext, Ut as createStorage, V as KubbPluginsEndContext, Vt as createRenderer, W as PossibleConfig, Wt as Adapter, X as defineGenerator, Xt as AsyncEventEmitter, Y as GeneratorContext, Yt as logLevel, Z as KubbDriver, _ as isUpdateDiagnostic, _t as ResolverFileParams, a as DiagnosticKind, at as NormalizedPlugin, b as CLIOptions, bt as Middleware, c as Diagnostics, ct as Plugin, d as ProblemDiagnostic, dt as BannerMeta, et as Group, f as SerializedDiagnostic, ft as ResolveBannerContext, g as isProblemDiagnostic, gt as ResolverContext, h as isPerformanceDiagnostic, ht as Resolver, i as DiagnosticError, it as KubbPluginStartContext, j as KubbFilesProcessingEndContext, jt as defineParser, k as KubbErrorContext, kt as ParsedFile, l as PerformanceDiagnostic, lt as PluginFactoryOptions, m as diagnosticCatalog, mt as ResolveOptionsContext, n as DiagnosticByCode, nt as KubbPluginEndContext, o as DiagnosticLocation, ot as Output, p as UpdateDiagnostic, pt as ResolveBannerFile, q as isInputPath, qt as createAdapter, r as DiagnosticDoc, rt as KubbPluginSetupContext, s as DiagnosticSeverity, st as Override, t as Diagnostic, tt as Include, u as ProblemCode, ut as definePlugin, v as narrowDiagnostic, vt as ResolverPathParams, w as Kubb, wt as LoggerOptions, x as Config, xt as defineMiddleware, y as BuildOutput, yt as defineResolver, z as KubbInfoContext, zt as Renderer } from "./diagnostics-CYfKPtbU.js";
 import * as ast from "@kubb/ast";
@@ -4,0 +4,0 @@

dist/index.js

 import "./chunk-C0LytTxp.js";
-import { _ as URLPath, a as defineResolver, c as Diagnostics, d as isProblemDiagnostic, f as isUpdateDiagnostic, g as logLevel, h as diagnosticCode, i as FileManager, l as diagnosticCatalog, m as DEFAULT_STUDIO_URL, n as _usingCtx, o as definePlugin, p as narrowDiagnostic, r as FileProcessor, s as DiagnosticError, t as KubbDriver, u as isPerformanceDiagnostic, v as AsyncEventEmitter, y as BuildError } from "./KubbDriver-CckeYpMG.js";
+import { _ as URLPath, a as defineResolver, c as Diagnostics, d as isProblemDiagnostic, f as isUpdateDiagnostic, g as logLevel, h as diagnosticCode, i as FileManager, l as diagnosticCatalog, m as DEFAULT_STUDIO_URL, n as _usingCtx, o as definePlugin, p as narrowDiagnostic, r as FileProcessor, s as DiagnosticError, t as KubbDriver, u as isPerformanceDiagnostic, v as AsyncEventEmitter, y as BuildError } from "./KubbDriver-CyNF-NIb.js";
 import { access, mkdir, readFile, readdir, rm, writeFile } from "node:fs/promises";
@@ -388,5 +388,6 @@ import { dirname, join, resolve } from "node:path";
 /**
-* Defines a reporter. Returns the reporter unchanged at runtime. It exists for type inference and
-* to mark the value as a reporter, mirroring {@link defineLogger}. Wiring the reporter onto the
-* run's events is the host's job, so the reporter only ever deals with a {@link GenerationResult}.
+* Defines a reporter. When the definition has a `flush`, the returned reporter buffers each value
+* `report` returns and hands the array to `flush` once, then clears it. Without a `flush`, nothing
+* is buffered. Wiring the reporter onto the run's events is the host's job, so the reporter only
+* ever deals with a {@link GenerationResult}.
 *
@@ -400,5 +401,7 @@ * @example
 *   report(result) {
-*     const status = Diagnostics.hasError(result.diagnostics) ? 'failed' : 'success'
-*     process.stdout.write(`${JSON.stringify({ status, diagnostics: result.diagnostics }, null, 2)}\n`)
+*     return { status: Diagnostics.hasError(result.diagnostics) ? 'failed' : 'success', diagnostics: result.diagnostics }
 *   },
+*   flush(context, reports) {
+*     process.stdout.write(`${JSON.stringify(reports, null, 2)}\n`)
+*   },
 * })
@@ -408,3 +411,18 @@ * ```
 function createReporter(reporter) {
-	return reporter;
+	const flush = reporter.flush;
+	if (!flush) return {
+		name: reporter.name,
+		report: reporter.report
+	};
+	const reports = [];
+	return {
+		name: reporter.name,
+		async report(result, context) {
+			reports.push(await reporter.report(result, context));
+		},
+		async flush(context) {
+			await flush(context, reports);
+			reports.length = 0;
+		}
+	};
 }
@@ -411,0 +429,0 @@ //#endregion

dist/mocks.cjs

 Object.defineProperty(exports, Symbol.toStringTag, { value: "Module" });
-const require_KubbDriver = require("./KubbDriver-CXoKVRxI.cjs");
+const require_KubbDriver = require("./KubbDriver-BYBUfOZ8.cjs");
 let node_path = require("node:path");
@@ -11,2 +11,3 @@ let _kubb_ast = require("@kubb/ast");
 function createMockedPluginDriver(options = {}) {
+	const fileManager = new require_KubbDriver.FileManager();
 	return {
@@ -21,3 +22,25 @@ config: options?.config ?? {
 		getResolver: (_pluginName) => options?.plugin?.resolver,
-		fileManager: new require_KubbDriver.FileManager()
+		fileManager,
+		async dispatch({ result, renderer }) {
+			try {
+				var _usingCtx$1 = require_KubbDriver._usingCtx();
+				if (!result) return;
+				if (Array.isArray(result)) {
+					fileManager.upsert(...result);
+					return;
+				}
+				if (!renderer) return;
+				const instance = _usingCtx$1.u(renderer());
+				if (instance.stream) {
+					for (const file of instance.stream(result)) fileManager.upsert(file);
+					return;
+				}
+				await instance.render(result);
+				fileManager.upsert(...instance.files);
+			} catch (_) {
+				_usingCtx$1.e = _;
+			} finally {
+				_usingCtx$1.d();
+			}
+		}
 	};
@@ -24,0 +47,0 @@ }

dist/mocks.cjs.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"mocks.cjs","names":["FileManager","KubbDriver"],"sources":["../src/mocks.ts"],"sourcesContent":["import { resolve } from 'node:path'\nimport type { FileNode, InputMeta, OperationNode, SchemaNode, Visitor } from '@kubb/ast'\nimport { transform } from '@kubb/ast'\nimport { FileManager } from './FileManager.ts'\nimport { KubbDriver } from './KubbDriver.ts'\nimport type { Adapter, AdapterFactoryOptions, Config, Generator, GeneratorContext, NormalizedPlugin, PluginFactoryOptions } from './types.ts'\n\n/**\n\n * Creates a minimal `PluginDriver` mock for unit tests.\n */\nexport function createMockedPluginDriver(options: { name?: string; plugin?: NormalizedPlugin; config?: Config } = {}): KubbDriver {\n  return {\n    config: options?.config ?? {\n      root: '.',\n      output: {\n        path: './path',\n      },\n    },\n    getPlugin(_pluginName: string): NormalizedPlugin | undefined {\n      return options?.plugin\n    },\n    getResolver: (_pluginName: string) => options?.plugin?.resolver,\n    fileManager: new FileManager(),\n  } as unknown as KubbDriver\n}\n\n/**\n * Creates a minimal `Adapter` mock for unit tests.\n * `parse` returns an empty `InputNode` by default. Override via `options.parse`.\n * `getImports` returns `[]` by default.\n */\nexport function createMockedAdapter<TOptions extends AdapterFactoryOptions = AdapterFactoryOptions>(\n  options: {\n    name?: TOptions['name']\n    resolvedOptions?: TOptions['resolvedOptions']\n    parse?: Adapter<TOptions>['parse']\n    getImports?: Adapter<TOptions>['getImports']\n  } = {},\n): Adapter<TOptions> {\n  return {\n    name: (options.name ?? 'oas') as TOptions['name'],\n    options: (options.resolvedOptions ?? {}) as TOptions['resolvedOptions'],\n    parse: options.parse ?? (async () => ({ kind: 'Input' as const, schemas: [], operations: [] })),\n    getImports: options.getImports ?? ((_node: SchemaNode, _resolve: (schemaName: string) => { name: string; path: string }) => []),\n  } as Adapter<TOptions>\n}\n\n/**\n * Creates a minimal plugin mock for unit tests.\n *\n * @example\n * `const plugin = createMockedPlugin<PluginTs>({ name: '@kubb/plugin-ts', options })`\n */\nexport function createMockedPlugin<TOptions extends PluginFactoryOptions = PluginFactoryOptions>(params: {\n  name: TOptions['name']\n  options: TOptions['resolvedOptions']\n  resolver?: TOptions['resolver']\n  transformer?: Visitor\n  dependencies?: Array<string>\n}): NormalizedPlugin<TOptions> {\n  return {\n    name: params.name,\n    options: params.options,\n    resolver: params.resolver,\n    transformer: params.transformer,\n    dependencies: params.dependencies,\n    hooks: {},\n  } as unknown as NormalizedPlugin<TOptions>\n}\n\ntype RenderGeneratorOptions<TOptions extends PluginFactoryOptions> = {\n  config: Config\n  adapter: Adapter\n  meta?: InputMeta\n  driver: KubbDriver\n  plugin: NormalizedPlugin<TOptions>\n  options: TOptions['resolvedOptions']\n  resolver: TOptions['resolver']\n}\n\nfunction createMockedPluginContext<TOptions extends PluginFactoryOptions>(opts: RenderGeneratorOptions<TOptions>): Omit<GeneratorContext<TOptions>, 'options'> {\n  const root = resolve(opts.config.root, opts.config.output.path)\n\n  return {\n    config: opts.config,\n    root,\n    getMode: (output: { path: string }) => KubbDriver.getMode(resolve(root, output.path)),\n    adapter: opts.adapter,\n    resolver: opts.resolver,\n    plugin: opts.plugin,\n    driver: opts.driver,\n    getResolver: (name: string) => opts.driver.getResolver(name),\n    meta: opts.meta ?? { circularNames: [], enumNames: [] },\n    addFile: async (...files: Array<FileNode>) => opts.driver.fileManager.add(...files),\n    upsertFile: async (...files: Array<FileNode>) => opts.driver.fileManager.upsert(...files),\n    hooks: opts.driver.hooks ?? ({} as never),\n    warn: (msg: string) => console.warn(msg),\n    error: (msg: string) => console.error(msg),\n    info: (msg: string) => console.info(msg),\n    openInStudio: async () => {},\n  } as unknown as Omit<GeneratorContext<TOptions>, 'options'>\n}\n\n/**\n * Renders a generator's `schema` method in a test context.\n *\n * @example\n * ```ts\n * await renderGeneratorSchema(typeGenerator, node, { config, adapter, driver, plugin, options, resolver })\n * await matchFiles(driver.fileManager.files)\n * ```\n */\nexport async function renderGeneratorSchema<TOptions extends PluginFactoryOptions>(\n  generator: Generator<TOptions>,\n  node: SchemaNode,\n  opts: RenderGeneratorOptions<TOptions>,\n): Promise<void> {\n  if (!generator.schema) return\n  const context = createMockedPluginContext(opts)\n  const transformedNode = opts.plugin.transformer ? transform(node, opts.plugin.transformer) : node\n  const result = await generator.schema(transformedNode, {\n    ...context,\n    options: opts.options,\n  })\n  await opts.driver.dispatch({ result, renderer: generator.renderer })\n}\n\n/**\n * Renders a generator's `operation` method in a test context.\n *\n * @example\n * ```ts\n * await renderGeneratorOperation(typeGenerator, node, { config, adapter, driver, plugin, options, resolver })\n * await matchFiles(driver.fileManager.files)\n * ```\n */\nexport async function renderGeneratorOperation<TOptions extends PluginFactoryOptions>(\n  generator: Generator<TOptions>,\n  node: OperationNode,\n  opts: RenderGeneratorOptions<TOptions>,\n): Promise<void> {\n  if (!generator.operation) return\n  const context = createMockedPluginContext(opts)\n  const transformedNode = opts.plugin.transformer ? transform(node, opts.plugin.transformer) : node\n  const result = await generator.operation(transformedNode, {\n    ...context,\n    options: opts.options,\n  })\n  await opts.driver.dispatch({ result, renderer: generator.renderer })\n}\n\n/**\n * Renders a generator's `operations` method in a test context.\n *\n * @example\n * ```ts\n * await renderGeneratorOperations(classClientGenerator, nodes, { config, adapter, driver, plugin, options, resolver })\n * await matchFiles(driver.fileManager.files)\n * ```\n */\nexport async function renderGeneratorOperations<TOptions extends PluginFactoryOptions>(\n  generator: Generator<TOptions>,\n  nodes: Array<OperationNode>,\n  opts: RenderGeneratorOptions<TOptions>,\n): Promise<void> {\n  if (!generator.operations) return\n  const context = createMockedPluginContext(opts)\n  const transformedNodes = opts.plugin.transformer ? nodes.map((n) => transform(n, opts.plugin.transformer!)) : nodes\n  const result = await generator.operations(transformedNodes, {\n    ...context,\n    options: opts.options,\n  })\n  await opts.driver.dispatch({ result, renderer: generator.renderer })\n}\n"],"mappings":";;;;;;;;;AAWA,SAAgB,yBAAyB,UAAyE,CAAC,GAAe;CAChI,OAAO;EACL,QAAQ,SAAS,UAAU;GACzB,MAAM;GACN,QAAQ,EACN,MAAM,SACR;EACF;EACA,UAAU,aAAmD;GAC3D,OAAO,SAAS;EAClB;EACA,cAAc,gBAAwB,SAAS,QAAQ;EACvD,aAAa,IAAIA,mBAAAA,YAAY;CAC/B;AACF;;;;;;AAOA,SAAgB,oBACd,UAKI,CAAC,GACc;CACnB,OAAO;EACL,MAAO,QAAQ,QAAQ;EACvB,SAAU,QAAQ,mBAAmB,CAAC;EACtC,OAAO,QAAQ,UAAU,aAAa;GAAE,MAAM;GAAkB,SAAS,CAAC;GAAG,YAAY,CAAC;EAAE;EAC5F,YAAY,QAAQ,gBAAgB,OAAmB,aAAqE,CAAC;CAC/H;AACF;;;;;;;AAQA,SAAgB,mBAAiF,QAMlE;CAC7B,OAAO;EACL,MAAM,OAAO;EACb,SAAS,OAAO;EAChB,UAAU,OAAO;EACjB,aAAa,OAAO;EACpB,cAAc,OAAO;EACrB,OAAO,CAAC;CACV;AACF;AAYA,SAAS,0BAAiE,MAAqF;CAC7J,MAAM,QAAA,GAAA,UAAA,SAAe,KAAK,OAAO,MAAM,KAAK,OAAO,OAAO,IAAI;CAE9D,OAAO;EACL,QAAQ,KAAK;EACb;EACA,UAAU,WAA6BC,mBAAAA,WAAW,SAAA,GAAA,UAAA,SAAgB,MAAM,OAAO,IAAI,CAAC;EACpF,SAAS,KAAK;EACd,UAAU,KAAK;EACf,QAAQ,KAAK;EACb,QAAQ,KAAK;EACb,cAAc,SAAiB,KAAK,OAAO,YAAY,IAAI;EAC3D,MAAM,KAAK,QAAQ;GAAE,eAAe,CAAC;GAAG,WAAW,CAAC;EAAE;EACtD,SAAS,OAAO,GAAG,UAA2B,KAAK,OAAO,YAAY,IAAI,GAAG,KAAK;EAClF,YAAY,OAAO,GAAG,UAA2B,KAAK,OAAO,YAAY,OAAO,GAAG,KAAK;EACxF,OAAO,KAAK,OAAO,SAAU,CAAC;EAC9B,OAAO,QAAgB,QAAQ,KAAK,GAAG;EACvC,QAAQ,QAAgB,QAAQ,MAAM,GAAG;EACzC,OAAO,QAAgB,QAAQ,KAAK,GAAG;EACvC,cAAc,YAAY,CAAC;CAC7B;AACF;;;;;;;;;;AAWA,eAAsB,sBACpB,WACA,MACA,MACe;CACf,IAAI,CAAC,UAAU,QAAQ;CACvB,MAAM,UAAU,0BAA0B,IAAI;CAC9C,MAAM,kBAAkB,KAAK,OAAO,eAAA,GAAA,UAAA,WAAwB,MAAM,KAAK,OAAO,WAAW,IAAI;CAC7F,MAAM,SAAS,MAAM,UAAU,OAAO,iBAAiB;EACrD,GAAG;EACH,SAAS,KAAK;CAChB,CAAC;CACD,MAAM,KAAK,OAAO,SAAS;EAAE;EAAQ,UAAU,UAAU;CAAS,CAAC;AACrE;;;;;;;;;;AAWA,eAAsB,yBACpB,WACA,MACA,MACe;CACf,IAAI,CAAC,UAAU,WAAW;CAC1B,MAAM,UAAU,0BAA0B,IAAI;CAC9C,MAAM,kBAAkB,KAAK,OAAO,eAAA,GAAA,UAAA,WAAwB,MAAM,KAAK,OAAO,WAAW,IAAI;CAC7F,MAAM,SAAS,MAAM,UAAU,UAAU,iBAAiB;EACxD,GAAG;EACH,SAAS,KAAK;CAChB,CAAC;CACD,MAAM,KAAK,OAAO,SAAS;EAAE;EAAQ,UAAU,UAAU;CAAS,CAAC;AACrE;;;;;;;;;;AAWA,eAAsB,0BACpB,WACA,OACA,MACe;CACf,IAAI,CAAC,UAAU,YAAY;CAC3B,MAAM,UAAU,0BAA0B,IAAI;CAC9C,MAAM,mBAAmB,KAAK,OAAO,cAAc,MAAM,KAAK,OAAA,GAAA,UAAA,WAAgB,GAAG,KAAK,OAAO,WAAY,CAAC,IAAI;CAC9G,MAAM,SAAS,MAAM,UAAU,WAAW,kBAAkB;EAC1D,GAAG;EACH,SAAS,KAAK;CAChB,CAAC;CACD,MAAM,KAAK,OAAO,SAAS;EAAE;EAAQ,UAAU,UAAU;CAAS,CAAC;AACrE"}
+{"version":3,"file":"mocks.cjs","names":["FileManager","KubbDriver"],"sources":["../src/mocks.ts"],"sourcesContent":["import { resolve } from 'node:path'\nimport type { FileNode, InputMeta, OperationNode, SchemaNode, Visitor } from '@kubb/ast'\nimport { transform } from '@kubb/ast'\nimport { FileManager } from './FileManager.ts'\nimport { KubbDriver } from './KubbDriver.ts'\nimport type { Adapter, AdapterFactoryOptions, Config, Generator, GeneratorContext, NormalizedPlugin, PluginFactoryOptions, RendererFactory } from './types.ts'\n\n/**\n\n * Creates a minimal `PluginDriver` mock for unit tests.\n */\nexport function createMockedPluginDriver(options: { name?: string; plugin?: NormalizedPlugin; config?: Config } = {}): KubbDriver {\n  const fileManager = new FileManager()\n\n  return {\n    config: options?.config ?? {\n      root: '.',\n      output: {\n        path: './path',\n      },\n    },\n    getPlugin(_pluginName: string): NormalizedPlugin | undefined {\n      return options?.plugin\n    },\n    getResolver: (_pluginName: string) => options?.plugin?.resolver,\n    fileManager,\n    async dispatch({ result, renderer }: { result: unknown; renderer?: RendererFactory | null }): Promise<void> {\n      if (!result) return\n\n      if (Array.isArray(result)) {\n        fileManager.upsert(...(result as Array<FileNode>))\n        return\n      }\n\n      if (!renderer) return\n\n      using instance = renderer()\n      if (instance.stream) {\n        for (const file of instance.stream(result)) fileManager.upsert(file)\n        return\n      }\n\n      await instance.render(result)\n      fileManager.upsert(...instance.files)\n    },\n  } as unknown as KubbDriver\n}\n\n/**\n * Creates a minimal `Adapter` mock for unit tests.\n * `parse` returns an empty `InputNode` by default. Override via `options.parse`.\n * `getImports` returns `[]` by default.\n */\nexport function createMockedAdapter<TOptions extends AdapterFactoryOptions = AdapterFactoryOptions>(\n  options: {\n    name?: TOptions['name']\n    resolvedOptions?: TOptions['resolvedOptions']\n    parse?: Adapter<TOptions>['parse']\n    getImports?: Adapter<TOptions>['getImports']\n  } = {},\n): Adapter<TOptions> {\n  return {\n    name: (options.name ?? 'oas') as TOptions['name'],\n    options: (options.resolvedOptions ?? {}) as TOptions['resolvedOptions'],\n    parse: options.parse ?? (async () => ({ kind: 'Input' as const, schemas: [], operations: [] })),\n    getImports: options.getImports ?? ((_node: SchemaNode, _resolve: (schemaName: string) => { name: string; path: string }) => []),\n  } as Adapter<TOptions>\n}\n\n/**\n * Creates a minimal plugin mock for unit tests.\n *\n * @example\n * `const plugin = createMockedPlugin<PluginTs>({ name: '@kubb/plugin-ts', options })`\n */\nexport function createMockedPlugin<TOptions extends PluginFactoryOptions = PluginFactoryOptions>(params: {\n  name: TOptions['name']\n  options: TOptions['resolvedOptions']\n  resolver?: TOptions['resolver']\n  transformer?: Visitor\n  dependencies?: Array<string>\n}): NormalizedPlugin<TOptions> {\n  return {\n    name: params.name,\n    options: params.options,\n    resolver: params.resolver,\n    transformer: params.transformer,\n    dependencies: params.dependencies,\n    hooks: {},\n  } as unknown as NormalizedPlugin<TOptions>\n}\n\ntype RenderGeneratorOptions<TOptions extends PluginFactoryOptions> = {\n  config: Config\n  adapter: Adapter\n  meta?: InputMeta\n  driver: KubbDriver\n  plugin: NormalizedPlugin<TOptions>\n  options: TOptions['resolvedOptions']\n  resolver: TOptions['resolver']\n}\n\nfunction createMockedPluginContext<TOptions extends PluginFactoryOptions>(opts: RenderGeneratorOptions<TOptions>): Omit<GeneratorContext<TOptions>, 'options'> {\n  const root = resolve(opts.config.root, opts.config.output.path)\n\n  return {\n    config: opts.config,\n    root,\n    getMode: (output: { path: string }) => KubbDriver.getMode(resolve(root, output.path)),\n    adapter: opts.adapter,\n    resolver: opts.resolver,\n    plugin: opts.plugin,\n    driver: opts.driver,\n    getResolver: (name: string) => opts.driver.getResolver(name),\n    meta: opts.meta ?? { circularNames: [], enumNames: [] },\n    addFile: async (...files: Array<FileNode>) => opts.driver.fileManager.add(...files),\n    upsertFile: async (...files: Array<FileNode>) => opts.driver.fileManager.upsert(...files),\n    hooks: opts.driver.hooks ?? ({} as never),\n    warn: (msg: string) => console.warn(msg),\n    error: (msg: string) => console.error(msg),\n    info: (msg: string) => console.info(msg),\n    openInStudio: async () => {},\n  } as unknown as Omit<GeneratorContext<TOptions>, 'options'>\n}\n\n/**\n * Renders a generator's `schema` method in a test context.\n *\n * @example\n * ```ts\n * await renderGeneratorSchema(typeGenerator, node, { config, adapter, driver, plugin, options, resolver })\n * await matchFiles(driver.fileManager.files)\n * ```\n */\nexport async function renderGeneratorSchema<TOptions extends PluginFactoryOptions>(\n  generator: Generator<TOptions>,\n  node: SchemaNode,\n  opts: RenderGeneratorOptions<TOptions>,\n): Promise<void> {\n  if (!generator.schema) return\n  const context = createMockedPluginContext(opts)\n  const transformedNode = opts.plugin.transformer ? transform(node, opts.plugin.transformer) : node\n  const result = await generator.schema(transformedNode, {\n    ...context,\n    options: opts.options,\n  })\n  await opts.driver.dispatch({ result, renderer: generator.renderer })\n}\n\n/**\n * Renders a generator's `operation` method in a test context.\n *\n * @example\n * ```ts\n * await renderGeneratorOperation(typeGenerator, node, { config, adapter, driver, plugin, options, resolver })\n * await matchFiles(driver.fileManager.files)\n * ```\n */\nexport async function renderGeneratorOperation<TOptions extends PluginFactoryOptions>(\n  generator: Generator<TOptions>,\n  node: OperationNode,\n  opts: RenderGeneratorOptions<TOptions>,\n): Promise<void> {\n  if (!generator.operation) return\n  const context = createMockedPluginContext(opts)\n  const transformedNode = opts.plugin.transformer ? transform(node, opts.plugin.transformer) : node\n  const result = await generator.operation(transformedNode, {\n    ...context,\n    options: opts.options,\n  })\n  await opts.driver.dispatch({ result, renderer: generator.renderer })\n}\n\n/**\n * Renders a generator's `operations` method in a test context.\n *\n * @example\n * ```ts\n * await renderGeneratorOperations(classClientGenerator, nodes, { config, adapter, driver, plugin, options, resolver })\n * await matchFiles(driver.fileManager.files)\n * ```\n */\nexport async function renderGeneratorOperations<TOptions extends PluginFactoryOptions>(\n  generator: Generator<TOptions>,\n  nodes: Array<OperationNode>,\n  opts: RenderGeneratorOptions<TOptions>,\n): Promise<void> {\n  if (!generator.operations) return\n  const context = createMockedPluginContext(opts)\n  const transformedNodes = opts.plugin.transformer ? nodes.map((n) => transform(n, opts.plugin.transformer!)) : nodes\n  const result = await generator.operations(transformedNodes, {\n    ...context,\n    options: opts.options,\n  })\n  await opts.driver.dispatch({ result, renderer: generator.renderer })\n}\n"],"mappings":";;;;;;;;;AAWA,SAAgB,yBAAyB,UAAyE,CAAC,GAAe;CAChI,MAAM,cAAc,IAAIA,mBAAAA,YAAY;CAEpC,OAAO;EACL,QAAQ,SAAS,UAAU;GACzB,MAAM;GACN,QAAQ,EACN,MAAM,SACR;EACF;EACA,UAAU,aAAmD;GAC3D,OAAO,SAAS;EAClB;EACA,cAAc,gBAAwB,SAAS,QAAQ;EACvD;EACA,MAAM,SAAS,EAAE,QAAQ,YAAmF;;;IAC1G,IAAI,CAAC,QAAQ;IAEb,IAAI,MAAM,QAAQ,MAAM,GAAG;KACzB,YAAY,OAAO,GAAI,MAA0B;KACjD;IACF;IAEA,IAAI,CAAC,UAAU;IAEf,MAAM,WAAA,YAAA,EAAW,SAAS,CAAA;IAC1B,IAAI,SAAS,QAAQ;KACnB,KAAK,MAAM,QAAQ,SAAS,OAAO,MAAM,GAAG,YAAY,OAAO,IAAI;KACnE;IACF;IAEA,MAAM,SAAS,OAAO,MAAM;IAC5B,YAAY,OAAO,GAAG,SAAS,KAAK;;;;;;EACtC;CACF;AACF;;;;;;AAOA,SAAgB,oBACd,UAKI,CAAC,GACc;CACnB,OAAO;EACL,MAAO,QAAQ,QAAQ;EACvB,SAAU,QAAQ,mBAAmB,CAAC;EACtC,OAAO,QAAQ,UAAU,aAAa;GAAE,MAAM;GAAkB,SAAS,CAAC;GAAG,YAAY,CAAC;EAAE;EAC5F,YAAY,QAAQ,gBAAgB,OAAmB,aAAqE,CAAC;CAC/H;AACF;;;;;;;AAQA,SAAgB,mBAAiF,QAMlE;CAC7B,OAAO;EACL,MAAM,OAAO;EACb,SAAS,OAAO;EAChB,UAAU,OAAO;EACjB,aAAa,OAAO;EACpB,cAAc,OAAO;EACrB,OAAO,CAAC;CACV;AACF;AAYA,SAAS,0BAAiE,MAAqF;CAC7J,MAAM,QAAA,GAAA,UAAA,SAAe,KAAK,OAAO,MAAM,KAAK,OAAO,OAAO,IAAI;CAE9D,OAAO;EACL,QAAQ,KAAK;EACb;EACA,UAAU,WAA6BC,mBAAAA,WAAW,SAAA,GAAA,UAAA,SAAgB,MAAM,OAAO,IAAI,CAAC;EACpF,SAAS,KAAK;EACd,UAAU,KAAK;EACf,QAAQ,KAAK;EACb,QAAQ,KAAK;EACb,cAAc,SAAiB,KAAK,OAAO,YAAY,IAAI;EAC3D,MAAM,KAAK,QAAQ;GAAE,eAAe,CAAC;GAAG,WAAW,CAAC;EAAE;EACtD,SAAS,OAAO,GAAG,UAA2B,KAAK,OAAO,YAAY,IAAI,GAAG,KAAK;EAClF,YAAY,OAAO,GAAG,UAA2B,KAAK,OAAO,YAAY,OAAO,GAAG,KAAK;EACxF,OAAO,KAAK,OAAO,SAAU,CAAC;EAC9B,OAAO,QAAgB,QAAQ,KAAK,GAAG;EACvC,QAAQ,QAAgB,QAAQ,MAAM,GAAG;EACzC,OAAO,QAAgB,QAAQ,KAAK,GAAG;EACvC,cAAc,YAAY,CAAC;CAC7B;AACF;;;;;;;;;;AAWA,eAAsB,sBACpB,WACA,MACA,MACe;CACf,IAAI,CAAC,UAAU,QAAQ;CACvB,MAAM,UAAU,0BAA0B,IAAI;CAC9C,MAAM,kBAAkB,KAAK,OAAO,eAAA,GAAA,UAAA,WAAwB,MAAM,KAAK,OAAO,WAAW,IAAI;CAC7F,MAAM,SAAS,MAAM,UAAU,OAAO,iBAAiB;EACrD,GAAG;EACH,SAAS,KAAK;CAChB,CAAC;CACD,MAAM,KAAK,OAAO,SAAS;EAAE;EAAQ,UAAU,UAAU;CAAS,CAAC;AACrE;;;;;;;;;;AAWA,eAAsB,yBACpB,WACA,MACA,MACe;CACf,IAAI,CAAC,UAAU,WAAW;CAC1B,MAAM,UAAU,0BAA0B,IAAI;CAC9C,MAAM,kBAAkB,KAAK,OAAO,eAAA,GAAA,UAAA,WAAwB,MAAM,KAAK,OAAO,WAAW,IAAI;CAC7F,MAAM,SAAS,MAAM,UAAU,UAAU,iBAAiB;EACxD,GAAG;EACH,SAAS,KAAK;CAChB,CAAC;CACD,MAAM,KAAK,OAAO,SAAS;EAAE;EAAQ,UAAU,UAAU;CAAS,CAAC;AACrE;;;;;;;;;;AAWA,eAAsB,0BACpB,WACA,OACA,MACe;CACf,IAAI,CAAC,UAAU,YAAY;CAC3B,MAAM,UAAU,0BAA0B,IAAI;CAC9C,MAAM,mBAAmB,KAAK,OAAO,cAAc,MAAM,KAAK,OAAA,GAAA,UAAA,WAAgB,GAAG,KAAK,OAAO,WAAY,CAAC,IAAI;CAC9G,MAAM,SAAS,MAAM,UAAU,WAAW,kBAAkB;EAC1D,GAAG;EACH,SAAS,KAAK;CAChB,CAAC;CACD,MAAM,KAAK,OAAO,SAAS;EAAE;EAAQ,UAAU,UAAU;CAAS,CAAC;AACrE"}

dist/mocks.d.ts

 import { t as __name } from "./chunk-C0LytTxp.js";
-import { Gt as AdapterFactoryOptions, J as Generator, Wt as Adapter, Z as KubbDriver, at as NormalizedPlugin, lt as PluginFactoryOptions, x as Config } from "./diagnostics-B0ONXReg.js";
+import { Gt as AdapterFactoryOptions, J as Generator, Wt as Adapter, Z as KubbDriver, at as NormalizedPlugin, lt as PluginFactoryOptions, x as Config } from "./diagnostics-CYfKPtbU.js";
 import { InputMeta, OperationNode, SchemaNode, Visitor } from "@kubb/ast";
@@ -4,0 +4,0 @@

dist/mocks.js

 import "./chunk-C0LytTxp.js";
-import { i as FileManager, t as KubbDriver } from "./KubbDriver-CckeYpMG.js";
+import { i as FileManager, n as _usingCtx, t as KubbDriver } from "./KubbDriver-CyNF-NIb.js";
 import { resolve } from "node:path";
@@ -11,2 +11,3 @@ import { transform } from "@kubb/ast";
 function createMockedPluginDriver(options = {}) {
+	const fileManager = new FileManager();
 	return {
@@ -21,3 +22,25 @@ config: options?.config ?? {
 		getResolver: (_pluginName) => options?.plugin?.resolver,
-		fileManager: new FileManager()
+		fileManager,
+		async dispatch({ result, renderer }) {
+			try {
+				var _usingCtx$1 = _usingCtx();
+				if (!result) return;
+				if (Array.isArray(result)) {
+					fileManager.upsert(...result);
+					return;
+				}
+				if (!renderer) return;
+				const instance = _usingCtx$1.u(renderer());
+				if (instance.stream) {
+					for (const file of instance.stream(result)) fileManager.upsert(file);
+					return;
+				}
+				await instance.render(result);
+				fileManager.upsert(...instance.files);
+			} catch (_) {
+				_usingCtx$1.e = _;
+			} finally {
+				_usingCtx$1.d();
+			}
+		}
 	};
@@ -24,0 +47,0 @@ }

dist/mocks.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"mocks.js","names":[],"sources":["../src/mocks.ts"],"sourcesContent":["import { resolve } from 'node:path'\nimport type { FileNode, InputMeta, OperationNode, SchemaNode, Visitor } from '@kubb/ast'\nimport { transform } from '@kubb/ast'\nimport { FileManager } from './FileManager.ts'\nimport { KubbDriver } from './KubbDriver.ts'\nimport type { Adapter, AdapterFactoryOptions, Config, Generator, GeneratorContext, NormalizedPlugin, PluginFactoryOptions } from './types.ts'\n\n/**\n\n * Creates a minimal `PluginDriver` mock for unit tests.\n */\nexport function createMockedPluginDriver(options: { name?: string; plugin?: NormalizedPlugin; config?: Config } = {}): KubbDriver {\n  return {\n    config: options?.config ?? {\n      root: '.',\n      output: {\n        path: './path',\n      },\n    },\n    getPlugin(_pluginName: string): NormalizedPlugin | undefined {\n      return options?.plugin\n    },\n    getResolver: (_pluginName: string) => options?.plugin?.resolver,\n    fileManager: new FileManager(),\n  } as unknown as KubbDriver\n}\n\n/**\n * Creates a minimal `Adapter` mock for unit tests.\n * `parse` returns an empty `InputNode` by default. Override via `options.parse`.\n * `getImports` returns `[]` by default.\n */\nexport function createMockedAdapter<TOptions extends AdapterFactoryOptions = AdapterFactoryOptions>(\n  options: {\n    name?: TOptions['name']\n    resolvedOptions?: TOptions['resolvedOptions']\n    parse?: Adapter<TOptions>['parse']\n    getImports?: Adapter<TOptions>['getImports']\n  } = {},\n): Adapter<TOptions> {\n  return {\n    name: (options.name ?? 'oas') as TOptions['name'],\n    options: (options.resolvedOptions ?? {}) as TOptions['resolvedOptions'],\n    parse: options.parse ?? (async () => ({ kind: 'Input' as const, schemas: [], operations: [] })),\n    getImports: options.getImports ?? ((_node: SchemaNode, _resolve: (schemaName: string) => { name: string; path: string }) => []),\n  } as Adapter<TOptions>\n}\n\n/**\n * Creates a minimal plugin mock for unit tests.\n *\n * @example\n * `const plugin = createMockedPlugin<PluginTs>({ name: '@kubb/plugin-ts', options })`\n */\nexport function createMockedPlugin<TOptions extends PluginFactoryOptions = PluginFactoryOptions>(params: {\n  name: TOptions['name']\n  options: TOptions['resolvedOptions']\n  resolver?: TOptions['resolver']\n  transformer?: Visitor\n  dependencies?: Array<string>\n}): NormalizedPlugin<TOptions> {\n  return {\n    name: params.name,\n    options: params.options,\n    resolver: params.resolver,\n    transformer: params.transformer,\n    dependencies: params.dependencies,\n    hooks: {},\n  } as unknown as NormalizedPlugin<TOptions>\n}\n\ntype RenderGeneratorOptions<TOptions extends PluginFactoryOptions> = {\n  config: Config\n  adapter: Adapter\n  meta?: InputMeta\n  driver: KubbDriver\n  plugin: NormalizedPlugin<TOptions>\n  options: TOptions['resolvedOptions']\n  resolver: TOptions['resolver']\n}\n\nfunction createMockedPluginContext<TOptions extends PluginFactoryOptions>(opts: RenderGeneratorOptions<TOptions>): Omit<GeneratorContext<TOptions>, 'options'> {\n  const root = resolve(opts.config.root, opts.config.output.path)\n\n  return {\n    config: opts.config,\n    root,\n    getMode: (output: { path: string }) => KubbDriver.getMode(resolve(root, output.path)),\n    adapter: opts.adapter,\n    resolver: opts.resolver,\n    plugin: opts.plugin,\n    driver: opts.driver,\n    getResolver: (name: string) => opts.driver.getResolver(name),\n    meta: opts.meta ?? { circularNames: [], enumNames: [] },\n    addFile: async (...files: Array<FileNode>) => opts.driver.fileManager.add(...files),\n    upsertFile: async (...files: Array<FileNode>) => opts.driver.fileManager.upsert(...files),\n    hooks: opts.driver.hooks ?? ({} as never),\n    warn: (msg: string) => console.warn(msg),\n    error: (msg: string) => console.error(msg),\n    info: (msg: string) => console.info(msg),\n    openInStudio: async () => {},\n  } as unknown as Omit<GeneratorContext<TOptions>, 'options'>\n}\n\n/**\n * Renders a generator's `schema` method in a test context.\n *\n * @example\n * ```ts\n * await renderGeneratorSchema(typeGenerator, node, { config, adapter, driver, plugin, options, resolver })\n * await matchFiles(driver.fileManager.files)\n * ```\n */\nexport async function renderGeneratorSchema<TOptions extends PluginFactoryOptions>(\n  generator: Generator<TOptions>,\n  node: SchemaNode,\n  opts: RenderGeneratorOptions<TOptions>,\n): Promise<void> {\n  if (!generator.schema) return\n  const context = createMockedPluginContext(opts)\n  const transformedNode = opts.plugin.transformer ? transform(node, opts.plugin.transformer) : node\n  const result = await generator.schema(transformedNode, {\n    ...context,\n    options: opts.options,\n  })\n  await opts.driver.dispatch({ result, renderer: generator.renderer })\n}\n\n/**\n * Renders a generator's `operation` method in a test context.\n *\n * @example\n * ```ts\n * await renderGeneratorOperation(typeGenerator, node, { config, adapter, driver, plugin, options, resolver })\n * await matchFiles(driver.fileManager.files)\n * ```\n */\nexport async function renderGeneratorOperation<TOptions extends PluginFactoryOptions>(\n  generator: Generator<TOptions>,\n  node: OperationNode,\n  opts: RenderGeneratorOptions<TOptions>,\n): Promise<void> {\n  if (!generator.operation) return\n  const context = createMockedPluginContext(opts)\n  const transformedNode = opts.plugin.transformer ? transform(node, opts.plugin.transformer) : node\n  const result = await generator.operation(transformedNode, {\n    ...context,\n    options: opts.options,\n  })\n  await opts.driver.dispatch({ result, renderer: generator.renderer })\n}\n\n/**\n * Renders a generator's `operations` method in a test context.\n *\n * @example\n * ```ts\n * await renderGeneratorOperations(classClientGenerator, nodes, { config, adapter, driver, plugin, options, resolver })\n * await matchFiles(driver.fileManager.files)\n * ```\n */\nexport async function renderGeneratorOperations<TOptions extends PluginFactoryOptions>(\n  generator: Generator<TOptions>,\n  nodes: Array<OperationNode>,\n  opts: RenderGeneratorOptions<TOptions>,\n): Promise<void> {\n  if (!generator.operations) return\n  const context = createMockedPluginContext(opts)\n  const transformedNodes = opts.plugin.transformer ? nodes.map((n) => transform(n, opts.plugin.transformer!)) : nodes\n  const result = await generator.operations(transformedNodes, {\n    ...context,\n    options: opts.options,\n  })\n  await opts.driver.dispatch({ result, renderer: generator.renderer })\n}\n"],"mappings":";;;;;;;;;AAWA,SAAgB,yBAAyB,UAAyE,CAAC,GAAe;CAChI,OAAO;EACL,QAAQ,SAAS,UAAU;GACzB,MAAM;GACN,QAAQ,EACN,MAAM,SACR;EACF;EACA,UAAU,aAAmD;GAC3D,OAAO,SAAS;EAClB;EACA,cAAc,gBAAwB,SAAS,QAAQ;EACvD,aAAa,IAAI,YAAY;CAC/B;AACF;;;;;;AAOA,SAAgB,oBACd,UAKI,CAAC,GACc;CACnB,OAAO;EACL,MAAO,QAAQ,QAAQ;EACvB,SAAU,QAAQ,mBAAmB,CAAC;EACtC,OAAO,QAAQ,UAAU,aAAa;GAAE,MAAM;GAAkB,SAAS,CAAC;GAAG,YAAY,CAAC;EAAE;EAC5F,YAAY,QAAQ,gBAAgB,OAAmB,aAAqE,CAAC;CAC/H;AACF;;;;;;;AAQA,SAAgB,mBAAiF,QAMlE;CAC7B,OAAO;EACL,MAAM,OAAO;EACb,SAAS,OAAO;EAChB,UAAU,OAAO;EACjB,aAAa,OAAO;EACpB,cAAc,OAAO;EACrB,OAAO,CAAC;CACV;AACF;AAYA,SAAS,0BAAiE,MAAqF;CAC7J,MAAM,OAAO,QAAQ,KAAK,OAAO,MAAM,KAAK,OAAO,OAAO,IAAI;CAE9D,OAAO;EACL,QAAQ,KAAK;EACb;EACA,UAAU,WAA6B,WAAW,QAAQ,QAAQ,MAAM,OAAO,IAAI,CAAC;EACpF,SAAS,KAAK;EACd,UAAU,KAAK;EACf,QAAQ,KAAK;EACb,QAAQ,KAAK;EACb,cAAc,SAAiB,KAAK,OAAO,YAAY,IAAI;EAC3D,MAAM,KAAK,QAAQ;GAAE,eAAe,CAAC;GAAG,WAAW,CAAC;EAAE;EACtD,SAAS,OAAO,GAAG,UAA2B,KAAK,OAAO,YAAY,IAAI,GAAG,KAAK;EAClF,YAAY,OAAO,GAAG,UAA2B,KAAK,OAAO,YAAY,OAAO,GAAG,KAAK;EACxF,OAAO,KAAK,OAAO,SAAU,CAAC;EAC9B,OAAO,QAAgB,QAAQ,KAAK,GAAG;EACvC,QAAQ,QAAgB,QAAQ,MAAM,GAAG;EACzC,OAAO,QAAgB,QAAQ,KAAK,GAAG;EACvC,cAAc,YAAY,CAAC;CAC7B;AACF;;;;;;;;;;AAWA,eAAsB,sBACpB,WACA,MACA,MACe;CACf,IAAI,CAAC,UAAU,QAAQ;CACvB,MAAM,UAAU,0BAA0B,IAAI;CAC9C,MAAM,kBAAkB,KAAK,OAAO,cAAc,UAAU,MAAM,KAAK,OAAO,WAAW,IAAI;CAC7F,MAAM,SAAS,MAAM,UAAU,OAAO,iBAAiB;EACrD,GAAG;EACH,SAAS,KAAK;CAChB,CAAC;CACD,MAAM,KAAK,OAAO,SAAS;EAAE;EAAQ,UAAU,UAAU;CAAS,CAAC;AACrE;;;;;;;;;;AAWA,eAAsB,yBACpB,WACA,MACA,MACe;CACf,IAAI,CAAC,UAAU,WAAW;CAC1B,MAAM,UAAU,0BAA0B,IAAI;CAC9C,MAAM,kBAAkB,KAAK,OAAO,cAAc,UAAU,MAAM,KAAK,OAAO,WAAW,IAAI;CAC7F,MAAM,SAAS,MAAM,UAAU,UAAU,iBAAiB;EACxD,GAAG;EACH,SAAS,KAAK;CAChB,CAAC;CACD,MAAM,KAAK,OAAO,SAAS;EAAE;EAAQ,UAAU,UAAU;CAAS,CAAC;AACrE;;;;;;;;;;AAWA,eAAsB,0BACpB,WACA,OACA,MACe;CACf,IAAI,CAAC,UAAU,YAAY;CAC3B,MAAM,UAAU,0BAA0B,IAAI;CAC9C,MAAM,mBAAmB,KAAK,OAAO,cAAc,MAAM,KAAK,MAAM,UAAU,GAAG,KAAK,OAAO,WAAY,CAAC,IAAI;CAC9G,MAAM,SAAS,MAAM,UAAU,WAAW,kBAAkB;EAC1D,GAAG;EACH,SAAS,KAAK;CAChB,CAAC;CACD,MAAM,KAAK,OAAO,SAAS;EAAE;EAAQ,UAAU,UAAU;CAAS,CAAC;AACrE"}
+{"version":3,"file":"mocks.js","names":[],"sources":["../src/mocks.ts"],"sourcesContent":["import { resolve } from 'node:path'\nimport type { FileNode, InputMeta, OperationNode, SchemaNode, Visitor } from '@kubb/ast'\nimport { transform } from '@kubb/ast'\nimport { FileManager } from './FileManager.ts'\nimport { KubbDriver } from './KubbDriver.ts'\nimport type { Adapter, AdapterFactoryOptions, Config, Generator, GeneratorContext, NormalizedPlugin, PluginFactoryOptions, RendererFactory } from './types.ts'\n\n/**\n\n * Creates a minimal `PluginDriver` mock for unit tests.\n */\nexport function createMockedPluginDriver(options: { name?: string; plugin?: NormalizedPlugin; config?: Config } = {}): KubbDriver {\n  const fileManager = new FileManager()\n\n  return {\n    config: options?.config ?? {\n      root: '.',\n      output: {\n        path: './path',\n      },\n    },\n    getPlugin(_pluginName: string): NormalizedPlugin | undefined {\n      return options?.plugin\n    },\n    getResolver: (_pluginName: string) => options?.plugin?.resolver,\n    fileManager,\n    async dispatch({ result, renderer }: { result: unknown; renderer?: RendererFactory | null }): Promise<void> {\n      if (!result) return\n\n      if (Array.isArray(result)) {\n        fileManager.upsert(...(result as Array<FileNode>))\n        return\n      }\n\n      if (!renderer) return\n\n      using instance = renderer()\n      if (instance.stream) {\n        for (const file of instance.stream(result)) fileManager.upsert(file)\n        return\n      }\n\n      await instance.render(result)\n      fileManager.upsert(...instance.files)\n    },\n  } as unknown as KubbDriver\n}\n\n/**\n * Creates a minimal `Adapter` mock for unit tests.\n * `parse` returns an empty `InputNode` by default. Override via `options.parse`.\n * `getImports` returns `[]` by default.\n */\nexport function createMockedAdapter<TOptions extends AdapterFactoryOptions = AdapterFactoryOptions>(\n  options: {\n    name?: TOptions['name']\n    resolvedOptions?: TOptions['resolvedOptions']\n    parse?: Adapter<TOptions>['parse']\n    getImports?: Adapter<TOptions>['getImports']\n  } = {},\n): Adapter<TOptions> {\n  return {\n    name: (options.name ?? 'oas') as TOptions['name'],\n    options: (options.resolvedOptions ?? {}) as TOptions['resolvedOptions'],\n    parse: options.parse ?? (async () => ({ kind: 'Input' as const, schemas: [], operations: [] })),\n    getImports: options.getImports ?? ((_node: SchemaNode, _resolve: (schemaName: string) => { name: string; path: string }) => []),\n  } as Adapter<TOptions>\n}\n\n/**\n * Creates a minimal plugin mock for unit tests.\n *\n * @example\n * `const plugin = createMockedPlugin<PluginTs>({ name: '@kubb/plugin-ts', options })`\n */\nexport function createMockedPlugin<TOptions extends PluginFactoryOptions = PluginFactoryOptions>(params: {\n  name: TOptions['name']\n  options: TOptions['resolvedOptions']\n  resolver?: TOptions['resolver']\n  transformer?: Visitor\n  dependencies?: Array<string>\n}): NormalizedPlugin<TOptions> {\n  return {\n    name: params.name,\n    options: params.options,\n    resolver: params.resolver,\n    transformer: params.transformer,\n    dependencies: params.dependencies,\n    hooks: {},\n  } as unknown as NormalizedPlugin<TOptions>\n}\n\ntype RenderGeneratorOptions<TOptions extends PluginFactoryOptions> = {\n  config: Config\n  adapter: Adapter\n  meta?: InputMeta\n  driver: KubbDriver\n  plugin: NormalizedPlugin<TOptions>\n  options: TOptions['resolvedOptions']\n  resolver: TOptions['resolver']\n}\n\nfunction createMockedPluginContext<TOptions extends PluginFactoryOptions>(opts: RenderGeneratorOptions<TOptions>): Omit<GeneratorContext<TOptions>, 'options'> {\n  const root = resolve(opts.config.root, opts.config.output.path)\n\n  return {\n    config: opts.config,\n    root,\n    getMode: (output: { path: string }) => KubbDriver.getMode(resolve(root, output.path)),\n    adapter: opts.adapter,\n    resolver: opts.resolver,\n    plugin: opts.plugin,\n    driver: opts.driver,\n    getResolver: (name: string) => opts.driver.getResolver(name),\n    meta: opts.meta ?? { circularNames: [], enumNames: [] },\n    addFile: async (...files: Array<FileNode>) => opts.driver.fileManager.add(...files),\n    upsertFile: async (...files: Array<FileNode>) => opts.driver.fileManager.upsert(...files),\n    hooks: opts.driver.hooks ?? ({} as never),\n    warn: (msg: string) => console.warn(msg),\n    error: (msg: string) => console.error(msg),\n    info: (msg: string) => console.info(msg),\n    openInStudio: async () => {},\n  } as unknown as Omit<GeneratorContext<TOptions>, 'options'>\n}\n\n/**\n * Renders a generator's `schema` method in a test context.\n *\n * @example\n * ```ts\n * await renderGeneratorSchema(typeGenerator, node, { config, adapter, driver, plugin, options, resolver })\n * await matchFiles(driver.fileManager.files)\n * ```\n */\nexport async function renderGeneratorSchema<TOptions extends PluginFactoryOptions>(\n  generator: Generator<TOptions>,\n  node: SchemaNode,\n  opts: RenderGeneratorOptions<TOptions>,\n): Promise<void> {\n  if (!generator.schema) return\n  const context = createMockedPluginContext(opts)\n  const transformedNode = opts.plugin.transformer ? transform(node, opts.plugin.transformer) : node\n  const result = await generator.schema(transformedNode, {\n    ...context,\n    options: opts.options,\n  })\n  await opts.driver.dispatch({ result, renderer: generator.renderer })\n}\n\n/**\n * Renders a generator's `operation` method in a test context.\n *\n * @example\n * ```ts\n * await renderGeneratorOperation(typeGenerator, node, { config, adapter, driver, plugin, options, resolver })\n * await matchFiles(driver.fileManager.files)\n * ```\n */\nexport async function renderGeneratorOperation<TOptions extends PluginFactoryOptions>(\n  generator: Generator<TOptions>,\n  node: OperationNode,\n  opts: RenderGeneratorOptions<TOptions>,\n): Promise<void> {\n  if (!generator.operation) return\n  const context = createMockedPluginContext(opts)\n  const transformedNode = opts.plugin.transformer ? transform(node, opts.plugin.transformer) : node\n  const result = await generator.operation(transformedNode, {\n    ...context,\n    options: opts.options,\n  })\n  await opts.driver.dispatch({ result, renderer: generator.renderer })\n}\n\n/**\n * Renders a generator's `operations` method in a test context.\n *\n * @example\n * ```ts\n * await renderGeneratorOperations(classClientGenerator, nodes, { config, adapter, driver, plugin, options, resolver })\n * await matchFiles(driver.fileManager.files)\n * ```\n */\nexport async function renderGeneratorOperations<TOptions extends PluginFactoryOptions>(\n  generator: Generator<TOptions>,\n  nodes: Array<OperationNode>,\n  opts: RenderGeneratorOptions<TOptions>,\n): Promise<void> {\n  if (!generator.operations) return\n  const context = createMockedPluginContext(opts)\n  const transformedNodes = opts.plugin.transformer ? nodes.map((n) => transform(n, opts.plugin.transformer!)) : nodes\n  const result = await generator.operations(transformedNodes, {\n    ...context,\n    options: opts.options,\n  })\n  await opts.driver.dispatch({ result, renderer: generator.renderer })\n}\n"],"mappings":";;;;;;;;;AAWA,SAAgB,yBAAyB,UAAyE,CAAC,GAAe;CAChI,MAAM,cAAc,IAAI,YAAY;CAEpC,OAAO;EACL,QAAQ,SAAS,UAAU;GACzB,MAAM;GACN,QAAQ,EACN,MAAM,SACR;EACF;EACA,UAAU,aAAmD;GAC3D,OAAO,SAAS;EAClB;EACA,cAAc,gBAAwB,SAAS,QAAQ;EACvD;EACA,MAAM,SAAS,EAAE,QAAQ,YAAmF;;;IAC1G,IAAI,CAAC,QAAQ;IAEb,IAAI,MAAM,QAAQ,MAAM,GAAG;KACzB,YAAY,OAAO,GAAI,MAA0B;KACjD;IACF;IAEA,IAAI,CAAC,UAAU;IAEf,MAAM,WAAA,YAAA,EAAW,SAAS,CAAA;IAC1B,IAAI,SAAS,QAAQ;KACnB,KAAK,MAAM,QAAQ,SAAS,OAAO,MAAM,GAAG,YAAY,OAAO,IAAI;KACnE;IACF;IAEA,MAAM,SAAS,OAAO,MAAM;IAC5B,YAAY,OAAO,GAAG,SAAS,KAAK;;;;;;EACtC;CACF;AACF;;;;;;AAOA,SAAgB,oBACd,UAKI,CAAC,GACc;CACnB,OAAO;EACL,MAAO,QAAQ,QAAQ;EACvB,SAAU,QAAQ,mBAAmB,CAAC;EACtC,OAAO,QAAQ,UAAU,aAAa;GAAE,MAAM;GAAkB,SAAS,CAAC;GAAG,YAAY,CAAC;EAAE;EAC5F,YAAY,QAAQ,gBAAgB,OAAmB,aAAqE,CAAC;CAC/H;AACF;;;;;;;AAQA,SAAgB,mBAAiF,QAMlE;CAC7B,OAAO;EACL,MAAM,OAAO;EACb,SAAS,OAAO;EAChB,UAAU,OAAO;EACjB,aAAa,OAAO;EACpB,cAAc,OAAO;EACrB,OAAO,CAAC;CACV;AACF;AAYA,SAAS,0BAAiE,MAAqF;CAC7J,MAAM,OAAO,QAAQ,KAAK,OAAO,MAAM,KAAK,OAAO,OAAO,IAAI;CAE9D,OAAO;EACL,QAAQ,KAAK;EACb;EACA,UAAU,WAA6B,WAAW,QAAQ,QAAQ,MAAM,OAAO,IAAI,CAAC;EACpF,SAAS,KAAK;EACd,UAAU,KAAK;EACf,QAAQ,KAAK;EACb,QAAQ,KAAK;EACb,cAAc,SAAiB,KAAK,OAAO,YAAY,IAAI;EAC3D,MAAM,KAAK,QAAQ;GAAE,eAAe,CAAC;GAAG,WAAW,CAAC;EAAE;EACtD,SAAS,OAAO,GAAG,UAA2B,KAAK,OAAO,YAAY,IAAI,GAAG,KAAK;EAClF,YAAY,OAAO,GAAG,UAA2B,KAAK,OAAO,YAAY,OAAO,GAAG,KAAK;EACxF,OAAO,KAAK,OAAO,SAAU,CAAC;EAC9B,OAAO,QAAgB,QAAQ,KAAK,GAAG;EACvC,QAAQ,QAAgB,QAAQ,MAAM,GAAG;EACzC,OAAO,QAAgB,QAAQ,KAAK,GAAG;EACvC,cAAc,YAAY,CAAC;CAC7B;AACF;;;;;;;;;;AAWA,eAAsB,sBACpB,WACA,MACA,MACe;CACf,IAAI,CAAC,UAAU,QAAQ;CACvB,MAAM,UAAU,0BAA0B,IAAI;CAC9C,MAAM,kBAAkB,KAAK,OAAO,cAAc,UAAU,MAAM,KAAK,OAAO,WAAW,IAAI;CAC7F,MAAM,SAAS,MAAM,UAAU,OAAO,iBAAiB;EACrD,GAAG;EACH,SAAS,KAAK;CAChB,CAAC;CACD,MAAM,KAAK,OAAO,SAAS;EAAE;EAAQ,UAAU,UAAU;CAAS,CAAC;AACrE;;;;;;;;;;AAWA,eAAsB,yBACpB,WACA,MACA,MACe;CACf,IAAI,CAAC,UAAU,WAAW;CAC1B,MAAM,UAAU,0BAA0B,IAAI;CAC9C,MAAM,kBAAkB,KAAK,OAAO,cAAc,UAAU,MAAM,KAAK,OAAO,WAAW,IAAI;CAC7F,MAAM,SAAS,MAAM,UAAU,UAAU,iBAAiB;EACxD,GAAG;EACH,SAAS,KAAK;CAChB,CAAC;CACD,MAAM,KAAK,OAAO,SAAS;EAAE;EAAQ,UAAU,UAAU;CAAS,CAAC;AACrE;;;;;;;;;;AAWA,eAAsB,0BACpB,WACA,OACA,MACe;CACf,IAAI,CAAC,UAAU,YAAY;CAC3B,MAAM,UAAU,0BAA0B,IAAI;CAC9C,MAAM,mBAAmB,KAAK,OAAO,cAAc,MAAM,KAAK,MAAM,UAAU,GAAG,KAAK,OAAO,WAAY,CAAC,IAAI;CAC9G,MAAM,SAAS,MAAM,UAAU,WAAW,kBAAkB;EAC1D,GAAG;EACH,SAAS,KAAK;CAChB,CAAC;CACD,MAAM,KAAK,OAAO,SAAS;EAAE;EAAQ,UAAU,UAAU;CAAS,CAAC;AACrE"}

package.json

 {
   "name": "@kubb/core",
-  "version": "5.0.0-beta.37",
+  "version": "5.0.0-beta.38",
   "description": "Core engine for Kubb's plugin-based code generation system. Provides the plugin driver, file manager, defineConfig, and build orchestration used by every Kubb plugin.",
@@ -61,10 +61,10 @@ "keywords": [
     "tinyexec": "~1.1.2",
-    "@kubb/ast": "5.0.0-beta.37"
+    "@kubb/ast": "5.0.0-beta.38"
   },
   "devDependencies": {
     "@internals/utils": "0.0.0",
-    "@kubb/renderer-jsx": "5.0.0-beta.37"
+    "@kubb/renderer-jsx": "5.0.0-beta.38"
   },
   "peerDependencies": {
-    "@kubb/renderer-jsx": "5.0.0-beta.37"
+    "@kubb/renderer-jsx": "5.0.0-beta.38"
   },
@@ -71,0 +71,0 @@ "size-limit": [

src/createReporter.ts

@@ -47,5 +47,5 @@ import type { logLevel } from './constants.ts'
 /**
- * Reporter contract. Unlike a Logger (the live TUI view), a reporter never sees the event
- * emitter. `report` is called once per config with its {@link GenerationResult} and produces
- * output (a terminal summary, a JSON report, a log file).
+ * Host-facing reporter, as installed onto a run. Unlike a Logger (the live TUI view), a reporter
+ * never sees the event emitter. `report` runs once per config; `flush`, when present, runs once
+ * after the last config.
  */
@@ -61,10 +61,25 @@ export type Reporter = {
   report: (result: GenerationResult, context: ReporterContext) => void | Promise<void>
+  /**
+   * Optional finalizer called once after the run's last config. The host wires it to
+   * `kubb:lifecycle:end`. {@link createReporter} closes it over the reports `report` returned.
+   */
+  flush?: (context: ReporterContext) => void | Promise<void>
 }
 
-export type UserReporter = Reporter
+/**
+ * Reporter definition passed to {@link createReporter}. `report` returns the value to collect for
+ * this config (e.g. a built report), and the optional `flush` receives the collected reports to
+ * emit as one document. `T` is inferred from `report`'s return type.
+ */
+export type UserReporter<T = void> = {
+  name: string
+  report: (result: GenerationResult, context: ReporterContext) => T | Promise<T>
+  flush?: (context: ReporterContext, reports: Array<T>) => void | Promise<void>
+}
 
 /**
- * Defines a reporter. Returns the reporter unchanged at runtime. It exists for type inference and
- * to mark the value as a reporter, mirroring {@link defineLogger}. Wiring the reporter onto the
- * run's events is the host's job, so the reporter only ever deals with a {@link GenerationResult}.
+ * Defines a reporter. When the definition has a `flush`, the returned reporter buffers each value
+ * `report` returns and hands the array to `flush` once, then clears it. Without a `flush`, nothing
+ * is buffered. Wiring the reporter onto the run's events is the host's job, so the reporter only
+ * ever deals with a {@link GenerationResult}.
  *
@@ -78,10 +93,28 @@ * @example
  *   report(result) {
- *     const status = Diagnostics.hasError(result.diagnostics) ? 'failed' : 'success'
- *     process.stdout.write(`${JSON.stringify({ status, diagnostics: result.diagnostics }, null, 2)}\n`)
+ *     return { status: Diagnostics.hasError(result.diagnostics) ? 'failed' : 'success', diagnostics: result.diagnostics }
  *   },
+ *   flush(context, reports) {
+ *     process.stdout.write(`${JSON.stringify(reports, null, 2)}\n`)
+ *   },
  * })
  * ```
  */
-export function createReporter(reporter: UserReporter): Reporter {
-  return reporter
+export function createReporter<T = void>(reporter: UserReporter<T>): Reporter {
+  const flush = reporter.flush
+  if (!flush) {
+    return { name: reporter.name, report: reporter.report }
+  }
+
+  const reports: Array<T> = []
+
+  return {
+    name: reporter.name,
+    async report(result, context) {
+      reports.push(await reporter.report(result, context))
+    },
+    async flush(context) {
+      await flush(context, reports)
+      reports.length = 0
+    },
+  }
 }

src/KubbDriver.ts

@@ -805,13 +805,7 @@ import { resolve } from 'node:path'
 
+    // Collect into the active build only. The host renders each collected diagnostic once after the
+    // build (the CLI via `Diagnostics.emit`, the agent via its post-build loop), so emitting a live
+    // `kubb:error`/`kubb:warn`/`kubb:info` here would render it twice.
     const report = (diagnostic: Omit<ProblemDiagnostic, 'plugin'>): void => {
       Diagnostics.report({ ...diagnostic, plugin: plugin.name })
-      if (diagnostic.severity === 'error') {
-        driver.hooks.emit('kubb:error', { error: diagnostic.cause ?? new Error(diagnostic.message) })
-        return
-      }
-      if (diagnostic.severity === 'warning') {
-        driver.hooks.emit('kubb:warn', { message: diagnostic.message })
-        return
-      }
-      driver.hooks.emit('kubb:info', { message: diagnostic.message })
     }
@@ -818,0 +812,0 @@

src/mocks.ts

@@ -6,3 +6,3 @@ import { resolve } from 'node:path'
 import { KubbDriver } from './KubbDriver.ts'
-import type { Adapter, AdapterFactoryOptions, Config, Generator, GeneratorContext, NormalizedPlugin, PluginFactoryOptions } from './types.ts'
+import type { Adapter, AdapterFactoryOptions, Config, Generator, GeneratorContext, NormalizedPlugin, PluginFactoryOptions, RendererFactory } from './types.ts'
 
@@ -14,2 +14,4 @@ /**
 export function createMockedPluginDriver(options: { name?: string; plugin?: NormalizedPlugin; config?: Config } = {}): KubbDriver {
+  const fileManager = new FileManager()
+
   return {
@@ -26,3 +28,22 @@ config: options?.config ?? {
     getResolver: (_pluginName: string) => options?.plugin?.resolver,
-    fileManager: new FileManager(),
+    fileManager,
+    async dispatch({ result, renderer }: { result: unknown; renderer?: RendererFactory | null }): Promise<void> {
+      if (!result) return
+
+      if (Array.isArray(result)) {
+        fileManager.upsert(...(result as Array<FileNode>))
+        return
+      }
+
+      if (!renderer) return
+
+      using instance = renderer()
+      if (instance.stream) {
+        for (const file of instance.stream(result)) fileManager.upsert(file)
+        return
+      }
+
+      await instance.render(result)
+      fileManager.upsert(...instance.files)
+    },
   } as unknown as KubbDriver
@@ -29,0 +50,0 @@ }

New alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

URL strings

Supply chain risk

Package contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.

Found 1 instance in 1 package

Fixed alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

URL strings

Supply chain risk

Package contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

1079844

0.56%

Lines of code

15857

0.78%

Dependency changes

• + Added

  @kubb/ast@5.0.0-beta.38
  (transitive)

• + Added

  @kubb/renderer-jsx@5.0.0-beta.38
  (transitive)

• - Removed

  @kubb/ast@5.0.0-beta.37
  (transitive)

• - Removed

  @kubb/renderer-jsx@5.0.0-beta.37
  (transitive)

• Updated

  @kubb/ast@5.0.0-beta.38