Klika Tech / Mbed 2 deprecated Nucleo-AWS-IoT-mbed

Example of AWS IoT connection and Web Dashboard thru STM32 Nucleo evaluation board and mbed OS.

Dependencies:   X_NUCLEO_IKS01A1 mbed FP MQTTPacket DnsQuery ATParser

Introduction

The demo is aimed to STM32 Nucleo board with WiFi and sensors expansions. The board is a "thing" for the AWS IoT service. It updates IoT service shadow with sensors data every second and checks subscription messages.

Hardware Configuration

https://github.com/Klika-Tech/nucleo-aws-iot-demo/raw/master/doc/assets/device.jpg

Software Configuration

  • Import this Project to mbed online compiler
  • Find the next part of code in main.cpp file ...

WiFi network credential

#include "mbed.h"
// WiFi network credential
#define SSID   ""  // Network must be visible otherwise it can't connect
#define PASSW  ""
#error "Wifi SSID & password empty"
  • ... And set it to your Network Name and Password. Do not forget to remove "#error" pragma line.

Information

Nucleo WiFi module is not the same as your smartphone or laptope - it is based on demo board. To avoid connection problems:

  1. Place Nucleo as close to WiFi hot spot as possible. Or...
  2. Turn on mobile hot spot in your laptop as close to the device as possible.
  3. Make sure that hot spot permits 2.4 GHz band communications
  • Setup BackEnd and store certificates using this backend setup instruction
  • Find AWS_IOT_MQTT_HOST define and change it to HTTPS point mentioned in your AWS IoT thing properties named "interact" 

#define AWS_IOT_MQTT_HOST              "xxxxxxxxxx.iot.us-east-1.amazonaws.com" //Use your own host.
  • Find the certificate defines clientCRT and clientKey in main.cpp file and change it to ones provided by Amazon. 

/**********************************************************************************************
***********************************************************************************************
				Device Identity Certificates: Modify for your AWS IoT Thing
***********************************************************************************************
***********************************************************************************************/

/****************************************
(somecode)-certificate.pem.crt - Amazon signed PEM sertificate.
*****************************************/

//This Client cert is example. Use own instead.
const uint8_t clientCRT[] = "\
-----BEGIN CERTIFICATE-----\n\
MIIDBjCCAe6gAwIBAgIUVph856omeIxW3UPioq+UrX1DbwowDQYJKoZIhvcNAQEL\
BQAwTTFLMEkGA1UECwxCQW1hem9uIFdlYiBTZXJ2aWNlcyBPPUFtYXpvbi5jb20g\
SW5jLiBMPVNlYXR0bGUgU1Q9V2FzaGluZ3RvbiBDPVVTMB4XDTE3MDUyNTExNTEy\
OVoXDTQ5MTIzMTIzNTk1OVowgZUxCzAJBgNVBAYTAkJZMQ4wDAYDVQQIDAVNaW5z\
azEOMAwGA1UEBwwFTWluc2sxFzAVBgNVBAoMDktsaWthLVRlY2ggTExDMRcwFQYD\
VQQLDA5LbGlrYS1UZWNoIExMQzEMMAoGA1UEAwwDUm5EMSYwJAYJKoZIhvcNAQkB\
FhdtdmF0YWxldUBrbGlrYS10ZWNoLmNvbTBZMBMGByqGSM49AgEGCCqGSM49AwEH\
A0IABCJgOQJmoTBJVPfli9Hm/JVixaxkY5rtlgrYO3hSl633A2hg0P/ue0wXDbF3\
aQ0X57IRFE4k4FEbr3UXjT/IczKjYDBeMB8GA1UdIwQYMBaAFK3YzTUPlYB2Li75\
i/z8rEogr1d6MB0GA1UdDgQWBBT18HXBaXFJuAR/0SwegnxJ+pyJ6TAMBgNVHRMB\
Af8EAjAAMA4GA1UdDwEB/wQEAwIHgDANBgkqhkiG9w0BAQsFAAOCAQEAb0Ux1aH5\
RLxjrfGqXN6rPVqh8QQRS+AyBfzmaQN8HaPZMkX5WxXLvcn0A3uWlwQxPPkcZ4zf\
51GHtFFQWB4YZ8dx8mUQ0v/j7onHjCJgZ8iDgwOyKMGtnsDZWCakQw+a6cj+NrMZ\
tzhjwCzEEP6ePcbXwErI5OOzLuWns2L/JEr2wWNkokgRuS8ewr/SQ9OLWIWa2rFM\
ahPNTb3y/qBeWdjeJmhI+TOxdqIpsF8roWP25zwo/zkzCHCjXFBrL+0CA4MpxIl9\
x02i7aAhlJ6ys80lDxdeWeeQJXRKkGknP8mcmKn3iEqqJ5s1dQePj2b5d3ldatya\
wsxQBqqZXzIWEw==\
\n\
-----END CERTIFICATE-----\n";



/**********************************************************************************************
***********************************************************************************************
						Private Key: Modify for your AWS IoT Thing
***********************************************************************************************
***********************************************************************************************/

/********************************************************************8****************************************
nucleo.key.pem - client key generated according to readme.
**************************************************************************************************************/

//This Client Key is example. Use own instead.
const uint8_t clientKey[] ="\
-----BEGIN EC PARAMETERS-----\n\
BggqhkjOPQMBBw==\
-----END EC PARAMETERS-----\n\
-----BEGIN EC PRIVATE KEY-----\n\
MHcCAQEEIHPRfWSC8/k/BsqDWKuP15dXsI9fGwpkTIsLZe6mIrAAoAoGCCqGSM49\
AwEHoUQDQgAEImA5AmahMElU9+WL0eb8lWLFrGRjmu2WCtg7eFKXrfcDaGDQ/+57\
TBcNsXdpDRfnshEUTiTgURuvdReNP8hzMg==\
-----END EC PRIVATE KEY-----\n";

Build and Check

  1. Plugin your board to USB of your PC. USB Disk Drive and USB COM Port should appear in your system.
  2. Open any Serial Console, connect it to your USB Serial Port and setup speed equal to 115200.
  3. Compile this Project and save .bin file to USB Disk Drive
  4. After board reset you should see next log in serial console: 

X-NUCLEO-IDW01M1 mbed Application

