turbidity sensor
Dependencies: watersenor_and_temp_code MQTT NetworkSocketAPI X_NUCLEO_IDW01M1v2 mbed
Fork of Dissolved_oxygen_sensor_online by
main.cpp@4:3642f63079ec, 2017-11-04 (annotated)
- Committer:
- rozendhyan@gmail.com
- Date:
- Sat Nov 04 00:14:23 2017 +0800
- Revision:
- 4:3642f63079ec
- Parent:
- 3:30d9b8d9adc9
- Child:
- 5:42113ea1b319
edit DS1820
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
rozendhyan@gmail.com | 0:80c7778c82b8 | 1 | #include "mbed.h" |
rozendhyan@gmail.com | 0:80c7778c82b8 | 2 | #include "BME280.hpp" |
rozendhyan@gmail.com | 0:80c7778c82b8 | 3 | #include "SpwfInterface.h" |
rozendhyan@gmail.com | 0:80c7778c82b8 | 4 | #include "TCPSocket.h" |
rozendhyan@gmail.com | 0:80c7778c82b8 | 5 | #include "MQTTClient.h" |
rozendhyan@gmail.com | 0:80c7778c82b8 | 6 | #include "MQTTWiFi.h" |
e58136782000 | 3:30d9b8d9adc9 | 7 | #include "DS1820.h" |
rozendhyan@gmail.com | 0:80c7778c82b8 | 8 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 9 | // MQTT use |
rozendhyan@gmail.com | 0:80c7778c82b8 | 10 | #define MQTT_MAX_PACKET_SIZE 250 |
rozendhyan@gmail.com | 0:80c7778c82b8 | 11 | #define MQTT_MAX_PAYLOAD_SIZE 300 |
rozendhyan@gmail.com | 0:80c7778c82b8 | 12 | //Configuration value needed to connect Red-node |
rozendhyan@gmail.com | 4:3642f63079ec | 13 | #define BROKER_URL "192.168.20.116"; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 14 | #define MQTT_PORT 1883 |
rozendhyan@gmail.com | 0:80c7778c82b8 | 15 | //MQTT use Topic |
e58136782000 | 3:30d9b8d9adc9 | 16 | #define TOPIC1 "1" |
e58136782000 | 3:30d9b8d9adc9 | 17 | #define TOPIC2 "3" |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 18 | #define SUB_TOPIC "LED" |
rozendhyan@gmail.com | 0:80c7778c82b8 | 19 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 20 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 21 | //Wifi network |
e58136782000 | 2:eab5b5c8271d | 22 | #define SSID "tnta" |
e58136782000 | 2:eab5b5c8271d | 23 | #define PASSW "tnta2355818" |
rozendhyan@gmail.com | 0:80c7778c82b8 | 24 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 25 | DigitalOut myled(LED1); |
rozendhyan@gmail.com | 4:3642f63079ec | 26 | //BME280 bmpSensor; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 27 | int connack_rc = 0; // MQTT connack return code |
rozendhyan@gmail.com | 0:80c7778c82b8 | 28 | const char * ip_addr = ""; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 29 | char *host_addr = ""; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 30 | bool netConnecting = false; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 31 | int connectTimeout = 1000; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 32 | bool mqttConnecting = false; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 33 | bool netConnected = false; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 34 | bool connected = false; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 35 | int retryAttempt = 0; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 36 | char subscription_url[MQTT_MAX_PAYLOAD_SIZE]; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 37 | |
e58136782000 | 3:30d9b8d9adc9 | 38 | |
rozendhyan@gmail.com | 4:3642f63079ec | 39 | |
e58136782000 | 3:30d9b8d9adc9 | 40 | Serial serial(USBTX, USBRX); |
rozendhyan@gmail.com | 4:3642f63079ec | 41 | DS1820 ds1820(PA_8); // substitute PA_9 with actual mbed pin name connected to the DS1820 data pin |
rozendhyan@gmail.com | 4:3642f63079ec | 42 | |
e58136782000 | 3:30d9b8d9adc9 | 43 | |
e58136782000 | 3:30d9b8d9adc9 | 44 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 45 | MQTT::Message message; |
e58136782000 | 3:30d9b8d9adc9 | 46 | MQTTString TopicName1={TOPIC1}; |
e58136782000 | 3:30d9b8d9adc9 | 47 | MQTTString TopicName2={TOPIC2}; |
e58136782000 | 3:30d9b8d9adc9 | 48 | MQTT::MessageData MsgData1(TopicName1, message); |
e58136782000 | 3:30d9b8d9adc9 | 49 | MQTT::MessageData MsgData2(TopicName2, message); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 50 | |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 51 | void subscribe_LED(char* msg){ |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 52 | int value = atoi(msg); |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 53 | //printf("value = %d\n", value); |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 54 | if(value ==1){ |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 55 | myled = !myled; |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 56 | } |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 57 | |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 58 | } |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 59 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 60 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 61 | void subscribe_cb(MQTT::MessageData & msgMQTT) { |
rozendhyan@gmail.com | 0:80c7778c82b8 | 62 | char msg[MQTT_MAX_PAYLOAD_SIZE]; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 63 | msg[0]='\0'; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 64 | strncat (msg, (char*)msgMQTT.message.payload, msgMQTT.message.payloadlen); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 65 | printf ("--->>> subscribe_cb msg: %s\n\r", msg); |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 66 | subscribe_LED(msg); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 67 | } |
rozendhyan@gmail.com | 0:80c7778c82b8 | 68 | int subscribe(MQTT::Client<MQTTWiFi, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTWiFi* ipstack) |
rozendhyan@gmail.com | 0:80c7778c82b8 | 69 | { |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 70 | char* pubTopic = SUB_TOPIC; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 71 | return client->subscribe(pubTopic, MQTT::QOS1, subscribe_cb); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 72 | } |
rozendhyan@gmail.com | 0:80c7778c82b8 | 73 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 74 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 75 | int connect(MQTT::Client<MQTTWiFi, Countdown, MQTT_MAX_PACKET_SIZE>* client,MQTTWiFi* ipstack){ |
rozendhyan@gmail.com | 0:80c7778c82b8 | 76 | const char* host = BROKER_URL; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 77 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 78 | char hostname[strlen(host) + 1]; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 79 | sprintf(hostname,"%s", host); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 80 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 81 | SpwfSAInterface& WiFi = ipstack->getWiFi(); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 82 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 83 | //Network Debug statements |
rozendhyan@gmail.com | 0:80c7778c82b8 | 84 | LOG("=====================================\n\r"); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 85 | LOG("Connecting WiFi.\n\r"); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 86 | LOG("Nucleo IP ADDRESS: %s\n\r", WiFi.get_ip_address()); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 87 | LOG("Nucleo MAC ADDRESS: %s\n\r", WiFi.get_mac_address()); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 88 | LOG("Server Hostname: %s port: %d\n\r", hostname, MQTT_PORT); |
e58136782000 | 3:30d9b8d9adc9 | 89 | LOG("Topic1: %s\n\r", TOPIC1); |
e58136782000 | 3:30d9b8d9adc9 | 90 | LOG("Topic2: %s\n\r", TOPIC2); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 91 | //need subscrie |
rozendhyan@gmail.com | 0:80c7778c82b8 | 92 | LOG("=====================================\n\r"); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 93 | netConnecting = true; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 94 | ipstack->open(&ipstack->getWiFi()); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 95 | int rc = ipstack->connect(hostname,MQTT_PORT,connectTimeout); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 96 | if (rc != 0) |
rozendhyan@gmail.com | 0:80c7778c82b8 | 97 | { |
rozendhyan@gmail.com | 0:80c7778c82b8 | 98 | WARN("IP Stack connect returned: %d\n", rc); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 99 | return rc; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 100 | } |
rozendhyan@gmail.com | 0:80c7778c82b8 | 101 | printf ("--->TCP Connected\n\r"); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 102 | netConnected = true; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 103 | netConnecting = false; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 104 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 105 | //MQTT Connect |
rozendhyan@gmail.com | 0:80c7778c82b8 | 106 | mqttConnecting = true; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 107 | MQTTPacket_connectData data = MQTTPacket_connectData_initializer; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 108 | data.MQTTVersion = 4; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 109 | data.struct_version =0; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 110 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 111 | if((rc = client->connect(data)) == 0){ |
rozendhyan@gmail.com | 0:80c7778c82b8 | 112 | connected = true; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 113 | printf("--->MQTT Connected\n\r"); |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 114 | //#ifdef SUBSCRIBE |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 115 | if (!subscribe(client, ipstack)) printf ("--->>>MQTT subscribed to: %s\n\r",SUB_TOPIC); |
rozendhyan@gmail.com | 1:2ee9e5685a1e | 116 | //#endif |
rozendhyan@gmail.com | 0:80c7778c82b8 | 117 | }else { |
rozendhyan@gmail.com | 0:80c7778c82b8 | 118 | WARN("MQTT connect returned %d\n", rc); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 119 | } |
rozendhyan@gmail.com | 0:80c7778c82b8 | 120 | if (rc >= 0) |
rozendhyan@gmail.com | 0:80c7778c82b8 | 121 | connack_rc = rc; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 122 | mqttConnecting = false; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 123 | return rc; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 124 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 125 | } |
rozendhyan@gmail.com | 0:80c7778c82b8 | 126 | int getConnTimeout(int attemptNumber) |
rozendhyan@gmail.com | 0:80c7778c82b8 | 127 | { // First 10 attempts try within 3 seconds, next 10 attempts retry after every 1 minute |
rozendhyan@gmail.com | 0:80c7778c82b8 | 128 | // after 20 attempts, retry every 10 minutes |
rozendhyan@gmail.com | 0:80c7778c82b8 | 129 | return (attemptNumber < 10) ? 3 : (attemptNumber < 20) ? 60 : 600; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 130 | } |
rozendhyan@gmail.com | 0:80c7778c82b8 | 131 | void attemptConnect(MQTT::Client<MQTTWiFi, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTWiFi* ipstack) |
rozendhyan@gmail.com | 0:80c7778c82b8 | 132 | { |
rozendhyan@gmail.com | 0:80c7778c82b8 | 133 | connected = false; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 134 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 135 | while (connect(client, ipstack) != MQTT_CONNECTION_ACCEPTED) |
rozendhyan@gmail.com | 0:80c7778c82b8 | 136 | { |
rozendhyan@gmail.com | 0:80c7778c82b8 | 137 | /*if (connack_rc == MQTT_NOT_AUTHORIZED || connack_rc == MQTT_BAD_USERNAME_OR_PASSWORD) { |
rozendhyan@gmail.com | 0:80c7778c82b8 | 138 | printf ("File: %s, Line: %d Error: %d\n\r",__FILE__,__LINE__, connack_rc); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 139 | return; // don't reattempt to connect if credentials are wrong |
rozendhyan@gmail.com | 0:80c7778c82b8 | 140 | } */ |
rozendhyan@gmail.com | 0:80c7778c82b8 | 141 | int timeout = getConnTimeout(++retryAttempt); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 142 | WARN("Retry attempt number %d waiting %d\n", retryAttempt, timeout); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 143 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 144 | // if ipstack and client were on the heap we could deconstruct and goto a label where they are constructed |
rozendhyan@gmail.com | 0:80c7778c82b8 | 145 | // or maybe just add the proper members to do this disconnect and call attemptConnect(...) |
rozendhyan@gmail.com | 0:80c7778c82b8 | 146 | // this works - reset the system when the retry count gets to a threshold |
rozendhyan@gmail.com | 0:80c7778c82b8 | 147 | if (retryAttempt == 5) |
rozendhyan@gmail.com | 0:80c7778c82b8 | 148 | NVIC_SystemReset(); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 149 | else |
rozendhyan@gmail.com | 0:80c7778c82b8 | 150 | wait(timeout); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 151 | } |
rozendhyan@gmail.com | 0:80c7778c82b8 | 152 | } |
e58136782000 | 3:30d9b8d9adc9 | 153 | int publish (MQTT::Client<MQTTWiFi, Countdown, MQTT_MAX_PACKET_SIZE>* client,MQTTWiFi* ipstack,int data){ |
rozendhyan@gmail.com | 0:80c7778c82b8 | 154 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 155 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 156 | MQTT::Message message; |
e58136782000 | 3:30d9b8d9adc9 | 157 | char *pubTopic = TOPIC1; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 158 | char buf[MQTT_MAX_PAYLOAD_SIZE]; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 159 | printf("Temp = %d\n", data); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 160 | sprintf(buf,"%d",data); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 161 | message.qos = MQTT::QOS0; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 162 | message.retained = false; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 163 | message.dup = false; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 164 | message.payload = (void*)buf; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 165 | message.payloadlen = strlen(buf); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 166 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 167 | printf("Publishing %s\n\r", buf); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 168 | return client->publish(pubTopic, message); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 169 | } |
rozendhyan@gmail.com | 0:80c7778c82b8 | 170 | |
rozendhyan@gmail.com | 4:3642f63079ec | 171 | int main() |
rozendhyan@gmail.com | 0:80c7778c82b8 | 172 | { |
rozendhyan@gmail.com | 0:80c7778c82b8 | 173 | myled =0; |
rozendhyan@gmail.com | 4:3642f63079ec | 174 | |
e58136782000 | 3:30d9b8d9adc9 | 175 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 176 | const char *ssid = SSID; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 177 | const char *seckey = PASSW; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 178 | //use SpwfSAInterface connect AP |
rozendhyan@gmail.com | 0:80c7778c82b8 | 179 | SpwfSAInterface spwf(D8,D2, false); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 180 | printf("\r\nX-NUCLEO-IDW01M1 mbed \n"); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 181 | printf("\r\nconnecting to AP\n"); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 182 | //connect to Wifi |
rozendhyan@gmail.com | 0:80c7778c82b8 | 183 | MQTTWiFi ipstack(spwf, ssid, seckey, NSAPI_SECURITY_WPA2); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 184 | //check wifi has got ip_address |
rozendhyan@gmail.com | 0:80c7778c82b8 | 185 | if(ipstack.getWiFi().get_ip_address() == 0){ |
rozendhyan@gmail.com | 0:80c7778c82b8 | 186 | printf("Connect WiFi is failed!\nPlease check your ssid and passwd is correct"); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 187 | return 0; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 188 | } |
rozendhyan@gmail.com | 0:80c7778c82b8 | 189 | printf("ip: %s\n",ipstack.getWiFi().get_ip_address() ); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 190 | |
rozendhyan@gmail.com | 0:80c7778c82b8 | 191 | MQTT::Client<MQTTWiFi, Countdown, MQTT_MAX_PACKET_SIZE> client(ipstack); |
rozendhyan@gmail.com | 0:80c7778c82b8 | 192 | attemptConnect(&client, &ipstack); |
rozendhyan@gmail.com | 4:3642f63079ec | 193 | |
rozendhyan@gmail.com | 4:3642f63079ec | 194 | int count = 0; |
rozendhyan@gmail.com | 4:3642f63079ec | 195 | int databuffer=0; |
rozendhyan@gmail.com | 0:80c7778c82b8 | 196 | // tyeld.start(); |
rozendhyan@gmail.com | 4:3642f63079ec | 197 | while (true){ |
rozendhyan@gmail.com | 4:3642f63079ec | 198 | if(!ds1820.begin()) |
rozendhyan@gmail.com | 4:3642f63079ec | 199 | return -1; |
rozendhyan@gmail.com | 4:3642f63079ec | 200 | else |
rozendhyan@gmail.com | 4:3642f63079ec | 201 | ds1820.startConversion(); |
rozendhyan@gmail.com | 4:3642f63079ec | 202 | |
e58136782000 | 3:30d9b8d9adc9 | 203 | if (++count == 3) |
e58136782000 | 3:30d9b8d9adc9 | 204 | { // Publish a message every second |
rozendhyan@gmail.com | 4:3642f63079ec | 205 | serial.printf("temp = %3.1f\r\n", ds1820.read()); // read temperature |
rozendhyan@gmail.com | 4:3642f63079ec | 206 | databuffer = ds1820.read(); |
rozendhyan@gmail.com | 4:3642f63079ec | 207 | ds1820.startConversion(); // start temperature conversion |
rozendhyan@gmail.com | 4:3642f63079ec | 208 | wait(1.0); // let DS1820 complete the temperature conversion |
e58136782000 | 3:30d9b8d9adc9 | 209 | if (publish(&client, &ipstack,databuffer) != 0) |
e58136782000 | 3:30d9b8d9adc9 | 210 | { |
e58136782000 | 3:30d9b8d9adc9 | 211 | attemptConnect(&client, &ipstack); // if we have lost the connection |
e58136782000 | 3:30d9b8d9adc9 | 212 | } |
e58136782000 | 3:30d9b8d9adc9 | 213 | count = 0; |
e58136782000 | 3:30d9b8d9adc9 | 214 | } |
e58136782000 | 3:30d9b8d9adc9 | 215 | else |
e58136782000 | 3:30d9b8d9adc9 | 216 | { |
e58136782000 | 3:30d9b8d9adc9 | 217 | serial.printf("count: %d \n",count); |
rozendhyan@gmail.com | 4:3642f63079ec | 218 | } |
e58136782000 | 3:30d9b8d9adc9 | 219 | // int start = tyeld.read_ms(); |
rozendhyan@gmail.com | 4:3642f63079ec | 220 | //client.yield(10); // allow the MQTT client to receive messages |
e58136782000 | 3:30d9b8d9adc9 | 221 | // printf ("tyeld: %d\n\r",tyeld.read_ms()-start); |
e58136782000 | 3:30d9b8d9adc9 | 222 | } |
rozendhyan@gmail.com | 0:80c7778c82b8 | 223 | } |