Aryan Varma / Mbed 2 deprecated PIRMotionsensor_IBMIoTclient

IoT based security system that detects suspicious movements through a motion detector and alerts the user on their gmail. In the presence of motion sensed between 7 to 9 times, the Grove PIR sensor sends an input to the board which is connected to internet via Ethernet. The board publishes the sensor data on IBM IoT foundation, which is known as IBM Watson. The data is then sent to IBM Bluemix which provides real time analysis and the remote time data management and monitoring. For more information : https://developer.ibm.com/recipes/tutorials/mbed-c-client-library-for-ibm-iot-foundation/

Dependencies:   C12832 EthernetInterface LM75B MMA7660 MQTT mbed-rtos mbed

Fork of IBMIoTClientEthernetExample by IBM Watson IoT

main.cpp@18:94da9de96d54, 2015-08-12 (annotated)

Committer:
icraggs
Date:
Wed Aug 12 20:50:56 2015 +0000
Revision:
18:94da9de96d54
Parent:
17:74801ec6a672
Child:
19:ee5e5c9573e5
Stop the display flashing unnecessarily

Who changed what in which revision?

UserRevisionLine numberNew contents of line
samdanbury 6:37b6d0d56190 1 /*******************************************************************************
icraggs 16:2420bfbf5f1c 2 * Copyright (c) 2014, 2015 IBM Corp.
samdanbury 6:37b6d0d56190 3 *
samdanbury 6:37b6d0d56190 4 * All rights reserved. This program and the accompanying materials
samdanbury 6:37b6d0d56190 5 * are made available under the terms of the Eclipse Public License v1.0
samdanbury 6:37b6d0d56190 6 * and Eclipse Distribution License v1.0 which accompany this distribution.
samdanbury 6:37b6d0d56190 7 *
samdanbury 6:37b6d0d56190 8 * The Eclipse Public License is available at
samdanbury 6:37b6d0d56190 9 * http://www.eclipse.org/legal/epl-v10.html
samdanbury 6:37b6d0d56190 10 * and the Eclipse Distribution License is available at
samdanbury 6:37b6d0d56190 11 * http://www.eclipse.org/org/documents/edl-v10.php.
samdanbury 6:37b6d0d56190 12 *
samdanbury 6:37b6d0d56190 13 * Contributors:
samdanbury 6:37b6d0d56190 14 * Sam Danbury - initial implementation
samdanbury 6:37b6d0d56190 15 * Ian Craggs - refactoring to remove STL and other changes
icraggs 8:80d49dd91542 16 * Sam Grove - added check for Ethernet cable.
chris 10:0b5e0dfee08e 17 * Chris Styles - Added additional menu screen for software revision
icraggs 16:2420bfbf5f1c 18 * James Sutton - Mac fix and extra debug
icraggs 16:2420bfbf5f1c 19 * Ian Craggs - add not authorized messages
chris 10:0b5e0dfee08e 20 *
chris 10:0b5e0dfee08e 21 * To do :
chris 10:0b5e0dfee08e 22 * Add magnetometer sensor output to IoT data stream
chris 10:0b5e0dfee08e 23 *
samdanbury 6:37b6d0d56190 24 *******************************************************************************/
samdanbury 6:37b6d0d56190 25
samdanbury 6:37b6d0d56190 26 #include "LM75B.h"
samdanbury 6:37b6d0d56190 27 #include "MMA7660.h"
samdanbury 6:37b6d0d56190 28 #include "MQTTClient.h"
samdanbury 6:37b6d0d56190 29 #include "MQTTEthernet.h"
samdanbury 6:37b6d0d56190 30 #include "C12832.h"
samdanbury 6:37b6d0d56190 31 #include "Arial12x12.h"
samdanbury 6:37b6d0d56190 32 #include "rtos.h"
samdanbury 6:37b6d0d56190 33
chris 10:0b5e0dfee08e 34 // Update this to the next number *before* a commit
icraggs 18:94da9de96d54 35 #define __APP_SW_REVISION__ "18"
chris 10:0b5e0dfee08e 36
samdanbury 6:37b6d0d56190 37 // Configuration values needed to connect to IBM IoT Cloud
icraggs 8:80d49dd91542 38 #define ORG "quickstart" // For a registered connection, replace with your org
icraggs 8:80d49dd91542 39 #define ID "" // For a registered connection, replace with your id
icraggs 8:80d49dd91542 40 #define AUTH_TOKEN "" // For a registered connection, replace with your auth-token
icraggs 8:80d49dd91542 41 #define TYPE DEFAULT_TYPE_NAME // For a registered connection, replace with your type
samdanbury 6:37b6d0d56190 42
samdanbury 6:37b6d0d56190 43 #define MQTT_PORT 1883
samdanbury 6:37b6d0d56190 44 #define MQTT_TLS_PORT 8883
samdanbury 6:37b6d0d56190 45 #define IBM_IOT_PORT MQTT_PORT
samdanbury 6:37b6d0d56190 46
samdanbury 6:37b6d0d56190 47 #define MQTT_MAX_PACKET_SIZE 250
samdanbury 6:37b6d0d56190 48
mazgch 11:7a6df9a2dcdc 49 #if defined(TARGET_UBLOX_C027)
mazgch 11:7a6df9a2dcdc 50 #warning "Compiling for mbed C027"
mazgch 11:7a6df9a2dcdc 51 #include "C027.h"
mazgch 11:7a6df9a2dcdc 52 #elif defined(TARGET_LPC1768)
samdanbury 6:37b6d0d56190 53 #warning "Compiling for mbed LPC1768"
samdanbury 6:37b6d0d56190 54 #include "LPC1768.h"
samdanbury 6:37b6d0d56190 55 #elif defined(TARGET_K64F)
samdanbury 6:37b6d0d56190 56 #warning "Compiling for mbed K64F"
samdanbury 6:37b6d0d56190 57 #include "K64F.h"
samdanbury 6:37b6d0d56190 58 #endif
samdanbury 6:37b6d0d56190 59
jsutton 14:1f961d19f3cf 60
icraggs 8:80d49dd91542 61 bool quickstartMode = true;
samdanbury 6:37b6d0d56190 62 char org[11] = ORG;
samdanbury 6:37b6d0d56190 63 char type[30] = TYPE;
samdanbury 6:37b6d0d56190 64 char id[30] = ID; // mac without colons
samdanbury 6:37b6d0d56190 65 char auth_token[30] = AUTH_TOKEN; // Auth_token is only used in non-quickstart mode
samdanbury 6:37b6d0d56190 66
samdanbury 6:37b6d0d56190 67 bool connected = false;
jsutton 14:1f961d19f3cf 68 bool mqttConnecting = false;
jsutton 14:1f961d19f3cf 69 bool netConnected = false;
jsutton 14:1f961d19f3cf 70 bool netConnecting = false;
jsutton 14:1f961d19f3cf 71 bool ethernetInitialising = true;
icraggs 16:2420bfbf5f1c 72 int connack_rc = 0; // MQTT connack return code
jsutton 14:1f961d19f3cf 73 int retryAttempt = 0;
jsutton 14:1f961d19f3cf 74 int menuItem = 0;
jsutton 14:1f961d19f3cf 75
samdanbury 6:37b6d0d56190 76 char* joystickPos = "CENTRE";
samdanbury 6:37b6d0d56190 77 int blink_interval = 0;
samdanbury 6:37b6d0d56190 78
jsutton 13:85801e3b83d3 79 char* ip_addr = "";
jsutton 13:85801e3b83d3 80 char* gateway_addr = "";
jsutton 14:1f961d19f3cf 81 char* host_addr = "";
jsutton 14:1f961d19f3cf 82 int connectTimeout = 1000;
jsutton 14:1f961d19f3cf 83
jsutton 14:1f961d19f3cf 84 // If we wanted to manually set the MAC address,
jsutton 14:1f961d19f3cf 85 // this is how to do it. In this example, we take
jsutton 14:1f961d19f3cf 86 // the original Mbed Set MAC address and combine it
jsutton 14:1f961d19f3cf 87 // with a prefix of our choosing.
jsutton 14:1f961d19f3cf 88 /*
jsutton 14:1f961d19f3cf 89 extern "C" void $Super$$mbed_mac_address(char *s);
jsutton 14:1f961d19f3cf 90 extern "C" void $Sub$$mbed_mac_address(char *s)
jsutton 14:1f961d19f3cf 91 {
jsutton 15:09458079f4bb 92 char originalMAC[6] = "";
jsutton 15:09458079f4bb 93 $Super$$mbed_mac_address(originalMAC);
jsutton 14:1f961d19f3cf 94
jsutton 14:1f961d19f3cf 95 char mac[6];
jsutton 14:1f961d19f3cf 96 mac[0] = 0x00;
jsutton 14:1f961d19f3cf 97 mac[1] = 0x08;
jsutton 14:1f961d19f3cf 98 mac[2] = 0xdc;
jsutton 15:09458079f4bb 99 mac[3] = originalMAC[3];
jsutton 15:09458079f4bb 100 mac[4] = originalMAC[4];
jsutton 15:09458079f4bb 101 mac[5] = originalMAC[5];
jsutton 14:1f961d19f3cf 102 memcpy(s, mac, 6);
jsutton 14:1f961d19f3cf 103 }
jsutton 14:1f961d19f3cf 104 */
jsutton 13:85801e3b83d3 105
samdanbury 6:37b6d0d56190 106
samdanbury 6:37b6d0d56190 107 void off()
samdanbury 6:37b6d0d56190 108 {
samdanbury 6:37b6d0d56190 109 r = g = b = 1.0; // 1 is off, 0 is full brightness
samdanbury 6:37b6d0d56190 110 }
samdanbury 6:37b6d0d56190 111
samdanbury 6:37b6d0d56190 112 void red()
samdanbury 6:37b6d0d56190 113 {
samdanbury 6:37b6d0d56190 114 r = 0.7; g = 1.0; b = 1.0; // 1 is off, 0 is full brightness
samdanbury 6:37b6d0d56190 115 }
samdanbury 6:37b6d0d56190 116
samdanbury 6:37b6d0d56190 117 void yellow()
samdanbury 6:37b6d0d56190 118 {
samdanbury 6:37b6d0d56190 119 r = 0.7; g = 0.7; b = 1.0; // 1 is off, 0 is full brightness
samdanbury 6:37b6d0d56190 120 }
samdanbury 6:37b6d0d56190 121
samdanbury 6:37b6d0d56190 122 void green()
samdanbury 6:37b6d0d56190 123 {
samdanbury 6:37b6d0d56190 124 r = 1.0; g = 0.7; b = 1.0; // 1 is off, 0 is full brightness
samdanbury 6:37b6d0d56190 125 }
samdanbury 6:37b6d0d56190 126
samdanbury 6:37b6d0d56190 127
samdanbury 6:37b6d0d56190 128 void flashing_yellow(void const *args)
samdanbury 6:37b6d0d56190 129 {
samdanbury 6:37b6d0d56190 130 bool on = false;
icraggs 16:2420bfbf5f1c 131 while (!connected && connack_rc != MQTT_NOT_AUTHORIZED && connack_rc != MQTT_BAD_USERNAME_OR_PASSWORD) // flashing yellow only while connecting
samdanbury 6:37b6d0d56190 132 {
samdanbury 6:37b6d0d56190 133 on = !on;
samdanbury 6:37b6d0d56190 134 if (on)
samdanbury 6:37b6d0d56190 135 yellow();
samdanbury 6:37b6d0d56190 136 else
samdanbury 6:37b6d0d56190 137 off();
samdanbury 6:37b6d0d56190 138 wait(0.5);
samdanbury 6:37b6d0d56190 139 }
samdanbury 6:37b6d0d56190 140 }
samdanbury 6:37b6d0d56190 141
samdanbury 6:37b6d0d56190 142
samdanbury 6:37b6d0d56190 143 void flashing_red(void const *args) // to be used when the connection is lost
samdanbury 6:37b6d0d56190 144 {
samdanbury 6:37b6d0d56190 145 bool on = false;
samdanbury 6:37b6d0d56190 146 while (!connected)
samdanbury 6:37b6d0d56190 147 {
samdanbury 6:37b6d0d56190 148 on = !on;
samdanbury 6:37b6d0d56190 149 if (on)
samdanbury 6:37b6d0d56190 150 red();
samdanbury 6:37b6d0d56190 151 else
samdanbury 6:37b6d0d56190 152 off();
samdanbury 6:37b6d0d56190 153 wait(2.0);
samdanbury 6:37b6d0d56190 154 }
samdanbury 6:37b6d0d56190 155 }
samdanbury 6:37b6d0d56190 156
samdanbury 6:37b6d0d56190 157
samdanbury 6:37b6d0d56190 158 void printMenu(int menuItem)
samdanbury 6:37b6d0d56190 159 {
icraggs 18:94da9de96d54 160 static char last_line1[30] = "", last_line2[30] = "";
icraggs 18:94da9de96d54 161 char line1[30] = "", line2[30] = "";
icraggs 18:94da9de96d54 162
samdanbury 6:37b6d0d56190 163 switch (menuItem)
samdanbury 6:37b6d0d56190 164 {
samdanbury 6:37b6d0d56190 165 case 0:
icraggs 18:94da9de96d54 166 sprintf(line1, "IBM IoT Cloud");
icraggs 18:94da9de96d54 167 sprintf(line2, "Scroll with joystick");
samdanbury 6:37b6d0d56190 168 break;
samdanbury 6:37b6d0d56190 169 case 1:
icraggs 18:94da9de96d54 170 sprintf(line1, "Go to:");
icraggs 18:94da9de96d54 171 sprintf(line2, "http://ibm.biz/iotqstart");
samdanbury 6:37b6d0d56190 172 break;
samdanbury 6:37b6d0d56190 173 case 2:
icraggs 18:94da9de96d54 174 sprintf(line1, "Device Identity:");
icraggs 18:94da9de96d54 175 sprintf(line2, "%s", id);
samdanbury 6:37b6d0d56190 176 break;
samdanbury 6:37b6d0d56190 177 case 3:
icraggs 18:94da9de96d54 178 sprintf(line1, "MQTT Status:");
icraggs 16:2420bfbf5f1c 179 if (mqttConnecting)
icraggs 18:94da9de96d54 180 sprintf(line2, "Connecting... %d/5", retryAttempt);
icraggs 16:2420bfbf5f1c 181 else
icraggs 16:2420bfbf5f1c 182 {
icraggs 16:2420bfbf5f1c 183 if (connected)
icraggs 18:94da9de96d54 184 sprintf(line2, "Connected");
icraggs 16:2420bfbf5f1c 185 else
icraggs 16:2420bfbf5f1c 186 {
icraggs 16:2420bfbf5f1c 187 switch (connack_rc)
icraggs 16:2420bfbf5f1c 188 {
icraggs 16:2420bfbf5f1c 189 case MQTT_CLIENTID_REJECTED:
icraggs 18:94da9de96d54 190 sprintf(line2, "Clientid rejected");
icraggs 16:2420bfbf5f1c 191 break;
icraggs 16:2420bfbf5f1c 192 case MQTT_BAD_USERNAME_OR_PASSWORD:
icraggs 18:94da9de96d54 193 sprintf(line2, "Invalid username or password");
icraggs 16:2420bfbf5f1c 194 break;
icraggs 16:2420bfbf5f1c 195 case MQTT_NOT_AUTHORIZED:
icraggs 18:94da9de96d54 196 sprintf(line2, "Not authorized");
icraggs 16:2420bfbf5f1c 197 break;
icraggs 16:2420bfbf5f1c 198 default:
icraggs 18:94da9de96d54 199 sprintf(line2, "Disconnected");
icraggs 16:2420bfbf5f1c 200 }
icraggs 16:2420bfbf5f1c 201 }
jsutton 14:1f961d19f3cf 202 }
samdanbury 6:37b6d0d56190 203 break;
chris 10:0b5e0dfee08e 204 case 4:
icraggs 18:94da9de96d54 205 sprintf(line1, "Ethernet State:");
icraggs 18:94da9de96d54 206 sprintf(line2, ethernetInitialising ? "Initializing..." : "Initialized");
jsutton 14:1f961d19f3cf 207 break;
jsutton 14:1f961d19f3cf 208 case 5:
icraggs 18:94da9de96d54 209 sprintf(line1, "Socket State:");
icraggs 16:2420bfbf5f1c 210 if (netConnecting)
icraggs 18:94da9de96d54 211 sprintf(line2, "Connecting... %d/5", retryAttempt);
icraggs 16:2420bfbf5f1c 212 else
icraggs 18:94da9de96d54 213 sprintf(line2, netConnected ? "Connected" : "Disconnected");
jsutton 13:85801e3b83d3 214 break;
jsutton 14:1f961d19f3cf 215 case 6:
icraggs 18:94da9de96d54 216 sprintf(line1, "IP Address:");
icraggs 18:94da9de96d54 217 sprintf(line2, "%s", ip_addr);
jsutton 13:85801e3b83d3 218 break;
jsutton 14:1f961d19f3cf 219 case 7:
icraggs 18:94da9de96d54 220 sprintf(line1, "Gateway:");
icraggs 18:94da9de96d54 221 sprintf(line2, "%s", gateway_addr);
jsutton 13:85801e3b83d3 222 break;
jsutton 14:1f961d19f3cf 223 case 8:
icraggs 18:94da9de96d54 224 sprintf(line1, "App version:");
icraggs 18:94da9de96d54 225 sprintf(line2, "%s", __APP_SW_REVISION__);
chris 10:0b5e0dfee08e 226 break;
jsutton 14:1f961d19f3cf 227 case 9:
icraggs 18:94da9de96d54 228 sprintf(line1, "Current Timeout:");
icraggs 18:94da9de96d54 229 sprintf(line2, "%d ms", connectTimeout);
jsutton 14:1f961d19f3cf 230 break;
samdanbury 6:37b6d0d56190 231 }
icraggs 18:94da9de96d54 232
icraggs 18:94da9de96d54 233 if (strcmp(line1, last_line1) != 0 || strcmp(line2, last_line2) != 0)
icraggs 18:94da9de96d54 234 {
icraggs 18:94da9de96d54 235 lcd.cls();
icraggs 18:94da9de96d54 236 lcd.locate(0, 0);
icraggs 18:94da9de96d54 237 lcd.printf(line1);
icraggs 18:94da9de96d54 238 strncpy(last_line1, line1, sizeof(last_line1));
icraggs 18:94da9de96d54 239
icraggs 18:94da9de96d54 240 lcd.locate(0,16);
icraggs 18:94da9de96d54 241 lcd.printf(line2);
icraggs 18:94da9de96d54 242 strncpy(last_line2, line2, sizeof(last_line2));
icraggs 18:94da9de96d54 243 }
samdanbury 6:37b6d0d56190 244 }
samdanbury 6:37b6d0d56190 245
samdanbury 6:37b6d0d56190 246
samdanbury 6:37b6d0d56190 247 void setMenu()
samdanbury 6:37b6d0d56190 248 {
jsutton 14:1f961d19f3cf 249
samdanbury 6:37b6d0d56190 250 if (Down)
samdanbury 6:37b6d0d56190 251 {
samdanbury 6:37b6d0d56190 252 joystickPos = "DOWN";
jsutton 14:1f961d19f3cf 253 if (menuItem >= 0 && menuItem < 9)
samdanbury 6:37b6d0d56190 254 printMenu(++menuItem);
samdanbury 6:37b6d0d56190 255 }
samdanbury 6:37b6d0d56190 256 else if (Left)
samdanbury 6:37b6d0d56190 257 joystickPos = "LEFT";
samdanbury 6:37b6d0d56190 258 else if (Click)
samdanbury 6:37b6d0d56190 259 joystickPos = "CLICK";
samdanbury 6:37b6d0d56190 260 else if (Up)
samdanbury 6:37b6d0d56190 261 {
samdanbury 6:37b6d0d56190 262 joystickPos = "UP";
jsutton 14:1f961d19f3cf 263 if (menuItem <= 9 && menuItem > 0)
samdanbury 6:37b6d0d56190 264 printMenu(--menuItem);
samdanbury 6:37b6d0d56190 265 }
samdanbury 6:37b6d0d56190 266 else if (Right)
samdanbury 6:37b6d0d56190 267 joystickPos = "RIGHT";
samdanbury 6:37b6d0d56190 268 else
samdanbury 6:37b6d0d56190 269 joystickPos = "CENTRE";
samdanbury 6:37b6d0d56190 270 }
samdanbury 6:37b6d0d56190 271
jsutton 13:85801e3b83d3 272 void menu_loop(void const *args)
jsutton 13:85801e3b83d3 273 {
jsutton 14:1f961d19f3cf 274 int count = 0;
icraggs 16:2420bfbf5f1c 275 while(true)
icraggs 16:2420bfbf5f1c 276 {
jsutton 13:85801e3b83d3 277 setMenu();
icraggs 16:2420bfbf5f1c 278 if (++count % 10 == 0)
jsutton 14:1f961d19f3cf 279 printMenu(menuItem);
jsutton 14:1f961d19f3cf 280 Thread::wait(100);
jsutton 13:85801e3b83d3 281 }
jsutton 13:85801e3b83d3 282 }
jsutton 13:85801e3b83d3 283
samdanbury 6:37b6d0d56190 284
samdanbury 6:37b6d0d56190 285 /**
samdanbury 6:37b6d0d56190 286 * Display a message on the LCD screen prefixed with IBM IoT Cloud
samdanbury 6:37b6d0d56190 287 */
samdanbury 6:37b6d0d56190 288 void displayMessage(char* message)
samdanbury 6:37b6d0d56190 289 {
samdanbury 6:37b6d0d56190 290 lcd.cls();
samdanbury 6:37b6d0d56190 291 lcd.locate(0,0);
samdanbury 6:37b6d0d56190 292 lcd.printf("IBM IoT Cloud");
samdanbury 6:37b6d0d56190 293 lcd.locate(0,16);
samdanbury 6:37b6d0d56190 294 lcd.printf(message);
samdanbury 6:37b6d0d56190 295 }
samdanbury 6:37b6d0d56190 296
samdanbury 6:37b6d0d56190 297
samdanbury 6:37b6d0d56190 298 int connect(MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTEthernet* ipstack)
samdanbury 6:37b6d0d56190 299 {
samdanbury 6:37b6d0d56190 300 const char* iot_ibm = ".messaging.internetofthings.ibmcloud.com";
samdanbury 6:37b6d0d56190 301
samdanbury 6:37b6d0d56190 302 char hostname[strlen(org) + strlen(iot_ibm) + 1];
samdanbury 6:37b6d0d56190 303 sprintf(hostname, "%s%s", org, iot_ibm);
jsutton 13:85801e3b83d3 304 EthernetInterface& eth = ipstack->getEth();
jsutton 13:85801e3b83d3 305 ip_addr = eth.getIPAddress();
jsutton 13:85801e3b83d3 306 gateway_addr = eth.getGateway();
jsutton 14:1f961d19f3cf 307
jsutton 14:1f961d19f3cf 308 // Construct clientId - d:org:type:id
jsutton 14:1f961d19f3cf 309 char clientId[strlen(org) + strlen(type) + strlen(id) + 5];
jsutton 14:1f961d19f3cf 310 sprintf(clientId, "d:%s:%s:%s", org, type, id);
jsutton 14:1f961d19f3cf 311
icraggs 16:2420bfbf5f1c 312 // Network debug statements
jsutton 14:1f961d19f3cf 313 LOG("=====================================\n");
jsutton 14:1f961d19f3cf 314 LOG("Connecting Ethernet.\n");
jsutton 14:1f961d19f3cf 315 LOG("IP ADDRESS: %s\n", eth.getIPAddress());
jsutton 14:1f961d19f3cf 316 LOG("MAC ADDRESS: %s\n", eth.getMACAddress());
jsutton 14:1f961d19f3cf 317 LOG("Gateway: %s\n", eth.getGateway());
jsutton 14:1f961d19f3cf 318 LOG("Network Mask: %s\n", eth.getNetworkMask());
jsutton 14:1f961d19f3cf 319 LOG("Server Hostname: %s\n", hostname);
jsutton 14:1f961d19f3cf 320 LOG("Client ID: %s\n", clientId);
jsutton 14:1f961d19f3cf 321 LOG("=====================================\n");
jsutton 14:1f961d19f3cf 322
jsutton 14:1f961d19f3cf 323 netConnecting = true;
jsutton 14:1f961d19f3cf 324 int rc = ipstack->connect(hostname, IBM_IOT_PORT, connectTimeout);
icraggs 16:2420bfbf5f1c 325 if (rc != 0)
icraggs 16:2420bfbf5f1c 326 {
icraggs 18:94da9de96d54 327 WARN("IP Stack connect returned: %d\n", rc);
samdanbury 6:37b6d0d56190 328 return rc;
jsutton 13:85801e3b83d3 329 }
jsutton 13:85801e3b83d3 330 netConnected = true;
jsutton 14:1f961d19f3cf 331 netConnecting = false;
jsutton 14:1f961d19f3cf 332
samdanbury 6:37b6d0d56190 333 // MQTT Connect
jsutton 14:1f961d19f3cf 334 mqttConnecting = true;
samdanbury 6:37b6d0d56190 335 MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
samdanbury 6:37b6d0d56190 336 data.MQTTVersion = 3;
samdanbury 6:37b6d0d56190 337 data.clientID.cstring = clientId;
samdanbury 6:37b6d0d56190 338
samdanbury 6:37b6d0d56190 339 if (!quickstartMode)
samdanbury 6:37b6d0d56190 340 {
samdanbury 6:37b6d0d56190 341 data.username.cstring = "use-token-auth";
samdanbury 6:37b6d0d56190 342 data.password.cstring = auth_token;
samdanbury 6:37b6d0d56190 343 }
samdanbury 6:37b6d0d56190 344
icraggs 8:80d49dd91542 345 if ((rc = client->connect(data)) == 0)
samdanbury 6:37b6d0d56190 346 {
samdanbury 6:37b6d0d56190 347 connected = true;
samdanbury 6:37b6d0d56190 348 green();
samdanbury 6:37b6d0d56190 349 displayMessage("Connected");
jsutton 13:85801e3b83d3 350 wait(1);
samdanbury 6:37b6d0d56190 351 displayMessage("Scroll with joystick");
samdanbury 6:37b6d0d56190 352 }
icraggs 16:2420bfbf5f1c 353 else
icraggs 16:2420bfbf5f1c 354 WARN("MQTT connect returned %d\n", rc);
icraggs 16:2420bfbf5f1c 355 if (rc >= 0)
icraggs 16:2420bfbf5f1c 356 connack_rc = rc;
jsutton 14:1f961d19f3cf 357 mqttConnecting = false;
samdanbury 6:37b6d0d56190 358 return rc;
samdanbury 6:37b6d0d56190 359 }
samdanbury 6:37b6d0d56190 360
samdanbury 6:37b6d0d56190 361
samdanbury 6:37b6d0d56190 362 int getConnTimeout(int attemptNumber)
samdanbury 6:37b6d0d56190 363 { // First 10 attempts try within 3 seconds, next 10 attempts retry after every 1 minute
samdanbury 6:37b6d0d56190 364 // after 20 attempts, retry every 10 minutes
samdanbury 6:37b6d0d56190 365 return (attemptNumber < 10) ? 3 : (attemptNumber < 20) ? 60 : 600;
samdanbury 6:37b6d0d56190 366 }
samdanbury 6:37b6d0d56190 367
samdanbury 6:37b6d0d56190 368
samdanbury 6:37b6d0d56190 369 void attemptConnect(MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTEthernet* ipstack)
samdanbury 6:37b6d0d56190 370 {
samdanbury 6:37b6d0d56190 371 connected = false;
icraggs 16:2420bfbf5f1c 372
icraggs 8:80d49dd91542 373 // make sure a cable is connected before starting to connect
icraggs 16:2420bfbf5f1c 374 while (!linkStatus())
icraggs 16:2420bfbf5f1c 375 {
icraggs 8:80d49dd91542 376 wait(1.0f);
icraggs 8:80d49dd91542 377 WARN("Ethernet link not present. Check cable connection\n");
icraggs 8:80d49dd91542 378 }
samdanbury 6:37b6d0d56190 379
icraggs 16:2420bfbf5f1c 380 while (connect(client, ipstack) != MQTT_CONNECTION_ACCEPTED)
samdanbury 6:37b6d0d56190 381 {
icraggs 16:2420bfbf5f1c 382 if (connack_rc == MQTT_NOT_AUTHORIZED || connack_rc == MQTT_BAD_USERNAME_OR_PASSWORD)
icraggs 16:2420bfbf5f1c 383 return; // don't reattempt to connect if credentials are wrong
icraggs 16:2420bfbf5f1c 384
samdanbury 6:37b6d0d56190 385 Thread red_thread(flashing_red);
chris 12:8b480eb8a496 386
samdanbury 6:37b6d0d56190 387 int timeout = getConnTimeout(++retryAttempt);
samdanbury 6:37b6d0d56190 388 WARN("Retry attempt number %d waiting %d\n", retryAttempt, timeout);
icraggs 8:80d49dd91542 389
icraggs 8:80d49dd91542 390 // if ipstack and client were on the heap we could deconstruct and goto a label where they are constructed
icraggs 8:80d49dd91542 391 // or maybe just add the proper members to do this disconnect and call attemptConnect(...)
icraggs 8:80d49dd91542 392
icraggs 8:80d49dd91542 393 // this works - reset the system when the retry count gets to a threshold
icraggs 8:80d49dd91542 394 if (retryAttempt == 5)
icraggs 8:80d49dd91542 395 NVIC_SystemReset();
icraggs 8:80d49dd91542 396 else
icraggs 8:80d49dd91542 397 wait(timeout);
samdanbury 6:37b6d0d56190 398 }
samdanbury 6:37b6d0d56190 399 }
samdanbury 6:37b6d0d56190 400
samdanbury 6:37b6d0d56190 401
samdanbury 6:37b6d0d56190 402 int publish(MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTEthernet* ipstack)
samdanbury 6:37b6d0d56190 403 {
samdanbury 6:37b6d0d56190 404 MQTT::Message message;
samdanbury 6:37b6d0d56190 405 char* pubTopic = "iot-2/evt/status/fmt/json";
samdanbury 6:37b6d0d56190 406
samdanbury 6:37b6d0d56190 407 char buf[250];
samdanbury 6:37b6d0d56190 408 sprintf(buf,
samdanbury 6:37b6d0d56190 409 "{\"d\":{\"myName\":\"IoT mbed\",\"accelX\":%0.4f,\"accelY\":%0.4f,\"accelZ\":%0.4f,\"temp\":%0.4f,\"joystick\":\"%s\",\"potentiometer1\":%0.4f,\"potentiometer2\":%0.4f}}",
samdanbury 6:37b6d0d56190 410 MMA.x(), MMA.y(), MMA.z(), sensor.temp(), joystickPos, ain1.read(), ain2.read());
samdanbury 6:37b6d0d56190 411 message.qos = MQTT::QOS0;
samdanbury 6:37b6d0d56190 412 message.retained = false;
samdanbury 6:37b6d0d56190 413 message.dup = false;
samdanbury 6:37b6d0d56190 414 message.payload = (void*)buf;
samdanbury 6:37b6d0d56190 415 message.payloadlen = strlen(buf);
samdanbury 6:37b6d0d56190 416
samdanbury 6:37b6d0d56190 417 LOG("Publishing %s\n", buf);
icraggs 8:80d49dd91542 418 return client->publish(pubTopic, message);
samdanbury 6:37b6d0d56190 419 }
samdanbury 6:37b6d0d56190 420
samdanbury 6:37b6d0d56190 421
samdanbury 6:37b6d0d56190 422 char* getMac(EthernetInterface& eth, char* buf, int buflen) // Obtain MAC address
samdanbury 6:37b6d0d56190 423 {
samdanbury 6:37b6d0d56190 424 strncpy(buf, eth.getMACAddress(), buflen);
samdanbury 6:37b6d0d56190 425
samdanbury 6:37b6d0d56190 426 char* pos; // Remove colons from mac address
samdanbury 6:37b6d0d56190 427 while ((pos = strchr(buf, ':')) != NULL)
samdanbury 6:37b6d0d56190 428 memmove(pos, pos + 1, strlen(pos) + 1);
samdanbury 6:37b6d0d56190 429 return buf;
samdanbury 6:37b6d0d56190 430 }
chris 12:8b480eb8a496 431
samdanbury 6:37b6d0d56190 432
samdanbury 6:37b6d0d56190 433 void messageArrived(MQTT::MessageData& md)
samdanbury 6:37b6d0d56190 434 {
samdanbury 6:37b6d0d56190 435 MQTT::Message &message = md.message;
samdanbury 6:37b6d0d56190 436 char topic[md.topicName.lenstring.len + 1];
samdanbury 6:37b6d0d56190 437
samdanbury 6:37b6d0d56190 438 sprintf(topic, "%.*s", md.topicName.lenstring.len, md.topicName.lenstring.data);
samdanbury 6:37b6d0d56190 439
samdanbury 6:37b6d0d56190 440 LOG("Message arrived on topic %s: %.*s\n", topic, message.payloadlen, message.payload);
samdanbury 6:37b6d0d56190 441
samdanbury 6:37b6d0d56190 442 // Command topic: iot-2/cmd/blink/fmt/json - cmd is the string between cmd/ and /fmt/
samdanbury 6:37b6d0d56190 443 char* start = strstr(topic, "/cmd/") + 5;
samdanbury 6:37b6d0d56190 444 int len = strstr(topic, "/fmt/") - start;
samdanbury 6:37b6d0d56190 445
samdanbury 6:37b6d0d56190 446 if (memcmp(start, "blink", len) == 0)
samdanbury 6:37b6d0d56190 447 {
samdanbury 6:37b6d0d56190 448 char payload[message.payloadlen + 1];
samdanbury 6:37b6d0d56190 449 sprintf(payload, "%.*s", message.payloadlen, (char*)message.payload);
samdanbury 6:37b6d0d56190 450
samdanbury 6:37b6d0d56190 451 char* pos = strchr(payload, '}');
samdanbury 6:37b6d0d56190 452 if (pos != NULL)
samdanbury 6:37b6d0d56190 453 {
samdanbury 6:37b6d0d56190 454 *pos = '\0';
samdanbury 6:37b6d0d56190 455 if ((pos = strchr(payload, ':')) != NULL)
samdanbury 6:37b6d0d56190 456 {
samdanbury 6:37b6d0d56190 457 int blink_rate = atoi(pos + 1);
samdanbury 6:37b6d0d56190 458 blink_interval = (blink_rate <= 0) ? 0 : (blink_rate > 50 ? 1 : 50/blink_rate);
samdanbury 6:37b6d0d56190 459 }
samdanbury 6:37b6d0d56190 460 }
samdanbury 6:37b6d0d56190 461 }
samdanbury 6:37b6d0d56190 462 else
samdanbury 6:37b6d0d56190 463 WARN("Unsupported command: %.*s\n", len, start);
samdanbury 6:37b6d0d56190 464 }
samdanbury 6:37b6d0d56190 465
samdanbury 6:37b6d0d56190 466
samdanbury 6:37b6d0d56190 467 int main()
samdanbury 6:37b6d0d56190 468 {
icraggs 8:80d49dd91542 469 quickstartMode = (strcmp(org, "quickstart") == 0);
icraggs 8:80d49dd91542 470
samdanbury 6:37b6d0d56190 471 lcd.set_font((unsigned char*) Arial12x12); // Set a nice font for the LCD screen
samdanbury 6:37b6d0d56190 472
samdanbury 6:37b6d0d56190 473 led2 = LED2_OFF; // K64F: turn off the main board LED
samdanbury 6:37b6d0d56190 474
samdanbury 6:37b6d0d56190 475 displayMessage("Connecting");
jsutton 13:85801e3b83d3 476 Thread yellow_thread(flashing_yellow);
jsutton 13:85801e3b83d3 477 Thread menu_thread(menu_loop);
jsutton 13:85801e3b83d3 478
jsutton 14:1f961d19f3cf 479 LOG("***** IBM IoT Client Ethernet Example *****\n");
samdanbury 6:37b6d0d56190 480 MQTTEthernet ipstack;
jsutton 14:1f961d19f3cf 481 ethernetInitialising = false;
samdanbury 6:37b6d0d56190 482 MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE> client(ipstack);
icraggs 18:94da9de96d54 483 LOG("Ethernet Initialized\n");
jsutton 13:85801e3b83d3 484
samdanbury 6:37b6d0d56190 485 if (quickstartMode)
icraggs 16:2420bfbf5f1c 486 getMac(ipstack.getEth(), id, sizeof(id));
icraggs 16:2420bfbf5f1c 487
icraggs 16:2420bfbf5f1c 488 attemptConnect(&client, &ipstack);
icraggs 16:2420bfbf5f1c 489
icraggs 16:2420bfbf5f1c 490 if (connack_rc == MQTT_NOT_AUTHORIZED || connack_rc == MQTT_BAD_USERNAME_OR_PASSWORD)
samdanbury 6:37b6d0d56190 491 {
icraggs 16:2420bfbf5f1c 492 red();
icraggs 16:2420bfbf5f1c 493 while (true)
icraggs 16:2420bfbf5f1c 494 wait(1.0); // Permanent failures - don't retry
samdanbury 6:37b6d0d56190 495 }
icraggs 16:2420bfbf5f1c 496
samdanbury 6:37b6d0d56190 497 if (!quickstartMode)
samdanbury 6:37b6d0d56190 498 {
samdanbury 6:37b6d0d56190 499 int rc = 0;
samdanbury 6:37b6d0d56190 500 if ((rc = client.subscribe("iot-2/cmd/+/fmt/json", MQTT::QOS1, messageArrived)) != 0)
samdanbury 6:37b6d0d56190 501 WARN("rc from MQTT subscribe is %d\n", rc);
samdanbury 6:37b6d0d56190 502 }
samdanbury 6:37b6d0d56190 503
samdanbury 6:37b6d0d56190 504 blink_interval = 0;
samdanbury 6:37b6d0d56190 505 int count = 0;
samdanbury 6:37b6d0d56190 506 while (true)
samdanbury 6:37b6d0d56190 507 {
samdanbury 6:37b6d0d56190 508 if (++count == 100)
samdanbury 6:37b6d0d56190 509 { // Publish a message every second
samdanbury 6:37b6d0d56190 510 if (publish(&client, &ipstack) != 0)
samdanbury 6:37b6d0d56190 511 attemptConnect(&client, &ipstack); // if we have lost the connection
samdanbury 6:37b6d0d56190 512 count = 0;
samdanbury 6:37b6d0d56190 513 }
samdanbury 6:37b6d0d56190 514
samdanbury 6:37b6d0d56190 515 if (blink_interval == 0)
samdanbury 6:37b6d0d56190 516 led2 = LED2_OFF;
samdanbury 6:37b6d0d56190 517 else if (count % blink_interval == 0)
samdanbury 6:37b6d0d56190 518 led2 = !led2;
samdanbury 6:37b6d0d56190 519 client.yield(10); // allow the MQTT client to receive messages
samdanbury 6:37b6d0d56190 520 }
samdanbury 6:37b6d0d56190 521 }