I would like to post my code here, but it´s actually not my code but the code from this website:
link
I am trying to make it MySensors MQTT Gateway compatible and I am not making any progress right now and need you help. First of all I would like to post the original arduino code from the above mentioned website:
#include <SPI.h>
#include <Ethernet.h>
#include <PubSubClient.h> // http://knolleary.net/arduino-client-for-mqtt/
// MAC Adresse des Ethernet Shields
byte mac[] = { 0xDE, 0xED, 0xBA, 0xFE, 0xFE, 0xED };
// IP des MQTT Servers
byte server[] = { 192, 168, 2, 9 };
// Ethernet Client zur Kommunikation des MQTT Clients
EthernetClient ethClient;
// MQTT Client zur Kommunikation mit dem Server
// Server - Variable des Types byte mit Serveradresse
// 1883 - Ist der Standard TCP Port
// callback - Function wird aufgerufen wen MQTT Nachrichten eintreffen. Am ende des Sketches
// ethClient - Angabe des Ethernet Clients
PubSubClient mqttClient(server, 1883, callback, ethClient);
// Timervariable für eine Verzögerung. Als alternative zu delay was die verarbeitung anhält.
int timer = 0;
int EndTimer = 200;
// Pins des RGB LED Strip
int LEDred=5;
int LEDgreen=6;
int LEDblue=3;
// Übermittelte Farbwerte
int LEDredValue = 0;
int LEDgreenValue = 0;
int LEDblueValue = 0;
// Gerade gesetzte Farbe
int CURredValue = 0;
int CURgreenValue = 0;
int CURblueValue = 0;
void setup()
{
// Setzen der PINS als Ausgang
pinMode(LEDblue, OUTPUT);
pinMode(LEDred, OUTPUT);
pinMode(LEDgreen, OUTPUT);
// Bei start Farbe Blau setzen
analogWrite(LEDred, 0);
analogWrite(LEDgreen, 0);
analogWrite(LEDblue, 100);
// Initialisierung des Ethernets
if (Ethernet.begin(mac) == 0) {
// Wenn DHCP fehlschlägt dann rot setzen und aufhören
analogWrite(LEDred, 100);
analogWrite(LEDgreen, 0);
analogWrite(LEDblue, 0);
while (true);
}
else {
// Wenn DHCP OK ist dann grün setzen
LEDgreenValue = 100;
}
}
void loop()
{
// Aufbau der Verbindung mit MQTT falls diese nicht offen ist.
if (!mqttClient.connected()) {
mqttClient.connect("arduinoClient");
// Abonieren von Nachrichten mit dem angegebenen Topics
mqttClient.subscribe("/openHAB/Nachtlicht/RED/#");
mqttClient.subscribe("/openHAB/Nachtlicht/GREEN/#");
mqttClient.subscribe("/openHAB/Nachtlicht/BLUE/#");
// Alternative Abonierung aller Topics unter /openHAB/Nachtlicht
// mqttClient.subscribe("/openHAB/Nachtlicht/#");
}
if (timer <= EndTimer) timer++;
else {
timer = 0;
if (LEDredValue < CURredValue) CURredValue--;
else if (LEDredValue > CURredValue) CURredValue++;
if (LEDgreenValue < CURgreenValue) CURgreenValue--;
else if (LEDgreenValue > CURgreenValue) CURgreenValue++;
if (LEDblueValue < CURblueValue) CURblueValue--;
else if (LEDblueValue > CURblueValue) CURblueValue++;
}
analogWrite(LEDred, CURredValue);
analogWrite(LEDgreen, CURgreenValue);
analogWrite(LEDblue, CURblueValue);
mqttClient.loop(); // Schleife für MQTT
}
// ===========================================================
// Callback Funktion von MQTT. Die Funktion wird aufgerufen
// wenn ein Wert empfangen wurde.
// ===========================================================
void callback(char* topic, byte* payload, unsigned int length) {
// Zähler
int i = 0;
// Hilfsvariablen für die Convertierung der Nachricht in ein String
char message_buff[100];
// Kopieren der Nachricht und erstellen eines Bytes mit abschließender \0
for(i=0; i<length; i++) {
message_buff[i] = payload[i];
}
message_buff[i] = '\0';
// Konvertierung der nachricht in ein String
String msgString = String(message_buff);
// Überprüfung des Topis und setzen der Farbe je nach übermittelten Topic
if (String(topic) == "/openHAB/Nachtlicht/RED") LEDredValue = round(msgString.toInt() * 2.55);
if (String(topic) == "/openHAB/Nachtlicht/GREEN") LEDgreenValue = round(msgString.toInt() * 2.55);
if (String(topic) == "/openHAB/Nachtlicht/BLUE") LEDblueValue = round(msgString.toInt() * 2.55);
}
and here follows my "modified" part. I hope you guys can support me here!
#include <MySensor.h>
#include <SPI.h>
// Timervariable für eine Verzögerung. Als alternative zu delay was die verarbeitung anhält.
int timer = 0;
int EndTimer = 200;
// Pins des RGB LED Strip
int LEDred=3;
int LEDgreen=4;
int LEDblue=2;
// Übermittelte Farbwerte
int LEDredValue = 0;
int LEDgreenValue = 0;
int LEDblueValue = 0;
// Gerade gesetzte Farbe
int CURredValue = 0;
int CURgreenValue = 0;
int CURblueValue = 0;
MySensor gw;
MyMessage dimmerMsg(21, V_DIMMER); //21=Sensor ID 21, Dimmer; An/Aus
MyMessage lightMsgR(22, V_LIGHT); //21=Sensor ID 21, Rot
MyMessage lightMsgG(23, V_LIGHT); //21=Sensor ID 21, Grün
MyMessage lightMsgB(24, V_LIGHT); //21=Sensor ID 21, Blau
void setup()
{
//MySensors Library initialisieren
gw.begin();
//Sensor ID und Typ übermitteln
gw.present(21, S_DIMMER);
gw.present(22, V_LIGHT);
gw.present(23, V_LIGHT);
gw.present(24, V_LIGHT);
// Setzen der PINS als Ausgang
pinMode(LEDblue, OUTPUT);
pinMode(LEDred, OUTPUT);
pinMode(LEDgreen, OUTPUT);
// Bei start Farbe Blau setzen
analogWrite(LEDred, 0);
analogWrite(LEDgreen, 0);
analogWrite(LEDblue, 100);
}
void loop()
{
// Abonieren von Nachrichten mit dem angegebenen Topics
mqttClient.subscribe("/openHAB/Nachtlicht/RED/#");
mqttClient.subscribe("/openHAB/Nachtlicht/GREEN/#");
mqttClient.subscribe("/openHAB/Nachtlicht/BLUE/#");
}
if (timer <= EndTimer) timer++;
else {
timer = 0;
if (LEDredValue < CURredValue) CURredValue--;
else if (LEDredValue > CURredValue) CURredValue++;
if (LEDgreenValue < CURgreenValue) CURgreenValue--;
else if (LEDgreenValue > CURgreenValue) CURgreenValue++;
if (LEDblueValue < CURblueValue) CURblueValue--;
else if (LEDblueValue > CURblueValue) CURblueValue++;
}
analogWrite(LEDred, CURredValue);
analogWrite(LEDgreen, CURgreenValue);
analogWrite(LEDblue, CURblueValue);
mqttClient.loop(); // Schleife für MQTT
}
// ===========================================================
// Callback Funktion von MQTT. Die Funktion wird aufgerufen
// wenn ein Wert empfangen wurde.
// ===========================================================
void callback(char* topic, byte* payload, unsigned int length) {
// Zähler
int i = 0;
// Hilfsvariablen für die Convertierung der Nachricht in ein String
char message_buff[100];
// Kopieren der Nachricht und erstellen eines Bytes mit abschließender \0
for(i=0; i<length; i++) {
message_buff[i] = payload[i];
}
message_buff[i] = '\0';
// Konvertierung der nachricht in ein String
String msgString = String(message_buff);
// Überprüfung des Topis und setzen der Farbe je nach übermittelten Topic
if (String(topic) == "/openHAB/Nachtlicht/RED") LEDredValue = round(msgString.toInt() * 2.55);
if (String(topic) == "/openHAB/Nachtlicht/GREEN") LEDgreenValue = round(msgString.toInt() * 2.55);
if (String(topic) == "/openHAB/Nachtlicht/BLUE") LEDblueValue = round(msgString.toInt() * 2.55);
}
I added LED Red, Green and Blue and set child ID´s to 22,23 and 24, 21 is for Dimmer. I have no idea if this done the right way
MyMessage dimmerMsg(21, V_DIMMER); //21=Sensor ID 21, Dimmer; An/Aus
MyMessage lightMsgR(22, V_LIGHT); //21=Sensor ID 21, Rot
MyMessage lightMsgG(23, V_LIGHT); //21=Sensor ID 21, Grün
MyMessage lightMsgB(24, V_LIGHT); //21=Sensor ID 21, Blau
especially the following part is a big problem to me because I don´t know how to "subscribe" with the MySensors MQTT library:
void loop()
{
// Abonieren von Nachrichten mit dem angegebenen Topics
mqttClient.subscribe("/openHAB/Nachtlicht/RED/#");
mqttClient.subscribe("/openHAB/Nachtlicht/GREEN/#");
mqttClient.subscribe("/openHAB/Nachtlicht/BLUE/#");
}
how must I modify this??
