Move thing_id outdated flag check outside update function and add handle_Disconnect() function

Author: pennam

src/ArduinoIoTCloud.cpp

@@ -33,6 +33,7 @@ ArduinoIoTCloudClass::ArduinoIoTCloudClass()
 , _thing_id{""}
 , _device_id{""}
 , _cloud_event_callback{nullptr}
+, _thing_id_outdated{false}
 {
 
 }

src/ArduinoIoTCloudTCP.cpp

@@ -332,12 +332,6 @@ void ArduinoIoTCloudTCP::update()
     _next_state = State::Invalid;
   }
 
-  if(getThingIdOutdatedFlag()) {
-    DEBUG_VERBOSE("ArduinoIoTCloudTCP::%s Thing id outdated, reconfiguring...", __FUNCTION__);
-    if (_mqttClient.connected())
-      _state =  State::CheckDeviceConfig;
-  }
-
   /* Run through the state machine. */
   State next_state = _state;
   switch (_state)
@@ -352,6 +346,7 @@ void ArduinoIoTCloudTCP::update()
   case State::SubscribeThingTopics: next_state = handle_SubscribeThingTopics(); break;
   case State::RequestLastValues:    next_state = handle_RequestLastValues();    break;
   case State::Connected:            next_state = handle_Connected();            break;
+  case State::Disconnect:           next_state = handle_Disconnect();           break;
   }
   _state = next_state;
 
