SmartREST client reference implementation for the u-blox C027 mbed compatible device.
Dependencies: C027 C027_Support mbed mbed-rtos MbedSmartRest LM75B MMA7660 C12832
Fork of MbedSmartRestTest by
program.cpp@24:8f9b678a7932, 2014-04-15 (annotated)
- Committer:
- vwochnik
- Date:
- Tue Apr 15 16:59:56 2014 +0000
- Revision:
- 24:8f9b678a7932
- Parent:
- 20:ef9cc1b42e9d
- Child:
- 25:8604bef314c1
fix
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
vwochnik | 6:642e7c233e83 | 1 | #include "common.h" |
vwochnik | 12:beb64aa0da86 | 2 | #include "io.h" |
vwochnik | 6:642e7c233e83 | 3 | #include "StaticData.h" |
vwochnik | 6:642e7c233e83 | 4 | #include "ComposedRecord.h" |
vwochnik | 6:642e7c233e83 | 5 | #include "CharValue.h" |
vwochnik | 6:642e7c233e83 | 6 | #include "IntegerValue.h" |
vwochnik | 6:642e7c233e83 | 7 | #include "FloatValue.h" |
vwochnik | 13:4045b6ac448d | 8 | #include "Aggregator.h" |
vwochnik | 6:642e7c233e83 | 9 | |
vwochnik | 8:940c782eec5e | 10 | long existing(); |
vwochnik | 8:940c782eec5e | 11 | long create(); |
vwochnik | 8:940c782eec5e | 12 | bool identify(long deviceId); |
vwochnik | 8:940c782eec5e | 13 | bool update(long deviceId); |
vwochnik | 8:940c782eec5e | 14 | void loop(long deviceId); |
vwochnik | 13:4045b6ac448d | 15 | void signalMeasurement(long deviceId, Aggregator& aggr); |
vwochnik | 13:4045b6ac448d | 16 | void temperatureMeasurement(long deviceId, Aggregator& aggr); |
vwochnik | 19:7bee744fe527 | 17 | void analogMeasurement(long deviceId, Aggregator& aggr); |
vwochnik | 13:4045b6ac448d | 18 | void motionMeasurement(long deviceId, Aggregator& aggr); |
vwochnik | 8:940c782eec5e | 19 | |
vwochnik | 6:642e7c233e83 | 20 | StaticData srtpl( |
vwochnik | 6:642e7c233e83 | 21 | // get device by identity |
vwochnik | 6:642e7c233e83 | 22 | // Usage: 100,<SERIAL/NR> |
vwochnik | 6:642e7c233e83 | 23 | "10,100,GET,/identity/externalIds/c8y_Serial/%%,,application/vnd.com.nsn.cumulocity.externalId+json,%%,STRING,\r\n" |
vwochnik | 6:642e7c233e83 | 24 | // get device id from identity |
vwochnik | 6:642e7c233e83 | 25 | // Response: 200,<DEVICE/ID> |
vwochnik | 6:642e7c233e83 | 26 | "11,200,\"$.managedObject\",,\"$.id\"\r\n" |
vwochnik | 6:642e7c233e83 | 27 | // Create device |
vwochnik | 6:642e7c233e83 | 28 | // Usage: 101,<SERIAL/NR> |
vwochnik | 19:7bee744fe527 | 29 | "10,101,POST,/inventory/managedObjects,application/vnd.com.nsn.cumulocity.managedObject+json,application/vnd.com.nsn.cumulocity.managedObject+json,%%,STRING,\"{\"\"name\"\":\"\"Mbed Test Device\"\",\"\"type\"\":\"\"com_ublox_C027_REV-A\"\",\"\"c8y_Hardware\"\":{\"\"revision\"\":\"\"1\"\",\"\"model\"\":\"\"Ublox C027\"\",\"\"serialNumber\"\":\"\"%%\"\"},\"\"c8y_SupportedMeasurements\"\":[\"\"c8y_SignalStrength\"\",\"\"c8y_TemperatureMeasurement\"\",\"\"c8y_AnalogMeasurement\"\",\"\"c8y_MotionMeasurement\"\"],\"\"c8y_RequiredAvailability\"\":{ \"\"responseInterval\"\":15},\"\"c8y_IsDevice\"\":{}}\"\r\n" |
vwochnik | 6:642e7c233e83 | 30 | // Get device id |
vwochnik | 6:642e7c233e83 | 31 | // Response: 201,<DEVICE/ID> |
vwochnik | 6:642e7c233e83 | 32 | "11,201,,\"$.c8y_IsDevice\",\"$.id\"\r\n" |
vwochnik | 6:642e7c233e83 | 33 | // Insert global ID |
vwochnik | 6:642e7c233e83 | 34 | // Usage: 102,<DEVICE/ID>,<SERIAL/NR> |
vwochnik | 6:642e7c233e83 | 35 | "10,102,POST,/identity/globalIds/%%/externalIds,application/vnd.com.nsn.cumulocity.externalId+json,application/vnd.com.nsn.cumulocity.externalId+json,%%,UNSIGNED STRING,\"{\"\"type\"\":\"\"c8y_Serial\"\",\"\"externalId\"\":\"\"%%\"\"}\"\r\n" |
vwochnik | 7:f77afd49c35d | 36 | // Update IMEI, CellId and iccid |
vwochnik | 7:f77afd49c35d | 37 | // Usage: 103,<DEVICE/ID>,<IMEI>,<CELL/ID>,<ICCID> |
vwochnik | 7:f77afd49c35d | 38 | "10,103,PUT,/inventory/managedObjects/%%,application/vnd.com.nsn.cumulocity.managedObject+json,application/vnd.com.nsn.cumulocity.managedObject+json,%%,UNSIGNED STRING STRING STRING,\"{\"\"c8y_Mobile\"\":{\"\"imei\"\":\"\"%%\"\",\"\"cellId\"\":\"\"%%\"\",\"\"iccid\"\":\"\"%%\"\"}}\"\r\n" |
vwochnik | 6:642e7c233e83 | 39 | // Insert measurement |
vwochnik | 7:f77afd49c35d | 40 | // USAGE: 104,<DEVICE/ID>,<RSSI>,<BER> |
vwochnik | 7:f77afd49c35d | 41 | "10,104,POST,/measurement/measurements,application/vnd.com.nsn.cumulocity.measurement+json,application/vnd.com.nsn.cumulocity.measurement+json,%%,NOW UNSIGNED NUMBER UNSIGNED,\"{\"\"time\"\":\"\"%%\"\",\"\"source\"\":{\"\"id\"\":\"\"%%\"\"},\"\"type\"\":\"\"c8y_SignalStrength\"\",\"\"c8y_SignalStrength\"\":{\"\"rssi\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"dBm\"\"},\"\"ber\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"%\"\"}}}\"\r\n" |
vwochnik | 13:4045b6ac448d | 42 | // Insert measurement |
vwochnik | 13:4045b6ac448d | 43 | // USAGE: 105,<DEVICE/ID>,<TEMPERATURE> |
vwochnik | 13:4045b6ac448d | 44 | "10,105,POST,/measurement/measurements,application/vnd.com.nsn.cumulocity.measurement+json,application/vnd.com.nsn.cumulocity.measurement+json,%%,NOW UNSIGNED NUMBER,\"{\"\"time\"\":\"\"%%\"\",\"\"source\"\":{\"\"id\"\":\"\"%%\"\"},\"\"type\"\":\"\"c8y_TemperatureMeasurement\"\",\"\"c8y_TemperatureMeasurement\"\":{\"\"T\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"C\"\"}}}\"\r\n" |
vwochnik | 13:4045b6ac448d | 45 | // Insert measurement |
vwochnik | 19:7bee744fe527 | 46 | // USAGE: 105,<DEVICE/ID>,<ANALOG0>,<ANALOG1> |
vwochnik | 19:7bee744fe527 | 47 | "10,106,POST,/measurement/measurements,application/vnd.com.nsn.cumulocity.measurement+json,application/vnd.com.nsn.cumulocity.measurement+json,%%,NOW UNSIGNED UNSIGNED UNSIGNED,\"{\"\"time\"\":\"\"%%\"\",\"\"source\"\":{\"\"id\"\":\"\"%%\"\"},\"\"type\"\":\"\"c8y_AnalogMeasurement\"\",\"\"c8y_AnalogMeasurement\"\":{\"\"analog0\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"%\"\"},\"\"analog1\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"%\"\"}}}\"\r\n" |
vwochnik | 13:4045b6ac448d | 48 | // Insert measurement |
vwochnik | 13:4045b6ac448d | 49 | // USAGE: 105,<DEVICE/ID>,<X>,<Y>,<Z> |
vwochnik | 13:4045b6ac448d | 50 | "10,107,POST,/measurement/measurements,application/vnd.com.nsn.cumulocity.measurement+json,application/vnd.com.nsn.cumulocity.measurement+json,%%,NOW UNSIGNED NUMBER NUMBER NUMBER,\"{\"\"time\"\":\"\"%%\"\",\"\"source\"\":{\"\"id\"\":\"\"%%\"\"},\"\"type\"\":\"\"c8y_MotionMeasurement\"\",\"\"c8y_MotionMeasurement\"\":{\"\"x\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"m^2/s\"\"},\"\"y\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"m^2/s\"\"},\"\"z\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"m^2/s\"\"}}}\"\r\n" |
vwochnik | 6:642e7c233e83 | 51 | ); |
vwochnik | 6:642e7c233e83 | 52 | |
vwochnik | 8:940c782eec5e | 53 | float interval = 120.0; // send measurements every two minutes |
vwochnik | 24:8f9b678a7932 | 54 | MbedSmartRest client("developer.cumulocity.com", 80, "vaillant/admin", "klanpi", "com_u-blox_C027_REV-A_0.10_Test1233123"); |
vwochnik | 24:8f9b678a7932 | 55 | //MbedSmartRest client("vsrv41584.customer.xenway.de", 8888, "vaillant/admin", "klanpi", "com_u-blox_C027_REV-A_0.10_Test123"); |
vwochnik | 6:642e7c233e83 | 56 | |
vwochnik | 6:642e7c233e83 | 57 | int program(void) |
vwochnik | 6:642e7c233e83 | 58 | { |
vwochnik | 15:0ccf0f530a05 | 59 | long deviceId = 0; Timer timer; |
vwochnik | 8:940c782eec5e | 60 | |
vwochnik | 20:ef9cc1b42e9d | 61 | lcd_tenant("vaillant"); |
vwochnik | 6:642e7c233e83 | 62 | puts("Hello!"); |
vwochnik | 24:8f9b678a7932 | 63 | |
vwochnik | 6:642e7c233e83 | 64 | puts("Bootstrapping"); |
vwochnik | 20:ef9cc1b42e9d | 65 | lcd_status("Bootstrapping"); |
vwochnik | 6:642e7c233e83 | 66 | if (client.bootstrap(srtpl) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 67 | puts("Bootstrapping failed."); |
vwochnik | 20:ef9cc1b42e9d | 68 | lcd_status("Bootstrapping failed."); |
vwochnik | 6:642e7c233e83 | 69 | return 2; |
vwochnik | 6:642e7c233e83 | 70 | } |
vwochnik | 24:8f9b678a7932 | 71 | |
vwochnik | 6:642e7c233e83 | 72 | puts("Starting action..."); |
vwochnik | 6:642e7c233e83 | 73 | |
vwochnik | 6:642e7c233e83 | 74 | if ((deviceId = existing()) == 0) { |
vwochnik | 20:ef9cc1b42e9d | 75 | if (((deviceId = create()) == 0) || (!identify(deviceId))) { |
vwochnik | 20:ef9cc1b42e9d | 76 | lcd_status("Device creation failed."); |
vwochnik | 7:f77afd49c35d | 77 | return 1; |
vwochnik | 20:ef9cc1b42e9d | 78 | } |
vwochnik | 6:642e7c233e83 | 79 | } |
vwochnik | 19:7bee744fe527 | 80 | update(deviceId); |
vwochnik | 6:642e7c233e83 | 81 | |
vwochnik | 6:642e7c233e83 | 82 | printf("Device ID: %ld\r\n", deviceId); |
vwochnik | 8:940c782eec5e | 83 | |
vwochnik | 8:940c782eec5e | 84 | timer.start(); |
vwochnik | 7:f77afd49c35d | 85 | while (true) { |
vwochnik | 8:940c782eec5e | 86 | timer.reset(); |
vwochnik | 8:940c782eec5e | 87 | loop(deviceId); |
vwochnik | 8:940c782eec5e | 88 | |
vwochnik | 20:ef9cc1b42e9d | 89 | lcd_status("Sleeping..."); |
vwochnik | 8:940c782eec5e | 90 | // block remaining number of seconds |
vwochnik | 16:94d6eae3195a | 91 | while (timer.read() < interval) { |
vwochnik | 16:94d6eae3195a | 92 | Thread::yield(); |
vwochnik | 16:94d6eae3195a | 93 | } |
vwochnik | 6:642e7c233e83 | 94 | } |
vwochnik | 6:642e7c233e83 | 95 | } |
vwochnik | 6:642e7c233e83 | 96 | |
vwochnik | 6:642e7c233e83 | 97 | long existing() |
vwochnik | 6:642e7c233e83 | 98 | { |
vwochnik | 6:642e7c233e83 | 99 | ComposedRecord newMoRec(true); // set copy=true b/c tmp objects |
vwochnik | 6:642e7c233e83 | 100 | ParsedRecord received; |
vwochnik | 6:642e7c233e83 | 101 | |
vwochnik | 20:ef9cc1b42e9d | 102 | lcd_status("Checking device existance..."); |
vwochnik | 6:642e7c233e83 | 103 | puts("Checking for device existance..."); |
vwochnik | 6:642e7c233e83 | 104 | |
vwochnik | 12:beb64aa0da86 | 105 | newMoRec.add(IntegerValue(100)).add(CharValue(imei())); |
vwochnik | 6:642e7c233e83 | 106 | |
vwochnik | 6:642e7c233e83 | 107 | if (client.send(newMoRec) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 108 | puts("Send failed."); |
vwochnik | 10:d5cd4a7ada7b | 109 | client.stop(); |
vwochnik | 6:642e7c233e83 | 110 | return 0; |
vwochnik | 6:642e7c233e83 | 111 | } |
vwochnik | 6:642e7c233e83 | 112 | |
vwochnik | 6:642e7c233e83 | 113 | if (client.receive(received) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 114 | puts("No device found."); |
vwochnik | 10:d5cd4a7ada7b | 115 | client.stop(); |
vwochnik | 6:642e7c233e83 | 116 | return 0; |
vwochnik | 6:642e7c233e83 | 117 | } |
vwochnik | 6:642e7c233e83 | 118 | |
vwochnik | 6:642e7c233e83 | 119 | if (received.values() == 0) { |
vwochnik | 6:642e7c233e83 | 120 | puts("Received no values."); |
vwochnik | 10:d5cd4a7ada7b | 121 | client.stop(); |
vwochnik | 6:642e7c233e83 | 122 | return 0; |
vwochnik | 6:642e7c233e83 | 123 | } |
vwochnik | 10:d5cd4a7ada7b | 124 | |
vwochnik | 6:642e7c233e83 | 125 | if (received.value(0).integerValue() == 50) { |
vwochnik | 6:642e7c233e83 | 126 | client.stop(); |
vwochnik | 6:642e7c233e83 | 127 | return 0; |
vwochnik | 6:642e7c233e83 | 128 | } |
vwochnik | 6:642e7c233e83 | 129 | |
vwochnik | 6:642e7c233e83 | 130 | if (received.value(0).integerValue() != 200) { |
vwochnik | 6:642e7c233e83 | 131 | puts("Bad response."); |
vwochnik | 10:d5cd4a7ada7b | 132 | client.stop(); |
vwochnik | 6:642e7c233e83 | 133 | return 0; |
vwochnik | 6:642e7c233e83 | 134 | } |
vwochnik | 6:642e7c233e83 | 135 | |
vwochnik | 6:642e7c233e83 | 136 | client.stop(); |
vwochnik | 6:642e7c233e83 | 137 | return received.value(2).integerValue(); |
vwochnik | 6:642e7c233e83 | 138 | } |
vwochnik | 6:642e7c233e83 | 139 | |
vwochnik | 6:642e7c233e83 | 140 | long create() |
vwochnik | 6:642e7c233e83 | 141 | { |
vwochnik | 6:642e7c233e83 | 142 | ComposedRecord newMoRec(true); // set copy=true b/c tmp objects |
vwochnik | 6:642e7c233e83 | 143 | ParsedRecord received; |
vwochnik | 6:642e7c233e83 | 144 | |
vwochnik | 20:ef9cc1b42e9d | 145 | lcd_status("Creating device..."); |
vwochnik | 6:642e7c233e83 | 146 | puts("Creating device..."); |
vwochnik | 6:642e7c233e83 | 147 | |
vwochnik | 12:beb64aa0da86 | 148 | newMoRec.add(IntegerValue(101)).add(CharValue(imei())); |
vwochnik | 6:642e7c233e83 | 149 | |
vwochnik | 6:642e7c233e83 | 150 | if (client.send(newMoRec) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 151 | puts("Send failed."); |
vwochnik | 10:d5cd4a7ada7b | 152 | client.stop(); |
vwochnik | 6:642e7c233e83 | 153 | return 0; |
vwochnik | 6:642e7c233e83 | 154 | } |
vwochnik | 6:642e7c233e83 | 155 | |
vwochnik | 6:642e7c233e83 | 156 | if (client.receive(received) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 157 | puts("No device found."); |
vwochnik | 10:d5cd4a7ada7b | 158 | client.stop(); |
vwochnik | 6:642e7c233e83 | 159 | return 0; |
vwochnik | 6:642e7c233e83 | 160 | } |
vwochnik | 6:642e7c233e83 | 161 | |
vwochnik | 6:642e7c233e83 | 162 | if (received.values() != 3) { |
vwochnik | 6:642e7c233e83 | 163 | puts("Bad received data."); |
vwochnik | 10:d5cd4a7ada7b | 164 | client.stop(); |
vwochnik | 6:642e7c233e83 | 165 | return 0; |
vwochnik | 6:642e7c233e83 | 166 | } |
vwochnik | 6:642e7c233e83 | 167 | |
vwochnik | 6:642e7c233e83 | 168 | if (received.value(0).integerValue() != 201) { |
vwochnik | 6:642e7c233e83 | 169 | puts("Bad received data."); |
vwochnik | 10:d5cd4a7ada7b | 170 | client.stop(); |
vwochnik | 6:642e7c233e83 | 171 | return 0; |
vwochnik | 6:642e7c233e83 | 172 | } |
vwochnik | 6:642e7c233e83 | 173 | |
vwochnik | 6:642e7c233e83 | 174 | client.stop(); |
vwochnik | 6:642e7c233e83 | 175 | return received.value(2).integerValue(); |
vwochnik | 6:642e7c233e83 | 176 | } |
vwochnik | 6:642e7c233e83 | 177 | |
vwochnik | 6:642e7c233e83 | 178 | bool identify(long deviceId) |
vwochnik | 6:642e7c233e83 | 179 | { |
vwochnik | 6:642e7c233e83 | 180 | ComposedRecord newMoRec(true); // set copy=true b/c tmp objects |
vwochnik | 6:642e7c233e83 | 181 | ParsedRecord received; |
vwochnik | 6:642e7c233e83 | 182 | |
vwochnik | 6:642e7c233e83 | 183 | puts("Adding global identifier..."); |
vwochnik | 6:642e7c233e83 | 184 | |
vwochnik | 12:beb64aa0da86 | 185 | newMoRec.add(IntegerValue(102)).add(IntegerValue(deviceId)).add(CharValue(imei())); |
vwochnik | 6:642e7c233e83 | 186 | |
vwochnik | 6:642e7c233e83 | 187 | if (client.send(newMoRec) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 188 | puts("Sending failed."); |
vwochnik | 10:d5cd4a7ada7b | 189 | client.stop(); |
vwochnik | 6:642e7c233e83 | 190 | return false; |
vwochnik | 6:642e7c233e83 | 191 | } |
vwochnik | 6:642e7c233e83 | 192 | |
vwochnik | 6:642e7c233e83 | 193 | if (client.receive(received) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 194 | puts("Failed."); |
vwochnik | 10:d5cd4a7ada7b | 195 | client.stop(); |
vwochnik | 6:642e7c233e83 | 196 | return false; |
vwochnik | 6:642e7c233e83 | 197 | } |
vwochnik | 6:642e7c233e83 | 198 | |
vwochnik | 6:642e7c233e83 | 199 | if (received.values() != 3) { |
vwochnik | 6:642e7c233e83 | 200 | puts("Received bad data."); |
vwochnik | 10:d5cd4a7ada7b | 201 | client.stop(); |
vwochnik | 6:642e7c233e83 | 202 | return false; |
vwochnik | 6:642e7c233e83 | 203 | } |
vwochnik | 6:642e7c233e83 | 204 | |
vwochnik | 6:642e7c233e83 | 205 | if (received.value(0).integerValue() != 200) { |
vwochnik | 6:642e7c233e83 | 206 | puts("Received bad data."); |
vwochnik | 10:d5cd4a7ada7b | 207 | client.stop(); |
vwochnik | 6:642e7c233e83 | 208 | return false; |
vwochnik | 6:642e7c233e83 | 209 | } |
vwochnik | 6:642e7c233e83 | 210 | |
vwochnik | 6:642e7c233e83 | 211 | client.stop(); |
vwochnik | 6:642e7c233e83 | 212 | return true; |
vwochnik | 6:642e7c233e83 | 213 | } |
vwochnik | 6:642e7c233e83 | 214 | |
vwochnik | 7:f77afd49c35d | 215 | bool update(long deviceId) |
vwochnik | 7:f77afd49c35d | 216 | { |
vwochnik | 7:f77afd49c35d | 217 | ComposedRecord newMoRec(true); // set copy=true b/c tmp objects |
vwochnik | 7:f77afd49c35d | 218 | ParsedRecord received; |
vwochnik | 7:f77afd49c35d | 219 | |
vwochnik | 20:ef9cc1b42e9d | 220 | lcd_status("Updating device object..."); |
vwochnik | 7:f77afd49c35d | 221 | puts("Updating device data..."); |
vwochnik | 7:f77afd49c35d | 222 | |
vwochnik | 7:f77afd49c35d | 223 | newMoRec.add(IntegerValue(103)).add(IntegerValue(deviceId)).add(CharValue(imei())).add(CharValue(cellId())).add(CharValue(iccid())); |
vwochnik | 7:f77afd49c35d | 224 | |
vwochnik | 7:f77afd49c35d | 225 | if (client.send(newMoRec) != SMARTREST_SUCCESS) { |
vwochnik | 7:f77afd49c35d | 226 | puts("Send failed."); |
vwochnik | 10:d5cd4a7ada7b | 227 | client.stop(); |
vwochnik | 7:f77afd49c35d | 228 | return false; |
vwochnik | 7:f77afd49c35d | 229 | } |
vwochnik | 7:f77afd49c35d | 230 | |
vwochnik | 7:f77afd49c35d | 231 | if (client.receive(received) != SMARTREST_SUCCESS) { |
vwochnik | 7:f77afd49c35d | 232 | puts("Update failed."); |
vwochnik | 10:d5cd4a7ada7b | 233 | client.stop(); |
vwochnik | 7:f77afd49c35d | 234 | return false; |
vwochnik | 7:f77afd49c35d | 235 | } |
vwochnik | 7:f77afd49c35d | 236 | |
vwochnik | 7:f77afd49c35d | 237 | if (received.values() != 3) { |
vwochnik | 7:f77afd49c35d | 238 | puts("Bad received data."); |
vwochnik | 10:d5cd4a7ada7b | 239 | client.stop(); |
vwochnik | 7:f77afd49c35d | 240 | return false; |
vwochnik | 7:f77afd49c35d | 241 | } |
vwochnik | 7:f77afd49c35d | 242 | |
vwochnik | 7:f77afd49c35d | 243 | if (received.value(0).integerValue() != 201) { |
vwochnik | 7:f77afd49c35d | 244 | puts("Bad received data."); |
vwochnik | 10:d5cd4a7ada7b | 245 | client.stop(); |
vwochnik | 7:f77afd49c35d | 246 | return false; |
vwochnik | 7:f77afd49c35d | 247 | } |
vwochnik | 7:f77afd49c35d | 248 | |
vwochnik | 7:f77afd49c35d | 249 | client.stop(); |
vwochnik | 7:f77afd49c35d | 250 | |
vwochnik | 7:f77afd49c35d | 251 | return true; |
vwochnik | 7:f77afd49c35d | 252 | } |
vwochnik | 7:f77afd49c35d | 253 | |
vwochnik | 8:940c782eec5e | 254 | void loop(long deviceId) |
vwochnik | 8:940c782eec5e | 255 | { |
vwochnik | 13:4045b6ac448d | 256 | Aggregator aggr(5, false, true); |
vwochnik | 8:940c782eec5e | 257 | |
vwochnik | 20:ef9cc1b42e9d | 258 | lcd_status("Sending measurements..."); |
vwochnik | 13:4045b6ac448d | 259 | signalMeasurement(deviceId, aggr); |
vwochnik | 15:0ccf0f530a05 | 260 | if (client.send(aggr) != SMARTREST_SUCCESS) { |
vwochnik | 15:0ccf0f530a05 | 261 | puts("Send failed."); |
vwochnik | 15:0ccf0f530a05 | 262 | } |
vwochnik | 15:0ccf0f530a05 | 263 | client.stop(); |
vwochnik | 15:0ccf0f530a05 | 264 | aggr.clear(); |
vwochnik | 13:4045b6ac448d | 265 | temperatureMeasurement(deviceId, aggr); |
vwochnik | 19:7bee744fe527 | 266 | analogMeasurement(deviceId, aggr); |
vwochnik | 15:0ccf0f530a05 | 267 | if (client.send(aggr) != SMARTREST_SUCCESS) { |
vwochnik | 15:0ccf0f530a05 | 268 | puts("Send failed."); |
vwochnik | 15:0ccf0f530a05 | 269 | } |
vwochnik | 15:0ccf0f530a05 | 270 | client.stop(); |
vwochnik | 15:0ccf0f530a05 | 271 | aggr.clear(); |
vwochnik | 13:4045b6ac448d | 272 | motionMeasurement(deviceId, aggr); |
vwochnik | 6:642e7c233e83 | 273 | |
vwochnik | 13:4045b6ac448d | 274 | if (client.send(aggr) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 275 | puts("Send failed."); |
vwochnik | 6:642e7c233e83 | 276 | } |
vwochnik | 6:642e7c233e83 | 277 | client.stop(); |
vwochnik | 13:4045b6ac448d | 278 | } |
vwochnik | 13:4045b6ac448d | 279 | |
vwochnik | 13:4045b6ac448d | 280 | void signalMeasurement(long deviceId, Aggregator& aggr) |
vwochnik | 13:4045b6ac448d | 281 | { |
vwochnik | 13:4045b6ac448d | 282 | sigq_t *sq = signalQuality(); |
vwochnik | 13:4045b6ac448d | 283 | |
vwochnik | 13:4045b6ac448d | 284 | if ((sq->rssi == 0) || (sq->ber == 0)) |
vwochnik | 13:4045b6ac448d | 285 | return; |
vwochnik | 13:4045b6ac448d | 286 | |
vwochnik | 13:4045b6ac448d | 287 | ComposedRecord measurement; |
vwochnik | 13:4045b6ac448d | 288 | IntegerValue msgId(104); |
vwochnik | 13:4045b6ac448d | 289 | IntegerValue devId(deviceId); |
vwochnik | 13:4045b6ac448d | 290 | FloatValue rssi(sq->rssi, 0); |
vwochnik | 13:4045b6ac448d | 291 | IntegerValue ber(sq->ber); |
vwochnik | 13:4045b6ac448d | 292 | measurement.add(msgId).add(devId).add(rssi).add(ber); |
vwochnik | 13:4045b6ac448d | 293 | aggr.add(measurement); |
vwochnik | 10:d5cd4a7ada7b | 294 | } |
vwochnik | 13:4045b6ac448d | 295 | |
vwochnik | 13:4045b6ac448d | 296 | void temperatureMeasurement(long deviceId, Aggregator& aggr) |
vwochnik | 13:4045b6ac448d | 297 | { |
vwochnik | 13:4045b6ac448d | 298 | ComposedRecord measurement; |
vwochnik | 13:4045b6ac448d | 299 | IntegerValue msgId(105); |
vwochnik | 13:4045b6ac448d | 300 | IntegerValue devId(deviceId); |
vwochnik | 13:4045b6ac448d | 301 | FloatValue temp(temperature(), 1); |
vwochnik | 13:4045b6ac448d | 302 | measurement.add(msgId).add(devId).add(temp); |
vwochnik | 13:4045b6ac448d | 303 | aggr.add(measurement); |
vwochnik | 13:4045b6ac448d | 304 | } |
vwochnik | 13:4045b6ac448d | 305 | |
vwochnik | 19:7bee744fe527 | 306 | void analogMeasurement(long deviceId, Aggregator& aggr) |
vwochnik | 13:4045b6ac448d | 307 | { |
vwochnik | 19:7bee744fe527 | 308 | long analog0 = (long)(potentiometer(0) * 100.0); |
vwochnik | 19:7bee744fe527 | 309 | long analog1 = (long)(potentiometer(1) * 100.0); |
vwochnik | 13:4045b6ac448d | 310 | ComposedRecord measurement; |
vwochnik | 13:4045b6ac448d | 311 | IntegerValue msgId(106); |
vwochnik | 13:4045b6ac448d | 312 | IntegerValue devId(deviceId); |
vwochnik | 19:7bee744fe527 | 313 | IntegerValue an0(analog0); |
vwochnik | 19:7bee744fe527 | 314 | IntegerValue an1(analog1); |
vwochnik | 19:7bee744fe527 | 315 | measurement.add(msgId).add(devId).add(an0).add(an1); |
vwochnik | 13:4045b6ac448d | 316 | aggr.add(measurement); |
vwochnik | 13:4045b6ac448d | 317 | } |
vwochnik | 13:4045b6ac448d | 318 | |
vwochnik | 13:4045b6ac448d | 319 | void motionMeasurement(long deviceId, Aggregator& aggr) |
vwochnik | 13:4045b6ac448d | 320 | { |
vwochnik | 13:4045b6ac448d | 321 | acceleration_t acc = acceleration(); |
vwochnik | 13:4045b6ac448d | 322 | ComposedRecord measurement; |
vwochnik | 13:4045b6ac448d | 323 | IntegerValue msgId(107); |
vwochnik | 13:4045b6ac448d | 324 | IntegerValue devId(deviceId); |
vwochnik | 13:4045b6ac448d | 325 | FloatValue x(acc.x, 2); |
vwochnik | 13:4045b6ac448d | 326 | FloatValue y(acc.y, 2); |
vwochnik | 13:4045b6ac448d | 327 | FloatValue z(acc.z, 2); |
vwochnik | 13:4045b6ac448d | 328 | measurement.add(msgId).add(devId).add(x).add(y).add(z); |
vwochnik | 13:4045b6ac448d | 329 | aggr.add(measurement); |
vwochnik | 13:4045b6ac448d | 330 | } |