computourist
commented
8 years ago Hi Thomas,
always difficult to troobleshoot at a distance..
Some thoughts:
- your sketch should display debug info if you compiled with the debug option. Check your COM settings (baud rate, COM port, etc)
- If you connected your RFM69 to an Arduino it is probably gone. The RFM69 does not withstand 5 Volts; it is meant to operate on 3.3 Volts on VSS and inputs.
- try to split up your faultfinding: first troubleshoot the MQTT connection. Use another client to send commands to you gateway and see if it responds. Once you have that working start troubleshooting the radio part.
- Have a look at our forum: http://homeautomation.proboards.com Lots of solutions and problems have been discussed there and there are always people willing to lend a helping hand....
Success, Computourist
Hello,
i'm rather fresh in this topic, but the gateway 2.4 is not working.
I tried to use an arduino uno with ethernet shield, i adjusted all values and uncommented the debug parameter for radio, but i don't see any debug information, neither the normal startup 433MHZ listening.
I tried the Gateway 2.3 and figured out this had problems with the mqtt_sub, i removed it and got at least the debug information in the CLI.
No i wonder what could it be, my radio chip is perfectly soldered and i don't have shortcuts.
My test sensor node is an arduino pro mini with rfm69hw connected, it sends data but i don't see any at the gateway with the old code. How can i display received data on the CLI in the debug section to my understanding no self-test is included.
Probably the void setup in the new code causes troubles because i don't see output at all in the CLI and its a part of the initialization, i had to remove it in the Version 2.3 as well to get at least some code compiled and loaded.
Do you have a sample code to check my rfm69hw chips or some hint that you heard abt similar problems?
Wiring was with Version 2.4 to PIN 8 and in the 2.3 Version to PIN 10.
My gateway and the node are both connected via USB and serial interface to my notebook.
I used normal phone cable to solder it, i checked as well with a volt meter the transition to the arduino pins, everthing is fine, i'm a bit clueless now what could it be else, i'm abt to solder cables another rfm69 chip to figure out if it causes troubles.
Some ideas or known issues?
Do you have a simple sample send/receive code, to verify if the chips work as expected?
Thats my code:
// RFM69 MQTT gateway sketch // // This gateway relays messages between a MQTT-broker and several wireless nodes and will: // - receive sensor data from several nodes periodically and on-demand // - send/receive commands from the broker to control actuators and node parameters // // Connection to the MQTT broker is over a fixed ethernet connection: // // The MQTT topic is /home/rfm_gw/direction/nodeid/devid // where direction is: southbound (sb) towards the remote node and northbound (nb) towards MQTT broker // // Connection to the nodes is over a closed radio network: // // RFM Message format is: nodeID/deviceID/command/integer/float/string // where Command = 1 for a read request and 0 for a write request // // Current defined gateway devices are: // 0 uptime: gateway uptime in minutes // 3 Version: read version gateway software //
// Reserved ranges for node devices, as implemented in the gateway are: // 0 - 16 Node system devices // 16 - 32 Binary output (LED, relay) // 32 - 40 Integer output (pwm, dimmer) // 40 - 48 Binary input (button, switch, PIR-sensor) // 48 - 64 Real input (temperature, humidity) // 64 - 72 Integer input (light intensity) // // 72 string: transparant string transport // // 73 - 90 Special devices not implemented in gateway (yet) // // Currently defined error messages are: // 90 error: Tx only: error message if no wireless connection // 91 error: Tx only: syntax error // 92 error: Tx only: invalid device type // 99 wakeup: Tx only: sends a message on node startup // // ==> Note: // - Interrupts are disabled during ethernet transactions in w5100.h (ethernet library) // (See http://harizanov.com/2012/04/rfm12b-and-arduino-ethernet-with-wiznet5100-chip/) // - Ethernet card and RFM68 board default use the same Slave Select pin (10) on the SPI bus; // To avoid conflict the RFM module is controlled by another SS pin (8). // // // RFM69 Library by Felix Rusu - felix@lowpowerlab.com // Get the RFM69 library at: https://github.com/LowPowerLab // Get the MQQT client library at: https://github.com/knolleary/pubsubclient // // version 1.8 - by Computourist@gmail.com december 2014 // version 1.9 - fixed resubscription after network outage Jan 2015 // version 2.0 - increased payload size; standard device types; trim float values; uptime & version function gateway; Jan 2015 // version 2.1 - implemented string device 72; devices 40-48 handled uniformly Feb 2015 // version 2.2 - changed handling of binary inputs to accomodate Openhab: message for ON and OFF on statechange; // - RSSI value changed to reception strength in the gateway giving a more accurate and uptodate value ; March 2015 // version 2.3 - System device 9 (number of retransmissions) implemented in gateway ; // - Deleted debug option 's' to toggle push interval due to memory constraints; Oct 2015 // version 2.4 - fixed function declaration to comply with new Arduino IDE; // - changed debug routines to comply with memory constraints; Jan 2016
include
include
include
include
// void mqtt_subs(char* topic, byte* payload, unsigned int length);
define DEBUGRADIO // uncomment for radio debugging
//#define DEBUG // uncomment for MQTT debugging
define VERSION "GW V2.4"
// Ethernet settings byte mac[] = { 0xDE, 0xAD, 0xBE, 0xEF, 0xBA, 0xBE }; // MAC address for ethernet byte mqtt_server[] = { 172, 17, 0, 6}; // MQTT broker address (Mosquitto) byte ip[] = { 172, 17, 0, 9 }; // Gateway address (if DHCP fails)
// Wireless settings
define NODEID 1 // unique node ID in the closed radio network; gateway is 1
define RFM_SS 8 // Slave Select RFM69 is connected to pin 8
define NETWORKID 100 // closed radio network ID
//Match frequency to the hardware version of the radio (uncomment one):
define FREQUENCY RF69_433MHZ
//#define FREQUENCY RF69_868MHZ //#define FREQUENCY RF69_915MHZ
define ENCRYPTKEY "QWERGBNMKJHGFDSA" // shared 16-char encryption key is equal on Gateway and nodes
define IS_RFM69HW // uncomment only for RFM69HW! Leave out if you have RFM69W!
define ACK_TIME 50 // max # of ms to wait for an ack
// PIN settings
define MQCON 7 // MQTT Connection indicator
define R_LED 9 // Radio activity indicator
define SERIAL_BAUD 115200
typedef struct { // Radio packet structure max 66 bytes int nodeID; // node identifier int devID; // device identifier 0 is node; 31 is temperature, 32 is humidity int cmd; // read or write long intVal; // integer payload float fltVal; // floating payload char payLoad[32]; // char array payload } Message;
Message mes;
int dest; // destination node for radio packet int DID; // Device ID int error; // Syntax error code long lastMinute = -1; // timestamp last minute long upTime = 0; // uptime in minutes bool Rstat = false; // radio indicator flag bool mqttCon = false; // MQTT broker connection flag bool respNeeded = false; // MQTT message flag in case of radio connection failure bool mqttToSend = false; // message request issued by MQTT request bool promiscuousMode = false; // only receive closed network nodes bool verbose = true; // generate error messages bool IntMess, RealMess, StatMess, StrMess; // types of messages long onMillis; // timestamp when radio LED was turned on char subTopic = "home/rfm_gw/sb/#"; // MQTT subscription topic ; direction is southbound char clientName = "RFM_gateway"; // MQTT system name of gateway char buff_topic[30]; // MQTT publish topic string char buff_mess[32]; // MQTT publish message string
RFM69 radio; EthernetClient ethClient; PubSubClient mqttClient(mqtt_server, 1883, ethClient );
// //============== SETUP //
void setup() {
ifdef DEBUG
endif
ifdef DEBUGRADIO
Serial.begin(SERIAL_BAUD);
endif
radio.setCS(RFM_SS); // change default Slave Select pin for RFM radio.initialize(FREQUENCY,NODEID,NETWORKID); // initialise radio module
ifdef IS_RFM69HW
radio.setHighPower(); // only for RFM69HW!
endif
radio.encrypt(ENCRYPTKEY); // encrypt with shared key radio.promiscuous(promiscuousMode); // listen only to nodes in closed network
pinMode(R_LED, OUTPUT); // set pin of radio indicator pinMode(MQCON, OUTPUT); // set pin for MQTT connection indicator digitalWrite(MQCON, LOW); // switch off MQTT connection indicator digitalWrite(R_LED, LOW); // switch off radio indicator
ifdef DEBUG
endif
ifdef DEBUG
endif
}
ifdef DEBUG
endif
ifdef DEBUG
endif
ifdef DEBUG
endif
ifdef DEBUG
endif
} // end setup
// //============== MAIN //
void loop() {
// CONTROL RADIO LED AND CALCULATE UPTIME //
if (Rstat) { // turn off radio LED after 100 msec if (millis() - onMillis > 100) { Rstat = false; digitalWrite(R_LED, LOW); } }
if (lastMinute != (millis()/60000)) { // another minute passed ? lastMinute = millis()/60000; upTime++; }
// RECEIVE AND SEND MESSAGES //
if (mqttToSend) {sendMsg(dest);} // send MQTT instruction packets over the radio network
if (radio.receiveDone()) { processPacket();} // check for received radio packets and construct MQTT message
if (!mqttClient.loop()) { // check connection MQTT server and process MQTT subscription input mqttCon = 0; digitalWrite(MQCON, LOW); while(mqttCon != 1){ // try to reconnect every 2 seconds mqttCon = mqttClient.connect(clientName); delay(2000); } if(mqttCon){ // Yes, we have a link so, digitalWrite(MQCON, mqttCon); // turn on MQTT link indicator and mqttClient.subscribe(subTopic); // re-subscribe to mqtt topic } } } // end loop
// //============== SENDMSG // // sends messages over the radio network
void sendMsg(int target) {
Rstat = true; // radio indicator on digitalWrite(R_LED, HIGH); // turn on radio LED onMillis = millis(); // store timestamp
int i = 5; // number of transmission retries
while (respNeeded && i>0) { // first try to send packets
if (radio.sendWithRetry(target, (const void*)(&mes), sizeof(mes),5)) { respNeeded = false;
ifdef DEBUGRADIO
endif
}
if (respNeeded && verbose) { // if not succeeded in sending packets after 5 retries sprintf(buff_topic, "home/rfm_gw/nb/node%02d/dev90", target); // construct MQTT topic and message sprintf(buff_mess, "radio lost node %d", target); // for radio loss (device 90) mqttClient.publish(buff_topic,buff_mess); // publish ... respNeeded = false; // reset response needed flag
ifdef DEBUGRADIO
endif
}
if (mqttToSend) mqttToSend = false; // reset send trigger
} // end sendMsg
// //============== PROCESSPACKET // // receives data from the wireless network, parses the contents and constructs MQTT topic and value
void processPacket() { Rstat = true; // set radio indicator flag digitalWrite(R_LED, HIGH); // turn on radio LED onMillis = millis(); // store timestamp
if (radio.DATALEN != sizeof(mes)) // wrong message size means trouble
ifdef DEBUGRADIO
endif
; else // message size OK... { mes = (Message)radio.DATA; // copy radio packet // and construct MQTT northbound topic
ifdef DEBUGRADIO
endif
} DID = mes.devID; // construct MQTT message, according to device ID
IntMess = (DID==0 || DID==1 || DID==7 || DID==9 || (DID>=64 && DID<72)); // Integer in payload message RealMess = (DID==4 || (DID>=48 && DID <64)); // Float in payload message StatMess = (DID==5 || DID==6 || DID==8 || (DID>=16 && DID <32) || (DID>=40 && DID <48)); // Status in payload message StrMess = (DID==3 || DID==72); // String in payload
if (IntMess) { // send integer value load sprintf(buff_mess, "%d",mes.intVal); }
if (RealMess) { // send decimal value dtostrf(mes.fltVal, 10,2, buff_mess); while (buff_mess[0] == 32) { // remove any leading spaces for (int i =0; i<strlen(buff_mess); i++) { buff_mess[i] = buff_mess[i+1]; } } }
if (StatMess) { // put status in payload if (mes.intVal == 1 )sprintf(buff_mess, "ON"); if (mes.intVal == 0 )sprintf(buff_mess, "OFF"); }
if (StrMess) { int i; for (i=0; i<32; i++){ buff_mess[i] = (mes.payLoad[i]); } }
switch (mes.devID)
{ case (2): // RSSI value { sprintf(buff_mess, "%d", radio.RSSI); } break; case (92): // invalid device message { sprintf(buff_mess, "NODE %d invalid device %d", mes.nodeID, mes.intVal); } break; case (99): // wakeup message { sprintf(buff_mess, "NODE %d WAKEUP", mes.nodeID); } break; } // end switch
ifdef DEBUG
Serial.print("MQTT msg: "); Serial.print(buff_topic); Serial.print(": "); Serial.println(buff_mess);
endif
mqttClient.publish(buff_topic,buff_mess); // publish MQTT message in northbound topic
if (radio.ACKRequested()) radio.sendACK(); // reply to any radio ACK requests
} // end processPacket
// //============== MQTT_SUBS // // receive messages from subscribed topics // parse MQTT topic / message and construct radio message // // The values in the MQTT topic/message are converted to corresponding values on the Radio network //
void mqtt_subs(char* topic, byte* payload, unsigned int length) {
ifdef DEBUG
endif
if (strlen(topic) == 27) { // correct topic length ? dest = (topic[19]-'0')_10 + topic[20]-'0'; // extract target node ID from MQTT topic DID = (topic[25]-'0')_10 + topic[26]-'0'; // extract device ID from MQTT topic payload[length] = '\0'; // terminate string with '0' String strPayload = String((char*)payload); // convert to string mes.devID = DID; mes.cmd = 0; // default is 'SET' value if (strPayload == "READ") mes.cmd = 1; // in this case 'READ' value if (length == 0) {error = 2;} // no payload sent else { StatMess = ( DID==5 || DID==6 || DID==8 || (DID>=16 && DID<32)); RealMess = (( DID==0 || DID==2 || DID==3 || DID==4 || (DID>=40 && DID<72))&& mes.cmd==1); IntMess = (DID==1 || DID==7 || DID==9 || (DID >=32 && DID <40)); StrMess = (DID==72);
ifdef DEBUGRADIO
endif
}
else { error = 1;
ifdef DEBUG
endif
if ((error != 0) && verbose) { // in case of syntax error
sprintf(buff_mess, "syntax error %d for node %d", error,dest);
sprintf(buff_topic, "home/rfm_gw/nb/node01/dev91"); // construct MQTT topic and message mqttClient.publish(buff_topic,buff_mess); // publish ...
ifdef DEBUG
Serial.print("Syntax err: "); Serial.println(error);
endif
} // end mqttSubs
Best regards, Thomas