iot_water_monitor_v2
Dependencies: easy-connect-v16 Watchdog FP MQTTPacket RecordType-v-16 watersenor_and_temp_code
Simple-MQTT/SimpleMQTT.h@31:0f7ea3981668, 2018-01-08 (annotated)
- Committer:
- Duy Tran@DESKTOP-0RPIPEQ
- Date:
- Mon Jan 08 22:09:56 2018 +0700
- Revision:
- 31:0f7ea3981668
- Parent:
- 30:e49b8e99db65
- Child:
- 32:8226837c56ae
version 2.0: add command execution
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
DuyLionTran | 30:e49b8e99db65 | 1 | #ifndef __SIMPLEMQTT_H__ |
DuyLionTran | 30:e49b8e99db65 | 2 | #define __SIMPLEMQTT_H__ |
DuyLionTran | 30:e49b8e99db65 | 3 | |
DuyLionTran | 30:e49b8e99db65 | 4 | /*************************************************************** |
DuyLionTran | 30:e49b8e99db65 | 5 | * Includes |
DuyLionTran | 30:e49b8e99db65 | 6 | ***************************************************************/ |
DuyLionTran | 30:e49b8e99db65 | 7 | #include "easy-connect.h" |
DuyLionTran | 30:e49b8e99db65 | 8 | #include "MQTTClient.h" |
DuyLionTran | 30:e49b8e99db65 | 9 | #include "NDefLib/NDefNfcTag.h" |
DuyLionTran | 30:e49b8e99db65 | 10 | #include "NDefLib/RecordType/RecordURI.h" |
DuyLionTran | 30:e49b8e99db65 | 11 | #include "MQTTNetwork.h" |
DuyLionTran | 30:e49b8e99db65 | 12 | #include "MQTTmbed.h" |
DuyLionTran | 30:e49b8e99db65 | 13 | |
DuyLionTran | 30:e49b8e99db65 | 14 | #include "Json.h" |
Duy Tran@DESKTOP-0RPIPEQ | 31:0f7ea3981668 | 15 | #include "CommandExecution.h" |
DuyLionTran | 30:e49b8e99db65 | 16 | /*************************************************************** |
DuyLionTran | 30:e49b8e99db65 | 17 | * Definitions |
DuyLionTran | 30:e49b8e99db65 | 18 | ***************************************************************/ |
DuyLionTran | 30:e49b8e99db65 | 19 | // Configuration values needed to connect to IBM IoT Cloud |
DuyLionTran | 30:e49b8e99db65 | 20 | #define ORG MQTT_ORG_ID // connect to ORG.internetofthings.ibmcloud.com/ For a registered connection, replace with your org |
DuyLionTran | 30:e49b8e99db65 | 21 | #define ID MQTT_DEVICE_ID // For a registered connection is your device id |
DuyLionTran | 30:e49b8e99db65 | 22 | #define AUTH_TOKEN MQTT_DEVICE_PASSWORD // For a registered connection is a device auth-token |
DuyLionTran | 30:e49b8e99db65 | 23 | #define DEFAULT_TYPE_NAME MQTT_DEVICE_TYPE // For a registered connection is device type |
DuyLionTran | 30:e49b8e99db65 | 24 | #define AUTH_METHOD MQTT_USERNAME |
DuyLionTran | 30:e49b8e99db65 | 25 | |
DuyLionTran | 30:e49b8e99db65 | 26 | #define TYPE DEFAULT_TYPE_NAME // For a registered connection, replace with your type |
DuyLionTran | 30:e49b8e99db65 | 27 | #define IBM_IOT_PORT MQTT_PORT |
DuyLionTran | 30:e49b8e99db65 | 28 | |
DuyLionTran | 30:e49b8e99db65 | 29 | #define MQTT_MAX_PACKET_SIZE 400 |
DuyLionTran | 30:e49b8e99db65 | 30 | #define MQTT_MAX_PAYLOAD_SIZE 300 |
DuyLionTran | 30:e49b8e99db65 | 31 | |
DuyLionTran | 30:e49b8e99db65 | 32 | /*************************************************************** |
DuyLionTran | 30:e49b8e99db65 | 33 | * Variables |
DuyLionTran | 30:e49b8e99db65 | 34 | ***************************************************************/ |
DuyLionTran | 30:e49b8e99db65 | 35 | typedef enum { |
DuyLionTran | 30:e49b8e99db65 | 36 | ADC_VALUE = 0, |
DuyLionTran | 30:e49b8e99db65 | 37 | SENSOR_VALUE, |
DuyLionTran | 30:e49b8e99db65 | 38 | RELAY_STATE, |
DuyLionTran | 30:e49b8e99db65 | 39 | CONFIG_VALUE |
DuyLionTran | 30:e49b8e99db65 | 40 | } UploadType; |
DuyLionTran | 30:e49b8e99db65 | 41 | |
DuyLionTran | 30:e49b8e99db65 | 42 | struct UploadValue { |
DuyLionTran | 30:e49b8e99db65 | 43 | float ADC_PHVal; |
DuyLionTran | 30:e49b8e99db65 | 44 | float ADC_DOVal; |
DuyLionTran | 30:e49b8e99db65 | 45 | |
DuyLionTran | 30:e49b8e99db65 | 46 | int RELAY_State_1; |
DuyLionTran | 30:e49b8e99db65 | 47 | int RELAY_State_2; |
DuyLionTran | 30:e49b8e99db65 | 48 | |
DuyLionTran | 30:e49b8e99db65 | 49 | uint8_t CONFIG_Mode; |
DuyLionTran | 30:e49b8e99db65 | 50 | uint8_t CONFIG_MinOxi; |
DuyLionTran | 30:e49b8e99db65 | 51 | uint8_t CONFIG_MaxOxi; |
DuyLionTran | 30:e49b8e99db65 | 52 | uint16_t CONFIG_UploadInterval; |
DuyLionTran | 30:e49b8e99db65 | 53 | } UploadValue; |
DuyLionTran | 30:e49b8e99db65 | 54 | |
DuyLionTran | 30:e49b8e99db65 | 55 | char *projectName = "WaterMonitor"; |
DuyLionTran | 30:e49b8e99db65 | 56 | static char id[30] = ID; // mac without colons |
DuyLionTran | 30:e49b8e99db65 | 57 | static char org[12] = ORG; |
DuyLionTran | 30:e49b8e99db65 | 58 | static char type[30] = TYPE; |
DuyLionTran | 30:e49b8e99db65 | 59 | static char auth_token[30] = AUTH_TOKEN; // Auth_token is only used in non-quickstart mode |
DuyLionTran | 30:e49b8e99db65 | 60 | static int connack_rc = 0; // MQTT connack return code |
DuyLionTran | 30:e49b8e99db65 | 61 | static bool netConnecting = false; |
DuyLionTran | 30:e49b8e99db65 | 62 | static bool mqttConnecting = false; |
DuyLionTran | 30:e49b8e99db65 | 63 | static bool netConnected = false; |
DuyLionTran | 30:e49b8e99db65 | 64 | static bool connected = false; |
DuyLionTran | 30:e49b8e99db65 | 65 | static int retryAttempt = 0; |
DuyLionTran | 30:e49b8e99db65 | 66 | static int connectTimeout = 1000; |
DuyLionTran | 30:e49b8e99db65 | 67 | uint16_t commandID = 0; |
DuyLionTran | 30:e49b8e99db65 | 68 | static char subscription_url[MQTT_MAX_PAYLOAD_SIZE]; |
DuyLionTran | 30:e49b8e99db65 | 69 | |
DuyLionTran | 30:e49b8e99db65 | 70 | /*************************************************************** |
DuyLionTran | 30:e49b8e99db65 | 71 | * Unity function definitions |
DuyLionTran | 30:e49b8e99db65 | 72 | ***************************************************************/ |
DuyLionTran | 30:e49b8e99db65 | 73 | void MQTT_MessageHandles(uint8_t ControlSignal); |
DuyLionTran | 30:e49b8e99db65 | 74 | |
DuyLionTran | 30:e49b8e99db65 | 75 | /** brief Callback function when MQTT message arrives |
DuyLionTran | 30:e49b8e99db65 | 76 | * param[in] msgMQTT |
DuyLionTran | 30:e49b8e99db65 | 77 | * retral None |
DuyLionTran | 30:e49b8e99db65 | 78 | */ |
DuyLionTran | 30:e49b8e99db65 | 79 | void MQTT_SubscribeCallback(MQTT::MessageData & msgMQTT); |
DuyLionTran | 30:e49b8e99db65 | 80 | |
DuyLionTran | 30:e49b8e99db65 | 81 | /** brief Subscribe to a MQTT topic and set the MQTT callback function |
DuyLionTran | 30:e49b8e99db65 | 82 | * param[in] subscribeTopic Topic to be subscribed |
DuyLionTran | 30:e49b8e99db65 | 83 | * param[in] client MQTT client |
DuyLionTran | 30:e49b8e99db65 | 84 | * retral returnCode from MQTTClient.h |
DuyLionTran | 30:e49b8e99db65 | 85 | */ |
DuyLionTran | 30:e49b8e99db65 | 86 | int MQTT_Subscribe(char *subscribeTopic, MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client); |
DuyLionTran | 30:e49b8e99db65 | 87 | |
DuyLionTran | 30:e49b8e99db65 | 88 | /** brief Connect to the internet then the MQTT network |
DuyLionTran | 30:e49b8e99db65 | 89 | * param[in] client MQTT client |
DuyLionTran | 30:e49b8e99db65 | 90 | * param[in] mqttNetwork MQTT network |
DuyLionTran | 30:e49b8e99db65 | 91 | * param[in] network The internet network interface (ethernet, wifi...) |
DuyLionTran | 30:e49b8e99db65 | 92 | * retral Internet connect result and returnCode from MQTTClient.h |
DuyLionTran | 30:e49b8e99db65 | 93 | */ |
DuyLionTran | 30:e49b8e99db65 | 94 | int MQTT_Connect(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTNetwork *mqttNetwork, NetworkInterface* network); |
DuyLionTran | 30:e49b8e99db65 | 95 | |
DuyLionTran | 30:e49b8e99db65 | 96 | /** brief Setup the number of attempt to re-connect to the internet |
DuyLionTran | 30:e49b8e99db65 | 97 | * param[in] attemptNumber The number of attemp |
DuyLionTran | 30:e49b8e99db65 | 98 | */ |
DuyLionTran | 30:e49b8e99db65 | 99 | int MQTT_GetConnTimeout(int attemptNumber); |
DuyLionTran | 30:e49b8e99db65 | 100 | |
DuyLionTran | 30:e49b8e99db65 | 101 | /** brief Try to reconnect to the internet and MQTT network |
DuyLionTran | 30:e49b8e99db65 | 102 | * retral None |
DuyLionTran | 30:e49b8e99db65 | 103 | */ |
DuyLionTran | 30:e49b8e99db65 | 104 | void MQTT_AttemptConnect(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTNetwork *mqttNetwork, NetworkInterface* network); |
DuyLionTran | 30:e49b8e99db65 | 105 | |
DuyLionTran | 30:e49b8e99db65 | 106 | /** brief Publish ADC values to the server |
DuyLionTran | 30:e49b8e99db65 | 107 | * param[in] client MQTT client |
DuyLionTran | 30:e49b8e99db65 | 108 | * param[in] inputTime The time when the data is attempt to be sent |
DuyLionTran | 30:e49b8e99db65 | 109 | * param[in] adcVal_0 The ADC value to be sent |
DuyLionTran | 30:e49b8e99db65 | 110 | * retral returnCode from MQTTClient.h |
DuyLionTran | 30:e49b8e99db65 | 111 | */ |
DuyLionTran | 30:e49b8e99db65 | 112 | int MQTT_PublishADC(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, float adcVal_0); |
DuyLionTran | 30:e49b8e99db65 | 113 | |
DuyLionTran | 30:e49b8e99db65 | 114 | /** brief Publish relay states to the server |
DuyLionTran | 30:e49b8e99db65 | 115 | * param[in] client MQTT client |
DuyLionTran | 30:e49b8e99db65 | 116 | * param[in] inputTime The time when the data is attempt to be sent |
DuyLionTran | 30:e49b8e99db65 | 117 | * param[in] relay1 Relay 1 state |
DuyLionTran | 30:e49b8e99db65 | 118 | * param[in] relay2 Relay 2 state |
DuyLionTran | 30:e49b8e99db65 | 119 | * retral returnCode from MQTTClient.h |
DuyLionTran | 30:e49b8e99db65 | 120 | */ |
DuyLionTran | 30:e49b8e99db65 | 121 | int MQTT_PublishRelayState(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, int relay1, int relay2); |
DuyLionTran | 30:e49b8e99db65 | 122 | |
DuyLionTran | 30:e49b8e99db65 | 123 | /** brief Publish relay states to the server |
DuyLionTran | 30:e49b8e99db65 | 124 | * param[in] client MQTT client |
DuyLionTran | 30:e49b8e99db65 | 125 | * param[in] inputTime The time when the data is attempt to be sent |
DuyLionTran | 30:e49b8e99db65 | 126 | * param[in] mode current mode: automatic (0) or manual (1) |
DuyLionTran | 30:e49b8e99db65 | 127 | * param[in] maxOxi Maximum Oxygen value |
DuyLionTran | 30:e49b8e99db65 | 128 | * param[in] minOxi Minimum Oxygen value |
DuyLionTran | 30:e49b8e99db65 | 129 | // * param[in] uploadInterval Interval between upload turns |
DuyLionTran | 30:e49b8e99db65 | 130 | * retral returnCode from MQTTClient.h |
DuyLionTran | 30:e49b8e99db65 | 131 | */ |
DuyLionTran | 30:e49b8e99db65 | 132 | int MQTT_PublishConfigValue(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, uint8_t mode, uint8_t minOxi, uint8_t maxOxi); |
DuyLionTran | 30:e49b8e99db65 | 133 | |
DuyLionTran | 30:e49b8e99db65 | 134 | /** brief Upload all the data to the MQTT server |
DuyLionTran | 30:e49b8e99db65 | 135 | * param[in] client MQTT client |
DuyLionTran | 30:e49b8e99db65 | 136 | * param[in] inputTime The time when the data is attempt to be sent |
DuyLionTran | 30:e49b8e99db65 | 137 | * param[in] uploadInterval The period between each upload moment |
DuyLionTran | 30:e49b8e99db65 | 138 | * retral returnCode from MQTTClient.h |
DuyLionTran | 30:e49b8e99db65 | 139 | */ |
DuyLionTran | 30:e49b8e99db65 | 140 | int MQTT_PublishAll(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, uint8_t uploadType, struct UploadValue uploadStruct); |
DuyLionTran | 30:e49b8e99db65 | 141 | |
DuyLionTran | 30:e49b8e99db65 | 142 | /********************************************************************************************************************************************************************************************/ |
DuyLionTran | 30:e49b8e99db65 | 143 | /*************************************************************** |
DuyLionTran | 30:e49b8e99db65 | 144 | * Unity function declarations |
DuyLionTran | 30:e49b8e99db65 | 145 | ***************************************************************/ |
DuyLionTran | 30:e49b8e99db65 | 146 | void MQTT_SubscribeCallback(MQTT::MessageData & msgMQTT) { |
DuyLionTran | 30:e49b8e99db65 | 147 | // Message Handles |
DuyLionTran | 30:e49b8e99db65 | 148 | char msg[MQTT_MAX_PAYLOAD_SIZE]; |
DuyLionTran | 30:e49b8e99db65 | 149 | msg[0]='\0'; |
DuyLionTran | 30:e49b8e99db65 | 150 | strncat (msg, (char*)msgMQTT.message.payload, msgMQTT.message.payloadlen); |
DuyLionTran | 30:e49b8e99db65 | 151 | printf ("--->>> MQTT_SubscribeCallback msg: %s\n\r", msg); |
DuyLionTran | 30:e49b8e99db65 | 152 | //{"type":"3","deviceId":"string"} |
DuyLionTran | 30:e49b8e99db65 | 153 | Json json(msg, msgMQTT.message.payloadlen); |
DuyLionTran | 30:e49b8e99db65 | 154 | if (!json.isValidJson()) { |
DuyLionTran | 30:e49b8e99db65 | 155 | printf("Invalid JSON: %s", msg); |
DuyLionTran | 30:e49b8e99db65 | 156 | } |
DuyLionTran | 30:e49b8e99db65 | 157 | else { |
DuyLionTran | 30:e49b8e99db65 | 158 | if (json.type(0) != JSMN_OBJECT ) { |
DuyLionTran | 30:e49b8e99db65 | 159 | printf("Invalid JSON. ROOT element is not Object: %s", msg); |
DuyLionTran | 30:e49b8e99db65 | 160 | } |
DuyLionTran | 30:e49b8e99db65 | 161 | else { |
DuyLionTran | 30:e49b8e99db65 | 162 | int CommandType; |
DuyLionTran | 30:e49b8e99db65 | 163 | int KeyIndex = json.findKeyIndexIn("type", 0); |
DuyLionTran | 30:e49b8e99db65 | 164 | int KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 30:e49b8e99db65 | 165 | int ret = json.tokenIntegerValue(KeyValueIndex, CommandType); |
DuyLionTran | 30:e49b8e99db65 | 166 | printf("Command Type: %d, error %d\r\n", CommandType, ret); |
DuyLionTran | 30:e49b8e99db65 | 167 | |
DuyLionTran | 30:e49b8e99db65 | 168 | switch (CommandType) { |
DuyLionTran | 30:e49b8e99db65 | 169 | case 3: |
DuyLionTran | 30:e49b8e99db65 | 170 | break; |
DuyLionTran | 30:e49b8e99db65 | 171 | |
DuyLionTran | 30:e49b8e99db65 | 172 | case 4: |
DuyLionTran | 30:e49b8e99db65 | 173 | break; |
DuyLionTran | 30:e49b8e99db65 | 174 | |
DuyLionTran | 30:e49b8e99db65 | 175 | default: break; |
DuyLionTran | 30:e49b8e99db65 | 176 | } |
DuyLionTran | 30:e49b8e99db65 | 177 | } |
DuyLionTran | 30:e49b8e99db65 | 178 | } |
DuyLionTran | 30:e49b8e99db65 | 179 | } |
DuyLionTran | 30:e49b8e99db65 | 180 | |
DuyLionTran | 30:e49b8e99db65 | 181 | int MQTT_Subscribe(char *subscribeTopic, MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client) { |
DuyLionTran | 30:e49b8e99db65 | 182 | return client->subscribe(subscribeTopic, MQTT::QOS1, MQTT_SubscribeCallback); |
DuyLionTran | 30:e49b8e99db65 | 183 | } |
DuyLionTran | 30:e49b8e99db65 | 184 | |
DuyLionTran | 30:e49b8e99db65 | 185 | int MQTT_Connect(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTNetwork *mqttNetwork, NetworkInterface* network) { |
DuyLionTran | 30:e49b8e99db65 | 186 | const char* iot_ibm = MQTT_BROKER_URL; |
DuyLionTran | 30:e49b8e99db65 | 187 | char hostname[strlen(org) + strlen(iot_ibm) + 1]; |
DuyLionTran | 30:e49b8e99db65 | 188 | |
DuyLionTran | 30:e49b8e99db65 | 189 | sprintf(hostname, "%s%s", org, iot_ibm); |
DuyLionTran | 30:e49b8e99db65 | 190 | // Construct clientId - d:org:type:id |
DuyLionTran | 30:e49b8e99db65 | 191 | char clientId[strlen(org) + strlen(type) + strlen(id) + 5]; |
DuyLionTran | 30:e49b8e99db65 | 192 | sprintf(clientId, "d:%s:%s:%s", org, type, id); |
DuyLionTran | 30:e49b8e99db65 | 193 | sprintf(subscription_url, "%s.%s/#/device/%s/%s/", org, "internetofthings.ibmcloud.com", id, DEFAULT_TYPE_NAME); |
DuyLionTran | 30:e49b8e99db65 | 194 | |
DuyLionTran | 30:e49b8e99db65 | 195 | // Network debug statements |
DuyLionTran | 30:e49b8e99db65 | 196 | LOG("=====================================\n\r"); |
DuyLionTran | 30:e49b8e99db65 | 197 | LOG("Nucleo IP ADDRESS: %s\n\r", network->get_ip_address()); |
DuyLionTran | 30:e49b8e99db65 | 198 | LOG("Nucleo MAC ADDRESS: %s\n\r", network->get_mac_address()); |
DuyLionTran | 30:e49b8e99db65 | 199 | LOG("Server Hostname: %s port: %d\n\r", hostname, IBM_IOT_PORT); |
DuyLionTran | 30:e49b8e99db65 | 200 | LOG("Client ID: %s\n\r", clientId); |
DuyLionTran | 30:e49b8e99db65 | 201 | LOG("Topic: %s\n\r",MQTT_EVENT_TOPIC); |
DuyLionTran | 30:e49b8e99db65 | 202 | LOG("Subscription URL: %s\n\r", subscription_url); |
DuyLionTran | 30:e49b8e99db65 | 203 | LOG("=====================================\n\r"); |
DuyLionTran | 30:e49b8e99db65 | 204 | netConnecting = true; |
DuyLionTran | 30:e49b8e99db65 | 205 | int rc = mqttNetwork->connect(hostname, IBM_IOT_PORT); |
DuyLionTran | 30:e49b8e99db65 | 206 | if (rc != 0) { |
DuyLionTran | 30:e49b8e99db65 | 207 | printf("rc from TCP connect is %d\r\n", rc); |
DuyLionTran | 30:e49b8e99db65 | 208 | return rc; |
DuyLionTran | 30:e49b8e99db65 | 209 | } |
DuyLionTran | 30:e49b8e99db65 | 210 | |
DuyLionTran | 30:e49b8e99db65 | 211 | printf ("--->TCP Connected\n\r"); |
DuyLionTran | 30:e49b8e99db65 | 212 | netConnected = true; |
DuyLionTran | 30:e49b8e99db65 | 213 | netConnecting = false; |
DuyLionTran | 30:e49b8e99db65 | 214 | |
DuyLionTran | 30:e49b8e99db65 | 215 | // MQTT Connect |
DuyLionTran | 30:e49b8e99db65 | 216 | mqttConnecting = true; |
DuyLionTran | 30:e49b8e99db65 | 217 | MQTTPacket_connectData data = MQTTPacket_connectData_initializer; |
DuyLionTran | 30:e49b8e99db65 | 218 | data.MQTTVersion = 4; |
DuyLionTran | 30:e49b8e99db65 | 219 | data.struct_version = 0; |
DuyLionTran | 30:e49b8e99db65 | 220 | data.clientID.cstring = clientId; |
DuyLionTran | 30:e49b8e99db65 | 221 | data.keepAliveInterval = MQTT_KEEPALIVE; // in Sec |
DuyLionTran | 30:e49b8e99db65 | 222 | data.username.cstring = AUTH_METHOD; |
DuyLionTran | 30:e49b8e99db65 | 223 | data.password.cstring = auth_token; |
DuyLionTran | 30:e49b8e99db65 | 224 | printf ("AutToken: %s\n\r", auth_token); |
DuyLionTran | 30:e49b8e99db65 | 225 | |
DuyLionTran | 30:e49b8e99db65 | 226 | if ((rc = client->connect(data)) != 0) { |
DuyLionTran | 30:e49b8e99db65 | 227 | printf("rc from MQTT connect is %d\r\n", rc); |
DuyLionTran | 30:e49b8e99db65 | 228 | connack_rc = rc; |
DuyLionTran | 30:e49b8e99db65 | 229 | return rc; |
DuyLionTran | 30:e49b8e99db65 | 230 | } |
DuyLionTran | 30:e49b8e99db65 | 231 | connected = true; |
DuyLionTran | 30:e49b8e99db65 | 232 | printf ("--->MQTT Connected\n\r"); |
DuyLionTran | 30:e49b8e99db65 | 233 | if ((rc = MQTT_Subscribe(MQTT_COMMAND_TOPIC, client)) == 0) { |
DuyLionTran | 30:e49b8e99db65 | 234 | LOG ("--->>>MQTT subscribed to: %s\n\r", MQTT_COMMAND_TOPIC); |
DuyLionTran | 30:e49b8e99db65 | 235 | } else { |
DuyLionTran | 30:e49b8e99db65 | 236 | LOG ("--->>>ERROR MQTT subscribe : %s\n\r", MQTT_COMMAND_TOPIC); |
DuyLionTran | 30:e49b8e99db65 | 237 | } |
DuyLionTran | 30:e49b8e99db65 | 238 | mqttConnecting = false; |
DuyLionTran | 30:e49b8e99db65 | 239 | connack_rc = rc; |
DuyLionTran | 30:e49b8e99db65 | 240 | return rc; |
DuyLionTran | 30:e49b8e99db65 | 241 | } |
DuyLionTran | 30:e49b8e99db65 | 242 | |
DuyLionTran | 30:e49b8e99db65 | 243 | |
DuyLionTran | 30:e49b8e99db65 | 244 | int MQTT_GetConnTimeout(int attemptNumber) { // First 10 attempts try within 3 seconds, next 10 attempts retry after every 1 minute |
DuyLionTran | 30:e49b8e99db65 | 245 | // after 20 attempts, retry every 10 minutes |
DuyLionTran | 30:e49b8e99db65 | 246 | return (attemptNumber < 10) ? 3 : (attemptNumber < 20) ? 60 : 600; |
DuyLionTran | 30:e49b8e99db65 | 247 | } |
DuyLionTran | 30:e49b8e99db65 | 248 | |
DuyLionTran | 30:e49b8e99db65 | 249 | |
DuyLionTran | 30:e49b8e99db65 | 250 | void MQTT_AttemptConnect(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTNetwork *mqttNetwork, NetworkInterface* network) { |
DuyLionTran | 30:e49b8e99db65 | 251 | connected = false; |
DuyLionTran | 30:e49b8e99db65 | 252 | |
DuyLionTran | 30:e49b8e99db65 | 253 | while (MQTT_Connect(client, mqttNetwork, network) != MQTT_CONNECTION_ACCEPTED) { |
DuyLionTran | 30:e49b8e99db65 | 254 | if (connack_rc == MQTT_NOT_AUTHORIZED || connack_rc == MQTT_BAD_USERNAME_OR_PASSWORD) { |
DuyLionTran | 30:e49b8e99db65 | 255 | printf ("File: %s, Line: %d Error: %d\n\r",__FILE__,__LINE__, connack_rc); |
DuyLionTran | 30:e49b8e99db65 | 256 | return; // don't reattempt to connect if credentials are wrong |
DuyLionTran | 30:e49b8e99db65 | 257 | } |
DuyLionTran | 30:e49b8e99db65 | 258 | int timeout = MQTT_GetConnTimeout(++retryAttempt); |
DuyLionTran | 30:e49b8e99db65 | 259 | WARN("Retry attempt number %d waiting %d\n", retryAttempt, timeout); |
DuyLionTran | 30:e49b8e99db65 | 260 | |
DuyLionTran | 30:e49b8e99db65 | 261 | // if ipstack and client were on the heap we could deconstruct and goto a label where they are constructed |
DuyLionTran | 30:e49b8e99db65 | 262 | // or maybe just add the proper members to do this disconnect and call MQTT_AttemptConnect(...) |
DuyLionTran | 30:e49b8e99db65 | 263 | // this works - reset the system when the retry count gets to a threshold |
DuyLionTran | 30:e49b8e99db65 | 264 | if (retryAttempt == 5) |
DuyLionTran | 30:e49b8e99db65 | 265 | NVIC_SystemReset(); |
DuyLionTran | 30:e49b8e99db65 | 266 | else |
DuyLionTran | 30:e49b8e99db65 | 267 | wait(timeout); |
DuyLionTran | 30:e49b8e99db65 | 268 | } |
DuyLionTran | 30:e49b8e99db65 | 269 | } |
DuyLionTran | 30:e49b8e99db65 | 270 | |
DuyLionTran | 30:e49b8e99db65 | 271 | int MQTT_PublishADC(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, float adcVal_0) { |
DuyLionTran | 30:e49b8e99db65 | 272 | MQTT::Message message; |
DuyLionTran | 30:e49b8e99db65 | 273 | const char* pubTopic = MQTT_EVENT_TOPIC; |
DuyLionTran | 30:e49b8e99db65 | 274 | |
DuyLionTran | 30:e49b8e99db65 | 275 | char buf[MQTT_MAX_PAYLOAD_SIZE]; |
DuyLionTran | 30:e49b8e99db65 | 276 | char timeBuf[50]; |
DuyLionTran | 30:e49b8e99db65 | 277 | |
DuyLionTran | 30:e49b8e99db65 | 278 | if (!client->isConnected()) { |
DuyLionTran | 30:e49b8e99db65 | 279 | printf ("---> MQTT DISCONNECTED\n\r"); return MQTT::FAILURE; |
DuyLionTran | 30:e49b8e99db65 | 280 | } |
DuyLionTran | 30:e49b8e99db65 | 281 | |
DuyLionTran | 30:e49b8e99db65 | 282 | strftime(timeBuf, 50, "%Y/%m/%d %H:%M:%S", localtime(&inputTime)); |
DuyLionTran | 30:e49b8e99db65 | 283 | // sprintf(buf, |
DuyLionTran | 30:e49b8e99db65 | 284 | // "{\"Project\":\"%s\",\"Time\":\"%s\",\"Type\":1,\"cmdID\":%d,\"ADC0\":%0.2f}", |
DuyLionTran | 30:e49b8e99db65 | 285 | // projectName, timeBuf, commandID, adcVal_0); |
DuyLionTran | 30:e49b8e99db65 | 286 | sprintf(buf, "{\"type\":1,\"deviceId\":\"PROEVN\",\"time\":\"%s\",\"cmdId\":%d,\"adc0\":%0.2f}", |
DuyLionTran | 30:e49b8e99db65 | 287 | timeBuf, commandID, adcVal_0); |
DuyLionTran | 30:e49b8e99db65 | 288 | message.qos = MQTT::QOS0; |
DuyLionTran | 30:e49b8e99db65 | 289 | message.retained = false; |
DuyLionTran | 30:e49b8e99db65 | 290 | message.dup = false; |
DuyLionTran | 30:e49b8e99db65 | 291 | message.payload = (void*)buf; |
DuyLionTran | 30:e49b8e99db65 | 292 | message.payloadlen = strlen(buf); |
DuyLionTran | 30:e49b8e99db65 | 293 | |
DuyLionTran | 30:e49b8e99db65 | 294 | if((message.payloadlen + strlen(pubTopic)+1) >= MQTT_MAX_PACKET_SIZE) |
DuyLionTran | 30:e49b8e99db65 | 295 | printf("message too long!\r\n"); |
DuyLionTran | 30:e49b8e99db65 | 296 | |
DuyLionTran | 30:e49b8e99db65 | 297 | LOG("Publishing %s\n\r", buf); |
DuyLionTran | 30:e49b8e99db65 | 298 | return client->publish(pubTopic, message); |
DuyLionTran | 30:e49b8e99db65 | 299 | } |
DuyLionTran | 30:e49b8e99db65 | 300 | |
DuyLionTran | 30:e49b8e99db65 | 301 | int MQTT_PublishRelayState(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, int relay1, int relay2) { |
DuyLionTran | 30:e49b8e99db65 | 302 | MQTT::Message message; |
DuyLionTran | 30:e49b8e99db65 | 303 | const char* pubTopic = MQTT_EVENT_TOPIC; |
DuyLionTran | 30:e49b8e99db65 | 304 | char buf[MQTT_MAX_PAYLOAD_SIZE]; |
DuyLionTran | 30:e49b8e99db65 | 305 | char timeBuf[50]; |
DuyLionTran | 30:e49b8e99db65 | 306 | |
DuyLionTran | 30:e49b8e99db65 | 307 | if (!client->isConnected()) { |
DuyLionTran | 30:e49b8e99db65 | 308 | printf ("---> MQTT DISCONNECTED\n\r"); |
DuyLionTran | 30:e49b8e99db65 | 309 | return MQTT::FAILURE; |
DuyLionTran | 30:e49b8e99db65 | 310 | } |
DuyLionTran | 30:e49b8e99db65 | 311 | strftime(timeBuf, 50, "%Y/%m/%d %H:%M:%S", localtime(&inputTime)); |
DuyLionTran | 30:e49b8e99db65 | 312 | sprintf(buf, "{\"type\":3,\"deviceId\":\"PROEVN\",\"time\":\"%s\",\"cmdId\":%d,\"relay1\":%d,\"relay2\":%d}", |
DuyLionTran | 30:e49b8e99db65 | 313 | timeBuf, commandID, relay1, relay2); |
DuyLionTran | 30:e49b8e99db65 | 314 | message.qos = MQTT::QOS0; |
DuyLionTran | 30:e49b8e99db65 | 315 | message.retained = false; |
DuyLionTran | 30:e49b8e99db65 | 316 | message.dup = false; |
DuyLionTran | 30:e49b8e99db65 | 317 | message.payload = (void*)buf; |
DuyLionTran | 30:e49b8e99db65 | 318 | message.payloadlen = strlen(buf); |
DuyLionTran | 30:e49b8e99db65 | 319 | |
DuyLionTran | 30:e49b8e99db65 | 320 | if((message.payloadlen + strlen(pubTopic)+1) >= MQTT_MAX_PACKET_SIZE) |
DuyLionTran | 30:e49b8e99db65 | 321 | printf("message too long!\r\n"); |
DuyLionTran | 30:e49b8e99db65 | 322 | |
DuyLionTran | 30:e49b8e99db65 | 323 | LOG("Publishing %s\n\r", buf); |
DuyLionTran | 30:e49b8e99db65 | 324 | return client->publish(pubTopic, message); |
DuyLionTran | 30:e49b8e99db65 | 325 | } |
DuyLionTran | 30:e49b8e99db65 | 326 | |
DuyLionTran | 30:e49b8e99db65 | 327 | int MQTT_PublishConfigValue(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, uint8_t mode, uint8_t minOxi, uint8_t maxOxi) { |
DuyLionTran | 30:e49b8e99db65 | 328 | MQTT::Message message; |
DuyLionTran | 30:e49b8e99db65 | 329 | const char* pubTopic = MQTT_EVENT_TOPIC; |
DuyLionTran | 30:e49b8e99db65 | 330 | char buf[MQTT_MAX_PAYLOAD_SIZE]; |
DuyLionTran | 30:e49b8e99db65 | 331 | char timeBuf[50]; |
DuyLionTran | 30:e49b8e99db65 | 332 | |
DuyLionTran | 30:e49b8e99db65 | 333 | if (!client->isConnected()) { |
DuyLionTran | 30:e49b8e99db65 | 334 | printf ("---> MQTT DISCONNECTED\n\r"); |
DuyLionTran | 30:e49b8e99db65 | 335 | return MQTT::FAILURE; |
DuyLionTran | 30:e49b8e99db65 | 336 | } |
DuyLionTran | 30:e49b8e99db65 | 337 | strftime(timeBuf, 50, "%Y/%m/%d %H:%M:%S", localtime(&inputTime)); |
DuyLionTran | 30:e49b8e99db65 | 338 | sprintf(buf, "{\"type\":4,\"deviceId\":\"PROEVN\",\"time\":\"%s\",\"cmdId\":%d,\"mode\":%d,\"minOxygenVal\":%d,\"maxOxygenVal\":%d}", |
DuyLionTran | 30:e49b8e99db65 | 339 | timeBuf, commandID, mode, minOxi, maxOxi); |
DuyLionTran | 30:e49b8e99db65 | 340 | message.qos = MQTT::QOS0; |
DuyLionTran | 30:e49b8e99db65 | 341 | message.retained = false; |
DuyLionTran | 30:e49b8e99db65 | 342 | message.dup = false; |
DuyLionTran | 30:e49b8e99db65 | 343 | message.payload = (void*)buf; |
DuyLionTran | 30:e49b8e99db65 | 344 | message.payloadlen = strlen(buf); |
DuyLionTran | 30:e49b8e99db65 | 345 | |
DuyLionTran | 30:e49b8e99db65 | 346 | if((message.payloadlen + strlen(pubTopic)+1) >= MQTT_MAX_PACKET_SIZE) |
DuyLionTran | 30:e49b8e99db65 | 347 | printf("message too long!\r\n"); |
DuyLionTran | 30:e49b8e99db65 | 348 | |
DuyLionTran | 30:e49b8e99db65 | 349 | LOG("Publishing %s\n\r", buf); |
DuyLionTran | 30:e49b8e99db65 | 350 | return client->publish(pubTopic, message); |
DuyLionTran | 30:e49b8e99db65 | 351 | } |
DuyLionTran | 30:e49b8e99db65 | 352 | |
DuyLionTran | 30:e49b8e99db65 | 353 | int MQTT_PublishAll(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, uint8_t uploadType, struct UploadValue uploadStruct) { |
DuyLionTran | 30:e49b8e99db65 | 354 | int retVal; |
DuyLionTran | 30:e49b8e99db65 | 355 | switch (uploadType) { |
DuyLionTran | 30:e49b8e99db65 | 356 | case (ADC_VALUE): retVal = MQTT_PublishADC(client, inputTime, uploadStruct.ADC_PHVal); |
DuyLionTran | 30:e49b8e99db65 | 357 | break; |
DuyLionTran | 30:e49b8e99db65 | 358 | case (SENSOR_VALUE): retVal = MQTT::SUCCESS; |
DuyLionTran | 30:e49b8e99db65 | 359 | break; |
DuyLionTran | 30:e49b8e99db65 | 360 | case (RELAY_STATE): retVal = MQTT_PublishRelayState(client, inputTime, uploadStruct.RELAY_State_1, uploadStruct.RELAY_State_2); |
DuyLionTran | 30:e49b8e99db65 | 361 | break; |
DuyLionTran | 30:e49b8e99db65 | 362 | case (CONFIG_VALUE): retVal = MQTT_PublishConfigValue(client, inputTime, uploadStruct.CONFIG_Mode, uploadStruct.CONFIG_MinOxi, uploadStruct.CONFIG_MaxOxi); |
DuyLionTran | 30:e49b8e99db65 | 363 | break; |
DuyLionTran | 30:e49b8e99db65 | 364 | default: break; |
DuyLionTran | 30:e49b8e99db65 | 365 | } |
DuyLionTran | 30:e49b8e99db65 | 366 | return retVal; |
DuyLionTran | 30:e49b8e99db65 | 367 | } |
DuyLionTran | 30:e49b8e99db65 | 368 | |
DuyLionTran | 30:e49b8e99db65 | 369 | #endif /* __SIMPLEMQTT_H__ */ |