Add support for channels with oneOf messages

Author: stavshamir

build.gradle

@@ -6,7 +6,7 @@ plugins {
 }
 
 group = 'io.github.springwolf'
-version = '0.3.1' + (Boolean.valueOf(System.getProperty('snapshot')) ? '-SNAPSHOT' : '')
+version = '0.4.0' + (Boolean.valueOf(System.getProperty('snapshot')) ? '-SNAPSHOT' : '')
 sourceCompatibility = '1.8'
 
 node {

src/app/channels/channel-main/channel-main.component.ts

@@ -18,7 +18,7 @@ export class ChannelMainComponent implements OnInit {
   @Input() docName: string;
   @Input() channelName: string;
   @Input() operation: Operation;
-  
+
   schema: Schema;
   defaultExample: Example;
   exampleTextAreaLineCount: number;
@@ -34,7 +34,7 @@ export class ChannelMainComponent implements OnInit {
 
   ngOnInit(): void {
     this.asyncApiService.getAsyncApis().subscribe(
-      asyncapi => {      
+      asyncapi => {
         let schemas: Map<string, Schema> = asyncapi.get(this.docName).components.schemas;
         this.schema = schemas.get(this.operation.message.title);
         this.defaultExample = this.schema.example;

src/app/channels/channels.component.css

@@ -9,3 +9,11 @@
 mat-divider {
     height: 20px;
 }
+
+.payload-name {
+    background-color: #E0E0E0;
+    border-radius: 4px;
+    padding: 4px;
+    font-weight: normal;
+    font-size: small;
+}

src/app/channels/channels.component.html

@@ -5,6 +5,7 @@ <h1>Channels</h1>
             <mat-panel-title fxLayout fxLayoutAlign="flex-start center" fxLayoutGap="16px">
                 <div class="operation-badge">{{ channel.operation.type }}</div>
                 <h3>{{ channel.name }}</h3>
+                <div class="payload-name">{{ channel.operation.message.title }}</div>
             </mat-panel-title>
         </mat-expansion-panel-header>
         <app-channel-main 

src/app/shared/asyncapi.service.ts

@@ -103,40 +103,36 @@ export class AsyncApiService {
                 bindings?: any;
             };
             publish?: {
-                message: Message;
+                message: Message | { oneOf: Message[] };
                 bindings?: any;
             };
         }
     }): Channel[] {
         const s = new Array<Channel>();
-        Object.entries(channels).forEach(([k, v]) => s.push({
-            name: k,
-            description: v.description,
-            operation: this.mapOperation(v.subscribe, v.publish)
-        }));
+        Object.entries(channels).forEach(([k, v]) => {
+            let operation = v.publish ? v.publish : v.subscribe;
+            let isSubscribe = !!v.subscribe;
+
+            let messages: Message[] = 'oneOf' in operation.message ? operation.message.oneOf : [operation.message];
+            messages.forEach(message => s.push({
+                name: k,
+                description: v.description,
+                operation: this.mapOperation(isSubscribe, message, operation.bindings)
+            }))
+        });
         return s;
     }
 
-    private mapOperation(subscribe: { message: Message; bindings?: any; }, publish: { message: Message; bindings?: any; }): Operation {
-        const isSubscribe = !!subscribe;
-
-        if (isSubscribe) {
-            return {
-                type: this.getProtocol(subscribe) + " producer",
-                message: subscribe.message,
-                bindings: subscribe.bindings
-            }
-        } else {
-            return {
-                type: this.getProtocol(publish) + " consumer",
-                message: publish.message,
-                bindings: publish.bindings
-            }
+    private mapOperation(isSubscribe: boolean, message: Message, bindings?: any): Operation {
+        return {
+            type: this.getProtocol(bindings) + (isSubscribe ? " producer" : " consumer"),
+            message: message,
+            bindings: bindings
         }
     }
 
-    private getProtocol(operation: { message: Message; bindings?: any; }): string {
-        return Object.keys(operation.bindings)[0];
+    private getProtocol(bindings?: any): string {
+        return Object.keys(bindings)[0];
     }
 
     mapSchemas(schemas: { [key: string]: { type: string; properties: object; example: object; } }): Map<string, Schema> {

src/app/shared/mock.json

@@ -13,8 +13,8 @@
       }
     },
     "channels": {
-      "another-topic": {
-        "subscribe": {
+      "example-consumer-topic": {
+        "publish": {
           "bindings": {
             "kafka": {
               "groupId": {
@@ -34,17 +34,10 @@
           }
         }
       },
-      "example-topic": {
+      "example-producer-topic": {
         "subscribe": {
           "bindings": {
-            "kafka": {
-              "groupId": {
-                "type": "string",
-                "enum": [
-                  ""
-                ]
-              }
-            }
+            "kafka": {}
           },
           "message": {
             "name": "io.github.stavshamir.springwolf.example.dtos.ExamplePayloadDto",
@@ -54,6 +47,31 @@
             }
           }
         }
+      },
+      "multi-payload-topic": {
+        "publish": {
+          "bindings": {
+            "kafka": {}
+          },
+          "message": {
+            "oneOf": [
+              {
+                "name": "io.github.stavshamir.springwolf.example.dtos.ExamplePayloadDto",
+                "title": "ExamplePayloadDto",
+                "payload": {
+                  "$ref": "#/components/schemas/ExamplePayloadDto"
+                }
+              },
+              {
+                "name": "io.github.stavshamir.springwolf.example.dtos.AnotherPayloadDto",
+                "title": "AnotherPayloadDto",
+                "payload": {
+                  "$ref": "#/components/schemas/AnotherPayloadDto"
+                }
+              }
+            ]
+          }
+        }
       }
     },
     "components": {
@@ -157,7 +175,6 @@
               "type": "string",
               "enum": [
                 "FOO1"
-                
               ]
             }
           },