add mqtt-parameter endpoint

fixes #13

Author: Shaoranlaos

README.md

@@ -85,6 +85,15 @@ the endpoint expects the following as a json payload on the message
 {"cmdCode": "WN511_SET_PERMANENT_WATTS_PACK","params": {"permanentWatts": 20}}
 ```
 
+### query MQTT configuration parameter
+
+This will query the HTTP-API for the needed configuration to use the offical MQTT-API.
+
+Example:
+```
+{"certificateAccount":"open-...","certificatePassword":"...","url":"mqtt-e.ecoflow.com","port":"8883","protocol":"mqtts"}
+```
+
 ## Getting Access Key and Secret Key
 
 The Credentials can be requested on the offical Ecoflow IoT Website: [Ecoflow OpenIoT](https://developer-eu.ecoflow.com).

ecoflow-api-node.html

@@ -22,6 +22,7 @@
                             { value: "queryQuotaAll", label: "query all data of a device" },
                             { value: "queryQuotaSelective", label: "query specific datapoints" },
                             { value: "setQuota", label: "set a specific value" },
+                            { value: "queryMqttCert", label: "get MQTT connection parameter" },
                             { value: "msg", label: "use the msg.function field" }
                         ]
                     }
@@ -31,7 +32,7 @@
             // polling or callback
             let updateFunction = function() {
                 let fn = $("#node-input-function").val();
-                if (fn == "deviceList") {
+                if (fn == "deviceList" || fn == 'queryMqttCert') {
                     $("#serialnumber").hide();
                 } else {
                     $("#serialnumber").show();
@@ -98,6 +99,7 @@ <h3>Inputs</h3>
                 <li>deviceList</li>
                 <li>queryQuotaSelective</li>
                 <li>setQuota</li>
+                <li>queryMqttCert</li>
             </ul>
         </dd>
     </dl>

ecoflow-api-node.js

@@ -44,6 +44,9 @@ module.exports = function(RED) {
                         [data,error] = await server.setQuotaSelective(serialNumber,quotaTypes);
                     }
                     break;
+                case 'queryMqttCert':
+                    [data,error] = await server.queryMqttCert();
+                    break;
             }
 
             if (data) {

ecoflow-api.js

@@ -66,6 +66,7 @@ module.exports = function(RED) {
                 })
                 .catch(function(error) {
                     node.error(error);
+                    console.log(error);
                     return [undefined,error];
                 });
         }
@@ -82,6 +83,9 @@ module.exports = function(RED) {
         node.setQuotaSelective = function(sn, values) {
             return EcoflowRequest("/iot-open/sign/device/quota", {}, 'PUT', {sn: sn, ...values });
         }
+        node.queryMqttCert =  function(sn) {
+            return EcoflowRequest("/iot-open/sign/certification", {});
+        }
     }
 
     RED.nodes.registerType("ecoflow-api-server", RemoteServerNode, {