Cumulocity Official / Mbed 2 deprecated MbedSmartRestMain Featured

Official reference client implementation for Cumulocity SmartREST on u-blox C027.

Dependencies:   C027_Support C12832 LM75B MMA7660 MbedSmartRest mbed-rtos mbed

Fork of MbedSmartRestMain by Vincent Wochnik

MbedAgent.cpp@106:c61f0d62b625, 2015-05-11 (annotated)

Committer:
xinlei
Date:
Mon May 11 18:10:44 2015 +0000
Revision:
106:c61f0d62b625
Parent:
101:dbcd3bc51758
Child:
107:fc5f25f0e0d5
SmartRestSSLSocket and various bug-fixes for rc3

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Cumulocity 41:804f6a0bda26 1 #include "MbedAgent.h"
xinlei 72:c5709ae7b193 2 #include "logging.h"
xinlei 76:b07effe83fb8 3 #include "watchdog.h"
Cumulocity 41:804f6a0bda26 4
xinlei 99:e369fc75c000 5 MbedAgent::MbedAgent(DeviceInfo& deviceInfo):
xinlei 100:47ea098f8a47 6 _client(), tpl(), _bootstrap(_client, deviceInfo),
xinlei 101:dbcd3bc51758 7 _integration(_client, tpl, deviceInfo), lcdThirdLineBlank(true),
xinlei 101:dbcd3bc51758 8 signal(deviceInfo), temp(), poti(), gps(), acc(), conf(), sock(),
xinlei 101:dbcd3bc51758 9 pool(), _operationSupport(_client, tpl, pool)
Cumulocity 41:804f6a0bda26 10 {
xinlei 100:47ea098f8a47 11 reporters[0] = &signal;
xinlei 100:47ea098f8a47 12 reporters[1] = &temp;
xinlei 100:47ea098f8a47 13 reporters[2] = &poti;
xinlei 100:47ea098f8a47 14 reporters[3] = &gps;
xinlei 100:47ea098f8a47 15 reporters[4] = &acc;
xinlei 100:47ea098f8a47 16 reporters[5] = &conf;
Cumulocity 41:804f6a0bda26 17 }
Cumulocity 41:804f6a0bda26 18
Cumulocity 41:804f6a0bda26 19 bool MbedAgent::init()
Cumulocity 41:804f6a0bda26 20 {
xinlei 71:063c45e99578 21 bool flag = true;
xinlei 101:dbcd3bc51758 22
xinlei 101:dbcd3bc51758 23 // Insert measurement Acceleration
xinlei 101:dbcd3bc51758 24 // USAGE: 106,<DEVICE/ID>,<X>,<Y>,<Z>
xinlei 101:dbcd3bc51758 25 if (!tpl.add("10,106,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/s^2\"\"},\"\"y\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"m/s^2\"\"},\"\"z\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"m/s^2\"\"}}}\"\r\n"))
xinlei 101:dbcd3bc51758 26 flag = false;
xinlei 101:dbcd3bc51758 27
xinlei 101:dbcd3bc51758 28 // Insert measurement Potentiometer
xinlei 101:dbcd3bc51758 29 // USAGE: 107,<DEVICE/ID>,<ANALOG1>,<ANALOG2>
xinlei 101:dbcd3bc51758 30 if (!tpl.add("10,107,POST,/measurement/measurements,application/vnd.com.nsn.cumulocity.measurement+json,application/vnd.com.nsn.cumulocity.measurement+json,%%,NOW UNSIGNED NUMBER NUMBER,\"{\"\"time\"\":\"\"%%\"\",\"\"source\"\":{\"\"id\"\":\"\"%%\"\"},\"\"type\"\":\"\"c8y_AnalogMeasurement\"\",\"\"c8y_AnalogMeasurement\"\":{\"\"A1\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"A\"\"},\"\"A2\"\":{\"\"value\"\":%%,\"\"unit\"\":\"\"A\"\"}}}\"\r\n"))
xinlei 101:dbcd3bc51758 31 flag = false;
xinlei 101:dbcd3bc51758 32
xinlei 101:dbcd3bc51758 33 // Update device position
xinlei 101:dbcd3bc51758 34 // USAGE: 108,<DEVICE/ID>,<ALTITUDE>,<LATITUDE>,<LONGITUDE>
xinlei 101:dbcd3bc51758 35 if (!tpl.add("10,108,PUT,/inventory/managedObjects/%%,application/vnd.com.nsn.cumulocity.managedObject+json,application/vnd.com.nsn.cumulocity.managedObject+json,%%,UNSIGNED NUMBER NUMBER NUMBER,\"{\"\"c8y_Position\"\":{\"\"alt\"\":%%,\"\"lat\"\":%%,\"\"lng\"\":%%},\"\"c8y_MotionTracking\"\":{\"\"active\"\":true}}\"\r\n"))
xinlei 101:dbcd3bc51758 36 flag = false;
xinlei 101:dbcd3bc51758 37
xinlei 101:dbcd3bc51758 38 // Insert measurement Location
xinlei 101:dbcd3bc51758 39 // USAGE: 109,<DEVICE/ID>,<ALTITUDE>,<LATITUDE>,<LONGITUDE>
xinlei 101:dbcd3bc51758 40 if (!tpl.add("10,109,POST,/event/events,application/vnd.com.nsn.cumulocity.event+json,application/vnd.com.nsn.cumulocity.event+json,%%,NOW UNSIGNED NUMBER NUMBER NUMBER,\"{\"\"time\"\":\"\"%%\"\",\"\"source\"\":{\"\"id\"\":\"\"%%\"\"},\"\"type\"\":\"\"c8y_LocationUpdate\"\",\"\"text\"\":\"\"Mbed location update\"\",\"\"c8y_Position\"\":{\"\"alt\"\":%%,\"\"lat\"\":%%,\"\"lng\"\":%%}}\"\r\n"))
xinlei 101:dbcd3bc51758 41 flag = false;
xinlei 101:dbcd3bc51758 42
xinlei 101:dbcd3bc51758 43 // Insert measurement Signal Quality
xinlei 101:dbcd3bc51758 44 // USAGE: 104,<DEVICE/ID>,<RSSI>,<BER>
xinlei 101:dbcd3bc51758 45 if (!tpl.add("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"))
xinlei 101:dbcd3bc51758 46 flag = false;
xinlei 101:dbcd3bc51758 47
xinlei 101:dbcd3bc51758 48 // Insert measurement Temperature
xinlei 101:dbcd3bc51758 49 // USAGE: 105,<DEVICE/ID>,<TEMPERATURE>
xinlei 101:dbcd3bc51758 50 if (!tpl.add("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"))
xinlei 101:dbcd3bc51758 51 flag = false;
xinlei 101:dbcd3bc51758 52
xinlei 101:dbcd3bc51758 53 // Update Configuration
xinlei 101:dbcd3bc51758 54 // Usage: 130,<DEVICE/ID>,<CONFIG/STRING>,<RESPONSIBILITY>
xinlei 101:dbcd3bc51758 55 if (!tpl.add("10,130,PUT,/inventory/managedObjects/%%,application/vnd.com.nsn.cumulocity.managedObject+json,application/vnd.com.nsn.cumulocity.managedObject+json,%%,UNSIGNED STRING NUMBER,\"{\"\"c8y_Configuration\"\":{\"\"config\"\":\"\"%%\"\"},\"\"c8y_RequiredAvailability\"\":{ \"\"responseInterval\"\":%%}}\"\r\n"))
xinlei 101:dbcd3bc51758 56 flag = false;
xinlei 101:dbcd3bc51758 57
xinlei 71:063c45e99578 58 if (!_integration.init()) {
xinlei 96:5dfdc8568e9f 59 LCDDisplay::inst().setLines("Integrate init fail");
xinlei 71:063c45e99578 60 flag = false;
xinlei 71:063c45e99578 61 }
xinlei 71:063c45e99578 62 if (!_operationSupport.init()) {
xinlei 96:5dfdc8568e9f 63 LCDDisplay::inst().setLines("Operation init fail");
xinlei 71:063c45e99578 64 flag = false;
xinlei 71:063c45e99578 65 }
xinlei 101:dbcd3bc51758 66 for (size_t i = 0; i < N; ++i) {
xinlei 101:dbcd3bc51758 67 if (!reporters[i]->init()) {
xinlei 101:dbcd3bc51758 68 aError("Init %s", reporters[i]->name());
xinlei 101:dbcd3bc51758 69 }
xinlei 101:dbcd3bc51758 70 }
xinlei 101:dbcd3bc51758 71 return flag;
Cumulocity 41:804f6a0bda26 72 }
Cumulocity 41:804f6a0bda26 73
xinlei 93:0acd11870c6a 74 int MbedAgent::run()
Cumulocity 41:804f6a0bda26 75 {
Cumulocity 41:804f6a0bda26 76 // device bootstrapping process
xinlei 106:c61f0d62b625 77 if (!_bootstrap.setUpCredentials()) {
xinlei 106:c61f0d62b625 78 LCDDisplay::inst().setLines("Bootstrap error");
xinlei 93:0acd11870c6a 79 return -1;
xinlei 106:c61f0d62b625 80 }
xinlei 94:61d44636f020 81 setAuth(_bootstrap.username(), _bootstrap.password());
xinlei 99:e369fc75c000 82 aInfo("Set auth: %s:%s (%s)\n", srUsername, srPassword, srAuthStr);
vwochnik 52:8f1370084268 83
xinlei 99:e369fc75c000 84 Thread::wait(2000);
Cumulocity 41:804f6a0bda26 85
xinlei 99:e369fc75c000 86 LCDDisplay::inst().setLines("Connect to Cloud", srHost);
Cumulocity 41:804f6a0bda26 87 if (!_integration.integrate()) {
xinlei 106:c61f0d62b625 88 LCDDisplay::inst().setLines("Integrate failure");
xinlei 93:0acd11870c6a 89 return -2;
Cumulocity 41:804f6a0bda26 90 }
xinlei 99:e369fc75c000 91 setX_ID(_client.getIdentifier());
xinlei 101:dbcd3bc51758 92 aInfo("Set X-ID: %s\n", srX_ID);
xinlei 94:61d44636f020 93
xinlei 93:0acd11870c6a 94 return 0;
Cumulocity 41:804f6a0bda26 95 }
Cumulocity 41:804f6a0bda26 96
Cumulocity 41:804f6a0bda26 97 void MbedAgent::loop()
Cumulocity 41:804f6a0bda26 98 {
xinlei 101:dbcd3bc51758 99 ReportThread reportThread(pool);
xinlei 94:61d44636f020 100 _operationSupport.run();
xinlei 101:dbcd3bc51758 101 PollThread pollThread(pool, conf);
xinlei 101:dbcd3bc51758 102 pollThread.setChannel(deviceID);
xinlei 94:61d44636f020 103
xinlei 76:b07effe83fb8 104 Watchdog wdt;
xinlei 101:dbcd3bc51758 105 wdt.kick(60.0); // set a 60.0 seconds watchdog
Cumulocity 41:804f6a0bda26 106 while (true) {
xinlei 101:dbcd3bc51758 107 for (size_t i = 0; i < N; ++i) {
xinlei 106:c61f0d62b625 108 // if (reporters[i] == &acc) {
xinlei 106:c61f0d62b625 109 size_t l = reporters[i]->read(buf2, sizeof(buf2), status, DISPLAY_LEN);
xinlei 101:dbcd3bc51758 110 bool b = l;
xinlei 101:dbcd3bc51758 111 if (b) { // Refresh LCD display needed
xinlei 101:dbcd3bc51758 112 LCDDisplay::inst().setThirdLine(status);
xinlei 101:dbcd3bc51758 113 } else if (!lcdThirdLineBlank && !b) { // Clear LCD display needed
xinlei 101:dbcd3bc51758 114 LCDDisplay::inst().setThirdLine("");
xinlei 101:dbcd3bc51758 115 }
xinlei 101:dbcd3bc51758 116 lcdThirdLineBlank = !b;
xinlei 101:dbcd3bc51758 117 if (b) {
xinlei 106:c61f0d62b625 118 int l2 = snprintf(buf, sizeof(buf), fmtSmartRest, "/s", l, buf2);
xinlei 101:dbcd3bc51758 119 l2 = sock.sendOnly(buf, l2);
xinlei 101:dbcd3bc51758 120 if (l2 < 0)
xinlei 106:c61f0d62b625 121 aWarning("%s\n", status);
xinlei 101:dbcd3bc51758 122 }
xinlei 101:dbcd3bc51758 123 // }
xinlei 101:dbcd3bc51758 124 }
xinlei 76:b07effe83fb8 125 wdt.kick(); // reset watchdog timer
Cumulocity 41:804f6a0bda26 126 }
Cumulocity 41:804f6a0bda26 127 }