ST / Mbed 2 deprecated IDW01M1_Cloud_IBM

Connect through Wifi to IBM MQTT cloud https://quickstart.internetofthings.ibmcloud.com

Dependencies:   MQTT NetworkSocketAPI X_NUCLEO_IDW01M1v2 X_NUCLEO_IKS01A1 mbed NDefLib X_NUCLEO_NFC01A1

Fork of IDW01M1_Cloud_IBM by ST Expansion SW Team

To start the demo the following expansion boards are required

X_NUCLEO_IDW01M1v2, X_NUCLEO_IKS01A1, X_NUCLEO_NFC01A1

After having mounted the board stack on the Nucleo board the below steps should be followed:

  • Program in the application source code you local WiFi SSID and password and flash the binary. Make sure the Wifi network has visible SSID.
  • Reset the Nucleo board and after few seconds the Nucleo green led will be on (it means the Nucleo is connected to the local Wifi and to the IBM cloud server)
  • Read the NFC tag with an Android device and the browser will be automatically opened and directed to the specific brocker IBM demo page where the environmental values are displayed in form of a x-y graph. The values are updated every few seconds. On the Hyperterminal is possible to see the values sent to the IBM cloud server and the board mac address to be entered on the IBM quickstart web page if a manual connection is needed (eg. to connect from a PC browser).

main.cpp@18:2c229fa282fa, 2016-10-04 (annotated)

Committer:
mapellil
Date:
Tue Oct 04 12:05:15 2016 +0000
Revision:
18:2c229fa282fa
Parent:
17:83d0cd810ed3
Child:
20:517b559ce91d
Minor changes

Who changed what in which revision?

