Rajath Ramesh / Mbed 2 deprecated IBMIoTClientExampleForLPC1768

Local copy

Dependencies:   C12832_lcd ConfigFile EthernetInterface LM75B MMA7660 MQTTPacket mbed-rtos mbed

Fork of IBMIoTClientExampleForLPC1768 by Sam Danbury

src/QuickstartClient.cpp@3:ca5b84eb8f3b, 2014-06-24 (annotated)

Committer:
samdanbury
Date:
Tue Jun 24 10:29:07 2014 +0000
Revision:
3:ca5b84eb8f3b
Parent:
2:25ddff75a8c7
Child:
5:1b54a0b7b39d
fixed memory issue

Who changed what in which revision?

UserRevisionLine numberNew contents of line
samdanbury 0:6276e9f72327 1 /*******************************************************************************
samdanbury 0:6276e9f72327 2 * Copyright (c) 2014 IBM Corporation and other Contributors.
samdanbury 0:6276e9f72327 3 *
samdanbury 0:6276e9f72327 4 * All rights reserved. This program and the accompanying materials
samdanbury 0:6276e9f72327 5 * are made available under the terms of the Eclipse Public License v1.0
samdanbury 0:6276e9f72327 6 * which accompanies this distribution, and is available at
samdanbury 0:6276e9f72327 7 * http://www.eclipse.org/legal/epl-v10.html
samdanbury 0:6276e9f72327 8 *
samdanbury 0:6276e9f72327 9 * Contributors: Sam Danbury
samdanbury 0:6276e9f72327 10 * IBM - Initial Contribution
samdanbury 0:6276e9f72327 11 *******************************************************************************/
samdanbury 0:6276e9f72327 12
samdanbury 0:6276e9f72327 13 #include "QuickstartClient.h"
samdanbury 0:6276e9f72327 14
samdanbury 0:6276e9f72327 15 QuickstartClient::QuickstartClient(string mac) {
samdanbury 2:25ddff75a8c7 16 quickstartMode = true;
samdanbury 0:6276e9f72327 17 connected = false;
samdanbury 0:6276e9f72327 18 macAddress = mac;
samdanbury 0:6276e9f72327 19
samdanbury 2:25ddff75a8c7 20 //Generate topic string
samdanbury 3:ca5b84eb8f3b 21 memcpy(topic, "iot-2/evt/status/fmt/json", 25);
samdanbury 3:ca5b84eb8f3b 22 topic[25] = '\0';
samdanbury 2:25ddff75a8c7 23
samdanbury 2:25ddff75a8c7 24 loadConfig();
samdanbury 0:6276e9f72327 25
samdanbury 0:6276e9f72327 26 tryMqttConnect();
samdanbury 0:6276e9f72327 27 }
samdanbury 0:6276e9f72327 28
samdanbury 2:25ddff75a8c7 29 void QuickstartClient::loadConfig() {
samdanbury 2:25ddff75a8c7 30
samdanbury 2:25ddff75a8c7 31 ConfigFile cfg;
samdanbury 2:25ddff75a8c7 32
samdanbury 3:ca5b84eb8f3b 33 char value[30];
samdanbury 3:ca5b84eb8f3b 34 char value1[30];
samdanbury 3:ca5b84eb8f3b 35 char value2[30];
samdanbury 3:ca5b84eb8f3b 36 char value3[30];
samdanbury 2:25ddff75a8c7 37
samdanbury 2:25ddff75a8c7 38 if (cfg.read("/local/device.cfg")) {
samdanbury 2:25ddff75a8c7 39 quickstartMode = false;
samdanbury 2:25ddff75a8c7 40
samdanbury 3:ca5b84eb8f3b 41 if (cfg.getValue("org", value, sizeof(value))) {
samdanbury 2:25ddff75a8c7 42 stringstream ss(value);
samdanbury 2:25ddff75a8c7 43 ss >> org;
samdanbury 2:25ddff75a8c7 44 } else {
samdanbury 2:25ddff75a8c7 45 lcd.printf("No org defined in config\n");
samdanbury 2:25ddff75a8c7 46 }
samdanbury 2:25ddff75a8c7 47
samdanbury 3:ca5b84eb8f3b 48 if (cfg.getValue("type", value1, sizeof(value1))) {
samdanbury 3:ca5b84eb8f3b 49 stringstream ss(value1);
samdanbury 2:25ddff75a8c7 50 ss >> type;
samdanbury 2:25ddff75a8c7 51 } else {
samdanbury 2:25ddff75a8c7 52 lcd.printf("No type defined in config\n");
samdanbury 2:25ddff75a8c7 53 }
samdanbury 2:25ddff75a8c7 54
samdanbury 3:ca5b84eb8f3b 55 if (cfg.getValue("id", value2, sizeof(value2))) {
samdanbury 3:ca5b84eb8f3b 56 stringstream ss(value2);
samdanbury 2:25ddff75a8c7 57 ss >> id;
samdanbury 2:25ddff75a8c7 58 } else {
samdanbury 2:25ddff75a8c7 59 lcd.printf("No id defined in config\n");
samdanbury 2:25ddff75a8c7 60 }
samdanbury 2:25ddff75a8c7 61
samdanbury 3:ca5b84eb8f3b 62 if (cfg.getValue("token", value3, sizeof(value3))) {
samdanbury 3:ca5b84eb8f3b 63 stringstream ss(value3);
samdanbury 2:25ddff75a8c7 64 ss >> token;
samdanbury 2:25ddff75a8c7 65 } else {
samdanbury 2:25ddff75a8c7 66 lcd.printf("No token defined in config\n");
samdanbury 2:25ddff75a8c7 67 }
samdanbury 3:ca5b84eb8f3b 68
samdanbury 2:25ddff75a8c7 69 } else {
samdanbury 2:25ddff75a8c7 70 org = "quickstart";
samdanbury 2:25ddff75a8c7 71 type = "iotsample-mbed-lpc1768";
samdanbury 2:25ddff75a8c7 72 id = macAddress;
samdanbury 2:25ddff75a8c7 73 }
samdanbury 2:25ddff75a8c7 74
samdanbury 2:25ddff75a8c7 75 }
samdanbury 2:25ddff75a8c7 76
samdanbury 0:6276e9f72327 77 int QuickstartClient::reconnectDelay(int i) {
samdanbury 0:6276e9f72327 78 if (i < 10) {
samdanbury 0:6276e9f72327 79 return 3; //First 10 attempts try within 3 seconds
samdanbury 0:6276e9f72327 80 } else if (i < 20) {
samdanbury 0:6276e9f72327 81 return 60; //Next 10 attempts retry after every 1 minute
samdanbury 0:6276e9f72327 82 } else {
samdanbury 0:6276e9f72327 83 return 600; //After 20 attempts, retry every 10 minutes
samdanbury 0:6276e9f72327 84 }
samdanbury 0:6276e9f72327 85 }
samdanbury 0:6276e9f72327 86
samdanbury 0:6276e9f72327 87 void QuickstartClient::tryMqttConnect() {
samdanbury 0:6276e9f72327 88 int retryAttempt = 0;
samdanbury 0:6276e9f72327 89
samdanbury 0:6276e9f72327 90 //Reinstantiate TCP socket connection object
samdanbury 0:6276e9f72327 91 mysock = TCPSocketConnection();
samdanbury 0:6276e9f72327 92
samdanbury 0:6276e9f72327 93 while (connected == false) {
samdanbury 0:6276e9f72327 94 lcd.cls();
samdanbury 0:6276e9f72327 95 lcd.locate(0,0);
samdanbury 0:6276e9f72327 96 lcd.printf("Trying to connect...");
samdanbury 0:6276e9f72327 97
samdanbury 0:6276e9f72327 98 //Based on number of connection attempts, determine timeout
samdanbury 0:6276e9f72327 99 int connDelayTimeout = reconnectDelay(++retryAttempt);
samdanbury 0:6276e9f72327 100
samdanbury 0:6276e9f72327 101 //Attempt to reconnect
samdanbury 0:6276e9f72327 102 connect();
samdanbury 0:6276e9f72327 103
samdanbury 0:6276e9f72327 104 //If connection was not established, continue retry
samdanbury 0:6276e9f72327 105 if (connected == false) {
samdanbury 0:6276e9f72327 106 wait(connDelayTimeout);
samdanbury 0:6276e9f72327 107 } else {
samdanbury 0:6276e9f72327 108 break;
samdanbury 0:6276e9f72327 109 }
samdanbury 0:6276e9f72327 110 }
samdanbury 0:6276e9f72327 111 }
samdanbury 0:6276e9f72327 112
samdanbury 0:6276e9f72327 113 void QuickstartClient::connect() {
samdanbury 0:6276e9f72327 114 MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
samdanbury 0:6276e9f72327 115 int rc = 0;
samdanbury 0:6276e9f72327 116 int len = 0;
samdanbury 0:6276e9f72327 117 char buf[200];
samdanbury 0:6276e9f72327 118 int buflen = sizeof(buf);
samdanbury 0:6276e9f72327 119
samdanbury 0:6276e9f72327 120 //Connect to TCP socket
samdanbury 0:6276e9f72327 121 mysock.connect(IBM_IOT_BROKER, IBM_IOT_PORT);
samdanbury 0:6276e9f72327 122
samdanbury 2:25ddff75a8c7 123 //Construct client ID
samdanbury 2:25ddff75a8c7 124 string str = string("d:") + org + ":" + type + ":" + id;
samdanbury 3:ca5b84eb8f3b 125 char clientId[str.size()];
samdanbury 3:ca5b84eb8f3b 126 memcpy(clientId, str.c_str(), str.size() + 1);
samdanbury 0:6276e9f72327 127
samdanbury 0:6276e9f72327 128 //Set MQTT connect options
samdanbury 0:6276e9f72327 129 data.clientID.cstring = clientId;
samdanbury 0:6276e9f72327 130 data.keepAliveInterval = 20;
samdanbury 0:6276e9f72327 131 data.cleansession = 1;
samdanbury 0:6276e9f72327 132 data.MQTTVersion = 3;
samdanbury 0:6276e9f72327 133
samdanbury 0:6276e9f72327 134 //Attempt MQTT connect
samdanbury 0:6276e9f72327 135 len = MQTTSerialize_connect(buf, buflen, &data);
samdanbury 0:6276e9f72327 136 rc = 0;
samdanbury 0:6276e9f72327 137 while (rc < len) {
samdanbury 0:6276e9f72327 138 int rc1 = mysock.send(buf, len);
samdanbury 0:6276e9f72327 139 if (rc1 == -1) {
samdanbury 0:6276e9f72327 140 connected = false;
samdanbury 0:6276e9f72327 141 break;
samdanbury 0:6276e9f72327 142 } else {
samdanbury 0:6276e9f72327 143 rc += rc1;
samdanbury 0:6276e9f72327 144 }
samdanbury 0:6276e9f72327 145 }
samdanbury 0:6276e9f72327 146 if (rc == len) {
samdanbury 0:6276e9f72327 147 connected = true;
samdanbury 0:6276e9f72327 148 }
samdanbury 0:6276e9f72327 149 }
samdanbury 0:6276e9f72327 150
samdanbury 0:6276e9f72327 151 void QuickstartClient::publish(string thePayload) {
samdanbury 0:6276e9f72327 152 int rc = 0;
samdanbury 0:6276e9f72327 153 int len = 0;
samdanbury 0:6276e9f72327 154 char buf[250];
samdanbury 0:6276e9f72327 155 int buflen = sizeof(buf);
samdanbury 0:6276e9f72327 156
samdanbury 0:6276e9f72327 157 MQTTString topicString = MQTTString_initializer;
samdanbury 0:6276e9f72327 158
samdanbury 0:6276e9f72327 159 topicString.cstring = topic;
samdanbury 0:6276e9f72327 160
samdanbury 0:6276e9f72327 161 //Convert payload from string to char array
samdanbury 0:6276e9f72327 162 char* payload = new char [thePayload.length()+1];
samdanbury 0:6276e9f72327 163 std::strcpy (payload, thePayload.c_str());
samdanbury 0:6276e9f72327 164 int payloadlen = strlen(payload);
samdanbury 0:6276e9f72327 165
samdanbury 0:6276e9f72327 166 //Attempt MQTT publish
samdanbury 0:6276e9f72327 167 len = MQTTSerialize_publish(buf, buflen, 0, 0, 0, 0, topicString, payload, payloadlen);
samdanbury 0:6276e9f72327 168 rc = 0;
samdanbury 0:6276e9f72327 169 while (rc < len) {
samdanbury 0:6276e9f72327 170 int rc1 = mysock.send(buf, len);
samdanbury 0:6276e9f72327 171 if (rc1 == -1) {
samdanbury 0:6276e9f72327 172 //If return code from MQTT publish is -1, attempt reconnect
samdanbury 0:6276e9f72327 173 connected = false;
samdanbury 0:6276e9f72327 174 tryMqttConnect();
samdanbury 0:6276e9f72327 175 break;
samdanbury 0:6276e9f72327 176 } else {
samdanbury 0:6276e9f72327 177 rc += rc1;
samdanbury 0:6276e9f72327 178 }
samdanbury 0:6276e9f72327 179 }
samdanbury 0:6276e9f72327 180 wait(0.2);
samdanbury 0:6276e9f72327 181
samdanbury 0:6276e9f72327 182 if (payload) {
samdanbury 0:6276e9f72327 183 delete payload;
samdanbury 0:6276e9f72327 184 }
samdanbury 0:6276e9f72327 185 }