fix(reference): add support for external cycles detection in AsyncAPI 2.x dereference strategy (#3872)

Refs #3863

Author: char0n

packages/apidom-reference/src/dereference/strategies/asyncapi-2/visitor.ts

@@ -56,13 +56,22 @@ const AsyncApi2DereferenceVisitor = stampit({
     reference: null,
     options: null,
     ancestors: null,
+    refractCache: null,
   },
-  init({ indirections = [], reference, namespace, options, ancestors = new AncestorLineage() }) {
+  init({
+    indirections = [],
+    reference,
+    namespace,
+    options,
+    ancestors = new AncestorLineage(),
+    refractCache = new Map(),
+  }) {
     this.indirections = indirections;
     this.namespace = namespace;
     this.reference = reference;
     this.options = options;
     this.ancestors = new AncestorLineage(...ancestors);
+    this.refractCache = refractCache;
   },
   methods: {
     toBaseURI(uri: string): string {
@@ -148,15 +157,20 @@ const AsyncApi2DereferenceVisitor = stampit({
       // applying semantics to a fragment
       if (isPrimitiveElement(referencedElement)) {
         const referencedElementType = toValue(referencingElement.meta.get('referenced-element'));
+        const cacheKey = `${referencedElementType}-${toValue(identityManager.identify(referencedElement))}`;
 
-        if (isReferenceLikeElement(referencedElement)) {
+        if (this.refractCache.has(cacheKey)) {
+          referencedElement = this.refractCache.get(cacheKey);
+        } else if (isReferenceLikeElement(referencedElement)) {
           // handling indirect references
           referencedElement = ReferenceElement.refract(referencedElement);
           referencedElement.setMetaProperty('referenced-element', referencedElementType);
+          this.refractCache.set(cacheKey, referencedElement);
         } else {
           // handling direct references
           const ElementClass = this.namespace.getElementClass(referencedElementType);
           referencedElement = ElementClass.refract(referencedElement);
+          this.refractCache.set(cacheKey, referencedElement);
         }
       }
 
@@ -182,6 +196,7 @@ const AsyncApi2DereferenceVisitor = stampit({
         indirections: [...this.indirections],
         options: this.options,
         ancestors: ancestorsLineage,
+        refractCache: this.refractCache,
       });
       referencedElement = await visitAsync(referencedElement, visitor, {
         keyMap,
@@ -288,7 +303,14 @@ const AsyncApi2DereferenceVisitor = stampit({
 
       // applying semantics to a referenced element
       if (isPrimitiveElement(referencedElement)) {
-        referencedElement = ChannelItemElement.refract(referencedElement);
+        const cacheKey = `channel-${toValue(identityManager.identify(referencedElement))}`;
+
+        if (this.refractCache.has(cacheKey)) {
+          referencedElement = this.refractCache.get(cacheKey);
+        } else {
+          referencedElement = ChannelItemElement.refract(referencedElement);
+          this.refractCache.set(cacheKey, referencedElement);
+        }
       }
 
       // detect direct or indirect reference
@@ -313,6 +335,7 @@ const AsyncApi2DereferenceVisitor = stampit({
         indirections: [...this.indirections],
         options: this.options,
         ancestors: ancestorsLineage,
+        refractCache: this.refractCache,
       });
       referencedElement = await visitAsync(referencedElement, visitor, {
         keyMap,

packages/apidom-reference/test/dereference/strategies/asyncapi-2/reference-object/fixtures/external-cycle/ex.json

@@ -0,0 +1,7 @@
+{
+  "properties": {
+    "parent": {
+      "$ref": "#"
+    }
+  }
+}

packages/apidom-reference/test/dereference/strategies/asyncapi-2/reference-object/fixtures/external-cycle/root.json

@@ -0,0 +1,10 @@
+{
+  "asyncapi": "2.6.0",
+  "components": {
+    "schemas": {
+      "externalSchema": {
+        "$ref": "./ex.json"
+      }
+    }
+  }
+}

packages/apidom-reference/test/dereference/strategies/asyncapi-2/reference-object/index.ts

@@ -84,6 +84,27 @@ describe('dereference', function () {
           });
         });
 
+        context('given Reference Objects pointing to external cycles', function () {
+          const fixturePath = path.join(rootFixturePath, 'external-cycle');
+
+          specify('should dereference', async function () {
+            const rootFilePath = path.join(fixturePath, 'root.json');
+            const dereferenced = await dereference(rootFilePath, {
+              parse: { mediaType: mediaTypes.latest('json') },
+            });
+            const parent = evaluate(
+              '/0/components/schemas/externalSchema/properties',
+              dereferenced,
+            );
+            const cyclicParent = evaluate(
+              '/0/components/schemas/externalSchema/properties/parent/properties',
+              dereferenced,
+            );
+
+            assert.strictEqual(parent, cyclicParent);
+          });
+        });
+
         context('given Reference Objects pointing to external indirections', function () {
           const fixturePath = path.join(rootFixturePath, 'external-indirections');