fix: apply traits to standalone messages from components section

lib/parser.js

@@ -15,6 +15,7 @@ const OPERATIONS = ['publish', 'subscribe'];
 const SPECIAL_SECURITY_TYPES = ['oauth2', 'openIdConnect'];
 const PARSERS = {};
 const xParserCircle = 'x-parser-circular';
+const xParserMessageParsed = 'x-parser-message-parsed';
 
 /**
  * @module @asyncapi/parser
@@ -169,14 +170,18 @@ async function customDocumentOperations(parsedJSON, asyncapiYAMLorJSON, initialF
   validateServerSecurity(parsedJSON, asyncapiYAMLorJSON, initialFormat, SPECIAL_SECURITY_TYPES);
 
   if (!parsedJSON.channels) return;
-  
+
   validateChannels(parsedJSON, asyncapiYAMLorJSON, initialFormat);
   validateOperationId(parsedJSON, asyncapiYAMLorJSON, initialFormat, OPERATIONS);
 
+  await customComponentsMsgOperations(parsedJSON, asyncapiYAMLorJSON, initialFormat, options);
   await customChannelsOperations(parsedJSON, asyncapiYAMLorJSON, initialFormat, options);
 }
 
 async function validateAndConvertMessage(msg, originalAsyncAPIDocument, fileFormat, parsedAsyncAPIDocument, pathToPayload) {
+  //check if the message has been parsed before
+  if (xParserMessageParsed in msg && msg[String(xParserMessageParsed)] === true) return;
+
   const schemaFormat = msg.schemaFormat || DEFAULT_SCHEMA_FORMAT;
 
   await PARSERS[String(schemaFormat)]({
@@ -190,6 +195,7 @@ async function validateAndConvertMessage(msg, originalAsyncAPIDocument, fileForm
   });
 
   msg.schemaFormat = DEFAULT_SCHEMA_FORMAT;
+  msg[String(xParserMessageParsed)] = true;
 }
 
 /**
@@ -231,7 +237,7 @@ function applyTraits(js) {
  * 
  * @param  {Object} parsedJSON parsed AsyncAPI document
  * @param  {String} asyncapiYAMLorJSON AsyncAPI document in string
- * @param  {String} initialFormat information of the document was oryginally JSON or YAML
+ * @param  {String} initialFormat information of the document was originally JSON or YAML
  * @param  {Object} options Configuration options.
  */
 async function customChannelsOperations(parsedJSON, asyncapiYAMLorJSON, initialFormat, options) {
@@ -253,4 +259,30 @@ async function customChannelsOperations(parsedJSON, asyncapiYAMLorJSON, initialF
     }));
   });
   await Promise.all(promisesArray);
-}
+}
+
+/**
+ * Triggers additional operations on the AsyncAPI messages located in the components section of the document. It triggers operations like traits application, validation and conversion
+ *
+ * @private
+ * 
+ * @param  {Object} parsedJSON parsed AsyncAPI document
+ * @param  {String} asyncapiYAMLorJSON AsyncAPI document in string
+ * @param  {String} initialFormat information of the document was originally JSON or YAML
+ * @param  {Object} options Configuration options.
+ */
+async function customComponentsMsgOperations(parsedJSON, asyncapiYAMLorJSON, initialFormat, options) {
+  if (!parsedJSON.components || !parsedJSON.components.messages) return;
+
+  const promisesArray = [];
+
+  Object.entries(parsedJSON.components.messages).forEach(([messageName, message]) => {
+    if (options.applyTraits) {
+      applyTraits(message);
+    }
+    const pathToPayload = `/components/messages/${messageName}/payload`;
+    promisesArray.push(validateAndConvertMessage(message, asyncapiYAMLorJSON, initialFormat, parsedJSON, pathToPayload));
+  });
+
+  await Promise.all(promisesArray);
+}

test/good/asyncapi-messages-channels.yml

@@ -0,0 +1,35 @@
+asyncapi: 2.0.0
+info:
+  title: My API
+  version: '1.0.0'
+
+channels:
+  mychannel:
+    publish:
+      message:
+        $ref: '#/components/messages/channelMessage'
+
+components:
+  messages:
+    channelMessage:
+      traits:
+        - $ref: '#/components/messageTraits/extension'
+    testMessage:
+      traits:
+        - $ref: '#/components/messageTraits/extension'
+      payload:
+        $ref: '#/components/schemas/testSchema'
+  schemas:
+    testSchema:
+      type: object
+      properties:
+        name:
+          type: string
+  messageTraits:
+    extension:
+      x-some-extension: 'some extension'
+      headers:
+        type: object
+        properties:
+          some-common-header:
+            type: string

test/good/asyncapi-no-channels.yml

@@ -0,0 +1,27 @@
+asyncapi: 2.0.0
+info:
+  title: My API
+  version: '1.0.0'
+channels: {}
+
+components:
+  messages:
+    testMessage:
+      traits:
+        - $ref: '#/components/messageTraits/extension'
+      payload:
+        $ref: '#/components/schemas/testSchema'
+  schemas:
+    testSchema:
+      type: object
+      properties:
+        name:
+          type: string
+  messageTraits:
+    extension:
+      x-some-extension: 'some extension'
+      headers:
+        type: object
+        properties:
+          some-common-header:
+            type: string

test/good/asyncapi-no-components.yml

@@ -0,0 +1,13 @@
+asyncapi: 2.0.0
+info:
+  title: My API
+  version: 1.0.0
+channels:
+  "/test/tester":
+    subscribe:
+      message:
+        payload:
+          type: object
+          properties:
+            name:
+              type: string