UserRevisionLine numberNew contents of line
mridup 10:c7b62ce013ad 1 /* SpwfInterface NetworkSocketAPI Example Program
mridup 10:c7b62ce013ad 2 * Copyright (c) 2015 ARM Limited
mridup 10:c7b62ce013ad 3 *
mridup 10:c7b62ce013ad 4 * Licensed under the Apache License, Version 2.0 (the "License");
mridup 10:c7b62ce013ad 5 * you may not use this file except in compliance with the License.
mridup 10:c7b62ce013ad 6 * You may obtain a copy of the License at
mridup 10:c7b62ce013ad 7 *
mridup 10:c7b62ce013ad 8 * http://www.apache.org/licenses/LICENSE-2.0
mridup 10:c7b62ce013ad 9 *
mridup 10:c7b62ce013ad 10 * Unless required by applicable law or agreed to in writing, software
mridup 10:c7b62ce013ad 11 * distributed under the License is distributed on an "AS IS" BASIS,
mridup 10:c7b62ce013ad 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
mridup 10:c7b62ce013ad 13 * See the License for the specific language governing permissions and
mridup 10:c7b62ce013ad 14 * limitations under the License.
mridup 10:c7b62ce013ad 15 */
mridup 10:c7b62ce013ad 16
mridup 0:cbf8bc43bc9e 17 #include "mbed.h"
mapellil 14:641560b57584 18 #include "SpwfInterface.h"
mridup 4:1ed7f173eec5 19 #include "TCPSocket.h"
fabiombed 13:0b31131bf711 20 #include "MQTTClient.h"
mapellil 14:641560b57584 21 #include "MQTTWiFi.h"
mapellil 14:641560b57584 22 #include <ctype.h>
mapellil 14:641560b57584 23 #include "x_nucleo_iks01a1.h"
fabiombed 13:0b31131bf711 24
mridup 0:cbf8bc43bc9e 25 //------------------------------------
mridup 0:cbf8bc43bc9e 26 // Hyperterminal configuration
mridup 0:cbf8bc43bc9e 27 // 9600 bauds, 8-bit data, no parity
mridup 0:cbf8bc43bc9e 28 //------------------------------------
mridup 8:6df01cb43137 29 Serial pc(SERIAL_TX, SERIAL_RX);
mridup 3:dfb8c6c8c31b 30 DigitalOut myled(LED1);
mapellil 14:641560b57584 31 SpwfSAInterface spwf(D8, D2, false);
mapellil 14:641560b57584 32 bool quickstartMode = true;
mapellil 17:83d0cd810ed3 33
mapellil 17:83d0cd810ed3 34 #define ORG_QUICKSTART // comment to connect to play.internetofthings.ibmcloud.com
mapellil 14:641560b57584 35
mapellil 14:641560b57584 36 #define MQTT_MAX_PACKET_SIZE 250
mapellil 14:641560b57584 37 #define MQTT_MAX_PAYLOAD_SIZE 300
mapellil 17:83d0cd810ed3 38
mapellil 14:641560b57584 39 // Configuration values needed to connect to IBM IoT Cloud
mapellil 17:83d0cd810ed3 40 #ifdef ORG_QUICKSTART
mapellil 17:83d0cd810ed3 41 #define ORG "quickstart" // connect to quickstart.internetofthings.ibmcloud.com/ For a registered connection, replace with your org
mapellil 17:83d0cd810ed3 42 #define ID ""
mapellil 17:83d0cd810ed3 43 #define AUTH_TOKEN ""
mapellil 14:641560b57584 44 #define DEFAULT_TYPE_NAME "iotsample-mbed-NucleoF401RE"
mapellil 17:83d0cd810ed3 45
mapellil 17:83d0cd810ed3 46 #else
mapellil 17:83d0cd810ed3 47 #define ORG "play" // connect to play.internetofthings.ibmcloud.com/ For a registered connection, replace with your org
mapellil 17:83d0cd810ed3 48 #define ID "testnucleo2" // For a registered connection, replace with your id
mapellil 17:83d0cd810ed3 49 #define AUTH_TOKEN "centrallab"// For a registered connection, replace with your auth-token
mapellil 17:83d0cd810ed3 50 #define DEFAULT_TYPE_NAME "sensor"
mapellil 17:83d0cd810ed3 51 #endif
mapellil 17:83d0cd810ed3 52
mapellil 14:641560b57584 53 #define TYPE DEFAULT_TYPE_NAME // For a registered connection, replace with your type
mapellil 14:641560b57584 54 #define MQTT_PORT 1883
mapellil 14:641560b57584 55 #define MQTT_TLS_PORT 8883
mapellil 14:641560b57584 56 #define IBM_IOT_PORT MQTT_PORT
mapellil 16:233b89a6b72f 57 // WiFi network credential
mapellil 16:233b89a6b72f 58 #define SSID "crespan" // Network must be visible otherwise it can't connect
mapellil 18:2c229fa282fa 59 #define PASSW ""
mapellil 16:233b89a6b72f 60 #warning "Wifi password empty"
mapellil 14:641560b57584 61
mapellil 14:641560b57584 62 char id[30] = ID; // mac without colons
mapellil 14:641560b57584 63 char org[12] = ORG;
mapellil 14:641560b57584 64 int connack_rc = 0; // MQTT connack return code
mapellil 14:641560b57584 65 const char* ip_addr = "";
mapellil 14:641560b57584 66 char* host_addr = "";
mapellil 14:641560b57584 67 char type[30] = TYPE;
mapellil 14:641560b57584 68 char auth_token[30] = AUTH_TOKEN; // Auth_token is only used in non-quickstart mode
mapellil 14:641560b57584 69 bool netConnecting = false;
mapellil 14:641560b57584 70 //int connectTimeout = 1000;
mapellil 14:641560b57584 71 int connectTimeout = 10;
mapellil 14:641560b57584 72 bool mqttConnecting = false;
mapellil 14:641560b57584 73 bool netConnected = false;
mapellil 14:641560b57584 74 bool connected = false;
mapellil 14:641560b57584 75 int retryAttempt = 0;
mapellil 14:641560b57584 76
mapellil 14:641560b57584 77 PressureSensor *pressure_sensor;
mapellil 14:641560b57584 78 HumiditySensor *humidity_sensor;
mapellil 14:641560b57584 79 TempSensor *temp_sensor1;
mapellil 14:641560b57584 80
mapellil 14:641560b57584 81
mapellil 14:641560b57584 82 int connect(MQTT::Client<MQTTWiFi, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTWiFi* ipstack)
mapellil 14:641560b57584 83 {
mapellil 14:641560b57584 84 const char* iot_ibm = ".messaging.internetofthings.ibmcloud.com";
mapellil 14:641560b57584 85
mapellil 14:641560b57584 86 char hostname[strlen(org) + strlen(iot_ibm) + 1];
mapellil 14:641560b57584 87 sprintf(hostname, "%s%s", org, iot_ibm);
mapellil 14:641560b57584 88 SpwfSAInterface& WiFi = ipstack->getWiFi();
mapellil 14:641560b57584 89 ip_addr = WiFi.get_ip_address();
mapellil 14:641560b57584 90 printf ("ID: %s\n\r",id);
mapellil 14:641560b57584 91 // Construct clientId - d:org:type:id
mapellil 14:641560b57584 92 char clientId[strlen(org) + strlen(type) + strlen(id) + 5];
mapellil 14:641560b57584 93 sprintf(clientId, "d:%s:%s:%s", org, type, id);
mapellil 14:641560b57584 94 // Network debug statements
mapellil 14:641560b57584 95 LOG("=====================================\n\r");
mapellil 14:641560b57584 96 LOG("Connecting WiFi.\n\r");
mapellil 14:641560b57584 97 LOG("IP ADDRESS: %s\n\r", WiFi.get_ip_address());
mapellil 14:641560b57584 98 LOG("MAC ADDRESS: %s\n\r", WiFi.get_mac_address());
mapellil 14:641560b57584 99 LOG("Server Hostname: %s\n\r", hostname);
mapellil 17:83d0cd810ed3 100 // for(int i = 0; clientId[i]; i++){
mapellil 17:83d0cd810ed3 101 // clientId[i] = tolower(clientId[i]);
mapellil 17:83d0cd810ed3 102 // }
mapellil 14:641560b57584 103 LOG("Client ID: %s\n\r", clientId);
mapellil 14:641560b57584 104 LOG("=====================================\n\r");
mapellil 14:641560b57584 105
mapellil 14:641560b57584 106 netConnecting = true;
mapellil 14:641560b57584 107 ipstack->open(&ipstack->getWiFi());
mapellil 14:641560b57584 108 int rc = ipstack->connect(hostname, IBM_IOT_PORT, connectTimeout);
mapellil 14:641560b57584 109 if (rc != 0)
mapellil 14:641560b57584 110 {
mapellil 14:641560b57584 111 WARN("IP Stack connect returned: %d\n", rc);
mapellil 14:641560b57584 112 return rc;
mapellil 14:641560b57584 113 }
mapellil 14:641560b57584 114 netConnected = true;
mapellil 14:641560b57584 115 netConnecting = false;
mapellil 14:641560b57584 116
mapellil 14:641560b57584 117 // MQTT Connect
mapellil 14:641560b57584 118 mqttConnecting = true;
mapellil 14:641560b57584 119 MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
mapellil 17:83d0cd810ed3 120 data.MQTTVersion = 4;
mapellil 17:83d0cd810ed3 121 data.struct_version=0;
mapellil 14:641560b57584 122 data.clientID.cstring = clientId;
mapellil 14:641560b57584 123
mapellil 14:641560b57584 124 if (!quickstartMode)
mapellil 14:641560b57584 125 {
mapellil 14:641560b57584 126 data.username.cstring = "use-token-auth";
mapellil 14:641560b57584 127 data.password.cstring = auth_token;
mapellil 14:641560b57584 128 }
mapellil 14:641560b57584 129 if ((rc = client->connect(data)) == 0)
mapellil 14:641560b57584 130 {
mapellil 14:641560b57584 131 connected = true;
mapellil 14:641560b57584 132 printf ("--->Connected\n\r");
mapellil 14:641560b57584 133 }
mapellil 14:641560b57584 134 else {
mapellil 14:641560b57584 135 WARN("MQTT connect returned %d\n", rc);
mapellil 14:641560b57584 136 }
mapellil 14:641560b57584 137 if (rc >= 0)
mapellil 14:641560b57584 138 connack_rc = rc;
mapellil 14:641560b57584 139 mqttConnecting = false;
mapellil 14:641560b57584 140 return rc;
mapellil 14:641560b57584 141 }
mapellil 14:641560b57584 142
mapellil 14:641560b57584 143 int getConnTimeout(int attemptNumber)
mapellil 14:641560b57584 144 { // First 10 attempts try within 3 seconds, next 10 attempts retry after every 1 minute
mapellil 14:641560b57584 145 // after 20 attempts, retry every 10 minutes
mapellil 14:641560b57584 146 return (attemptNumber < 10) ? 3 : (attemptNumber < 20) ? 60 : 600;
mapellil 14:641560b57584 147 }
mapellil 14:641560b57584 148
mapellil 14:641560b57584 149 void attemptConnect(MQTT::Client<MQTTWiFi, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTWiFi* ipstack)
mapellil 14:641560b57584 150 {
mapellil 14:641560b57584 151 connected = false;
mapellil 14:641560b57584 152
mapellil 14:641560b57584 153 while (connect(client, ipstack) != MQTT_CONNECTION_ACCEPTED)
mapellil 14:641560b57584 154 {
mapellil 14:641560b57584 155 if (connack_rc == MQTT_NOT_AUTHORIZED || connack_rc == MQTT_BAD_USERNAME_OR_PASSWORD) {
mapellil 14:641560b57584 156 printf ("File: %s, Line: %d\n\r",__FILE__,__LINE__);
mapellil 14:641560b57584 157 return; // don't reattempt to connect if credentials are wrong
mapellil 14:641560b57584 158 }
mapellil 14:641560b57584 159 int timeout = getConnTimeout(++retryAttempt);
mapellil 14:641560b57584 160 WARN("Retry attempt number %d waiting %d\n", retryAttempt, timeout);
mapellil 14:641560b57584 161
mapellil 14:641560b57584 162 // if ipstack and client were on the heap we could deconstruct and goto a label where they are constructed
mapellil 14:641560b57584 163 // or maybe just add the proper members to do this disconnect and call attemptConnect(...)
mapellil 14:641560b57584 164
mapellil 14:641560b57584 165 // this works - reset the system when the retry count gets to a threshold
mapellil 14:641560b57584 166 if (retryAttempt == 5)
mapellil 14:641560b57584 167 NVIC_SystemReset();
mapellil 14:641560b57584 168 else
mapellil 14:641560b57584 169 wait(timeout);
mapellil 14:641560b57584 170 }
mapellil 14:641560b57584 171 }
mapellil 14:641560b57584 172
mapellil 14:641560b57584 173 int publish(MQTT::Client<MQTTWiFi, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTWiFi* ipstack)
mapellil 14:641560b57584 174 {
mapellil 14:641560b57584 175 MQTT::Message message;
mapellil 14:641560b57584 176 char* pubTopic = "iot-2/evt/status/fmt/json";
mapellil 14:641560b57584 177
mapellil 14:641560b57584 178 char buf[MQTT_MAX_PAYLOAD_SIZE];
mapellil 14:641560b57584 179 float temp, press, hum;
mapellil 14:641560b57584 180 temp_sensor1->GetTemperature(&temp);
mapellil 14:641560b57584 181 pressure_sensor->GetPressure(&press);
mapellil 14:641560b57584 182 humidity_sensor->GetHumidity(&hum);
mapellil 14:641560b57584 183 sprintf(buf,
mapellil 14:641560b57584 184 "{\"d\":{\"ST\":\"Nucleo-IoT-mbed\",\"Temp\":%0.4f,\"Pressure\":\"%0.4f,\",\"Humidity\":%0.4f}}",
mapellil 14:641560b57584 185 temp, press, hum);
mapellil 14:641560b57584 186 message.qos = MQTT::QOS0;
mapellil 14:641560b57584 187 message.retained = false;
mapellil 14:641560b57584 188 message.dup = false;
mapellil 14:641560b57584 189 message.payload = (void*)buf;
mapellil 14:641560b57584 190 message.payloadlen = strlen(buf);
mapellil 14:641560b57584 191
mapellil 14:641560b57584 192 LOG("Publishing %s\n", buf);
mapellil 14:641560b57584 193 return client->publish(pubTopic, message);
mapellil 14:641560b57584 194 }
mridup 4:1ed7f173eec5 195
fabiombed 13:0b31131bf711 196 int main()
fabiombed 13:0b31131bf711 197 {
mapellil 16:233b89a6b72f 198 const char * ssid = SSID; // Network must be visible otherwise it can't connect
mapellil 16:233b89a6b72f 199 const char * seckey = PASSW;
mapellil 14:641560b57584 200
mapellil 14:641560b57584 201 // Timer tyeld;
mapellil 14:641560b57584 202
mapellil 14:641560b57584 203 DevI2C *i2c = new DevI2C(I2C_SDA, I2C_SCL);
mapellil 14:641560b57584 204 i2c->frequency(400000);
mapellil 14:641560b57584 205
mapellil 14:641560b57584 206 X_NUCLEO_IKS01A1 *mems_expansion_board = X_NUCLEO_IKS01A1::Instance(i2c);
mapellil 14:641560b57584 207
mapellil 14:641560b57584 208 pressure_sensor = mems_expansion_board->pt_sensor;
mapellil 14:641560b57584 209 temp_sensor1 = mems_expansion_board->ht_sensor;
mapellil 14:641560b57584 210 humidity_sensor = mems_expansion_board->ht_sensor;
mridup 4:1ed7f173eec5 211
mridup 6:0d838d564181 212 pc.printf("\r\nX-NUCLEO-IDW01M1 mbed Application\r\n");
mapellil 14:641560b57584 213 pc.printf("\r\nconnecting to AP\r\n");
fabiombed 13:0b31131bf711 214
mapellil 17:83d0cd810ed3 215 quickstartMode=false;
mapellil 16:233b89a6b72f 216 if (strcmp(org, "quickstart") == 0){quickstartMode = true;}
mapellil 16:233b89a6b72f 217 MQTTWiFi ipstack(spwf, ssid, seckey, NSAPI_SECURITY_WPA2);
mapellil 16:233b89a6b72f 218 MQTT::Client<MQTTWiFi, Countdown, MQTT_MAX_PACKET_SIZE> client(ipstack);
mapellil 16:233b89a6b72f 219 if (quickstartMode){
mapellil 14:641560b57584 220 char mac[50];
mapellil 17:83d0cd810ed3 221 char *digit=NULL;
mapellil 17:83d0cd810ed3 222 sprintf (id,"%s", "");
mapellil 14:641560b57584 223 sprintf (mac,"%s",ipstack.getWiFi().get_mac_address());
mapellil 14:641560b57584 224 strcpy (mac, ipstack.getWiFi().get_mac_address());
mapellil 14:641560b57584 225 digit = strtok (mac,":");
mapellil 14:641560b57584 226 while (digit != NULL)
mapellil 14:641560b57584 227 {
mapellil 14:641560b57584 228 strcat (id, digit);
mapellil 14:641560b57584 229 digit = strtok (NULL, ":");
mapellil 17:83d0cd810ed3 230 }
mapellil 16:233b89a6b72f 231 }
mapellil 16:233b89a6b72f 232 attemptConnect(&client, &ipstack);
mapellil 16:233b89a6b72f 233 if (connack_rc == MQTT_NOT_AUTHORIZED || connack_rc == MQTT_BAD_USERNAME_OR_PASSWORD)
mapellil 16:233b89a6b72f 234 {
mapellil 16:233b89a6b72f 235 while (true)
mapellil 16:233b89a6b72f 236 wait(1.0); // Permanent failures - don't retry
mapellil 16:233b89a6b72f 237 }
mapellil 16:233b89a6b72f 238 int count = 0;
mapellil 16:233b89a6b72f 239 // tyeld.start();
mapellil 14:641560b57584 240 while (true)
mridup 8:6df01cb43137 241 {
mapellil 14:641560b57584 242 if (++count == /*100*/2)
mapellil 14:641560b57584 243 { // Publish a message every second
mapellil 14:641560b57584 244 if (publish(&client, &ipstack) != 0)
mapellil 14:641560b57584 245 attemptConnect(&client, &ipstack); // if we have lost the connection
mapellil 14:641560b57584 246 count = 0;
mapellil 14:641560b57584 247 }
mapellil 14:641560b57584 248 // int start = tyeld.read_ms();
mapellil 14:641560b57584 249 client.yield(/*10*/1); // allow the MQTT client to receive messages
mapellil 14:641560b57584 250 // printf ("tyeld: %d\n\r",tyeld.read_ms()-start);
mridup 3:dfb8c6c8c31b 251 }
mridup 4:1ed7f173eec5 252 }