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@4:77fd4b6ceecb, 2014-07-22 (annotated)

Committer:
samdanbury
Date:
Tue Jul 22 09:19:54 2014 +0000
Revision:
4:77fd4b6ceecb
Parent:
3:69ef39823eef
Child:
5:11fd21af0c0f
Fixed issue with RGB LEDs not working correctly for FRDM-K64F

Who changed what in which revision?

UserRevisionLine numberNew contents of line
samdanbury 0:cae064bcbe5e 1 /*******************************************************************************
samdanbury 0:cae064bcbe5e 2 * Copyright (c) 2014 IBM Corporation and other Contributors.
samdanbury 0:cae064bcbe5e 3 *
samdanbury 0:cae064bcbe5e 4 * All rights reserved. This program and the accompanying materials
samdanbury 0:cae064bcbe5e 5 * are made available under the terms of the Eclipse Public License v1.0
samdanbury 0:cae064bcbe5e 6 * which accompanies this distribution, and is available at
samdanbury 0:cae064bcbe5e 7 * http://www.eclipse.org/legal/epl-v10.html
samdanbury 0:cae064bcbe5e 8 *
samdanbury 0:cae064bcbe5e 9 * Contributors: Sam Danbury
samdanbury 0:cae064bcbe5e 10 * IBM - Initial Contribution
samdanbury 0:cae064bcbe5e 11 *******************************************************************************/
samdanbury 0:cae064bcbe5e 12
samdanbury 0:cae064bcbe5e 13 #include "stdio.h"
samdanbury 0:cae064bcbe5e 14 #include "mbed.h"
samdanbury 0:cae064bcbe5e 15 #include "rtos.h"
samdanbury 0:cae064bcbe5e 16 #include "C12832.h"
samdanbury 0:cae064bcbe5e 17 #include "LM75B.h"
samdanbury 0:cae064bcbe5e 18 #include "MMA7660.h"
samdanbury 2:d8fddda78c38 19 #include "EthernetInterface.h"
samdanbury 2:d8fddda78c38 20 #include "MQTTSocket.h"
samdanbury 0:cae064bcbe5e 21 #include "MQTTClient.h"
samdanbury 0:cae064bcbe5e 22 #include "ConfigFile.h"
samdanbury 1:1f187285667c 23 #include "Arial12x12.h"
samdanbury 0:cae064bcbe5e 24
samdanbury 0:cae064bcbe5e 25 #include <string>
samdanbury 0:cae064bcbe5e 26 #include <sstream>
samdanbury 0:cae064bcbe5e 27 #include <algorithm>
samdanbury 0:cae064bcbe5e 28
samdanbury 0:cae064bcbe5e 29 using namespace std;
samdanbury 0:cae064bcbe5e 30
samdanbury 0:cae064bcbe5e 31 #ifdef TARGET_LPC1768
samdanbury 0:cae064bcbe5e 32
samdanbury 0:cae064bcbe5e 33 #warning "Compiling for mbed LPC1768"
samdanbury 0:cae064bcbe5e 34
samdanbury 0:cae064bcbe5e 35 LocalFileSystem local("local");
samdanbury 0:cae064bcbe5e 36 C12832 lcd(p5, p7, p6, p8, p11);
samdanbury 0:cae064bcbe5e 37 DigitalOut led2(LED2);
samdanbury 1:1f187285667c 38 PwmOut r (p23);
samdanbury 1:1f187285667c 39 PwmOut g (p24);
samdanbury 1:1f187285667c 40 PwmOut b (p25);
samdanbury 0:cae064bcbe5e 41 MMA7660 MMA(p28, p27);
samdanbury 0:cae064bcbe5e 42 LM75B sensor(p28, p27);
samdanbury 0:cae064bcbe5e 43 DigitalIn Down(p12);
samdanbury 0:cae064bcbe5e 44 DigitalIn Left(p13);
samdanbury 0:cae064bcbe5e 45 DigitalIn Click(p14);
samdanbury 0:cae064bcbe5e 46 DigitalIn Up(p15);
samdanbury 0:cae064bcbe5e 47 DigitalIn Right(p16);
samdanbury 0:cae064bcbe5e 48 AnalogIn ain1(p19);
samdanbury 0:cae064bcbe5e 49 AnalogIn ain2(p20);
samdanbury 0:cae064bcbe5e 50
samdanbury 0:cae064bcbe5e 51 #elif TARGET_K64F
samdanbury 0:cae064bcbe5e 52
samdanbury 0:cae064bcbe5e 53 #warning "Compiling for mbed K64F"
samdanbury 0:cae064bcbe5e 54
samdanbury 0:cae064bcbe5e 55 //#define ORGANISATION "<org>";
samdanbury 0:cae064bcbe5e 56 //#define TYPE "<type>";
samdanbury 0:cae064bcbe5e 57 //#define ID "<id>";
samdanbury 0:cae064bcbe5e 58 //#define AUTHMETHOD "<auth-method>";
samdanbury 0:cae064bcbe5e 59 //#define AUTHTOKEN "<auth-token>";
samdanbury 0:cae064bcbe5e 60
samdanbury 0:cae064bcbe5e 61 C12832 lcd(D11, D13, D12, D7, D10);
samdanbury 4:77fd4b6ceecb 62 BusOut r (D5);
samdanbury 4:77fd4b6ceecb 63 BusOut g (D9);
samdanbury 4:77fd4b6ceecb 64 BusOut led2 (LED_BLUE);
samdanbury 0:cae064bcbe5e 65 MMA7660 MMA(PTE25, PTE24);
samdanbury 0:cae064bcbe5e 66 LM75B sensor(PTE25, PTE24);
samdanbury 0:cae064bcbe5e 67 DigitalIn Up(A2);
samdanbury 0:cae064bcbe5e 68 DigitalIn Down(A3);
samdanbury 0:cae064bcbe5e 69 DigitalIn Right(A4);
samdanbury 0:cae064bcbe5e 70 DigitalIn Left(A5);
samdanbury 0:cae064bcbe5e 71 DigitalIn Click(D4);
samdanbury 0:cae064bcbe5e 72 AnalogIn ain1(A0);
samdanbury 0:cae064bcbe5e 73 AnalogIn ain2(A1);
samdanbury 0:cae064bcbe5e 74
samdanbury 0:cae064bcbe5e 75 #else
samdanbury 0:cae064bcbe5e 76
samdanbury 0:cae064bcbe5e 77 LocalFileSystem local("local");
samdanbury 0:cae064bcbe5e 78 C12832 lcd(D11, D13, D12, D7, D10);
samdanbury 0:cae064bcbe5e 79 DigitalOut led1(LED1);
samdanbury 0:cae064bcbe5e 80 DigitalOut led2(LED2);
samdanbury 0:cae064bcbe5e 81 DigitalOut led3(LED3);
samdanbury 0:cae064bcbe5e 82 MMA7660 MMA(D14, D15);
samdanbury 0:cae064bcbe5e 83 LM75B sensor(D14,D15);
samdanbury 0:cae064bcbe5e 84 DigitalIn Up(A2);
samdanbury 0:cae064bcbe5e 85 DigitalIn Down(A3);
samdanbury 0:cae064bcbe5e 86 DigitalIn Left(A4);
samdanbury 0:cae064bcbe5e 87 DigitalIn Right(A5);
samdanbury 0:cae064bcbe5e 88 DigitalIn Click(D4);
samdanbury 0:cae064bcbe5e 89 AnalogIn ain1 (A0);
samdanbury 0:cae064bcbe5e 90 AnalogIn ain2 (A1);
samdanbury 0:cae064bcbe5e 91
samdanbury 0:cae064bcbe5e 92 #endif
samdanbury 0:cae064bcbe5e 93
samdanbury 0:cae064bcbe5e 94 //Joystick
samdanbury 0:cae064bcbe5e 95 string joystickPos;
samdanbury 0:cae064bcbe5e 96 void joystickThread(void const *args);
samdanbury 0:cae064bcbe5e 97
samdanbury 0:cae064bcbe5e 98 //Commands
samdanbury 0:cae064bcbe5e 99 enum command {
samdanbury 0:cae064bcbe5e 100 blink
samdanbury 0:cae064bcbe5e 101 };
samdanbury 0:cae064bcbe5e 102 command getCommand (std::string const& command);
samdanbury 0:cae064bcbe5e 103 void messageArrived(MQTT::MessageData& md);
samdanbury 1:1f187285667c 104
samdanbury 1:1f187285667c 105 //MQTT
samdanbury 1:1f187285667c 106 void connect();
samdanbury 1:1f187285667c 107 void attemptConnect();
samdanbury 1:1f187285667c 108 int getConnTimeout(int attemptNumber);
samdanbury 1:1f187285667c 109 void subscribe();
samdanbury 0:cae064bcbe5e 110
samdanbury 0:cae064bcbe5e 111 //Config
samdanbury 0:cae064bcbe5e 112 void parseConfig();
samdanbury 0:cae064bcbe5e 113 bool quickstartMode = true;
samdanbury 0:cae064bcbe5e 114 string org = "";
samdanbury 0:cae064bcbe5e 115 string type = "";
samdanbury 0:cae064bcbe5e 116 string id = "";
samdanbury 0:cae064bcbe5e 117 string auth_method = "";
samdanbury 0:cae064bcbe5e 118 string auth_token = "";
samdanbury 0:cae064bcbe5e 119 string mac = "";
samdanbury 0:cae064bcbe5e 120
samdanbury 1:1f187285667c 121 //LCD menu
samdanbury 1:1f187285667c 122 bool connected = false;
samdanbury 1:1f187285667c 123 bool menuActivated = false;
samdanbury 1:1f187285667c 124 int menu = 0;
samdanbury 1:1f187285667c 125 void printMenu();
samdanbury 1:1f187285667c 126
samdanbury 1:1f187285667c 127 int interval;
samdanbury 1:1f187285667c 128 string getUUID48();
samdanbury 1:1f187285667c 129
samdanbury 1:1f187285667c 130 MQTTSocket ipstack;
samdanbury 1:1f187285667c 131 MQTT::Client<MQTTSocket, Countdown, 250>* client;
samdanbury 0:cae064bcbe5e 132
samdanbury 0:cae064bcbe5e 133 void parseConfig() {
samdanbury 0:cae064bcbe5e 134
samdanbury 0:cae064bcbe5e 135 ConfigFile cfg;
samdanbury 0:cae064bcbe5e 136
samdanbury 0:cae064bcbe5e 137 char value[30];
samdanbury 0:cae064bcbe5e 138 char value1[30];
samdanbury 0:cae064bcbe5e 139 char value2[30];
samdanbury 0:cae064bcbe5e 140 char value3[30];
samdanbury 0:cae064bcbe5e 141
samdanbury 0:cae064bcbe5e 142 if (cfg.read("/local/device.cfg")) {
samdanbury 0:cae064bcbe5e 143 quickstartMode = false;
samdanbury 0:cae064bcbe5e 144
samdanbury 0:cae064bcbe5e 145 if (cfg.getValue("org", value, sizeof(value))) {
samdanbury 0:cae064bcbe5e 146 stringstream ss(value);
samdanbury 0:cae064bcbe5e 147 ss >> org;
samdanbury 0:cae064bcbe5e 148 }
samdanbury 0:cae064bcbe5e 149 if (cfg.getValue("type", value1, sizeof(value1))) {
samdanbury 0:cae064bcbe5e 150 stringstream ss(value1);
samdanbury 0:cae064bcbe5e 151 ss >> type;
samdanbury 1:1f187285667c 152 }
samdanbury 0:cae064bcbe5e 153 if (cfg.getValue("id", value2, sizeof(value2))) {
samdanbury 0:cae064bcbe5e 154 stringstream ss(value2);
samdanbury 0:cae064bcbe5e 155 ss >> id;
samdanbury 0:cae064bcbe5e 156 }
samdanbury 0:cae064bcbe5e 157 if (cfg.getValue("auth-token", value3, sizeof(value3))) {
samdanbury 0:cae064bcbe5e 158 stringstream ss(value3);
samdanbury 0:cae064bcbe5e 159 ss >> auth_token;
samdanbury 0:cae064bcbe5e 160 }
samdanbury 0:cae064bcbe5e 161
samdanbury 0:cae064bcbe5e 162 } else {
samdanbury 0:cae064bcbe5e 163 quickstartMode = true;
samdanbury 0:cae064bcbe5e 164 org = "quickstart";
samdanbury 2:d8fddda78c38 165 #ifdef TARGET_K64F
samdanbury 2:d8fddda78c38 166 type = "iotsample-mbed-k64f";
samdanbury 2:d8fddda78c38 167 #else
samdanbury 2:d8fddda78c38 168 type = "iotsample-mbed-lpc1768";
samdanbury 2:d8fddda78c38 169 #endif
samdanbury 0:cae064bcbe5e 170 id = mac;
samdanbury 0:cae064bcbe5e 171 }
samdanbury 0:cae064bcbe5e 172
samdanbury 0:cae064bcbe5e 173 #ifdef TARGET_K64F
samdanbury 0:cae064bcbe5e 174 #ifdef ORGANISATION
samdanbury 0:cae064bcbe5e 175 quickstartMode = false;
samdanbury 0:cae064bcbe5e 176 org = ORGANISATION;
samdanbury 0:cae064bcbe5e 177
samdanbury 0:cae064bcbe5e 178 #ifdef TYPE
samdanbury 0:cae064bcbe5e 179 type = TYPE;
samdanbury 0:cae064bcbe5e 180 #else
samdanbury 0:cae064bcbe5e 181 lcd.printf("Type is not defined");
samdanbury 0:cae064bcbe5e 182 #endif
samdanbury 0:cae064bcbe5e 183
samdanbury 0:cae064bcbe5e 184 #ifdef ID
samdanbury 0:cae064bcbe5e 185 id = ID;
samdanbury 0:cae064bcbe5e 186 #else
samdanbury 0:cae064bcbe5e 187 lcd.printf("ID is not defined");
samdanbury 0:cae064bcbe5e 188 #endif
samdanbury 0:cae064bcbe5e 189
samdanbury 0:cae064bcbe5e 190 #ifdef AUTHMETHOD
samdanbury 0:cae064bcbe5e 191 auth_method = AUTHMETHOD;
samdanbury 0:cae064bcbe5e 192 #else
samdanbury 0:cae064bcbe5e 193 lcd.printf("Auth method is not defined");
samdanbury 0:cae064bcbe5e 194 #endif
samdanbury 0:cae064bcbe5e 195
samdanbury 0:cae064bcbe5e 196 #ifdef AUTHTOKEN
samdanbury 0:cae064bcbe5e 197 auth_token = AUTHTOKEN;
samdanbury 0:cae064bcbe5e 198 #else
samdanbury 0:cae064bcbe5e 199 lcd.printf("Auth token is not defined");
samdanbury 0:cae064bcbe5e 200 #endif
samdanbury 0:cae064bcbe5e 201 #endif
samdanbury 0:cae064bcbe5e 202 #endif
samdanbury 0:cae064bcbe5e 203 }
samdanbury 0:cae064bcbe5e 204
samdanbury 0:cae064bcbe5e 205 int main()
samdanbury 0:cae064bcbe5e 206 {
samdanbury 1:1f187285667c 207 //RGB: yellow
samdanbury 1:1f187285667c 208 r = 0;
samdanbury 1:1f187285667c 209 g = 0;
samdanbury 4:77fd4b6ceecb 210
samdanbury 4:77fd4b6ceecb 211 #ifdef TARGET_K64F
samdanbury 4:77fd4b6ceecb 212 led2 = 1;
samdanbury 4:77fd4b6ceecb 213 #endif
samdanbury 1:1f187285667c 214
samdanbury 1:1f187285667c 215 lcd.cls();
samdanbury 1:1f187285667c 216 lcd.set_font((unsigned char*) Arial12x12);
samdanbury 1:1f187285667c 217 lcd.locate(0,0);
samdanbury 1:1f187285667c 218 lcd.printf("IBM IoT Cloud");
samdanbury 1:1f187285667c 219 lcd.locate(0,16);
samdanbury 1:1f187285667c 220 lcd.printf("Connecting");
samdanbury 0:cae064bcbe5e 221
samdanbury 0:cae064bcbe5e 222 //Connect to network
samdanbury 1:1f187285667c 223 EthernetInterface eth;
samdanbury 1:1f187285667c 224 eth.init();
samdanbury 1:1f187285667c 225 eth.connect();
samdanbury 0:cae064bcbe5e 226
samdanbury 0:cae064bcbe5e 227 //Obtain mac address of mbed
samdanbury 0:cae064bcbe5e 228 #ifdef TARGET_K64F
samdanbury 0:cae064bcbe5e 229 mac = getUUID48();
samdanbury 0:cae064bcbe5e 230 #else
samdanbury 1:1f187285667c 231 mac = eth.getMACAddress();
samdanbury 0:cae064bcbe5e 232
samdanbury 0:cae064bcbe5e 233 //Remove colons from mac address
samdanbury 0:cae064bcbe5e 234 mac.erase(remove(mac.begin(), mac.end(), ':'), mac.end());
samdanbury 0:cae064bcbe5e 235 #endif
samdanbury 0:cae064bcbe5e 236
samdanbury 0:cae064bcbe5e 237 //Parse config file if present
samdanbury 0:cae064bcbe5e 238 parseConfig();
samdanbury 0:cae064bcbe5e 239
samdanbury 1:1f187285667c 240 attemptConnect();
samdanbury 0:cae064bcbe5e 241
samdanbury 0:cae064bcbe5e 242 if (!quickstartMode) {
samdanbury 1:1f187285667c 243 subscribe();
samdanbury 0:cae064bcbe5e 244 }
samdanbury 0:cae064bcbe5e 245
samdanbury 0:cae064bcbe5e 246 //Start thread to read data from joystick
samdanbury 0:cae064bcbe5e 247 joystickPos = "CENTRE";
samdanbury 0:cae064bcbe5e 248 Thread jThd(joystickThread);
samdanbury 0:cae064bcbe5e 249
samdanbury 0:cae064bcbe5e 250 interval = 0;
samdanbury 0:cae064bcbe5e 251 int i = 0;
samdanbury 0:cae064bcbe5e 252
samdanbury 0:cae064bcbe5e 253 while(1)
samdanbury 0:cae064bcbe5e 254 {
samdanbury 0:cae064bcbe5e 255 //Message published every second
samdanbury 0:cae064bcbe5e 256 if (i == 100) {
samdanbury 0:cae064bcbe5e 257 //MQTT Publish
samdanbury 0:cae064bcbe5e 258 MQTT::Message message;
samdanbury 0:cae064bcbe5e 259 char* pubTopic = "iot-2/evt/status/fmt/json";
samdanbury 0:cae064bcbe5e 260
samdanbury 0:cae064bcbe5e 261 char buf[250];
samdanbury 0:cae064bcbe5e 262 sprintf(buf,
samdanbury 0:cae064bcbe5e 263 "{\"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 0:cae064bcbe5e 264 MMA.x(), MMA.y(), MMA.z(),
samdanbury 0:cae064bcbe5e 265 sensor.temp(),
samdanbury 0:cae064bcbe5e 266 joystickPos,
samdanbury 0:cae064bcbe5e 267 ain1.read(),
samdanbury 0:cae064bcbe5e 268 ain2.read());
samdanbury 0:cae064bcbe5e 269 message.qos = MQTT::QOS0;
samdanbury 0:cae064bcbe5e 270 message.retained = false;
samdanbury 0:cae064bcbe5e 271 message.dup = false;
samdanbury 0:cae064bcbe5e 272 message.payload = (void*)buf;
samdanbury 0:cae064bcbe5e 273 message.payloadlen = strlen(buf);
samdanbury 0:cae064bcbe5e 274
samdanbury 1:1f187285667c 275 int rc = 0;
samdanbury 1:1f187285667c 276 if ((rc = client->publish(pubTopic, &message)) != 0) {
samdanbury 1:1f187285667c 277 connected = false;
samdanbury 1:1f187285667c 278 attemptConnect();
samdanbury 1:1f187285667c 279 }
samdanbury 0:cae064bcbe5e 280
samdanbury 0:cae064bcbe5e 281 i = 0;
samdanbury 0:cae064bcbe5e 282 }
samdanbury 0:cae064bcbe5e 283
samdanbury 0:cae064bcbe5e 284 if (interval == 0) {
samdanbury 4:77fd4b6ceecb 285 #ifdef TARGET_K64F
samdanbury 4:77fd4b6ceecb 286 led2 = 1;
samdanbury 4:77fd4b6ceecb 287 #else
samdanbury 4:77fd4b6ceecb 288 led2 = 0;
samdanbury 4:77fd4b6ceecb 289 #endif
samdanbury 0:cae064bcbe5e 290 } else {
samdanbury 0:cae064bcbe5e 291 if (i%(interval)==0) {
samdanbury 4:77fd4b6ceecb 292 led2 = !led2;
samdanbury 0:cae064bcbe5e 293 }
samdanbury 0:cae064bcbe5e 294 }
samdanbury 0:cae064bcbe5e 295
samdanbury 0:cae064bcbe5e 296 wait(0.01);
samdanbury 0:cae064bcbe5e 297 i++;
samdanbury 1:1f187285667c 298 client->yield(1);
samdanbury 1:1f187285667c 299 }
samdanbury 1:1f187285667c 300 }
samdanbury 1:1f187285667c 301
samdanbury 1:1f187285667c 302 void attemptConnect() {
samdanbury 1:1f187285667c 303 int retryAttempt = 0;
samdanbury 1:1f187285667c 304 menuActivated = false;
samdanbury 1:1f187285667c 305
samdanbury 1:1f187285667c 306 //RGB: yellow
samdanbury 1:1f187285667c 307 r = 0;
samdanbury 1:1f187285667c 308 g = 0;
samdanbury 1:1f187285667c 309
samdanbury 1:1f187285667c 310 lcd.cls();
samdanbury 1:1f187285667c 311 lcd.locate(0,0);
samdanbury 1:1f187285667c 312 lcd.printf("IBM IoT Cloud");
samdanbury 1:1f187285667c 313 lcd.locate(0,16);
samdanbury 1:1f187285667c 314 lcd.printf("Connecting");
samdanbury 1:1f187285667c 315
samdanbury 1:1f187285667c 316 while (!connected) {
samdanbury 1:1f187285667c 317
samdanbury 1:1f187285667c 318 int connTimeout = getConnTimeout(++retryAttempt);
samdanbury 1:1f187285667c 319
samdanbury 1:1f187285667c 320 connect();
samdanbury 1:1f187285667c 321
samdanbury 1:1f187285667c 322 if (!connected) {
samdanbury 1:1f187285667c 323 wait(connTimeout);
samdanbury 1:1f187285667c 324 } else {
samdanbury 1:1f187285667c 325 break;
samdanbury 1:1f187285667c 326 }
samdanbury 1:1f187285667c 327 }
samdanbury 1:1f187285667c 328 }
samdanbury 1:1f187285667c 329
samdanbury 1:1f187285667c 330 int getConnTimeout(int attemptNumber) {
samdanbury 1:1f187285667c 331 if (attemptNumber < 10) {
samdanbury 1:1f187285667c 332 return 3; //First 10 attempts try within 3 seconds
samdanbury 1:1f187285667c 333 } else if (attemptNumber < 20) {
samdanbury 1:1f187285667c 334 return 60; //Next 10 attempts retry after every 1 minute
samdanbury 1:1f187285667c 335 } else {
samdanbury 1:1f187285667c 336 return 600; //After 20 attempts, retry every 10 minutes
samdanbury 0:cae064bcbe5e 337 }
samdanbury 0:cae064bcbe5e 338 }
samdanbury 0:cae064bcbe5e 339
samdanbury 1:1f187285667c 340 void connect() {
samdanbury 1:1f187285667c 341 ipstack = MQTTSocket();
samdanbury 1:1f187285667c 342 client = new MQTT::Client<MQTTSocket, Countdown, 250>(ipstack);
samdanbury 1:1f187285667c 343
samdanbury 1:1f187285667c 344 //TCP Connect
samdanbury 1:1f187285667c 345 string ip = org + ".messaging.internetofthings.ibmcloud.com";
samdanbury 1:1f187285667c 346
samdanbury 1:1f187285667c 347 char* hostname = new char[ip.length() + 1];
samdanbury 1:1f187285667c 348 strcpy(hostname, ip.c_str());
samdanbury 1:1f187285667c 349
samdanbury 1:1f187285667c 350 int port = 1883;
samdanbury 1:1f187285667c 351 int rc = ipstack.connect(hostname, port);
samdanbury 1:1f187285667c 352 if (rc != 0) {
samdanbury 1:1f187285667c 353 lcd.printf("TCP connect failed");
samdanbury 1:1f187285667c 354 }
samdanbury 1:1f187285667c 355
samdanbury 1:1f187285667c 356 //Construct clientId based on config
samdanbury 1:1f187285667c 357 string str = string("d:") + org + ":" + type + ":" + id;
samdanbury 1:1f187285667c 358 char clientId[str.size()];
samdanbury 1:1f187285667c 359 memcpy(clientId, str.c_str(), str.size() + 1);
samdanbury 1:1f187285667c 360
samdanbury 1:1f187285667c 361 //MQTT Connect
samdanbury 1:1f187285667c 362 MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
samdanbury 1:1f187285667c 363 data.MQTTVersion = 3;
samdanbury 1:1f187285667c 364 data.clientID.cstring = clientId;
samdanbury 1:1f187285667c 365
samdanbury 1:1f187285667c 366 if (!quickstartMode) {
samdanbury 1:1f187285667c 367 char* password = new char[auth_token.length() + 1];
samdanbury 1:1f187285667c 368 strcpy(password, auth_token.c_str());
samdanbury 1:1f187285667c 369
samdanbury 1:1f187285667c 370 data.username.cstring = "use-token-auth";
samdanbury 1:1f187285667c 371 data.password.cstring = password;
samdanbury 1:1f187285667c 372 }
samdanbury 1:1f187285667c 373
samdanbury 3:69ef39823eef 374 if ((rc = client->connect(&data)) == 0) {
samdanbury 1:1f187285667c 375 connected = true;
samdanbury 1:1f187285667c 376
samdanbury 1:1f187285667c 377 //RGB: green
samdanbury 1:1f187285667c 378 r = 1;
samdanbury 1:1f187285667c 379 g = 0;
samdanbury 1:1f187285667c 380
samdanbury 1:1f187285667c 381 lcd.locate(0,0);
samdanbury 1:1f187285667c 382 lcd.printf("IBM IoT Cloud");
samdanbury 1:1f187285667c 383 lcd.locate(0,16);
samdanbury 1:1f187285667c 384 lcd.printf("Connected");
samdanbury 1:1f187285667c 385
samdanbury 1:1f187285667c 386 wait(2);
samdanbury 1:1f187285667c 387
samdanbury 1:1f187285667c 388 lcd.locate(0,0);
samdanbury 1:1f187285667c 389 lcd.printf("IBM IoT Cloud");
samdanbury 1:1f187285667c 390 lcd.locate(0,16);
samdanbury 1:1f187285667c 391 lcd.printf("Scroll with joystick");
samdanbury 1:1f187285667c 392
samdanbury 1:1f187285667c 393 menuActivated = true;
samdanbury 1:1f187285667c 394 }
samdanbury 1:1f187285667c 395 }
samdanbury 1:1f187285667c 396
samdanbury 1:1f187285667c 397 void subscribe() {
samdanbury 1:1f187285667c 398 char* subTopic = "iot-2/cmd/+/fmt/json";
samdanbury 1:1f187285667c 399 int rc = 0;
samdanbury 1:1f187285667c 400 if ((rc = client->subscribe(subTopic, MQTT::QOS1, messageArrived)) != 0)
samdanbury 1:1f187285667c 401 lcd.printf("rc from MQTT subscribe is %d\n", rc);
samdanbury 1:1f187285667c 402 }
samdanbury 1:1f187285667c 403
samdanbury 0:cae064bcbe5e 404 void messageArrived(MQTT::MessageData& md) {
samdanbury 0:cae064bcbe5e 405 MQTT::Message &message = md.message;
samdanbury 0:cae064bcbe5e 406
samdanbury 0:cae064bcbe5e 407 char* topic = new char[md.topicName.lenstring.len + 1];
samdanbury 0:cae064bcbe5e 408 sprintf(topic, "%.*s", md.topicName.lenstring.len, md.topicName.lenstring.data);
samdanbury 0:cae064bcbe5e 409
samdanbury 0:cae064bcbe5e 410 char* payload = new char[message.payloadlen + 1];
samdanbury 0:cae064bcbe5e 411 sprintf(payload, "%.*s", message.payloadlen, (char*)message.payload);
samdanbury 0:cae064bcbe5e 412
samdanbury 0:cae064bcbe5e 413 string topicStr = topic;
samdanbury 0:cae064bcbe5e 414 string payloadStr = payload;
samdanbury 0:cae064bcbe5e 415
samdanbury 0:cae064bcbe5e 416 //Command topic: iot-2/cmd/blink/fmt/json
samdanbury 0:cae064bcbe5e 417 string cmd = topicStr.substr(10, topicStr.find("/fmt/") - 10);
samdanbury 0:cae064bcbe5e 418
samdanbury 0:cae064bcbe5e 419 switch(getCommand(cmd)) {
samdanbury 0:cae064bcbe5e 420 case blink: {
samdanbury 0:cae064bcbe5e 421 string str = payloadStr.substr(8, payloadStr.find("}") - 8);
samdanbury 0:cae064bcbe5e 422 int rate = atoi(str.c_str());
samdanbury 0:cae064bcbe5e 423
samdanbury 0:cae064bcbe5e 424 if (rate == 0) {
samdanbury 0:cae064bcbe5e 425 interval = 0;
samdanbury 0:cae064bcbe5e 426 } else if (rate > 50) {
samdanbury 0:cae064bcbe5e 427 interval = 1;
samdanbury 0:cae064bcbe5e 428 } else if (rate > 0) {
samdanbury 0:cae064bcbe5e 429 interval = 50/rate;
samdanbury 0:cae064bcbe5e 430 }
samdanbury 0:cae064bcbe5e 431
samdanbury 0:cae064bcbe5e 432 break;
samdanbury 0:cae064bcbe5e 433 }
samdanbury 0:cae064bcbe5e 434 default:
samdanbury 0:cae064bcbe5e 435 lcd.printf("Unsupported command: %s\n", cmd);
samdanbury 0:cae064bcbe5e 436 }
samdanbury 0:cae064bcbe5e 437
samdanbury 0:cae064bcbe5e 438 if (topic) {
samdanbury 0:cae064bcbe5e 439 delete[] topic;
samdanbury 0:cae064bcbe5e 440 }
samdanbury 0:cae064bcbe5e 441 if (payload) {
samdanbury 0:cae064bcbe5e 442 delete[] payload;
samdanbury 0:cae064bcbe5e 443 }
samdanbury 0:cae064bcbe5e 444
samdanbury 0:cae064bcbe5e 445 }
samdanbury 0:cae064bcbe5e 446
samdanbury 0:cae064bcbe5e 447 command getCommand (string const& command) {
samdanbury 0:cae064bcbe5e 448 if (command == "blink")
samdanbury 0:cae064bcbe5e 449 return blink;
samdanbury 0:cae064bcbe5e 450 }
samdanbury 0:cae064bcbe5e 451
samdanbury 0:cae064bcbe5e 452 void joystickThread(void const *args) {
samdanbury 0:cae064bcbe5e 453 while (true) {
samdanbury 1:1f187285667c 454
samdanbury 1:1f187285667c 455 if (!menuActivated) {
samdanbury 1:1f187285667c 456 menu = 0;
samdanbury 1:1f187285667c 457 }
samdanbury 1:1f187285667c 458
samdanbury 1:1f187285667c 459 if (Down) {
samdanbury 0:cae064bcbe5e 460 joystickPos = "DOWN";
samdanbury 1:1f187285667c 461 if (menu >= 0 && menu < 3) {
samdanbury 1:1f187285667c 462 menu++;
samdanbury 1:1f187285667c 463 printMenu();
samdanbury 1:1f187285667c 464 }
samdanbury 1:1f187285667c 465 } else if (Left) {
samdanbury 0:cae064bcbe5e 466 joystickPos = "LEFT";
samdanbury 1:1f187285667c 467 } else if (Click) {
samdanbury 0:cae064bcbe5e 468 joystickPos = "CLICK";
samdanbury 1:1f187285667c 469 } else if (Up) {
samdanbury 0:cae064bcbe5e 470 joystickPos = "UP";
samdanbury 1:1f187285667c 471 if (menu <= 3 && menu > 0) {
samdanbury 1:1f187285667c 472 menu--;
samdanbury 1:1f187285667c 473 printMenu();
samdanbury 1:1f187285667c 474 }
samdanbury 1:1f187285667c 475 } else if (Right) {
samdanbury 0:cae064bcbe5e 476 joystickPos = "RIGHT";
samdanbury 1:1f187285667c 477 } else {
samdanbury 0:cae064bcbe5e 478 joystickPos = "CENTRE";
samdanbury 1:1f187285667c 479 }
samdanbury 1:1f187285667c 480 wait(0.2);
samdanbury 1:1f187285667c 481 }
samdanbury 1:1f187285667c 482 }
samdanbury 1:1f187285667c 483
samdanbury 1:1f187285667c 484 void printMenu() {
samdanbury 1:1f187285667c 485 if (menuActivated) {
samdanbury 1:1f187285667c 486 lcd.cls();
samdanbury 1:1f187285667c 487 lcd.locate(0,0);
samdanbury 1:1f187285667c 488
samdanbury 1:1f187285667c 489 switch(menu) {
samdanbury 1:1f187285667c 490 case 0:
samdanbury 1:1f187285667c 491 lcd.printf("IBM IoT Cloud");
samdanbury 1:1f187285667c 492 lcd.locate(0,16);
samdanbury 1:1f187285667c 493 lcd.printf("Scroll with joystick");
samdanbury 1:1f187285667c 494 break;
samdanbury 1:1f187285667c 495 case 1:
samdanbury 1:1f187285667c 496 lcd.printf("Go to:");
samdanbury 1:1f187285667c 497 lcd.locate(0,16);
samdanbury 1:1f187285667c 498 lcd.printf("http://ibm.biz/iotqstart");
samdanbury 1:1f187285667c 499 break;
samdanbury 1:1f187285667c 500 case 2:
samdanbury 1:1f187285667c 501 lcd.printf("Device Identity:");
samdanbury 1:1f187285667c 502 lcd.locate(0,16);
samdanbury 1:1f187285667c 503 lcd.printf("%s", mac);
samdanbury 1:1f187285667c 504 break;
samdanbury 1:1f187285667c 505 case 3:
samdanbury 1:1f187285667c 506 lcd.printf("Status:");
samdanbury 1:1f187285667c 507 lcd.locate(0,16);
samdanbury 1:1f187285667c 508 lcd.printf("Connected");
samdanbury 1:1f187285667c 509 break;
samdanbury 1:1f187285667c 510 }
samdanbury 1:1f187285667c 511 } else {
samdanbury 1:1f187285667c 512 menu = 0;
samdanbury 0:cae064bcbe5e 513 }
samdanbury 0:cae064bcbe5e 514 }
samdanbury 0:cae064bcbe5e 515
samdanbury 0:cae064bcbe5e 516 string getUUID48 () {
samdanbury 0:cae064bcbe5e 517
samdanbury 0:cae064bcbe5e 518 unsigned int UUID_LOC_WORD0 = 0x40048060;
samdanbury 0:cae064bcbe5e 519 unsigned int UUID_LOC_WORD1 = 0x4004805C;
samdanbury 0:cae064bcbe5e 520
samdanbury 0:cae064bcbe5e 521 // Fetch word 0
samdanbury 0:cae064bcbe5e 522 uint32_t Word0 = *(uint32_t *)UUID_LOC_WORD0;
samdanbury 0:cae064bcbe5e 523
samdanbury 0:cae064bcbe5e 524 // Fetch word 1
samdanbury 0:cae064bcbe5e 525 // we only want bottom 16 bits of word1 (MAC bits 32-47)
samdanbury 0:cae064bcbe5e 526 // and bit 9 forced to 1, bit 8 forced to 0
samdanbury 0:cae064bcbe5e 527 // Locally administered MAC, reduced conflicts
samdanbury 0:cae064bcbe5e 528 // http://en.wikipedia.org/wiki/MAC_address
samdanbury 0:cae064bcbe5e 529 uint32_t Word1 = *(uint32_t *)UUID_LOC_WORD1;
samdanbury 0:cae064bcbe5e 530 Word1 |= 0x00000200;
samdanbury 0:cae064bcbe5e 531 Word1 &= 0x0000FEFF;
samdanbury 0:cae064bcbe5e 532
samdanbury 0:cae064bcbe5e 533 string sd;
samdanbury 0:cae064bcbe5e 534 char stemp[100] = "";
samdanbury 0:cae064bcbe5e 535 snprintf(stemp, 100, "%4X%08X", Word1,Word0); // I use the safer version of sprintf() -- snprintf()
samdanbury 0:cae064bcbe5e 536 sd = stemp; // the contents of sd are now "This is a string!"
samdanbury 0:cae064bcbe5e 537
samdanbury 0:cae064bcbe5e 538 return (sd);
samdanbury 0:cae064bcbe5e 539 }