chore(release): v0.26.0

Author: jonaslagoni

docs/README.md

@@ -55,3 +55,4 @@ Each protocol has its own limitations, corner cases, and features; thus, each ha
 
 
 
+

docs/contributing.md

@@ -135,3 +135,4 @@ What about MAJOR release? just add `!` to the prefix, like `fix!: ` or `refactor
 
 Prefix that follows specification is not enough though. Remember that the title must be clear and descriptive with usage of [imperative mood](https://chris.beams.io/posts/git-commit/#imperative).
 
+

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.25.0 linux-x64 node-v18.20.5
+@the-codegen-project/cli/0.26.0 linux-x64 node-v18.20.5
 $ 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.25.0/src/commands/generate.ts)_
+_See code: [src/commands/generate.ts](https://github.com/the-codegen-project/cli/blob/v0.26.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.25.0/src/commands/init.ts)_
+_See code: [src/commands/init.ts](https://github.com/the-codegen-project/cli/blob/v0.26.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.25.0",
+  "version": "0.26.0",
   "bin": {
     "codegen": "./bin/run.mjs"
   },

package.json

@@ -164,11 +164,13 @@
                                         "items": {
                                             "type": "string",
                                             "enum": [
-                                                "nats"
+                                                "nats",
+                                                "kafka"
                                             ]
                                         },
                                         "default": [
-                                            "nats"
+                                            "nats",
+                                            "kafka"
                                         ]
                                     },
                                     "parameterGeneratorId": {
@@ -209,7 +211,9 @@
                                                             "nats_subscribe",
                                                             "nats_publish",
                                                             "nats_request",
-                                                            "nats_reply"
+                                                            "nats_reply",
+                                                            "kafka_publish",
+                                                            "kafka_subscribe"
                                                         ]
                                                     }
                                                 }
@@ -218,6 +222,11 @@
                                         "default": {},
                                         "description": "Used in conjunction with AsyncAPI input, can define channel ID along side the type of functions that should be rendered."
                                     },
+                                    "kafkaTopicSeparator": {
+                                        "type": "string",
+                                        "default": ".",
+                                        "description": "Used with AsyncAPI to ensure the right character separate topics, example if address is my/resource/path it will be converted to my.resource.path"
+                                    },
                                     "language": {
                                         "type": "string",
                                         "const": "typescript",

schemas/configuration-schema-0.json

@@ -386,9 +386,8 @@ export async function generateTypeScriptChannels(
               `Could not find payload for ${channel.id()} for channel typescript generator`
             );
           }
-          const {messageModule, messageType} =
-            getMessageTypeAndModule(payload);
-            kafkaContext = {...kafkaContext, messageType, messageModule};
+          const {messageModule, messageType} = getMessageTypeAndModule(payload);
+          kafkaContext = {...kafkaContext, messageType, messageModule};
           const operations = channel.operations().all();
           if (operations.length > 0 && !ignoreOperation) {
             for (const operation of operations) {

src/codegen/generators/typescript/channels/index.ts

@@ -60,7 +60,8 @@ export function renderSubscribe({
       jsDoc: ' * @param kafka the KafkaJS client to subscribe through'
     },
     {
-      parameter: 'options: {fromBeginning: boolean, groupId: string} = {fromBeginning: true, groupId: \'\'}',
+      parameter:
+        "options: {fromBeginning: boolean, groupId: string} = {fromBeginning: true, groupId: ''}",
       jsDoc: ' * @param options when setting up the subscription'
     }
   ];
@@ -73,11 +74,11 @@ export function renderSubscribe({
 onDataCallback(undefined, callbackData, parameters, kafkaMessage);`;
     }
   } else if (messageType === 'null') {
-      whenReceivingMessage = `onDataCallback(undefined, null, kafkaMessage);`;
-    } else {
-      whenReceivingMessage = `const callbackData = ${messageUnmarshalling};
+    whenReceivingMessage = `onDataCallback(undefined, null, kafkaMessage);`;
+  } else {
+    whenReceivingMessage = `const callbackData = ${messageUnmarshalling};
   onDataCallback(undefined, callbackData, kafkaMessage);`;
-    }
+  }
   const jsDocParameters = functionParameters
     .map((param) => param.jsDoc)
     .join('\n');

src/codegen/generators/typescript/channels/protocols/kafka/subscribe.ts

@@ -61,7 +61,13 @@ export const zodTypescriptChannelsGenerator = z.object({
     .describe(
       'Used in conjunction with AsyncAPI input, can define channel ID along side the type of functions that should be rendered.'
     ),
-  kafkaTopicSeparator: z.string().optional().default('.').describe('Used with AsyncAPI to ensure the right character separate topics, example if address is my/resource/path it will be converted to my.resource.path'),
+  kafkaTopicSeparator: z
+    .string()
+    .optional()
+    .default('.')
+    .describe(
+      'Used with AsyncAPI to ensure the right character separate topics, example if address is my/resource/path it will be converted to my.resource.path'
+    ),
   language: z.literal('typescript').optional().default('typescript')
 });