debut d'utilisation d'un topic de retour

This commit is contained in:
Julien Cabillot 2017-03-04 01:14:26 +01:00 committed by Cabillot Julien
parent a73c5f7eb5
commit d6a0afae79

View File

@ -10,6 +10,7 @@ int color = LED_COLOR_DEFAULT;
int speed = LED_SPEED_DEFAULT; int speed = LED_SPEED_DEFAULT;
CRGB leds[LED_NUM]; CRGB leds[LED_NUM];
int ledEffect = LED_EFFECT_OFF; int ledEffect = LED_EFFECT_OFF;
boolean ledState = false;
// WIFI // WIFI
WiFiClient espClient; WiFiClient espClient;
@ -18,7 +19,8 @@ WiFiClient espClient;
char message_buff[100]; char message_buff[100];
PubSubClient client(espClient); PubSubClient client(espClient);
void setup() { void setup()
{
Serial.begin(SERIAL_SPEED); Serial.begin(SERIAL_SPEED);
Serial.println("\nresetting"); Serial.println("\nresetting");
@ -29,19 +31,20 @@ void setup() {
client.setServer(MQTT_SERVER, MQTT_PORT); client.setServer(MQTT_SERVER, MQTT_PORT);
client.setCallback(callbackMQTT); client.setCallback(callbackMQTT);
testConnectMQTT(); testConnectMQTT();
client.subscribe(MQTT_LED_EFFECT); client.subscribe(MQTT_LED_EFFECT_COMMAND);
client.subscribe(MQTT_LED_BRIGHTNESS); client.subscribe(MQTT_LED_BRIGHTNESS_COMMAND);
client.subscribe(MQTT_LED_COLOR); client.subscribe(MQTT_LED_COLOR_COMMAND);
client.subscribe(MQTT_LED_SPEED); client.subscribe(MQTT_LED_SPEED_COMMAND);
// LED // LED
LEDS.addLeds<LED_CHIPSET,LED_PIN, LED_COLOR_ORDER>(leds, LED_NUM).setCorrection(TypicalSMD5050); LEDS.addLeds<LED_CHIPSET,LED_PIN, LED_COLOR_ORDER>(leds, LED_NUM).setCorrection(TypicalSMD5050);
FastLED.setBrightness(brightness);
ledBlackAll(); ledBlackAll();
FastLED.setBrightness(brightness);
} }
// WIFI // WIFI
void setupWifi() { void setupWifi()
{
Serial.print("Connexion a "); Serial.print("Connexion a ");
Serial.print(WIFI_SSID); Serial.print(WIFI_SSID);
WiFi.mode(WIFI_STA); WiFi.mode(WIFI_STA);
@ -58,7 +61,8 @@ void setupWifi() {
} }
// MQTT // MQTT
void testConnectMQTT() { void testConnectMQTT()
{
while (!client.connected()) { while (!client.connected()) {
Serial.print("Connexion au serveur MQTT... "); Serial.print("Connexion au serveur MQTT... ");
if (client.connect("ESP8266Client", MQTT_USER, MQTT_PASS)) { if (client.connect("ESP8266Client", MQTT_USER, MQTT_PASS)) {
@ -74,54 +78,44 @@ void testConnectMQTT() {
} }
// Déclenche les actions à la réception d'un message // Déclenche les actions à la réception d'un message
void callbackMQTT(char* topic, byte* payload, unsigned int length) { void callbackMQTT(char* topic, byte* payload, unsigned int length)
if (String(topic) == MQTT_LED_EFFECT) { {
Serial.print("Received [" + String(topic) + "] : "); String stopic = String(topic);
Serial.print(payload[0]); unsigned int i = 0;
Serial.print(" ~ "); for(i = 0; i < length; i++) {
Serial.print(payload[0] - '0'); message_buff[i] = payload[i];
}
message_buff[i] = '\0';
String msgString = String(message_buff);
ledEffect = payload[0] - '0'; Serial.print("Received [" + stopic + "] : ");
Serial.print("["); Serial.println(msgString);
Serial.print(ledEffect);
Serial.println("]");
if (stopic == MQTT_LED_COMMAND) {
if (msgString == "ON") {
ledState = true;
client.publish(MQTT_LED_STATE, message_buff, true);
} else {
ledState = false;
client.publish(MQTT_LED_STATE, message_buff, true);
}
} else if (stopic == MQTT_LED_EFFECT_COMMAND) {
// Si on ne repasse pas tout à noir, cela peut faire des effets surprenants // Si on ne repasse pas tout à noir, cela peut faire des effets surprenants
ledBlackAll(); ledBlackAll();
} else if (String(topic) == MQTT_LED_BRIGHTNESS) { ledEffect = msgString.toInt();
unsigned int i = 0; // TODO : a vraiment tester
for(i = 0; i < length; i++) { client.publish(MQTT_LED_EFFECT_STATE, message_buff, true);
message_buff[i] = payload[i]; } else if (stopic == MQTT_LED_BRIGHTNESS_COMMAND) {
}
message_buff[i] = '\0';
// TODO : il est surement possible de faire plus propre
String msgString = String(message_buff);
brightness = msgString.toInt(); brightness = msgString.toInt();
FastLED.setBrightness(brightness); FastLED.setBrightness(brightness);
client.publish(MQTT_LED_BRIGHTNESS_STATE, message_buff, true);
Serial.print("Received [" + String(topic) + "] : "); } else if (stopic == MQTT_LED_COLOR_COMMAND) {
Serial.println(msgString);
} else if (String(topic) == MQTT_LED_COLOR) {
unsigned int i = 0;
for(i = 0; i < length; i++) {
message_buff[i] = payload[i];
}
message_buff[i] = '\0';
String msgString = String(message_buff);
color = msgString.toInt(); color = msgString.toInt();
Serial.print("Received [" + String(topic) + "] : "); client.publish(MQTT_LED_COLOR_STATE, message_buff, true);
Serial.println(msgString); } else if (stopic == MQTT_LED_SPEED_COMMAND) {
} else if (String(topic) == MQTT_LED_SPEED) {
unsigned int i = 0;
for(i = 0; i < length; i++) {
message_buff[i] = payload[i];
}
message_buff[i] = '\0';
String msgString = String(message_buff);
speed = msgString.toInt(); speed = msgString.toInt();
Serial.print("Received [" + String(topic) + "] : "); client.publish(MQTT_LED_SPEED_STATE, message_buff, true);
Serial.println(msgString);
} }
} }
@ -196,30 +190,33 @@ void loop() {
testConnectMQTT(); testConnectMQTT();
client.loop(); client.loop();
// TODO : à retirer je pense
EVERY_N_SECONDS(180) { EVERY_N_SECONDS(180) {
Serial.print("MQTT Subscribe refresh"); Serial.print("MQTT Subscribe refresh");
client.subscribe(MQTT_LED_EFFECT); client.subscribe(MQTT_LED_EFFECT_COMMAND);
client.subscribe(MQTT_LED_BRIGHTNESS); client.subscribe(MQTT_LED_BRIGHTNESS_COMMAND);
client.subscribe(MQTT_LED_COLOR); client.subscribe(MQTT_LED_COLOR_COMMAND);
client.subscribe(MQTT_LED_SPEED); client.subscribe(MQTT_LED_SPEED_COMMAND);
Serial.println(" done"); Serial.println(" done");
} }
// LED // LED
switch(ledEffect) if (!ledState) {
{ ledBlackAll();
case LED_EFFECT_OFF: FastLED.delay(1000);
ledBlackAll(); } else {
break; switch(ledEffect)
case LED_EFFECT_CYLON: {
ledCylon(); case LED_EFFECT_CYLON:
break; ledCylon();
case LED_EFFECT_FULLRED: break;
ledFullRed(); case LED_EFFECT_FULLRED:
break; ledFullRed();
default: break;
ledError(); default:
break; ledError();
break;
}
} }
} }