MQTT for WS2812FX working

[LeonVos]

// MQTT control added to the MC-LIGHTING V2 from Tobias Blum, https://github.com/toblum/McLighting, In this setup
// i only changed this page, You only need to change extra the 'HOST' name on "definitions.h".
// On this page you need to change the:
// MQTTserver IP (now: 192.168.192.53)
// MQTT: user & passw (now: leon & 1122
// SUBscribe topic (now: "ws2812-set/mode") here you can set SPEED, COLOR and MODE
// PUBlish TOPICS ( now: "ws2812-set/state/ws2812-160") here will be feedback for MODE's on your MQTT broker.
// ( all above is random, only my name ;-)
// On "if (mode == OFF)" and "if (mode == ALL)" i have added MQTT control for (all) OFF and (all) ON (static, warm white, brightness 200)
// (because i can't get websocket running, yet, on my Raspberry-Pi Mosquitto (MQTT-broker) i use this from my CCU-2 (Homamatic controller),
// with java scripts control for normal garden lights, i have 10 ws2812 lights in my back garden, each with 2x 26 leds)
//
// For the different MODEs (effects) put/publish : m 0 for static
// m 1 for Blink
// m 2 for Breath etc...
// m 47 for FIRE
// So ALL 47 ws2812FX modes!!
// For ALL colors, just put "c 0xFFFFFF" for white, or any HEX code AFTER c 0x.
// For Brightness, use "b 0" (is off) or "b 255" (is brightesd) or any number in between) 0-255
// for speed, it's the same but then "s 0" (is slow) or "s 255" (is fastest)
//
// on the end the complete list off controls
//
// Good Luck Leon Vos, NL.

#include "definitions.h"

// ***************************************************************************
// Load libraries for: WebServer / WiFiManager / WebSockets /MQTT-broker
// ***************************************************************************
#include <ESP8266WiFi.h> //https://github.com/esp8266/Arduino

// needed for library WiFiManager
#include <DNSServer.h>
#include <ESP8266WebServer.h>
#include <WiFiManager.h> //https://github.com/tzapu/WiFiManager

#include <WiFiClient.h>
#include <ESP8266mDNS.h>
#include <FS.h>
#include <PubSubClient.h>
#include <WebSockets.h> //https://github.com/Links2004/arduinoWebSockets
#include <WebSocketsServer.h>
#include <WS2812FX.h>
WS2812FX strip = WS2812FX(NUMLEDS, PIN, NEO_GRB + NEO_KHZ800);

IPAddress mqttserver(192, 168, 192, 53); // replace this with your MQTT brokers IP

WiFiClient wclient;
PubSubClient client(wclient, mqttserver);

#define BUFFER_SIZE 100

// Start handle MQTT message arrived
void callback(const MQTT::Publish& pub) {
Serial.println(pub.payload_string());
String command = pub.payload_string();

if(command == F("b+")) {
strip.increaseBrightness(25);
Serial.print(F("Increased brightness by 25 to: "));
Serial.println(strip.getBrightness());
}

if(command == F("b-")) {
strip.decreaseBrightness(25);
Serial.print(F("Decreased brightness by 25 to: "));
Serial.println(strip.getBrightness());
}

if(command.startsWith(F("b "))) {
uint8_t b = (uint8_t) command.substring(2, command.length()).toInt();
strip.setBrightness(b);
Serial.print(F("Set brightness to: "));
Serial.println(strip.getBrightness());
}

if(command == F("s+")) {
strip.increaseSpeed(10);
Serial.print(F("Increased speed by 10 to: "));
Serial.println(strip.getSpeed());
}

if(command == F("s-")) {
strip.decreaseSpeed(10);
Serial.print(F("Decreased speed by 10 to: "));
Serial.println(strip.getSpeed());
}

if(command.startsWith(F("s "))) {
uint8_t s = (uint8_t) command.substring(2, command.length()).toInt();
strip.setSpeed(s);
Serial.print(F("Set speed to: "));
Serial.println(strip.getSpeed());
}

if(command.startsWith(F("m "))) {
uint8_t m = (uint8_t) command.substring(2, command.length()).toInt();
strip.setMode(m);
Serial.print(F("Set mode to: "));
Serial.print(strip.getMode());
Serial.print(" - ");
Serial.println(strip.getModeName(strip.getMode()));
client.publish("ws2812-set/state/ws2812-160",strip.getModeName(strip.getMode()));
}

if(command.startsWith(F("c "))) {
uint32_t c = (uint32_t) strtol(&command.substring(2, command.length())[0], NULL,
16);
strip.setColor(c);
Serial.print(F("Set color to: "));
Serial.print(F("0x"));
if(strip.getColor() < 0x100000) { Serial.print(F("0")); }
if(strip.getColor() < 0x010000) { Serial.print(F("0")); }
if(strip.getColor() < 0x001000) { Serial.print(F("0")); }
if(strip.getColor() < 0x000100) { Serial.print(F("0")); }
if(strip.getColor() < 0x000010) { Serial.print(F("0")); }
Serial.println(strip.getColor(), HEX);
}
Serial.println("End of callback");
}
// End handle MQTT message arrived

