fixx error

jonaslagoni · jonaslagoni · commit ac447e1b5d8f · 2026-01-27T20:13:20.000+01:00
diff --git a/src/LoggingInterface.ts b/src/LoggingInterface.ts
@@ -4,7 +4,13 @@
  */
 import pc from 'picocolors';
 
-export type LogLevel = 'silent' | 'error' | 'warn' | 'info' | 'verbose' | 'debug';
+export type LogLevel =
+  | 'silent'
+  | 'error'
+  | 'warn'
+  | 'info'
+  | 'verbose'
+  | 'debug';
 
 const LOG_LEVEL_PRIORITY: Record<LogLevel, number> = {
   silent: 0,
@@ -104,6 +110,7 @@ export class LoggerClass implements ExtendedLoggingInterface {
   private pauseSpinner(): void {
     if (this.spinner?.interval) {
       clearInterval(this.spinner.interval);
+      this.spinner.interval = null;
       // Clear the current line
       if (process.stdout.isTTY) {
         process.stdout.clearLine(0);
@@ -266,8 +273,9 @@ export class LoggerClass implements ExtendedLoggingInterface {
    * Stop the spinner with a success message
    */
   succeedSpinner(text?: string): void {
+    const spinnerText = this.spinner?.text;
     this.stopSpinner();
-    const displayText = text || this.spinner?.text || '';
+    const displayText = text || spinnerText || '';
     if (displayText && this.shouldLog('info')) {
       const symbol = this.colorsEnabled ? pc.green('✓') : '[OK]';
       console.log(`${symbol} ${displayText}`);
@@ -278,8 +286,9 @@ export class LoggerClass implements ExtendedLoggingInterface {
    * Stop the spinner with a failure message
    */
   failSpinner(text?: string): void {
+    const spinnerText = this.spinner?.text;
     this.stopSpinner();
-    const displayText = text || this.spinner?.text || '';
+    const displayText = text || spinnerText || '';
     if (displayText && this.shouldLog('error')) {
       const symbol = this.colorsEnabled ? pc.red('✗') : '[FAIL]';
       console.log(`${symbol} ${displayText}`);
diff --git a/src/codegen/errors.ts b/src/codegen/errors.ts
@@ -344,4 +344,3 @@ export function parseZodErrors(zodError: any): string[] {
 
   return errors;
 }
-
diff --git a/src/codegen/generators/typescript/channels/asyncapi.ts b/src/codegen/generators/typescript/channels/asyncapi.ts
@@ -116,7 +116,10 @@ export async function generateTypeScriptChannelsForAsyncAPI(
     if (channel.parameters().length > 0) {
       parameter = parameters.channelModels[channel.id()];
       if (parameter === undefined) {
-        throw createMissingParameterError({channelOrOperation: channel.id(), protocol: 'channels'});
+        throw createMissingParameterError({
+          channelOrOperation: channel.id(),
+          protocol: 'channels'
+        });
       }
     }
 
@@ -210,10 +213,16 @@ function validateAsyncapiContext(context: TypeScriptChannelsContext): {
 } {
   const {asyncapiDocument, inputType} = context;
   if (inputType !== 'asyncapi') {
-    throw createMissingInputDocumentError({expectedType: 'asyncapi', generatorPreset: 'channels'});
+    throw createMissingInputDocumentError({
+      expectedType: 'asyncapi',
+      generatorPreset: 'channels'
+    });
   }
   if (asyncapiDocument === undefined) {
-    throw createMissingInputDocumentError({expectedType: 'asyncapi', generatorPreset: 'channels'});
+    throw createMissingInputDocumentError({
+      expectedType: 'asyncapi',
+      generatorPreset: 'channels'
+    });
   }
   return {asyncapiDocument};
 }
diff --git a/src/codegen/generators/typescript/channels/openapi.ts b/src/codegen/generators/typescript/channels/openapi.ts
@@ -243,10 +243,16 @@ function validateOpenAPIContext(context: TypeScriptChannelsContext): {
 } {
   const {openapiDocument, inputType} = context;
   if (inputType !== 'openapi') {
-    throw createMissingInputDocumentError({expectedType: 'openapi', generatorPreset: 'channels'});
+    throw createMissingInputDocumentError({
+      expectedType: 'openapi',
+      generatorPreset: 'channels'
+    });
   }
   if (!openapiDocument) {
-    throw createMissingInputDocumentError({expectedType: 'openapi', generatorPreset: 'channels'});
+    throw createMissingInputDocumentError({
+      expectedType: 'openapi',
+      generatorPreset: 'channels'
+    });
   }
   return {openapiDocument};
 }
diff --git a/src/codegen/generators/typescript/channels/protocols/amqp/index.ts b/src/codegen/generators/typescript/channels/protocols/amqp/index.ts
@@ -101,7 +101,10 @@ async function generateForOperations(
     const payloadId = findOperationId(operation, channel);
     const payload = payloads.operationModels[payloadId];
     if (!payload) {
-      throw createMissingPayloadError({channelOrOperation: payloadId, protocol: 'AMQP'});
+      throw createMissingPayloadError({
+        channelOrOperation: payloadId,
+        protocol: 'AMQP'
+      });
     }
 
     const {messageModule, messageType} = getMessageTypeAndModule(payload);
@@ -186,7 +189,10 @@ async function generateForChannels(
 
   const payload = payloads.channelModels[channel.id()];
   if (!payload) {
-    throw createMissingPayloadError({channelOrOperation: channel.id(), protocol: 'AMQP'});
+    throw createMissingPayloadError({
+      channelOrOperation: channel.id(),
+      protocol: 'AMQP'
+    });
   }
 
   const {messageModule, messageType} = getMessageTypeAndModule(payload);
diff --git a/src/codegen/generators/typescript/channels/protocols/eventsource/index.ts b/src/codegen/generators/typescript/channels/protocols/eventsource/index.ts
@@ -184,7 +184,10 @@ async function generateForChannels(
 
   const payload = payloads.channelModels[channel.id()];
   if (!payload) {
-    throw createMissingPayloadError({channelOrOperation: channel.id(), protocol: 'EventSource'});
+    throw createMissingPayloadError({
+      channelOrOperation: channel.id(),
+      protocol: 'EventSource'
+    });
   }
 
   const {messageModule, messageType} = getMessageTypeAndModule(payload);
diff --git a/src/codegen/generators/typescript/channels/protocols/kafka/index.ts b/src/codegen/generators/typescript/channels/protocols/kafka/index.ts
@@ -101,7 +101,10 @@ async function generateForOperations(
     const payloadId = findOperationId(operation, channel);
     const payload = payloads.operationModels[payloadId];
     if (!payload) {
-      throw createMissingPayloadError({channelOrOperation: payloadId, protocol: 'Kafka'});
+      throw createMissingPayloadError({
+        channelOrOperation: payloadId,
+        protocol: 'Kafka'
+      });
     }
 
     const {messageModule, messageType} = getMessageTypeAndModule(payload);
@@ -175,7 +178,10 @@ async function generateForChannels(
 
   const payload = payloads.channelModels[channel.id()];
   if (!payload) {
-    throw createMissingPayloadError({channelOrOperation: channel.id(), protocol: 'Kafka'});
+    throw createMissingPayloadError({
+      channelOrOperation: channel.id(),
+      protocol: 'Kafka'
+    });
   }
 
   const {messageModule, messageType} = getMessageTypeAndModule(payload);
diff --git a/src/codegen/generators/typescript/channels/protocols/mqtt/index.ts b/src/codegen/generators/typescript/channels/protocols/mqtt/index.ts
@@ -99,7 +99,10 @@ function generateForOperations(
     const payloadId = findOperationId(operation, channel);
     const payload = payloads.operationModels[payloadId];
     if (payload === undefined) {
-      throw createMissingPayloadError({channelOrOperation: payloadId, protocol: 'MQTT'});
+      throw createMissingPayloadError({
+        channelOrOperation: payloadId,
+        protocol: 'MQTT'
+      });
     }
     const {messageModule, messageType} = getMessageTypeAndModule(payload);
     if (messageType === undefined) {
@@ -152,7 +155,10 @@ function generateForChannels(
     getFunctionTypeMappingFromAsyncAPI(channel) ?? functionTypeMapping;
   const payload = payloads.channelModels[channel.id()];
   if (payload === undefined) {
-    throw createMissingPayloadError({channelOrOperation: channel.id(), protocol: 'MQTT'});
+    throw createMissingPayloadError({
+      channelOrOperation: channel.id(),
+      protocol: 'MQTT'
+    });
   }
   const {messageModule, messageType} = getMessageTypeAndModule(payload);
   if (messageType === undefined) {
diff --git a/src/codegen/generators/typescript/channels/protocols/nats/index.ts b/src/codegen/generators/typescript/channels/protocols/nats/index.ts
@@ -324,7 +324,10 @@ async function generateForChannels(
 
   const payload = payloads.channelModels[channel.id()];
   if (!payload) {
-    throw createMissingPayloadError({channelOrOperation: channel.id(), protocol: 'NATS'});
+    throw createMissingPayloadError({
+      channelOrOperation: channel.id(),
+      protocol: 'NATS'
+    });
   }
 
   const {messageModule, messageType} = getMessageTypeAndModule(payload);
diff --git a/src/codegen/generators/typescript/channels/protocols/websocket/index.ts b/src/codegen/generators/typescript/channels/protocols/websocket/index.ts
@@ -204,7 +204,10 @@ async function generateForChannels(
 
   const payload = payloads.channelModels[channel.id()];
   if (!payload) {
-    throw createMissingPayloadError({channelOrOperation: channel.id(), protocol: 'WebSocket'});
+    throw createMissingPayloadError({
+      channelOrOperation: channel.id(),
+      protocol: 'WebSocket'
+    });
   }
 
   const {messageModule, messageType} = getMessageTypeAndModule(payload);
diff --git a/src/codegen/generators/typescript/client/index.ts b/src/codegen/generators/typescript/client/index.ts
@@ -34,7 +34,10 @@ export async function generateTypeScriptClient(
 ): Promise<TypeScriptClientRenderType> {
   const {asyncapiDocument, generator, inputType} = context;
   if (inputType === 'asyncapi' && asyncapiDocument === undefined) {
-    throw createMissingInputDocumentError({expectedType: 'asyncapi', generatorPreset: 'client'});
+    throw createMissingInputDocumentError({
+      expectedType: 'asyncapi',
+      generatorPreset: 'client'
+    });
   }
 
   await mkdir(context.generator.outputPath, {recursive: true});
diff --git a/src/codegen/generators/typescript/client/protocols/nats.ts b/src/codegen/generators/typescript/client/protocols/nats.ts
@@ -28,17 +28,26 @@ export async function generateNatsClient(
 ): Promise<string> {
   const {asyncapiDocument, generator, inputType} = context;
   if (inputType === 'asyncapi' && asyncapiDocument === undefined) {
-    throw createMissingInputDocumentError({expectedType: 'asyncapi', generatorPreset: 'client'});
+    throw createMissingInputDocumentError({
+      expectedType: 'asyncapi',
+      generatorPreset: 'client'
+    });
   }
 
   if (!context.dependencyOutputs) {
-    throw createMissingDependencyOutputError({generatorPreset: 'client', dependencyName: 'dependencyOutputs'});
+    throw createMissingDependencyOutputError({
+      generatorPreset: 'client',
+      dependencyName: 'dependencyOutputs'
+    });
   }
   const channels = context.dependencyOutputs[
     generator.channelsGeneratorId
   ] as TypeScriptChannelRenderType;
   if (!channels) {
-    throw createMissingDependencyOutputError({generatorPreset: 'client', dependencyName: 'channels'});
+    throw createMissingDependencyOutputError({
+      generatorPreset: 'client',
+      dependencyName: 'channels'
+    });
   }
   const renderedFunctions = channels.renderedFunctions;
   const renderedNatsFunctions = renderedFunctions['nats'] ?? [];
diff --git a/src/codegen/generators/typescript/headers.ts b/src/codegen/generators/typescript/headers.ts
@@ -145,13 +145,19 @@ export async function generateTypescriptHeaders(
   switch (inputType) {
     case 'asyncapi':
       if (!asyncapiDocument) {
-        throw createMissingInputDocumentError({expectedType: 'asyncapi', generatorPreset: 'headers'});
+        throw createMissingInputDocumentError({
+          expectedType: 'asyncapi',
+          generatorPreset: 'headers'
+        });
       }
       processedData = processAsyncAPIHeaders(asyncapiDocument);
       break;
     case 'openapi':
       if (!openapiDocument) {
-        throw createMissingInputDocumentError({expectedType: 'openapi', generatorPreset: 'headers'});
+        throw createMissingInputDocumentError({
+          expectedType: 'openapi',
+          generatorPreset: 'headers'
+        });
       }
       processedData = processOpenAPIHeaders(openapiDocument);
       break;
diff --git a/src/codegen/generators/typescript/parameters.ts b/src/codegen/generators/typescript/parameters.ts
@@ -62,7 +62,10 @@ export async function generateTypescriptParameters(
   switch (inputType) {
     case 'asyncapi': {
       if (!asyncapiDocument) {
-        throw createMissingInputDocumentError({expectedType: 'asyncapi', generatorPreset: 'parameters'});
+        throw createMissingInputDocumentError({
+          expectedType: 'asyncapi',
+          generatorPreset: 'parameters'
+        });
       }
 
       processedSchemaData = await processAsyncAPIParameters(asyncapiDocument);
@@ -71,7 +74,10 @@ export async function generateTypescriptParameters(
     }
     case 'openapi': {
       if (!openapiDocument) {
-        throw createMissingInputDocumentError({expectedType: 'openapi', generatorPreset: 'parameters'});
+        throw createMissingInputDocumentError({
+          expectedType: 'openapi',
+          generatorPreset: 'parameters'
+        });
       }
 
       processedSchemaData = processOpenAPIParameters(openapiDocument);
diff --git a/src/codegen/generators/typescript/payloads.ts b/src/codegen/generators/typescript/payloads.ts
@@ -303,15 +303,21 @@ export async function generateTypescriptPayload(
   switch (inputType) {
     case 'asyncapi': {
       if (!asyncapiDocument) {
-        throw createMissingInputDocumentError({expectedType: 'asyncapi', generatorPreset: 'payloads'});
+        throw createMissingInputDocumentError({
+          expectedType: 'asyncapi',
+          generatorPreset: 'payloads'
+        });
       }
 
       processedSchemaData = await processAsyncAPIPayloads(asyncapiDocument);
       break;
     }
     case 'openapi': {
       if (!openapiDocument) {
-        throw createMissingInputDocumentError({expectedType: 'openapi', generatorPreset: 'payloads'});
+        throw createMissingInputDocumentError({
+          expectedType: 'openapi',
+          generatorPreset: 'payloads'
+        });
       }
 
       processedSchemaData = processOpenAPIPayloads(openapiDocument);
diff --git a/src/codegen/generators/typescript/types.ts b/src/codegen/generators/typescript/types.ts
@@ -48,7 +48,10 @@ export async function generateTypescriptTypes(
   switch (inputType) {
     case 'asyncapi':
       if (!asyncapiDocument) {
-        throw createMissingInputDocumentError({expectedType: 'asyncapi', generatorPreset: 'types'});
+        throw createMissingInputDocumentError({
+          expectedType: 'asyncapi',
+          generatorPreset: 'types'
+        });
       }
       {
         const asyncAPIResult = await generateAsyncAPITypes(
@@ -61,7 +64,10 @@ export async function generateTypescriptTypes(
       break;
     case 'openapi':
       if (!openapiDocument) {
-        throw createMissingInputDocumentError({expectedType: 'openapi', generatorPreset: 'types'});
+        throw createMissingInputDocumentError({
+          expectedType: 'openapi',
+          generatorPreset: 'types'
+        });
       }
       {
         const openAPIResult = await generateOpenAPITypes(
diff --git a/src/codegen/inputs/jsonschema/parser.ts b/src/codegen/inputs/jsonschema/parser.ts
@@ -46,9 +46,17 @@ export async function loadJsonSchema(
     return document;
   } catch (error) {
     if (error instanceof Error) {
-      throw createInputDocumentError({inputPath: documentPath, inputType: 'jsonschema', errorMessage: error.message});
+      throw createInputDocumentError({
+        inputPath: documentPath,
+        inputType: 'jsonschema',
+        errorMessage: error.message
+      });
     }
-    throw createInputDocumentError({inputPath: documentPath, inputType: 'jsonschema', errorMessage: 'Unknown error'});
+    throw createInputDocumentError({
+      inputPath: documentPath,
+      inputType: 'jsonschema',
+      errorMessage: 'Unknown error'
+    });
   }
 }
 
@@ -82,9 +90,17 @@ export async function loadJsonSchemaDocument(
     return document;
   } catch (error) {
     if (error instanceof Error) {
-      throw createInputDocumentError({inputPath: filePath, inputType: 'jsonschema', errorMessage: error.message});
+      throw createInputDocumentError({
+        inputPath: filePath,
+        inputType: 'jsonschema',
+        errorMessage: error.message
+      });
     }
-    throw createInputDocumentError({inputPath: filePath, inputType: 'jsonschema', errorMessage: 'Unknown error'});
+    throw createInputDocumentError({
+      inputPath: filePath,
+      inputType: 'jsonschema',
+      errorMessage: 'Unknown error'
+    });
   }
 }
 
diff --git a/src/codegen/renderer.ts b/src/codegen/renderer.ts
diff --git a/src/commands/generate.ts b/src/commands/generate.ts
diff --git a/src/commands/telemetry.ts b/src/commands/telemetry.ts
diff --git a/test/LoggingInterface.spec.ts b/test/LoggingInterface.spec.ts

Original file line number	Diff line number	Diff line change
`@@ -344,4 +344,3 @@ export function parseZodErrors(zodError: any): string[] {`
`344`	`344`
`345`	`345`	`return errors;`
`346`	`346`	`}`
`347`		`-`
Original file line number	Diff line number	Diff line change
`@@ -116,7 +116,10 @@ export async function generateTypeScriptChannelsForAsyncAPI(`
`116`	`116`	`if (channel.parameters().length > 0) {`
`117`	`117`	`parameter = parameters.channelModels[channel.id()];`
`118`	`118`	`if (parameter === undefined) {`
`119`		`- throw createMissingParameterError({channelOrOperation: channel.id(), protocol: 'channels'});`
	`119`	`+ throw createMissingParameterError({`
	`120`	`+ channelOrOperation: channel.id(),`
	`121`	`+ protocol: 'channels'`
	`122`	`+ });`
`120`	`123`	`}`
`121`	`124`	`}`
`122`	`125`
`@@ -210,10 +213,16 @@ function validateAsyncapiContext(context: TypeScriptChannelsContext): {`
`210`	`213`	`} {`
`211`	`214`	`const {asyncapiDocument, inputType} = context;`
`212`	`215`	`if (inputType !== 'asyncapi') {`
`213`		`- throw createMissingInputDocumentError({expectedType: 'asyncapi', generatorPreset: 'channels'});`
	`216`	`+ throw createMissingInputDocumentError({`
	`217`	`+ expectedType: 'asyncapi',`
	`218`	`+ generatorPreset: 'channels'`
	`219`	`+ });`
`214`	`220`	`}`
`215`	`221`	`if (asyncapiDocument === undefined) {`
`216`		`- throw createMissingInputDocumentError({expectedType: 'asyncapi', generatorPreset: 'channels'});`
	`222`	`+ throw createMissingInputDocumentError({`
	`223`	`+ expectedType: 'asyncapi',`
	`224`	`+ generatorPreset: 'channels'`
	`225`	`+ });`
`217`	`226`	`}`
`218`	`227`	`return {asyncapiDocument};`
`219`	`228`	`}`
Original file line number	Diff line number	Diff line change
`@@ -243,10 +243,16 @@ function validateOpenAPIContext(context: TypeScriptChannelsContext): {`
`243`	`243`	`} {`
`244`	`244`	`const {openapiDocument, inputType} = context;`
`245`	`245`	`if (inputType !== 'openapi') {`
`246`		`- throw createMissingInputDocumentError({expectedType: 'openapi', generatorPreset: 'channels'});`
	`246`	`+ throw createMissingInputDocumentError({`
	`247`	`+ expectedType: 'openapi',`
	`248`	`+ generatorPreset: 'channels'`
	`249`	`+ });`
`247`	`250`	`}`
`248`	`251`	`if (!openapiDocument) {`
`249`		`- throw createMissingInputDocumentError({expectedType: 'openapi', generatorPreset: 'channels'});`
	`252`	`+ throw createMissingInputDocumentError({`
	`253`	`+ expectedType: 'openapi',`
	`254`	`+ generatorPreset: 'channels'`
	`255`	`+ });`
`250`	`256`	`}`
`251`	`257`	`return {openapiDocument};`
`252`	`258`	`}`