fix: work correctly on pre-parsed AsyncAPI docs when given as Input (#…

…103) * fix: work correctly on pre-parsed input * add tests for parsed asyncapi docs * Update test/testsUtil.js Co-authored-by: Maciej Urbańczyk <[email protected]> * Update lib/utils.js Co-authored-by: Maciej Urbańczyk <[email protected]> * chore: remove console * chore: fix code smells * fix: code smell Co-authored-by: Maciej Urbańczyk <[email protected]> Co-authored-by: Lukasz Gornicki <[email protected]>
asyncapi-archived-repos · May 12, 2022 · 133921a · 133921a
1 parent f049d17
commit 133921a
Show file tree

Hide file tree

Showing 3 changed files with 42 additions and 9 deletions.
diff --git a/lib/utils.js b/lib/utils.js
@@ -6,9 +6,10 @@ const parser = require('@asyncapi/parser');
  * @param {Array} asyncApiDocs unparsed AsyncAPI documents
  * @returns {Promise<Array>} parsed AsyncAPI documents
  */
+
 function validate(asyncApiDocs) {
   return Promise.all(asyncApiDocs.map(async doc => {
-    if (doc && doc['x-parser-spec-parsed'] === true) {
+    if (typeof doc === 'object' && typeof doc.ext === 'function' && doc.ext('x-parser-spec-parsed')) {
       return doc;
     }
     return parser.parse(doc);

diff --git a/test/appRelationsDiscovery_test.js b/test/appRelationsDiscovery_test.js
diff --git a/test/testsUtil.js b/test/testsUtil.js
@@ -1,8 +1,18 @@
 const path = require('path');
 const fs = require('fs');
+const parser = require('@asyncapi/parser');
 
 const examplesPath = './test/examples/flightService';
 
+async function parseAsyncApiExamples(asyncApiDocs) {
+  const docs = [];
+  for (const doc of asyncApiDocs) {
+    const parsedDoc = await parser.parse(doc);
+    docs.push(parsedDoc);
+  }
+  return docs;
+}
+
 function getAsyncApiExamples() {
   const docs = [];
   const files = fs.readdirSync(examplesPath);
@@ -14,4 +24,4 @@ function getAsyncApiExamples() {
   return docs;
 }
 
-module.exports = {getAsyncApiExamples};
+module.exports = {getAsyncApiExamples,parseAsyncApiExamples};