connecting to AP
LOG:   int main() L#361 Connected to WiFI.
LOG:   int connect(MQTT::Client<MQTTWiFi, Countdown, 350, 5> *, MQTTWiFi *) L#186 =====================================
LOG:   int connect(MQTT::Client<MQTTWiFi, Countdown, 350, 5> *, MQTTWiFi *) L#187 Connecting WiFi.
LOG:   int connect(MQTT::Client<MQTTWiFi, Countdown, 350, 5> *, MQTTWiFi *) L#188 Nucleo IP ADDRESS: X.X.X.X
LOG:   int connect(MQTT::Client<MQTTWiFi, Countdown, 350, 5> *, MQTTWiFi *) L#189 Nucleo MAC ADDRESS: 00:11:22:33:44:55
LOG:   int connect(MQTT::Client<MQTTWiFi, Countdown, 350, 5> *, MQTTWiFi *) L#190 Server Hostname: xxxxxxxx.iot.us-east-1.amazonaws.com port: 8883
LOG:   int connect(MQTT::Client<MQTTWiFi, Countdown, 350, 5> *, MQTTWiFi *) L#191 Client ID: Nucleo
LOG:   int connect(MQTT::Client<MQTTWiFi, Countdown, 350, 5> *, MQTTWiFi *) L#194 =====================================
LOG:   int MQTTSocket::getNTPtime(int) L#58 Success receiving time from ntp server. Tick from 1 Jan 1970 is equal to 1505399292.
--->TCP Connected
--->MQTT Connected
--->>>MQTT subscribed to: Nucleo/test
Length - 245, Publishing {"state": {"reported": {"temperature": 23.690001, "humidity": 98.190002, "pressure": 982.869141, "accelerometer": [-0.009000, 0.030000, 0.971000], "gyroscope": [0.420000, -2.660000, 1.750000], "magnetometer": [-3.600000, -7.100000, 53.300000]}}}
Length - 245, Publishing {"state": {"reported": {"temperature": 23.660000, "humidity": 98.010002, "pressure": 982.770264, "accelerometer": [-0.009000, 0.030000, 0.971000], "gyroscope": [0.770000, -2.310000, 1.470000], "magnetometer": [-3.100000, -8.300000, 54.200000]}}}
Length - 245, Publishing {"state": {"reported": {"temperature": 23.670000, "humidity": 98.129997, "pressure": 982.724121, "accelerometer": [-0.008000, 0.029000, 0.971000], "gyroscope": [0.630000, -2.380000, 1.400000], "magnetometer": [-3.100000, -7.900000, 53.400000]}}}
Length - 245, Publishing {"state": {"reported": {"temperature": 23.690001, "humidity": 98.019997, "pressure": 982.840088, "accelerometer": [-0.009000, 0.030000, 0.972000], "gyroscope": [0.700000, -2.450000, 1.540000], "magnetometer": [-3.700000, -7.900000, 53.400000]}}}
Length - 245, Publishing {"state": {"reported": {"temperature": 23.709999, "humidity": 98.040001, "pressure": 982.828613, "accelerometer": [-0.009000, 0.030000, 0.971000], "gyroscope": [0.630000, -2.520000, 1.470000], "magnetometer": [-2.900000, -7.400000, 52.400000]}}}
Length - 245, Publishing {"state": {"reported": {"temperature": 23.719999, "humidity": 97.860001, "pressure": 982.917236, "accelerometer": [-0.026000, 0.103000, 0.891000], "gyroscope": [1.050000, -2.310000, 1.260000], "magnetometer": [-3.300000, -7.100000, 53.500000]}}}

Information

Device connection state might be checked by Green Led on the board. Green light means that device is connected and transferring data to cloud.

  1. Configure and start your dashboard using instruction and corresponding sources from github
  2. Use Blue button to set up markers to charts.
  3. Use AWS IoT console MQTT Client to test device subscription to "Nucleo/test". Just publish any message to this topic and serial port output.
  4. PROFIT!

main.cpp@1:042ca9148926, 2017-10-19 (annotated)

