feat: support mqtts protocol (#174)

Co-authored-by: Lukasz Gornicki <lpgornicki@gmail.com>
asyncapi · Nov 8, 2022 · 35305fc · 35305fc
1 parent 7c47b72
commit 35305fc
Show file tree

Hide file tree

Showing 8 changed files with 629 additions and 28 deletions.
diff --git a/README.md b/README.md
@@ -40,7 +40,7 @@ Property name | Reason | Fallback | Default
 ## Supported protocols
 
 * [AMQP](https://en.wikipedia.org/wiki/Advanced_Message_Queuing_Protocol)
-* [MQTT](https://en.wikipedia.org/wiki/MQTT)
+* [MQTT and MQTTS](https://en.wikipedia.org/wiki/MQTT)
 * [Kafka](https://en.wikipedia.org/wiki/Apache_Kafka)
 * [WebSocket](https://en.wikipedia.org/wiki/WebSocket)
 

diff --git a/package.json b/package.json
@@ -78,6 +78,7 @@
     "supportedProtocols": [
       "amqp",
       "mqtt",
+      "mqtts",
       "kafka",
       "kafka-secure",
       "ws"

diff --git a/template/config/common.yml b/template/config/common.yml
@@ -25,9 +25,9 @@ default:
         durable: true
         autoDelete: true
 {%- endif %}
-{%- if asyncapi.server(params.server).protocol() === "mqtt" %}
+{%- if asyncapi.server(params.server).protocol() === "mqtt" or asyncapi.server(params.server).protocol() === "mqtts"%}
     mqtt:
-      url: mqtt://{{ asyncapi.server(params.server).url() |  replaceServerVariablesWithValues(asyncapi.server(params.server).variables()) | stripProtocol  }}
+      url: {{ asyncapi.server(params.server).protocol() }}://{{ asyncapi.server(params.server).url() |  replaceServerVariablesWithValues(asyncapi.server(params.server).variables()) | stripProtocol  }}
       topics: {{ asyncapi | channelNamesWithPublish | toMqttTopic | dump | safe }}
       qos:
       protocol: mqtt

diff --git a/template/package.json b/template/package.json
@@ -11,7 +11,7 @@
     "hermesjs": "2.x",
     "hermesjs-router": "1.x",
     "asyncapi-validator": "3.0.0",
-    {% if asyncapi.server(params.server).protocol() === 'mqtt' -%}
+    {% if asyncapi.server(params.server).protocol() === 'mqtt' or asyncapi.server(params.server).protocol() === 'mqtts' -%}
     "hermesjs-mqtt": "2.x",
     {%- endif -%}
     {% if asyncapi.server(params.server).protocol() === 'kafka' or asyncapi.server(params.server).protocol() === 'kafka-secure' -%}

diff --git a/template/src/api/index.js b/template/src/api/index.js
@@ -9,6 +9,9 @@ const logger = require('./middlewares/logger');
 const errorLogger = require('./middlewares/error-logger');
 const config = require('../lib/config');
 {%- set protocol = asyncapi.server(params.server).protocol() %}
+{%- if protocol === 'mqtts' %}
+  {%- set protocol = 'mqtt' %}
+{%- endif %}
 const serverConfig = {{ protocol | getConfig }};
 const {{ protocol | getProtocol | capitalize }}Adapter = require('hermesjs-{{ protocol | getProtocol }}');
 {%- for channelName, channel in asyncapi.channels() %}