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@5:11fd21af0c0f, 2014-08-07 (annotated)

Committer:
samdanbury
Date:
Thu Aug 07 09:33:26 2014 +0000
Revision:
5:11fd21af0c0f
Parent:
4:77fd4b6ceecb
Child:
6:37b6d0d56190
LPC1768 blue RGB LED is no longer turned on

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