Diff: main.cpp

Revision:

23:d508f2806faa

Parent:

21:a68bd76740f9

Child:

24:4b8390b87ab3

--- a/main.cpp	Mon Sep 11 16:43:49 2017 +0200
+++ b/main.cpp	Fri Jan 05 17:51:46 2018 +0000
@@ -1,139 +1,127 @@
-/*******************************************************************************
- * Copyright (c) 2014, 2015 IBM Corp.
- *
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * and Eclipse Distribution License v1.0 which accompany this distribution.
- *
- * The Eclipse Public License is available at
- *    http://www.eclipse.org/legal/epl-v10.html
- * and the Eclipse Distribution License is available at
- *   http://www.eclipse.org/org/documents/edl-v10.php.
- *
- * Contributors:
- *    Ian Craggs - initial API and implementation and/or initial documentation
- *    Ian Craggs - make sure QoS2 processing works, and add device headers
- *******************************************************************************/
-
- /**
-  This is a sample program to illustrate the use of the MQTT Client library
-  on the mbed platform.  The Client class requires two classes which mediate
-  access to system interfaces for networking and timing.  As long as these two
-  classes provide the required public programming interfaces, it does not matter
-  what facilities they use underneath. In this program, they use the mbed
-  system libraries.
-
- */
-
  // change this to 1 to output messages to LCD instead of serial
-#define USE_LCD 0
-
-#if USE_LCD
-#include "C12832.h"
-
-// the actual pins are defined in mbed_app.json and can be overridden per target
-C12832 lcd(LCD_MOSI, LCD_SCK, LCD_MISO, LCD_A0, LCD_NCS);
-
-#define logMessage lcd.cls();lcd.printf
-
-#else
-
 #define logMessage printf
-
-#endif
-
 #define MQTTCLIENT_QOS2 1
 
+#include <string>
+#include "mbed.h"
 #include "easy-connect.h"
 #include "MQTTNetwork.h"
 #include "MQTTmbed.h"
 #include "MQTTClient.h"
+#include "TCPSocket.h"
+#include "DHT22.h"
 
-int arrivedcount = 0;
+#define WIFI_HW_RESET_PIN D4
+
+#define MQTT_BROKER_ADDR "192.168.0.10"
+#define MQTT_BROKER_PORT 1883
 