// OTA
#ifdef ENABLE_OTA
#include <WiFiUdp.h>
#include <ArduinoOTA.h>
#endif

// ***************************************************************************
// Instanciate HTTP(80) / WebSockets(81) Server
// ***************************************************************************
ESP8266WebServer server ( 80 );
WebSocketsServer webSocket = WebSocketsServer(81);

// ***************************************************************************
// Load libraries / Instanciate WS2812FX library
// ***************************************************************************
// https://github.com/kitesurfer1404/WS2812FX

// Parameter 1 = number of pixels in strip
// Parameter 2 = Arduino pin number (most are valid)
// Parameter 3 = pixel type flags, add together as needed:
// NEO_KHZ800 800 KHz bitstream (most NeoPixel products w/WS2812 LEDs)
// NEO_KHZ400 400 KHz (classic 'v1' (not v2) FLORA pixels, WS2811 drivers)
// NEO_GRB Pixels are wired for GRB bitstream (most NeoPixel products)
// NEO_RGB Pixels are wired for RGB bitstream (v1 FLORA pixels, not v2)

// IMPORTANT: To reduce NeoPixel burnout risk, add 1000 uF capacitor across
// pixel power leads, add 300 - 500 Ohm resistor on first pixel's data input
// and minimize distance between Arduino and first pixel. Avoid connecting
// on a live circuit...if you must, connect GND first.

// ***************************************************************************
// Load library "ticker" for blinking status led
// ***************************************************************************
#include <Ticker.h>
Ticker ticker;

void tick()
{
//toggle state
int state = digitalRead(BUILTIN_LED); // get the current state of GPIO1 pin
digitalWrite(BUILTIN_LED, !state); // set pin to the opposite state
}

// ***************************************************************************
// Callback for WiFiManager library when config mode is entered
// ***************************************************************************
//gets called when WiFiManager enters configuration mode
void configModeCallback (WiFiManager *myWiFiManager) {
DBG_OUTPUT_PORT.println("Entered config mode");
DBG_OUTPUT_PORT.println(WiFi.softAPIP());
//if you used auto generated SSID, print it
DBG_OUTPUT_PORT.println(myWiFiManager->getConfigPortalSSID());
//entered config mode, make led toggle faster
ticker.attach(0.2, tick);

uint16_t i;
for (i = 0; i < strip.numPixels(); i++) {
strip.setPixelColor(i, 0, 0, 255);
}
strip.show();
}

// ***************************************************************************
// Include: Webserver
// ***************************************************************************
#include "spiffs_webserver.h"

// ***************************************************************************
// Include: Request handlers
// ***************************************************************************
#include "request_handlers.h"

// ***************************************************************************
// Include: Color modes
// ***************************************************************************
#include "colormodes.h"

