0
Dependencies: Cayenne-MQTT-mbed nfc X_NUCLEO_IDW01M1v2 NetworkSocketAPI 13
main.cpp@9:c206c33736fe, 2019-08-28 (annotated)
- Committer:
- kapitaninternet
- Date:
- Wed Aug 28 18:52:43 2019 +0000
- Revision:
- 9:c206c33736fe
- Parent:
- 8:3bcc1a412fe3
0
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
jburhenn | 0:d20655cd1f3c | 1 | /** |
jburhenn | 0:d20655cd1f3c | 2 | * Example app for using the Cayenne MQTT C++ library to send and receive example data. This example uses |
jburhenn | 0:d20655cd1f3c | 3 | * the X-NUCLEO-IDW01M1 WiFi expansion board via the X_NUCLEO_IDW01M1v2 library. |
jburhenn | 0:d20655cd1f3c | 4 | */ |
jburhenn | 0:d20655cd1f3c | 5 | |
jburhenn | 0:d20655cd1f3c | 6 | #include "MQTTTimer.h" |
jburhenn | 0:d20655cd1f3c | 7 | #include "CayenneMQTTClient.h" |
jburhenn | 0:d20655cd1f3c | 8 | #include "MQTTNetworkIDW01M1.h" |
jburhenn | 0:d20655cd1f3c | 9 | #include "SpwfInterface.h" |
jburhenn | 0:d20655cd1f3c | 10 | |
kapitaninternet | 9:c206c33736fe | 11 | |
kapitaninternet | 9:c206c33736fe | 12 | |
kapitaninternet | 9:c206c33736fe | 13 | #include "mbed.h" |
kapitaninternet | 9:c206c33736fe | 14 | #include "XNucleoIKS01A2.h" |
kapitaninternet | 9:c206c33736fe | 15 | |
kapitaninternet | 9:c206c33736fe | 16 | /* Instantiate the expansion board */ |
kapitaninternet | 9:c206c33736fe | 17 | static XNucleoIKS01A2 *mems_expansion_board = XNucleoIKS01A2::instance(D14, D15, D4, D5); |
kapitaninternet | 9:c206c33736fe | 18 | |
kapitaninternet | 9:c206c33736fe | 19 | /* Retrieve the composing elements of the expansion board */ |
kapitaninternet | 9:c206c33736fe | 20 | static LSM303AGRMagSensor *magnetometer = mems_expansion_board->magnetometer; |
kapitaninternet | 9:c206c33736fe | 21 | static HTS221Sensor *hum_temp = mems_expansion_board->ht_sensor; |
kapitaninternet | 9:c206c33736fe | 22 | static LPS22HBSensor *press_temp = mems_expansion_board->pt_sensor; |
kapitaninternet | 9:c206c33736fe | 23 | static LSM6DSLSensor *acc_gyro = mems_expansion_board->acc_gyro; |
kapitaninternet | 9:c206c33736fe | 24 | static LSM303AGRAccSensor *accelerometer = mems_expansion_board->accelerometer; |
kapitaninternet | 9:c206c33736fe | 25 | |
kapitaninternet | 9:c206c33736fe | 26 | /* Helper function for printing floats & doubles */ |
kapitaninternet | 9:c206c33736fe | 27 | static char *print_double(char* str, double v, int decimalDigits=2) |
kapitaninternet | 9:c206c33736fe | 28 | { |
kapitaninternet | 9:c206c33736fe | 29 | int i = 1; |
kapitaninternet | 9:c206c33736fe | 30 | int intPart, fractPart; |
kapitaninternet | 9:c206c33736fe | 31 | int len; |
kapitaninternet | 9:c206c33736fe | 32 | char *ptr; |
kapitaninternet | 9:c206c33736fe | 33 | |
kapitaninternet | 9:c206c33736fe | 34 | /* prepare decimal digits multiplicator */ |
kapitaninternet | 9:c206c33736fe | 35 | for (;decimalDigits!=0; i*=10, decimalDigits--); |
kapitaninternet | 9:c206c33736fe | 36 | |
kapitaninternet | 9:c206c33736fe | 37 | /* calculate integer & fractinal parts */ |
kapitaninternet | 9:c206c33736fe | 38 | intPart = (int)v; |
kapitaninternet | 9:c206c33736fe | 39 | fractPart = (int)((v-(double)(int)v)*i); |
kapitaninternet | 9:c206c33736fe | 40 | |
kapitaninternet | 9:c206c33736fe | 41 | /* fill in integer part */ |
kapitaninternet | 9:c206c33736fe | 42 | sprintf(str, "%i.", intPart); |
kapitaninternet | 9:c206c33736fe | 43 | |
kapitaninternet | 9:c206c33736fe | 44 | /* prepare fill in of fractional part */ |
kapitaninternet | 9:c206c33736fe | 45 | len = strlen(str); |
kapitaninternet | 9:c206c33736fe | 46 | ptr = &str[len]; |
kapitaninternet | 9:c206c33736fe | 47 | |
kapitaninternet | 9:c206c33736fe | 48 | /* fill in leading fractional zeros */ |
kapitaninternet | 9:c206c33736fe | 49 | for (i/=10;i>1; i/=10, ptr++) { |
kapitaninternet | 9:c206c33736fe | 50 | if (fractPart >= i) { |
kapitaninternet | 9:c206c33736fe | 51 | break; |
kapitaninternet | 9:c206c33736fe | 52 | } |
kapitaninternet | 9:c206c33736fe | 53 | *ptr = '0'; |
kapitaninternet | 9:c206c33736fe | 54 | } |
kapitaninternet | 9:c206c33736fe | 55 | |
kapitaninternet | 9:c206c33736fe | 56 | /* fill in (rest of) fractional part */ |
kapitaninternet | 9:c206c33736fe | 57 | sprintf(ptr, "%i", fractPart); |
kapitaninternet | 9:c206c33736fe | 58 | |
kapitaninternet | 9:c206c33736fe | 59 | return str; |
kapitaninternet | 9:c206c33736fe | 60 | } |
kapitaninternet | 9:c206c33736fe | 61 | |
kapitaninternet | 9:c206c33736fe | 62 | |
kapitaninternet | 9:c206c33736fe | 63 | |
kapitaninternet | 9:c206c33736fe | 64 | |
kapitaninternet | 9:c206c33736fe | 65 | #include "XNucleoNFC01A1.h" |
kapitaninternet | 9:c206c33736fe | 66 | #include "NDefLib/NDefNfcTag.h" |
kapitaninternet | 9:c206c33736fe | 67 | #include "NDefLib/RecordType/RecordURI.h" |
kapitaninternet | 9:c206c33736fe | 68 | |
kapitaninternet | 9:c206c33736fe | 69 | /** |
kapitaninternet | 9:c206c33736fe | 70 | * Write a Ndef URI message linking to st.com site. |
kapitaninternet | 9:c206c33736fe | 71 | * Write an NDef message with a Uri record linking the st.com site |
kapitaninternet | 9:c206c33736fe | 72 | * @param nfcNucleo expansion board where write the NDef message |
kapitaninternet | 9:c206c33736fe | 73 | */ |
kapitaninternet | 9:c206c33736fe | 74 | |
kapitaninternet | 9:c206c33736fe | 75 | |
kapitaninternet | 9:c206c33736fe | 76 | |
kapitaninternet | 9:c206c33736fe | 77 | |
kapitaninternet | 9:c206c33736fe | 78 | |
kapitaninternet | 9:c206c33736fe | 79 | |
kapitaninternet | 9:c206c33736fe | 80 | |
kapitaninternet | 9:c206c33736fe | 81 | |
kapitaninternet | 9:c206c33736fe | 82 | |
kapitaninternet | 9:c206c33736fe | 83 | |
kapitaninternet | 9:c206c33736fe | 84 | |
jburhenn | 0:d20655cd1f3c | 85 | // WiFi network info. |
kapitaninternet | 9:c206c33736fe | 86 | char* ssid = "Interneto"; |
kapitaninternet | 9:c206c33736fe | 87 | char* wifiPassword = "matu1234"; |
jburhenn | 0:d20655cd1f3c | 88 | |
jburhenn | 0:d20655cd1f3c | 89 | // Cayenne authentication info. This should be obtained from the Cayenne Dashboard. |
kapitaninternet | 9:c206c33736fe | 90 | char* username = "68880f30-7425-11e9-beb3-736c9e4bf7d0"; |
kapitaninternet | 9:c206c33736fe | 91 | char* password = "19f07b4d8806fe42bdda724980634f39d8e639ba"; |
kapitaninternet | 9:c206c33736fe | 92 | char* clientID = "bb8e7cc0-74b9-11e9-94e9-493d67fd755e"; |
jburhenn | 0:d20655cd1f3c | 93 | |
jburhenn | 0:d20655cd1f3c | 94 | SpwfSAInterface interface(D8, D2); // TX, RX |
jburhenn | 0:d20655cd1f3c | 95 | MQTTNetwork<SpwfSAInterface> network(interface); |
jburhenn | 2:445f09de09bd | 96 | CayenneMQTT::MQTTClient<MQTTNetwork<SpwfSAInterface>, MQTTTimer> mqttClient(network, username, password, clientID); |
jburhenn | 0:d20655cd1f3c | 97 | |
jburhenn | 1:a2d8aec2bb92 | 98 | DigitalOut led1(LED1); |
jburhenn | 1:a2d8aec2bb92 | 99 | |
jburhenn | 0:d20655cd1f3c | 100 | /** |
jburhenn | 0:d20655cd1f3c | 101 | * Print the message info. |
jburhenn | 0:d20655cd1f3c | 102 | * @param[in] message The message received from the Cayenne server. |
jburhenn | 0:d20655cd1f3c | 103 | */ |
jburhenn | 2:445f09de09bd | 104 | void outputMessage(CayenneMQTT::MessageData& message) |
jburhenn | 0:d20655cd1f3c | 105 | { |
jburhenn | 0:d20655cd1f3c | 106 | switch (message.topic) { |
jburhenn | 0:d20655cd1f3c | 107 | case COMMAND_TOPIC: |
jburhenn | 0:d20655cd1f3c | 108 | printf("topic=Command"); |
jburhenn | 0:d20655cd1f3c | 109 | break; |
jburhenn | 0:d20655cd1f3c | 110 | case CONFIG_TOPIC: |
jburhenn | 0:d20655cd1f3c | 111 | printf("topic=Config"); |
jburhenn | 0:d20655cd1f3c | 112 | break; |
jburhenn | 0:d20655cd1f3c | 113 | default: |
jburhenn | 0:d20655cd1f3c | 114 | printf("topic=%d", message.topic); |
jburhenn | 0:d20655cd1f3c | 115 | break; |
jburhenn | 0:d20655cd1f3c | 116 | } |
jburhenn | 0:d20655cd1f3c | 117 | printf(" channel=%d", message.channel); |
jburhenn | 0:d20655cd1f3c | 118 | if (message.clientID) { |
jburhenn | 0:d20655cd1f3c | 119 | printf(" clientID=%s", message.clientID); |
jburhenn | 0:d20655cd1f3c | 120 | } |
jburhenn | 0:d20655cd1f3c | 121 | if (message.type) { |
jburhenn | 0:d20655cd1f3c | 122 | printf(" type=%s", message.type); |
jburhenn | 0:d20655cd1f3c | 123 | } |
jburhenn | 0:d20655cd1f3c | 124 | for (size_t i = 0; i < message.valueCount; ++i) { |
jburhenn | 2:445f09de09bd | 125 | if (message.getValue(i)) { |
jburhenn | 2:445f09de09bd | 126 | printf(" value=%s", message.getValue(i)); |
jburhenn | 0:d20655cd1f3c | 127 | } |
jburhenn | 2:445f09de09bd | 128 | if (message.getUnit(i)) { |
jburhenn | 2:445f09de09bd | 129 | printf(" unit=%s", message.getUnit(i)); |
jburhenn | 0:d20655cd1f3c | 130 | } |
jburhenn | 0:d20655cd1f3c | 131 | } |
jburhenn | 0:d20655cd1f3c | 132 | if (message.id) { |
jburhenn | 0:d20655cd1f3c | 133 | printf(" id=%s", message.id); |
jburhenn | 0:d20655cd1f3c | 134 | } |
jburhenn | 0:d20655cd1f3c | 135 | printf("\n"); |
jburhenn | 0:d20655cd1f3c | 136 | } |
jburhenn | 0:d20655cd1f3c | 137 | |
jburhenn | 0:d20655cd1f3c | 138 | /** |
jburhenn | 0:d20655cd1f3c | 139 | * Handle messages received from the Cayenne server. |
jburhenn | 0:d20655cd1f3c | 140 | * @param[in] message The message received from the Cayenne server. |
jburhenn | 0:d20655cd1f3c | 141 | */ |
jburhenn | 2:445f09de09bd | 142 | void messageArrived(CayenneMQTT::MessageData& message) |
jburhenn | 0:d20655cd1f3c | 143 | { |
jburhenn | 0:d20655cd1f3c | 144 | int error = 0; |
jburhenn | 0:d20655cd1f3c | 145 | // Add code to process the message. Here we just ouput the message data. |
jburhenn | 0:d20655cd1f3c | 146 | outputMessage(message); |
jburhenn | 0:d20655cd1f3c | 147 | |
jburhenn | 1:a2d8aec2bb92 | 148 | if (message.topic == COMMAND_TOPIC) { |
jburhenn | 1:a2d8aec2bb92 | 149 | switch(message.channel) { |
jburhenn | 1:a2d8aec2bb92 | 150 | case 0: |
jburhenn | 1:a2d8aec2bb92 | 151 | // Set the onboard LED state |
jburhenn | 2:445f09de09bd | 152 | led1 = atoi(message.getValue()); |
jburhenn | 1:a2d8aec2bb92 | 153 | // Publish the updated LED state |
jburhenn | 2:445f09de09bd | 154 | if ((error = mqttClient.publishData(DATA_TOPIC, message.channel, NULL, NULL, message.getValue())) != CAYENNE_SUCCESS) { |
jburhenn | 1:a2d8aec2bb92 | 155 | printf("Publish LED state failure, error: %d\n", error); |
jburhenn | 1:a2d8aec2bb92 | 156 | } |
jburhenn | 1:a2d8aec2bb92 | 157 | break; |
jburhenn | 1:a2d8aec2bb92 | 158 | } |
jburhenn | 1:a2d8aec2bb92 | 159 | |
jburhenn | 1:a2d8aec2bb92 | 160 | // If this is a command message we publish a response. Here we are just sending a default 'OK' response. |
jburhenn | 1:a2d8aec2bb92 | 161 | // An error response should be sent if there are issues processing the message. |
jburhenn | 4:939f308d004a | 162 | if ((error = mqttClient.publishResponse(message.id, NULL, message.clientID)) != CAYENNE_SUCCESS) { |
jburhenn | 1:a2d8aec2bb92 | 163 | printf("Response failure, error: %d\n", error); |
jburhenn | 1:a2d8aec2bb92 | 164 | } |
jburhenn | 0:d20655cd1f3c | 165 | } |
jburhenn | 0:d20655cd1f3c | 166 | } |
jburhenn | 0:d20655cd1f3c | 167 | |
jburhenn | 0:d20655cd1f3c | 168 | /** |
jburhenn | 0:d20655cd1f3c | 169 | * Connect to the Cayenne server. |
jburhenn | 0:d20655cd1f3c | 170 | * @return Returns CAYENNE_SUCCESS if the connection succeeds, or an error code otherwise. |
jburhenn | 0:d20655cd1f3c | 171 | */ |
jburhenn | 0:d20655cd1f3c | 172 | int connectClient(void) |
jburhenn | 0:d20655cd1f3c | 173 | { |
jburhenn | 0:d20655cd1f3c | 174 | int error = 0; |
jburhenn | 0:d20655cd1f3c | 175 | // Connect to the server. |
jburhenn | 0:d20655cd1f3c | 176 | printf("Connecting to %s:%d\n", CAYENNE_DOMAIN, CAYENNE_PORT); |
jburhenn | 0:d20655cd1f3c | 177 | while ((error = network.connect(CAYENNE_DOMAIN, CAYENNE_PORT)) != 0) { |
jburhenn | 0:d20655cd1f3c | 178 | printf("TCP connect failed, error: %d\n", error); |
jburhenn | 0:d20655cd1f3c | 179 | wait(2); |
jburhenn | 0:d20655cd1f3c | 180 | } |
jburhenn | 0:d20655cd1f3c | 181 | |
jburhenn | 2:445f09de09bd | 182 | if ((error = mqttClient.connect()) != MQTT::SUCCESS) { |
jburhenn | 0:d20655cd1f3c | 183 | printf("MQTT connect failed, error: %d\n", error); |
jburhenn | 0:d20655cd1f3c | 184 | return error; |
jburhenn | 0:d20655cd1f3c | 185 | } |
jburhenn | 0:d20655cd1f3c | 186 | printf("Connected\n"); |
jburhenn | 0:d20655cd1f3c | 187 | |
jburhenn | 0:d20655cd1f3c | 188 | // Subscribe to required topics. |
jburhenn | 0:d20655cd1f3c | 189 | if ((error = mqttClient.subscribe(COMMAND_TOPIC, CAYENNE_ALL_CHANNELS)) != CAYENNE_SUCCESS) { |
jburhenn | 0:d20655cd1f3c | 190 | printf("Subscription to Command topic failed, error: %d\n", error); |
jburhenn | 0:d20655cd1f3c | 191 | } |
jburhenn | 0:d20655cd1f3c | 192 | if ((error = mqttClient.subscribe(CONFIG_TOPIC, CAYENNE_ALL_CHANNELS)) != CAYENNE_SUCCESS) { |
jburhenn | 0:d20655cd1f3c | 193 | printf("Subscription to Config topic failed, error:%d\n", error); |
jburhenn | 0:d20655cd1f3c | 194 | } |
jburhenn | 0:d20655cd1f3c | 195 | |
jburhenn | 0:d20655cd1f3c | 196 | // 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:d20655cd1f3c | 197 | mqttClient.publishData(SYS_VERSION_TOPIC, CAYENNE_NO_CHANNEL, NULL, NULL, CAYENNE_VERSION); |
jburhenn | 0:d20655cd1f3c | 198 | mqttClient.publishData(SYS_MODEL_TOPIC, CAYENNE_NO_CHANNEL, NULL, NULL, "mbedDevice"); |
jburhenn | 2:445f09de09bd | 199 | //mqttClient.publishData(SYS_CPU_MODEL_TOPIC, CAYENNE_NO_CHANNEL, NULL, NULL, "CPU Model"); |
jburhenn | 2:445f09de09bd | 200 | //mqttClient.publishData(SYS_CPU_SPEED_TOPIC, CAYENNE_NO_CHANNEL, NULL, NULL, "1000000000"); |
jburhenn | 0:d20655cd1f3c | 201 | |
jburhenn | 0:d20655cd1f3c | 202 | return CAYENNE_SUCCESS; |
jburhenn | 0:d20655cd1f3c | 203 | } |
jburhenn | 0:d20655cd1f3c | 204 | |
jburhenn | 0:d20655cd1f3c | 205 | /** |
jburhenn | 0:d20655cd1f3c | 206 | * Main loop where MQTT code is run. |
jburhenn | 0:d20655cd1f3c | 207 | */ |
jburhenn | 0:d20655cd1f3c | 208 | void loop(void) |
jburhenn | 0:d20655cd1f3c | 209 | { |
jburhenn | 7:78cefe0937ab | 210 | // Start the countdown timer for publishing data every 5 seconds. Change the timeout parameter to publish at a different interval. |
jburhenn | 0:d20655cd1f3c | 211 | MQTTTimer timer(5000); |
jburhenn | 0:d20655cd1f3c | 212 | |
jburhenn | 0:d20655cd1f3c | 213 | while (true) { |
jburhenn | 0:d20655cd1f3c | 214 | // Yield to allow MQTT message processing. |
jburhenn | 0:d20655cd1f3c | 215 | mqttClient.yield(1000); |
jburhenn | 0:d20655cd1f3c | 216 | |
jburhenn | 0:d20655cd1f3c | 217 | // Check that we are still connected, if not, reconnect. |
jburhenn | 0:d20655cd1f3c | 218 | if (!network.connected() || !mqttClient.connected()) { |
jburhenn | 0:d20655cd1f3c | 219 | network.disconnect(); |
jburhenn | 0:d20655cd1f3c | 220 | mqttClient.disconnect(); |
jburhenn | 0:d20655cd1f3c | 221 | printf("Reconnecting\n"); |
jburhenn | 0:d20655cd1f3c | 222 | while (connectClient() != CAYENNE_SUCCESS) { |
jburhenn | 0:d20655cd1f3c | 223 | wait(2); |
jburhenn | 0:d20655cd1f3c | 224 | printf("Reconnect failed, retrying\n"); |
jburhenn | 0:d20655cd1f3c | 225 | } |
jburhenn | 0:d20655cd1f3c | 226 | } |
jburhenn | 0:d20655cd1f3c | 227 | |
jburhenn | 0:d20655cd1f3c | 228 | // Publish some example data every few seconds. This should be changed to send your actual data to Cayenne. |
jburhenn | 0:d20655cd1f3c | 229 | if (timer.expired()) { |
jburhenn | 0:d20655cd1f3c | 230 | int error = 0; |
kapitaninternet | 9:c206c33736fe | 231 | |
kapitaninternet | 9:c206c33736fe | 232 | uint8_t id; |
kapitaninternet | 9:c206c33736fe | 233 | float value1, value2; |
kapitaninternet | 9:c206c33736fe | 234 | char buffer1[32], buffer2[32]; |
kapitaninternet | 9:c206c33736fe | 235 | int32_t axes[3]; |
kapitaninternet | 9:c206c33736fe | 236 | |
kapitaninternet | 9:c206c33736fe | 237 | /* Enable all sensors */ |
kapitaninternet | 9:c206c33736fe | 238 | hum_temp->enable(); |
kapitaninternet | 9:c206c33736fe | 239 | press_temp->enable(); |
kapitaninternet | 9:c206c33736fe | 240 | magnetometer->enable(); |
kapitaninternet | 9:c206c33736fe | 241 | accelerometer->enable(); |
kapitaninternet | 9:c206c33736fe | 242 | acc_gyro->enable_x(); |
kapitaninternet | 9:c206c33736fe | 243 | acc_gyro->enable_g(); |
kapitaninternet | 9:c206c33736fe | 244 | |
kapitaninternet | 9:c206c33736fe | 245 | printf("\r\n--- Starting new run ---\r\n"); |
kapitaninternet | 9:c206c33736fe | 246 | |
kapitaninternet | 9:c206c33736fe | 247 | hum_temp->read_id(&id); |
kapitaninternet | 9:c206c33736fe | 248 | printf("HTS221 humidity & temperature = 0x%X\r\n", id); |
kapitaninternet | 9:c206c33736fe | 249 | press_temp->read_id(&id); |
kapitaninternet | 9:c206c33736fe | 250 | printf("LPS22HB pressure & temperature = 0x%X\r\n", id); |
kapitaninternet | 9:c206c33736fe | 251 | magnetometer->read_id(&id); |
kapitaninternet | 9:c206c33736fe | 252 | printf("LSM303AGR magnetometer = 0x%X\r\n", id); |
kapitaninternet | 9:c206c33736fe | 253 | accelerometer->read_id(&id); |
kapitaninternet | 9:c206c33736fe | 254 | printf("LSM303AGR accelerometer = 0x%X\r\n", id); |
kapitaninternet | 9:c206c33736fe | 255 | acc_gyro->read_id(&id); |
kapitaninternet | 9:c206c33736fe | 256 | printf("LSM6DSL accelerometer & gyroscope = 0x%X\r\n", id); |
kapitaninternet | 9:c206c33736fe | 257 | |
kapitaninternet | 9:c206c33736fe | 258 | printf("\r\n"); |
kapitaninternet | 9:c206c33736fe | 259 | |
kapitaninternet | 9:c206c33736fe | 260 | hum_temp->get_temperature(&value1); |
kapitaninternet | 9:c206c33736fe | 261 | hum_temp->get_humidity(&value2); |
kapitaninternet | 9:c206c33736fe | 262 | printf("HTS221: [temp] %7s C, [hum] %s%%\r\n", print_double(buffer1, value1), print_double(buffer2, value2)); |
kapitaninternet | 9:c206c33736fe | 263 | |
kapitaninternet | 9:c206c33736fe | 264 | press_temp->get_temperature(&value1); |
kapitaninternet | 9:c206c33736fe | 265 | press_temp->get_pressure(&value2); |
kapitaninternet | 9:c206c33736fe | 266 | printf("LPS22HB: [temp] %7s C, [press] %s mbar\r\n", print_double(buffer1, value1), print_double(buffer2, value2)); |
kapitaninternet | 9:c206c33736fe | 267 | |
kapitaninternet | 9:c206c33736fe | 268 | printf("---\r\n"); |
kapitaninternet | 9:c206c33736fe | 269 | |
kapitaninternet | 9:c206c33736fe | 270 | magnetometer->get_m_axes(axes); |
kapitaninternet | 9:c206c33736fe | 271 | printf("LSM303AGR [mag/mgauss]: %6ld, %6ld, %6ld\r\n", axes[0], axes[1], axes[2]); |
kapitaninternet | 9:c206c33736fe | 272 | |
kapitaninternet | 9:c206c33736fe | 273 | accelerometer->get_x_axes(axes); |
kapitaninternet | 9:c206c33736fe | 274 | printf("LSM303AGR [acc/mg]: %6ld, %6ld, %6ld\r\n", axes[0], axes[1], axes[2]); |
kapitaninternet | 9:c206c33736fe | 275 | |
kapitaninternet | 9:c206c33736fe | 276 | acc_gyro->get_x_axes(axes); |
kapitaninternet | 9:c206c33736fe | 277 | printf("LSM6DSL [acc/mg]: %6ld, %6ld, %6ld\r\n", axes[0], axes[1], axes[2]); |
kapitaninternet | 9:c206c33736fe | 278 | |
kapitaninternet | 9:c206c33736fe | 279 | acc_gyro->get_g_axes(axes); |
kapitaninternet | 9:c206c33736fe | 280 | printf("LSM6DSL [gyro/mdps]: %6ld, %6ld, %6ld\r\n", axes[0], axes[1], axes[2]); |
kapitaninternet | 9:c206c33736fe | 281 | |
kapitaninternet | 9:c206c33736fe | 282 | |
kapitaninternet | 9:c206c33736fe | 283 | |
kapitaninternet | 9:c206c33736fe | 284 | if ((error = mqttClient.publishData(DATA_TOPIC, 1, TYPE_TEMPERATURE, UNIT_CELSIUS, value1)) != CAYENNE_SUCCESS) { |
jburhenn | 0:d20655cd1f3c | 285 | printf("Publish temperature failed, error: %d\n", error); |
jburhenn | 0:d20655cd1f3c | 286 | } |
kapitaninternet | 9:c206c33736fe | 287 | |
kapitaninternet | 9:c206c33736fe | 288 | |
kapitaninternet | 9:c206c33736fe | 289 | if ((error = mqttClient.publishData(DATA_TOPIC, 2, TYPE_BAROMETRIC_PRESSURE, UNIT_HECTOPASCAL, value2)) != CAYENNE_SUCCESS) { |
jburhenn | 0:d20655cd1f3c | 290 | printf("Publish barometric pressure failed, error: %d\n", error); |
jburhenn | 0:d20655cd1f3c | 291 | } |
kapitaninternet | 9:c206c33736fe | 292 | // Restart the countdown timer for publishing data every 2 seconds. Change the timeout parameter to publish at a different interval. |
kapitaninternet | 9:c206c33736fe | 293 | timer.countdown_ms(2000); |
jburhenn | 0:d20655cd1f3c | 294 | } |
jburhenn | 0:d20655cd1f3c | 295 | } |
jburhenn | 0:d20655cd1f3c | 296 | } |
jburhenn | 0:d20655cd1f3c | 297 | |
kapitaninternet | 9:c206c33736fe | 298 | |
kapitaninternet | 9:c206c33736fe | 299 | |
kapitaninternet | 9:c206c33736fe | 300 | |
kapitaninternet | 9:c206c33736fe | 301 | |
jburhenn | 0:d20655cd1f3c | 302 | /** |
jburhenn | 0:d20655cd1f3c | 303 | * Main function. |
jburhenn | 0:d20655cd1f3c | 304 | */ |
jburhenn | 0:d20655cd1f3c | 305 | int main() |
jburhenn | 0:d20655cd1f3c | 306 | { |
kapitaninternet | 9:c206c33736fe | 307 | printf("Initializing interface\n"); |
jburhenn | 0:d20655cd1f3c | 308 | interface.connect(ssid, wifiPassword, NSAPI_SECURITY_WPA2); |
jburhenn | 0:d20655cd1f3c | 309 | |
jburhenn | 0:d20655cd1f3c | 310 | // Set the default function that receives Cayenne messages. |
jburhenn | 0:d20655cd1f3c | 311 | mqttClient.setDefaultMessageHandler(messageArrived); |
jburhenn | 0:d20655cd1f3c | 312 | |
jburhenn | 0:d20655cd1f3c | 313 | // Connect to Cayenne. |
jburhenn | 0:d20655cd1f3c | 314 | if (connectClient() == CAYENNE_SUCCESS) { |
jburhenn | 0:d20655cd1f3c | 315 | // Run main loop. |
jburhenn | 0:d20655cd1f3c | 316 | loop(); |
jburhenn | 0:d20655cd1f3c | 317 | } |
jburhenn | 0:d20655cd1f3c | 318 | else { |
jburhenn | 0:d20655cd1f3c | 319 | printf("Connection failed, exiting\n"); |
jburhenn | 0:d20655cd1f3c | 320 | } |
jburhenn | 0:d20655cd1f3c | 321 | |
jburhenn | 0:d20655cd1f3c | 322 | if (mqttClient.connected()) |
jburhenn | 0:d20655cd1f3c | 323 | mqttClient.disconnect(); |
jburhenn | 0:d20655cd1f3c | 324 | if (network.connected()) |
jburhenn | 0:d20655cd1f3c | 325 | network.disconnect(); |
kapitaninternet | 9:c206c33736fe | 326 | return 0; |
jburhenn | 0:d20655cd1f3c | 327 | |
jburhenn | 0:d20655cd1f3c | 328 | } |
jburhenn | 0:d20655cd1f3c | 329 | |
kapitaninternet | 9:c206c33736fe | 330 | |
kapitaninternet | 9:c206c33736fe | 331 |