Revision 1:cca24408264b, committed 2018-01-02

Comitter:

fbdp1202

Date:

Tue Jan 02 07:54:50 2018 +0000

Parent:

0:0681e205d0e9

Child:

2:88961540141d

Commit message:

reference in easy-connect and DHT library

Changed in this revision

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/DHT.lib	Tue Jan 02 07:54:50 2018 +0000
@@ -0,0 +1,1 @@
+https://developer.mbed.org/users/david8251/code/DHT/#b2a9b214a03f

--- a/mbed_app.json	Wed Feb 15 21:18:58 2017 +0100
+++ b/mbed_app.json	Tue Jan 02 07:54:50 2018 +0000
@@ -2,7 +2,7 @@
     "config": {
         "network-interface":{
             "help": "options are ETHERNET, WIFI_ESP8266, WIFI_ODIN, MESH_LOWPAN_ND, MESH_THREAD",
-            "value": "ETHERNET"
+            "value": "WIFI_ESP8266"
         },
         "mesh_radio_type": {
         	"help": "options are ATMEL, MCR20",
@@ -10,20 +10,20 @@
         },
         "esp8266-tx": {
             "help": "Pin used as TX (connects to ESP8266 RX)",
-            "value": "D1"
+            "value": "D8"
         },
         "esp8266-rx": {
             "help": "Pin used as RX (connects to ESP8266 TX)",
-            "value": "D0"
+            "value": "D2"
         },
         "esp8266-debug": {
             "value": true
         },
         "wifi-ssid": {
-            "value": "\"SSID\""
+            "value": "\"netlab3\""
         },
         "wifi-password": {
-            "value": "\"Password\""
+            "value": "\"netlab3@414\""
         },
         "button": {
             "help": "Pin which you'll use as button (can be overriden per target below)",

--- a/source/main.cpp	Wed Feb 15 21:18:58 2017 +0100
+++ b/source/main.cpp	Tue Jan 02 07:54:50 2018 +0000
@@ -1,136 +1,70 @@
-/*
- * PackageLicenseDeclared: Apache-2.0
- * Copyright (c) 2017 ARM Limited
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#include <string>
+#include <string.h>
 #include "mbed.h"
 #include "easy-connect.h"
-#include "sn_nsdl.h"
-#include "sn_coap_protocol.h"
-#include "sn_coap_header.h"
+#include "TCPSocket.h"
+#include "DHT.h"
 
-UDPSocket socket;           // Socket to talk CoAP over
-Thread recvfromThread;      // Thread to receive messages over CoAP
-
-struct coap_s* coapHandle;
-coap_version_e coapVersion = COAP_VERSION_1;
+DHT sensor(D7,DHT22);
 
-// CoAP HAL
-void* coap_malloc(uint16_t size) {
-    return malloc(size);
-}
+#define SERVER_IP "192.168.0.6"
+#define SERVER_PORT 50000
+
+Serial pc(USBTX, USBRX);
 
-void coap_free(void* addr) {
-    free(addr);
-}
-
-// tx_cb and rx_cb are not used in this program
-uint8_t coap_tx_cb(uint8_t *a, uint16_t b, sn_nsdl_addr_s *c, void *d) {
-    printf("coap tx cb\n");
-    return 0;
-}
+int main(){
+    int error = 0;
+    pc.baud(115200);
+    pc.printf("\r\n Simple HTTP example over ESP8266\r\n\r\n");
 
-int8_t coap_rx_cb(sn_coap_hdr_s *a, sn_nsdl_addr_s *b, void *c) {
-    printf("coap rx cb\n");
-    return 0;
-}
-
-// Main function for the recvfrom thread
-void recvfromMain() {
-    SocketAddress addr;
-    uint8_t* recv_buffer = (uint8_t*)malloc(1280); // Suggested is to keep packet size under 1280 bytes
-
-    nsapi_size_or_error_t ret;
-
-    while ((ret = socket.recvfrom(&addr, recv_buffer, 1280)) >= 0) {
-        // to see where the message came from, inspect addr.get_addr() and addr.get_port()
+    pc.printf("\r\nConnecting...\r\n");
+    NetworkInterface *network = easy_connect(true);
+    while(!network){
+        pc.printf("Error: Cannot connect to the network\r\n");
+        wait(1);
+        network = easy_connect(true);
+    }
+    
+    pc.printf("Success\r\n\r\n");
+    pc.printf("MAC: %s\r\n", network->get_mac_address());
+    pc.printf("IP: %s\r\n", network->get_ip_address());
+    pc.printf("Netmask: %s\r\n", network->get_netmask());
+    pc.printf("Gateway: %s\r\n", network->get_gateway());
+    pc.printf("RSSI: %d\r\n\r\n", wifi.get_rssi());
 
-        printf("Received a message of length '%d'\n", ret);
-
-        sn_coap_hdr_s* parsed = sn_coap_parser(coapHandle, ret, recv_buffer, &coapVersion);
-
-        // We know the payload is going to be a string
-        std::string payload((const char*)parsed->payload_ptr, parsed->payload_len);
+    pc.printf("\r\nDone\r\n");
 
-        printf("\tmsg_id:           %d\n", parsed->msg_id);
-        printf("\tmsg_code:         %d\n", parsed->msg_code);
-        printf("\tcontent_format:   %d\n", parsed->content_format);
-        printf("\tpayload_len:      %d\n", parsed->payload_len);
-        printf("\tpayload:          %s\n", payload.c_str());
-        printf("\toptions_list_ptr: %p\n", parsed->options_list_ptr);
-    }
-
-    free(recv_buffer);
+    TCPSocket socket;
 
-    printf("UDPSocket::recvfrom failed, error code %d. Shutting down receive thread.\n", ret);
-}
-
-int main() {
-    NetworkInterface *network = easy_connect(true);
-    if (!network) {
-        printf("Cannot connect to the network, see serial output");
-        return 1;
-    }
-
-    printf("Connected to the network. Opening a socket...\n");
+    socket.open(network);
+    socket.connect(SERVER_IP, SERVER_PORT);
 
-    // Open a socket on the network interface
-    socket.open(network);
-
-    // Initialize the CoAP protocol handle, pointing to local implementations on malloc/free/tx/rx functions
-    coapHandle = sn_coap_protocol_init(&coap_malloc, &coap_free, &coap_tx_cb, &coap_rx_cb);
-
-    // UDPSocket::recvfrom is blocking, so run it in a separate RTOS thread
-    recvfromThread.start(&recvfromMain);
-
-    // Path to the resource we want to retrieve
-    const char* coap_uri_path = "/hello";
+    pc.printf("Sending request to %s : %d ...\r\n", SERVER_IP, SERVER_PORT);
 
-    // See ns_coap_header.h
-    sn_coap_hdr_s *coap_res_ptr = (sn_coap_hdr_s*)calloc(sizeof(sn_coap_hdr_s), 1);
-    coap_res_ptr->uri_path_ptr = (uint8_t*)coap_uri_path;       // Path
-    coap_res_ptr->uri_path_len = strlen(coap_uri_path);
-    coap_res_ptr->msg_code = COAP_MSG_CODE_REQUEST_GET;         // CoAP method
-    coap_res_ptr->content_format = COAP_CT_TEXT_PLAIN;          // CoAP content type
-    coap_res_ptr->payload_len = 0;                              // Body length
-    coap_res_ptr->payload_ptr = 0;                              // Body pointer
-    coap_res_ptr->options_list_ptr = 0;                         // Optional: options list
-    // Message ID is used to track request->response patterns, because we're using UDP (so everything is unconfirmed).
-    // See the receive code to verify that we get the same message ID back
-    coap_res_ptr->msg_id = 7;
-
-    // Calculate the CoAP message size, allocate the memory and build the message
-    uint16_t message_len = sn_coap_builder_calc_needed_packet_data_size(coap_res_ptr);
-    printf("Calculated message length: %d bytes\n", message_len);
-
-    uint8_t* message_ptr = (uint8_t*)malloc(message_len);
-    sn_coap_builder(message_ptr, coap_res_ptr);
-
-    // Uncomment to see the raw buffer that will be sent...
-    // printf("Message is: ");
-    // for (size_t ix = 0; ix < message_len; ix++) {
-    //     printf("%02x ", message_ptr[ix]);
-    // }
-    // printf("\n");
-
-    int scount = socket.sendto("coap.me", 5683, message_ptr, message_len);
-    printf("Sent %d bytes to coap://coap.me:5683\n", scount);
-
-    free(coap_res_ptr);
-    free(message_ptr);
-
-    Thread::wait(osWaitForever);
+    float c = 0, h = 0;
+    int scount, rcount;
+    while(1){
+        char rbuffer[64];
+        rcount = socket.recv(rbuffer, sizeof rbuffer);
+//        pc.printf("%s\r\n", rbuffer);
+        if(!strcmp(rbuffer, "GET /DHT22\r\n")){
+            pc.printf("Command Request")
+            scount = socket.send("OK!", sizeof("OK!"));
+            error = sensor.readData();
+            if (error == 0) {
+                c   = sensor.ReadTemperature(CELCIUS);
+                h   = sensor.ReadHumidity();
+            }
+            else if(error == 6){
+                printf("CheckSum Error.\r\n");
+            }
+            char sbuffer[64];
+            sprintf(sbuffer, "{temp: \"%.1f\", humid: \"%.1f\"}\n", c, h);
+            scount = socket.send(sbuffer, sizeof(sbuffer));
+            pc.printf(sbuffer);
+        }
+        else{
+            pc.printf("Unknown request\r\n");
+            scount = socket.send("Unknown request\r\n", sizeof("Unknown request\r\n"));
+        }
+    }
 }