Trying OTA firmware update using @thingsboard in ESP32

Question

I am trying to perform OTA update using ESP32 and @thingsboard community version. I am using mqtt in esp32 to connect with Thingsboard. What I have achieved is: When I am updating firmware in Thingsboard DEVICE PROFILE which is attached with my device and device to dashboard, I am getting notification that payload load arrived from subscribed topic and showing payload as well as it is showing that OTA Initialized. But actual update is not happening because in no way esp32 getting the .bin file from Thingsboard. How can I achieve actual firmware update?

In thingsboard: I have added edge rule chain and attached that with root rule chain. Setup of device profile, device and dashboard is also done.

ESP32 script: (I know I have not included update.h and other dependencies because .bin not coming up.)

OUTPUT:

Payload: {"fw_title":"OTA","fw_version":"1.4","fw_tag":"OTA 1.4","fw_size":823792,"fw_checksum_algorithm":"SHA256","fw_checksum":"a5a0c30171ae48e611efd254cd164f94427d128f57a0114d6e1eac7ba89bd7ec"}

// printing the received pyload
#include 
#include 
#include 

// WiFi credentials
const char* ssid = "CURRENT";
const char* password = "11111111";

// ThingsBoard MQTT broker configuration
const char* mqttServer = "111.93.67.82";
const int mqttPort = 7045;
const char* mqttAccessToken = "gGnF3jGV0pGp7uvuFlHz"; // Replace with your device access token
const char* mqttTopic = "v1/devices/me/attributes";
const char* mqttPassword = ""; // Leave empty if no password is required

WiFiClient wifiClient;
PubSubClient mqttClient(wifiClient);

bool otaUpdateRequested = false;

// OTA update started event handler
void handleOTAStart() {
  Serial.println("OTA update started");
}

// OTA update in progress event handler
void handleOTAProgress(unsigned int progress, unsigned int total) {
  Serial.printf("OTA update progress: %u%%
", (progress / (total / 100)));
}

// OTA update completed event handler
void handleOTAEnd() {
  Serial.println("OTA update completed");
}

// OTA update error event handler
void handleOTAError(ota_error_t error) {
  Serial.printf("OTA update error[%u]: ", error);
  if (error == OTA_AUTH_ERROR) Serial.println("Auth Failed");
  else if (error == OTA_BEGIN_ERROR) Serial.println("Begin Failed");
  else if (error == OTA_CONNECT_ERROR) Serial.println("Connect Failed");
  else if (error == OTA_RECEIVE_ERROR) Serial.println("Receive Failed");
  else if (error == OTA_END_ERROR) Serial.println("End Failed");
}

void setupOTA() {
  // Set the port for OTA updates
  ArduinoOTA.setPort(3232);

  // Set the hostname for the ESP32 device
  ArduinoOTA.setHostname("ESP32_OTA-DEVICE");

  // Set OTA event handlers
  ArduinoOTA.onStart(handleOTAStart);
  ArduinoOTA.onProgress(handleOTAProgress);
  ArduinoOTA.onEnd(handleOTAEnd);
  ArduinoOTA.onError(handleOTAError);

  // Uncomment and set a password if needed
  // ArduinoOTA.setPassword("YOUR_OTA_PASSWORD");

  // Start OTA server
  ArduinoOTA.begin();
}

void setupMQTT() {
  mqttClient.setServer(mqttServer, mqttPort);
  mqttClient.setCallback(mqttCallback);
}

void mqttCallback(char* topic, byte* payload, unsigned int length) {
  Serial.print("Message arrived [");
  Serial.print(topic);
  Serial.print("] Payload: ");
  // Print the payload
  for (int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println();
  
  // Check if the topic is for OTA update
  if (strcmp(topic, "v1/devices/me/attributes") == 0) {
    if (length > 0) {
      // Process the received binary data here
      // For simplicity, we'll just set a flag to indicate OTA update
      Serial.println("OTA update requested");
      otaUpdateRequested = true;
    } else {
      Serial.println("Empty payload received");
    }
  } else {
    // Handle other topics if necessary
  }
}

void reconnectMQTT() {
  while (!mqttClient.connected()) {
    Serial.print("Attempting MQTT connection...");
    if (mqttClient.connect(mqttAccessToken, mqttAccessToken, mqttPassword)) {
      Serial.println("connected");
      mqttClient.subscribe(mqttTopic);
    } else {
      Serial.print("failed, rc=");
      Serial.print(mqttClient.state());
      Serial.println(" try again in 5 seconds");
      delay(5000);
    }
  }
}

// setup() and loop() functions...
void setup() {
  Serial.begin(115200);
  Serial.println("Booting");

  WiFi.mode(WIFI_STA);
  WiFi.begin(ssid, password);
  while (WiFi.waitForConnectResult() != WL_CONNECTED) {
    Serial.println("Connection Failed! Rebooting...");
    delay(5000);
    ESP.restart();
  }

  setupOTA();
  setupMQTT();
}

void loop() {
  if (!mqttClient.connected()) {
    reconnectMQTT();
  }
  mqttClient.loop();
  
  if (otaUpdateRequested) {
    Serial.println("Initiating OTA update...");
    otaUpdateRequested = false; // Reset the flag
    ArduinoOTA.begin(); // Start OTA update
  }
  ArduinoOTA.handle(); // Handle OTA update process
  // Your main application code goes here
}

Trying OTA firmware update using @thingsboard in ESP32

Answers (1)

Related Questions