feat: added file path as input

src/generators/AbstractFileGenerator.ts

@@ -7,7 +7,7 @@ export type FileGenerator = (content: string, toFile: string) => Promise<void>;
  */
 export interface AbstractFileGenerator<RenderCompleteModelOptions> {
   generateToFiles(
-    input: Record<string, unknown> | InputMetaModel,
+    input: any | InputMetaModel,
     outputDirectory: string,
     options: RenderCompleteModelOptions
   ): Promise<OutputModel[]>;

src/generators/AbstractGenerator.ts

@@ -14,11 +14,12 @@ import { InputProcessor } from '../processors';
 import { IndentationTypes } from '../helpers';
 import { DeepPartial, isPresetWithOptions } from '../utils';
 import { AbstractDependencyManager } from './AbstractDependencyManager';
+import Parser, { fromFile } from '@asyncapi/parser';
 
 export interface CommonGeneratorOptions<
   P extends Preset = Preset,
   DependencyManager extends
-    AbstractDependencyManager = AbstractDependencyManager
+  AbstractDependencyManager = AbstractDependencyManager
 > {
   indentation?: {
     type: IndentationTypes;
@@ -27,6 +28,7 @@ export interface CommonGeneratorOptions<
   defaultPreset?: P;
   presets?: Presets<P>;
   processorOptions?: ProcessorOptions;
+  inputProcessor?: InputProcessorOptions;
   /**
    * This dependency manager type serves two functions.
    * 1. It can be used to provide a factory for generate functions
@@ -63,6 +65,16 @@ export interface AbstractGeneratorRenderCompleteModelArgs<
   options?: DeepPartial<Options>;
 }
 
+export interface InputProcessorOptions {
+  type?: InputType
+}
+
+export enum InputType {
+  FILE = 'file',
+  DOCUMENT = 'document',
+  OBJECT = 'object'
+}
+
 /**
  * Abstract generator which must be implemented by each language
  */
@@ -73,7 +85,7 @@ export abstract class AbstractGenerator<
   constructor(
     public readonly languageName: string,
     public readonly options: Options
-  ) {}
+  ) { }
 
   public abstract render(
     args: AbstractGeneratorRenderArgs<Options>
@@ -165,7 +177,7 @@ export abstract class AbstractGenerator<
       for (const unionConstrainedModel of unionConstrainedModelsWithDepManager) {
         if (
           unionConstrainedModel.constrainedModel instanceof
-            ConstrainedUnionModel &&
+          ConstrainedUnionModel &&
           unionConstrainedModel.constrainedModel.union.some(
             (m) =>
               m.name === constrainedModel.name &&
@@ -259,8 +271,7 @@ export abstract class AbstractGenerator<
   protected async processInput(
     input: any | InputMetaModel
   ): Promise<InputMetaModel> {
-    const rawInputModel =
-      input instanceof InputMetaModel ? input : await this.process(input);
+    const rawInputModel = await this.getRawInputModel(input)
 
     //Split out the models based on the language specific requirements of which models is rendered separately
     const splitOutModels: { [key: string]: MetaModel } = {};
@@ -274,6 +285,22 @@ export abstract class AbstractGenerator<
     return rawInputModel;
   }
 
+  protected async getRawInputModel(
+    input: any | InputMetaModel
+  ): Promise<InputMetaModel> {
+    const inputProcessorOptions = this.options.inputProcessor
+    switch (inputProcessorOptions?.type) {
+      case InputType.FILE:
+        const parser = new Parser();
+        const { document, diagnostics } = await fromFile(parser, input).parse();
+        // TODO : Want to log the diagnostics
+        if (!document) throw new Error('Invalid file input')
+        return this.process(document as any)
+      default:
+        return input instanceof InputMetaModel ? input : this.process(input);
+    }
+  }
+
   /**
    * Get all presets (default and custom ones from options) for a given preset type (class, enum, etc).
    */

test/generators/AbstractGenerator.spec.ts

@@ -1,3 +1,5 @@
+import path from 'path';
+import { InputType } from '../../src';
 import {
   InputMetaModel,
   AnyModel,
@@ -50,6 +52,25 @@ describe('AbstractGenerator', () => {
     expect(outputModels[0].modelName).toEqual('TestName');
   });
 
+  test('generate() should process file input', async () => {
+    const newGenerator = new TestGenerator({
+      inputProcessor: { type: InputType.FILE }
+    });
+    const outputModels = await newGenerator.generate(path.resolve('test/generators/testasyncapi.yml'));
+    expect(outputModels[0].result).toEqual('anonymous_schema_1');
+    expect(outputModels[0].modelName).toEqual('TestName');
+  });
+
+  test('generateCompleteModels() should process InputMetaModel instance', async () => {
+    const newGenerator = new TestGenerator({
+      inputProcessor: { type: InputType.FILE }
+    });
+    const outputModels = await newGenerator.generate(path.resolve('test/generators/testasyncapi.yml'));
+
+    expect(outputModels[0].result).toEqual('anonymous_schema_1');
+    expect(outputModels[0].modelName).toEqual('TestName');
+  });
+
   test('should `process` function return InputMetaModel', async () => {
     const doc: any = { type: 'string', $id: 'test' };
     const commonInputModel = await generator.process(doc);

test/generators/testasyncapi.yml

@@ -0,0 +1,23 @@
+asyncapi: '2.6.0'
+info:
+  title: Account Service
+  version: 1.0.0
+  description: This service is in charge of processing user signups
+channels:
+  user/signedup:
+    subscribe:
+      message:
+        $ref: '#/components/messages/UserSignedUp'
+components:
+  messages:
+    UserSignedUp:
+      payload:
+        type: object
+        properties:
+          displayName:
+            type: string
+            description: Name of the user
+          email:
+            type: string
+            format: email
+            description: Email of the user