added the file generation code.

src/commands/new/glee.ts

@@ -1,99 +1,154 @@
-import {Flags} from '@oclif/core';
-import { promises as fPromises } from 'fs';
-import Command from '../../base';
-import { resolve, join } from 'path';
-import fs from 'fs-extra';
-import { load, Specification } from '../../models/SpecificationFile';
-import {parse} from '../../parser'
-import { exec } from 'child_process';
+import { Flags } from "@oclif/core";
+import { promises as fPromises } from "fs";
+import Command from "../../base";
+import { resolve, join } from "path";
+import fs from "fs-extra";
+import { load } from "../../models/SpecificationFile";
+import { parse } from "../../parser";
+import { createTypes } from "utils/createTypes";
+import { convertToJSONSchema } from "../../utils/convertToJsonSchema";
+import Handlebars from "handlebars";
+import fileTemplate from "./template";
 
 export default class NewGlee extends Command {
-  static description = 'Creates a new Glee project';
-  
-  protected commandName = 'glee';
+  static description = "Creates a new Glee project";
+
+  protected commandName = "glee";
 
   static flags = {
-    help: Flags.help({ char: 'h' }),
-    name: Flags.string({ char: 'n', description: 'name of the project', default: 'project' }),
+    help: Flags.help({ char: "h" }),
+    name: Flags.string({
+      char: "n",
+      description: "name of the project",
+      default: "project",
+    }),
   };
 
   static args = [
     {
-      name: 'file',
-      description: 'spec path, URL or context-name',
+      name: "file",
+      description: "spec path, URL or context-name",
       required: true,
     },
   ];
   async run() {
-    const {args,flags } = await this.parse(NewGlee); // NOSONAR
+    const { args, flags } = await this.parse(NewGlee); // NOSONAR
 
     const projectName = flags.name;
     // console.log(flags.name , {flags} , {args})
 
     const PROJECT_DIRECTORY = join(process.cwd(), projectName);
-    const GLEE_TEMPLATES_DIRECTORY = resolve(__dirname, '../../../assets/create-glee-app/templates/default');
-    let operationList : Array<any> = []
-    let response:any;
-    let asyncApiFile:any;
+    const GLEE_TEMPLATES_DIRECTORY = resolve(
+      __dirname,
+      "../../../assets/create-glee-app/templates/default",
+    );
+    let operationList: Array<any> = [];
+    let response: any;
+    let asyncApiFile: any;
+    const requiredList: any = [];
+
     try {
       await fPromises.mkdir(PROJECT_DIRECTORY);
-      const document  = await load(args.file);
-       response = await parse(this, document)
-      const Jsondocument:any = JSON.stringify(response.document)
+      const document = await load(args.file);
+      console.log({ document }, this);
+      response = await parse(this, document);
+
+      console.log(response);
       asyncApiFile = response.document._meta.asyncapi.input;
+      console.log(response.document);
+
+      operationList = Object.keys(response.document._json.operations);
+      //console.log({ operationList });
+      const operationArray: Array<any> = Object.entries(
+        response.document._json.operations,
+      );
+
+      // const operationTypeArray: Array<any> = [];
+      for (const value of operationArray) {
+        const currentFunctionObject = {
+          name: "",
+          payload: {},
+        };
 
-      // console.log({document},{response},{Jsondocument})
-      console.log(response.document._meta.asyncapi.input,"<<<<<<<this is the response")
-      // console.log(Object.keys(response.document._json.operations))
-       operationList = Object.keys(response.document._json.operations);
-      // console.log( JSON.stringify(response.document), {Jsondocument}, response.document._json.channels['/hello'].publish.operationId)
-      //  operation_id = response.document._json.channels['/hello'].publish.operationId
-      // console.log({operation_id})
+        currentFunctionObject.name = value[0];
+        const response = convertToJSONSchema(value[1].messages);
+        console.log(response);
+        currentFunctionObject.payload = response;
 
+        requiredList.push(currentFunctionObject);
+      }
     } catch (err: any) {
       switch (err.code) {
-      case 'EEXIST':
-        this.error(`Unable to create the project. We tried to use "${projectName}" as the directory of your new project but it already exists (${PROJECT_DIRECTORY}). Please specify a different name for the new project. For example, run the following command instead:\n\n  asyncapi new ${this.commandName} --name ${projectName}-1\n`);
-        break;
-      case 'EACCES':
-        this.error(`Unable to create the project. We tried to access the "${PROJECT_DIRECTORY}" directory but it was not possible due to file access permissions. Please check the write permissions of your current working directory ("${process.cwd()}").`);
-        break;
-      case 'EPERM':
-        this.error(`Unable to create the project. We tried to create the "${PROJECT_DIRECTORY}" directory but the operation requires elevated privileges. Please check the privileges for your current user.`);
-        break;
-      default:
-        this.error(`Unable to create the project. Please check the following message for further info about the error:\n\n${err}`);
+        case "EEXIST":
+          this.error(
+            `Unable to create the project. We tried to use "${projectName}" as the directory of your new project but it already exists (${PROJECT_DIRECTORY}). Please specify a different name for the new project. For example, run the following command instead:\n\n  asyncapi new ${this.commandName} --name ${projectName}-1\n`,
+          );
+          break;
+        case "EACCES":
+          this.error(
+            `Unable to create the project. We tried to access the "${PROJECT_DIRECTORY}" directory but it was not possible due to file access permissions. Please check the write permissions of your current working directory ("${process.cwd()}").`,
+          );
+          break;
+        case "EPERM":
+          this.error(
+            `Unable to create the project. We tried to create the "${PROJECT_DIRECTORY}" directory but the operation requires elevated privileges. Please check the privileges for your current user.`,
+          );
+          break;
+        default:
+          this.error(
+            `Unable to create the project. Please check the following message for further info about the error:\n\n${err}`,
+          );
       }
     }
-
-  
+    // await createTypes();
+
     const createOperationFunction = async () => {
-      for (const fileName of operationList) {
-        await fPromises.writeFile(`${PROJECT_DIRECTORY}/functions/${fileName}.js`, "");
-        await fPromises.copyFile(
-          `${PROJECT_DIRECTORY}/functions/onHello.js`,
-          `${PROJECT_DIRECTORY}/functions/${fileName}.js`
+      for (const value of requiredList) {
+        const template = Handlebars.compile(fileTemplate);
+        const fileContent = template({
+          payload: value.payload,
+          functionName: value.functionName,
+        });
+        console.log(value.payload);
+        await fPromises.writeFile(
+          `${PROJECT_DIRECTORY}/functions/${value.name}.ts`,
+          fileContent,
         );
       }
     };
-        try {
+    try {
       await fs.copy(GLEE_TEMPLATES_DIRECTORY, PROJECT_DIRECTORY);
-      await fPromises.rename(`${PROJECT_DIRECTORY}/env`, `${PROJECT_DIRECTORY}/.env`);
-      await fPromises.rename(`${PROJECT_DIRECTORY}/gitignore`, `${PROJECT_DIRECTORY}/.gitignore`);
-      await fPromises.rename(`${PROJECT_DIRECTORY}/README-template.md`, `${PROJECT_DIRECTORY}/README.md`);
-
-        await createOperationFunction()
-        await fPromises.unlink(`${PROJECT_DIRECTORY}/functions/onHello.js`);
+      await fPromises.rename(
+        `${PROJECT_DIRECTORY}/env`,
+        `${PROJECT_DIRECTORY}/.env`,
+      );
+      await fPromises.rename(
+        `${PROJECT_DIRECTORY}/gitignore`,
+        `${PROJECT_DIRECTORY}/.gitignore`,
+      );
+      await fPromises.rename(
+        `${PROJECT_DIRECTORY}/README-template.md`,
+        `${PROJECT_DIRECTORY}/README.md`,
+      );
 
-      await fPromises.writeFile(`${PROJECT_DIRECTORY}/asyncapi.yaml`,asyncApiFile);
+      await createOperationFunction();
+      await fPromises.unlink(`${PROJECT_DIRECTORY}/functions/onHello.js`);
 
+      await fPromises.writeFile(
+        `${PROJECT_DIRECTORY}/asyncapi.yaml`,
+        asyncApiFile,
+      );
 
-      this.log(`Your project "${projectName}" has been created successfully!\n\nNext steps:\n\n  cd ${projectName}\n  npm install\n  npm run dev\n\nAlso, you can already open the project in your favorite editor and start tweaking it.`);
+      this.log(
+        `Your project "${projectName}" has been created successfully!\n\nNext steps:\n\n  cd ${projectName}\n  npm install\n  npm run dev\n\nAlso, you can already open the project in your favorite editor and start tweaking it.`,
+      );
     } catch (err) {
-      this.error(`Unable to create the project. Please check the following message for further info about the error:\n\n${err}`);
+      this.error(
+        `Unable to create the project. Please check the following message for further info about the error:\n\n${err}`,
+      );
     }
   }
   // const parseDocument = async () =>{
 
   // }
-}
+}

src/commands/new/template.ts

@@ -0,0 +1,4 @@
+const template =
+  'import { GleeFunction, GleeFunctionEvent } from "@asyncapi/glee"; type PayloadType = {{payload}}; type GleeFunctionEventWithCustomPayload = GleeFunctionEvent & { payload?: PayloadType;}; const {{functionName}}: GleeFunction = async ( event: GleeFunctionEventWithCustomPayload,) => { return { reply: [{payload:`Hello from Glee! You said: "${event.payload}".`,},],};};export default {{functionName}}; ';
+
+export default template;

src/utils/convertToJsonSchema.ts

@@ -0,0 +1,28 @@
+// const inputArray = [
+//   {
+//     payload: { type: "string", "x-parser-schema-id": "<anonymous-schema-1>" },
+//     "x-parser-message-name": "hello",
+//   },
+// ];
+
+export const convertToJSONSchema = (inputArray) => {
+  const jsonSchemaDraft7 = {
+    type: "object",
+    properties: {},
+  };
+
+  inputArray.forEach((item) => {
+    const propertyName = item["x-parser-message-name"];
+    const payload = item.payload;
+
+    if (propertyName && payload) {
+      jsonSchemaDraft7.properties[propertyName] = {
+        type: payload.type,
+      };
+    }
+  });
+
+  return jsonSchemaDraft7;
+};
+
+// const result = convertToJSONSchema(inputArray);

src/utils/createTypes.ts

@@ -0,0 +1,20 @@
+import { TypeScriptGenerator } from "@asyncapi/modelina";
+
+const generator = new TypeScriptGenerator({ modelType: "interface" });
+const jsonSchemaDraft7 = {
+  type: "object",
+  properties: {
+    hello: {
+      type: "string",
+    },
+  },
+};
+
+export async function createTypes(): Promise<void> {
+  console.log("the function is running.");
+  const models = await generator.generate(jsonSchemaDraft7);
+  for (const model of models) {
+    console.log(model.result);
+  }
+  console.log({ models });
+}