InputProcessor.ts

import { AbstractInputProcessor } from './AbstractInputProcessor';
import { AsyncAPIInputProcessor } from './AsyncAPIInputProcessor';
import { JsonSchemaInputProcessor } from './JsonSchemaInputProcessor';
import { ProcessorOptions, InputMetaModel } from '../models';
import { SwaggerInputProcessor } from './SwaggerInputProcessor';
import { OpenAPIInputProcessor } from './OpenAPIInputProcessor';
import { TypeScriptInputProcessor } from './TypeScriptInputProcessor';

/**
 * Main input processor which figures out the type of input it receives and delegates the processing into separate individual processors.
 */
export class InputProcessor {
  public static processor: InputProcessor = new InputProcessor();
  private processors: Map<string, AbstractInputProcessor> = new Map();

  constructor() {
    this.setProcessor('asyncapi', new AsyncAPIInputProcessor());
    this.setProcessor('swagger', new SwaggerInputProcessor());
    this.setProcessor('openapi', new OpenAPIInputProcessor());
    this.setProcessor('default', new JsonSchemaInputProcessor());
    this.setProcessor('typescript', new TypeScriptInputProcessor());
  }

  /**
   * Set a processor.
   *
   * @param type of processor
   * @param processor
   */
  setProcessor(type: string, processor: AbstractInputProcessor): void {
    this.processors.set(type, processor);
  }

  /**
   *
   * @returns all processors
   */
  getProcessors(): Map<string, AbstractInputProcessor> {
    return this.processors;
  }

  /**
   * The processor code which delegates the processing to the correct implementation.
   *
   * @param input to process
   * @param options passed to the processors
   */
  process(input: any, options?: ProcessorOptions): Promise<InputMetaModel> {
    for (const [type, processor] of this.processors) {
      if (type === 'default') {
        continue;
      }
      if (processor.shouldProcess(input)) {
        return processor.process(input, options);
      }
    }
    const defaultProcessor = this.processors.get('default');
    if (defaultProcessor !== undefined) {
      return defaultProcessor.process(input, options);
    }
    return Promise.reject(new Error('No default processor found'));
  }
}