Example for connecting to Cayenne using the WIZ820ioInterface (W5200) library.
Dependencies: Cayenne-MQTT-mbed WIZ820ioInterface mbed
main.cpp@0:846ee26b6faa, 2016-10-07 (annotated)
- Committer:
- jburhenn
- Date:
- Fri Oct 07 23:28:09 2016 +0000
- Revision:
- 0:846ee26b6faa
- Child:
- 2:09f0c27ef315
Connect to Cayenne using WIZ820ioInterface (W5200) library.
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
jburhenn | 0:846ee26b6faa | 1 | /** |
jburhenn | 0:846ee26b6faa | 2 | * Example app for using the Cayenne MQTT C++ library to send and receive example data. This example uses |
jburhenn | 0:846ee26b6faa | 3 | * the WIZ820ioInterface library to connect via Ethernet. |
jburhenn | 0:846ee26b6faa | 4 | */ |
jburhenn | 0:846ee26b6faa | 5 | |
jburhenn | 0:846ee26b6faa | 6 | #include "MQTTTimer.h" |
jburhenn | 0:846ee26b6faa | 7 | #include "CayenneMQTTClient.h" |
jburhenn | 0:846ee26b6faa | 8 | #include "MQTTNetwork.h" |
jburhenn | 0:846ee26b6faa | 9 | #include "WIZ820ioInterface.h" |
jburhenn | 0:846ee26b6faa | 10 | |
jburhenn | 0:846ee26b6faa | 11 | WIZ820ioInterface interface(D11, D12, D13, D10, D5); // MOSI, MISO, SCK, SEL, Reset |
jburhenn | 0:846ee26b6faa | 12 | MQTTNetwork<WIZ820ioInterface> network(interface); |
jburhenn | 0:846ee26b6faa | 13 | Cayenne::MQTTClient<MQTTNetwork<WIZ820ioInterface>, MQTTTimer> mqttClient(network); |
jburhenn | 0:846ee26b6faa | 14 | |
jburhenn | 0:846ee26b6faa | 15 | // Cayenne authentication info. This should be obtained from the Cayenne Dashboard. |
jburhenn | 0:846ee26b6faa | 16 | char* username = "MQTT_USERNAME"; |
jburhenn | 0:846ee26b6faa | 17 | char* clientID = "CLIENT_ID"; |
jburhenn | 0:846ee26b6faa | 18 | char* password = "MQTT_PASSWORD"; |
jburhenn | 0:846ee26b6faa | 19 | |
jburhenn | 0:846ee26b6faa | 20 | /** |
jburhenn | 0:846ee26b6faa | 21 | * Print the message info. |
jburhenn | 0:846ee26b6faa | 22 | * @param[in] message The message received from the Cayenne server. |
jburhenn | 0:846ee26b6faa | 23 | */ |
jburhenn | 0:846ee26b6faa | 24 | void outputMessage(Cayenne::MessageData& message) |
jburhenn | 0:846ee26b6faa | 25 | { |
jburhenn | 0:846ee26b6faa | 26 | switch (message.topic) { |
jburhenn | 0:846ee26b6faa | 27 | case COMMAND_TOPIC: |
jburhenn | 0:846ee26b6faa | 28 | printf("topic=Command"); |
jburhenn | 0:846ee26b6faa | 29 | break; |
jburhenn | 0:846ee26b6faa | 30 | case CONFIG_TOPIC: |
jburhenn | 0:846ee26b6faa | 31 | printf("topic=Config"); |
jburhenn | 0:846ee26b6faa | 32 | break; |
jburhenn | 0:846ee26b6faa | 33 | default: |
jburhenn | 0:846ee26b6faa | 34 | printf("topic=%d", message.topic); |
jburhenn | 0:846ee26b6faa | 35 | break; |
jburhenn | 0:846ee26b6faa | 36 | } |
jburhenn | 0:846ee26b6faa | 37 | printf(" channel=%d", message.channel); |
jburhenn | 0:846ee26b6faa | 38 | if (message.clientID) { |
jburhenn | 0:846ee26b6faa | 39 | printf(" clientID=%s", message.clientID); |
jburhenn | 0:846ee26b6faa | 40 | } |
jburhenn | 0:846ee26b6faa | 41 | if (message.type) { |
jburhenn | 0:846ee26b6faa | 42 | printf(" type=%s", message.type); |
jburhenn | 0:846ee26b6faa | 43 | } |
jburhenn | 0:846ee26b6faa | 44 | for (size_t i = 0; i < message.valueCount; ++i) { |
jburhenn | 0:846ee26b6faa | 45 | if (message.values[i].value) { |
jburhenn | 0:846ee26b6faa | 46 | printf(" value=%s", message.values[i].value); |
jburhenn | 0:846ee26b6faa | 47 | } |
jburhenn | 0:846ee26b6faa | 48 | if (message.values[i].unit) { |
jburhenn | 0:846ee26b6faa | 49 | printf(" unit=%s", message.values[i].unit); |
jburhenn | 0:846ee26b6faa | 50 | } |
jburhenn | 0:846ee26b6faa | 51 | } |
jburhenn | 0:846ee26b6faa | 52 | if (message.id) { |
jburhenn | 0:846ee26b6faa | 53 | printf(" id=%s", message.id); |
jburhenn | 0:846ee26b6faa | 54 | } |
jburhenn | 0:846ee26b6faa | 55 | printf("\n"); |
jburhenn | 0:846ee26b6faa | 56 | } |
jburhenn | 0:846ee26b6faa | 57 | |
jburhenn | 0:846ee26b6faa | 58 | /** |
jburhenn | 0:846ee26b6faa | 59 | * Handle messages received from the Cayenne server. |
jburhenn | 0:846ee26b6faa | 60 | * @param[in] message The message received from the Cayenne server. |
jburhenn | 0:846ee26b6faa | 61 | */ |
jburhenn | 0:846ee26b6faa | 62 | void messageArrived(Cayenne::MessageData& message) |
jburhenn | 0:846ee26b6faa | 63 | { |
jburhenn | 0:846ee26b6faa | 64 | int error = 0; |
jburhenn | 0:846ee26b6faa | 65 | // Add code to process the message. Here we just ouput the message data. |
jburhenn | 0:846ee26b6faa | 66 | outputMessage(message); |
jburhenn | 0:846ee26b6faa | 67 | |
jburhenn | 0:846ee26b6faa | 68 | // If this is a command message we publish a response. Here we are just sending a default 'OK' response. |
jburhenn | 0:846ee26b6faa | 69 | // An error response should be sent if there are issues processing the message. |
jburhenn | 0:846ee26b6faa | 70 | if (message.topic == COMMAND_TOPIC && (error = mqttClient.publishResponse(message.channel, message.id, NULL, message.clientID)) != CAYENNE_SUCCESS) { |
jburhenn | 0:846ee26b6faa | 71 | printf("Response failure, error: %d\n", error); |
jburhenn | 0:846ee26b6faa | 72 | } |
jburhenn | 0:846ee26b6faa | 73 | } |
jburhenn | 0:846ee26b6faa | 74 | |
jburhenn | 0:846ee26b6faa | 75 | /** |
jburhenn | 0:846ee26b6faa | 76 | * Connect to the Cayenne server. |
jburhenn | 0:846ee26b6faa | 77 | * @return Returns CAYENNE_SUCCESS if the connection succeeds, or an error code otherwise. |
jburhenn | 0:846ee26b6faa | 78 | */ |
jburhenn | 0:846ee26b6faa | 79 | int connectClient(void) |
jburhenn | 0:846ee26b6faa | 80 | { |
jburhenn | 0:846ee26b6faa | 81 | int error = 0; |
jburhenn | 0:846ee26b6faa | 82 | // Connect to the server. |
jburhenn | 0:846ee26b6faa | 83 | printf("Connecting to %s:%d\n", CAYENNE_DOMAIN, CAYENNE_PORT); |
jburhenn | 0:846ee26b6faa | 84 | while ((error = network.connect(CAYENNE_DOMAIN, CAYENNE_PORT)) != 0) { |
jburhenn | 0:846ee26b6faa | 85 | printf("TCP connect failed, error: %d\n", error); |
jburhenn | 0:846ee26b6faa | 86 | wait(2); |
jburhenn | 0:846ee26b6faa | 87 | } |
jburhenn | 0:846ee26b6faa | 88 | |
jburhenn | 0:846ee26b6faa | 89 | if ((error = mqttClient.connect(username, clientID, password)) != MQTT::SUCCESS) { |
jburhenn | 0:846ee26b6faa | 90 | printf("MQTT connect failed, error: %d\n", error); |
jburhenn | 0:846ee26b6faa | 91 | return error; |
jburhenn | 0:846ee26b6faa | 92 | } |
jburhenn | 0:846ee26b6faa | 93 | printf("Connected\n"); |
jburhenn | 0:846ee26b6faa | 94 | |
jburhenn | 0:846ee26b6faa | 95 | // Subscribe to required topics. |
jburhenn | 0:846ee26b6faa | 96 | if ((error = mqttClient.subscribe(COMMAND_TOPIC, CAYENNE_ALL_CHANNELS)) != CAYENNE_SUCCESS) { |
jburhenn | 0:846ee26b6faa | 97 | printf("Subscription to Command topic failed, error: %d\n", error); |
jburhenn | 0:846ee26b6faa | 98 | } |
jburhenn | 0:846ee26b6faa | 99 | if ((error = mqttClient.subscribe(CONFIG_TOPIC, CAYENNE_ALL_CHANNELS)) != CAYENNE_SUCCESS) { |
jburhenn | 0:846ee26b6faa | 100 | printf("Subscription to Config topic failed, error:%d\n", error); |
jburhenn | 0:846ee26b6faa | 101 | } |
jburhenn | 0:846ee26b6faa | 102 | |
jburhenn | 0:846ee26b6faa | 103 | // Send device info. Here we just send some example values for the system info. These should be changed to use actual system data, or removed if not needed. |
jburhenn | 0:846ee26b6faa | 104 | mqttClient.publishData(SYS_VERSION_TOPIC, CAYENNE_NO_CHANNEL, NULL, NULL, CAYENNE_VERSION); |
jburhenn | 0:846ee26b6faa | 105 | mqttClient.publishData(SYS_MODEL_TOPIC, CAYENNE_NO_CHANNEL, NULL, NULL, "mbedDevice"); |
jburhenn | 0:846ee26b6faa | 106 | mqttClient.publishData(SYS_CPU_MODEL_TOPIC, CAYENNE_NO_CHANNEL, NULL, NULL, "CPU Model"); |
jburhenn | 0:846ee26b6faa | 107 | mqttClient.publishData(SYS_CPU_SPEED_TOPIC, CAYENNE_NO_CHANNEL, NULL, NULL, "1000000000"); |
jburhenn | 0:846ee26b6faa | 108 | |
jburhenn | 0:846ee26b6faa | 109 | return CAYENNE_SUCCESS; |
jburhenn | 0:846ee26b6faa | 110 | } |
jburhenn | 0:846ee26b6faa | 111 | |
jburhenn | 0:846ee26b6faa | 112 | /** |
jburhenn | 0:846ee26b6faa | 113 | * Main loop where MQTT code is run. |
jburhenn | 0:846ee26b6faa | 114 | */ |
jburhenn | 0:846ee26b6faa | 115 | void loop(void) |
jburhenn | 0:846ee26b6faa | 116 | { |
jburhenn | 0:846ee26b6faa | 117 | MQTTTimer timer(5000); |
jburhenn | 0:846ee26b6faa | 118 | |
jburhenn | 0:846ee26b6faa | 119 | while (true) { |
jburhenn | 0:846ee26b6faa | 120 | // Yield to allow MQTT message processing. |
jburhenn | 0:846ee26b6faa | 121 | mqttClient.yield(1000); |
jburhenn | 0:846ee26b6faa | 122 | |
jburhenn | 0:846ee26b6faa | 123 | // Check that we are still connected, if not, reconnect. |
jburhenn | 0:846ee26b6faa | 124 | if (!network.connected() || !mqttClient.connected()) { |
jburhenn | 0:846ee26b6faa | 125 | network.disconnect(); |
jburhenn | 0:846ee26b6faa | 126 | mqttClient.disconnect(); |
jburhenn | 0:846ee26b6faa | 127 | printf("Reconnecting\n"); |
jburhenn | 0:846ee26b6faa | 128 | while (connectClient() != CAYENNE_SUCCESS) { |
jburhenn | 0:846ee26b6faa | 129 | wait(2); |
jburhenn | 0:846ee26b6faa | 130 | printf("Reconnect failed, retrying\n"); |
jburhenn | 0:846ee26b6faa | 131 | } |
jburhenn | 0:846ee26b6faa | 132 | } |
jburhenn | 0:846ee26b6faa | 133 | |
jburhenn | 0:846ee26b6faa | 134 | // Publish some example data every few seconds. This should be changed to send your actual data to Cayenne. |
jburhenn | 0:846ee26b6faa | 135 | if (timer.expired()) { |
jburhenn | 0:846ee26b6faa | 136 | int error = 0; |
jburhenn | 0:846ee26b6faa | 137 | if ((error = mqttClient.publishData(DATA_TOPIC, 0, TEMPERATURE, CELSIUS, 30.5)) != CAYENNE_SUCCESS) { |
jburhenn | 0:846ee26b6faa | 138 | printf("Publish temperature failed, error: %d\n", error); |
jburhenn | 0:846ee26b6faa | 139 | } |
jburhenn | 0:846ee26b6faa | 140 | if ((error = mqttClient.publishData(DATA_TOPIC, 1, LUMINOSITY, LUX, 1000)) != CAYENNE_SUCCESS) { |
jburhenn | 0:846ee26b6faa | 141 | printf("Publish luminosity failed, error: %d\n", error); |
jburhenn | 0:846ee26b6faa | 142 | } |
jburhenn | 0:846ee26b6faa | 143 | if ((error = mqttClient.publishData(DATA_TOPIC, 2, BAROMETRIC_PRESSURE, HECTOPASCAL, 800)) != CAYENNE_SUCCESS) { |
jburhenn | 0:846ee26b6faa | 144 | printf("Publish barometric pressure failed, error: %d\n", error); |
jburhenn | 0:846ee26b6faa | 145 | } |
jburhenn | 0:846ee26b6faa | 146 | timer.countdown_ms(5000); |
jburhenn | 0:846ee26b6faa | 147 | } |
jburhenn | 0:846ee26b6faa | 148 | } |
jburhenn | 0:846ee26b6faa | 149 | } |
jburhenn | 0:846ee26b6faa | 150 | |
jburhenn | 0:846ee26b6faa | 151 | /** |
jburhenn | 0:846ee26b6faa | 152 | * Main function. |
jburhenn | 0:846ee26b6faa | 153 | */ |
jburhenn | 0:846ee26b6faa | 154 | int main() |
jburhenn | 0:846ee26b6faa | 155 | { |
jburhenn | 0:846ee26b6faa | 156 | printf("Initializing interface\n"); |
jburhenn | 0:846ee26b6faa | 157 | interface.init(); |
jburhenn | 0:846ee26b6faa | 158 | |
jburhenn | 0:846ee26b6faa | 159 | // Set the default function that receives Cayenne messages. |
jburhenn | 0:846ee26b6faa | 160 | mqttClient.setDefaultMessageHandler(messageArrived); |
jburhenn | 0:846ee26b6faa | 161 | |
jburhenn | 0:846ee26b6faa | 162 | // Connect to Cayenne. |
jburhenn | 0:846ee26b6faa | 163 | if (connectClient() == CAYENNE_SUCCESS) { |
jburhenn | 0:846ee26b6faa | 164 | // Run main loop. |
jburhenn | 0:846ee26b6faa | 165 | loop(); |
jburhenn | 0:846ee26b6faa | 166 | } |
jburhenn | 0:846ee26b6faa | 167 | else { |
jburhenn | 0:846ee26b6faa | 168 | printf("Connection failed, exiting\n"); |
jburhenn | 0:846ee26b6faa | 169 | } |
jburhenn | 0:846ee26b6faa | 170 | |
jburhenn | 0:846ee26b6faa | 171 | if (mqttClient.connected()) |
jburhenn | 0:846ee26b6faa | 172 | mqttClient.disconnect(); |
jburhenn | 0:846ee26b6faa | 173 | if (network.connected()) |
jburhenn | 0:846ee26b6faa | 174 | network.disconnect(); |
jburhenn | 0:846ee26b6faa | 175 | |
jburhenn | 0:846ee26b6faa | 176 | return 0; |
jburhenn | 0:846ee26b6faa | 177 | } |
jburhenn | 0:846ee26b6faa | 178 |