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@137:a52821cdb108, 2016-02-15 (annotated)

Committer:
xinlei
Date:
Mon Feb 15 09:49:35 2016 +0000
Revision:
137:a52821cdb108
Parent:
135:c4009ecaf5c0 
watchdog workaround for mobile connection lost after 24 hours.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Cumulocity 41:804f6a0bda26 1 #include "MbedAgent.h"
xinlei 109:2ec12f10ebf4 2 #include "watchdog.h"
xinlei 72:c5709ae7b193 3 #include "logging.h"
Cumulocity 41:804f6a0bda26 4
xinlei 99:e369fc75c000 5 MbedAgent::MbedAgent(DeviceInfo& deviceInfo):
xinlei 117:5de54f09f754 6 client(), tpl(), _bootstrap(deviceInfo), _integration(client, tpl, deviceInfo),
xinlei 117:5de54f09f754 7 lcdThirdLineBlank(true), signal(deviceInfo), temp(), poti(), gps(),
xinlei 117:5de54f09f754 8 acc(), sock(), pool(), _operationSupport(tpl, pool)
Cumulocity 41:804f6a0bda26 9 {
xinlei 108:f1ee3e1eb126 10 reporters[0] = &ConfigSync::inst();
xinlei 100:47ea098f8a47 11 reporters[1] = &temp;
xinlei 107:fc5f25f0e0d5 12 reporters[2] = &signal;
xinlei 100:47ea098f8a47 13 reporters[3] = &gps;
xinlei 100:47ea098f8a47 14 reporters[4] = &acc;
xinlei 107:fc5f25f0e0d5 15 reporters[5] = &poti;
Cumulocity 41:804f6a0bda26 16 }
Cumulocity 41:804f6a0bda26 17
Cumulocity 41:804f6a0bda26 18 bool MbedAgent::init()
Cumulocity 41:804f6a0bda26 19 {
xinlei 71:063c45e99578 20 bool flag = true;
xinlei 101:dbcd3bc51758 21
xinlei 101:dbcd3bc51758 22 // Insert measurement Acceleration
xinlei 101:dbcd3bc51758 23 // USAGE: 106,<DEVICE/ID>,<X>,<Y>,<Z>
xinlei 101:dbcd3bc51758 24 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 25 flag = false;
xinlei 101:dbcd3bc51758 26
xinlei 101:dbcd3bc51758 27 // Insert measurement Potentiometer
xinlei 101:dbcd3bc51758 28 // USAGE: 107,<DEVICE/ID>,<ANALOG1>,<ANALOG2>
xinlei 101:dbcd3bc51758 29 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 30 flag = false;
xinlei 101:dbcd3bc51758 31
xinlei 101:dbcd3bc51758 32 // Update device position
xinlei 101:dbcd3bc51758 33 // USAGE: 108,<DEVICE/ID>,<ALTITUDE>,<LATITUDE>,<LONGITUDE>
xinlei 101:dbcd3bc51758 34 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 35 flag = false;
xinlei 101:dbcd3bc51758 36
xinlei 101:dbcd3bc51758 37 // Insert measurement Location
xinlei 101:dbcd3bc51758 38 // USAGE: 109,<DEVICE/ID>,<ALTITUDE>,<LATITUDE>,<LONGITUDE>
xinlei 101:dbcd3bc51758 39 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 40 flag = false;
xinlei 101:dbcd3bc51758 41
xinlei 101:dbcd3bc51758 42 // Insert measurement Signal Quality
xinlei 101:dbcd3bc51758 43 // USAGE: 104,<DEVICE/ID>,<RSSI>,<BER>
xinlei 101:dbcd3bc51758 44 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 45 flag = false;
xinlei 101:dbcd3bc51758 46
xinlei 101:dbcd3bc51758 47 // Insert measurement Temperature
xinlei 101:dbcd3bc51758 48 // USAGE: 105,<DEVICE/ID>,<TEMPERATURE>
xinlei 101:dbcd3bc51758 49 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 50 flag = false;
xinlei 101:dbcd3bc51758 51
xinlei 101:dbcd3bc51758 52 // Update Configuration
xinlei 101:dbcd3bc51758 53 // Usage: 130,<DEVICE/ID>,<CONFIG/STRING>,<RESPONSIBILITY>
xinlei 101:dbcd3bc51758 54 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 55 flag = false;
xinlei 101:dbcd3bc51758 56
xinlei 71:063c45e99578 57 if (!_integration.init()) {
xinlei 96:5dfdc8568e9f 58 LCDDisplay::inst().setLines("Integrate init fail");
xinlei 71:063c45e99578 59 flag = false;
xinlei 71:063c45e99578 60 }
xinlei 71:063c45e99578 61 if (!_operationSupport.init()) {
xinlei 96:5dfdc8568e9f 62 LCDDisplay::inst().setLines("Operation init fail");
xinlei 71:063c45e99578 63 flag = false;
xinlei 71:063c45e99578 64 }
xinlei 101:dbcd3bc51758 65 for (size_t i = 0; i < N; ++i) {
xinlei 101:dbcd3bc51758 66 if (!reporters[i]->init()) {
xinlei 101:dbcd3bc51758 67 aError("Init %s", reporters[i]->name());
xinlei 101:dbcd3bc51758 68 }
xinlei 101:dbcd3bc51758 69 }
xinlei 101:dbcd3bc51758 70 return flag;
Cumulocity 41:804f6a0bda26 71 }
Cumulocity 41:804f6a0bda26 72
xinlei 93:0acd11870c6a 73 int MbedAgent::run()
Cumulocity 41:804f6a0bda26 74 {
Cumulocity 41:804f6a0bda26 75 // device bootstrapping process
xinlei 113:3872569be2af 76 if (!_bootstrap.bootstrap()) {
xinlei 117:5de54f09f754 77 LCDDisplay::inst().setLines("Bootstrap Failure");
xinlei 93:0acd11870c6a 78 return -1;
xinlei 106:c61f0d62b625 79 }
xinlei 117:5de54f09f754 80
xinlei 99:e369fc75c000 81 Thread::wait(2000);
xinlei 99:e369fc75c000 82 LCDDisplay::inst().setLines("Connect to Cloud", srHost);
xinlei 117:5de54f09f754 83 setX_ID(UBLOX_SMARTREST_VERSION);
Cumulocity 41:804f6a0bda26 84 if (!_integration.integrate()) {
xinlei 106:c61f0d62b625 85 LCDDisplay::inst().setLines("Integrate failure");
xinlei 93:0acd11870c6a 86 return -2;
Cumulocity 41:804f6a0bda26 87 }
xinlei 117:5de54f09f754 88 setX_ID(client.getIdentifier());
xinlei 101:dbcd3bc51758 89 aInfo("Set X-ID: %s\n", srX_ID);
xinlei 94:61d44636f020 90
xinlei 93:0acd11870c6a 91 return 0;
Cumulocity 41:804f6a0bda26 92 }
Cumulocity 41:804f6a0bda26 93
Cumulocity 41:804f6a0bda26 94 void MbedAgent::loop()
Cumulocity 41:804f6a0bda26 95 {
xinlei 101:dbcd3bc51758 96 ReportThread reportThread(pool);
xinlei 107:fc5f25f0e0d5 97 _operationSupport.executePendingOperations();
xinlei 109:2ec12f10ebf4 98 PollThread pollThread(pool);
xinlei 109:2ec12f10ebf4 99 pollThread.setChannel(deviceID);
xinlei 94:61d44636f020 100
xinlei 76:b07effe83fb8 101 Watchdog wdt;
xinlei 137:a52821cdb108 102 wdt.kick(300.0); // set a 60.0 seconds watchdog
Cumulocity 41:804f6a0bda26 103 while (true) {
xinlei 107:fc5f25f0e0d5 104 int l = 0;
xinlei 137:a52821cdb108 105 bool flag = false;
xinlei 101:dbcd3bc51758 106 for (size_t i = 0; i < N; ++i) {
xinlei 135:c4009ecaf5c0 107 // if (reporters[i] == &ConfigSync::inst()) {
xinlei 107:fc5f25f0e0d5 108 int l2 = reporters[i]->read(buf2+l, sizeof(buf2)-l, status, DISPLAY_LEN);
xinlei 137:a52821cdb108 109 if (l2 < 0) {
xinlei 137:a52821cdb108 110 flag |= reporters[i] == &signal;
xinlei 137:a52821cdb108 111 } else if (l2 > 0) { // Refresh LCD display needed
xinlei 137:a52821cdb108 112 l += l2;
xinlei 101:dbcd3bc51758 113 LCDDisplay::inst().setThirdLine(status);
xinlei 137:a52821cdb108 114 lcdThirdLineBlank = false;
xinlei 121:d4d44550e087 115 Thread::wait(400);
xinlei 137:a52821cdb108 116 } else if (!lcdThirdLineBlank) { // Clear LCD display needed
xinlei 101:dbcd3bc51758 117 LCDDisplay::inst().setThirdLine("");
xinlei 137:a52821cdb108 118 lcdThirdLineBlank = true;
xinlei 107:fc5f25f0e0d5 119 Thread::wait(100);
xinlei 101:dbcd3bc51758 120 }
xinlei 126:e1fcf720c63a 121 // }
xinlei 107:fc5f25f0e0d5 122 }
xinlei 107:fc5f25f0e0d5 123 if (l) {
xinlei 107:fc5f25f0e0d5 124 l = snprintf(buf, sizeof(buf), fmtSmartRest, "/s", l, buf2);
xinlei 122:68217ccb8cd1 125 sock.setBlocking(3000);
xinlei 117:5de54f09f754 126 l = sock.sendOnly(buf, l);
xinlei 107:fc5f25f0e0d5 127 if (l < 0)
xinlei 107:fc5f25f0e0d5 128 aWarning("%s\n", status);
xinlei 101:dbcd3bc51758 129 }
xinlei 137:a52821cdb108 130 if (!flag)
xinlei 137:a52821cdb108 131 wdt.kick(); // reset watchdog timer
Cumulocity 41:804f6a0bda26 132 }
Cumulocity 41:804f6a0bda26 133 }