Diff: src/CloudDataHandler/CloudDataHandler.cpp

Revision:

26:6bd4868171c7

Parent:

20:653923c2f37a

Child:

27:38205cebc3da

--- a/src/CloudDataHandler/CloudDataHandler.cpp	Thu Sep 08 15:32:50 2016 +0000
+++ b/src/CloudDataHandler/CloudDataHandler.cpp	Thu Sep 08 17:55:32 2016 +0000
@@ -1,12 +1,38 @@
 #include "CloudDataHandler.h"
+#include "MTSLog.h"
 #include <stdio.h>
+#include "mDot.h"
+#include <vector>
 #include "rtos.h"
+#include "global.h"
 
 void CloudDataHandler(void const *args)
 {
+    int32_t ret;
+
     printf("\r%s has started...\n", __func__);
-    
+
     while ( true ) {
-        
+
+        std::string tmp_buffer("{\"mtype\":\"20\"}");
+        std::vector<uint8_t> data(tmp_buffer.begin(), tmp_buffer.end());
+
+        // send the data to the gateway
+        if ((ret = GLOBAL_mdot->send(data)) != mDot::MDOT_OK)
+            logError("failed to send", ret, mDot::getReturnCodeString(ret).c_str());
+        else {
+            logInfo("Sent to gateway: %s", tmp_buffer.c_str());
+            std::vector<uint8_t> rcvData(256);
+            rcvData.clear();
+            if ((ret = GLOBAL_mdot->recv(rcvData)) == mDot::MDOT_OK) {
+                if (!rcvData.empty()) {
+                    std::string rcv_string(rcvData.begin(), rcvData.end()); 
+                    logInfo("Received Data: %s", rcv_string.c_str());
+//                   if( edIotParse( rcvData, &parseObj ) == true ) {
+//                       edIotProcessIn( &parseObj, &execEnv, dot );
+                }
+            }
+        }
+        Thread::wait(5000);
     }
 }
\ No newline at end of file