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