chore(release): v0.44.0 (#224)

Author: jonaslagoni

docs/README.md

@@ -72,3 +72,4 @@ Get an overview of how to contribute to the project
 
 
 
+

docs/contributing.md

@@ -155,5 +155,6 @@ Prefix that follows specification is not enough though. Remember that the title
 
 
 
+
 
 

docs/migrations/v0.md

@@ -63,3 +63,4 @@ const subscriber = await jetStreamPullSubscribeToReceiveUserSignedup({
 
 
 
+

docs/usage.md

@@ -9,7 +9,7 @@ $ npm install -g @the-codegen-project/cli
 $ codegen COMMAND
 running command...
 $ codegen (--version)
-@the-codegen-project/cli/0.43.0 linux-x64 node-v18.20.8
+@the-codegen-project/cli/0.44.0 linux-x64 node-v18.20.8
 $ codegen --help [COMMAND]
 USAGE
   $ codegen COMMAND
@@ -81,7 +81,7 @@ DESCRIPTION
   Generate code based on your configuration, use `init` to get started.
 ```
 
-_See code: [src/commands/generate.ts](https://github.com/the-codegen-project/cli/blob/v0.43.0/src/commands/generate.ts)_
+_See code: [src/commands/generate.ts](https://github.com/the-codegen-project/cli/blob/v0.44.0/src/commands/generate.ts)_
 
 ## `codegen help [COMMAND]`
 
@@ -139,7 +139,7 @@ DESCRIPTION
   Initialize The Codegen Project in your project
 ```
 
-_See code: [src/commands/init.ts](https://github.com/the-codegen-project/cli/blob/v0.43.0/src/commands/init.ts)_
+_See code: [src/commands/init.ts](https://github.com/the-codegen-project/cli/blob/v0.44.0/src/commands/init.ts)_
 
 ## `codegen version`
 

package-lock.json

@@ -1,7 +1,7 @@
 {
   "name": "@the-codegen-project/cli",
   "description": "CLI to work with code generation in any environment",
-  "version": "0.43.0",
+  "version": "0.44.0",
   "bin": {
     "codegen": "./bin/run.mjs"
   },

package.json

@@ -30,6 +30,9 @@
                     "type": "array",
                     "items": {
                         "anyOf": [
+                            {
+                                "$ref": "#/definitions/AsyncAPICodegenConfiguration/properties/generators/items/anyOf/0"
+                            },
                             {
                                 "$ref": "#/definitions/AsyncAPICodegenConfiguration/properties/generators/items/anyOf/4"
                             },

schemas/configuration-schema-0.json

@@ -11,13 +11,16 @@ import {
 } from '@asyncapi/modelina';
 import {GenericCodegenContext, PayloadRenderType} from '../../types';
 import {AsyncAPIDocumentInterface} from '@asyncapi/parser';
-import {processAsyncAPIPayloads, ProcessedPayloadSchemaData} from '../../inputs/asyncapi/generators/payloads';
+import {
+  processAsyncAPIPayloads,
+  ProcessedPayloadSchemaData
+} from '../../inputs/asyncapi/generators/payloads';
 import {processOpenAPIPayloads} from '../../inputs/openapi/generators/payloads';
 import {z} from 'zod';
 import {defaultCodegenTypescriptModelinaOptions} from './utils';
 import {Logger} from '../../../LoggingInterface';
 import {TypeScriptRenderer} from '@asyncapi/modelina/lib/types/generators/typescript/TypeScriptRenderer';
-import { OpenAPIV2, OpenAPIV3, OpenAPIV3_1 } from 'openapi-types';
+import {OpenAPIV2, OpenAPIV3, OpenAPIV3_1} from 'openapi-types';
 
 export const zodTypeScriptPayloadGenerator = z.object({
   id: z.string().optional().default('payloads-typescript'),
@@ -87,8 +90,14 @@ export type TypeScriptPayloadRenderType =
 
 // Interface for processed payloads data (input-agnostic)
 export interface ProcessedPayloadData {
-  channelModels: Record<string, {messageModel: OutputModel; messageType: string}>;
-  operationModels: Record<string, {messageModel: OutputModel; messageType: string}>;
+  channelModels: Record<
+    string,
+    {messageModel: OutputModel; messageType: string}
+  >;
+  operationModels: Record<
+    string,
+    {messageModel: OutputModel; messageType: string}
+  >;
   otherModels: Array<{messageModel: OutputModel; messageType: string}>;
 }
 
@@ -303,14 +312,14 @@ export function safeStringify(value: any): string {
   let depth = 0;
   const maxDepth = 255;
   const maxRepetitions = 5; // Allow up to 5 repetitions of the same object
-  
+
   // eslint-disable-next-line sonarjs/cognitive-complexity
   function stringify(val: any, currentPath: any[] = []): any {
     // Check depth limit
     if (depth > maxDepth) {
       return true;
     }
-    
+
     switch (typeof val) {
       case 'function':
         return true;
@@ -322,38 +331,47 @@ export function safeStringify(value: any): string {
         if (val === null) {
           return null;
         }
-        
+
         // Check for immediate circular reference (direct self-reference)
-        if (currentPath.length > 0 && currentPath[currentPath.length - 1] === val) {
+        if (
+          currentPath.length > 0 &&
+          currentPath[currentPath.length - 1] === val
+        ) {
           return true;
         }
-        
+
         // Count how many times this object appears in the current path
-        const repetitionCount = currentPath.filter(obj => obj === val).length;
-        
+        const repetitionCount = currentPath.filter((obj) => obj === val).length;
+
         // If we've seen this object too many times in the current path, cut it off
         if (repetitionCount >= maxRepetitions) {
           return true;
         }
-        
+
         depth++;
         const newPath = [...currentPath, val];
-        
+
         let result: any;
-        
+
         if (Array.isArray(val)) {
-          result = val.map(item => stringify(item, newPath));
+          result = val.map((item) => stringify(item, newPath));
         } else {
           result = {};
           for (const [key, value] of Object.entries(val)) {
             // Skip extension properties
-            if (key.startsWith('x-modelina') || key.startsWith('x-the-codegen-project') || key.startsWith('x-parser-') || key.startsWith('x-modelgen-') || key.startsWith('discriminator')) {
+            if (
+              key.startsWith('x-modelina') ||
+              key.startsWith('x-the-codegen-project') ||
+              key.startsWith('x-parser-') ||
+              key.startsWith('x-modelgen-') ||
+              key.startsWith('discriminator')
+            ) {
               continue;
             }
             result[key] = stringify(value, newPath);
           }
         }
-        
+
         depth--;
         return result;
       }
@@ -363,7 +381,7 @@ export function safeStringify(value: any): string {
         return true;
     }
   }
-  
+
   return JSON.stringify(stringify(value));
 }
 
@@ -372,7 +390,7 @@ export async function generateTypescriptPayloadsCore(
   processedData: ProcessedPayloadData,
   generator: TypeScriptPayloadGeneratorInternal
 ): Promise<TypeScriptPayloadRenderType> {
-  // The models are already generated by the input processors, 
+  // The models are already generated by the input processors,
   // so we just need to return them in the expected format
   return {
     channelModels: processedData.channelModels,
@@ -480,12 +498,21 @@ ${renderUnionUnmarshalByStatusCode(model)}`;
     useJavascriptReservedKeywords: generator.useForJavaScript
   });
 
-  const channelModels: Record<string, {messageModel: OutputModel; messageType: string}> = {};
-  const operationModels: Record<string, {messageModel: OutputModel; messageType: string}> = {};
-  const otherModels: Array<{messageModel: OutputModel; messageType: string}> = [];
+  const channelModels: Record<
+    string,
+    {messageModel: OutputModel; messageType: string}
+  > = {};
+  const operationModels: Record<
+    string,
+    {messageModel: OutputModel; messageType: string}
+  > = {};
+  const otherModels: Array<{messageModel: OutputModel; messageType: string}> =
+    [];
 
   // Generate models for channel payloads
-  for (const [channelId, schemaData] of Object.entries(processedSchemaData.channelPayloads)) {
+  for (const [channelId, schemaData] of Object.entries(
+    processedSchemaData.channelPayloads
+  )) {
     if (schemaData) {
       const models = await modelinaGenerator.generateToFiles(
         schemaData.schema,
@@ -508,7 +535,9 @@ ${renderUnionUnmarshalByStatusCode(model)}`;
   }
 
   // Generate models for operation payloads
-  for (const [operationId, schemaData] of Object.entries(processedSchemaData.operationPayloads)) {
+  for (const [operationId, schemaData] of Object.entries(
+    processedSchemaData.operationPayloads
+  )) {
     if (schemaData) {
       const models = await modelinaGenerator.generateToFiles(
         schemaData.schema,
@@ -573,15 +602,15 @@ export async function generateTypescriptPayload(
       if (!asyncapiDocument) {
         throw new Error('Expected AsyncAPI input, was not given');
       }
-      
+
       processedSchemaData = await processAsyncAPIPayloads(asyncapiDocument);
       break;
     }
     case 'openapi': {
       if (!openapiDocument) {
         throw new Error('Expected OpenAPI input, was not given');
       }
-      
+
       processedSchemaData = processOpenAPIPayloads(openapiDocument);
       break;
     }
@@ -590,5 +619,8 @@ export async function generateTypescriptPayload(
   }
 
   // Generate final result using processed schema data
-  return generateTypescriptPayloadsCoreFromSchemas(processedSchemaData, generator);
+  return generateTypescriptPayloadsCoreFromSchemas(
+    processedSchemaData,
+    generator
+  );
 }

src/codegen/generators/typescript/payloads.ts

@@ -1,10 +1,13 @@
 /* eslint-disable security/detect-object-injection */
-import {
-  AsyncAPIInputProcessor
-} from '@asyncapi/modelina';
+import {AsyncAPIInputProcessor} from '@asyncapi/modelina';
 import {AsyncAPIDocumentInterface, MessageInterface} from '@asyncapi/parser';
 import {pascalCase} from '../../../generators/typescript/utils';
-import {findNameFromChannel, findOperationId, findReplyId, onlyUnique} from '../../../utils';
+import {
+  findNameFromChannel,
+  findOperationId,
+  findReplyId,
+  onlyUnique
+} from '../../../utils';
 
 // Interface for processed payload schema data
 export interface ProcessedPayloadSchemaData {
@@ -68,7 +71,10 @@ export async function processAsyncAPIPayloads(
         if (typeof schema === 'boolean') {
           schemaObj = schema;
         } else {
-          id = message.id() ?? message.name() ?? schema['x-modelgen-inferred-name'];
+          id =
+            message.id() ??
+            message.name() ??
+            schema['x-modelgen-inferred-name'];
           if (id.includes('AnonymousSchema_')) {
             id = pascalCase(`${preId}_Payload`);
           }
@@ -84,7 +90,7 @@ export async function processAsyncAPIPayloads(
     } else {
       return;
     }
-    
+
     return {
       schema: schemaObj,
       schemaId: id ?? schemaObj.$id ?? pascalCase(`${preId}_Payload`)
@@ -97,7 +103,7 @@ export async function processAsyncAPIPayloads(
       for (const operation of channel.operations().all()) {
         const operationMessages = operation.messages().all();
         const operationReply = operation.reply();
-        
+
         if (operationReply) {
           const operationReplyId = findReplyId(
             operation,
@@ -112,17 +118,14 @@ export async function processAsyncAPIPayloads(
             operationPayloads[operationReplyId] = operationReplySchema;
           }
         }
-        
+
         const operationId = findOperationId(operation, channel);
-        const operationSchema = processMessages(
-          operationMessages,
-          operationId
-        );
+        const operationSchema = processMessages(operationMessages, operationId);
         if (operationSchema) {
           operationPayloads[operationId] = operationSchema;
         }
       }
-      
+
       // Process channel messages
       const channelSchema = processMessages(
         channel.messages().all(),