feat(ns-asyncapi-2-0): add support for WS Message Binding Obj

Refs #387

Author: char0n

apidom/packages/apidom-ns-asyncapi-2-0/README.md

@@ -187,7 +187,7 @@ Only fully implemented specification objects should be checked here.
 - [x] [Server Binding Object](https://github.com/asyncapi/bindings/blob/master/websockets/README.md#server-binding-object)
 - [x] [Channel Binding Object](https://github.com/asyncapi/bindings/blob/master/websockets/README.md#channel-binding-object)
 - [x] [Operation Binding Object](https://github.com/asyncapi/bindings/blob/master/websockets/README.md#operation-binding-object)
-- [ ] [Message Binding Object](https://github.com/asyncapi/bindings/blob/master/websockets/README.md#message-binding-object) (reserved for future)
+- [x] [Message Binding Object](https://github.com/asyncapi/bindings/blob/master/websockets/README.md#message-binding-object)
 
 #### Kafka Bindings
 

apidom/packages/apidom-ns-asyncapi-2-0/src/elements/bindings/ws/WebSocketMessageBinding.ts

@@ -0,0 +1,10 @@
+import { Attributes, Meta, ObjectElement } from 'minim';
+
+class WebSocketMessageBinding extends ObjectElement {
+  constructor(content?: Record<string, unknown>, meta?: Meta, attributes?: Attributes) {
+    super(content, meta, attributes);
+    this.element = 'webSocketMessageBinding';
+  }
+}
+
+export default WebSocketMessageBinding;

apidom/packages/apidom-ns-asyncapi-2-0/src/index.ts

@@ -107,5 +107,6 @@ export { default as MqttOperationBindingElement } from './elements/bindings/mqtt
 export { default as MqttServerBindingElement } from './elements/bindings/mqtt/MqttServerBinding';
 // WebSocket
 export { default as WebSocketChannelBindingElement } from './elements/bindings/ws/WebSocketChannelBinding';
+export { default as WebSocketMessageBindingElement } from './elements/bindings/ws/WebSocketMessageBinding';
 export { default as WebSocketOperationBindingElement } from './elements/bindings/ws/WebSocketOperationBinding';
 export { default as WebSocketServerBindingElement } from './elements/bindings/ws/WebSocketServerBinding';

apidom/packages/apidom-ns-asyncapi-2-0/src/namespace.ts

@@ -55,6 +55,7 @@ import MqttOperationBindingElement from './elements/bindings/mqtt/MqttOperationB
 import MqttServerBindingElement from './elements/bindings/mqtt/MqttServerBinding';
 // WebSocket
 import WebSocketChannelBindingElement from './elements/bindings/ws/WebSocketChannelBinding';
+import WebSocketMessageBindingElement from './elements/bindings/ws/WebSocketMessageBinding';
 import WebSocketOperationBindingElement from './elements/bindings/ws/WebSocketOperationBinding';
 import WebSocketServerBindingElement from './elements/bindings/ws/WebSocketServerBinding';
 
@@ -118,6 +119,7 @@ const asyncApi2_0 = {
     base.register('mqttServerBinding', MqttServerBindingElement);
     // WebSocket
     base.register('webSocketChannelBinding', WebSocketChannelBindingElement);
+    base.register('webSocketMessageBinding', WebSocketMessageBindingElement);
     base.register('webSocketOperationBinding', WebSocketOperationBindingElement);
     base.register('webSocketServerBinding', WebSocketServerBindingElement);
 

apidom/packages/apidom-ns-asyncapi-2-0/src/refractor/registration.ts

@@ -54,6 +54,7 @@ import MqttOperationBindingElement from '../elements/bindings/mqtt/MqttOperation
 import MqttServerBindingElement from '../elements/bindings/mqtt/MqttServerBinding';
 // WebSocket
 import WebSocketChannelBindingElement from '../elements/bindings/ws/WebSocketChannelBinding';
+import WebSocketMessageBindingElement from '../elements/bindings/ws/WebSocketMessageBinding';
 import WebSocketOperationBindingElement from '../elements/bindings/ws/WebSocketOperationBinding';
 import WebSocketServerBindingElement from '../elements/bindings/ws/WebSocketServerBinding';
 
@@ -381,6 +382,15 @@ WebSocketChannelBindingElement.refract = createRefractor([
   'ChannelBinding',
   '$visitor',
 ]);
+WebSocketMessageBindingElement.refract = createRefractor([
+  'visitors',
+  'document',
+  'objects',
+  'bindings',
+  'ws',
+  'MessageBinding',
+  '$visitor',
+]);
 WebSocketOperationBindingElement.refract = createRefractor([
   'visitors',
   'document',

apidom/packages/apidom-ns-asyncapi-2-0/src/refractor/specification.ts

@@ -126,6 +126,7 @@ import MqttServerBindingBindingVersionVisitor from './visitors/async-api-2-0/bin
 import WebSocketChannelBindingVisitor from './visitors/async-api-2-0/bindings/ws/channel-binding';
 import WebSocketChannelBindingMethodVisitor from './visitors/async-api-2-0/bindings/ws/channel-binding/MethodVisitor';
 import WebSocketChannelBindingBindingVersionVisitor from './visitors/async-api-2-0/bindings/ws/channel-binding/BindingVersionVisitor';
+import WebSocketMessageBindingVisitor from './visitors/async-api-2-0/bindings/ws/message-binding';
 import WebSocketOperationBindingVisitor from './visitors/async-api-2-0/bindings/ws/operation-binding';
 import WebSocketServerBindingVisitor from './visitors/async-api-2-0/bindings/ws/server-binding';
 
@@ -500,7 +501,9 @@ const specification = {
             OperationBinding: {
               $visitor: WebSocketOperationBindingVisitor,
             },
-            MessageBinding: FallbackVisitor,
+            MessageBinding: {
+              $visitor: WebSocketMessageBindingVisitor,
+            },
           },
         },
       },

apidom/packages/apidom-ns-asyncapi-2-0/src/refractor/visitors/async-api-2-0/bindings/ws/message-binding/index.ts

@@ -0,0 +1,18 @@
+import stampit from 'stampit';
+import { always } from 'ramda';
+
+import WebSocketMessageBindingElement from '../../../../../../elements/bindings/ws/WebSocketMessageBinding';
+import FallbackVisitor from '../../../../FallbackVisitor';
+import FixedFieldsVisitor from '../../../../generics/FixedFieldsVisitor';
+
+const WebSocketMessageBindingVisitor = stampit(FixedFieldsVisitor, FallbackVisitor, {
+  props: {
+    specPath: always(['document', 'objects', 'bindings', 'ws', 'MessageBinding']),
+    canSupportSpecificationExtensions: false,
+  },
+  init() {
+    this.element = new WebSocketMessageBindingElement();
+  },
+});
+
+export default WebSocketMessageBindingVisitor;

apidom/packages/apidom-ns-asyncapi-2-0/src/refractor/visitors/async-api-2-0/bindings/ws/server-binding/index.ts

@@ -7,7 +7,7 @@ import FixedFieldsVisitor from '../../../../generics/FixedFieldsVisitor';
 
 const WebSocketServerBindingVisitor = stampit(FixedFieldsVisitor, FallbackVisitor, {
   props: {
-    specPath: always(['document', 'objects', 'bindings', 'ws', 'OperationBinding']),
+    specPath: always(['document', 'objects', 'bindings', 'ws', 'ServerBinding']),
     canSupportSpecificationExtensions: false,
   },
   init() {

apidom/packages/apidom-ns-asyncapi-2-0/src/traversal/visitor.ts

@@ -62,6 +62,7 @@ export const keyMap = {
   MqttServerBindingElement: ['content'],
   // WebSocket
   WebSocketChannelBindingElement: ['content'],
+  WebSocketMessageBindingElement: ['content'],
   WebSocketOperationBindingElement: ['content'],
   WebSocketServerBindingElement: ['content'],
   ...keyMapBase,