@@ -50,7 +50,8 @@ const static int CONNECT_FAILURE_SUBSCRIBE = -1;
5050 LOCAL MODULE FUNCTIONS
5151 ******************************************************************************/
5252
53- static unsigned long getTime () {
53+ static unsigned long getTime ()
54+ {
5455 return time_service.getTime ();
5556}
5657
@@ -75,9 +76,12 @@ ArduinoIoTCloudTCP::ArduinoIoTCloudTCP():
7576 _shadowTopicIn(" " ),
7677 _dataTopicOut(" " ),
7778 _dataTopicIn(" " )
78- {}
79+ {
7980
80- ArduinoIoTCloudTCP::~ArduinoIoTCloudTCP () {
81+ }
82+
83+ ArduinoIoTCloudTCP::~ArduinoIoTCloudTCP ()
84+ {
8185 delete _mqttClient; _mqttClient = NULL ;
8286 delete _sslClient; _sslClient = NULL ;
8387}
@@ -86,15 +90,17 @@ ArduinoIoTCloudTCP::~ArduinoIoTCloudTCP() {
8690 * PUBLIC MEMBER FUNCTIONS
8791 ******************************************************************************/
8892
89- int ArduinoIoTCloudTCP::begin (ConnectionHandler & connection, String brokerAddress, uint16_t brokerPort) {
93+ int ArduinoIoTCloudTCP::begin (ConnectionHandler & connection, String brokerAddress, uint16_t brokerPort)
94+ {
9095 _connection = &connection;
9196 _brokerAddress = brokerAddress;
9297 _brokerPort = brokerPort;
9398 time_service.begin (&connection);
9499 return begin (_brokerAddress, _brokerPort);
95100}
96101
97- int ArduinoIoTCloudTCP::begin (String brokerAddress, uint16_t brokerPort) {
102+ int ArduinoIoTCloudTCP::begin (String brokerAddress, uint16_t brokerPort)
103+ {
98104
99105 _brokerAddress = brokerAddress;
100106 _brokerPort = brokerPort;
@@ -135,8 +141,8 @@ int ArduinoIoTCloudTCP::begin(String brokerAddress, uint16_t brokerPort) {
135141 return 1 ;
136142}
137143
138- int ArduinoIoTCloudTCP::connect () {
139-
144+ int ArduinoIoTCloudTCP::connect ()
145+ {
140146 if (!_mqttClient->connect (_brokerAddress.c_str (), _brokerPort)) {
141147 return CONNECT_FAILURE;
142148 }
@@ -158,13 +164,14 @@ int ArduinoIoTCloudTCP::connect() {
158164}
159165
160166
161- bool ArduinoIoTCloudTCP::disconnect () {
167+ bool ArduinoIoTCloudTCP::disconnect ()
168+ {
162169 _mqttClient->stop ();
163-
164170 return true ;
165171}
166172
167- void ArduinoIoTCloudTCP::update () {
173+ void ArduinoIoTCloudTCP::update ()
174+ {
168175 // Check if a primitive property wrapper is locally changed
169176 _thing.updateTimestampOnLocallyChangedProperties ();
170177
@@ -199,36 +206,39 @@ void ArduinoIoTCloudTCP::update() {
199206 }
200207}
201208
202- void ArduinoIoTCloudTCP::printDebugInfo () {
209+ void ArduinoIoTCloudTCP::printDebugInfo ()
210+ {
203211 Debug.print (DBG_INFO, " ***** Arduino IoT Cloud - configuration info *****" );
204212 Debug.print (DBG_INFO, " Device ID: %s" , getDeviceId ().c_str ());
205213 Debug.print (DBG_INFO, " Thing ID: %s" , getThingId ().c_str ());
206214 Debug.print (DBG_INFO, " MQTT Broker: %s:%d" , _brokerAddress.c_str (), _brokerPort);
207215}
208216
209- int ArduinoIoTCloudTCP::reconnect () {
217+ int ArduinoIoTCloudTCP::reconnect ()
218+ {
210219 if (_mqttClient->connected ()) {
211220 _mqttClient->stop ();
212221 }
213-
214- // Connect to the broker
215222 return connect ();
216223}
217224
218225
219- int ArduinoIoTCloudTCP::connected () {
226+ int ArduinoIoTCloudTCP::connected ()
227+ {
220228 return _mqttClient->connected ();
221229}
222230
223231/* *****************************************************************************
224232 * PRIVATE MEMBER FUNCTIONS
225233 ******************************************************************************/
226234
227- void ArduinoIoTCloudTCP::onMessage (int length) {
235+ void ArduinoIoTCloudTCP::onMessage (int length)
236+ {
228237 ArduinoCloud.handleMessage (length);
229238}
230239
231- void ArduinoIoTCloudTCP::handleMessage (int length) {
240+ void ArduinoIoTCloudTCP::handleMessage (int length)
241+ {
232242 String topic = _mqttClient->messageTopic ();
233243
234244 byte bytes[length];
@@ -250,7 +260,8 @@ void ArduinoIoTCloudTCP::handleMessage(int length) {
250260 }
251261}
252262
253- void ArduinoIoTCloudTCP::sendPropertiesToCloud () {
263+ void ArduinoIoTCloudTCP::sendPropertiesToCloud ()
264+ {
254265 uint8_t data[MQTT_TRANSMIT_BUFFER_SIZE];
255266 int const length = _thing.encode (data, sizeof (data));
256267 if (length > 0 )
@@ -265,7 +276,8 @@ void ArduinoIoTCloudTCP::sendPropertiesToCloud() {
265276 }
266277}
267278
268- void ArduinoIoTCloudTCP::requestLastValue () {
279+ void ArduinoIoTCloudTCP::requestLastValue ()
280+ {
269281 // Send the getLastValues CBOR message to the cloud
270282 // [{0: "r:m", 3: "getLastValues"}] = 81 A2 00 63 72 3A 6D 03 6D 67 65 74 4C 61 73 74 56 61 6C 75 65 73
271283 // Use http://cbor.me to easily generate CBOR encoding
0 commit comments