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@8:940c782eec5e, 2014-02-12 (annotated)
- Committer:
- vwochnik
- Date:
- Wed Feb 12 12:13:36 2014 +0000
- Revision:
- 8:940c782eec5e
- Parent:
- 7:f77afd49c35d
- Child:
- 9:5e182f6e5e9b
fix
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
vwochnik | 6:642e7c233e83 | 1 | #include "common.h" |
vwochnik | 6:642e7c233e83 | 2 | #include "StaticData.h" |
vwochnik | 6:642e7c233e83 | 3 | #include "ComposedRecord.h" |
vwochnik | 6:642e7c233e83 | 4 | #include "CharValue.h" |
vwochnik | 6:642e7c233e83 | 5 | #include "IntegerValue.h" |
vwochnik | 6:642e7c233e83 | 6 | #include "FloatValue.h" |
vwochnik | 6:642e7c233e83 | 7 | |
vwochnik | 8:940c782eec5e | 8 | long existing(); |
vwochnik | 8:940c782eec5e | 9 | long create(); |
vwochnik | 8:940c782eec5e | 10 | bool identify(long deviceId); |
vwochnik | 8:940c782eec5e | 11 | bool update(long deviceId); |
vwochnik | 8:940c782eec5e | 12 | void loop(long deviceId); |
vwochnik | 8:940c782eec5e | 13 | bool measurement(long deviceId, double rssi, int ber); |
vwochnik | 8:940c782eec5e | 14 | |
vwochnik | 6:642e7c233e83 | 15 | StaticData srtpl( |
vwochnik | 6:642e7c233e83 | 16 | // get device by identity |
vwochnik | 6:642e7c233e83 | 17 | // Usage: 100,<SERIAL/NR> |
vwochnik | 6:642e7c233e83 | 18 | "10,100,GET,/identity/externalIds/c8y_Serial/%%,,application/vnd.com.nsn.cumulocity.externalId+json,%%,STRING,\r\n" |
vwochnik | 6:642e7c233e83 | 19 | // get device id from identity |
vwochnik | 6:642e7c233e83 | 20 | // Response: 200,<DEVICE/ID> |
vwochnik | 6:642e7c233e83 | 21 | "11,200,\"$.managedObject\",,\"$.id\"\r\n" |
vwochnik | 6:642e7c233e83 | 22 | // Create device |
vwochnik | 6:642e7c233e83 | 23 | // Usage: 101,<SERIAL/NR> |
vwochnik | 8:940c782eec5e | 24 | "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\"\":\"\"Curl Test Device\"\",\"\"serialNumber\"\":\"\"%%\"\"},\"\"c8y_SupportedMeasurements\"\":[\"\"c8y_SignalStrength\"\"],\"\"c8y_RequiredAvailability\"\":{ \"\"responseInterval\"\":15},\"\"c8y_IsDevice\"\":{}}\"\r\n" |
vwochnik | 6:642e7c233e83 | 25 | // Get device id |
vwochnik | 6:642e7c233e83 | 26 | // Response: 201,<DEVICE/ID> |
vwochnik | 6:642e7c233e83 | 27 | "11,201,,\"$.c8y_IsDevice\",\"$.id\"\r\n" |
vwochnik | 6:642e7c233e83 | 28 | // Insert global ID |
vwochnik | 6:642e7c233e83 | 29 | // Usage: 102,<DEVICE/ID>,<SERIAL/NR> |
vwochnik | 6:642e7c233e83 | 30 | "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 | 31 | // Update IMEI, CellId and iccid |
vwochnik | 7:f77afd49c35d | 32 | // Usage: 103,<DEVICE/ID>,<IMEI>,<CELL/ID>,<ICCID> |
vwochnik | 7:f77afd49c35d | 33 | "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 | 34 | // Insert measurement |
vwochnik | 7:f77afd49c35d | 35 | // USAGE: 104,<DEVICE/ID>,<RSSI>,<BER> |
vwochnik | 7:f77afd49c35d | 36 | "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 | 6:642e7c233e83 | 37 | ); |
vwochnik | 6:642e7c233e83 | 38 | |
vwochnik | 8:940c782eec5e | 39 | const char * const serialNumber = "ublox-2a354bd"; |
vwochnik | 8:940c782eec5e | 40 | float interval = 120.0; // send measurements every two minutes |
vwochnik | 8:940c782eec5e | 41 | MbedSmartRest client("http://developer.cumulocity.com/s", "vaillant/admin", "klanpi", "com_u-blox_C027_REV-A_0.6"); |
vwochnik | 6:642e7c233e83 | 42 | //MbedSmartRest client("http://nocore.info:8888/", "vaillant/admin", "klanpi", "com_cumulocity_MbedTestDevice_2.0"); |
vwochnik | 6:642e7c233e83 | 43 | |
vwochnik | 6:642e7c233e83 | 44 | int program(void) |
vwochnik | 6:642e7c233e83 | 45 | { |
vwochnik | 8:940c782eec5e | 46 | long deviceId; Timer timer; |
vwochnik | 8:940c782eec5e | 47 | |
vwochnik | 6:642e7c233e83 | 48 | puts("Hello!"); |
vwochnik | 6:642e7c233e83 | 49 | |
vwochnik | 6:642e7c233e83 | 50 | puts("Bootstrapping"); |
vwochnik | 6:642e7c233e83 | 51 | if (client.bootstrap(srtpl) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 52 | puts("Bootstrapping failed."); |
vwochnik | 6:642e7c233e83 | 53 | return 2; |
vwochnik | 6:642e7c233e83 | 54 | } |
vwochnik | 6:642e7c233e83 | 55 | |
vwochnik | 6:642e7c233e83 | 56 | puts("Starting action..."); |
vwochnik | 6:642e7c233e83 | 57 | |
vwochnik | 6:642e7c233e83 | 58 | if ((deviceId = existing()) == 0) { |
vwochnik | 6:642e7c233e83 | 59 | deviceId = create(); |
vwochnik | 7:f77afd49c35d | 60 | if (deviceId == 0) |
vwochnik | 7:f77afd49c35d | 61 | return 1; |
vwochnik | 7:f77afd49c35d | 62 | if (!identify(deviceId)) |
vwochnik | 7:f77afd49c35d | 63 | return 2; |
vwochnik | 6:642e7c233e83 | 64 | } |
vwochnik | 7:f77afd49c35d | 65 | if (!update(deviceId)) |
vwochnik | 7:f77afd49c35d | 66 | return 3; |
vwochnik | 6:642e7c233e83 | 67 | |
vwochnik | 6:642e7c233e83 | 68 | printf("Device ID: %ld\r\n", deviceId); |
vwochnik | 8:940c782eec5e | 69 | |
vwochnik | 8:940c782eec5e | 70 | timer.start(); |
vwochnik | 7:f77afd49c35d | 71 | while (true) { |
vwochnik | 8:940c782eec5e | 72 | timer.reset(); |
vwochnik | 8:940c782eec5e | 73 | loop(deviceId); |
vwochnik | 8:940c782eec5e | 74 | |
vwochnik | 8:940c782eec5e | 75 | // block remaining number of seconds |
vwochnik | 8:940c782eec5e | 76 | while (timer.read() < interval); |
vwochnik | 6:642e7c233e83 | 77 | } |
vwochnik | 6:642e7c233e83 | 78 | } |
vwochnik | 6:642e7c233e83 | 79 | |
vwochnik | 6:642e7c233e83 | 80 | long existing() |
vwochnik | 6:642e7c233e83 | 81 | { |
vwochnik | 6:642e7c233e83 | 82 | ComposedRecord newMoRec(true); // set copy=true b/c tmp objects |
vwochnik | 6:642e7c233e83 | 83 | ParsedRecord received; |
vwochnik | 6:642e7c233e83 | 84 | |
vwochnik | 6:642e7c233e83 | 85 | puts("Checking for device existance..."); |
vwochnik | 6:642e7c233e83 | 86 | |
vwochnik | 6:642e7c233e83 | 87 | newMoRec.add(IntegerValue(100)).add(CharValue(serialNumber)); |
vwochnik | 6:642e7c233e83 | 88 | |
vwochnik | 6:642e7c233e83 | 89 | if (client.send(newMoRec) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 90 | puts("Send failed."); |
vwochnik | 6:642e7c233e83 | 91 | return 0; |
vwochnik | 6:642e7c233e83 | 92 | } |
vwochnik | 6:642e7c233e83 | 93 | |
vwochnik | 6:642e7c233e83 | 94 | if (client.receive(received) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 95 | puts("No device found."); |
vwochnik | 6:642e7c233e83 | 96 | return 0; |
vwochnik | 6:642e7c233e83 | 97 | } |
vwochnik | 6:642e7c233e83 | 98 | |
vwochnik | 6:642e7c233e83 | 99 | if (received.values() == 0) { |
vwochnik | 6:642e7c233e83 | 100 | puts("Received no values."); |
vwochnik | 6:642e7c233e83 | 101 | return 0; |
vwochnik | 6:642e7c233e83 | 102 | } |
vwochnik | 6:642e7c233e83 | 103 | if (received.value(0).integerValue() == 50) { |
vwochnik | 6:642e7c233e83 | 104 | client.stop(); |
vwochnik | 6:642e7c233e83 | 105 | return 0; |
vwochnik | 6:642e7c233e83 | 106 | } |
vwochnik | 6:642e7c233e83 | 107 | |
vwochnik | 6:642e7c233e83 | 108 | if (received.value(0).integerValue() != 200) { |
vwochnik | 6:642e7c233e83 | 109 | puts("Bad response."); |
vwochnik | 6:642e7c233e83 | 110 | return 0; |
vwochnik | 6:642e7c233e83 | 111 | } |
vwochnik | 6:642e7c233e83 | 112 | |
vwochnik | 6:642e7c233e83 | 113 | client.stop(); |
vwochnik | 6:642e7c233e83 | 114 | return received.value(2).integerValue(); |
vwochnik | 6:642e7c233e83 | 115 | } |
vwochnik | 6:642e7c233e83 | 116 | |
vwochnik | 6:642e7c233e83 | 117 | long create() |
vwochnik | 6:642e7c233e83 | 118 | { |
vwochnik | 6:642e7c233e83 | 119 | ComposedRecord newMoRec(true); // set copy=true b/c tmp objects |
vwochnik | 6:642e7c233e83 | 120 | ParsedRecord received; |
vwochnik | 6:642e7c233e83 | 121 | |
vwochnik | 6:642e7c233e83 | 122 | puts("Creating device..."); |
vwochnik | 6:642e7c233e83 | 123 | |
vwochnik | 6:642e7c233e83 | 124 | newMoRec.add(IntegerValue(101)).add(CharValue(serialNumber)); |
vwochnik | 6:642e7c233e83 | 125 | |
vwochnik | 6:642e7c233e83 | 126 | if (client.send(newMoRec) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 127 | puts("Send failed."); |
vwochnik | 6:642e7c233e83 | 128 | return 0; |
vwochnik | 6:642e7c233e83 | 129 | } |
vwochnik | 6:642e7c233e83 | 130 | |
vwochnik | 6:642e7c233e83 | 131 | if (client.receive(received) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 132 | puts("No device found."); |
vwochnik | 6:642e7c233e83 | 133 | return 0; |
vwochnik | 6:642e7c233e83 | 134 | } |
vwochnik | 6:642e7c233e83 | 135 | |
vwochnik | 6:642e7c233e83 | 136 | if (received.values() != 3) { |
vwochnik | 6:642e7c233e83 | 137 | puts("Bad received data."); |
vwochnik | 6:642e7c233e83 | 138 | return 0; |
vwochnik | 6:642e7c233e83 | 139 | } |
vwochnik | 6:642e7c233e83 | 140 | |
vwochnik | 6:642e7c233e83 | 141 | if (received.value(0).integerValue() != 201) { |
vwochnik | 6:642e7c233e83 | 142 | puts("Bad received data."); |
vwochnik | 6:642e7c233e83 | 143 | return 0; |
vwochnik | 6:642e7c233e83 | 144 | } |
vwochnik | 6:642e7c233e83 | 145 | |
vwochnik | 6:642e7c233e83 | 146 | client.stop(); |
vwochnik | 6:642e7c233e83 | 147 | return received.value(2).integerValue(); |
vwochnik | 6:642e7c233e83 | 148 | } |
vwochnik | 6:642e7c233e83 | 149 | |
vwochnik | 6:642e7c233e83 | 150 | bool identify(long deviceId) |
vwochnik | 6:642e7c233e83 | 151 | { |
vwochnik | 6:642e7c233e83 | 152 | ComposedRecord newMoRec(true); // set copy=true b/c tmp objects |
vwochnik | 6:642e7c233e83 | 153 | ParsedRecord received; |
vwochnik | 6:642e7c233e83 | 154 | |
vwochnik | 6:642e7c233e83 | 155 | puts("Adding global identifier..."); |
vwochnik | 6:642e7c233e83 | 156 | |
vwochnik | 6:642e7c233e83 | 157 | newMoRec.add(IntegerValue(102)).add(IntegerValue(deviceId)).add(CharValue(serialNumber)); |
vwochnik | 6:642e7c233e83 | 158 | |
vwochnik | 6:642e7c233e83 | 159 | if (client.send(newMoRec) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 160 | puts("Sending failed."); |
vwochnik | 6:642e7c233e83 | 161 | return false; |
vwochnik | 6:642e7c233e83 | 162 | } |
vwochnik | 6:642e7c233e83 | 163 | |
vwochnik | 6:642e7c233e83 | 164 | if (client.receive(received) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 165 | puts("Failed."); |
vwochnik | 6:642e7c233e83 | 166 | return false; |
vwochnik | 6:642e7c233e83 | 167 | } |
vwochnik | 6:642e7c233e83 | 168 | |
vwochnik | 6:642e7c233e83 | 169 | if (received.values() != 3) { |
vwochnik | 6:642e7c233e83 | 170 | puts("Received bad data."); |
vwochnik | 6:642e7c233e83 | 171 | return false; |
vwochnik | 6:642e7c233e83 | 172 | } |
vwochnik | 6:642e7c233e83 | 173 | |
vwochnik | 6:642e7c233e83 | 174 | if (received.value(0).integerValue() != 200) { |
vwochnik | 6:642e7c233e83 | 175 | puts("Received bad data."); |
vwochnik | 6:642e7c233e83 | 176 | return false; |
vwochnik | 6:642e7c233e83 | 177 | } |
vwochnik | 6:642e7c233e83 | 178 | |
vwochnik | 6:642e7c233e83 | 179 | client.stop(); |
vwochnik | 6:642e7c233e83 | 180 | return true; |
vwochnik | 6:642e7c233e83 | 181 | } |
vwochnik | 6:642e7c233e83 | 182 | |
vwochnik | 7:f77afd49c35d | 183 | bool update(long deviceId) |
vwochnik | 7:f77afd49c35d | 184 | { |
vwochnik | 7:f77afd49c35d | 185 | ComposedRecord newMoRec(true); // set copy=true b/c tmp objects |
vwochnik | 7:f77afd49c35d | 186 | ParsedRecord received; |
vwochnik | 7:f77afd49c35d | 187 | |
vwochnik | 7:f77afd49c35d | 188 | puts("Updating device data..."); |
vwochnik | 7:f77afd49c35d | 189 | |
vwochnik | 7:f77afd49c35d | 190 | newMoRec.add(IntegerValue(103)).add(IntegerValue(deviceId)).add(CharValue(imei())).add(CharValue(cellId())).add(CharValue(iccid())); |
vwochnik | 7:f77afd49c35d | 191 | |
vwochnik | 7:f77afd49c35d | 192 | if (client.send(newMoRec) != SMARTREST_SUCCESS) { |
vwochnik | 7:f77afd49c35d | 193 | puts("Send failed."); |
vwochnik | 7:f77afd49c35d | 194 | return false; |
vwochnik | 7:f77afd49c35d | 195 | } |
vwochnik | 7:f77afd49c35d | 196 | |
vwochnik | 7:f77afd49c35d | 197 | if (client.receive(received) != SMARTREST_SUCCESS) { |
vwochnik | 7:f77afd49c35d | 198 | puts("Update failed."); |
vwochnik | 7:f77afd49c35d | 199 | return false; |
vwochnik | 7:f77afd49c35d | 200 | } |
vwochnik | 7:f77afd49c35d | 201 | |
vwochnik | 7:f77afd49c35d | 202 | if (received.values() != 3) { |
vwochnik | 7:f77afd49c35d | 203 | puts("Bad received data."); |
vwochnik | 7:f77afd49c35d | 204 | return false; |
vwochnik | 7:f77afd49c35d | 205 | } |
vwochnik | 7:f77afd49c35d | 206 | |
vwochnik | 7:f77afd49c35d | 207 | if (received.value(0).integerValue() != 201) { |
vwochnik | 7:f77afd49c35d | 208 | puts("Bad received data."); |
vwochnik | 7:f77afd49c35d | 209 | return false; |
vwochnik | 7:f77afd49c35d | 210 | } |
vwochnik | 7:f77afd49c35d | 211 | |
vwochnik | 7:f77afd49c35d | 212 | client.stop(); |
vwochnik | 7:f77afd49c35d | 213 | |
vwochnik | 7:f77afd49c35d | 214 | return true; |
vwochnik | 7:f77afd49c35d | 215 | } |
vwochnik | 7:f77afd49c35d | 216 | |
vwochnik | 8:940c782eec5e | 217 | void loop(long deviceId) |
vwochnik | 8:940c782eec5e | 218 | { |
vwochnik | 8:940c782eec5e | 219 | sigq_t *signal = signalQuality(); |
vwochnik | 8:940c782eec5e | 220 | measurement(deviceId, signal->rssi, signal->ber); |
vwochnik | 8:940c782eec5e | 221 | } |
vwochnik | 8:940c782eec5e | 222 | |
vwochnik | 6:642e7c233e83 | 223 | bool measurement(long deviceId, double rssi, int ber) |
vwochnik | 6:642e7c233e83 | 224 | { |
vwochnik | 6:642e7c233e83 | 225 | ComposedRecord newMoRec(true); // set copy=true b/c tmp objects |
vwochnik | 6:642e7c233e83 | 226 | |
vwochnik | 6:642e7c233e83 | 227 | puts("Creating measurement..."); |
vwochnik | 6:642e7c233e83 | 228 | |
vwochnik | 7:f77afd49c35d | 229 | newMoRec.add(IntegerValue(104)).add(IntegerValue(deviceId)).add(FloatValue(rssi, 0)).add(IntegerValue(ber)); |
vwochnik | 6:642e7c233e83 | 230 | |
vwochnik | 6:642e7c233e83 | 231 | if (client.send(newMoRec) != SMARTREST_SUCCESS) { |
vwochnik | 6:642e7c233e83 | 232 | puts("Send failed."); |
vwochnik | 6:642e7c233e83 | 233 | return false; |
vwochnik | 6:642e7c233e83 | 234 | } |
vwochnik | 6:642e7c233e83 | 235 | |
vwochnik | 6:642e7c233e83 | 236 | client.stop(); |
vwochnik | 6:642e7c233e83 | 237 | return true; |
vwochnik | 6:642e7c233e83 | 238 | } |