overload publish and chat functions

Author: chavee

MicroGear.cpp

@@ -26,7 +26,7 @@ void msgCallback(char* topic, uint8_t* payload, unsigned int length) {
         }
         else if (strcmp(rtopic,"&resetendpoint") == 0) {
             #ifdef DEBUG_H
-                Serial.println("RESETTTT-EP");
+                Serial.println("to reset endpoint");
             #endif
             if (mg) mg->resetEndpoint();
         }
@@ -89,7 +89,7 @@ int MicroGear::getHTTPReply(Client *client, char *buff, size_t buffsize) {
 }
 
 void MicroGear::resetEndpoint() {
-    writeEEPROM("",EEPROM_ENDPOINTSOFFSET,MAXENDPOINTLENGTH);
+    writeEEPROM("",EEPROM_ENDPOINTSOFFSET,1);
 }
 
 void MicroGear::initEndpoint(Client *client, char* endpoint) {
@@ -562,9 +562,9 @@ bool MicroGear::connect(char* appid) {
 }
 
 bool MicroGear::connected() {
-    if (constate == CLIENT_NOTCONNECT) return CLIENT_NOTCONNECT;
-    else return this->mqttclient->connected();
-    //return this->sockclient->connected();
+    //if (constate == CLIENT_NOTCONNECT) return CLIENT_NOTCONNECT;
+    //else return this->mqttclient->connected();
+    return this->sockclient->connected();
 }
 
 void MicroGear::subscribe(char* topic) {
@@ -583,16 +583,48 @@ void MicroGear::unsubscribe(char* topic) {
     mqttclient->unsubscribe(top);
 }
 
-void MicroGear::publish(char* topic, char* message) {
-    publish(topic, message, false);
-}
-
-void MicroGear::publish(char* topic, char* message, bool retained) {
+bool MicroGear::publish(char* topic, char* message, bool retained) {
     char top[MAXTOPICSIZE] = "/";
 
     strcat(top,appid);
     strcat(top,topic);
-    mqttclient->publish(top, message, retained);
+    return mqttclient->publish(top, message, retained);
+}
+
+bool MicroGear::publish(char* topic, char* message) {
+    return publish(topic, message, false);
+}
+
+bool MicroGear::publish(char* topic, double message, int n) {
+    return publish(topic, message, n, false);
+}
+
+bool MicroGear::publish(char* topic, double message, int n, bool retained) {
+    char mstr[16];
+    dtostrf(message,0,n,mstr);
+    return publish(topic, mstr, retained);
+}
+
+bool MicroGear::publish(char* topic, double message) {
+    return publish(topic, message, 8, false);
+}
+
+bool MicroGear::publish(char* topic, double message, bool retained) {
+    return publish(topic, message, 8, retained);
+}
+
+bool MicroGear::publish(char* topic, int message) {
+    return publish(topic, message, 0, false);
+}
+
+bool MicroGear::publish(char* topic, int message, bool retained) {
+    return publish(topic, message, 0, retained);
+}
+
+bool MicroGear::publish(char* topic, String message, bool retained) {
+    char buff[MAXBUFFSIZE];
+    message.toCharArray(buff,MAXBUFFSIZE);
+    return publish(topic, buff, retained);
 }
 
 /*
@@ -620,10 +652,38 @@ void MicroGear::setAlias(char* gearalias) {
     publish(top,"");
 }
 
-void MicroGear::chat(char* targetgear, char* message) {
+bool MicroGear::chat(char* targetgear, char* message) {
+    bool result;
     char top[MAXTOPICSIZE];
+
     sprintf(top,"/%s/gearname/%s",appid,targetgear);
-    mqttclient->publish(top, message);
+    result = mqttclient->publish(top, message);
+    mqttclient->loop();
+    return result;
+}
+
+bool MicroGear::chat(char* topic, double message, int n) {
+    bool result;
+    char mstr[16];
+
+    dtostrf(message,0,n,mstr);
+    result = chat(topic, mstr);
+    mqttclient->loop();
+    return result;
+}
+
+bool MicroGear::chat(char* topic, double message) {
+    return chat(topic, message, 8);
+}
+
+bool MicroGear::chat(char* topic, int message) {
+    return chat(topic, message, 0);
+}
+
+bool MicroGear::chat(char* topic, String message) {
+    char buff[MAXBUFFSIZE];
+    message.toCharArray(buff,MAXBUFFSIZE);
+    return chat(topic, buff);
 }
 
 int MicroGear::init(char* gearkey,char* gearsecret) {

MicroGear.h

@@ -19,15 +19,13 @@
 
 #define GBPORT 1883
 #define GBSECUREPORT 8883
-//#define CAPORT 8079
-//#define CAFINGERPRINT "57 BA 02 8A 81 CB 6D D3 26 CE B7 21 7E A8 6C B5 DA D8 5A D0"
-
 #define DEFAULTSECUREMODE false
 
 #define MINBACKOFFTIME             10
 #define MAXBACKOFFTIME             10000
 #define MAXENDPOINTLENGTH          200
 #define MAXTOPICSIZE               128
+#define MAXBUFFSIZE               128
 
 #define KEYSIZE                    16
 #define TOKENSIZE                  16
@@ -93,7 +91,7 @@ class MicroGear {
 		bool clientReadln(Client*, char*, size_t);
 		void syncTime(Client*, unsigned long*);
 		void initEndpoint(Client*, char*);
-        void getToken(char*, char*, char*, char*, char*);
+    void getToken(char*, char*, char*, char*, char*);
 
 	public:
 		int constate;
@@ -105,11 +103,27 @@ class MicroGear {
 		void useTLS(bool);
 		bool connect(char*);
 		bool connected();
-		void publish(char*, char*);
-		void publish(char*, char*, bool);
+
+		bool publish(char*, char*);
+		bool publish(char*, char*, bool);
+
+		bool publish(char*, double);
+		bool publish(char*, double, bool);
+		bool publish(char*, double, int);
+		bool publish(char*, double, int, bool);
+		bool publish(char*, int);
+		bool publish(char*, int, bool);
+		bool publish(char*, String);
+		bool publish(char*, String, bool);
+
+		bool chat(char*, char*);
+		bool chat(char*, int);
+		bool chat(char*, double);
+		bool chat(char*, double, int);
+		bool chat(char*, String);
+
 		void subscribe(char*);
 		void unsubscribe(char*);
-		void chat(char*, char*);
 		int state();
 		void loop();
         void resetToken();