Template coding for ST IoT Challenge 2019
Dependencies: Cayenne-MQTT-mbed mbed X_NUCLEO_IKS01A2 X_NUCLEO_IDW01M1v2 NetworkSocketAPI
main.cpp@22:22570ebcc4f2, 2019-03-12 (annotated)
- Committer:
- stiotchallenge
- Date:
- Tue Mar 12 03:46:52 2019 +0000
- Revision:
- 22:22570ebcc4f2
- Parent:
- 21:101560c87a89
Coding template for STIoTChallenge2019
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
cparata | 0:69566eea0fba | 1 | /* Includes */ |
cparata | 0:69566eea0fba | 2 | #include "mbed.h" |
davide.aliprandi@st.com | 13:fc873da5b445 | 3 | #include "XNucleoIKS01A2.h" |
stiotchallenge | 18:aedf981aa752 | 4 | #include "MQTTTimer.h" |
stiotchallenge | 18:aedf981aa752 | 5 | #include "CayenneMQTTClient.h" |
stiotchallenge | 18:aedf981aa752 | 6 | #include "MQTTNetworkIDW01M1.h" |
stiotchallenge | 18:aedf981aa752 | 7 | #include "SpwfInterface.h" |
cparata | 0:69566eea0fba | 8 | |
cparata | 0:69566eea0fba | 9 | /* Instantiate the expansion board */ |
davide.aliprandi@st.com | 13:fc873da5b445 | 10 | static XNucleoIKS01A2 *mems_expansion_board = XNucleoIKS01A2::instance(D14, D15, D4, D5); |
cparata | 0:69566eea0fba | 11 | |
cparata | 0:69566eea0fba | 12 | /* Retrieve the composing elements of the expansion board */ |
davide.aliprandi@st.com | 13:fc873da5b445 | 13 | static LSM303AGRMagSensor *magnetometer = mems_expansion_board->magnetometer; |
cparata | 0:69566eea0fba | 14 | static HTS221Sensor *hum_temp = mems_expansion_board->ht_sensor; |
cparata | 0:69566eea0fba | 15 | static LPS22HBSensor *press_temp = mems_expansion_board->pt_sensor; |
cparata | 0:69566eea0fba | 16 | static LSM6DSLSensor *acc_gyro = mems_expansion_board->acc_gyro; |
davide.aliprandi@st.com | 13:fc873da5b445 | 17 | static LSM303AGRAccSensor *accelerometer = mems_expansion_board->accelerometer; |
cparata | 0:69566eea0fba | 18 | |
stiotchallenge | 18:aedf981aa752 | 19 | // WiFi network info. |
stiotchallenge | 22:22570ebcc4f2 | 20 | char* ssid = "iPhone"; |
stiotchallenge | 22:22570ebcc4f2 | 21 | char* wifiPassword = "abcd1234"; |
stiotchallenge | 18:aedf981aa752 | 22 | |
stiotchallenge | 18:aedf981aa752 | 23 | // Cayenne authentication info. This should be obtained from the Cayenne Dashboard. |
stiotchallenge | 18:aedf981aa752 | 24 | char* username = "4f3fbcb0-3796-11e9-ad96-c15442ccb423"; |
stiotchallenge | 18:aedf981aa752 | 25 | char* password = "9e099f3d9aaedd7b76ca94044c6bb488c3999e3c"; |
stiotchallenge | 20:51804ecf98a1 | 26 | char* clientID = "4fb9dca0-3f13-11e9-a6b5-e30ec853fbf2"; |
stiotchallenge | 18:aedf981aa752 | 27 | |
stiotchallenge | 18:aedf981aa752 | 28 | SpwfSAInterface interface(D8, D2); // TX, RX |
stiotchallenge | 18:aedf981aa752 | 29 | MQTTNetwork<SpwfSAInterface> network(interface); |
stiotchallenge | 18:aedf981aa752 | 30 | CayenneMQTT::MQTTClient<MQTTNetwork<SpwfSAInterface>, MQTTTimer> mqttClient(network, username, password, clientID); |
stiotchallenge | 18:aedf981aa752 | 31 | |
stiotchallenge | 20:51804ecf98a1 | 32 | /***********************************************************/ |
stiotchallenge | 20:51804ecf98a1 | 33 | /* External sensor and output/actuators declared here */ |
stiotchallenge | 20:51804ecf98a1 | 34 | /***********************************************************/ |
stiotchallenge | 18:aedf981aa752 | 35 | DigitalOut led1(LED1); |
stiotchallenge | 22:22570ebcc4f2 | 36 | //DigitalOut ledy(D1); |
stiotchallenge | 18:aedf981aa752 | 37 | |
cparata | 0:69566eea0fba | 38 | /* Helper function for printing floats & doubles */ |
davide.aliprandi@st.com | 13:fc873da5b445 | 39 | static char *print_double(char* str, double v, int decimalDigits=2) |
cparata | 0:69566eea0fba | 40 | { |
cparata | 0:69566eea0fba | 41 | int i = 1; |
cparata | 0:69566eea0fba | 42 | int intPart, fractPart; |
cparata | 0:69566eea0fba | 43 | int len; |
cparata | 0:69566eea0fba | 44 | char *ptr; |
cparata | 0:69566eea0fba | 45 | |
cparata | 0:69566eea0fba | 46 | /* prepare decimal digits multiplicator */ |
cparata | 0:69566eea0fba | 47 | for (;decimalDigits!=0; i*=10, decimalDigits--); |
cparata | 0:69566eea0fba | 48 | |
cparata | 0:69566eea0fba | 49 | /* calculate integer & fractinal parts */ |
cparata | 0:69566eea0fba | 50 | intPart = (int)v; |
cparata | 0:69566eea0fba | 51 | fractPart = (int)((v-(double)(int)v)*i); |
cparata | 0:69566eea0fba | 52 | |
cparata | 0:69566eea0fba | 53 | /* fill in integer part */ |
cparata | 0:69566eea0fba | 54 | sprintf(str, "%i.", intPart); |
cparata | 0:69566eea0fba | 55 | |
cparata | 0:69566eea0fba | 56 | /* prepare fill in of fractional part */ |
cparata | 0:69566eea0fba | 57 | len = strlen(str); |
cparata | 0:69566eea0fba | 58 | ptr = &str[len]; |
cparata | 0:69566eea0fba | 59 | |
cparata | 0:69566eea0fba | 60 | /* fill in leading fractional zeros */ |
cparata | 0:69566eea0fba | 61 | for (i/=10;i>1; i/=10, ptr++) { |
davide.aliprandi@st.com | 13:fc873da5b445 | 62 | if (fractPart >= i) { |
davide.aliprandi@st.com | 13:fc873da5b445 | 63 | break; |
davide.aliprandi@st.com | 13:fc873da5b445 | 64 | } |
cparata | 0:69566eea0fba | 65 | *ptr = '0'; |
cparata | 0:69566eea0fba | 66 | } |
cparata | 0:69566eea0fba | 67 | |
cparata | 0:69566eea0fba | 68 | /* fill in (rest of) fractional part */ |
cparata | 0:69566eea0fba | 69 | sprintf(ptr, "%i", fractPart); |
cparata | 0:69566eea0fba | 70 | |
cparata | 0:69566eea0fba | 71 | return str; |
cparata | 0:69566eea0fba | 72 | } |
cparata | 0:69566eea0fba | 73 | |
stiotchallenge | 18:aedf981aa752 | 74 | /** |
stiotchallenge | 18:aedf981aa752 | 75 | * Print the message info. |
stiotchallenge | 18:aedf981aa752 | 76 | * @param[in] message The message received from the Cayenne server. |
stiotchallenge | 18:aedf981aa752 | 77 | */ |
stiotchallenge | 18:aedf981aa752 | 78 | void outputMessage(CayenneMQTT::MessageData& message) |
stiotchallenge | 18:aedf981aa752 | 79 | { |
stiotchallenge | 18:aedf981aa752 | 80 | switch (message.topic) { |
stiotchallenge | 18:aedf981aa752 | 81 | case COMMAND_TOPIC: |
stiotchallenge | 18:aedf981aa752 | 82 | printf("topic=Command"); |
stiotchallenge | 18:aedf981aa752 | 83 | break; |
stiotchallenge | 18:aedf981aa752 | 84 | case CONFIG_TOPIC: |
stiotchallenge | 18:aedf981aa752 | 85 | printf("topic=Config"); |
stiotchallenge | 18:aedf981aa752 | 86 | break; |
stiotchallenge | 18:aedf981aa752 | 87 | default: |
stiotchallenge | 18:aedf981aa752 | 88 | printf("topic=%d", message.topic); |
stiotchallenge | 18:aedf981aa752 | 89 | break; |
stiotchallenge | 18:aedf981aa752 | 90 | } |
stiotchallenge | 18:aedf981aa752 | 91 | printf(" channel=%d", message.channel); |
stiotchallenge | 18:aedf981aa752 | 92 | if (message.clientID) { |
stiotchallenge | 18:aedf981aa752 | 93 | printf(" clientID=%s", message.clientID); |
stiotchallenge | 18:aedf981aa752 | 94 | } |
stiotchallenge | 18:aedf981aa752 | 95 | if (message.type) { |
stiotchallenge | 18:aedf981aa752 | 96 | printf(" type=%s", message.type); |
stiotchallenge | 18:aedf981aa752 | 97 | } |
stiotchallenge | 18:aedf981aa752 | 98 | for (size_t i = 0; i < message.valueCount; ++i) { |
stiotchallenge | 18:aedf981aa752 | 99 | if (message.getValue(i)) { |
stiotchallenge | 18:aedf981aa752 | 100 | printf(" value=%s", message.getValue(i)); |
stiotchallenge | 18:aedf981aa752 | 101 | } |
stiotchallenge | 18:aedf981aa752 | 102 | if (message.getUnit(i)) { |
stiotchallenge | 18:aedf981aa752 | 103 | printf(" unit=%s", message.getUnit(i)); |
stiotchallenge | 18:aedf981aa752 | 104 | } |
stiotchallenge | 18:aedf981aa752 | 105 | } |
stiotchallenge | 18:aedf981aa752 | 106 | if (message.id) { |
stiotchallenge | 18:aedf981aa752 | 107 | printf(" id=%s", message.id); |
stiotchallenge | 18:aedf981aa752 | 108 | } |
stiotchallenge | 18:aedf981aa752 | 109 | printf("\n"); |
stiotchallenge | 18:aedf981aa752 | 110 | } |
stiotchallenge | 18:aedf981aa752 | 111 | |
stiotchallenge | 18:aedf981aa752 | 112 | /** |
stiotchallenge | 18:aedf981aa752 | 113 | * Handle messages received from the Cayenne server. |
stiotchallenge | 18:aedf981aa752 | 114 | * @param[in] message The message received from the Cayenne server. |
stiotchallenge | 18:aedf981aa752 | 115 | */ |
stiotchallenge | 18:aedf981aa752 | 116 | void messageArrived(CayenneMQTT::MessageData& message) |
stiotchallenge | 18:aedf981aa752 | 117 | { |
stiotchallenge | 18:aedf981aa752 | 118 | int error = 0; |
stiotchallenge | 18:aedf981aa752 | 119 | // Add code to process the message. Here we just ouput the message data. |
stiotchallenge | 18:aedf981aa752 | 120 | outputMessage(message); |
stiotchallenge | 18:aedf981aa752 | 121 | |
stiotchallenge | 18:aedf981aa752 | 122 | if (message.topic == COMMAND_TOPIC) { |
stiotchallenge | 20:51804ecf98a1 | 123 | switch(message.channel) { /****************************************************/ |
stiotchallenge | 20:51804ecf98a1 | 124 | case 0: /* the channel number for input */ |
stiotchallenge | 20:51804ecf98a1 | 125 | // Set the onboard LED state /* */ |
stiotchallenge | 20:51804ecf98a1 | 126 | led1 = atoi(message.getValue()); /*can add other function after received input signal*/ |
stiotchallenge | 20:51804ecf98a1 | 127 | // Publish the updated LED state /****************************************************/ |
stiotchallenge | 18:aedf981aa752 | 128 | if ((error = mqttClient.publishData(DATA_TOPIC, message.channel, NULL, NULL, message.getValue())) != CAYENNE_SUCCESS) { |
stiotchallenge | 18:aedf981aa752 | 129 | printf("Publish LED state failure, error: %d\n", error); |
stiotchallenge | 18:aedf981aa752 | 130 | } |
stiotchallenge | 18:aedf981aa752 | 131 | break; |
stiotchallenge | 18:aedf981aa752 | 132 | } |
stiotchallenge | 18:aedf981aa752 | 133 | |
stiotchallenge | 18:aedf981aa752 | 134 | // If this is a command message we publish a response. Here we are just sending a default 'OK' response. |
stiotchallenge | 18:aedf981aa752 | 135 | // An error response should be sent if there are issues processing the message. |
stiotchallenge | 18:aedf981aa752 | 136 | if ((error = mqttClient.publishResponse(message.id, NULL, message.clientID)) != CAYENNE_SUCCESS) { |
stiotchallenge | 18:aedf981aa752 | 137 | printf("Response failure, error: %d\n", error); |
stiotchallenge | 18:aedf981aa752 | 138 | } |
stiotchallenge | 18:aedf981aa752 | 139 | } |
stiotchallenge | 18:aedf981aa752 | 140 | } |
stiotchallenge | 18:aedf981aa752 | 141 | |
stiotchallenge | 18:aedf981aa752 | 142 | /** |
stiotchallenge | 18:aedf981aa752 | 143 | * Connect to the Cayenne server. |
stiotchallenge | 18:aedf981aa752 | 144 | * @return Returns CAYENNE_SUCCESS if the connection succeeds, or an error code otherwise. |
stiotchallenge | 18:aedf981aa752 | 145 | */ |
stiotchallenge | 18:aedf981aa752 | 146 | int connectClient(void) |
stiotchallenge | 18:aedf981aa752 | 147 | { |
stiotchallenge | 18:aedf981aa752 | 148 | int error = 0; |
stiotchallenge | 18:aedf981aa752 | 149 | // Connect to the server. |
stiotchallenge | 18:aedf981aa752 | 150 | printf("Connecting to %s:%d\n", CAYENNE_DOMAIN, CAYENNE_PORT); |
stiotchallenge | 18:aedf981aa752 | 151 | while ((error = network.connect(CAYENNE_DOMAIN, CAYENNE_PORT)) != 0) { |
stiotchallenge | 18:aedf981aa752 | 152 | printf("TCP connect failed, error: %d\n", error); |
stiotchallenge | 18:aedf981aa752 | 153 | wait(2); |
stiotchallenge | 18:aedf981aa752 | 154 | } |
stiotchallenge | 18:aedf981aa752 | 155 | |
stiotchallenge | 18:aedf981aa752 | 156 | if ((error = mqttClient.connect()) != MQTT::SUCCESS) { |
stiotchallenge | 18:aedf981aa752 | 157 | printf("MQTT connect failed, error: %d\n", error); |
stiotchallenge | 18:aedf981aa752 | 158 | return error; |
stiotchallenge | 18:aedf981aa752 | 159 | } |
stiotchallenge | 18:aedf981aa752 | 160 | printf("Connected\n"); |
stiotchallenge | 18:aedf981aa752 | 161 | |
stiotchallenge | 18:aedf981aa752 | 162 | // Subscribe to required topics. |
stiotchallenge | 18:aedf981aa752 | 163 | if ((error = mqttClient.subscribe(COMMAND_TOPIC, CAYENNE_ALL_CHANNELS)) != CAYENNE_SUCCESS) { |
stiotchallenge | 18:aedf981aa752 | 164 | printf("Subscription to Command topic failed, error: %d\n", error); |
stiotchallenge | 18:aedf981aa752 | 165 | } |
stiotchallenge | 18:aedf981aa752 | 166 | if ((error = mqttClient.subscribe(CONFIG_TOPIC, CAYENNE_ALL_CHANNELS)) != CAYENNE_SUCCESS) { |
stiotchallenge | 18:aedf981aa752 | 167 | printf("Subscription to Config topic failed, error:%d\n", error); |
stiotchallenge | 18:aedf981aa752 | 168 | } |
stiotchallenge | 18:aedf981aa752 | 169 | |
stiotchallenge | 18:aedf981aa752 | 170 | // 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. |
stiotchallenge | 18:aedf981aa752 | 171 | mqttClient.publishData(SYS_VERSION_TOPIC, CAYENNE_NO_CHANNEL, NULL, NULL, CAYENNE_VERSION); |
stiotchallenge | 18:aedf981aa752 | 172 | mqttClient.publishData(SYS_MODEL_TOPIC, CAYENNE_NO_CHANNEL, NULL, NULL, "mbedDevice"); |
stiotchallenge | 18:aedf981aa752 | 173 | //mqttClient.publishData(SYS_CPU_MODEL_TOPIC, CAYENNE_NO_CHANNEL, NULL, NULL, "CPU Model"); |
stiotchallenge | 18:aedf981aa752 | 174 | //mqttClient.publishData(SYS_CPU_SPEED_TOPIC, CAYENNE_NO_CHANNEL, NULL, NULL, "1000000000"); |
stiotchallenge | 18:aedf981aa752 | 175 | |
stiotchallenge | 18:aedf981aa752 | 176 | return CAYENNE_SUCCESS; |
stiotchallenge | 18:aedf981aa752 | 177 | } |
stiotchallenge | 18:aedf981aa752 | 178 | |
cparata | 0:69566eea0fba | 179 | /* Simple main function */ |
cparata | 0:69566eea0fba | 180 | int main() { |
stiotchallenge | 18:aedf981aa752 | 181 | uint8_t id; |
stiotchallenge | 18:aedf981aa752 | 182 | float value1, value2, value3, value4; |
stiotchallenge | 18:aedf981aa752 | 183 | char buffer1[32], buffer2[32], buffer3[32], buffer4[32]; |
stiotchallenge | 18:aedf981aa752 | 184 | int32_t axes[3]; |
cparata | 0:69566eea0fba | 185 | |
stiotchallenge | 18:aedf981aa752 | 186 | /* Enable all sensors */ |
stiotchallenge | 18:aedf981aa752 | 187 | hum_temp->enable(); |
stiotchallenge | 18:aedf981aa752 | 188 | press_temp->enable(); |
stiotchallenge | 18:aedf981aa752 | 189 | magnetometer->enable(); |
stiotchallenge | 18:aedf981aa752 | 190 | accelerometer->enable(); |
stiotchallenge | 18:aedf981aa752 | 191 | acc_gyro->enable_x(); |
stiotchallenge | 18:aedf981aa752 | 192 | acc_gyro->enable_g(); |
cparata | 0:69566eea0fba | 193 | |
stiotchallenge | 18:aedf981aa752 | 194 | printf("\r\n--- Starting new run ---\r\n"); |
cparata | 0:69566eea0fba | 195 | |
stiotchallenge | 18:aedf981aa752 | 196 | hum_temp->read_id(&id); |
stiotchallenge | 18:aedf981aa752 | 197 | printf("HTS221 humidity & temperature = 0x%X\r\n", id); |
stiotchallenge | 18:aedf981aa752 | 198 | press_temp->read_id(&id); |
stiotchallenge | 18:aedf981aa752 | 199 | printf("LPS22HB pressure & temperature = 0x%X\r\n", id); |
stiotchallenge | 18:aedf981aa752 | 200 | magnetometer->read_id(&id); |
stiotchallenge | 18:aedf981aa752 | 201 | printf("LSM303AGR magnetometer = 0x%X\r\n", id); |
stiotchallenge | 18:aedf981aa752 | 202 | accelerometer->read_id(&id); |
stiotchallenge | 18:aedf981aa752 | 203 | printf("LSM303AGR accelerometer = 0x%X\r\n", id); |
stiotchallenge | 18:aedf981aa752 | 204 | acc_gyro->read_id(&id); |
stiotchallenge | 18:aedf981aa752 | 205 | printf("LSM6DSL accelerometer & gyroscope = 0x%X\r\n", id); |
cparata | 0:69566eea0fba | 206 | |
stiotchallenge | 18:aedf981aa752 | 207 | // Initialize the network interface. |
stiotchallenge | 18:aedf981aa752 | 208 | printf("Initializing interface\n"); |
stiotchallenge | 18:aedf981aa752 | 209 | interface.connect(ssid, wifiPassword, NSAPI_SECURITY_WPA2); |
stiotchallenge | 18:aedf981aa752 | 210 | |
stiotchallenge | 18:aedf981aa752 | 211 | // Set the default function that receives Cayenne messages. |
stiotchallenge | 18:aedf981aa752 | 212 | mqttClient.setDefaultMessageHandler(messageArrived); |
stiotchallenge | 18:aedf981aa752 | 213 | |
stiotchallenge | 18:aedf981aa752 | 214 | // Connect to Cayenne. |
stiotchallenge | 18:aedf981aa752 | 215 | if (connectClient() == CAYENNE_SUCCESS) { |
stiotchallenge | 18:aedf981aa752 | 216 | // Start the countdown timer for publishing data every 5 seconds. Change the timeout parameter to publish at a different interval. |
stiotchallenge | 18:aedf981aa752 | 217 | MQTTTimer timer(5000); |
stiotchallenge | 18:aedf981aa752 | 218 | |
stiotchallenge | 18:aedf981aa752 | 219 | while (true) { |
stiotchallenge | 22:22570ebcc4f2 | 220 | |
stiotchallenge | 18:aedf981aa752 | 221 | // Yield to allow MQTT message processing. |
stiotchallenge | 18:aedf981aa752 | 222 | mqttClient.yield(1000); |
cparata | 0:69566eea0fba | 223 | |
stiotchallenge | 18:aedf981aa752 | 224 | // Check that we are still connected, if not, reconnect. |
stiotchallenge | 18:aedf981aa752 | 225 | if (!network.connected() || !mqttClient.connected()) { |
stiotchallenge | 18:aedf981aa752 | 226 | network.disconnect(); |
stiotchallenge | 18:aedf981aa752 | 227 | mqttClient.disconnect(); |
stiotchallenge | 18:aedf981aa752 | 228 | printf("Reconnecting\n"); |
stiotchallenge | 18:aedf981aa752 | 229 | while (connectClient() != CAYENNE_SUCCESS) { |
stiotchallenge | 18:aedf981aa752 | 230 | wait(2); |
stiotchallenge | 18:aedf981aa752 | 231 | printf("Reconnect failed, retrying\n"); |
stiotchallenge | 18:aedf981aa752 | 232 | } |
stiotchallenge | 18:aedf981aa752 | 233 | } |
stiotchallenge | 18:aedf981aa752 | 234 | |
stiotchallenge | 18:aedf981aa752 | 235 | printf("\r\n"); |
stiotchallenge | 18:aedf981aa752 | 236 | |
stiotchallenge | 18:aedf981aa752 | 237 | hum_temp->get_temperature(&value1); |
stiotchallenge | 18:aedf981aa752 | 238 | hum_temp->get_humidity(&value2); |
stiotchallenge | 18:aedf981aa752 | 239 | printf("HTS221: [temp] %7s C, [hum] %s%%\r\n", print_double(buffer1, value1), print_double(buffer2, value2)); |
cparata | 0:69566eea0fba | 240 | |
stiotchallenge | 18:aedf981aa752 | 241 | press_temp->get_temperature(&value3); |
stiotchallenge | 18:aedf981aa752 | 242 | press_temp->get_pressure(&value4); |
stiotchallenge | 18:aedf981aa752 | 243 | printf("LPS22HB: [temp] %7s C, [press] %s mbar\r\n", print_double(buffer1, value3), print_double(buffer2, value4)); |
cparata | 0:69566eea0fba | 244 | |
stiotchallenge | 18:aedf981aa752 | 245 | printf("---\r\n"); |
cparata | 0:69566eea0fba | 246 | |
stiotchallenge | 18:aedf981aa752 | 247 | magnetometer->get_m_axes(axes); |
stiotchallenge | 18:aedf981aa752 | 248 | printf("LSM303AGR [mag/mgauss]: %6ld, %6ld, %6ld\r\n", axes[0], axes[1], axes[2]); |
cparata | 0:69566eea0fba | 249 | |
stiotchallenge | 18:aedf981aa752 | 250 | acc_gyro->get_x_axes(axes); |
stiotchallenge | 18:aedf981aa752 | 251 | printf("LSM6DSL [acc/mg]: %6ld, %6ld, %6ld\r\n", axes[0], axes[1], axes[2]); |
cparata | 0:69566eea0fba | 252 | |
stiotchallenge | 18:aedf981aa752 | 253 | accelerometer->get_x_axes(axes); |
stiotchallenge | 18:aedf981aa752 | 254 | printf("LSM303AGR [acc/mg]: %6ld, %6ld, %6ld\r\n", axes[0], axes[1], axes[2]); |
stiotchallenge | 18:aedf981aa752 | 255 | |
stiotchallenge | 18:aedf981aa752 | 256 | acc_gyro->get_g_axes(axes); |
stiotchallenge | 18:aedf981aa752 | 257 | printf("LSM6DSL [gyro/mdps]: %6ld, %6ld, %6ld\r\n", axes[0], axes[1], axes[2]); |
stiotchallenge | 18:aedf981aa752 | 258 | |
stiotchallenge | 18:aedf981aa752 | 259 | wait(1.5); |
stiotchallenge | 20:51804ecf98a1 | 260 | |
stiotchallenge | 18:aedf981aa752 | 261 | |
stiotchallenge | 18:aedf981aa752 | 262 | // Publish some example data every few seconds. This should be changed to send your actual data to Cayenne. |
stiotchallenge | 18:aedf981aa752 | 263 | if (timer.expired()) { |
stiotchallenge | 20:51804ecf98a1 | 264 | int error = 0; /************************/ |
stiotchallenge | 20:51804ecf98a1 | 265 | if ((error = mqttClient.publishData(DATA_TOPIC, 1, TYPE_TEMPERATURE, UNIT_CELSIUS, value1)) != CAYENNE_SUCCESS) { /* duplicate the if {} */ |
stiotchallenge | 20:51804ecf98a1 | 266 | printf("Publish temperature failed, error: %d\n", error); /* for more channel */ |
stiotchallenge | 20:51804ecf98a1 | 267 | } /************************/ |
stiotchallenge | 18:aedf981aa752 | 268 | if ((error = mqttClient.publishData(DATA_TOPIC, 2, TYPE_BAROMETRIC_PRESSURE, UNIT_PASCAL, value4)) != CAYENNE_SUCCESS) { |
stiotchallenge | 20:51804ecf98a1 | 269 | printf("Publish barometric pressure failed, error: %d\n", error); |
stiotchallenge | 18:aedf981aa752 | 270 | } |
stiotchallenge | 18:aedf981aa752 | 271 | if ((error = mqttClient.publishData(DATA_TOPIC, 3, TYPE_PROXIMITY, UNIT_METER, axes[1])) != CAYENNE_SUCCESS) { |
stiotchallenge | 20:51804ecf98a1 | 272 | printf("Publish proximity failed, error: %d\n", error); |
stiotchallenge | 18:aedf981aa752 | 273 | } |
stiotchallenge | 18:aedf981aa752 | 274 | // Restart the countdown timer for publishing data every 5 seconds. Change the timeout parameter to publish at a different interval. |
stiotchallenge | 18:aedf981aa752 | 275 | timer.countdown_ms(5000); |
stiotchallenge | 18:aedf981aa752 | 276 | } |
stiotchallenge | 18:aedf981aa752 | 277 | } |
stiotchallenge | 18:aedf981aa752 | 278 | } |
stiotchallenge | 18:aedf981aa752 | 279 | else { |
stiotchallenge | 18:aedf981aa752 | 280 | printf("Connection failed, exiting\n"); |
stiotchallenge | 18:aedf981aa752 | 281 | } |
cparata | 0:69566eea0fba | 282 | |
stiotchallenge | 18:aedf981aa752 | 283 | if (mqttClient.connected()) |
stiotchallenge | 18:aedf981aa752 | 284 | mqttClient.disconnect(); |
stiotchallenge | 18:aedf981aa752 | 285 | if (network.connected()) |
stiotchallenge | 18:aedf981aa752 | 286 | network.disconnect(); |
cparata | 0:69566eea0fba | 287 | } |