Committer:
PavelSavyhin
Date:
Thu Oct 19 11:36:41 2017 +0000
Revision:
1:042ca9148926
Parent:
0:4cdaf9b1e7d0 
Connection times are optimized and logging is extended.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
PavelSavyhin 0:4cdaf9b1e7d0 1 /* SpwfInterface NetworkSocketAPI Example Program
PavelSavyhin 0:4cdaf9b1e7d0 2 * Copyright (c) 2015 ARM Limited
PavelSavyhin 0:4cdaf9b1e7d0 3 * Copyright (c) 2017 KLIKA TECH, LLC
PavelSavyhin 0:4cdaf9b1e7d0 4 *
PavelSavyhin 0:4cdaf9b1e7d0 5 * Licensed under the Apache License, Version 2.0 (the "License");
PavelSavyhin 0:4cdaf9b1e7d0 6 * you may not use this file except in compliance with the License.
PavelSavyhin 0:4cdaf9b1e7d0 7 * You may obtain a copy of the License at
PavelSavyhin 0:4cdaf9b1e7d0 8 *
PavelSavyhin 0:4cdaf9b1e7d0 9 * http://www.apache.org/licenses/LICENSE-2.0
PavelSavyhin 0:4cdaf9b1e7d0 10 *
PavelSavyhin 0:4cdaf9b1e7d0 11 * Unless required by applicable law or agreed to in writing, software
PavelSavyhin 0:4cdaf9b1e7d0 12 * distributed under the License is distributed on an "AS IS" BASIS,
PavelSavyhin 0:4cdaf9b1e7d0 13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
PavelSavyhin 0:4cdaf9b1e7d0 14 * See the License for the specific language governing permissions and
PavelSavyhin 0:4cdaf9b1e7d0 15 * limitations under the License.
PavelSavyhin 0:4cdaf9b1e7d0 16
PavelSavyhin 0:4cdaf9b1e7d0 17 Contributors:
PavelSavyhin 0:4cdaf9b1e7d0 18 * Klika Tech - completely adopted to Amazon AWS IoT service
PavelSavyhin 0:4cdaf9b1e7d0 19
PavelSavyhin 0:4cdaf9b1e7d0 20 */
PavelSavyhin 0:4cdaf9b1e7d0 21
PavelSavyhin 0:4cdaf9b1e7d0 22 #include "mbed.h"
PavelSavyhin 0:4cdaf9b1e7d0 23 #include "SpwfInterface.h"
PavelSavyhin 0:4cdaf9b1e7d0 24 #include "TCPSocket.h"
PavelSavyhin 0:4cdaf9b1e7d0 25 #include "MQTTClient.h"
PavelSavyhin 0:4cdaf9b1e7d0 26 #include "MQTTWiFi.h"
PavelSavyhin 0:4cdaf9b1e7d0 27 #include <ctype.h>
PavelSavyhin 0:4cdaf9b1e7d0 28 #include "x_nucleo_iks01a1.h"
PavelSavyhin 0:4cdaf9b1e7d0 29
PavelSavyhin 0:4cdaf9b1e7d0 30 //------------------------------------
PavelSavyhin 0:4cdaf9b1e7d0 31 // Hyperterminal default configuration
PavelSavyhin 0:4cdaf9b1e7d0 32 // 9600 bauds, 8-bit data, no parity
PavelSavyhin 0:4cdaf9b1e7d0 33 //------------------------------------
PavelSavyhin 0:4cdaf9b1e7d0 34 Serial pc(SERIAL_TX, SERIAL_RX);
PavelSavyhin 0:4cdaf9b1e7d0 35 DigitalOut myled(LED2);
PavelSavyhin 0:4cdaf9b1e7d0 36 DigitalOut butled(LED3);
PavelSavyhin 0:4cdaf9b1e7d0 37 InterruptIn mybutton(USER_BUTTON);
PavelSavyhin 0:4cdaf9b1e7d0 38
PavelSavyhin 0:4cdaf9b1e7d0 39 bool myButtonPressed = false;
PavelSavyhin 0:4cdaf9b1e7d0 40
PavelSavyhin 0:4cdaf9b1e7d0 41 #define MQTT_MAX_PACKET_SIZE 350
PavelSavyhin 0:4cdaf9b1e7d0 42 #define MQTT_MAX_PAYLOAD_SIZE 300
PavelSavyhin 0:4cdaf9b1e7d0 43
PavelSavyhin 1:042ca9148926 44 #define AWS_IOT_MQTT_HOST "a3t8vwpkw3sltg.iot.us-east-2.amazonaws.com" //Use your own host.
PavelSavyhin 0:4cdaf9b1e7d0 45 #define AWS_IOT_MQTT_PORT 8883
PavelSavyhin 0:4cdaf9b1e7d0 46 #define AWS_IOT_MQTT_CLIENT_ID "Nucleo" //Should be kept if you are using same device clent.
PavelSavyhin 0:4cdaf9b1e7d0 47 #define AWS_IOT_MY_THING_NAME "Nucleo" //Should be kept if you are using same device thing name.
PavelSavyhin 0:4cdaf9b1e7d0 48 #define AWS_IOT_MQTT_TOPIC_TEST "Nucleo/test"
PavelSavyhin 0:4cdaf9b1e7d0 49 #define AWS_IOT_MQTT_TOPIC_DATA "Nucleo/data"
PavelSavyhin 0:4cdaf9b1e7d0 50 #define AWS_IOT_MQTT_TOPIC_SHADOW "$aws/things/Nucleo/shadow/update"
PavelSavyhin 0:4cdaf9b1e7d0 51 #define AWS_IOT_ID ""
PavelSavyhin 0:4cdaf9b1e7d0 52 #define AWS_IOT_AUTH_TOKEN ""
PavelSavyhin 0:4cdaf9b1e7d0 53
PavelSavyhin 0:4cdaf9b1e7d0 54 // WiFi network credential
PavelSavyhin 0:4cdaf9b1e7d0 55 #define SSID "" // Network must be visible otherwise it can't connect
PavelSavyhin 0:4cdaf9b1e7d0 56 #define PASSW ""
PavelSavyhin 0:4cdaf9b1e7d0 57 #error "Wifi SSID & password empty"
PavelSavyhin 0:4cdaf9b1e7d0 58
PavelSavyhin 0:4cdaf9b1e7d0 59 #include "stdint.h"
PavelSavyhin 0:4cdaf9b1e7d0 60
PavelSavyhin 0:4cdaf9b1e7d0 61
PavelSavyhin 0:4cdaf9b1e7d0 62 /**********************************************************************************************
PavelSavyhin 0:4cdaf9b1e7d0 63 ***********************************************************************************************
PavelSavyhin 0:4cdaf9b1e7d0 64 Root CA certificate: Never modify
PavelSavyhin 0:4cdaf9b1e7d0 65 ***********************************************************************************************
PavelSavyhin 0:4cdaf9b1e7d0 66 ***********************************************************************************************/
PavelSavyhin 0:4cdaf9b1e7d0 67
PavelSavyhin 0:4cdaf9b1e7d0 68 //This root CA can be used.
PavelSavyhin 0:4cdaf9b1e7d0 69 const uint8_t rootCA[] = "\
PavelSavyhin 0:4cdaf9b1e7d0 70 -----BEGIN CERTIFICATE-----\n\
PavelSavyhin 0:4cdaf9b1e7d0 71 MIIE0zCCA7ugAwIBAgIQGNrRniZ96LtKIVjNzGs7SjANBgkqhkiG9w0BAQUFADCB\
PavelSavyhin 0:4cdaf9b1e7d0 72 yjELMAkGA1UEBhMCVVMxFzAVBgNVBAoTDlZlcmlTaWduLCBJbmMuMR8wHQYDVQQL\
PavelSavyhin 0:4cdaf9b1e7d0 73 ExZWZXJpU2lnbiBUcnVzdCBOZXR3b3JrMTowOAYDVQQLEzEoYykgMjAwNiBWZXJp\
PavelSavyhin 0:4cdaf9b1e7d0 74 U2lnbiwgSW5jLiAtIEZvciBhdXRob3JpemVkIHVzZSBvbmx5MUUwQwYDVQQDEzxW\
PavelSavyhin 0:4cdaf9b1e7d0 75 ZXJpU2lnbiBDbGFzcyAzIFB1YmxpYyBQcmltYXJ5IENlcnRpZmljYXRpb24gQXV0\
PavelSavyhin 0:4cdaf9b1e7d0 76 aG9yaXR5IC0gRzUwHhcNMDYxMTA4MDAwMDAwWhcNMzYwNzE2MjM1OTU5WjCByjEL\
PavelSavyhin 0:4cdaf9b1e7d0 77 MAkGA1UEBhMCVVMxFzAVBgNVBAoTDlZlcmlTaWduLCBJbmMuMR8wHQYDVQQLExZW\
PavelSavyhin 0:4cdaf9b1e7d0 78 ZXJpU2lnbiBUcnVzdCBOZXR3b3JrMTowOAYDVQQLEzEoYykgMjAwNiBWZXJpU2ln\
PavelSavyhin 0:4cdaf9b1e7d0 79 biwgSW5jLiAtIEZvciBhdXRob3JpemVkIHVzZSBvbmx5MUUwQwYDVQQDEzxWZXJp\
PavelSavyhin 0:4cdaf9b1e7d0 80 U2lnbiBDbGFzcyAzIFB1YmxpYyBQcmltYXJ5IENlcnRpZmljYXRpb24gQXV0aG9y\
PavelSavyhin 0:4cdaf9b1e7d0 81 aXR5IC0gRzUwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQCvJAgIKXo1\
PavelSavyhin 0:4cdaf9b1e7d0 82 nmAMqudLO07cfLw8RRy7K+D+KQL5VwijZIUVJ/XxrcgxiV0i6CqqpkKzj/i5Vbex\
PavelSavyhin 0:4cdaf9b1e7d0 83 t0uz/o9+B1fs70PbZmIVYc9gDaTY3vjgw2IIPVQT60nKWVSFJuUrjxuf6/WhkcIz\
PavelSavyhin 0:4cdaf9b1e7d0 84 SdhDY2pSS9KP6HBRTdGJaXvHcPaz3BJ023tdS1bTlr8Vd6Gw9KIl8q8ckmcY5fQG\
PavelSavyhin 0:4cdaf9b1e7d0 85 BO+QueQA5N06tRn/Arr0PO7gi+s3i+z016zy9vA9r911kTMZHRxAy3QkGSGT2RT+\
PavelSavyhin 0:4cdaf9b1e7d0 86 rCpSx4/VBEnkjWNHiDxpg8v+R70rfk/Fla4OndTRQ8Bnc+MUCH7lP59zuDMKz10/\
PavelSavyhin 0:4cdaf9b1e7d0 87 NIeWiu5T6CUVAgMBAAGjgbIwga8wDwYDVR0TAQH/BAUwAwEB/zAOBgNVHQ8BAf8E\
PavelSavyhin 0:4cdaf9b1e7d0 88 BAMCAQYwbQYIKwYBBQUHAQwEYTBfoV2gWzBZMFcwVRYJaW1hZ2UvZ2lmMCEwHzAH\
PavelSavyhin 0:4cdaf9b1e7d0 89 BgUrDgMCGgQUj+XTGoasjY5rw8+AatRIGCx7GS4wJRYjaHR0cDovL2xvZ28udmVy\
PavelSavyhin 0:4cdaf9b1e7d0 90 aXNpZ24uY29tL3ZzbG9nby5naWYwHQYDVR0OBBYEFH/TZafC3ey78DAJ80M5+gKv\
PavelSavyhin 0:4cdaf9b1e7d0 91 MzEzMA0GCSqGSIb3DQEBBQUAA4IBAQCTJEowX2LP2BqYLz3q3JktvXf2pXkiOOzE\
PavelSavyhin 0:4cdaf9b1e7d0 92 p6B4Eq1iDkVwZMXnl2YtmAl+X6/WzChl8gGqCBpH3vn5fJJaCGkgDdk+bW48DW7Y\
PavelSavyhin 0:4cdaf9b1e7d0 93 5gaRQBi5+MHt39tBquCWIMnNZBU4gcmU7qKEKQsTb47bDN0lAtukixlE0kF6BWlK\
PavelSavyhin 0:4cdaf9b1e7d0 94 WE9gyn6CagsCqiUXObXbf+eEZSqVir2G3l6BFoMtEMze/aiCKm0oHw0LxOXnGiYZ\
PavelSavyhin 0:4cdaf9b1e7d0 95 4fQRbxC1lfznQgUy286dUV4otp6F01vvpX1FQHKOtw5rDgb7MzVIcbidJ4vEZV8N\
PavelSavyhin 0:4cdaf9b1e7d0 96 hnacRHr2lVz2XTIIM6RUthg/aFzyQkqFOFSDX9HoLPKsEdao8WNq\n\
PavelSavyhin 0:4cdaf9b1e7d0 97 -----END CERTIFICATE-----\n";
PavelSavyhin 0:4cdaf9b1e7d0 98
PavelSavyhin 0:4cdaf9b1e7d0 99 /**********************************************************************************************
PavelSavyhin 0:4cdaf9b1e7d0 100 ***********************************************************************************************
PavelSavyhin 0:4cdaf9b1e7d0 101 Device Identity Certificates: Modify for your AWS IoT Thing
PavelSavyhin 0:4cdaf9b1e7d0 102 ***********************************************************************************************
PavelSavyhin 0:4cdaf9b1e7d0 103 ***********************************************************************************************/
PavelSavyhin 0:4cdaf9b1e7d0 104
PavelSavyhin 0:4cdaf9b1e7d0 105 /****************************************
PavelSavyhin 0:4cdaf9b1e7d0 106 (somecode)-certificate.pem.crt - Amazon signed PEM sertificate.
PavelSavyhin 0:4cdaf9b1e7d0 107 *****************************************/
PavelSavyhin 0:4cdaf9b1e7d0 108
PavelSavyhin 0:4cdaf9b1e7d0 109 //This Client cert is example. Use own instead.
PavelSavyhin 0:4cdaf9b1e7d0 110 const uint8_t clientCRT[] = "\
PavelSavyhin 0:4cdaf9b1e7d0 111 -----BEGIN CERTIFICATE-----\n\
PavelSavyhin 1:042ca9148926 112 MIIC8jCCAdqgAwIBAgIVAJrIfpHLnCshC2j/Tp0dBJlSgaFnMA0GCSqGSIb3DQEB\
PavelSavyhin 1:042ca9148926 113 CwUAME0xSzBJBgNVBAsMQkFtYXpvbiBXZWIgU2VydmljZXMgTz1BbWF6b24uY29t\
PavelSavyhin 1:042ca9148926 114 IEluYy4gTD1TZWF0dGxlIFNUPVdhc2hpbmd0b24gQz1VUzAeFw0xNzA5MTUxMjQ3\
PavelSavyhin 1:042ca9148926 115 NDBaFw00OTEyMzEyMzU5NTlaMIGAMQswCQYDVQQGEwJERTENMAsGA1UECBMERGVt\
PavelSavyhin 1:042ca9148926 116 bzENMAsGA1UEBxMERGVtbzENMAsGA1UEChMERGVtbzENMAsGA1UECxMERGVtbzEN\
PavelSavyhin 1:042ca9148926 117 MAsGA1UEAxMERGVtbzEmMCQGCSqGSIb3DQEJARYXcHNhdnloaW5Aa2xpa2EtdGVj\
PavelSavyhin 1:042ca9148926 118 aC5jb20wWTATBgcqhkjOPQIBBggqhkjOPQMBBwNCAAT5IihA21BQZFW0vSdVxNuD\
PavelSavyhin 1:042ca9148926 119 VKXAN7rI3Op3/MiWOlXqHEGHZeYs5ug8qEYkDZDkafhO87LNC0xhNSnGsNnNmyPI\
PavelSavyhin 1:042ca9148926 120 o2AwXjAfBgNVHSMEGDAWgBRF1n2grhwmYjwSZmF74bVqm/enfjAdBgNVHQ4EFgQU\
PavelSavyhin 1:042ca9148926 121 qSNNYMI1XGRMnnLenZlU1h/WNAkwDAYDVR0TAQH/BAIwADAOBgNVHQ8BAf8EBAMC\
PavelSavyhin 1:042ca9148926 122 B4AwDQYJKoZIhvcNAQELBQADggEBADTAhidWjd+MD6sLqr8+ZTdIcka0kT0tnMGy\
PavelSavyhin 1:042ca9148926 123 Chz5ixaDpNI/OS9fi+SfOAd1Dd+/panpNtvJ5OfN0wkYJRd+lhBaN8M5lWsIF7EM\
PavelSavyhin 1:042ca9148926 124 FvFtc+UV2cvGyYmSW47fFaV3DOv8vL068cmpNkd/HF8q9r0QNd0h2o97G99Xkk9k\
PavelSavyhin 1:042ca9148926 125 90DIOgzu0C3sSTy5xDankCvfWIM2ibh5Laz3NmIqVW9jnnkMpQ00xViR8IdnfR4g\
PavelSavyhin 1:042ca9148926 126 ke1C33ZQh1yTGNEE94nVGRMB2cPY62ChrM/ffgmUo4De0M45tX8ucFVL+ZwaCc3E\
PavelSavyhin 1:042ca9148926 127 pmjMxFza6yZU50a74zZESmWGR5HYp0PSovglr9Xc5jvktqSugKM=\
PavelSavyhin 0:4cdaf9b1e7d0 128 \n\
PavelSavyhin 0:4cdaf9b1e7d0 129 -----END CERTIFICATE-----\n";
PavelSavyhin 0:4cdaf9b1e7d0 130
PavelSavyhin 0:4cdaf9b1e7d0 131
PavelSavyhin 0:4cdaf9b1e7d0 132
PavelSavyhin 0:4cdaf9b1e7d0 133 /**********************************************************************************************
PavelSavyhin 0:4cdaf9b1e7d0 134 ***********************************************************************************************
PavelSavyhin 0:4cdaf9b1e7d0 135 Private Key: Modify for your AWS IoT Thing
PavelSavyhin 0:4cdaf9b1e7d0 136 ***********************************************************************************************
PavelSavyhin 0:4cdaf9b1e7d0 137 ***********************************************************************************************/
PavelSavyhin 0:4cdaf9b1e7d0 138
PavelSavyhin 0:4cdaf9b1e7d0 139 /********************************************************************8****************************************
PavelSavyhin 0:4cdaf9b1e7d0 140 nucleo.key.pem - client key generated according to readme.
PavelSavyhin 0:4cdaf9b1e7d0 141 **************************************************************************************************************/
PavelSavyhin 0:4cdaf9b1e7d0 142
PavelSavyhin 0:4cdaf9b1e7d0 143 //This Client Key is example. Use own instead.
PavelSavyhin 0:4cdaf9b1e7d0 144 const uint8_t clientKey[] ="\
PavelSavyhin 0:4cdaf9b1e7d0 145 -----BEGIN EC PARAMETERS-----\n\
PavelSavyhin 1:042ca9148926 146 BggqhkjOPQMBBw==\
PavelSavyhin 0:4cdaf9b1e7d0 147 -----END EC PARAMETERS-----\n\
PavelSavyhin 0:4cdaf9b1e7d0 148 -----BEGIN EC PRIVATE KEY-----\n\
PavelSavyhin 1:042ca9148926 149 MHcCAQEEIByuPtqukIClJ35+FA0gdvlMs7FmSFiOJGpaYsyQs4wwoAoGCCqGSM49\
PavelSavyhin 1:042ca9148926 150 AwEHoUQDQgAE+SIoQNtQUGRVtL0nVcTbg1SlwDe6yNzqd/zIljpV6hxBh2XmLObo\
PavelSavyhin 1:042ca9148926 151 PKhGJA2Q5Gn4TvOyzQtMYTUpxrDZzZsjyA==\
PavelSavyhin 0:4cdaf9b1e7d0 152 -----END EC PRIVATE KEY-----\n";
PavelSavyhin 0:4cdaf9b1e7d0 153
PavelSavyhin 0:4cdaf9b1e7d0 154 int connack_rc = 0; // MQTT connack return code
PavelSavyhin 0:4cdaf9b1e7d0 155 int connectTimeout = 1000;
PavelSavyhin 0:4cdaf9b1e7d0 156 int retryAttempt = 0;
PavelSavyhin 0:4cdaf9b1e7d0 157
PavelSavyhin 0:4cdaf9b1e7d0 158 PressureSensor *pressure_sensor;
PavelSavyhin 0:4cdaf9b1e7d0 159 HumiditySensor *humidity_sensor;
PavelSavyhin 0:4cdaf9b1e7d0 160 TempSensor *temp_sensor1;
PavelSavyhin 0:4cdaf9b1e7d0 161 MagneticSensor *magnetic_sensor;
PavelSavyhin 0:4cdaf9b1e7d0 162 GyroSensor *gyro_sensor;
PavelSavyhin 0:4cdaf9b1e7d0 163 MotionSensor *accel_sensor;
PavelSavyhin 0:4cdaf9b1e7d0 164
PavelSavyhin 0:4cdaf9b1e7d0 165 MQTT::Message message;
PavelSavyhin 0:4cdaf9b1e7d0 166 MQTTString TopicName= { AWS_IOT_MQTT_TOPIC_TEST };
PavelSavyhin 0:4cdaf9b1e7d0 167 MQTT::MessageData MsgData(TopicName, message);
PavelSavyhin 0:4cdaf9b1e7d0 168
PavelSavyhin 0:4cdaf9b1e7d0 169 void subscribe_cb(MQTT::MessageData & msgMQTT) {
PavelSavyhin 0:4cdaf9b1e7d0 170 char msg[MQTT_MAX_PAYLOAD_SIZE];
PavelSavyhin 0:4cdaf9b1e7d0 171 msg[0]='\0';
PavelSavyhin 0:4cdaf9b1e7d0 172 strncat (msg, (char*)msgMQTT.message.payload, msgMQTT.message.payloadlen);
PavelSavyhin 0:4cdaf9b1e7d0 173 printf ("--->>> subscribe_cb msg: %s\n\r", msg);
PavelSavyhin 0:4cdaf9b1e7d0 174 }
PavelSavyhin 0:4cdaf9b1e7d0 175
PavelSavyhin 0:4cdaf9b1e7d0 176 int subscribe(MQTT::Client<MQTTWiFi, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTWiFi* ipstack)
PavelSavyhin 0:4cdaf9b1e7d0 177 {
PavelSavyhin 0:4cdaf9b1e7d0 178 char* pubTopic = AWS_IOT_MQTT_TOPIC_TEST;
PavelSavyhin 0:4cdaf9b1e7d0 179 return client->subscribe(pubTopic, MQTT::QOS0, subscribe_cb);
PavelSavyhin 0:4cdaf9b1e7d0 180 }
PavelSavyhin 0:4cdaf9b1e7d0 181
PavelSavyhin 0:4cdaf9b1e7d0 182 int connect(MQTT::Client<MQTTWiFi, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTWiFi* ipstack)
PavelSavyhin 0:4cdaf9b1e7d0 183 {
PavelSavyhin 0:4cdaf9b1e7d0 184 SpwfSAInterface& WiFi = ipstack->getWiFi();
PavelSavyhin 0:4cdaf9b1e7d0 185
PavelSavyhin 0:4cdaf9b1e7d0 186 // Network debug statements
PavelSavyhin 0:4cdaf9b1e7d0 187 LOG("=====================================\n\r");
PavelSavyhin 0:4cdaf9b1e7d0 188 LOG("Connecting WiFi.\n\r");
PavelSavyhin 0:4cdaf9b1e7d0 189 LOG("Nucleo IP ADDRESS: %s\n\r", WiFi.get_ip_address());
PavelSavyhin 0:4cdaf9b1e7d0 190 LOG("Nucleo MAC ADDRESS: %s\n\r", WiFi.get_mac_address());
PavelSavyhin 0:4cdaf9b1e7d0 191 LOG("Server Hostname: %s port: %d\n\r", AWS_IOT_MQTT_HOST, AWS_IOT_MQTT_PORT);
PavelSavyhin 0:4cdaf9b1e7d0 192 LOG("Client ID: %s\n\r", AWS_IOT_MQTT_CLIENT_ID);
PavelSavyhin 0:4cdaf9b1e7d0 193 //LOG("Topic: %s\n\r", AWS_IOT_MQTT_TOPIC_TEST);
PavelSavyhin 0:4cdaf9b1e7d0 194 //LOG("Subscription URL: %s\n\r", subscription_url);
PavelSavyhin 0:4cdaf9b1e7d0 195 LOG("=====================================\n\r");
PavelSavyhin 0:4cdaf9b1e7d0 196
PavelSavyhin 0:4cdaf9b1e7d0 197 ipstack->open(&ipstack->getWiFi());
PavelSavyhin 0:4cdaf9b1e7d0 198
PavelSavyhin 0:4cdaf9b1e7d0 199 int rc=ipstack->getNTPtime();
PavelSavyhin 0:4cdaf9b1e7d0 200
PavelSavyhin 0:4cdaf9b1e7d0 201 if (rc != 0)
PavelSavyhin 0:4cdaf9b1e7d0 202 {
PavelSavyhin 1:042ca9148926 203 WARN("Get NTP time error: %d\n", rc);
PavelSavyhin 0:4cdaf9b1e7d0 204 return rc;
PavelSavyhin 0:4cdaf9b1e7d0 205 }
PavelSavyhin 0:4cdaf9b1e7d0 206
PavelSavyhin 0:4cdaf9b1e7d0 207 rc = WiFi.setSocketClientSecurity((uint8_t *)"m", (uint8_t *)rootCA, (uint8_t *)clientCRT, (uint8_t *)clientKey, (uint8_t *)AWS_IOT_MQTT_HOST, ipstack->getTime());
PavelSavyhin 0:4cdaf9b1e7d0 208
PavelSavyhin 0:4cdaf9b1e7d0 209 if (rc != 0)
PavelSavyhin 0:4cdaf9b1e7d0 210 {
PavelSavyhin 1:042ca9148926 211 WARN("Set security params error: %d\n", rc);
PavelSavyhin 0:4cdaf9b1e7d0 212 return rc;
PavelSavyhin 0:4cdaf9b1e7d0 213 }
PavelSavyhin 0:4cdaf9b1e7d0 214
PavelSavyhin 0:4cdaf9b1e7d0 215 rc = ipstack->connect(AWS_IOT_MQTT_HOST, AWS_IOT_MQTT_PORT, connectTimeout);
PavelSavyhin 0:4cdaf9b1e7d0 216
PavelSavyhin 0:4cdaf9b1e7d0 217 if (rc != 0)
PavelSavyhin 0:4cdaf9b1e7d0 218 {
PavelSavyhin 1:042ca9148926 219 WARN("IP Stack connect returned: %d\n\r", rc);
PavelSavyhin 0:4cdaf9b1e7d0 220 return rc;
PavelSavyhin 0:4cdaf9b1e7d0 221 }
PavelSavyhin 0:4cdaf9b1e7d0 222
PavelSavyhin 0:4cdaf9b1e7d0 223 printf ("--->TCP Connected\n\r");
PavelSavyhin 0:4cdaf9b1e7d0 224
PavelSavyhin 0:4cdaf9b1e7d0 225 // MQTT Connect
PavelSavyhin 0:4cdaf9b1e7d0 226 MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
PavelSavyhin 0:4cdaf9b1e7d0 227 data.MQTTVersion = 4;
PavelSavyhin 0:4cdaf9b1e7d0 228 data.struct_version=0;
PavelSavyhin 0:4cdaf9b1e7d0 229 data.clientID.cstring = AWS_IOT_MQTT_CLIENT_ID;
PavelSavyhin 0:4cdaf9b1e7d0 230 //data.username.cstring = "use-token-auth";
PavelSavyhin 0:4cdaf9b1e7d0 231 //data.password.cstring = AWS_IOT_AUTH_TOKEN;
PavelSavyhin 0:4cdaf9b1e7d0 232
PavelSavyhin 0:4cdaf9b1e7d0 233 if ((rc = client->connect(data)) == 0)
PavelSavyhin 0:4cdaf9b1e7d0 234 {
PavelSavyhin 0:4cdaf9b1e7d0 235 printf ("--->MQTT Connected\n\r");
PavelSavyhin 0:4cdaf9b1e7d0 236
PavelSavyhin 0:4cdaf9b1e7d0 237 if (!subscribe(client, ipstack)) printf ("--->>>MQTT subscribed to: %s\n\r",AWS_IOT_MQTT_TOPIC_TEST);
PavelSavyhin 0:4cdaf9b1e7d0 238 }
PavelSavyhin 0:4cdaf9b1e7d0 239 else
PavelSavyhin 0:4cdaf9b1e7d0 240 {
PavelSavyhin 0:4cdaf9b1e7d0 241 WARN("MQTT connect returned %d\n", rc);
PavelSavyhin 0:4cdaf9b1e7d0 242 }
PavelSavyhin 0:4cdaf9b1e7d0 243 if (rc >= 0)
PavelSavyhin 0:4cdaf9b1e7d0 244 connack_rc = rc;
PavelSavyhin 0:4cdaf9b1e7d0 245 return rc;
PavelSavyhin 0:4cdaf9b1e7d0 246 }
PavelSavyhin 0:4cdaf9b1e7d0 247
PavelSavyhin 0:4cdaf9b1e7d0 248 int getConnTimeout(int attemptNumber)
PavelSavyhin 0:4cdaf9b1e7d0 249 { // First 10 attempts try within 3 seconds, next 10 attempts retry after every 1 minute
PavelSavyhin 0:4cdaf9b1e7d0 250 // after 20 attempts, retry every 10 minutes
PavelSavyhin 0:4cdaf9b1e7d0 251 return (attemptNumber < 10) ? 3 : (attemptNumber < 20) ? 60 : 600;
PavelSavyhin 0:4cdaf9b1e7d0 252 }
PavelSavyhin 0:4cdaf9b1e7d0 253
PavelSavyhin 0:4cdaf9b1e7d0 254 void attemptConnect(MQTT::Client<MQTTWiFi, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTWiFi* ipstack)
PavelSavyhin 0:4cdaf9b1e7d0 255 {
PavelSavyhin 0:4cdaf9b1e7d0 256 while (connect(client, ipstack) != MQTT_CONNECTION_ACCEPTED)
PavelSavyhin 0:4cdaf9b1e7d0 257 {
PavelSavyhin 0:4cdaf9b1e7d0 258 if (connack_rc == MQTT_NOT_AUTHORIZED || connack_rc == MQTT_BAD_USERNAME_OR_PASSWORD)
PavelSavyhin 0:4cdaf9b1e7d0 259 {
PavelSavyhin 0:4cdaf9b1e7d0 260 printf ("File: %s, Line: %d Error: %d\n\r",__FILE__,__LINE__, connack_rc);
PavelSavyhin 0:4cdaf9b1e7d0 261 return; // don't reattempt to connect if credentials are wrong
PavelSavyhin 0:4cdaf9b1e7d0 262 }
PavelSavyhin 0:4cdaf9b1e7d0 263
PavelSavyhin 0:4cdaf9b1e7d0 264 int timeout = getConnTimeout(++retryAttempt);
PavelSavyhin 1:042ca9148926 265 WARN("Retry attempt number %d waiting %d\n\r", retryAttempt, timeout);
PavelSavyhin 0:4cdaf9b1e7d0 266
PavelSavyhin 0:4cdaf9b1e7d0 267 // if ipstack and client were on the heap we could deconstruct and goto a label where they are constructed
PavelSavyhin 0:4cdaf9b1e7d0 268 // or maybe just add the proper members to do this disconnect and call attemptConnect(...)
PavelSavyhin 0:4cdaf9b1e7d0 269 // this works - reset the system when the retry count gets to a threshold
PavelSavyhin 1:042ca9148926 270 if (retryAttempt == 2)
PavelSavyhin 0:4cdaf9b1e7d0 271 {
PavelSavyhin 0:4cdaf9b1e7d0 272 ipstack->getWiFi().reset_chip();
PavelSavyhin 0:4cdaf9b1e7d0 273 NVIC_SystemReset();
PavelSavyhin 0:4cdaf9b1e7d0 274 }
PavelSavyhin 0:4cdaf9b1e7d0 275 else
PavelSavyhin 0:4cdaf9b1e7d0 276 wait(timeout);
PavelSavyhin 0:4cdaf9b1e7d0 277 }
PavelSavyhin 0:4cdaf9b1e7d0 278 }
PavelSavyhin 0:4cdaf9b1e7d0 279
PavelSavyhin 0:4cdaf9b1e7d0 280 int publish(MQTT::Client<MQTTWiFi, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTWiFi* ipstack)
PavelSavyhin 0:4cdaf9b1e7d0 281 {
PavelSavyhin 0:4cdaf9b1e7d0 282 MQTT::Message message;
PavelSavyhin 0:4cdaf9b1e7d0 283 char* pubTopic = AWS_IOT_MQTT_TOPIC_SHADOW;
PavelSavyhin 0:4cdaf9b1e7d0 284
PavelSavyhin 0:4cdaf9b1e7d0 285 char buf[MQTT_MAX_PAYLOAD_SIZE];
PavelSavyhin 0:4cdaf9b1e7d0 286 float temp, press, hum;
PavelSavyhin 0:4cdaf9b1e7d0 287 int32_t magnet[3];
PavelSavyhin 0:4cdaf9b1e7d0 288 int32_t gyro[3];
PavelSavyhin 0:4cdaf9b1e7d0 289 int32_t accel[3];
PavelSavyhin 0:4cdaf9b1e7d0 290
PavelSavyhin 0:4cdaf9b1e7d0 291 temp_sensor1->GetTemperature(&temp);
PavelSavyhin 0:4cdaf9b1e7d0 292 pressure_sensor->GetPressure(&press);
PavelSavyhin 0:4cdaf9b1e7d0 293 humidity_sensor->GetHumidity(&hum);
PavelSavyhin 0:4cdaf9b1e7d0 294 magnetic_sensor->Get_M_Axes(magnet);
PavelSavyhin 0:4cdaf9b1e7d0 295 gyro_sensor->Get_G_Axes(gyro);
PavelSavyhin 0:4cdaf9b1e7d0 296 accel_sensor->Get_X_Axes(accel);
PavelSavyhin 1:042ca9148926 297
PavelSavyhin 0:4cdaf9b1e7d0 298 if (!myButtonPressed)
PavelSavyhin 0:4cdaf9b1e7d0 299 {
PavelSavyhin 0:4cdaf9b1e7d0 300 butled = 1;
PavelSavyhin 0:4cdaf9b1e7d0 301 sprintf(buf, "{\"state\": {\"reported\": {\"temperature\": %f, \"humidity\": %f, \"pressure\": %f, \"accelerometer\": [%f, %f, %f], \"gyroscope\": [%f, %f, %f], \"magnetometer\": [%f, %f, %f]}}}",
PavelSavyhin 0:4cdaf9b1e7d0 302 temp, hum, press, accel[0]/1000.0, accel[1]/1000.0, accel[2]/1000.0, gyro[0]/1000.0, gyro[1]/1000.0, gyro[2]/1000.0, magnet[0]/10.0, magnet[1]/10.0, magnet[2]/10.0);
PavelSavyhin 0:4cdaf9b1e7d0 303 }
PavelSavyhin 0:4cdaf9b1e7d0 304 else
PavelSavyhin 0:4cdaf9b1e7d0 305 {
PavelSavyhin 0:4cdaf9b1e7d0 306 myButtonPressed = false; // reset state
PavelSavyhin 0:4cdaf9b1e7d0 307 butled = 0;
PavelSavyhin 0:4cdaf9b1e7d0 308
PavelSavyhin 0:4cdaf9b1e7d0 309 sprintf(buf, "{\"temperature\": %f, \"humidity\": %f, \"pressure\": %f, \"accelerometer\": [%f, %f, %f], \"gyroscope\": [%f, %f, %f], \"magnetometer\": [%f, %f, %f], \"marker\": true}",
PavelSavyhin 0:4cdaf9b1e7d0 310 temp, hum, press, accel[0]/1000.0, accel[1]/1000.0, accel[2]/1000.0, gyro[0]/1000.0, gyro[1]/1000.0, gyro[2]/1000.0, magnet[0]/10.0, magnet[1]/10.0, magnet[2]/10.0);
PavelSavyhin 0:4cdaf9b1e7d0 311 pubTopic = AWS_IOT_MQTT_TOPIC_DATA;
PavelSavyhin 0:4cdaf9b1e7d0 312 }
PavelSavyhin 0:4cdaf9b1e7d0 313
PavelSavyhin 0:4cdaf9b1e7d0 314 message.qos = MQTT::QOS0;
PavelSavyhin 0:4cdaf9b1e7d0 315 message.retained = false;
PavelSavyhin 0:4cdaf9b1e7d0 316 message.dup = false;
PavelSavyhin 0:4cdaf9b1e7d0 317 message.payload = (void*)buf;
PavelSavyhin 0:4cdaf9b1e7d0 318 message.payloadlen = strlen(buf);
PavelSavyhin 0:4cdaf9b1e7d0 319
PavelSavyhin 0:4cdaf9b1e7d0 320 printf("Length - %d, Publishing %s\n\r", strlen(buf), buf);
PavelSavyhin 0:4cdaf9b1e7d0 321
PavelSavyhin 0:4cdaf9b1e7d0 322 return client->publish(pubTopic, message);
PavelSavyhin 0:4cdaf9b1e7d0 323 }
PavelSavyhin 0:4cdaf9b1e7d0 324
PavelSavyhin 0:4cdaf9b1e7d0 325 void pressed()
PavelSavyhin 0:4cdaf9b1e7d0 326 {
PavelSavyhin 0:4cdaf9b1e7d0 327 myButtonPressed = true;
PavelSavyhin 0:4cdaf9b1e7d0 328 }
PavelSavyhin 0:4cdaf9b1e7d0 329
PavelSavyhin 0:4cdaf9b1e7d0 330 int main()
PavelSavyhin 0:4cdaf9b1e7d0 331 {
PavelSavyhin 0:4cdaf9b1e7d0 332 const char * ssid = SSID; // Network must be visible otherwise it can't connect
PavelSavyhin 0:4cdaf9b1e7d0 333 const char * seckey = PASSW;
PavelSavyhin 0:4cdaf9b1e7d0 334
PavelSavyhin 0:4cdaf9b1e7d0 335 pc.baud(115200);
PavelSavyhin 0:4cdaf9b1e7d0 336
PavelSavyhin 1:042ca9148926 337 SpwfSAInterface spwf(D8, D2, true);
PavelSavyhin 0:4cdaf9b1e7d0 338
PavelSavyhin 0:4cdaf9b1e7d0 339 myled=0;
PavelSavyhin 0:4cdaf9b1e7d0 340 DevI2C *i2c = new DevI2C(I2C_SDA, I2C_SCL);
PavelSavyhin 0:4cdaf9b1e7d0 341 i2c->frequency(400000);
PavelSavyhin 0:4cdaf9b1e7d0 342
PavelSavyhin 0:4cdaf9b1e7d0 343 mybutton.fall(&pressed);
PavelSavyhin 0:4cdaf9b1e7d0 344
PavelSavyhin 0:4cdaf9b1e7d0 345 X_NUCLEO_IKS01A1 *mems_expansion_board = X_NUCLEO_IKS01A1::Instance(i2c);
PavelSavyhin 0:4cdaf9b1e7d0 346 pressure_sensor = mems_expansion_board->pt_sensor;
PavelSavyhin 0:4cdaf9b1e7d0 347 temp_sensor1 = mems_expansion_board->ht_sensor;
PavelSavyhin 0:4cdaf9b1e7d0 348 humidity_sensor = mems_expansion_board->ht_sensor;
PavelSavyhin 0:4cdaf9b1e7d0 349 magnetic_sensor = mems_expansion_board->magnetometer;
PavelSavyhin 0:4cdaf9b1e7d0 350 gyro_sensor = mems_expansion_board->GetGyroscope();
PavelSavyhin 0:4cdaf9b1e7d0 351 accel_sensor = mems_expansion_board->GetAccelerometer();
PavelSavyhin 0:4cdaf9b1e7d0 352
PavelSavyhin 1:042ca9148926 353 // Due to bug in mbed this workaround is needed to avoid Nucleo hang up when lsm6ds3 is absent
PavelSavyhin 1:042ca9148926 354 if (mems_expansion_board->gyro_lsm6ds3 == NULL)
PavelSavyhin 1:042ca9148926 355 {
PavelSavyhin 1:042ca9148926 356 NVIC_DisableIRQ(EXTI4_IRQn);
PavelSavyhin 1:042ca9148926 357 NVIC_ClearPendingIRQ(EXTI4_IRQn);
PavelSavyhin 1:042ca9148926 358 }
PavelSavyhin 1:042ca9148926 359
PavelSavyhin 0:4cdaf9b1e7d0 360 pc.printf("\r\nX-NUCLEO-IDW01M1 mbed Application\r\n");
PavelSavyhin 0:4cdaf9b1e7d0 361 pc.printf("\r\nconnecting to AP\r\n");
PavelSavyhin 0:4cdaf9b1e7d0 362
PavelSavyhin 0:4cdaf9b1e7d0 363 MQTTWiFi ipstack(spwf, ssid, seckey, NSAPI_SECURITY_WPA2);
PavelSavyhin 0:4cdaf9b1e7d0 364
PavelSavyhin 0:4cdaf9b1e7d0 365 LOG("Connected to WiFI.\r\n");
PavelSavyhin 1:042ca9148926 366
PavelSavyhin 1:042ca9148926 367 spwf.set_debug(false);
PavelSavyhin 0:4cdaf9b1e7d0 368
PavelSavyhin 1:042ca9148926 369 MQTT::Client<MQTTWiFi, Countdown, MQTT_MAX_PACKET_SIZE> client(ipstack, 5000);
PavelSavyhin 0:4cdaf9b1e7d0 370
PavelSavyhin 0:4cdaf9b1e7d0 371 attemptConnect(&client, &ipstack);
PavelSavyhin 0:4cdaf9b1e7d0 372
PavelSavyhin 0:4cdaf9b1e7d0 373 if (connack_rc == MQTT_NOT_AUTHORIZED || connack_rc == MQTT_BAD_USERNAME_OR_PASSWORD)
PavelSavyhin 0:4cdaf9b1e7d0 374 {
PavelSavyhin 0:4cdaf9b1e7d0 375 while (true)
PavelSavyhin 0:4cdaf9b1e7d0 376 wait(1.0); // Permanent failures - don't retry
PavelSavyhin 0:4cdaf9b1e7d0 377 }
PavelSavyhin 0:4cdaf9b1e7d0 378
PavelSavyhin 0:4cdaf9b1e7d0 379 myled=1;
PavelSavyhin 0:4cdaf9b1e7d0 380
PavelSavyhin 0:4cdaf9b1e7d0 381 int count = 0;
PavelSavyhin 0:4cdaf9b1e7d0 382
PavelSavyhin 0:4cdaf9b1e7d0 383 while (true)
PavelSavyhin 0:4cdaf9b1e7d0 384 {
PavelSavyhin 1:042ca9148926 385 if (++count == 1)
PavelSavyhin 0:4cdaf9b1e7d0 386 {
PavelSavyhin 0:4cdaf9b1e7d0 387 myled = 0;
PavelSavyhin 0:4cdaf9b1e7d0 388 // Publish a message every second
PavelSavyhin 0:4cdaf9b1e7d0 389 if (publish(&client, &ipstack) != 0)
PavelSavyhin 0:4cdaf9b1e7d0 390 {
PavelSavyhin 0:4cdaf9b1e7d0 391 myled=0;
PavelSavyhin 0:4cdaf9b1e7d0 392 ipstack.getWiFi().reset_chip();
PavelSavyhin 0:4cdaf9b1e7d0 393 NVIC_SystemReset();
PavelSavyhin 0:4cdaf9b1e7d0 394 attemptConnect(&client, &ipstack); // if we have lost the connection
PavelSavyhin 0:4cdaf9b1e7d0 395 }
PavelSavyhin 0:4cdaf9b1e7d0 396 else myled=1;
PavelSavyhin 0:4cdaf9b1e7d0 397
PavelSavyhin 0:4cdaf9b1e7d0 398 count = 0;
PavelSavyhin 0:4cdaf9b1e7d0 399 }
PavelSavyhin 0:4cdaf9b1e7d0 400
PavelSavyhin 1:042ca9148926 401 client.yield(1000); // allow the MQTT client to receive messages
PavelSavyhin 0:4cdaf9b1e7d0 402 }
PavelSavyhin 0:4cdaf9b1e7d0 403 }