feat!: support asyncapi v3

helpers/channels-topics.js

@@ -50,12 +50,8 @@ export function toHermesTopic(str) {
   return str.replace(/\{([^}]+)\}/g, ':$1');
 }
 
-export function channelNamesWithPublish(asyncapi) {
-  const result = [];
-  asyncapi.channelNames().forEach((name) => {
-    if (asyncapi.channel(name).hasPublish()) result.push(name);
-  });
-  return result;
+export function channelNamesWithReceive(asyncapi) {
+  return asyncapi.channels().filterByReceive().map(channel => channel.id());
 }
 
 export function host(url) {
@@ -151,4 +147,4 @@ export function getProtocol(p) {
 // https://mozilla.github.io/nunjucks/templating.html#dump
 export function dump(obj) {
   return JSON.stringify(obj);
-}
+}

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@asyncapi/nodejs-template",
-  "version": "2.0.1",
+  "version": "2.0.0",
   "description": "Node.js template for the AsyncAPI generator.",
   "keywords": [
     "asyncapi",
@@ -21,7 +21,6 @@
   "scripts": {
     "test": "rimraf test/temp && jest --modulePathIgnorePatterns='./template'",
     "test:updateSnapshot": "rimraf test/temp && jest --updateSnapshot --modulePathIgnorePatterns='./template'",
-    "test:example": "node test/example/script.js",
     "lint": "eslint --max-warnings 0 --config .eslintrc .",
     "lint:fix": "eslint --fix --config .eslintrc .",
     "generate:assets": "npm run generate:readme:toc",
@@ -34,23 +33,24 @@
   "dependencies": {
     "@asyncapi/generator-filters": "^2.1.0",
     "@asyncapi/generator-hooks": "^0.1.0",
-    "@asyncapi/generator-react-sdk": "^1.0.18",
+    "@asyncapi/generator-react-sdk": "^1.0.14",
     "eslint-plugin-react": "^7.34.1",
-    "filenamify": "^4.1.0",
+    "filenamify": "^4.3.0",
     "js-beautify": "^1.15.1",
-    "lodash": "^4.17.15",
+    "lodash": "^4.17.21",
     "markdown-toc": "^1.2.0"
   },
   "devDependencies": {
-    "@asyncapi/generator": "^1.17.25",
-    "eslint": "^8.7.0",
+    "@asyncapi/generator": "^1.17.12",
+    "eslint": "^8.57.0",
     "eslint-plugin-jest": "^25.7.0",
     "eslint-plugin-sonarjs": "^0.11.0",
-    "jest": "^27.3.1",
-    "node-fetch": "^2.6.1",
-    "rimraf": "^5.0.1"
+    "jest": "^27.5.1",
+    "node-fetch": "^2.7.0",
+    "rimraf": "^5.0.5"
   },
   "generator": {
+    "apiVersion": "v3",
     "supportedProtocols": [
       "amqp",
       "mqtt",
@@ -94,4 +94,4 @@
       "^nimma/(.*)": "<rootDir>/node_modules/nimma/dist/cjs/$1"
     }
   }
-}
+}

template/README.md.js

@@ -1,6 +1,21 @@
 import { File } from '@asyncapi/generator-react-sdk';
 
 export default function readmeFile({asyncapi, params}) {
+  const server = asyncapi.allServers().get(params.server);
+  const protocol = server.protocol();
+  const security = server.security();
+
+  let hasSecuritySchemeX509 = false;
+  let securitySchemeType;
+  if (params.securityScheme && security && security.length > 0) {
+    const securityReq = security[0].all();
+    if (securityReq && securityReq.length > 0) {
+      securitySchemeType = securityReq[0].scheme().type();
+    }
+  }
+
+  hasSecuritySchemeX509 = (params.securityScheme && (protocol === 'kafka' || protocol === 'kafka-secure') && securitySchemeType === 'X509');
+
   return <File name={'README.md'}>
     {`# ${ asyncapi.info().title() }
 
@@ -12,7 +27,7 @@ ${ asyncapi.info().description() || '' }
     \`\`\`sh
     npm i
     \`\`\`
-${(params.securityScheme && (asyncapi.server(params.server).protocol() === 'kafka' || asyncapi.server(params.server).protocol() === 'kafka-secure') && asyncapi.components().securityScheme(params.securityScheme).type() === 'X509') ? '1. (Optional) For X509 security provide files with all data required to establish secure connection using certificates. Place files like `ca.pem`, `service.cert`, `service.key` in the root of the project or the location that you explicitly specified during generation.' : ''}
+${ hasSecuritySchemeX509 ? '1. (Optional) For X509 security provide files with all data required to establish secure connection using certificates. Place files like `ca.pem`, `service.cert`, `service.key` in the root of the project or the location that you explicitly specified during generation.' : ''}
 
 ## Import and start
 

template/config/common.yml.js

@@ -1,11 +1,17 @@
 import { File } from '@asyncapi/generator-react-sdk';
-import { camelCase, channelNamesWithPublish, dump, host, port, queueName, stripProtocol, toAmqpTopic, toKafkaTopic, toMqttTopic } from '../../helpers/index';
+import { camelCase, channelNamesWithReceive, dump, host, port, queueName, stripProtocol, toAmqpTopic, toKafkaTopic, toMqttTopic } from '../../helpers/index';
 import { replaceServerVariablesWithValues } from '@asyncapi/generator-filters/src/customFilters';
 
 export default function CommonConfigYAMLRender({ asyncapi, params }) {
-  const serverProtocol = asyncapi.server(params.server).protocol();
-  const serverVariables = asyncapi.server(params.server).variables();
-  const resolvedBrokerUrlWithReplacedVariables = replaceServerVariablesWithValues(asyncapi.server(params.server).url(), serverVariables);
+  const server = asyncapi.allServers().get(params.server);
+  const serverProtocol = server.protocol();
+  const serverVariablesArray = server.variables();
+  const serverVariables = {};
+  serverVariablesArray.forEach(item => {
+    serverVariables[item.id()] = item;
+  });
+
+  const resolvedBrokerUrlWithReplacedVariables = replaceServerVariablesWithValues(server.url(), serverVariables);
 
   return (
     <File name={'common.yml'}>
@@ -47,7 +53,7 @@ function amqpBlock(url, asyncapi) {
       password:
       host: ${host(url)}
       port:
-      topics: ${dump(toAmqpTopic(channelNamesWithPublish(asyncapi)))}
+      topics: ${dump(toAmqpTopic(channelNamesWithReceive(asyncapi)))}
       queue: ${queueName(asyncapi.info().title(), asyncapi.info().version())}
       queueOptions:
         exclusive: false
@@ -57,9 +63,10 @@ function amqpBlock(url, asyncapi) {
 }
 
 function mqttBlock(url, asyncapi, params) {
+  const server = asyncapi.allServers().get(params.server);
   return `    mqtt:
-      url: ${asyncapi.server(params.server).protocol()}://${stripProtocol(url)}
-      topics: ${dump(toMqttTopic(channelNamesWithPublish(asyncapi)))}
+      url: ${server.protocol()}://${stripProtocol(url)}
+      topics: ${dump(toMqttTopic(channelNamesWithReceive(asyncapi)))}
       qos:
       protocol: mqtt
       retain:
@@ -75,7 +82,7 @@ function kafkaBlock(url, asyncapi) {
       consumerOptions:
         groupId: ${camelCase(asyncapi.info().title())}
       topics:
-      ${channelNamesWithPublish(asyncapi).map(topic => `- ${toKafkaTopic(topic)}`).join('\n')}
+      ${channelNamesWithReceive(asyncapi).map(topic => `- ${toKafkaTopic(topic)}`).join('\n')}
       topicSeparator: '__'
       topicPrefix:
 `;
@@ -87,12 +94,12 @@ function kafkaProductionBlock(params, asyncapi) {
       ssl:
         rejectUnauthorized: true
 `;
-  if (params.securityScheme && asyncapi.components().securityScheme(params.securityScheme).type() !== 'X509') {
+  if (params.securityScheme && asyncapi.components().securitySchemes().get(params.securityScheme).type() !== 'X509') {
     productionBlock += `      sasl:
         mechanism: 'plain'
         username:
         password:
 `;
   }
   return productionBlock;
-}
+}

template/package.json.js

@@ -12,7 +12,7 @@ export default function packageFile({ asyncapi, params }) {
     'node-yaml-config': '0.0.4',
   };
 
-  const serverProtocol = asyncapi.server(params.server).protocol();
+  const serverProtocol = asyncapi.allServers().get(params.server).protocol();
   if (serverProtocol === 'mqtt' || serverProtocol === 'mqtts') {
     dependencies['hermesjs-mqtt'] = '2.x';
   } else if (serverProtocol === 'kafka' || serverProtocol === 'kafka-secure') {