// ***************************************************************************
// MAIN
// ***************************************************************************
void setup() {
DBG_OUTPUT_PORT.begin(115200);

// set builtin led pin as output
pinMode(BUILTIN_LED, OUTPUT);
// start ticker with 0.5 because we start in AP mode and try to connect
ticker.attach(0.6, tick);

// ***************************************************************************
// Setup: Neopixel
// ***************************************************************************
strip.init();
strip.setBrightness(brightness);
strip.setSpeed(ws2812fx_speed);
//strip.setMode(FX_MODE_RAINBOW_CYCLE);
strip.start();

// ***************************************************************************
// Setup: WiFiManager
// ***************************************************************************
//Local intialization. Once its business is done, there is no need to keep it around
WiFiManager wifiManager;
//reset settings - for testing
//wifiManager.resetSettings();

//set callback that gets called when connecting to previous WiFi fails, and enters Access Point mode
wifiManager.setAPCallback(configModeCallback);

//fetches ssid and pass and tries to connect
//if it does not connect it starts an access point with the specified name
//here "AutoConnectAP"
//and goes into a blocking loop awaiting configuration
if (!wifiManager.autoConnect()) {
DBG_OUTPUT_PORT.println("failed to connect and hit timeout");
//reset and try again, or maybe put it to deep sleep
ESP.reset();
delay(1000);
}

//if you get here you have connected to the WiFi
DBG_OUTPUT_PORT.println("connected...yeey :)");
ticker.detach();
//keep LED on
digitalWrite(BUILTIN_LED, LOW);

// ***************************************************************************
// Configure OTA
// ***************************************************************************
#ifdef ENABLE_OTA
DBG_OUTPUT_PORT.println("Arduino OTA activated.");

// Port defaults to 8266
ArduinoOTA.setPort(8266);

// Hostname defaults to esp8266-[ChipID]
ArduinoOTA.setHostname(HOSTNAME);

// No authentication by default
 ArduinoOTA.setPassword("admin");

// Password can be set with it's md5 value as well
// MD5(admin) = 21232f297a57a5a743894a0e4a801fc3
//  ArduinoOTA.setPasswordHash("0638737163");

ArduinoOTA.onStart([]() {
  DBG_OUTPUT_PORT.println("Arduino OTA: Start updating");
});
ArduinoOTA.onEnd([]() {
  DBG_OUTPUT_PORT.println("Arduino OTA: End");
});
ArduinoOTA.onProgress([](unsigned int progress, unsigned int total) {
  DBG_OUTPUT_PORT.printf("Arduino OTA Progress: %u%%\r", (progress / (total / 100)));
});
ArduinoOTA.onError([](ota_error_t error) {
  DBG_OUTPUT_PORT.printf("Arduino OTA Error[%u]: ", error);
  if (error == OTA_AUTH_ERROR) DBG_OUTPUT_PORT.println("Arduino OTA: Auth Failed");
  else if (error == OTA_BEGIN_ERROR) DBG_OUTPUT_PORT.println("Arduino OTA: Begin Failed");
  else if (error == OTA_CONNECT_ERROR) DBG_OUTPUT_PORT.println("Arduino OTA: Connect Failed");
  else if (error == OTA_RECEIVE_ERROR) DBG_OUTPUT_PORT.println("Arduino OTA: Receive Failed");
  else if (error == OTA_END_ERROR) DBG_OUTPUT_PORT.println("Arduino OTA: End Failed");
});

ArduinoOTA.begin();
DBG_OUTPUT_PORT.println("");

#endif

// ***************************************************************************
// Setup: MDNS responder
// ***************************************************************************
MDNS.begin(HOSTNAME);
DBG_OUTPUT_PORT.print("Open http://");
DBG_OUTPUT_PORT.print(WiFi.localIP());
DBG_OUTPUT_PORT.println("/ to open McLighting.");

DBG_OUTPUT_PORT.print("Use http://");
DBG_OUTPUT_PORT.print(HOSTNAME);
DBG_OUTPUT_PORT.println(".local/ when you have Bobjour installed.");

DBG_OUTPUT_PORT.print("New users: Open http://");
DBG_OUTPUT_PORT.print(WiFi.localIP());
DBG_OUTPUT_PORT.println("/upload to upload the webpages first.");

DBG_OUTPUT_PORT.println("");

// ***************************************************************************
// Setup: WebSocket server
// ***************************************************************************
webSocket.begin();
webSocket.onEvent(webSocketEvent);

// ***************************************************************************
// Setup: SPIFFS
// ***************************************************************************
SPIFFS.begin();
{
Dir dir = SPIFFS.openDir("/");
while (dir.next()) {
String fileName = dir.fileName();
size_t fileSize = dir.fileSize();
DBG_OUTPUT_PORT.printf("FS File: %s, size: %s\n", fileName.c_str(), formatBytes(fileSize).c_str());
}
DBG_OUTPUT_PORT.printf("\n");
}

// ***************************************************************************
// Setup: SPIFFS Webserver handler
// ***************************************************************************
//list directory
server.on("/list", HTTP_GET, handleFileList);
//load editor
server.on("/edit", HTTP_GET, {
if (!handleFileRead("/edit.htm")) server.send(404, "text/plain", "FileNotFound");
});
//create file
server.on("/edit", HTTP_PUT, handleFileCreate);
//delete file
server.on("/edit", HTTP_DELETE, handleFileDelete);
//first callback is called after the request has ended with all parsed arguments
//second callback handles file uploads at that location
server.on("/edit", HTTP_POST, {
server.send(200, "text/plain", "");
}, handleFileUpload);
//get heap status, analog input value and all GPIO statuses in one json call
server.on("/esp_status", HTTP_GET, {
String json = "{";
json += ""heap":" + String(ESP.getFreeHeap());
json += ", "analog":" + String(analogRead(A0));
json += ", "gpio":" + String((uint32_t)(((GPI | GPO) & 0xFFFF) | ((GP16I & 0x01) << 16)));
json += "}";
server.send(200, "text/json", json);
json = String();
});

//called when the url is not defined here
//use it to load content from SPIFFS
server.onNotFound( {
if (!handleFileRead(server.uri()))
handleNotFound();
});

server.on("/upload", handleMinimalUpload);

server.on("/restart", {
DBG_OUTPUT_PORT.printf("/restart:\n");
server.send(200, "text/plain", "restarting..." );
ESP.restart();
});

server.on("/reset_wlan", {
DBG_OUTPUT_PORT.printf("/reset_wlan:\n");
server.send(200, "text/plain", "Resetting WLAN and restarting..." );
WiFiManager wifiManager;
wifiManager.resetSettings();
ESP.restart();
});

// ***************************************************************************
// Setup: SPIFFS Webserver handler
// ***************************************************************************
server.on("/set_brightness", {
if (server.arg("c").toInt() > 0) {
brightness = (int) server.arg("c").toInt() * 2.55;
} else {
brightness = server.arg("p").toInt();
}
if (brightness > 255) {
brightness = 255;
}
if (brightness < 0) {
brightness = 0;
}
strip.setBrightness(brightness);

if (mode == HOLD) {
  mode = ALL;
}

getStatusJSON();

});

server.on("/get_brightness", {
String str_brightness = String((int) (brightness / 2.55));
server.send(200, "text/plain", str_brightness );
DBG_OUTPUT_PORT.print("/get_brightness: ");
DBG_OUTPUT_PORT.println(str_brightness);
});

server.on("/get_switch", {
server.send(200, "text/plain", (mode == OFF) ? "0" : "1" );
DBG_OUTPUT_PORT.printf("/get_switch: %s\n", (mode == OFF) ? "0" : "1");
});

server.on("/get_color", {
String rgbcolor = String(main_color.red, HEX) + String(main_color.green, HEX) + String(main_color.blue, HEX);
server.send(200, "text/plain", rgbcolor );
DBG_OUTPUT_PORT.print("/get_color: ");
DBG_OUTPUT_PORT.println(rgbcolor);
});

server.on("/status", {
getStatusJSON();
});

server.on("/off", {
exit_func = true;
mode = OFF;
getArgs();
getStatusJSON();
});

server.on("/all", {
exit_func = true;
mode = ALL;
getArgs();
getStatusJSON();
});

server.on("/wipe", {
exit_func = true;
mode = WIPE;
getArgs();
getStatusJSON();
});

server.on("/rainbow", {
exit_func = true;
mode = RAINBOW;

getArgs();
getStatusJSON();

});

server.on("/rainbowCycle", {
exit_func = true;
mode = RAINBOWCYCLE;
getArgs();
getStatusJSON();
});

server.on("/theaterchase", {
exit_func = true;
mode = THEATERCHASE;
getArgs();
getStatusJSON();
});

server.on("/theaterchaseRainbow", {
exit_func = true;
mode = THEATERCHASERAINBOW;
getArgs();
getStatusJSON();
});

server.on("/tv", {
exit_func = true;
mode = TV;
getArgs();
getStatusJSON();
});

server.on("/get_modes", {
getModesJSON();
});

server.on("/set_mode", {
getArgs();
mode = SET_MODE;
getStatusJSON();
});

server.begin();
}

