fix: remove forceful normalization of YAML to JSON

asyncapi · Jul 3, 2024 · 087a11f · 087a11f
1 parent 0676ea0
commit 087a11f
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 14 deletions.
diff --git a/.changeset/smooth-pumas-deliver.md b/.changeset/smooth-pumas-deliver.md
@@ -0,0 +1,5 @@
+---
+"@asyncapi/parser": patch
+---
+
+fix: remove forceful normalization of YAML to JSON
diff --git a/packages/parser/src/parse.ts b/packages/parser/src/parse.ts
@@ -38,24 +38,14 @@ const defaultOptions: ParseOptions = {
  validateOptions: {},
  __unstable: {},
 };
-import yaml from 'js-yaml';
+
 export async function parse(parser: Parser, spectral: Spectral, asyncapi: Input, options: ParseOptions = {}): Promise<ParseOutput> {
  let spectralDocument: Document | undefined;
 
  try {
  options = mergePatch<ParseOptions>(defaultOptions, options);
- // Normalize input to always be JSON 
- let loadedObj;
- if (typeof asyncapi === 'string') {
- try {
- loadedObj = yaml.load(asyncapi);
- } catch (e) {
- loadedObj = JSON.parse(asyncapi);
- }
- } else {
- loadedObj = asyncapi;
- }
- const { validated, diagnostics, extras } = await validate(parser, spectral, loadedObj, { ...options.validateOptions, source: options.source, __unstable: options.__unstable });
+
+ const { validated, diagnostics, extras } = await validate(parser, spectral, asyncapi, { ...options.validateOptions, source: options.source, __unstable: options.__unstable });
  if (validated === undefined) {
  return {
  document: undefined,
@@ -72,7 +62,7 @@ export async function parse(parser: Parser, spectral: Spectral, asyncapi: Input,
 
  // Apply unique ids which are used as part of iterating between channels <-> operations <-> messages
  applyUniqueIds(validatedDoc);
- const detailed = createDetailedAsyncAPI(validatedDoc, loadedObj as DetailedAsyncAPI['input'], options.source);
+ const detailed = createDetailedAsyncAPI(validatedDoc, asyncapi as DetailedAsyncAPI['input'], options.source);
  const document = createAsyncAPIDocument(detailed);
  setExtension(xParserSpecParsed, true, document);
  setExtension(xParserApiVersion, ParserAPIVersion, document);