Fabio Gatti
das
Diff: main.cpp
- Revision:
- 3:647e37ef0eec
- Parent:
- 2:983b7f5dde1e
--- a/main.cpp Wed Aug 01 23:01:53 2018 +0000
+++ b/main.cpp Fri Aug 17 14:57:03 2018 +0000
@@ -1,11 +1,22 @@
// main.cpp
+#include <string>
#include "mbed.h"
#include "ISM43362Interface.h"
#include "TCPSocket.h"
+#include "HTS221Sensor.h"
+
+#include "thingsboard_account.h"
+
+
+// H file per MQTT
#include "MQTTmbed.h"
#include "MQTTClient.h"
-#include "HTS221Sensor.h"
+
+// H file per COAP
+#include "sn_nsdl.h"
+#include "sn_coap_protocol.h"
+#include "sn_coap_header.h"
// Definitions ---------------------------------------------------------
@@ -15,9 +26,10 @@
// Change it with your WiFi password name
//#define WIFI_NETWORK_PASSWORD "smartlab"
#define WIFI_NETWORK_PASSWORD "Rosmarino_10"
+
#define WIFI_SECURITY NSAPI_SECURITY_WPA_WPA2
-#define COMM_PROTO 0
+#define COMM_PROTO 2
// scegliere il protocollo di trasporto dati
// COMM_PROTO = 0 -> accesso MQTT (default);
@@ -27,17 +39,38 @@
#define COMM_PROTO 0
#endif
-#if COMM_PROTO==0
+// scegliere il token al device
+#define DEVICE_ID 5
+#define DEVICE_ACCESS_TOKEN TEAM_5_DEVICE_ACCESS_TOKEN
+
+// ciclo di frequenza lettura
+#define SENSOR_READING_PERIOD 5000 //in ms
+
+#if COMM_PROTO==0 //MQTT protocol
+
+ #define MQTT_HOST "demo.thingsboard.io"
+ #define MQTT_PORT 1883
+ #define MQTT_TOPIC "v1/devices/me/telemetry"
-#define MQTT_HOST "demo.thingsboard.io"
-#define MQTT_PORT 1883
-#define MQTT_TOPIC "v1/devices/me/telemetry"
-#define DEVICE_ACCESS_TOKEN "nNcsYA9xXL8OsEmHd6Cq"
+#elif COMM_PROTO==1 //HTTP protocol
+ #define HTTP_HOST "demo.thingsboard.io"
+ #define HTTP_PORT 80
+ #define HTTP_STR_1 "/api/v1/"
+ #define HTTP_STR_2 "/telemetry"
-#endif
+#elif COMM_PROTO==2 //COAP protocol
+ #define COAP_HOST "demo.thingsboard.io"
+ #define COAP_PORT 5683
+ #define COAP_STR_1 "/api/v1/"
+ #define COAP_STR_2 "/telemetry"
+
+ #define SHOW_COAP_RESPONSE false
+#endif //end protocol
-#if COMM_PROTO==0
+// strutture comuni
+
+#if COMM_PROTO == 0
class MQTTNetwork
{
public:
@@ -70,12 +103,44 @@
NetworkInterface* network;
TCPSocket* socket;
};
+
+#elif COMM_PROTO==2 //COAP protocol
+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;
+
+// CoAP HAL
+void* coap_malloc(uint16_t size) {
+ return malloc(size);
+}
+
+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;
+}
+
+int8_t coap_rx_cb(sn_coap_hdr_s *a, sn_nsdl_addr_s *b, void *c) {
+ printf("coap rx cb\n");
+ return 0;
+}
+
+
#endif
+Serial pc(USBTX, USBRX); //use these pins for serial coms.
int main()
{
+
int count = 0;
-
+ pc.baud(115200);
+
+ printf(" --- START SESSION ---\n");
ISM43362Interface wifi(MBED_CONF_APP_WIFI_SPI_MOSI,
MBED_CONF_APP_WIFI_SPI_MISO,
MBED_CONF_APP_WIFI_SPI_SCLK,
@@ -118,7 +183,7 @@
printf("Gateway: %s\n", wifi.get_gateway());
printf("RSSI: %d\n\n", wifi.get_rssi());
-#if COMM_PROTO==0
+#if COMM_PROTO == 0 //MQTT
printf("Collegamento MQTT server: " MQTT_HOST "\n");
MQTTNetwork network(&wifi);
@@ -140,46 +205,226 @@
}
printf("successfully connect to MQTT server!\n");
+
+#elif COMM_PROTO == 1 //HTTP
+
+ printf("Collegamento HTTP server: " HTTP_HOST "\n");
+ TCPSocket socket;
+ nsapi_error_t response;
+
+ // Open a socket on the network interface, and create a TCP connection
+ socket.open(&wifi);
+ response = socket.connect(HTTP_HOST, HTTP_PORT);
+ if(0 != response) {
+ printf("Error connecting: %d\n", response);
+ socket.close();
+ return -1;
+ }
+ socket.close();
+#elif COMM_PROTO == 2 // COAP
+
+ //inserire un test di invio dati al server coap
+
+
#endif
// Initialize sensors --------------------------------------------------
uint8_t id;
-DevI2C i2c_2(PB_11, PB_10);
-HTS221Sensor hum_temp(&i2c_2);
+ DevI2C i2c_2(PB_11, PB_10);
+ HTS221Sensor hum_temp(&i2c_2);
+
+ hum_temp.init(NULL);
+ hum_temp.enable();
+ hum_temp.read_id(&id);
+ printf("HTS221 humidity & temperature sensor = 0x%X\r\n", id);
-hum_temp.init(NULL);
-hum_temp.enable();
-hum_temp.read_id(&id);
-printf("HTS221 humidity & temperature sensor = 0x%X\r\n", id);
+// Variabili di appoggio -----------------------------------------------
+#if COMM_PROTO == 1
+ uint8_t http_request[1024];
+ char request_body[256];
+ static uint8_t http_resp[512];
+ uint16_t reqLen;
+ uint16_t respLen;
-// Get data from sensors -----------------------------------------------
+#elif COMM_PROTO == 2 // COAP
+ char coap_body[256];
+ char coap_uri_path[256];
+ uint16_t coap_message_id;
+ coap_message_id=0;
+
+#endif
+
+
+
+
+// ciclo di lettura sensori e caricamento su cloud
for (;;) {
float temp, humid;
hum_temp.get_temperature(&temp);
hum_temp.get_humidity(&humid);
- printf("HTS221: [temp] %.2f C, [hum] %.2f%%\r\n", temp, humid);
+
+ printf("ID: %d HTS221: [temp] %.2f C, [hum] %.2f%%\r\n", DEVICE_ID,temp, humid);
+#if COMM_PROTO == 0
char msg[256];
int n = snprintf(msg, sizeof(msg),
- "{\"temperature\":%f, \"humidity\":%f, \"active\": false}",
- temp, humid);
+ "{\"ID\":%d,\"temperature\":%f, \"humidity\":%f}",
+ DEVICE_ID,temp, humid);
void *payload = reinterpret_cast<void*>(msg);
size_t payload_len = n;
-
+ printf("Message payload lenght: %d\r\n",payload_len);
printf("publish to: %s %d %s\r\n", MQTT_HOST, MQTT_PORT, MQTT_TOPIC);
-#if COMM_PROTO==0
if (client.publish(MQTT_TOPIC, payload, n) < 0) {
printf("failed to publish MQTT message");
}
-#endif
- wait_ms(5000);
+
+#elif COMM_PROTO == 1
+ // ciclo di scrittura su socket
+ // - open
+ // - connect
+ // - send
+ // - close
+
+ socket.open(&wifi);
+ response = socket.connect(HTTP_HOST, HTTP_PORT);
+ if(0 != response) {
+ printf("Error connecting: %d\n", response);
+ socket.close();
+ return -1;
+ }
+
+
+ // body of the request
+
+ sprintf(request_body, "{\"ID\":%d,\"temperature\": %f,\"humidity\": %f}\r\n",DEVICE_ID, temp, humid);
+
+ // build header of the request
+ sprintf((char *)http_request, "POST %s%s%s HTTP/1.1\r\nHost: %s \r\n", HTTP_STR_1,DEVICE_ACCESS_TOKEN,HTTP_STR_2, HTTP_HOST);
+ strcat((char *)http_request, "Accept: */*\r\n");
+ strcat((char *)http_request, "User-agent: ST-475-IOT\r\n");
+ strcat((char *)http_request, "Connection: Close\r\n");
+ char buffer[64];
+ strcat((char *)http_request, "Content-Type: application/json\r\n");
+ sprintf(buffer, "Content-Length: %d \r\n\r\n", strlen(request_body));
+ strcat((char *)http_request, buffer);
+
+ // append body to the header of the request
+ strcat((char *)http_request, request_body);
+ reqLen = strlen((char *)http_request);
+ printf((char *)http_request);
+
+ // Send a simple http request
+
+ nsapi_size_t size = strlen((char *)http_request);
+ response = 0;
+
+ while(size)
+ {
+ response = socket.send(((char *)http_request)+response, size);
+
+ if (response < 0) {
+ printf("Error sending data: %d\n", response);
+ socket.close();
+ return -1;
+ } else {
+ size -= response;
+ // Check if entire message was sent or not
+ printf("sent %d [%.*s]\n", response, strstr((char *)http_request, "\r\n")-(char *)http_request, (char *)http_request);
+ }
+ }
+ // pulizia risorse della socket
+ socket.close();
+
+#elif COMM_PROTO == 2 //COAP
+
+
+ // Open a socket on the network interface
+ socket.open(&wifi);
+
+ // 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);
+
+
+ // Path to the resource we want to retrieve
+ sprintf(coap_uri_path, "%s%s%s", COAP_STR_1,DEVICE_ACCESS_TOKEN,COAP_STR_2);
+ sprintf(coap_body, "{\"ID\":%d,\"temperature\": %f,\"humidity\": %f}\r\n", DEVICE_ID,temp, humid);
+
+ printf ("URI PATH: %s\n",coap_uri_path);
+ printf ("BODY: %s\n",coap_body);
+ printf ("id: %d\n",coap_message_id);
+
+ // 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_type = COAP_MSG_TYPE_NON_CONFIRMABLE;
+ coap_res_ptr->msg_code = COAP_MSG_CODE_REQUEST_POST; // CoAP method
+ coap_res_ptr->content_format = COAP_CT_JSON; // CoAP content type
+ coap_res_ptr->payload_len = strlen(coap_body); // Body length
+ coap_res_ptr->payload_ptr = (uint8_t*)coap_body; // Body pointer
+ coap_res_ptr->options_list_ptr = 0; // Optional: options list
+ coap_res_ptr->msg_id = coap_message_id; //msg ID, don't forget to increase it
+ coap_message_id++;
+
+ // 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_HOST, COAP_PORT, message_ptr, message_len);
+ printf("Sent %d bytes to coap://%s:%d\n", scount,COAP_HOST, COAP_PORT);
+
+// routine di ricezione
+#if SHOW_COAP_RESPONSE == true
+ SocketAddress addr;
+ uint8_t* recv_buffer = (uint8_t*)malloc(1280); // Suggested is to keep packet size under 1280 bytes
+
+ if ((ret = socket.recvfrom(&addr, recv_buffer, 1280)) >= 0) {
+ // to see where the message came from, inspect addr.get_addr() and addr.get_port()
+
+ printf("Received packets from (%s,%d)\n", addr.get_ip_address(),addr.get_port());
+
+ 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);
+
+ 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);
+
+
+#endif //end SHOW_COAP_RESPONSE
+ socket.close();
+ sn_coap_protocol_destroy(coapHandle);
+ free(coap_res_ptr);
+ free(message_ptr);
+
+
+#endif //end protocol selection
+ wait_ms(SENSOR_READING_PERIOD);
}
-
+//le disconnect non vengono raggiunte perche' rimaniamo all'interno del ciclo
//client.disconnect();
//wifi.disconnect();