Salve la mia è una domanda semplice almeno a parole (ho il codice scritto che vi giro sotto) ma non riesco a far attivare la callback() nonostante i comandi destra e sinistra dovrebbero triggerarsi; ora forse è colpa mia che ho mal impostato mosquitto?? sto usando homeassistant con sopra mosquitto e Node Red; il debug funziona, stavo provando con MQTT explorer e quello fornito nel menù di MQTT su Home Assistant ed effettivamente posso pubblicare messaggi e leggerli da una finestra piuttosto che l'altra.
Il mio codice:
//Librerie ESP
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
#include <Wire.h>
#include <Adafruit_NeoPixel.h>
/************* IMPOSTAZIONI PIN e VARIABILI **************************/
const uint16_t NUM_LEDS = 20;
const uint8_t PixelPin = 12;
Adafruit_NeoPixel neopixel(NUM_LEDS, PixelPin, NEO_GRB + NEO_KHZ800);
//WiFi
const char* ssid = "EX-TpLink";
const char* password = "xyz";
IPAddress local_IP(192, 168, 1, 61);
IPAddress gateway(192, 168, 1, 1);
IPAddress subnet(255, 255, 0, 0);
//MQTT
const char* mqttServer = "192.168.1.57";
const char* mqttUser = "mqttb";
const char* mqttPassword = "xyz";
const int mqttPort = 1883;
const char *TOPIC ="Casa/LEDW2812B";
WiFiClient espClient;
PubSubClient client(espClient);
/************************FUNZIONE CALLBACK*****************************/
void callback(char* topic, byte* payload, unsigned int length) {
/*Serial.print("Message arrived [");
Serial.print(topic);
Serial.print("] ");
for (int i = 0; i < length; i++) {
Serial.print((char)payload[i]);
}
Serial.println();
payload[length] = '\0'; // Null terminator used to terminate the char array
String message = (char*)payload;
client.publish("TOPIC","CALLBACK IS WORKING");*/
String message;
for (int i =0; i<length; i++){
message += (char)payload[i];
}
if(strcmp(Topic, "LEDW2812B") == 0){
if(message == "UP"){
client.publish("TOPIC", "RICEVUTO"); //tipo, va cambiato il for correttamente
}
if(message == "DOWN"){
client.publish("TOPIC", "RICEVUTO"); //tipo, va cambiato il for correttamente
}
if(message == "LEFT"){
client.publish("TOPIC", "RICEVUTO"); //tipo, va cambiato il for correttamente
Serial.println("RICEVUTO");
sinistra();
}
if(message == "RIGHT"){
client.publish("TOPIC", "RICEVUTO"); //tipo, va cambiato il for correttamente
destra();
}
}
}
/********************** SETUP WS2812B *************************/
void setup() {
Serial.begin(115200);
while (!Serial); // wait for serial
Serial.println();
Serial.println("Sto inizializando...");
Serial.flush();
neopixel.begin();
neopixel.clear();
for (int i = 0; i <= NUM_LEDS-1; i++) {
neopixel.setPixelColor(i, neopixel.Color(0, 0, 0));
neopixel.show();
delay(100);
}
/****************SETUP WI-Fi e MQTT ***********************/
// Configures static IP address
if (!WiFi.config(local_IP, gateway, subnet)) {
Serial.println("STA Failed to configure");
}
// Connect to Wi-Fi network with SSID and password
Serial.print("Connecting to ");
Serial.println(ssid);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
// Print local IP address
Serial.println("");
Serial.println("WiFi connected.");
Serial.print("IP address: ");
Serial.println(WiFi.localIP());
//MQTT
client.setServer(mqttServer, mqttPort);
client.setCallback(callback);
while (!client.connected()) {
Serial.println("Connecting to MQTT...");
if (client.connect("ESP8266ClientSUB", mqttUser, mqttPassword )) {
Serial.println("connected");
} else {
Serial.println("failed with state ");
Serial.println(client.state());
delay(2000);
}
}
}
/**********************MAIN LOOP *********************/
void loop() {
client.loop();
}
/*********************FUNZIONI LED ********************/
void destra(){
for (int i = 0; i <= NUM_LEDS-1; i++) {
neopixel.setPixelColor(i, neopixel.Color(0, 0, 0));
neopixel.show();
delay(10);
}
for (int i = 0; i <= NUM_LEDS-1; i++) {
neopixel.setPixelColor(i, neopixel.Color(100, 255, 255));
neopixel.show();
delay(200);
}
}
void sinistra(){
for (int i = NUM_LEDS-1; i >= NUM_LEDS-1; i--) {
neopixel.setPixelColor(i, neopixel.Color(0, 0, 0));
neopixel.show();
delay(10);
}
for (int i = NUM_LEDS-1; i >= NUM_LEDS-1; i--) {
neopixel.setPixelColor(i, neopixel.Color(100, 255, 255));
neopixel.show();
delay(200);
}
}