void loop() {
server.handleClient();
webSocket.loop();
#ifdef ENABLE_OTA
ArduinoOTA.handle();
#endif

// Simple statemachine that handles the different modes
if (mode == SET_MODE) {
DBG_OUTPUT_PORT.printf("SET_MODE: %d %d\n", ws2812fx_mode, mode);
strip.setMode(ws2812fx_mode);
mode = HOLD;
}
if (mode == OFF) {
strip.setColor(0,0,0);
strip.setMode(FX_MODE_STATIC);
// mode = HOLD;
client.publish("ws2812-set/mode","b 0"); // Change this, or //, if you DON"T need this for daily websocket control
}

if (mode == ALL) {
strip.setColor(main_color.red, main_color.green, main_color.blue);
strip.setMode(FX_MODE_STATIC);
mode = HOLD;
//Change this if you DON'T use DAILY websocket control
client.publish("ws2812-set/mode","b 200"); // Brightness 200, ALL subscribed lights will be set.
delay(1500);
client.publish("ws2812-set/mode","m 0"); // MODE static, ALL subscribed lights will be set.
delay(1500);
client.publish("ws2812-set/mode","c 0xFFFF40"); // Color WarmWhite, ALL subscribed lights will be set.
}
if (mode == WIPE) {
strip.setColor(main_color.red, main_color.green, main_color.blue);
strip.setMode(FX_MODE_COLOR_WIPE);
mode = HOLD;
}
if (mode == RAINBOW) {
strip.setMode(FX_MODE_RAINBOW);
mode = HOLD;
}
if (mode == RAINBOWCYCLE) {
strip.setMode(FX_MODE_RAINBOW_CYCLE);
mode = HOLD;
}
if (mode == THEATERCHASE) {
strip.setColor(main_color.red, main_color.green, main_color.blue);
strip.setMode(FX_MODE_THEATER_CHASE);
mode = HOLD;
}
if (mode == THEATERCHASERAINBOW) {
strip.setMode(FX_MODE_THEATER_CHASE_RAINBOW);
mode = HOLD;
}
if (mode == HOLD) {
if (exit_func) {
exit_func = false;
}
}
if (mode == TV) {
tv();
}

if (mode != TV) {
strip.service();
}
if (WiFi.status() == WL_CONNECTED) {
if (!client.connected()) {
Serial.println("Connecting to MQTT server");
if (client.connect(MQTT::Connect("ws2812fx-160")
.set_auth("leon", "1122"))) { // Change this to yours, or remove when not needed
Serial.println("Connected to MQTT server");
client.set_callback(callback);
client.publish("ws2812-set/state/ws2812-160","160 MC-Lighting Online");
client.subscribe("ws2812-set/mode");
} else {
Serial.println("MQTT error connecting");
}
}

if (client.connected())
  client.loop();

}
}
/*
Usage:

m : select mode , "m 8" runs Rainbow (without " " ;-)

b+ : increase brightness
b- : decrease brightness
b : set brightness to , "b 255" sets max brightness (without " " ;-)

s+ : increase speed
s- : decrease speed
s : set speed to , "s 255" sets max speed (without " " ;-)

c 0x007BFF : set color to 0x007BFF, "c 0xFFFFFF" sets color to white (without " " ;-)

Have a nice day.

0 Static
1 Blink
2 Breath
3 Color Wipe
4 Color Wipe Random
5 Random Color
6 Single Dynamic
7 Multi Dynamic
8 Rainbow
9 Rainbow Cycle
10 Scan
11 Dual Scan
12 Fade
13 Theater Chase
14 Theater Chase Rainbow
15 Running Lights
16 Twinkle
17 Twinkle Random
18 Twinkle Fade
19 Twinkle Fade Random
20 Sparkle
21 Flash Sparkle
22 Hyper Sparkle
23 Strobe
24 Strobe Rainbow
25 Multi Strobe
26 Blink Rainbow
27 Chase White
28 Chase Color
29 Chase Random
30 Chase Rainbow
31 Chase Flash
32 Chase Flash Random
33 Chase Rainbow White
34 Chase Blackout
35 Chase Blackout Rainbow
36 Color Sweep Random
37 Running Color
38 Running Red Blue
39 Running Random
40 Larson Scanner
41 Comet
42 Fireworks
43 Fireworks Random
44 Merry Christmas
45 Fire Flicker
46 Fire Flicker (soft)

*/

