add first draft for mqtt blocks

2020-11-11 11:09:19 +01:00
parent 3df66cd425
commit fe328f9da3
8 changed files with 157 additions and 1 deletions
@@ -0,0 +1,61 @@
+import * as Blockly from 'blockly/core';
+/**
+* MQTT Blocks 
+*/
+
+Blockly.Arduino.sensebox_mqtt_setup = function () {
+    var server = this.getFieldValue('server');
+    var port = this.getFieldValue('port');
+    var username = this.getFieldValue('username');
+    var pass = this.getFieldValue('password');
+    Blockly.Arduino.libraries_['library_senseBoxMCU'] = '#include "SenseBoxMCU.h"';
+    Blockly.Arduino.libraries_['library_adafruitmqtt'] = '#include "Adafruit_MQTT.h"';
+    Blockly.Arduino.libraries_['library_adafruitmqttclient'] = '#include "Adafruit_MQTT_Client.h"';
+    Blockly.Arduino.definitions_['mqtt_server'] = '#define SERVER      "' + server + '"';
+    Blockly.Arduino.definitions_['mqtt_port'] = '#define SERVERPORT      ' + port + '';
+    Blockly.Arduino.definitions_['mqtt_username'] = '#define USERNAME      "' + username + '"';
+    Blockly.Arduino.definitions_['mqtt_pass'] = '#define PASS      "' + pass + '"';
+    Blockly.Arduino.definitions_['wifi_client'] = 'WiFiClient client;';
+    Blockly.Arduino.definitions_['mqtt_client'] = 'Adafruit_MQTT_Client mqtt(&client, SERVER, SERVERPORT, USERNAME, PASS);'
+    var code = '';
+    return code;
+};
+
+Blockly.Arduino.sensebox_mqtt_publish = function (block) {
+    var feedname = this.getFieldValue('publishfeed');
+    var res = feedname.split("/");
+    var feed_client = res[res.length - 1];
+    var value = Blockly.Arduino.valueToCode(this, 'value', Blockly.Arduino.ORDER_ATOMIC) || '"No Block connected"';
+    Blockly.Arduino.definitions_['mqtt_' + feed_client + ''] = 'Adafruit_MQTT_Publish ' + feed_client + ' = Adafruit_MQTT_Publish(&mqtt, USERNAME "/feeds/' + feedname + '");'
+    Blockly.Arduino.codeFunctions_['mqtt_connect_function'] = `// Function to connect and reconnect as necessary to the MQTT server.
+    // Should be called in the loop function and it will take care if connecting.
+void MQTT_connect() {
+      int8_t ret;
+      // Stop if already connected.
+      if (mqtt.connected()) {
+        return;
+      }  
+      while ((ret = mqtt.connect()) != 0) { // connect will return 0 for connected
+           mqtt.disconnect();
+           delay(5000);  // wait 5 seconds
+      }
+}`;
+    Blockly.Arduino.loopCodeOnce_['mqtt_connect'] = 'MQTT_connect();';
+    var code = '' + feed_client + '.publish(' + value + ');';
+    return code
+};
+
+Blockly.Arduino.sensebox_mqtt_subscribe = function (block) {
+    var feedname = this.getFieldValue('subscribefeed');
+    var x = 5, feed_client;
+    feed_client = feedname.substr(feedname.length - x, x);
+    Blockly.Arduino.definitions_['mqtt_' + feed_client + ''] = 'Adafruit_MQTT_Subscribe ' + feed_client + '= Adafruit_MQTT_Subscribe(&mqtt,' + feedname + ');';
+    Blockly.Arduino.codeFunctions_['mqtt_' + feed_client + 'callbackFunction'] = `void ` + feed_client + `Callback (double x){
+      Serial.println(x);
+    }`;
+    Blockly.Arduino.setupCode_['mqtt_' + feed_client + '_callback'] = '' + feed_client + '.setCallback(' + feed_client + 'Callback);';
+    Blockly.Arduino.setupCode_['mqtt_' + feed_client + '_subscribe'] = 'mqtt.subscribe(&' + feed_client + ');';
+    Blockly.Arduino.loopCodeOnce_['mqtt_processPackages'] = 'mqtt.processPackets(10);';
+    var code = '';
+    return code;
+};