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 //https://github.com/esp8266/Arduino

// needed for library WiFiManager

include

include

include //https://github.com/tzapu/WiFiManager

include

include

include

include

include //https://github.com/Links2004/arduinoWebSockets

include

include

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

include

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 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: https://github.com/tzapu/WiFiManager/issues/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