[marksev1]

Could you integrate that into the main sketch so that we have all the features at once? :)

[LeonVos]

I am working on that. (but time is the problem, be patient)

[toblum]

Hi @LeonVos,

this is great, I also experimented with that some weeks ago, but did not find any time to dig deeper.

I had a problem to make PubSubClient and WiFiManger work together. This is a known issue: tzapu/WiFiManager#15

I had some progres with https://github.com/btomer/WiFiManager which is a fork of WiFiManger, but this may ba a bad option, as this is not regularly updated.

Regards
Tobias

[LeonVos]

@toblum,
MQTT finished !!
Works great, i did not find any issue with the other clients/servers, everything works like a ...... ;-)
I only did not test OTA yet.
When you like it (too) you can ADD this to your MC Lighting (V3 ?) ;-)

Regards Leon Vos

[marksev1]

So its updated in the first post right? Can we see it on your github too?

[LeonVos]

Hi, becauce it's a addon on MClighting, i want to keep it here.
I have update the above, just kopie and past it over the main MCLichting sketch page, and make your needed changes on it.
Leon Vos.

[toblum]

Hi @LeonVos,
These are great news. I will put your code in a new branch. There we can do some tests before we replace the master branch.
Regards
Tobias

[drschnalli]

No matter what i do... i cannot compile the mqtt branch :(

McLighting.ino: In function 'void setup()': McLighting:354: error: expected '}' before ';' token McLighting:354: error: expected ')' before ';' token McLighting.ino: At global scope: McLighting:355: error: mixing declarations and function-definitions is forbidden McLighting:355: error: expected initializer before ')' token McLighting:357: error: 'server' does not name a type McLighting:365: error: expected unqualified-id before ')' token McLighting:369: error: 'server' does not name a type McLighting:372: error: expected unqualified-id before ')' token McLighting:374: error: 'server' does not name a type McLighting:376: error: 'server' does not name a type McLighting:380: error: expected unqualified-id before ')' token McLighting:382: error: 'server' does not name a type McLighting:388: error: expected unqualified-id before ')' token McLighting:393: error: 'server' does not name a type McLighting:412: error: expected unqualified-id before ')' token McLighting:414: error: 'server' does not name a type McLighting:419: error: expected unqualified-id before ')' token McLighting:421: error: 'server' does not name a type McLighting:424: error: expected unqualified-id before ')' token McLighting:426: error: 'server' does not name a type McLighting:431: error: expected unqualified-id before ')' token McLighting:433: error: 'server' does not name a type McLighting:435: error: expected unqualified-id before ')' token McLighting:437: error: 'server' does not name a type McLighting:442: error: expected unqualified-id before ')' token McLighting:444: error: 'server' does not name a type McLighting:449: error: expected unqualified-id before ')' token McLighting:451: error: 'server' does not name a type McLighting:456: error: expected unqualified-id before ')' token McLighting:458: error: 'server' does not name a type McLighting:464: error: expected unqualified-id before ')' token McLighting:466: error: 'server' does not name a type McLighting:471: error: expected unqualified-id before ')' token McLighting:473: error: 'server' does not name a type McLighting:478: error: expected unqualified-id before ')' token McLighting:480: error: 'server' does not name a type McLighting:485: error: expected unqualified-id before ')' token McLighting:487: error: 'server' does not name a type McLighting:492: error: expected unqualified-id before ')' token McLighting:494: error: 'server' does not name a type McLighting:496: error: expected unqualified-id before ')' token McLighting:498: error: 'server' does not name a type McLighting:502: error: expected unqualified-id before ')' token McLighting:504: error: 'server' does not name a type McLighting:505: error: expected declaration before '}' token expected '}' before ';' token

[LeonVos]

Hhhmmm i see alot of missing }}}}}}}} errors , i think you copied wrong. This week i try to place it on a "new" github, with (and thats importend too) to correct pubsubclient.h. A link will be put here.

[drschnalli]

I was a bit confused as i just downloaded the complete zip package of the mqtt branch. I was using Arduino 1.8.x for Windows and i didnt change the libraries with which i could compile the master branch (successfully) before. So i dont know what i'm doing wrong... i think youre using a special PubSubClient or Wifimanager or some other library :(... i even tried another Arduino IDE (1.6.5) which gave me the same error messages :(

[toblum]

@ALL:
I also did not manage to get the above code to work. Maybe problems when I copied the text.

In the meantime I got my initial MQTT implementation also running. I created a new branch "mclighting_mqtt_pubsub". My implementation uses the same codes as the websockets protocol, so no changes here.
The MQTT credentials can be configured via the WiFiManager.

Maybe you all can have a look at it and maybe it's a good idea to merge it with LeonVos code. What do you think @LeonVos ?

[toblum]

I will close this issue now just to cleanup a bit.

Tobias