@@ -427,10 +422,7 @@ ArduinoIoTCloudTCP::State ArduinoIoTCloudTCP::handle_SendDeviceProperties()
 {
   if (!_mqttClient.connected())
   {
-    DEBUG_ERROR("ArduinoIoTCloudTCP::%s MQTT client connection lost", __FUNCTION__);
-    _mqttClient.stop();
-    execCloudEventCallback(ArduinoIoTCloudEvent::DISCONNECT);
-    return State::ConnectPhy;
+    return State::Disconnect;
   }
 
 #if OTA_ENABLED
@@ -443,10 +435,7 @@ ArduinoIoTCloudTCP::State ArduinoIoTCloudTCP::handle_SubscribeDeviceTopic()
 {
   if (!_mqttClient.connected())
   {
-    DEBUG_ERROR("ArduinoIoTCloudTCP::%s MQTT client connection lost", __FUNCTION__);
-    _mqttClient.stop();
-    execCloudEventCallback(ArduinoIoTCloudEvent::DISCONNECT);
-    return State::ConnectPhy;
+    return State::Disconnect;
   }
 
   if (!_mqttClient.subscribe(_deviceTopicIn))
@@ -475,10 +464,12 @@ ArduinoIoTCloudTCP::State ArduinoIoTCloudTCP::handle_WaitDeviceConfig()
 {
   if (!_mqttClient.connected())
   {
-    DEBUG_ERROR("ArduinoIoTCloudTCP::%s MQTT client connection lost", __FUNCTION__);
-    _mqttClient.stop();
-    execCloudEventCallback(ArduinoIoTCloudEvent::DISCONNECT);
-    return State::ConnectPhy;
+    return State::Disconnect;
+  }
+
+  if (getThingIdOutdatedFlag())
+  {
+    return State::CheckDeviceConfig;
   }
 
   if (millis() > _next_device_subscribe_attempt_tick)
@@ -496,10 +487,7 @@ ArduinoIoTCloudTCP::State ArduinoIoTCloudTCP::handle_CheckDeviceConfig()
 {
   if (!_mqttClient.connected())
   {
-    DEBUG_ERROR("ArduinoIoTCloudTCP::%s MQTT client connection lost", __FUNCTION__);
-    _mqttClient.stop();
-    execCloudEventCallback(ArduinoIoTCloudEvent::DISCONNECT);
-    return State::ConnectPhy;
+    return State::Disconnect;
   }
 
   if(_deviceSubscribedToThing == true)
@@ -534,10 +522,12 @@ ArduinoIoTCloudTCP::State ArduinoIoTCloudTCP::handle_SubscribeThingTopics()
 {
   if (!_mqttClient.connected())
   {
-    DEBUG_ERROR("ArduinoIoTCloudTCP::%s MQTT client connection lost", __FUNCTION__);
-    _mqttClient.stop();
-    execCloudEventCallback(ArduinoIoTCloudEvent::DISCONNECT);
-    return State::ConnectPhy;
+    return State::Disconnect;
+  }
+
+  if (getThingIdOutdatedFlag())
+  {
+    return State::CheckDeviceConfig;
   }
 
   if (!_mqttClient.subscribe(_dataTopicIn))
@@ -569,10 +559,12 @@ ArduinoIoTCloudTCP::State ArduinoIoTCloudTCP::handle_RequestLastValues()
 {
   if (!_mqttClient.connected())
   {
-    DEBUG_ERROR("ArduinoIoTCloudTCP::%s MQTT client connection lost", __FUNCTION__);
-    _mqttClient.stop();
-    execCloudEventCallback(ArduinoIoTCloudEvent::DISCONNECT);
-    return State::ConnectPhy;
+    return State::Disconnect;
+  }
+
+  if (getThingIdOutdatedFlag())
+  {
+    return State::CheckDeviceConfig;
   }
 
   /* Check whether or not we need to send a new request. */
@@ -606,22 +598,18 @@ ArduinoIoTCloudTCP::State ArduinoIoTCloudTCP::handle_Connected()
 {
   if (!_mqttClient.connected())
   {
-    DEBUG_ERROR("ArduinoIoTCloudTCP::%s MQTT client connection lost", __FUNCTION__);
-
-    /* Forcefully disconnect MQTT client and trigger a reconnection. */
-    _mqttClient.stop();
-
     /* The last message was definitely lost, trigger a retransmit. */
     _mqtt_data_request_retransmit = true;
-
-    /* We are not connected anymore, trigger the callback for a disconnected event. */
-    execCloudEventCallback(ArduinoIoTCloudEvent::DISCONNECT);
-
-    return State::ConnectPhy;
+    return State::Disconnect;
   }
   /* We are connected so let's to our stuff here. */
   else
   {
+    if (getThingIdOutdatedFlag())
+    {
+      return State::CheckDeviceConfig;
+    }
+
     /* Check if a primitive property wrapper is locally changed.
     * This function requires an existing time service which in
     * turn requires an established connection. Not having that
@@ -675,6 +663,14 @@ ArduinoIoTCloudTCP::State ArduinoIoTCloudTCP::handle_Connected()
   }
 }
 
+ArduinoIoTCloudTCP::State ArduinoIoTCloudTCP::handle_Disconnect()
+{
+  DEBUG_ERROR("ArduinoIoTCloudTCP::%s MQTT client connection lost", __FUNCTION__);
+  _mqttClient.stop();
+  execCloudEventCallback(ArduinoIoTCloudEvent::DISCONNECT);
+  return State::ConnectPhy;
+}
+
 void ArduinoIoTCloudTCP::onMessage(int length)
 {
   ArduinoCloud.handleMessage(length);

src/ArduinoIoTCloudTCP.h

@@ -112,6 +112,7 @@ class ArduinoIoTCloudTCP: public ArduinoIoTCloudClass
       SubscribeThingTopics,
       RequestLastValues,
       Connected,
+      Disconnect,
       Invalid
     };
 
@@ -179,6 +180,7 @@ class ArduinoIoTCloudTCP: public ArduinoIoTCloudClass
     State handle_SubscribeThingTopics();
     State handle_RequestLastValues();
     State handle_Connected();
+    State handle_Disconnect();
 
     static void onMessage(int length);
     void handleMessage(int length);
@@ -193,7 +195,6 @@ class ArduinoIoTCloudTCP: public ArduinoIoTCloudClass
 #endif
 
     void updateThingTopics();
-
 };
 
 /******************************************************************************