Eric Jung / IBMIoTClientEthernetExample_WIZnet

IBMIoTClientEthernetExample for WIZwiki-W7500 platform

Dependencies:   MQTT WIZnetInterface mbed-src

main.cpp@4:167fd0256a06, 2015-09-17 (annotated)

Committer:
hkjung
Date:
Thu Sep 17 04:42:29 2015 +0000
Revision:
4:167fd0256a06
Parent:
2:b1dcfd885d7f 
Modified the netinfo allocation method

Who changed what in which revision?

UserRevisionLine numberNew contents of line
hkjung 0:7488a229e6fc 1 #include "mbed.h"
hkjung 0:7488a229e6fc 2 #include "EthernetInterface.h"
hkjung 0:7488a229e6fc 3 #include "MQTTClient.h"
hkjung 0:7488a229e6fc 4 #include "MQTTEthernet.h"
hkjung 0:7488a229e6fc 5
hkjung 2:b1dcfd885d7f 6 Serial pc(USBTX, USBRX);
hkjung 2:b1dcfd885d7f 7
hkjung 0:7488a229e6fc 8 // Update this to the next number *before* a commit
hkjung 0:7488a229e6fc 9 #define __APP_SW_REVISION__ "1"
hkjung 0:7488a229e6fc 10
hkjung 0:7488a229e6fc 11 // Configuration values needed to connect to IBM IoT Cloud
hkjung 2:b1dcfd885d7f 12 #define QUICKSTARTMODE 1
hkjung 2:b1dcfd885d7f 13 #if (QUICKSTARTMODE)
hkjung 4:167fd0256a06 14 #define ORG "quickstart" // For a registered connection, replace with your org
hkjung 4:167fd0256a06 15 #define ID "" // For a registered connection, replace with your id
hkjung 4:167fd0256a06 16 #define AUTH_TOKEN "" // For a registered connection, replace with your auth-token
hkjung 4:167fd0256a06 17 #define TYPE DEFAULT_TYPE_NAME // For a registered connection, replace with your type
hkjung 2:b1dcfd885d7f 18 #else
hkjung 4:167fd0256a06 19 #define ORG "" // For a registered connection, replace with your org
hkjung 4:167fd0256a06 20 #define ID "" // For a registered connection, replace with your id
hkjung 4:167fd0256a06 21 #define AUTH_TOKEN "" // For a registered connection, replace with your auth-token
hkjung 4:167fd0256a06 22 #define TYPE "WIZwiki-W7500" // For a registered connection, replace with your type
hkjung 2:b1dcfd885d7f 23 #endif
hkjung 2:b1dcfd885d7f 24
hkjung 2:b1dcfd885d7f 25 #if defined(TARGET_WIZwiki_W7500)
hkjung 2:b1dcfd885d7f 26 //#warning "Compiling for mbed WIZwiki-W7500"
hkjung 2:b1dcfd885d7f 27 #include "WIZwiki-W7500.h"
hkjung 2:b1dcfd885d7f 28 #endif
hkjung 0:7488a229e6fc 29
hkjung 0:7488a229e6fc 30 #define MQTT_PORT 1883
hkjung 0:7488a229e6fc 31 #define MQTT_TLS_PORT 8883
hkjung 0:7488a229e6fc 32 #define IBM_IOT_PORT MQTT_PORT
hkjung 0:7488a229e6fc 33
hkjung 0:7488a229e6fc 34 #define MQTT_MAX_PACKET_SIZE 250
hkjung 0:7488a229e6fc 35
hkjung 0:7488a229e6fc 36 #if defined(TARGET_WIZwiki_W7500)
hkjung 4:167fd0256a06 37 // RGB LED control
hkjung 2:b1dcfd885d7f 38 void off();
hkjung 2:b1dcfd885d7f 39 void red();
hkjung 2:b1dcfd885d7f 40 void green();
hkjung 2:b1dcfd885d7f 41 void blue();
hkjung 0:7488a229e6fc 42 #endif
hkjung 0:7488a229e6fc 43
hkjung 2:b1dcfd885d7f 44 bool quickstartMode = QUICKSTARTMODE;
hkjung 0:7488a229e6fc 45 char org[11] = ORG;
hkjung 0:7488a229e6fc 46 char type[30] = TYPE;
hkjung 0:7488a229e6fc 47 char id[30] = ID; // mac without colons
hkjung 0:7488a229e6fc 48 char auth_token[30] = AUTH_TOKEN; // Auth_token is only used in non-quickstart mode
hkjung 0:7488a229e6fc 49
hkjung 0:7488a229e6fc 50 bool connected = false;
hkjung 0:7488a229e6fc 51 int blink_interval = 0;
hkjung 0:7488a229e6fc 52
hkjung 0:7488a229e6fc 53 int connect(MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTEthernet* ipstack)
hkjung 0:7488a229e6fc 54 {
hkjung 0:7488a229e6fc 55 const char* iot_ibm = ".messaging.internetofthings.ibmcloud.com";
hkjung 0:7488a229e6fc 56 char hostname[strlen(org) + strlen(iot_ibm) + 1];
hkjung 0:7488a229e6fc 57 sprintf(hostname, "%s%s", org, iot_ibm);
hkjung 0:7488a229e6fc 58
hkjung 0:7488a229e6fc 59 //const char* iot_ibm = "23.246.232.210";
hkjung 0:7488a229e6fc 60 //char hostname[strlen(iot_ibm) + 1];
hkjung 0:7488a229e6fc 61 //sprintf(hostname, "%s", iot_ibm);
hkjung 2:b1dcfd885d7f 62
hkjung 0:7488a229e6fc 63 DEBUG("hostname is %s\r\n", hostname);
hkjung 0:7488a229e6fc 64 int rc = ipstack->connect(hostname, IBM_IOT_PORT);
hkjung 0:7488a229e6fc 65 if (rc != 0)
hkjung 0:7488a229e6fc 66 return rc;
hkjung 0:7488a229e6fc 67
hkjung 0:7488a229e6fc 68 // Construct clientId - d:org:type:id
hkjung 0:7488a229e6fc 69 char clientId[strlen(org) + strlen(type) + strlen(id) + 5];
hkjung 2:b1dcfd885d7f 70 sprintf(clientId, "d:%s:%s:%s", org, type, id);
hkjung 0:7488a229e6fc 71 DEBUG("clientid is %s\r\n", clientId);
hkjung 0:7488a229e6fc 72
hkjung 0:7488a229e6fc 73 // MQTT Connect
hkjung 0:7488a229e6fc 74 MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
hkjung 0:7488a229e6fc 75 data.MQTTVersion = 3;
hkjung 0:7488a229e6fc 76 data.clientID.cstring = clientId;
hkjung 0:7488a229e6fc 77
hkjung 0:7488a229e6fc 78 if (!quickstartMode) {
hkjung 0:7488a229e6fc 79 data.username.cstring = "use-token-auth";
hkjung 0:7488a229e6fc 80 data.password.cstring = auth_token;
hkjung 0:7488a229e6fc 81 }
hkjung 0:7488a229e6fc 82
hkjung 0:7488a229e6fc 83 if ((rc = client->connect(data)) == 0) {
hkjung 0:7488a229e6fc 84 connected = true;
hkjung 2:b1dcfd885d7f 85 #if defined(TARGET_WIZwiki_W7500)
hkjung 0:7488a229e6fc 86 green();
hkjung 2:b1dcfd885d7f 87 #endif
hkjung 0:7488a229e6fc 88 printf("Connected\r\n");
hkjung 0:7488a229e6fc 89 wait(2);
hkjung 0:7488a229e6fc 90 }
hkjung 0:7488a229e6fc 91 return rc;
hkjung 0:7488a229e6fc 92 }
hkjung 0:7488a229e6fc 93
hkjung 0:7488a229e6fc 94 int getConnTimeout(int attemptNumber)
hkjung 0:7488a229e6fc 95 {
hkjung 0:7488a229e6fc 96 // First 10 attempts try within 3 seconds, next 10 attempts retry after every 1 minute
hkjung 0:7488a229e6fc 97 // after 20 attempts, retry every 10 minutes
hkjung 0:7488a229e6fc 98 return (attemptNumber < 10) ? 3 : (attemptNumber < 20) ? 60 : 600;
hkjung 0:7488a229e6fc 99 }
hkjung 0:7488a229e6fc 100
hkjung 0:7488a229e6fc 101
hkjung 0:7488a229e6fc 102 void attemptConnect(MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTEthernet* ipstack)
hkjung 0:7488a229e6fc 103 {
hkjung 0:7488a229e6fc 104 int retryAttempt = 0;
hkjung 0:7488a229e6fc 105 connected = false;
hkjung 0:7488a229e6fc 106
hkjung 0:7488a229e6fc 107 // make sure a cable is connected before starting to connect
hkjung 0:7488a229e6fc 108 /*
hkjung 0:7488a229e6fc 109 while (!linkStatus()) {
hkjung 0:7488a229e6fc 110 wait(1.0f);
hkjung 0:7488a229e6fc 111 WARN("Ethernet link not present. Check cable connection\n");
hkjung 0:7488a229e6fc 112 }
hkjung 0:7488a229e6fc 113 */
hkjung 0:7488a229e6fc 114
hkjung 0:7488a229e6fc 115 while (connect(client, ipstack) != 0) {
hkjung 0:7488a229e6fc 116 #if defined(TARGET_WIZwiki_W7500)
hkjung 0:7488a229e6fc 117 red();
hkjung 0:7488a229e6fc 118 #endif
hkjung 0:7488a229e6fc 119 int timeout = getConnTimeout(++retryAttempt);
hkjung 2:b1dcfd885d7f 120 WARN("Retry attempt number %d waiting %d\r\n", retryAttempt, timeout);
hkjung 0:7488a229e6fc 121
hkjung 0:7488a229e6fc 122 // if ipstack and client were on the heap we could deconstruct and goto a label where they are constructed
hkjung 0:7488a229e6fc 123 // or maybe just add the proper members to do this disconnect and call attemptConnect(...)
hkjung 0:7488a229e6fc 124
hkjung 0:7488a229e6fc 125 // this works - reset the system when the retry count gets to a threshold
hkjung 0:7488a229e6fc 126 if (retryAttempt == 5)
hkjung 0:7488a229e6fc 127 NVIC_SystemReset();
hkjung 0:7488a229e6fc 128 else
hkjung 0:7488a229e6fc 129 wait(timeout);
hkjung 0:7488a229e6fc 130 }
hkjung 0:7488a229e6fc 131 }
hkjung 0:7488a229e6fc 132
hkjung 0:7488a229e6fc 133 int publish(MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTEthernet* ipstack)
hkjung 0:7488a229e6fc 134 {
hkjung 0:7488a229e6fc 135 MQTT::Message message;
hkjung 0:7488a229e6fc 136 char* pubTopic = "iot-2/evt/status/fmt/json";
hkjung 0:7488a229e6fc 137
hkjung 0:7488a229e6fc 138 char buf[250];
hkjung 2:b1dcfd885d7f 139
hkjung 4:167fd0256a06 140 sprintf(buf, "{\"d\":{\"myName\":\"IoT mbed\",\"potentiometer\":%0.3f}}", ain0.read());
hkjung 4:167fd0256a06 141 //sprintf(buf, "{\"d\":{\"myName\":\"IoT mbed\",\"potentiometer\":%0.4f}}", ain0.read());
hkjung 0:7488a229e6fc 142
hkjung 0:7488a229e6fc 143 message.qos = MQTT::QOS0;
hkjung 0:7488a229e6fc 144 message.retained = false;
hkjung 0:7488a229e6fc 145 message.dup = false;
hkjung 0:7488a229e6fc 146 message.payload = (void*)buf;
hkjung 0:7488a229e6fc 147 message.payloadlen = strlen(buf);
hkjung 0:7488a229e6fc 148
hkjung 0:7488a229e6fc 149 LOG("Publishing %s\r\n", buf);
hkjung 0:7488a229e6fc 150 return client->publish(pubTopic, message);
hkjung 0:7488a229e6fc 151 }
hkjung 0:7488a229e6fc 152
hkjung 0:7488a229e6fc 153 char* getMac(EthernetInterface& eth, char* buf, int buflen) // Obtain MAC address
hkjung 0:7488a229e6fc 154 {
hkjung 0:7488a229e6fc 155 strncpy(buf, eth.getMACAddress(), buflen);
hkjung 0:7488a229e6fc 156
hkjung 0:7488a229e6fc 157 char* pos; // Remove colons from mac address
hkjung 0:7488a229e6fc 158 while ((pos = strchr(buf, ':')) != NULL)
hkjung 0:7488a229e6fc 159 memmove(pos, pos + 1, strlen(pos) + 1);
hkjung 0:7488a229e6fc 160 return buf;
hkjung 0:7488a229e6fc 161 }
hkjung 0:7488a229e6fc 162
hkjung 0:7488a229e6fc 163 void messageArrived(MQTT::MessageData& md)
hkjung 0:7488a229e6fc 164 {
hkjung 0:7488a229e6fc 165 MQTT::Message &message = md.message;
hkjung 0:7488a229e6fc 166 char topic[md.topicName.lenstring.len + 1];
hkjung 0:7488a229e6fc 167
hkjung 0:7488a229e6fc 168 sprintf(topic, "%.*s", md.topicName.lenstring.len, md.topicName.lenstring.data);
hkjung 0:7488a229e6fc 169
hkjung 0:7488a229e6fc 170 LOG("Message arrived on topic %s: %.*s\r\n", topic, message.payloadlen, message.payload);
hkjung 0:7488a229e6fc 171
hkjung 0:7488a229e6fc 172 // Command topic: iot-2/cmd/blink/fmt/json - cmd is the string between cmd/ and /fmt/
hkjung 0:7488a229e6fc 173 char* start = strstr(topic, "/cmd/") + 5;
hkjung 0:7488a229e6fc 174 int len = strstr(topic, "/fmt/") - start;
hkjung 0:7488a229e6fc 175
hkjung 0:7488a229e6fc 176 if (memcmp(start, "blink", len) == 0) {
hkjung 0:7488a229e6fc 177 char payload[message.payloadlen + 1];
hkjung 0:7488a229e6fc 178 sprintf(payload, "%.*s", message.payloadlen, (char*)message.payload);
hkjung 0:7488a229e6fc 179
hkjung 0:7488a229e6fc 180 char* pos = strchr(payload, '}');
hkjung 0:7488a229e6fc 181 if (pos != NULL) {
hkjung 0:7488a229e6fc 182 *pos = '\0';
hkjung 0:7488a229e6fc 183 if ((pos = strchr(payload, ':')) != NULL) {
hkjung 0:7488a229e6fc 184 int blink_rate = atoi(pos + 1);
hkjung 0:7488a229e6fc 185 blink_interval = (blink_rate <= 0) ? 0 : (blink_rate > 50 ? 1 : 50/blink_rate);
hkjung 0:7488a229e6fc 186 }
hkjung 0:7488a229e6fc 187 }
hkjung 0:7488a229e6fc 188 } else
hkjung 2:b1dcfd885d7f 189 WARN("Unsupported command: %.*s\r\n", len, start);
hkjung 0:7488a229e6fc 190 }
hkjung 0:7488a229e6fc 191
hkjung 0:7488a229e6fc 192 int main (void)
hkjung 0:7488a229e6fc 193 {
hkjung 2:b1dcfd885d7f 194 pc.baud(115200);
hkjung 2:b1dcfd885d7f 195
hkjung 2:b1dcfd885d7f 196 #if defined(TARGET_WIZwiki_W7500)
hkjung 2:b1dcfd885d7f 197 // Board init indicator : Init success
hkjung 0:7488a229e6fc 198 red();
hkjung 0:7488a229e6fc 199 wait(0.2);
hkjung 2:b1dcfd885d7f 200 blue();
hkjung 0:7488a229e6fc 201 wait(0.2);
hkjung 0:7488a229e6fc 202 green();
hkjung 0:7488a229e6fc 203 wait(0.2);
hkjung 0:7488a229e6fc 204 off();
hkjung 0:7488a229e6fc 205 wait(0.2);
hkjung 0:7488a229e6fc 206 // end of board init indicator
hkjung 2:b1dcfd885d7f 207 #endif
hkjung 0:7488a229e6fc 208
hkjung 2:b1dcfd885d7f 209 quickstartMode = (strcmp(org, "quickstart") == 0);
hkjung 0:7488a229e6fc 210 printf("Connecting...\r\n");
hkjung 0:7488a229e6fc 211
hkjung 0:7488a229e6fc 212 #if defined(TARGET_WIZwiki_W7500)
hkjung 2:b1dcfd885d7f 213 blue();
hkjung 0:7488a229e6fc 214 #endif
hkjung 0:7488a229e6fc 215
hkjung 0:7488a229e6fc 216 MQTTEthernet ipstack;
hkjung 0:7488a229e6fc 217 MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE> client(ipstack);
hkjung 0:7488a229e6fc 218
hkjung 0:7488a229e6fc 219 if (quickstartMode) {
hkjung 0:7488a229e6fc 220 getMac(ipstack.getEth(), id, sizeof(id));
hkjung 2:b1dcfd885d7f 221 //printf("getMac: %s\r\n", id);
hkjung 0:7488a229e6fc 222 }
hkjung 0:7488a229e6fc 223
hkjung 0:7488a229e6fc 224 attemptConnect(&client, &ipstack);
hkjung 0:7488a229e6fc 225
hkjung 0:7488a229e6fc 226 if (!quickstartMode)
hkjung 0:7488a229e6fc 227 {
hkjung 0:7488a229e6fc 228 int rc = 0;
hkjung 0:7488a229e6fc 229 if ((rc = client.subscribe("iot-2/cmd/+/fmt/json", MQTT::QOS1, messageArrived)) != 0)
hkjung 2:b1dcfd885d7f 230 WARN("rc from MQTT subscribe is %d\r\n", rc);
hkjung 0:7488a229e6fc 231 }
hkjung 0:7488a229e6fc 232
hkjung 0:7488a229e6fc 233 blink_interval = 0;
hkjung 0:7488a229e6fc 234 int count = 0;
hkjung 0:7488a229e6fc 235
hkjung 0:7488a229e6fc 236 while(true)
hkjung 0:7488a229e6fc 237 {
hkjung 2:b1dcfd885d7f 238 if (++count == 100)
hkjung 2:b1dcfd885d7f 239 { // Publish a message every second
hkjung 2:b1dcfd885d7f 240
hkjung 2:b1dcfd885d7f 241 //printf("A0: %0.4f\r\n", ain0.read());
hkjung 0:7488a229e6fc 242
hkjung 0:7488a229e6fc 243 if (publish(&client, &ipstack) != 0)
hkjung 0:7488a229e6fc 244 attemptConnect(&client, &ipstack); // if we have lost the connection
hkjung 0:7488a229e6fc 245 count = 0;
hkjung 0:7488a229e6fc 246 }
hkjung 0:7488a229e6fc 247
hkjung 2:b1dcfd885d7f 248
hkjung 4:167fd0256a06 249 // Control the LED Blink interval: By Bluemix Node-RED
hkjung 2:b1dcfd885d7f 250 if (blink_interval == 0)
hkjung 2:b1dcfd885d7f 251 off();
hkjung 2:b1dcfd885d7f 252 else if (count % blink_interval == 0)
hkjung 2:b1dcfd885d7f 253 b = !b;
hkjung 2:b1dcfd885d7f 254
hkjung 0:7488a229e6fc 255 client.yield(10); // allow the MQTT client to receive messages
hkjung 0:7488a229e6fc 256 }
hkjung 0:7488a229e6fc 257 }
hkjung 0:7488a229e6fc 258
hkjung 2:b1dcfd885d7f 259 #if defined(TARGET_WIZwiki_W7500)
hkjung 4:167fd0256a06 260 // RGB LED control -> DigitalOut
hkjung 2:b1dcfd885d7f 261 void off()
hkjung 4:167fd0256a06 262 {
hkjung 2:b1dcfd885d7f 263 r = g = b = 1;
hkjung 2:b1dcfd885d7f 264 }
hkjung 2:b1dcfd885d7f 265
hkjung 2:b1dcfd885d7f 266 void red()
hkjung 4:167fd0256a06 267 {
hkjung 2:b1dcfd885d7f 268 r = 0; g = 1; b = 1;
hkjung 2:b1dcfd885d7f 269 }
hkjung 2:b1dcfd885d7f 270
hkjung 2:b1dcfd885d7f 271 void green()
hkjung 4:167fd0256a06 272 {
hkjung 2:b1dcfd885d7f 273 r = 1; g = 0; b = 1;
hkjung 2:b1dcfd885d7f 274 }
hkjung 2:b1dcfd885d7f 275
hkjung 2:b1dcfd885d7f 276 void blue()
hkjung 4:167fd0256a06 277 {
hkjung 2:b1dcfd885d7f 278 r = 1; g = 1; b = 0;
hkjung 2:b1dcfd885d7f 279 }
hkjung 2:b1dcfd885d7f 280 #endif
hkjung 2:b1dcfd885d7f 281