chriz/OpenMQTT-Gateway
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 5 Wiki Activity

OpenMQTTGateway refactoring of 433toMQTTto433 and 433nIRtoMQTTtoIRn433

Browse Source
This commit is contained in:
1technophile committed 2017-02-22 20:34:16 +01:00
1 parent 2f263068e6
commit d70875c13d
5 files changed
+329 -833
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

OpenMQTTGateway.ino
+162 -195
View File
@@ -1,7 +1,6 @@
/* /*
OpenMQTTGateway - ESP8266 or Arduino program for home automation OpenMQTTGateway - ESP8266 or Arduino program for home automation
Tested OK on GeekCreek ESP12F and Arduino Uno + W5100
Not working on NodeMCU V0.9
Act as a wifi or ethernet gateway between your 433mhz/infrared IR signal and a MQTT broker Act as a wifi or ethernet gateway between your 433mhz/infrared IR signal and a MQTT broker
Send and receiving command by MQTT Send and receiving command by MQTT
@@ -11,20 +10,15 @@
- receive MQTT data from a topic and send IR signal corresponding to the received MQTT data - receive MQTT data from a topic and send IR signal corresponding to the received MQTT data
- publish MQTT data to a different topic related to received IR signal - publish MQTT data to a different topic related to received IR signal
Copyright: (c)1technophile
Contributors: Contributors:
- 1technophile - 1technophile
- crankyoldgit - crankyoldgit
- Spudtater
Based on: IMPORTANT NOTE: On arduino UNO connect IR emitter pin to D9 , comment #define IR_USE_TIMER2 and uncomment #define IR_USE_TIMER1 on library <library>IRremote/IRremoteInt.h so as to free pin D3 for RF RECEIVER PIN
- MQTT library (https://github.com/knolleary)
- RCSwitch (https://github.com/sui77/rc-switch)
- Ethernet
- IRRemote
- ESP8266Wifi
- IRremoteESP8266 (https://github.com/markszabo/IRremoteESP8266)
Project home:
Blog, tutorial:
Permission is hereby granted, free of charge, to any person obtaining a copy of this software Permission is hereby granted, free of charge, to any person obtaining a copy of this software
and associated documentation files (the "Software"), to deal in the Software without restriction, and associated documentation files (the "Software"), to deal in the Software without restriction,
including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense,
@@ -35,96 +29,63 @@ THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLI
TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF
CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
Some usefull commands to test gateway with mosquitto:
Subscribe to the subject for data receiption from RF signal
mosquitto_sub -t home/433toMQTT
Send data by MQTT to convert it on RF signal
mosquitto_pub -t home/MQTTto433/ -m 1315153
*/ */
#ifdef ESP8266 #include "User_config.h"
#include <IRremoteESP8266.h>
#include <ESP8266WiFi.h>
#else
#include <IRremote.h>
#include <Ethernet.h>
#endif
#include <PubSubClient.h> #include <PubSubClient.h>
#include <RCSwitch.h> // library for controling Radio frequency switch #include <RCSwitch.h> // library for controling Radio frequency switch
RCSwitch mySwitch = RCSwitch(); // array to store previous received RFs, IRs codes and their timestamps
unsigned long ReceivedSignal[10][2] ={{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0}};
/*------------------------------------------------------------------------*/
IRrecv irrecv(2); //adding this to bypass the problem of the arduino builder issue 50
IRsend irsend(14);
decode_results results;
//Do we want to see trace for debugging purposes
#define TRACE 1 // 0= trace off 1 = trace on
//adding this to bypass to problem of the arduino builder issue 50
void callback(char*topic, byte* payload,unsigned int length); void callback(char*topic, byte* payload,unsigned int length);
// Update these with values suitable for your network. RCSwitch mySwitch = RCSwitch();
#ifdef ESP8266 #ifdef ESP8266
#define wifi_ssid "ssid" #include <IRremoteESP8266.h>
#define wifi_password "password" #include <ESP8266WiFi.h>
IRrecv irrecv(IR_RECEIVER_PIN);
IRsend irsend(IR_EMITTER_PIN);
WiFiClient eClient; WiFiClient eClient;
#else #else
byte mac[] = { 0xDE, 0xED, 0xBA, 0xFE, 0x34, 0x99 }; //W5100 ethernet shield mac adress #include <IRremote.h>
byte ip[] = { 192, 168, 1, 23 }; //W5100 etherrnet shield ip adress #include <Ethernet.h>
EthernetClient eClient; EthernetClient eClient;
IRrecv irrecv(IR_RECEIVER_PIN);
IRsend irsend; //connect IR emitter pin to D9 on arduino, you need to comment #define IR_USE_TIMER2 and uncomment #define IR_USE_TIMER1 on library IRremote.h so as to free pin D3 for RF RECEIVER PIN
#endif #endif
#define mqtt_server "192.168.1.45" decode_results results;
#define mqtt_user "your_username" // not compulsory if you set it uncomment line 143 and comment line 145
#define mqtt_password "your_password" // not compulsory if you set it uncomment line 143 and comment line 145
//variables to avoid duplicates for RF
#define time_avoid_duplicate 3000 // if you want to avoid duplicate mqtt message received set this to > 0, the value is the time in milliseconds during which we don't publish duplicates
// array to store previous received RFs codes and their timestamps
long ReceivedSignal[10][2] ={{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0}};
#define subjectMQTTtoX "home/commands/#"
//RF MQTT Subjects
#define subject433toMQTT "home/433toMQTT"
#define subjectMQTTto433 "home/commands/MQTTto433"
//IR MQTT Subjects
#define subjectIRtoMQTT "home/sensors/ir"
#define subjectMQTTtoIRCOOLIX "home/commands/sendCOOLIX"
#define subjectMQTTtoIRWhynter "home/commands/sendWhynter"
#define subjectMQTTtoIRNEC "home/commands/sendNEC"
#define subjectMQTTtoIRLG "home/commands/sendLG"
#define subjectMQTTtoIRSony "home/commands/sendSony"
#define subjectMQTTtoIRDISH "home/commands/sendDISH"
#define subjectMQTTtoIRSharp "home/commands/sendSharp"
#define subjectMQTTtoIRPanasonic "home/commands/sendPanasonic"
#define subjectMQTTtoIRSAMSUNG "home/commands/sendSAMSUNG"
// client parameters // client parameters
PubSubClient client(mqtt_server, 1883, callback, eClient); PubSubClient client(mqtt_server, 1883, callback, eClient);
//MQTT last attemps reconnection number //MQTT last attemps reconnection date
long lastReconnectAttempt = 0; int lastReconnectAttempt = 0;
boolean reconnect() { boolean reconnect() {
// Loop until we're reconnected // Loop until we're reconnected
while (!client.connected()) { while (!client.connected()) {
trc("Attempting MQTT connection..."); trc(F("Attempting MQTT connection...")); //F function enable to decrease sram usage
// Attempt to connect #ifdef mqtt_user
// If you want to use a username and password, uncomment next line and comment the line if (client.connect("433toMQTTto433")) { if (client.connect(GatewayName, mqtt_user, mqtt_password)) { // if an mqtt user is defined we connect to the broker with authentication
//if (client.connect("433nIRtoMQTTto433nIR", mqtt_user, mqtt_password)) { #else
// and set username and password at the program beginning if (client.connect(GatewayName)) {
if (client.connect("OpenMQTTGateway")) { #endif
// Once connected, publish an announcement... // Once connected, publish an announcement...
client.publish("outTopic","hello world"); client.publish(GatewayAnnouncementTopic,GatewayAnnouncementMsg);
trc("connected"); trc(F("connected"));
//Subscribing to topic(s) //Subscribing to topic
subscribing(subjectMQTTtoX); if (client.subscribe(subjectMQTTtoX)) {
trc(F("subscription OK to"));
trc(subjectMQTTtoX);
}
} else { } else {
trc("failed, rc="); trc(F("failed, rc="));
trc(String(client.state())); trc(String(client.state()));
trc(" try again in 5 seconds"); trc(F(" try again in 5 seconds"));
// Wait 5 seconds before retrying // Wait 5 seconds before retrying
delay(5000); delay(5000);
} }
@@ -132,26 +93,20 @@ boolean reconnect() {
return client.connected(); return client.connected();
} }
// Callback function, when the gateway receive an MQTT value on the topics subscribed this function is called // Callback function, when the gateway receive an MQTT value on the topics subscribed this function is called
void callback(char* topic, byte* payload, unsigned int length) { void callback(char* topic, byte* payload, unsigned int length) {
// In order to republish this payload, a copy must be made // In order to republish this payload, a copy must be made
// as the orignal payload buffer will be overwritten whilst // as the orignal payload buffer will be overwritten whilst
// constructing the PUBLISH packet. // constructing the PUBLISH packet.
trc("Hey I got a callback "); trc(F("Hey I got a callback "));
// Allocate the correct amount of memory for the payload copy // Allocate the correct amount of memory for the payload copy
byte* p = (byte*)malloc(length + 1); byte* p = (byte*)malloc(length + 1);
// Copy the payload to the new buffer // Copy the payload to the new buffer
memcpy(p,payload,length); memcpy(p,payload,length);
// Conversion to a printable string // Conversion to a printable string
p[length] = '\0'; p[length] = '\0';
String callbackstring = String((char *) p);
String topicNameRec = String((char*) topic);
//launch the function to treat received data //launch the function to treat received data
receivingMQTT(topicNameRec,callbackstring); receivingMQTT(topic,(char *) p);
// Free the memory // Free the memory
free(p); free(p);
} }
@@ -162,10 +117,10 @@ void setup()
Serial.begin(115200); Serial.begin(115200);
#ifdef ESP8266 #ifdef ESP8266
//Begining wifi connection //Begining wifi connection in case of ESP8266
setup_wifi(); setup_wifi();
#else #else
//Begining ethernet connection //Begining ethernet connection in case of Arduino + W5100
Ethernet.begin(mac, ip); Ethernet.begin(mac, ip);
#endif #endif
@@ -174,101 +129,106 @@ void setup()
lastReconnectAttempt = 0; lastReconnectAttempt = 0;
//IR init parameters //IR init parameters
#ifdef ESP8266
irsend.begin(); irsend.begin();
#endif
irrecv.enableIRIn(); // Start the receiver irrecv.enableIRIn(); // Start the receiver
//RF init parameters //RF init parameters
mySwitch.enableTransmit(4); // RF Transmitter is connected to Pin D2 mySwitch.enableTransmit(RF_EMITTER_PIN);
mySwitch.setRepeatTransmit(20); //increase transmit repeat to avoid lost of rf sendings mySwitch.setRepeatTransmit(RF_EMITTER_REPEAT);
mySwitch.enableReceive(5); // Receiver on pin D1 mySwitch.enableReceive(RF_RECEIVER_PIN);
} }
#ifdef ESP8266
void setup_wifi() { void setup_wifi() {
delay(10); delay(10);
// We start by connecting to a WiFi network // We start by connecting to a WiFi network
trc("Connecting to "); trc(F("Connecting to "));
trc(wifi_ssid); trc(wifi_ssid);
WiFi.begin(wifi_ssid, wifi_password); WiFi.begin(wifi_ssid, wifi_password);
while (WiFi.status() != WL_CONNECTED) { while (WiFi.status() != WL_CONNECTED) {
delay(500); delay(500);
trc("."); trc(F("."));
} }
trc("WiFi connected"); trc(F("WiFi connected"));
} }
#endif
void loop() void loop()
{ {
//MQTT client connexion management //MQTT client connexion management
if (!client.connected()) { if (!client.connected()) { // not connected
long now = millis(); long now = millis();
if (now - lastReconnectAttempt > 5000) { if (now - lastReconnectAttempt > 5000) {
lastReconnectAttempt = now; lastReconnectAttempt = now;
trc("client mqtt not connected, trying to connect"); trc(F("client mqtt not connected, trying to connect"));
// Attempt to reconnect // Attempt to reconnect
if (reconnect()) { if (reconnect()) {
lastReconnectAttempt = 0; lastReconnectAttempt = 0;
} }
} }
} else { } else { //connected
// MQTT loop // MQTT loop
client.loop(); client.loop();
} #ifdef ZaddonDHT
MeasureTempAndHum(); //Addon to measure the temperature with a DHT
// Receive loop, if data received by RF433 send it by MQTT to subject433toMQTT #endif
if (mySwitch.available()) { // Receive loop, if data received by RF433 or IR send it by MQTT
// Topic on which we will send data if (mySwitch.available() || irrecv.decode(&results)) {
trc("Receiving 433Mhz signal"); boolean result = sendValuebyMQTT();
unsigned long MQTTvalue; if(result)
MQTTvalue=mySwitch.getReceivedValue(); trc(F("value successfully sent by MQTT"));
mySwitch.resetAvailable();
if (client.connected()) {
if (!isAduplicate(MQTTvalue)) {// conditions to avoid duplications of RF -->MQTT
trc("Sending 433Mhz signal to MQTT");
trc(String(MQTTvalue));
sendMQTT(subject433toMQTT,String(MQTTvalue));
storeValue(MQTTvalue);
}
} else {
if (reconnect()) {
trc("Sending 433Mhz signal to MQTT after reconnect");
trc(String(MQTTvalue));
sendMQTT(subject433toMQTT,String(MQTTvalue));
storeValue(MQTTvalue);
lastReconnectAttempt = 0;
}
} }
} }
// Receive loop, if data received by IR send it by MQTT to subjectIRtoMQTT
if (irrecv.decode(&results)) {
trc("Receiving IR signal");
unsigned long MQTTvalue;
MQTTvalue=results.value;
if (!isAduplicate(MQTTvalue)) {// conditions to avoid duplications of IR -->MQTT
trc("Sending IR signal to MQTT");
trc(String(MQTTvalue));
sendMQTT(subjectIRtoMQTT,String(MQTTvalue));
storeValue(MQTTvalue);
}
irrecv.resume(); // Receive the next value
}
delay(100); delay(100);
}
boolean sendValuebyMQTT(){
// Topic on which we will send data
trc(F("Receiving 433Mhz or IR signal"));
unsigned long MQTTvalue = 0;
if (mySwitch.available()||irrecv.decode(&results)){
trc(F("Signal detected"));
String subject;
if (mySwitch.available()){
MQTTvalue = mySwitch.getReceivedValue();
mySwitch.resetAvailable();
subject = subject433toMQTT;
}else if (irrecv.decode(&results)){
MQTTvalue=results.value;
irrecv.resume(); // Receive the next value
subject = subjectIRtoMQTT;
}
if (!isAduplicate(MQTTvalue) && MQTTvalue!=0) {// conditions to avoid duplications of RF -->MQTT
trc(F("Sending signal to MQTT"));
String value = String(MQTTvalue);
trc(value);
boolean result = client.publish((char *)subject.c_str(),(char *)value.c_str());
if (result)storeValue(MQTTvalue);
return result;
}
return false;
}
} }
void storeValue(long MQTTvalue){ void storeValue(long MQTTvalue){
long now = millis(); long now = millis();
// find oldest value of the buffer // find oldest value of the buffer
int o = getMin(); int o = getMin();
trc("Minimum index: " + String(o)); trc(F("Minimum index: "));
trc(String(o));
// replace it by the new one // replace it by the new one
ReceivedSignal[o][0] = MQTTvalue; ReceivedSignal[o][0] = MQTTvalue;
ReceivedSignal[o][1] = now; ReceivedSignal[o][1] = now;
trc("send this code :" + String(ReceivedSignal[o][0])+"/"+String(ReceivedSignal[o][1])); trc(F("send this code :"));
trc("Col: value/timestamp"); trc(String(ReceivedSignal[o][0])+"/"+String(ReceivedSignal[o][1]));
trc(F("Col: value/timestamp"));
for (int i = 0; i < 10; i++) for (int i = 0; i < 10; i++)
{ {
trc(String(i) + ":" + String(ReceivedSignal[i][0])+"/"+String(ReceivedSignal[i][1])); trc(String(i) + ":" + String(ReceivedSignal[i][0])+"/"+String(ReceivedSignal[i][1]));
@@ -289,13 +249,13 @@ int getMin(){
} }
boolean isAduplicate(long value){ boolean isAduplicate(long value){
trc("isAduplicate"); trc(F("isAduplicate"));
// check if the value has been already sent during the last "time_avoid_duplicate" // check if the value has been already sent during the last time_avoid_duplicate
for (int i=0; i<10;i++){ for (int i=0; i<10;i++){
if (ReceivedSignal[i][0] == value){ if (ReceivedSignal[i][0] == value){
long now = millis(); long now = millis();
if (now - ReceivedSignal[i][1] < time_avoid_duplicate){ if (now - ReceivedSignal[i][1] < time_avoid_duplicate){ // change
trc("don't send this code :" + String(ReceivedSignal[i][0])+"/"+String(ReceivedSignal[i][1])); trc(F("don't send the received code"));
return true; return true;
} }
} }
@@ -303,76 +263,83 @@ for (int i=0; i<10;i++){
return false; return false;
} }
void subscribing(String topicNameRec){ // MQTT subscribing to topic void receivingMQTT(char * topicOri, char * datacallback) {
char topicStrRec[26]; String topic = topicOri;
topicNameRec.toCharArray(topicStrRec,26); if(topic.lastIndexOf(subjectAck) == -1){ //avoid loop when publishing an acknowledgement
// subscription to topic for receiving data trc(F("Receiving data by MQTT"));
boolean pubresult = client.subscribe(topicStrRec); trc(topic);
if (pubresult) {
trc("subscription OK to");
trc(topicNameRec);
}
}
void receivingMQTT(String topicNameRec, String callbackstring) {
trc("Receiving data by MQTT");
trc(topicNameRec);
char topicOri[26] = "";
char topicStrAck[26] = "";
char datacallback[32] = "";
// Acknowledgement inside a subtopic to avoid loop // Acknowledgement inside a subtopic to avoid loop
topicNameRec.toCharArray(topicOri,26); char AckSubject[strlen(topicOri)+5];
char DataAck[26] = "OK"; AckSubject[strlen(topicOri)+4] ='\0';
client.publish("home/ack", DataAck); strcpy(AckSubject, topicOri);
callbackstring.toCharArray(datacallback,32); strcat(AckSubject, subjectAck);
trc("Callback value"); boolean result = client.publish(AckSubject, "OK");
trc(datacallback); if (result)trc(F("Acknowedgement of reception published"));
unsigned long data = strtoul(datacallback, NULL, 10); // we will not be able to pass value > 4294967295
trc("Converted value to unsigned long"); trc(F("Callback value"));
trc(String(datacallback));
unsigned long data = strtoul(datacallback, NULL, 10); // we will not be able to pass values > 4294967295
trc(F("Converted value to unsigned long"));
trc(String(data)); trc(String(data));
if (topicNameRec == subjectMQTTto433){ // RF DATA ANALYSIS
trc("Send received data by RF 433"); //We look into the subject to see if a special RF protocol is defined
//send received MQTT value by RF signal (example of signal sent data = 5264660) int valuePRT = 0;
int valuePLSL = 0;
int pos = topic.lastIndexOf(RFprotocolKey);
if (pos != -1){
pos = pos + +strlen(RFprotocolKey);
valuePRT = (topic.substring(pos,pos + 1)).toInt();
trc(F("RF Protocol number:"));
trc(String(valuePRT));
}
//We look into the subject to see if a special RF pulselength is defined
int pos2 = topic.lastIndexOf(RFpulselengthKey);
if (pos2 != -1) {
pos2 = pos2 + strlen(RFpulselengthKey);
valuePLSL = (topic.substring(pos2,pos2 + 3)).toInt();
trc(F("RF Pulse Length:"));
trc(String(valuePLSL));
}
if ((topic == subjectMQTTto433)){
trc(F("Sending data by RF, default parameters"));
mySwitch.setProtocol(1,350);
mySwitch.send(data, 24);
} else if ((valuePRT != 0) || (valuePLSL != 0)){
trc(F("Sending data by RF, user defined parameters"));
if (valuePLSL != 0) valuePRT = 1;
if (valuePRT != 0) valuePLSL = 350;
mySwitch.setProtocol(valuePRT,valuePLSL);
mySwitch.send(data, 24); mySwitch.send(data, 24);
} }
// IR DATA ANALYSIS
//send received MQTT value by IR signal (example of signal sent data = 1086296175) //send received MQTT value by IR signal (example of signal sent data = 1086296175)
if (topicNameRec == subjectMQTTtoIRCOOLIX) #ifdef ESP8266 // send coolix not available for arduino IRRemote library
if (topic.lastIndexOf("IR_COOLIX") != -1 ){
irsend.sendCOOLIX(data, 24); irsend.sendCOOLIX(data, 24);
if (topicNameRec == subjectMQTTtoIRWhynter) }
irsend.sendWhynter(data, 32); #endif
if (topicNameRec == subjectMQTTtoIRNEC) if (topic.lastIndexOf("IR_NEC")!= -1 || topic == subjectMQTTtoIR)
irsend.sendNEC(data, 32); irsend.sendNEC(data, 32);
if (topicNameRec == subjectMQTTtoIRLG) if (topic.lastIndexOf("IR_Whynter")!=-1)
irsend.sendWhynter(data, 32);
if (topic.lastIndexOf("IR_LG")!=-1)
irsend.sendLG(data, 28); irsend.sendLG(data, 28);
if (topicNameRec == subjectMQTTtoIRSony) if (topic.lastIndexOf("IR_Sony")!=-1)
irsend.sendSony(data, 12); irsend.sendSony(data, 12);
if (topicNameRec == subjectMQTTtoIRDISH) if (topic.lastIndexOf("IR_DISH")!=-1)
irsend.sendDISH(data, 16); irsend.sendDISH(data, 16);
if (topicNameRec == subjectMQTTtoIRSharp) if (topic.lastIndexOf("IR_Sharp")!=-1)
irsend.sendSharpRaw(data, 15); irsend.sendSharpRaw(data, 15);
/* if (topic.lastIndexOf("IR_SAMSUNG")!=-1)
Panasonic has a two arguments per call. An address(16bit) and data(32bit), not data and nr_bits.
if (topicNameRec == subjectMQTTtoIRPanasonic)
irsend.sendPanasonic(data, 36);
*/
if (topicNameRec == subjectMQTTtoIRSAMSUNG)
irsend.sendSAMSUNG(data, 32); irsend.sendSAMSUNG(data, 32);
}
//send MQTT data dataStr to topic topicNameSend
void sendMQTT(String topicNameSend, String dataStr){
char topicStrSend[26];
topicNameSend.toCharArray(topicStrSend,26);
char dataStrSend[200];
dataStr.toCharArray(dataStrSend,200);
boolean pubresult = client.publish(topicStrSend,dataStrSend);
trc("sending ");
trc(dataStr);
trc("to ");
trc(topicNameSend);
irrecv.enableIRIn(); // ReStart the IR receiver (if not restarted it is not able to receive data)
} else
trc(F("Not processing this callback contains $subjectAck"));
} }
//trace //trace
User_config.h
+108
View File
@@ -0,0 +1,108 @@
/*
OpenMQTTGateway - ESP8266 or Arduino program for home automation
Act as a wifi or ethernet gateway between your 433mhz/infrared IR signal and a MQTT broker
Send and receiving command by MQTT
This program enables to:
- receive MQTT data from a topic and send RF 433Mhz signal corresponding to the received MQTT data
- publish MQTT data to a different topic related to received 433Mhz signal
- receive MQTT data from a topic and send IR signal corresponding to the received MQTT data
- publish MQTT data to a different topic related to received IR signal
Copyright: (c)1technophile
Contributors:
- crankyoldgit
- Spudtater
Permission is hereby granted, free of charge, to any person obtaining a copy of this software
and associated documentation files (the "Software"), to deal in the Software without restriction,
including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so,
subject to the following conditions:
The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED
TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF
CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*/
/*----------------------------USER PARAMETERS-----------------------------*/
/*-------------DEFINE YOUR MQTT & NETWORK PARAMETERS BELOW----------------*/
//MQTT Parameters definition
#define mqtt_server "192.168.1.17"
#define mqtt_user "your_username" // not compulsory only if your broker needs authentication
#define mqtt_password "your_password" // not compulsory only if your broker needs authentication
// Update these with values suitable for your network.
#ifdef ESP8266 // for nodemcu, weemos and esp8266
#define wifi_ssid "wifi ssid"
#define wifi_password "wifi password"
#else // for arduino + W5100
const byte mac[] = { 0xDE, 0xED, 0xBA, 0xFE, 0x54, 0x95 }; //W5100 ethernet shield mac adress
const byte ip[] = { 192, 168, 1, 95 }; //W5100 ethernet shield ip adress
#endif
//Addons management, comment the line if you don't use
//#define ZaddonDHT true
/*----------------------------OTHER PARAMETERS-----------------------------*/
/*-------------------CHANGING THEM IS NOT COMPULSORY-----------------------*/
//variables to avoid duplicates for RF
#define time_avoid_duplicate 3000 // if you want to avoid duplicate mqtt message received set this to > 0, the value is the time in milliseconds during which we don't publish duplicates
//MQTT definitions
//RF MQTT Subjects
#define GatewayName "OpenMQTTGateway"
#define GatewayAnnouncementTopic "OpenMQTTGateway connected"
#define GatewayAnnouncementMsg "hello broker!"
// global MQTT subject listened by the gateway to execute commands (send RF, IR or others)
#define subjectMQTTtoX "home/commands/#"
#define subjectAck "/ack"
//433Mhz MQTT Subjects and keys
#define subjectMQTTto433 "home/commands/MQTTto433"
#define subject433toMQTT "home/433toMQTT"
#define RFprotocolKey "433_" // protocol will be defined if a subject contains RFprotocolKey followed by a value of 1 digit
#define RFpulselengthKey "PLSL_" // pulselength will be defined if a subject contains RFprotocolKey followed by a value of 3 digits
//IR MQTT Subjects
#define subjectIRtoMQTT "home/sensors/ir"
#define subjectMQTTtoIR "home/commands/MQTTtoIR"
/*
RF supported protocols
433_1
433_2
433_3
433_4
433_5
433_6
IR supported protocols
IR_NEC
IR_LG
IR_Sony
IR_DISH
IR_Sharp
IR_SAMSUNG
IR_COOLIX
IR_Whynter
*/
//IR PIN definition
#define IR_RECEIVER_PIN 2 // put 2 = D4 on nodemcu, 2 = D2 on arduino
#define RF_EMITTER_PIN 4 //put 4 = D2 on nodemcu, 4 = D4 on arduino
#ifdef ESP8266
#define IR_EMITTER_PIN 14 // 14 = D5 on nodemcu #define only usefull for ESP8266
//RF PIN definition
#define RF_RECEIVER_PIN 5 // 5 = D1 on nodemcu
#else
//IMPORTANT NOTE: On arduino UNO connect IR emitter pin to D9 , comment #define IR_USE_TIMER2 and uncomment #define IR_USE_TIMER1 on library <library>IRremote/IRremoteInt.h so as to free pin D3 for RF RECEIVER PIN
//RF PIN definition
#define RF_RECEIVER_PIN 1 // 1 = D3 on arduino
#endif
//RF number of signal repetition
#define RF_EMITTER_REPEAT 20
//Do we want to see trace for debugging purposes
#define TRACE 1 // 0= trace off 1 = trace on
ZaddonDHT.ino
+59
View File
@@ -0,0 +1,59 @@
/*
OpenMQTTGateway Addon - ESP8266 or Arduino program for home automation
Act as a wifi or ethernet gateway between your 433mhz/infrared IR signal and a MQTT broker
Send and receiving command by MQTT
DHT reading Addon
Copyright: (c)1technophile
Contributors:
- prahjister
- 1technophile
Permission is hereby granted, free of charge, to any person obtaining a copy of this software
and associated documentation files (the "Software"), to deal in the Software without restriction,
including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so,
subject to the following conditions:
The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED
TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF
CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*/
#ifdef ZaddonDHT
#include <DHT.h>
#include <DHT_U.h>
#define TimeBetweenReading 60000
DHT dht(6,DHT11);
/*----------------------------USER PARAMETERS-----------------------------*/
/*-------------DEFINE YOUR MQTT PARAMETERS BELOW----------------*/
#define HUM1 "home/433toMQTT/dht1/hum"
#define TEMP1 "home/433toMQTT/dht1/temp"
//Time used to wait for an interval before resending temp and hum
unsigned long time1 = 0;
void MeasureTempAndHum(){
if (millis() > (time1 + TimeBetweenReading)) {//retriving value of temperature and humidity of the box from DHT every xUL
time1 = millis();
float h = dht.readHumidity();
// Read temperature as Celsius (the default)
float t = dht.readTemperature();
// Check if any reads failed and exit early (to try again).
if (isnan(h) || isnan(t)) {
trc(F("Failed to read from DHT sensor!"));
}else{
char temp[5];
char hum[5];
dtostrf(t,4,2,temp);
dtostrf(h,4,2,hum);
client.publish(HUM1,hum);
client.publish(TEMP1,temp);
}
}
}
#endif
_433nIRtoMQTTto433nIR_ESP8266.ino
-355
View File
@@ -1,355 +0,0 @@
/*
433nIRtoMQTTto433nIR - ESP8266 program for home automation
Tested OK on GeekCreek ESP12F
Not working on NodeMCU V0.9
Act as a wifi gateway between your 433mhz/infrared IR signal and a MQTT broker
Send and receiving command by MQTT
This program enables to:
- receive MQTT data from a topic and send RF 433Mhz signal corresponding to the received MQTT data
- publish MQTT data to a different topic related to received 433Mhz signal
- receive MQTT data from a topic and send IR signal corresponding to the received MQTT data
- publish MQTT data to a different topic related to received IR signal
Contributors:
- 1technophile
- crankyoldgit
Based on:
- MQTT library (https://github.com/knolleary)
- RCSwitch (https://github.com/sui77/rc-switch)
- ESP8266Wifi
- IRremoteESP8266 (https://github.com/markszabo/IRremoteESP8266)
Project home: https://github.com/1technophile/433nIRtoMQTTto433nIR_ESP8266
Blog, tutorial: http://1technophile.blogspot.com/2016/09/433nIRtomqttto433nIR-bidirectional-esp8266.html
Permission is hereby granted, free of charge, to any person obtaining a copy of this software
and associated documentation files (the "Software"), to deal in the Software without restriction,
including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so,
subject to the following conditions:
The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED
TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF
CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
Some usefull commands to test gateway with mosquitto:
Subscribe to the subject for data receiption from RF signal
mosquitto_sub -t home/433toMQTT
Send data by MQTT to convert it on RF signal
mosquitto_pub -t home/MQTTto433/ -m 1315153
*/
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
#include <RCSwitch.h> // library for controling Radio frequency switch
#include <IRremoteESP8266.h>
RCSwitch mySwitch = RCSwitch();
IRrecv irrecv(2);
IRsend irsend(14);
decode_results results;
//Do we want to see trace for debugging purposes
#define TRACE 1 // 0= trace off 1 = trace on
// Update these with values suitable for your network.
#define wifi_ssid "mywifiid"
#define wifi_password "mypwd"
#define mqtt_server "192.168.0.22"
#define mqtt_user "your_username" // not compulsory if you set it uncomment line 143 and comment line 145
#define mqtt_password "your_password" // not compulsory if you set it uncomment line 143 and comment line 145
//variables to avoid duplicates for RF
#define time_avoid_duplicate 3000 // if you want to avoid duplicate mqtt message received set this to > 0, the value is the time in milliseconds during which we don't publish duplicates
// array to store previous received RFs codes and their timestamps
long ReceivedRF[10][2] ={{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0}};
#define subjectMQTTtoX "home/commands/#"
//RF MQTT Subjects
#define subject433toMQTT "home/433toMQTT"
#define subjectMQTTto433 "home/commands/MQTTto433"
//IR MQTT Subjects
#define subjectIRtoMQTT "home/sensors/ir"
#define subjectMQTTtoIRCOOLIX "home/commands/sendCOOLIX"
#define subjectMQTTtoIRWhynter "home/commands/sendWhynter"
#define subjectMQTTtoIRNEC "home/commands/sendNEC"
#define subjectMQTTtoIRLG "home/commands/sendLG"
#define subjectMQTTtoIRSony "home/commands/sendSony"
#define subjectMQTTtoIRDISH "home/commands/sendDISH"
#define subjectMQTTtoIRSharp "home/commands/sendSharp"
#define subjectMQTTtoIRPanasonic "home/commands/sendPanasonic"
#define subjectMQTTtoIRSAMSUNG "home/commands/sendSAMSUNG"
//adding this to bypass to problem of the arduino builder issue 50
void callback(char*topic, byte* payload,unsigned int length);
WiFiClient espClient;
// client parameters
PubSubClient client(mqtt_server, 1883, callback, espClient);
//MQTT last attemps reconnection number
long lastReconnectAttempt = 0;
// Callback function, when the gateway receive an MQTT value on the topics subscribed this function is called
void callback(char* topic, byte* payload, unsigned int length) {
// In order to republish this payload, a copy must be made
// as the orignal payload buffer will be overwritten whilst
// constructing the PUBLISH packet.
trc("Hey I got a callback ");
// Allocate the correct amount of memory for the payload copy
byte* p = (byte*)malloc(length + 1);
// Copy the payload to the new buffer
memcpy(p,payload,length);
// Conversion to a printable string
p[length] = '\0';
String callbackstring = String((char *) p);
String topicNameRec = String((char*) topic);
//launch the function to treat received data
receivingMQTT(topicNameRec,callbackstring);
// Free the memory
free(p);
}
void setup()
{
//Launch serial for debugging purposes
Serial.begin(9600);
//Begining wifi connection
setup_wifi();
delay(1500);
lastReconnectAttempt = 0;
//IR init parameters
irsend.begin();
irrecv.enableIRIn(); // Start the receiver
//RF init parameters
mySwitch.enableTransmit(4); // RF Transmitter is connected to Pin D2
mySwitch.setRepeatTransmit(20); //increase transmit repeat to avoid lost of rf sendings
mySwitch.enableReceive(5); // Receiver on pin D1
}
void setup_wifi() {
delay(10);
// We start by connecting to a WiFi network
trc("Connecting to ");
trc(wifi_ssid);
WiFi.begin(wifi_ssid, wifi_password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
trc(".");
}
trc("WiFi connected");
}
boolean reconnect() {
// Loop until we're reconnected
while (!client.connected()) {
trc("Attempting MQTT connection...");
// Attempt to connect
// If you want to use a username and password, uncomment next line and comment the line if (client.connect("433toMQTTto433")) {
//if (client.connect("433nIRtoMQTTto433nIR", mqtt_user, mqtt_password)) {
// and set username and password at the program beginning
if (client.connect("433nIRtoMQTTto433nIR")) {
// Once connected, publish an announcement...
client.publish("outTopic","hello world");
trc("connected");
//Subscribing to topic(s)
subscribing(subjectMQTTtoX);
} else {
trc("failed, rc=");
trc(String(client.state()));
trc(" try again in 5 seconds");
// Wait 5 seconds before retrying
delay(5000);
}
}
return client.connected();
}
void loop()
{
//MQTT client connexion management
if (!client.connected()) {
long now = millis();
if (now - lastReconnectAttempt > 5000) {
lastReconnectAttempt = now;
trc("client mqtt not connected, trying to connect");
// Attempt to reconnect
if (reconnect()) {
lastReconnectAttempt = 0;
}
}
} else {
// MQTT loop
client.loop();
}
// Receive loop, if data received by RF433 send it by MQTT to subject433toMQTT
if (mySwitch.available()) {
// Topic on which we will send data
trc("Receiving 433Mhz signal");
unsigned long MQTTvalue;
MQTTvalue=mySwitch.getReceivedValue();
mySwitch.resetAvailable();
if (client.connected()) {
if (!isAduplicate(MQTTvalue)) {// conditions to avoid duplications of RF -->MQTT
trc("Sending 433Mhz signal to MQTT");
trc(String(MQTTvalue));
sendMQTT(subject433toMQTT,String(MQTTvalue));
storeValue(MQTTvalue);
}
} else {
if (reconnect()) {
trc("Sending 433Mhz signal to MQTT after reconnect");
trc(String(MQTTvalue));
sendMQTT(subject433toMQTT,String(MQTTvalue));
storeValue(MQTTvalue);
lastReconnectAttempt = 0;
}
}
}
// Receive loop, if data received by IR send it by MQTT to subjectIRtoMQTT
if (irrecv.decode(&results)) {
trc("Receiving IR signal");
String MQTTvalue;
MQTTvalue=results.value;
trc("Sending IR signal to MQTT");
trc(MQTTvalue);
sendMQTT(subjectIRtoMQTT,MQTTvalue);
irrecv.resume(); // Receive the next value
}
delay(100);
}
void storeValue(long MQTTvalue){
long now = millis();
// find oldest value of the buffer
int o = getMin();
trc("Minimum index: " + String(o));
// replace it by the new one
ReceivedRF[o][0] = MQTTvalue;
ReceivedRF[o][1] = now;
trc("send this code :" + String(ReceivedRF[o][0])+"/"+String(ReceivedRF[o][1]));
trc("Col: value/timestamp");
for (int i = 0; i < 10; i++)
{
trc(String(i) + ":" + String(ReceivedRF[i][0])+"/"+String(ReceivedRF[i][1]));
}
}
int getMin(){
int minimum = ReceivedRF[0][1];
int minindex=0;
for (int i = 0; i < 10; i++)
{
if (ReceivedRF[i][1] < minimum) {
minimum = ReceivedRF[i][1];
minindex = i;
}
}
return minindex;
}
boolean isAduplicate(long value){
trc("isAduplicate");
// check if the value has been already sent during the last "time_avoid_duplicate"
for (int i=0; i<10;i++){
if (ReceivedRF[i][0] == value){
long now = millis();
if (now - ReceivedRF[i][1] < time_avoid_duplicate){
trc("don't send this code :" + String(ReceivedRF[i][0])+"/"+String(ReceivedRF[i][1]));
return true;
}
}
}
return false;
}
void subscribing(String topicNameRec){ // MQTT subscribing to topic
char topicStrRec[26];
topicNameRec.toCharArray(topicStrRec,26);
// subscription to topic for receiving data
boolean pubresult = client.subscribe(topicStrRec);
if (pubresult) {
trc("subscription OK to");
trc(topicNameRec);
}
}
void receivingMQTT(String topicNameRec, String callbackstring) {
trc("Receiving data by MQTT");
trc(topicNameRec);
char topicOri[26] = "";
char topicStrAck[26] = "";
char datacallback[32] = "";
// Acknowledgement inside a subtopic to avoid loop
topicNameRec.toCharArray(topicOri,26);
char DataAck[26] = "OK";
client.publish("home/ack", DataAck);
callbackstring.toCharArray(datacallback,32);
trc(datacallback);
unsigned long data = strtoul(datacallback, NULL, 10); // we will not be able to pass value > 4294967295
trc(String(data));
if (topicNameRec == subjectMQTTto433){
trc("Send received data by RF 433");
//send received MQTT value by RF signal (example of signal sent data = 5264660)
mySwitch.send(data, 24);
}
//send received MQTT value by IR signal (example of signal sent data = 1086296175)
if (topicNameRec == subjectMQTTtoIRCOOLIX)
irsend.sendCOOLIX(data, 24);
if (topicNameRec == subjectMQTTtoIRWhynter)
irsend.sendWhynter(data, 32);
if (topicNameRec == subjectMQTTtoIRNEC)
irsend.sendNEC(data, 32);
if (topicNameRec == subjectMQTTtoIRLG)
irsend.sendLG(data, 28);
if (topicNameRec == subjectMQTTtoIRSony)
irsend.sendSony(data, 12);
if (topicNameRec == subjectMQTTtoIRDISH)
irsend.sendDISH(data, 16);
if (topicNameRec == subjectMQTTtoIRSharp)
irsend.sendSharpRaw(data, 15);
/*
Panasonic has a two arguments per call. An address(16bit) and data(32bit), not data and nr_bits.
if (topicNameRec == subjectMQTTtoIRPanasonic)
irsend.sendPanasonic(data, 36);
*/
if (topicNameRec == subjectMQTTtoIRSAMSUNG)
irsend.sendSAMSUNG(data, 32);
}
//send MQTT data dataStr to topic topicNameSend
void sendMQTT(String topicNameSend, String dataStr){
char topicStrSend[26];
topicNameSend.toCharArray(topicStrSend,26);
char dataStrSend[200];
dataStr.toCharArray(dataStrSend,200);
boolean pubresult = client.publish(topicStrSend,dataStrSend);
trc("sending ");
trc(dataStr);
trc("to ");
trc(topicNameSend);
}
//trace
void trc(String msg){
if (TRACE) {
Serial.println(msg);
}
}
_433toMQTTto433_ESP8266.ino
-283
View File
@@ -1,283 +0,0 @@
/*
433toMQTTto433 - ESP8266 program for home automation
Act as a wifi gateway between your 433mhz nodes and a MQTT broker
Send and receiving command by MQTT
This program enables to:
- receive MQTT data from a topic and send RF 433Mhz signal corresponding to the received MQTT data
- publish MQTT data to a different topic related to received 433Mhz signal
Contributor:
- 1technophile
Based on:
- MQTT library (https://github.com/knolleary)
- RCSwitch (https://github.com/sui77/rc-switch)
- ESP8266Wifi
Project home: https://github.com/1technophile/433toMQTTto433_ESP8266
Blog, tutorial: http://1technophile.blogspot.com/2016/09/433tomqttto433-bidirectional-esp8266.html
Permission is hereby granted, free of charge, to any person obtaining a copy of this software
and associated documentation files (the "Software"), to deal in the Software without restriction,
including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so,
subject to the following conditions:
The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED
TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF
CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
Some usefull commands to test gateway with mosquitto:
Subscribe to the subject for data receiption from RF signal
mosquitto_sub -t home/433toMQTT
Send data by MQTT to convert it on RF signal
mosquitto_pub -t home/MQTTto433/ -m 1315153
*/
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
#include <RCSwitch.h> // library for controling Radio frequency switch
RCSwitch mySwitch = RCSwitch();
//Do we want to see trace for debugging purposes
#define TRACE 1 // 0= trace off 1 = trace on
// Update these with values suitable for your network.
#define wifi_ssid "mywifiid"
#define wifi_password "mypwd"
#define mqtt_server "192.168.0.22"
#define mqtt_user "your_username" // not compulsory if you set it uncomment line 127 and comment line 129
#define mqtt_password "your_password" // not compulsory if you set it uncomment line 127 and comment line 129
//variables to avoid duplicates
#define time_avoid_duplicate 3000 // if you want to avoid duplicate mqtt message received set this to > 0, the value is the time in milliseconds during which we don't publish duplicates
// array to store previous received RFs codes and their timestamps
long ReceivedRF[10][2] ={{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0},{0,0}};
#define subjectMQTTtoX "home/commands/#"
//RF MQTT Subjects
#define subject433toMQTT "home/433toMQTT"
#define subjectMQTTto433 "home/commands/MQTTto433"
//adding this to bypass to problem of the arduino builder issue 50
void callback(char*topic, byte* payload,unsigned int length);
WiFiClient espClient;
// client parameters
PubSubClient client(mqtt_server, 1883, callback, espClient);
//MQTT last attemps reconnection number
long lastReconnectAttempt = 0;
// Callback function, when the gateway receive an MQTT value on the topics subscribed this function is called
void callback(char* topic, byte* payload, unsigned int length) {
// In order to republish this payload, a copy must be made
// as the orignal payload buffer will be overwritten whilst
// constructing the PUBLISH packet.
trc("Hey I got a callback ");
// Allocate the correct amount of memory for the payload copy
byte* p = (byte*)malloc(length + 1);
// Copy the payload to the new buffer
memcpy(p,payload,length);
// Conversion to a printable string
p[length] = '\0';
String callbackstring = String((char *) p);
String topicNameRec = String((char*) topic);
//launch the function to treat received data
receivingMQTT(topicNameRec,callbackstring);
// Free the memory
free(p);
}
void setup()
{
//Launch serial for debugging purposes
Serial.begin(9600);
//Begining wifi connection
setup_wifi();
delay(1500);
lastReconnectAttempt = 0;
mySwitch.enableTransmit(4); // RF Transmitter is connected to Pin D2
mySwitch.setRepeatTransmit(20); //increase transmit repeat to avoid lost of rf sendings
mySwitch.enableReceive(5); // Receiver on pin D1
}
void setup_wifi() {
delay(10);
// We start by connecting to a WiFi network
trc("Connecting to ");
trc(wifi_ssid);
WiFi.begin(wifi_ssid, wifi_password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
trc(".");
}
trc("WiFi connected");
}
boolean reconnect() {
// Loop until we're reconnected
while (!client.connected()) {
trc("Attempting MQTT connection...");
// Attempt to connect
// If you want to use a username and password, uncomment next line and comment the line if (client.connect("433toMQTTto433")) {
//if (client.connect("433toMQTTto433", mqtt_user, mqtt_password)) {
// and set username and password at the program beginning
if (client.connect("433toMQTTto433")) {
// Once connected, publish an announcement...
client.publish("outTopic","hello world");
trc("connected");
//Subscribing to topic(s)
subscribing(subjectMQTTtoX);
} else {
trc("failed, rc=");
trc(String(client.state()));
trc(" try again in 5 seconds");
// Wait 5 seconds before retrying
delay(5000);
}
}
return client.connected();
}
void loop()
{
//MQTT client connexion management
if (!client.connected()) {
long now = millis();
if (now - lastReconnectAttempt > 5000) {
lastReconnectAttempt = now;
trc("client mqtt not connected, trying to connect");
// Attempt to reconnect
if (reconnect()) {
lastReconnectAttempt = 0;
}
}
} else {
// MQTT loop
client.loop();
}
// Receive loop, if data received by RF433 send it by MQTT to subject433toMQTT
if (mySwitch.available()) {
// Topic on which we will send data
trc("Receiving 433Mhz signal");
unsigned long MQTTvalue;
MQTTvalue=mySwitch.getReceivedValue();
mySwitch.resetAvailable();
if (client.connected()) {
if (!isAduplicate(MQTTvalue)) {// conditions to avoid duplications of RF -->MQTT
trc("Sending 433Mhz signal to MQTT");
trc(String(MQTTvalue));
sendMQTT(subject433toMQTT,String(MQTTvalue));
storeValue(MQTTvalue);
}
} else {
if (reconnect()) {
trc("Sending 433Mhz signal to MQTT after reconnect");
trc(String(MQTTvalue));
sendMQTT(subject433toMQTT,String(MQTTvalue));
storeValue(MQTTvalue);
lastReconnectAttempt = 0;
}
}
}
}
void storeValue(long MQTTvalue){
long now = millis();
// find oldest value of the buffer
int o = getMin();
trc("Minimum index: " + String(o));
// replace it by the new one
ReceivedRF[o][0] = MQTTvalue;
ReceivedRF[o][1] = now;
trc("send this code :" + String(ReceivedRF[o][0])+"/"+String(ReceivedRF[o][1]));
trc("Col: value/timestamp");
for (int i = 0; i < 10; i++)
{
trc(String(i) + ":" + String(ReceivedRF[i][0])+"/"+String(ReceivedRF[i][1]));
}
}
int getMin()
{
int minimum = ReceivedRF[0][1];
int minindex=0;
for (int i = 0; i < 10; i++)
{
if (ReceivedRF[i][1] < minimum) {
minimum = ReceivedRF[i][1];
minindex = i;
}
}
return minindex;
}
boolean isAduplicate(long value){
trc("isAduplicate");
// check if the value has been already sent during the last "time_avoid_duplicate"
for (int i=0; i<10;i++){
if (ReceivedRF[i][0] == value){
long now = millis();
if (now - ReceivedRF[i][1] < time_avoid_duplicate){
trc("don't send this code :" + String(ReceivedRF[i][0])+"/"+String(ReceivedRF[i][1]));
return true;
}
}
}
return false;
}
void subscribing(String topicNameRec){ // MQTT subscribing to topic
char topicStrRec[26];
topicNameRec.toCharArray(topicStrRec,26);
// subscription to topic for receiving data
boolean pubresult = client.subscribe(topicStrRec);
if (pubresult) {
trc("subscription OK to");
trc(topicNameRec);
}
}
void receivingMQTT(String topicNameRec, String callbackstring) {
trc("Receiving data by MQTT");
trc(topicNameRec);
char topicOri[26] = "";
char topicStrAck[26] = "";
char datacallback[26] = "";
// Below you send RF signal following data value received by MQTT
callbackstring.toCharArray(datacallback,26);
trc(datacallback);
long int data = atol(datacallback);
trc("Send received data by RF 433");
trc(String(data));
//send received MQTT value by RF signal (example of signal sent data = 5264660)
mySwitch.send(data, 24);
}
//send MQTT data dataStr to topic topicNameSend
void sendMQTT(String topicNameSend, String dataStr){
char topicStrSend[26];
topicNameSend.toCharArray(topicStrSend,26);
char dataStrSend[200];
dataStr.toCharArray(dataStrSend,200);
boolean pubresult = client.publish(topicStrSend,dataStrSend);
trc("sending ");
trc(dataStr);
trc("to ");
trc(topicNameSend);
}
//trace
void trc(String msg){
if (TRACE) {
Serial.println(msg);
}
}