The topic name for the OTA input and output topic will be stored as member variables and is created using the syntax '/a/d//ota/i' and '/a/d//ota/o' respectively

Author: aentinger

src/ArduinoIoTCloudTCP.cpp

@@ -75,7 +75,9 @@ ArduinoIoTCloudTCP::ArduinoIoTCloudTCP():
   _shadowTopicOut(""),
   _shadowTopicIn(""),
   _dataTopicOut(""),
-  _dataTopicIn("")
+  _dataTopicIn(""),
+  _ota_topic_in{""},
+  _ota_topic_out{""}
 {
 
 }
@@ -132,6 +134,8 @@ int ArduinoIoTCloudTCP::begin(String brokerAddress, uint16_t brokerPort)
   _shadowTopicIn  = getTopic_shadowin();
   _dataTopicOut   = getTopic_dataout();
   _dataTopicIn    = getTopic_datain();
+  _ota_topic_in   = getTopic_ota_in();
+  _ota_topic_out  = getTopic_ota_out();
 
   _thing.begin();
   _thing.registerGetTimeCallbackFunc(getTime);

src/ArduinoIoTCloudTCP.h

@@ -114,13 +114,17 @@ class ArduinoIoTCloudTCP: public ArduinoIoTCloudClass
     String _shadowTopicIn;
     String _dataTopicOut;
     String _dataTopicIn;
+    String _ota_topic_in;
+    String _ota_topic_out;
 
     inline String getTopic_stdin    () { return String("/a/d/" + getDeviceId() + "/s/i"); }
     inline String getTopic_stdout   () { return String("/a/d/" + getDeviceId() + "/s/o"); }
     inline String getTopic_shadowout() { return ( getThingId().length() == 0) ? String("")                            : String("/a/t/" + getThingId() + "/shadow/o"); }
     inline String getTopic_shadowin () { return ( getThingId().length() == 0) ? String("")                            : String("/a/t/" + getThingId() + "/shadow/i"); }
     inline String getTopic_dataout  () { return ( getThingId().length() == 0) ? String("/a/d/" + getDeviceId() + "/e/o") : String("/a/t/" + getThingId() + "/e/o"); }
     inline String getTopic_datain   () { return ( getThingId().length() == 0) ? String("/a/d/" + getDeviceId() + "/e/i") : String("/a/t/" + getThingId() + "/e/i"); }
+    inline String getTopic_ota_in   () { return String("/a/d/" + getDeviceId() + "/ota/i"); }
+    inline String getTopic_ota_out  () { return String("/a/d/" + getDeviceId() + "/ota/o"); }
 
     static void onMessage(int length);
     void handleMessage(int length);