Diff: DeviceIntegration.cpp

Revision:

41:804f6a0bda26

Child:

47:89ae46d5c466

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/DeviceIntegration.cpp	Tue Jul 15 12:44:34 2014 +0000
@@ -0,0 +1,247 @@
+#include "DeviceIntegration.h"
+#include <stdio.h>
+#include "ComposedRecord.h"
+#include "CharValue.h"
+#include "IntegerValue.h"
+
+DeviceIntegration::DeviceIntegration(SmartRest& client, SmartRestTemplate& tpl, long& deviceId, DeviceInfo& deviceInfo) :
+    _client(client),
+    _tpl(tpl),
+    _deviceId(deviceId),
+    _deviceInfo(deviceInfo)
+{
+    _init = false;
+}
+
+bool DeviceIntegration::init()
+{
+    if (_init)
+        return false;
+    
+    // get device by identity
+    // Usage: 100,<SERIAL/NR>
+    if (!_tpl.add("10,100,GET,/identity/externalIds/c8y_Serial/%%,,application/vnd.com.nsn.cumulocity.externalId+json,%%,STRING,\r\n"))
+        return false;
+
+    // get device id from identity
+    // Response: 200,<DEVICE/ID>
+    if (!_tpl.add("11,200,\"$.managedObject\",,\"$.id\"\r\n"))
+        return false;
+
+    // Create device
+    // Usage: 101,<SERIAL/NR>
+    if (!_tpl.add("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"))
+        return false;
+
+    // Get device id
+    // Response: 201,<DEVICE/ID>
+    if (!_tpl.add("11,201,,\"$.c8y_IsDevice\",\"$.id\"\r\n"))
+        return false;
+
+    // Insert global ID
+    // Usage: 102,<DEVICE/ID>,<SERIAL/NR>
+    if (!_tpl.add("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"))
+        return false;
+
+    // Update IMEI, CellId and iccid
+    // Usage: 103,<DEVICE/ID>,<IMEI>,<CELL/ID>,<ICCID>
+    if (!_tpl.add("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"))
+        return false;
+
+    _init = true;
+    _deviceId = 0;
+    return true;
+}
+
+bool DeviceIntegration::integrate()
+{
+    if (_deviceId != 0)
+        return false;
+
+    // template bootstrapping process
+    if (_client.bootstrap(_tpl) != SMARTREST_SUCCESS) {
+        puts("Template bootstrap failed.");
+        return 1;
+    }
+
+    puts("Hello.");
+    if (!deviceExisting()) {
+        puts("Creating device.");
+        if (!createDevice()) {
+            puts("Failed.");
+            return false;
+        }
+        puts("Adding global identifier.");
+        if (!addGlobalIdentifier()) {
+            puts("Failed.");
+            return false;
+        }
+    }
+
+    puts("Updating device data.");
+    if (!updateDevice()) {
+        puts("Failed.");
+        return false;
+    }
+
+    return true;
+}
+
+bool DeviceIntegration::deviceExisting()
+{
+    ComposedRecord record;
+    ParsedRecord received;
+
+    IntegerValue msgId(100);
+    CharValue imei(_deviceInfo.imei());
+    if ((!record.add(msgId)) || (!record.add(imei)))
+        return false;
+
+    if (_client.send(record) != SMARTREST_SUCCESS) {
+        puts("Send failed.");
+        _client.stop();
+        return false;
+    }
+
+    if (_client.receive(received) != SMARTREST_SUCCESS) {
+        puts("No device found.");
+        _client.stop();
+        return false;
+    }
+    _client.stop();
+
+    if (received.values() == 0) {
+        puts("Received no values.");
+        return false;
+    }
+
+    if (received.value(0).integerValue() == 50) {
+        return false;
+    }
+    
+    if (received.value(0).integerValue() != 200) {
+        puts("Bad response.");
+        return false;
+    }
+
+    _deviceId = received.value(2).integerValue();
+    
+    return true;
+}
+
+bool DeviceIntegration::createDevice()
+{
+    ComposedRecord record;
+    ParsedRecord received;
+
+    puts("Creating device...");
+
+    IntegerValue msgId(101);
+    CharValue imei(_deviceInfo.imei());
+    if ((!record.add(msgId)) || (!record.add(imei)))
+        return false;
+
+    if (_client.send(record) != SMARTREST_SUCCESS) {
+        puts("Send failed.");
+        _client.stop();
+        return 0;
+    }
+
+    if (_client.receive(received) != SMARTREST_SUCCESS) {
+        puts("No device found.");
+        _client.stop();
+        return false;
+    }
+    _client.stop();
+
+    if (received.values() != 3) {
+        puts("Bad received data.");
+        return false;
+    }
+    
+    if (received.value(0).integerValue() != 201) {
+        puts("Bad received data.");
+        return false;
+    }
+
+    _deviceId = received.value(2).integerValue();
+    return true;
+}
+
+bool DeviceIntegration::addGlobalIdentifier()
+{
+    ComposedRecord record;
+    ParsedRecord received;
+
+    puts("Adding global identifier...");
+
+    IntegerValue msgId(102);
+    IntegerValue deviceId(_deviceId);
+    CharValue imei(_deviceInfo.imei());
+    if ((!record.add(msgId)) || (!record.add(deviceId)) || (!record.add(imei)))
+        return false;
+
+    if (_client.send(record) != SMARTREST_SUCCESS) {
+        puts("Sending failed.");
+        _client.stop();
+        return false;
+    }
+
+    if (_client.receive(received) != SMARTREST_SUCCESS) {
+        puts("Failed.");
+        _client.stop();
+        return false;
+    }
+    _client.stop();
+
+    if (received.values() != 3) {
+        puts("Received bad data.");
+        return false;
+    }
+    
+    if (received.value(0).integerValue() != 200) {
+        puts("Received bad data.");
+        return false;
+    }
+
+    return true;
+}
+
+bool DeviceIntegration::updateDevice()
+{
+    ComposedRecord record;
+    ParsedRecord received;
+
+    IntegerValue msgId(103);
+    IntegerValue deviceId(_deviceId);
+    CharValue imei(_deviceInfo.imei());
+    CharValue cellId(_deviceInfo.cellId());
+    CharValue iccid(_deviceInfo.iccid());
+    if ((!record.add(msgId)) || (!record.add(deviceId)) || (!record.add(imei)) || (!record.add(cellId)) || (!record.add(iccid)))
+        return false;
+
+    if (_client.send(record) != SMARTREST_SUCCESS) {
+        puts("Send failed.");
+        _client.stop();
+        return false;
+    }
+
+    if (_client.receive(received) != SMARTREST_SUCCESS) {
+        puts("Update failed.");
+        _client.stop();
+        return false;
+    }
+    _client.stop();
+
+    if (received.values() != 3) {
+        puts("Bad received data.");
+        return false;
+    }
+    
+    if (received.value(0).integerValue() != 201) {
+        puts("Bad received data.");
+        return false;
+    }
+
+    return true;
+}