+DigitalOut wifiHwResetPin(WIFI_HW_RESET_PIN);
+DigitalOut led2(LED2);
+DHT22 dht22(D7);
+Serial pc(USBTX, USBRX, 115200);
+
+volatile bool flag = false;
+
+Mutex mqttMtx;
+
+char* topic_toGW = "toGW";
+char* topic_fromGW = "toNUCLEO";
 
 void messageArrived(MQTT::MessageData& md)
 {
     MQTT::Message &message = md.message;
-    logMessage("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id);
-    logMessage("Payload %.*s\r\n", message.payloadlen, (char*)message.payload);
-    ++arrivedcount;
+    //logMessage("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id);
+    //logMessage("Payload %.*s\r\n", message.payloadlen, (char*)message.payload);
+    
+    pc.printf("Subscribe from GW: %.*s\r\n", message.payloadlen, (char*)message.payload);
+    char fwdTarget = ((char*)message.payload)[0];
+    switch(fwdTarget){
+        case '0':
+            led2 = 0;
+            pc.printf("LED Turn Off\r\n\r\n");
+            break;
+        case '1':
+            led2 = 1;
+            pc.printf("LED Turn On\r\n");
+            break;
+        default:
+            pc.printf("Unknown MQTT message\r\n");
+            break;
+    }
 }
 
+double getTemp(void){
+    double temp;
+    if(dht22.sample()){
+        temp=dht22.getTemperature()/10.0;
+        pc.printf("temperature: %3.1f\r\n",temp);
+    } else{
+        temp=-999;
+        pc.printf("Checksum error\r\n");
+    }
+    return temp;
+}
 
 int main(int argc, char* argv[])
 {
-    float version = 0.6;
-    char* topic = "mbed-sample";
-
-    logMessage("HelloMQTT: version is %.2f\r\n", version);
-
-    NetworkInterface* network = easy_connect(true);
-    if (!network) {
+    float version = 0.5;
+    NetworkInterface* net = easy_connect(true);
+    if (!net) {
+        pc.printf("Error in easy connection\r\n");
         return -1;
     }
+    logMessage("HelloMQTT: version is %.2f\r\n", version);
 
-    MQTTNetwork mqttNetwork(network);
-
+    wait(0.2);
+    pc.printf("Resetting ESP8266 Hardware...\r\n");
+    wifiHwResetPin = 0;
+    wait_ms(500);
+    wifiHwResetPin = 1;
+    
+    MQTTNetwork mqttNetwork(net);
     MQTT::Client<MQTTNetwork, Countdown> client(mqttNetwork);
 
-    const char* hostname = "m2m.eclipse.org";
-    int port = 1883;
-    logMessage("Connecting to %s:%d\r\n", hostname, port);
-    int rc = mqttNetwork.connect(hostname, port);
+    logMessage("Connecting to %s:%d\r\n", MQTT_BROKER_ADDR, MQTT_BROKER_PORT);
+    int rc = mqttNetwork.connect(MQTT_BROKER_ADDR, MQTT_BROKER_PORT);
     if (rc != 0)
-        logMessage("rc from TCP connect is %d\r\n", rc);
+        logMessage("rc from GW connect is %d\r\n", rc);
 
     MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
     data.MQTTVersion = 3;
-    data.clientID.cstring = "mbed-sample";
+    data.clientID.cstring = "mbed-sample-Hyoeun";
     data.username.cstring = "testuser";
     data.password.cstring = "testpassword";
     if ((rc = client.connect(data)) != 0)
         logMessage("rc from MQTT connect is %d\r\n", rc);
 
-    if ((rc = client.subscribe(topic, MQTT::QOS2, messageArrived)) != 0)
+    if ((rc = client.subscribe(topic_fromGW, MQTT::QOS2, messageArrived)) != 0)
         logMessage("rc from MQTT subscribe is %d\r\n", rc);
 
-    MQTT::Message message;
-
-    // QoS 0
-    char buf[100];
-    sprintf(buf, "Hello World!  QoS 0 message from app version %f\r\n", version);
-    message.qos = MQTT::QOS0;
-    message.retained = false;
-    message.dup = false;
-    message.payload = (void*)buf;
-    message.payloadlen = strlen(buf)+1;
-    rc = client.publish(topic, message);
-    while (arrivedcount < 1)
-        client.yield(100);
+    int count = 0;
+    while(1){
+        Thread::wait(1000);
+        char buf[100];
+        MQTT::Message message;
+        
+        if(count == 5){
+            pc.printf("Publish: toGW\r\n");
+            sprintf(buf, "{\"temp\": %3.1f}", getTemp());
+            message.qos = MQTT::QOS0;
+            message.retained = false;
+            message.dup = false;
+            message.payload = (void*)buf;
+            message.payloadlen = strlen(buf)+1;
+            pc.printf("%s",message);
+            mqttMtx.lock();
+            rc = client.publish(topic_toGW, message);
+            mqttMtx.unlock();
+            count = 0;
+            pc.printf("\r\n");
+        }
+        if(!client.isConnected()) NVIC_SystemReset();
+        client.yield(10);
+        count++;
+    }
+}
 
-    // QoS 1
-    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);
-    while (arrivedcount < 2)
-        client.yield(100);
-
-    // QoS 2
-    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);
-    while (arrivedcount < 3)
-        client.yield(100);
-
-    if ((rc = client.unsubscribe(topic)) != 0)
-        logMessage("rc from unsubscribe was %d\r\n", rc);
-
-    if ((rc = client.disconnect()) != 0)
-        logMessage("rc from disconnect was %d\r\n", rc);
-
-    mqttNetwork.disconnect();
-
-    logMessage("Version %.2f: finish %d msgs\r\n", version, arrivedcount);
-
-    return 0;
-}