fix warnings from compiler and move defines to header files
This commit is contained in:
@@ -119,12 +119,6 @@ uint8_t local_ip[] = {192, 168, 178, 11};
|
|||||||
//replace with ethernet shield mac. It's mandatory every device is assigned a unique mac. Is ignored on Yun
|
//replace with ethernet shield mac. It's mandatory every device is assigned a unique mac. Is ignored on Yun
|
||||||
uint8_t mac[] = { 0xA2, 0xAE, 0xAD, 0xA0, 0xA0, 0xA2 };
|
uint8_t mac[] = { 0xA2, 0xAE, 0xAD, 0xA0, 0xA0, 0xA2 };
|
||||||
|
|
||||||
///////////////////////////////////////////////////////////////////
|
|
||||||
#define MQTT_AUTH_REQUIRED // if your broker has anonymous access uncomment
|
|
||||||
#define MQTT_USER "username" // username on MQTT broker
|
|
||||||
#define MQTT_PWD "pwd" // password for MQTT username above
|
|
||||||
//////////////////////////////////////////////////////////////////
|
|
||||||
|
|
||||||
#if defined remote_ip && defined remote_host
|
#if defined remote_ip && defined remote_host
|
||||||
#error "cannot define both remote_ip and remote_host at the same time!"
|
#error "cannot define both remote_ip and remote_host at the same time!"
|
||||||
#endif
|
#endif
|
||||||
@@ -152,6 +146,10 @@ MyMessage msg;
|
|||||||
char convBuf[MAX_PAYLOAD * 2 + 1];
|
char convBuf[MAX_PAYLOAD * 2 + 1];
|
||||||
uint8_t buffsize;
|
uint8_t buffsize;
|
||||||
char buffer[MQTT_MAX_PACKET_SIZE];
|
char buffer[MQTT_MAX_PACKET_SIZE];
|
||||||
|
char user[sizeof(MQTT_USER)]; // introduced the bufs to get rid of compiler warnings
|
||||||
|
char pwd[sizeof(MQTT_PWD)]; // see above
|
||||||
|
char connID[sizeof(MQTT_CONN_ID)]; // see above
|
||||||
|
char mqttTopicMask[sizeof(MQTT_TOPIC_MASK)]; // see above
|
||||||
|
|
||||||
////////////////////////////////////////////////////////////////
|
////////////////////////////////////////////////////////////////
|
||||||
|
|
||||||
@@ -186,6 +184,9 @@ MySensor gw(transport, hw
|
|||||||
*/
|
*/
|
||||||
void setup()
|
void setup()
|
||||||
{
|
{
|
||||||
|
strcpy(connID,MQTT_CONN_ID);
|
||||||
|
strcpy(mqttTopicMask,MQTT_TOPIC_MASK);
|
||||||
|
|
||||||
countRx = 0;
|
countRx = 0;
|
||||||
countTx = 0;
|
countTx = 0;
|
||||||
countErr = 0;
|
countErr = 0;
|
||||||
@@ -204,12 +205,14 @@ void loop()
|
|||||||
{
|
{
|
||||||
if (!client.connected())
|
if (!client.connected())
|
||||||
{
|
{
|
||||||
client.connect("MySensor"
|
|
||||||
#ifdef MQTT_AUTH_REQUIRED
|
#ifdef MQTT_AUTH_REQUIRED
|
||||||
,MQTT_USER,MQTT_PWD
|
strcpy(user, MQTT_USER);
|
||||||
|
strcpy(pwd, MQTT_PWD);
|
||||||
|
client.connect(connID, user,pwd);
|
||||||
|
#else
|
||||||
|
client.connect(connID);
|
||||||
#endif
|
#endif
|
||||||
);
|
client.subscribe(mqttTopicMask);
|
||||||
client.subscribe(MQTT_TOPIC_MASK);
|
|
||||||
}
|
}
|
||||||
client.loop();
|
client.loop();
|
||||||
gw.process();
|
gw.process();
|
||||||
@@ -297,7 +300,7 @@ void sendMQTT(const MyMessage &inMsg)
|
|||||||
{
|
{
|
||||||
strcpy_P(buffer, mqtt_prefix);
|
strcpy_P(buffer, mqtt_prefix);
|
||||||
buffsize += strlen_P(mqtt_prefix);
|
buffsize += strlen_P(mqtt_prefix);
|
||||||
buffsize += sprintf(&buffer[buffsize], "/%i/255/BATTERY_LEVEL\0", msg.sender );
|
buffsize += sprintf(&buffer[buffsize], "/%i/255/BATTERY_LEVEL", msg.sender );
|
||||||
msg.getString(convBuf);
|
msg.getString(convBuf);
|
||||||
#ifdef DEBUG
|
#ifdef DEBUG
|
||||||
Serial.print("publish: ");
|
Serial.print("publish: ");
|
||||||
@@ -311,7 +314,7 @@ void sendMQTT(const MyMessage &inMsg)
|
|||||||
{
|
{
|
||||||
strcpy_P(buffer, mqtt_prefix);
|
strcpy_P(buffer, mqtt_prefix);
|
||||||
buffsize += strlen_P(mqtt_prefix);
|
buffsize += strlen_P(mqtt_prefix);
|
||||||
buffsize += sprintf(&buffer[buffsize], "/%i/255/SKETCH_NAME\0", msg.sender );
|
buffsize += sprintf(&buffer[buffsize], "/%i/255/SKETCH_NAME", msg.sender );
|
||||||
msg.getString(convBuf);
|
msg.getString(convBuf);
|
||||||
#ifdef DEBUG
|
#ifdef DEBUG
|
||||||
Serial.print("publish: ");
|
Serial.print("publish: ");
|
||||||
@@ -325,7 +328,7 @@ void sendMQTT(const MyMessage &inMsg)
|
|||||||
{
|
{
|
||||||
strcpy_P(buffer, mqtt_prefix);
|
strcpy_P(buffer, mqtt_prefix);
|
||||||
buffsize += strlen_P(mqtt_prefix);
|
buffsize += strlen_P(mqtt_prefix);
|
||||||
buffsize += sprintf(&buffer[buffsize], "/%i/255/SKETCH_VERSION\0", msg.sender );
|
buffsize += sprintf(&buffer[buffsize], "/%i/255/SKETCH_VERSION", msg.sender );
|
||||||
msg.getString(convBuf);
|
msg.getString(convBuf);
|
||||||
#ifdef DEBUG
|
#ifdef DEBUG
|
||||||
Serial.print("publish: ");
|
Serial.print("publish: ");
|
||||||
@@ -346,7 +349,7 @@ void sendMQTT(const MyMessage &inMsg)
|
|||||||
msg.type = VAR_TOTAL; // If type > defined types set to unknown.
|
msg.type = VAR_TOTAL; // If type > defined types set to unknown.
|
||||||
strcpy_P(buffer, mqtt_prefix);
|
strcpy_P(buffer, mqtt_prefix);
|
||||||
buffsize += strlen_P(mqtt_prefix);
|
buffsize += strlen_P(mqtt_prefix);
|
||||||
buffsize += sprintf(&buffer[buffsize], "/%i/%i/V_%s\0", msg.sender,
|
buffsize += sprintf(&buffer[buffsize], "/%i/%i/V_%s", msg.sender,
|
||||||
msg.sensor, getType(convBuf, &VAR_Type[msg.type]));
|
msg.sensor, getType(convBuf, &VAR_Type[msg.type]));
|
||||||
msg.getString(convBuf);
|
msg.getString(convBuf);
|
||||||
#ifdef DEBUG
|
#ifdef DEBUG
|
||||||
@@ -523,7 +526,7 @@ void processMQTTMessage(char* topic, byte* payload,
|
|||||||
setTime(epoch);
|
setTime(epoch);
|
||||||
}
|
}
|
||||||
#ifdef DEBUG
|
#ifdef DEBUG
|
||||||
Serial.print("Time recieved ");
|
Serial.print("Time received ");
|
||||||
Serial.println(epoch);
|
Serial.println(epoch);
|
||||||
#endif
|
#endif
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#define MY_HMAC_KEY 0x10,0x23,0x0A,0x78,0x77,0x35,0xB0,0x01,0x70,0x47,0xF1,0xDE,0x21,0x94,0x94,0x67,0xEE,0x36,0x72,0x42,0x97,0xBB,0xA0,0x0A,0x0F,0x09,0x03,0xE2,0x00,0x31,0xE4,0x41/*
|
/*
|
||||||
The MySensors library adds a new layer on top of the RF24 library.
|
The MySensors library adds a new layer on top of the RF24 library.
|
||||||
It handles radio network routing, relaying and ids.
|
It handles radio network routing, relaying and ids.
|
||||||
Created by Henrik Ekblad <henrik.ekblad@gmail.com>
|
Created by Henrik Ekblad <henrik.ekblad@gmail.com>
|
||||||
@@ -27,6 +27,13 @@ version 2 as published by the Free Software Foundation.
|
|||||||
#define MQTT_CMD_SET "set" // command (see MQTT_TOPIC_MASK); mapped to C_SET command type of sensor network
|
#define MQTT_CMD_SET "set" // command (see MQTT_TOPIC_MASK); mapped to C_SET command type of sensor network
|
||||||
#define MQTT_CMD_GET "get" // command (see MQTT_TOPIC_MASK); mapped to C_REQ command type of sensor network
|
#define MQTT_CMD_GET "get" // command (see MQTT_TOPIC_MASK); mapped to C_REQ command type of sensor network
|
||||||
|
|
||||||
|
|
||||||
|
#define MQTT_AUTH_REQUIRED // if your broker has anonymous access uncomment
|
||||||
|
#define MQTT_USER "username" // username on MQTT broker
|
||||||
|
#define MQTT_PWD "pwd" // password for MQTT username above
|
||||||
|
#define MQTT_CONN_ID "MySensors" // passed as id to the MQTT broker
|
||||||
|
|
||||||
|
|
||||||
// NOTE above : Beware to check if there is any length on payload in your incommingMessage code:
|
// NOTE above : Beware to check if there is any length on payload in your incommingMessage code:
|
||||||
// Example: if (msg.type==V_LIGHT && strlen(msg.getString())>0) otherwise the code might do strange things.
|
// Example: if (msg.type==V_LIGHT && strlen(msg.getString())>0) otherwise the code might do strange things.
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user