feat: add global specification watcher

src/commands/diff.ts

@@ -12,6 +12,8 @@ import {
   DiffOverrideFileError,
   DiffOverrideJSONError,
 } from '../errors/diff-error';
+import { specWatcher } from '../globals';
+import { watchFlag } from '../flags';
 
 const { readFile } = fs;
 
@@ -36,6 +38,7 @@ export default class Diff extends Command {
       char: 'o',
       description: 'path to JSON file containing the override properties',
     }),
+    watch: watchFlag
   };
 
   static args = [
@@ -59,9 +62,9 @@ export default class Diff extends Command {
     const outputFormat = flags['format'];
     const outputType = flags['type'];
     const overrideFilePath = flags['overrides'];
-
+    const watchMode = flags['watch'];
     let firstDocument: Specification, secondDocument: Specification;
-
+   
     try {
       firstDocument = await load(firstDocumentPath);
     } catch (err) {
@@ -125,6 +128,10 @@ export default class Diff extends Command {
         err: error,
       });
     }
+    if (watchMode) {
+      specWatcher(firstDocumentPath,this,'diff');
+      specWatcher(secondDocumentPath,this,'diff');
+    }
   }
 
   outputJson(diffOutput: AsyncAPIDiff, outputType: string) {

src/commands/validate.ts

@@ -4,21 +4,27 @@ import Command from '../base';
 import { ValidationError } from '../errors/validation-error';
 import { load } from '../models/SpecificationFile';
 import { SpecificationFileNotFound } from '../errors/specification-file';
+import { specWatcher } from '../globals';
+import { watchFlag } from '../flags';
 
 export default class Validate extends Command {
   static description = 'validate asyncapi file';
 
   static flags = {
-    help: flags.help({ char: 'h' })
+    help: flags.help({ char: 'h' }),
+    watch: watchFlag
   }
 
   static args = [
     { name: 'spec-file', description: 'spec path, url, or context-name', required: false },
   ]
 
   async run() {
-    const { args } = this.parse(Validate);
+    const { args, flags } = this.parse(Validate); // NOSONAR
     const filePath = args['spec-file'];
+
+    const watchMode = flags['watch'];
+
     let specFile;
 
     try {
@@ -35,6 +41,7 @@ export default class Validate extends Command {
     }
     try {
       if (specFile.getFilePath()) {
+        if (watchMode) {specWatcher(specFile.getFilePath() as string,this,'validate');}
         await parser.parse(specFile.text());
         this.log(`File ${specFile.getFilePath()} successfully validated!`);
       } else if (specFile.getFileURL()) {

src/flags.ts

@@ -0,0 +1,6 @@
+import { flags } from '@oclif/command';
+
+export const watchFlag = flags.boolean({
+  char: 'w',
+  description: 'Enable watch mode'
+});

src/globals.ts

@@ -0,0 +1,28 @@
+import chokidar from 'chokidar';
+import chalk from 'chalk';
+import Command from '@oclif/command';
+
+const GreenLog = chalk.hex('#00FF00');
+const OrangeLog = chalk.hex('#FFA500');
+
+const CHOKIDAR_CONFIG = {
+  // awaitWriteFinish: true
+};
+const WATCH_MESSAGES = {
+  logOnStart: (filePath: string) => console.log(GreenLog(`Watching AsyncAPI file at ${filePath}`)),
+  logOnChange: (handlerName: string) => console.log(OrangeLog(`Change detected, running ${handlerName}`)),
+};
+
+export const specWatcher = (filePath: string, handler: Command, handlerName: string) => {
+  try {
+    WATCH_MESSAGES.logOnStart(filePath);
+    chokidar
+      .watch(filePath, CHOKIDAR_CONFIG)
+      .on('change', async () => {
+        WATCH_MESSAGES.logOnChange(handlerName);
+        await handler.run();
+      });
+  } catch (error) {
+    console.log(error);
+  }
+};

test/commands/validate.test.ts

@@ -2,7 +2,6 @@
 
 import * as path from 'path';
 import { expect, test } from '@oclif/test';
-
 import TestHelper from '../testHelper';
 
 const testHelper = new TestHelper();