Diff: main.cpp

Revision:

20:568d04eb3d63

Parent:

19:9dfb938f07eb

Child:

21:f08f17225c7c

diff -r 9dfb938f07eb -r 568d04eb3d63 main.cpp
--- a/main.cpp	Thu Mar 07 08:55:54 2019 +0000
+++ b/main.cpp	Fri Mar 08 04:51:18 2019 +0000
@@ -4,17 +4,20 @@
 #include "MbedJSONValue.h"
 char buf[100];
 
-MQTTESP8266 ipstack(D1, D0, D10, "BHNTG1682GFFE2","220960b5"); // change to match your wifi access point
+MQTTESP8266 ipstack(D1, D0, D10, "Sidsap10","Arduino111"); // change to match your wifi access point
 float version = 0.47;
 char* topic = "k64";
 char* topic2 = "k64rec";
 char* topic3 = "bulb";
     
 char* key2 = "key";
-char* hostname = "192.168.0.6"; // Ip 
+char* hostname = "192.168.43.87"; // Ip 
 int port = 1883;
 int rc = ipstack.connect(hostname, port);
+unsigned long previousTime = 0;        // will store last time LED was updated
 
+// constants won't change:
+const long interval = 20;
 MQTT::Client<MQTTESP8266, Countdown> client = MQTT::Client<MQTTESP8266, Countdown>(ipstack);
 MbedJSONValue demo;
 int arrivedcount = 0;
@@ -32,7 +35,7 @@
 void subscribeCallback(MQTT::MessageData& md)
 {
     MQTT::Message &message = md.message;
-    printf("Message received: qos %d, retained %d, dup %d, packetid %d\n", message.qos, message.retained, message.dup, message.id);
+    printf("Message received: qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id);
     
     printf("%s",(char*)message.payload);
     printf("\r\n");
@@ -54,27 +57,27 @@
        message.payload = (void*)buf;
        message.payloadlen = strlen(buf)+1;
        rc = client.publish(topic3, message);
-       printf("if condition checked, its cloudy\n");
+       printf("if condition checked, its cloudy\r\n");
     }
     else  if ( !(someString.find(clearsky)) )
     {  
-       sprintf(buf, "dCglDR-G9WoQUiig0XMNhOV4ozIEIVu3rWdBh5IlQ7d,clearsky %s\n", key2);
+       sprintf(buf, "dCglDR-G9WoQUiig0XMNhOV4ozIEIVu3rWdBh5IlQ7d,clearsky %s\r\n", key2);
        message.payload = (void*)buf;
        message.payloadlen = strlen(buf)+1;
        rc = client.publish(topic3, message);
-       printf("if condition checked, its clear\n");
+       printf("if condition checked, its clear\r\n");
     }
     else  if ( !(someString.find(snow)) )
     {  
-       sprintf(buf, "dCglDR-G9WoQUiig0XMNhOV4ozIEIVu3rWdBh5IlQ7d,snow %s\n",key2);
+       sprintf(buf, "dCglDR-G9WoQUiig0XMNhOV4ozIEIVu3rWdBh5IlQ7d,snow %s\r\n",key2);
        message.payload = (void*)buf;
        message.payloadlen = strlen(buf)+1;
        rc = client.publish(topic3, message);
-       printf("if condition checked, its snowy\n");
+       printf("if condition checked, its snowy\r\n");
     }
     else
     {
-        printf("went into else\n");
+        printf("went into else\r\n");
     }
 
 }
@@ -82,14 +85,14 @@
 int main(int argc, char* argv[])
 {  
     wait (1);
-    printf("Starting\n");
+    printf("Starting\r\n");
     
-    printf("Version is %f\n", version);
+    printf("Version is %f\r\n", version);
 
     
 
     if (rc != 0)
-        printf("rc from TCP connect is %d\n", rc);
+        printf("rc from TCP connect is %d\r\n", rc);
 
     MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
     //data.MQTTVersion = 3;
@@ -98,33 +101,39 @@
     //data.password.cstring = "testpassword";
     
     if ((rc = client.connect(data)) != 0)
-        printf("rc from MQTT connect is %d\n", rc);
+        printf("rc from MQTT connect is %d\r\n", rc);
 
     if ((rc = client.subscribe(topic2, MQTT::QOS1, subscribeCallback)) != 0)
-        printf("Recv'd from MQTT subscribe is %d\n", rc);
+        printf("Recv'd from MQTT subscribe is %d\r\n", rc);
 
     MQTT::Message message;
     // QoS 0
-
-    sprintf(buf, "fa02d31610ce9ea0de15b22bb2fe279d, %s\n", key2);
+    time_t seconds = time(NULL);
+     
+    sprintf(buf, "fa02d31610ce9ea0de15b22bb2fe279d, %s\r\n", key2);
     message.qos = MQTT::QOS0;
     message.retained = false;
     message.dup = false;
     message.payload = (void*)buf;
     message.payloadlen = strlen(buf)+1;
+    
+    
     rc = client.publish(topic, message);
     wait(5);
     /*
-    sprintf(buf, "dCglDR-G9WoQUiig0XMNhOV4ozIEIVu3rWdBh5IlQ7d, %s\n", key2);
+    sprintf(buf, "dCglDR-G9WoQUiig0XMNhOV4ozIEIVu3rWdBh5IlQ7d, %s\r\n", key2);
     message.payload = (void*)buf;
     message.payloadlen = strlen(buf)+1;
     rc = client.publish(topic2, message);
     */
+    
     while (arrivedcount < 10)
         client.yield(100);
+    
+     
   /*
     // QoS 1
-    sprintf(buf, "Hello World!  QoS 1 message from app version %f\n", version);
+    sprintf(buf, "Hello World!  QoS 1 message from app version %f\r\n", version);
     message.qos = MQTT::QOS1;
     message.payloadlen = strlen(buf)+1;
     rc = client.publish(topic, message);
@@ -132,7 +141,7 @@
         client.yield(100);
     
     // QoS 2
-    sprintf(buf, "Hello World!  QoS 2 message from app version %f\n", version);
+    sprintf(buf, "Hello World!  QoS 2 message from app version %f\r\n", version);
     message.qos = MQTT::QOS2;
     message.payloadlen = strlen(buf)+1;
     rc = client.publish(topic, message);
@@ -142,7 +151,7 @@
     // n * QoS 2
     
     for (int i = 1; i <= 10; ++i) {
-        sprintf(buf, "Hello World!  QoS 2 message number %d from app version %f\n", i, version);
+        sprintf(buf, "Hello World!  QoS 2 message number %d from app version %f\r\n", i, version);
         message.qos = MQTT::QOS2;
         message.payloadlen = strlen(buf)+1;
         rc = client.publish(topic, message);
@@ -152,13 +161,13 @@
     */
     
     if ((rc = client.unsubscribe(topic)) != 0)
-        printf("rc from unsubscribe was %d\n", rc);
+        printf("rc from unsubscribe was %d\r\n", rc);
 
     if ((rc = client.disconnect()) != 0)
-        printf("rc from disconnect was %d\n", rc);
+        printf("rc from disconnect was %d\r\n", rc);
 
     //ipstack.disconnect();
-    //printf("Finishing with %d messages received\n", arrivedcount);
+    //printf("Finishing with %d messages received\r\n", arrivedcount);
 
     return 0;
 }