Diff: main.cpp

Revision:

21:c5f6350a292d

Parent:

20:3858e42b0cd3

--- a/main.cpp	Wed Nov 25 07:07:31 2015 +0000
+++ b/main.cpp	Wed Dec 02 01:54:31 2015 +0000
@@ -1,15 +1,33 @@
+/*
+ * ennoForMbed.c
+ *
+ *  Created on: 2015年11月20日
+ *      Author: v-chawei
+ */
 #include "mbed.h"
+#include "MQTTClient.h"
 #include "enno_api.h"
 
+
 #define MQTTCLIENT_QOS2 1
 DigitalOut led1(LED1);
 DigitalOut led2(LED2);
 DigitalOut led3(LED3);
 DigitalOut led4(LED4);
 
-int main(int argc, char* argv[]){
 
+int main(int argc, char* argv[]){
+    Error_t rc = NONE_ERROR;
     float version = 0.5;
+    char *ennoCommandPrefix = "SiteWhere/commands/";
+    char *ennoSystemPrefix = "SiteWhere/system/";
+    char *ennoSystemInbound = "SiteWhere/input/protobuf";
+    char *deviceId = "enno-xbed-test-30";
+    char *topicType = "command";
+    char *hostURL = "139.217.10.99";
+    int port = 1883;
+    char *appKey = NULL;
+
     led1=1;led2=1;led3=1;led4=1;                    //light on
     wait(0.5);
     led1=!led1;led2=!led2;led3=!led3;led4=!led4;    //light off
@@ -20,7 +38,51 @@
 
     printf("HelloMQTT: version is %f\n", version);
 
-    return 0;
+    printf("Connecting to enno server %s:%d...\n",hostURL,port);
+
+    rc = enno_connect(hostURL, port, appKey);
+    if (NONE_ERROR != rc) {
+        printf("Error(%d) on connecting.\n", rc);
+        exit(rc);
+    }
+    printf("connected.\n");
+
+    printf("Subscribing system topic...");
+    char systemTopic[64];
+    char commandTopic[64];
+    strcpy(systemTopic,ennoSystemPrefix);
+    strcat(systemTopic,deviceId);
+
+    rc = enno_subscribe(systemTopic, topicType);
+    if (NONE_ERROR != rc) {
+       printf("Error on subscrie system topic.");
+       exit(rc);
+    }
+   printf("subscribed.\n");
+
+    printf("Send device registeration...\n");
+
+    EnnoMessages Messages_enno = EnnoMessagesDefault;
+    Messages_enno.Register.pHardwareId = deviceId;
+    Messages_enno.messageType = 'R';
+    rc = enno_publish(ennoSystemInbound, &Messages_enno);
+    if (NONE_ERROR != rc) {
+        printf("Error on Registering device.\n");
+        exit(rc);
+    }
+
+    printf("sent.\n");
+    Messages_enno.messageType = 'L';
+    // main loop
+    while (NONE_ERROR == rc) {
+        enno_loop(1000);
+    //  sleep(1);
+        rc = enno_publish(ennoSystemInbound, &Messages_enno);
+        led3=!led3;
+        printf("Location updated.\n");
+    }
+
+    return rc;
 }