feat: enable v3 support

components/Asyncapi.js

@@ -0,0 +1,26 @@
+
+import { Info } from './Info';
+import { Servers } from './Servers';
+import { Operations } from './Operations';
+import { FrontMatter } from './FrontMatter';
+import { TableOfContents } from './TableOfContents';
+
+// eslint-disable-next-line no-unused-vars
+import { AsyncAPIDocumentInterface } from '@asyncapi/parser';
+
+/**
+ * @param {{asyncapi: AsyncAPIDocumentInterface, params: any}} param0 
+ */
+export function Asyncapi({ asyncapi, params }) {
+  return (
+    <>
+      {params.frontMatter && <FrontMatter asyncapi={asyncapi} params={params} />}
+      <Info asyncapi={asyncapi} params={params} />
+      {params.toc !== 'false' && <TableOfContents asyncapi={asyncapi} />}
+
+      <Servers asyncapi={asyncapi} />
+      <Operations asyncapi={asyncapi} />
+    </>
+  );
+}
+

components/Operations.js

@@ -1,52 +1,57 @@
 import { Text } from '@asyncapi/generator-react-sdk';
-
 import { Bindings } from './Bindings';
 import { Extensions } from './Extensions';
 import { Message } from './Message';
 import { Schema } from './Schema';
 import { Security } from './Security';
 import { Tags } from './Tags';
 import { Header, ListItem, Link } from './common';
-
 import { SchemaHelpers } from '../helpers/schema';
 import { FormatHelpers } from '../helpers/format';
 
+// eslint-disable-next-line no-unused-vars
+import { AsyncAPIDocumentInterface, OperationInterface, OperationReplyInterface, ChannelInterface } from '@asyncapi/parser';
+
+/**
+ * @param {{asyncapi: AsyncAPIDocumentInterface}} param0 
+ */
 export function Operations({ asyncapi }) {
   const channels = asyncapi.channels();
   if (channels.isEmpty()) {
     return null;
   }
 
   const operationsList = [];
-  channels.all().map(channel => {
+  for (const channel of channels.all()) {
     const channelName = channel.address();
-    channel.operations().all().forEach(operation => {
-      if (operation.action() === 'publish') {
-        operationsList.push(
-          <Operation
-            key={`pub-${channelName}`}
-            type='publish'
-            asyncapi={asyncapi}
-            operation={operation}
-            channelName={channelName}
-            channel={channel}
-          />
-        );
-      }
-      if (operation.action() === 'subscribe') {
-        operationsList.push(
-          <Operation
-            key={`sub-${channelName}`}
-            type='subscribe'
-            asyncapi={asyncapi}
-            operation={operation}
-            channelName={channelName}
-            channel={channel}
-          />
-        );
+    const operations = channel.operations().all();
+    operations.map(operation => {
+      let type;
+      if (operation.isSend()) {
+        if (operation.reply() !== undefined) {
+          type = 'request';
+        } else {
+          type = 'publish';
+        }
+      } else if (operation.isReceive()) {
+        if (operation.reply() !== undefined) {
+          type = 'response';
+        } else {
+          type = 'subscribe';
+        }
       }
+      operationsList.push(
+        <Operation
+          key={`${operation.action()}-${channelName}`}
+          type={type}
+          asyncapi={asyncapi}
+          operation={operation}
+          channelName={channelName}
+          channel={channel}
+        />
+      );
     });
-  });
+  }
 
   return (
     <>
@@ -58,7 +63,10 @@ export function Operations({ asyncapi }) {
   );
 }
 
-function Operation({ type, asyncapi, operation, channelName, channel }) { // NOSONAR
+/**
+ * @param {{asyncapi: AsyncAPIDocumentInterface, type: string, operation: OperationInterface, channelName: string, channel: ChannelInterface}} param0 
+ */
+function Operation({ asyncapi, type, operation, channelName, channel }) { // NOSONAR
   if (!operation || !channel) {
     return null;
   }
@@ -68,7 +76,21 @@ function Operation({ type, asyncapi, operation, channelName, channel }) { // NOS
   const applyToAllServers = asyncapi.servers().all().length === channel.servers().all().length;
   const servers = applyToAllServers ? [] : channel.servers().all();
   const security = operation.security();
-  const renderedType = type === 'publish' ? 'PUB' : 'SUB';
+  let renderedType;
+  switch (type) {
+  case 'request':
+    renderedType = 'REQUEST';
+    break;
+  case 'publish':
+    renderedType = 'PUB';
+    break;
+  case 'response':
+    renderedType = 'RESPONSE';
+    break;
+  case 'subscribe':
+    renderedType = 'SUB';
+    break;
+  }
   const showInfoList = operationId || (servers && servers.length);
 
   return (
@@ -139,10 +161,14 @@ function Operation({ type, asyncapi, operation, channelName, channel }) { // NOS
       <Extensions name="Operation extensions" item={operation} />
 
       <OperationMessages operation={operation} />
+
+      <OperationReply operation={operation} />
     </Text>
   );
 }
-
+/**
+ * @param {{channel: ChannelInterface}} param0 
+ */
 function OperationParameters({ channel }) {
   const parameters = SchemaHelpers.parametersToSchema(channel.parameters().all());
   if (!parameters) {
@@ -156,7 +182,9 @@ function OperationParameters({ channel }) {
     </Text>
   );
 }
-
+/**
+ * @param {{operation: OperationInterface}} param0 
+ */
 function OperationMessages({ operation }) {
   const messages = operation.messages().all();
   if (messages.length === 0) {
@@ -176,3 +204,79 @@ function OperationMessages({ operation }) {
     </>
   );
 }
+
+/**
+ * @param {{operation: OperationInterface}} param0 
+ */
+function OperationReply({ operation }) {
+  const reply = operation.reply();
+  if (reply === undefined) {
+    return null;
+  }
+  const replyId = reply.id();
+  const explicitChannel = reply.channel();
+
+  let type;
+  if (operation.isSend()) {
+    type = 'Request';
+  } else if (operation.isReceive()) {
+    type = 'Response';
+  }
+
+  return (
+    <Text>
+      <Header type={4}>
+        {`${type} information`}
+      </Header>
+
+      {replyId && <ListItem>Operation reply ID: `{replyId}`</ListItem>}
+
+      {explicitChannel && <ListItem>{type} should be done to channel: `{reply.channel().address()}`</ListItem>}
+
+      <OperationReplyAddress name="Operation reply address" reply={reply} />
+
+      <>
+        {reply.messages().length > 1 && (
+          <Text newLines={2}>
+            Accepts **one of** the following messages:
+          </Text>
+        )}
+        {reply.messages().length > 1 && reply.messages().map((msg, idx) => (
+          <Message message={msg} key={`message-${idx}`} />
+        ))}
+      </>
+      <Extensions name="Operation reply extensions" item={reply} />
+    </Text>
+  );
+}
+
+/**
+ * @param {{reply: OperationReplyInterface}} param0 
+ */
+function OperationReplyAddress({ reply }) {
+  const address = reply.address();
+  if (address === undefined) {
+    return null;
+  }
+  const addressId = address.id();
+  const location = address.location();
+
+  return (
+    <Text>
+      <Header type={4}>
+        {'Operation reply address information'}
+      </Header>
+
+      {addressId && <ListItem>Operation reply address ID: `{addressId}`</ListItem>}
+      <ListItem>Operation reply address location: `{location}`</ListItem>
+
+      {address.hasDescription() && (
+        <Text newLines={2}>
+          {address.description()}
+        </Text>
+      )}
+
+      <Extensions name="Operation reply address extensions" item={address} />
+    </Text>
+  );
+}