Eric Jung / IBMIoTClientEthernetExample_WIZnet

IBMIoTClientEthernetExample for WIZwiki-W7500 platform

Dependencies:   MQTT WIZnetInterface mbed-src

main.cpp@0:7488a229e6fc, 2015-06-29 (annotated)

Committer:
hkjung
Date:
Mon Jun 29 11:57:28 2015 +0000
Revision:
0:7488a229e6fc
Child:
2:b1dcfd885d7f
IBMIoTClientEthernetExample for WIZwiki-W7500 platform

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