feat!: enable usage of generated app as a library without its code modification

template/src/api/handlers/$$channel$$.js

@@ -1,21 +1,13 @@
 {%- if channel.hasPublish() and channel.publish().ext('x-lambda') %}const fetch = require('node-fetch');{%- endif %}
 const handler = module.exports = {};
+
+const middlewares = [];
+
+handler.registerMiddleware = (middlewareFn) => {
+  middlewares.push(middlewareFn);
+}
+
 {% if channel.hasPublish() %}
-/**
- * {{ channel.publish().summary() }}
- * @param {object} options
- * @param {object} options.message
-{%- if channel.publish().message(0).headers() %}
-{%- for fieldName, field in channel.publish().message(0).headers().properties() %}
-{{ field | docline(fieldName, 'options.message.headers') }}
-{%- endfor %}
-{%- endif %}
-{%- if channel.publish().message(0).payload() %}
-{%- for fieldName, field in channel.publish().message(0).payload().properties() %}
-{{ field | docline(fieldName, 'options.message.payload') }}
-{%- endfor %}
-{%- endif %}
- */
 handler.{{ channel.publish().id() }} = async ({message}) => {
   {%- if channel.publish().ext('x-lambda') %}
   {%- set lambda = channel.publish().ext('x-lambda') %}
@@ -30,29 +22,18 @@ handler.{{ channel.publish().id() }} = async ({message}) => {
     .then(json => console.log(json))
     .catch(err => { throw err; });
   {%-  else %}
-  // Implement your business logic here...
+  for (const middleware of middlewares) {
+    await middleware(message);
+  }
   {%- endif %}
 };
 
 {%- endif %}
 {%- if channel.hasSubscribe() %}
-/**
- * {{ channel.subscribe().summary() }}
- * @param {object} options
- * @param {object} options.message
-{%- if channel.subscribe().message(0).headers() %}
-{%- for fieldName, field in channel.subscribe().message(0).headers().properties() %}
-{{ field | docline(fieldName, 'options.message.headers') }}
-{%- endfor %}
-{%- endif %}
-{%- if channel.subscribe().message(0).payload() %}
-{%- for fieldName, field in channel.subscribe().message(0).payload().properties() %}
-{{ field | docline(fieldName, 'options.message.payload') }}
-{%- endfor %}
-{%- endif %}
- */
 handler.{{ channel.subscribe().id() }} = async ({message}) => {
-  // Implement your business logic here...
+  for (const middleware of middlewares) {
+    await middleware(message);
+  }
 };
 
 {%- endif %}

template/src/lib/message-validator.js

@@ -1,8 +1,10 @@
+const path = require('path');
 const AsyncApiValidator = require('asyncapi-validator');
 
 // Try to parse the payload, and increment nValidated if parsing was successful.
 module.exports.validateMessage = async (payload, channelName, messageName, operation, nValidated=0) => {
-  const va = await AsyncApiValidator.fromSource('./asyncapi.yaml', {msgIdentifier: 'name'});
+  const asyncApiFilePath = path.resolve(__dirname, '../../asyncapi.yaml');
+  const va = await AsyncApiValidator.fromSource(asyncApiFilePath, {msgIdentifier: 'name'});
   va.validate(messageName, payload, channelName, operation);
   nValidated++;