ESP32 Forum

Code: Select all

void start_connection() {
  //ledflash (5, 100);
  WiFi.mode(WIFI_OFF);
  delay (15000);
  static uint16_t attempt = 0;
  uint8_t i = 0;
  WiFi.begin("xxxxxxxxxxxx", "xxxxxxxxx");
  WiFi.setHostname("ESP32");
  while (WiFi.status() != WL_CONNECTED && i++ < 70)
  {
    delay(200);
    if (debug == true)
    {
      Serial.print(".");
    }
   // ledflash (1, 400);
  }

  ++attempt;
  if (debug == true)
  {
    Serial.println("");
  }

  if (i == 71) {
    if (debug == true)
    {
      Serial.print("Connection: TIMEOUT on attempt: ");
      Serial.println(attempt);
    }
    if (attempt % 2 == 0)
      //Serial.println("Check if access point available or SSID and Password\r\n");
      //Serial.println ( "Scrittura errore 2 ");
      errore = 2;
    delay(100);
    return ;
  }

  if (debug == true)
  {
    Serial.println("");
    Serial.println("WiFi connected.");
    Serial.println("IP address: ");
    Serial.println(WiFi.localIP());

  }


  execOTA(bin1, mail_to);

}

void execOTA(String path, char* mail_to) {
  int len = strlen(mail_to);
  if (debug == true)
  {
    Serial.println ( "Scrittura errore 5 ");
  }
  delay(100);
  //Serial.println("Connecting to: " + String(host));
  // Connect to S3
  if (client.connect(host.c_str(), port)) {
    // Connection Succeed.
    // Fecthing the bin

    //Serial.println("Fetching Bin: " + String(path));
    // Serial.println("");

    // Get the contents of the bin file
    client.print(String("GET ") + path + " HTTP/1.1\r\n" +
                 "Host: " + host + "\r\n" +
                 "Cache-Control: no-cache\r\n" +
                 "Connection: close\r\n\r\n");

    // Check what is being sent
    //    Serial.print(String("GET ") + bin + " HTTP/1.1\r\n" +
    //                 "Host: " + host + "\r\n" +
    //                 "Cache-Control: no-cache\r\n" +
    //                 "Connection: close\r\n\r\n");

    unsigned long timeout = millis();
    while (client.available() == 0) {
      if (millis() - timeout > 35000) {
        if (debug == true)
        {
          Serial.println(">>> Client Timeout !");
          Serial.println ( "Scrittura errore 2 ");
        }
        errore = 2;
        delay(100);
        client.stop();
        return;
      }
    }

    // Once the response is available,
    // check stuff

    while (client.available()) {
      // read line till /n
      String line = client.readStringUntil('\n');
      // remove space, to check if the line is end of headers
      line.trim();
      //Serial.println(line);
      // if the the line is empty,
      // this is end of headers
      // break the while and feed the
      // remaining `client` to the
      // Update.writeStream();
      if (!line.length()) {
        //headers ended
        break; // and get the OTA started
      }

      // Check if the HTTP Response is 200
      // else break and Exit Update
      if (line.startsWith("HTTP/1.1")) {
        if (line.indexOf("200") < 0) {
          if (debug == true)
          {
            Serial.println("Got a non 200 status code from server. Exiting OTA Update.");
          }
          errore = 1;
          break;
        }
      }

      // extract headers here
      // Start with content length
      if (line.startsWith("Content-Length: ")) {
        contentLength = atoi((getHeaderValue(line, "Content-Length: ")).c_str());
        //Serial.println("Got " + String(contentLength) + " bytes from server");
      }

      // Next, the content type
      if (line.startsWith("Content-Type: ")) {
        contentType = getHeaderValue(line, "Content-Type: ");
        //Serial.println("Got " + contentType + " payload.");
        if (contentType == "application/octet-stream" || contentType == "application/macbinary") {
          isValidContentType = true;
        }
      }
    }
  } else {
    // Connect to S3 failed
    // May be try?
    // Probably a choppy network?
    if (debug == true)
    {
      Serial.println("Connection to " + String(host) + " failed. Please check your setup");
    }
    errore = 2;
    // retry??
    // execOTA();
  }
  if (debug == true)
  {
    Serial.println("Got " + contentType + " payload.");
    Serial.println("Got " + String(contentLength) + " bytes from server");
    // Check what is the contentLength and if content type is `application/octet-stream`
    Serial.println("contentLength : " + String(contentLength) + ", isValidContentType : " + String(isValidContentType));
    Serial.println("");
  }
  // check contentLength and content type
  if (contentLength && isValidContentType) {
    // Check if there is enough to OTA Update
    bool canBegin = Update.begin(contentLength);
    // If yes, begin
    if (canBegin) {
      errore = 3;
     // digitalWrite(ledPin, LOW);
      if (debug == true)
      {
        Serial.println("Begin OTA. This may take 2 - 5 mins to complete. Things might be quite for a while.. Patience!");
      }

      size_t written = Update.writeStream(client);

      if (written == contentLength) {
        if (debug == true)
        {
          Serial.println("Written : " + String(written) + " successfully");
        }

      } else {
        if (debug == true)
        {
          Serial.println("Written only : " + String(written) + "/" + String(contentLength) + ". Retry?" );

        }
       
        delay (1000);
        esp_restart();
        // retry??
        // execOTA();
      }
      Serial.println("test6");
      if (Update.end()) {
        if (debug == true)
        {
          Serial.println("OTA done!");
        }

        if (Update.isFinished()) {
          errore = 0;
          if (debug == true)
          {
            Serial.println("Update successfully completed. Rebooting.");
            Serial.println("Scrittura errore : ok");
          }
          delay (1000);
          esp_restart();
        } else {
          if (debug == true)
          {
            Serial.println("Update not finished? Something went wrong!");
          }
          errore = 3;
          esp_restart();
        }
      } else {
        if (debug == true)
        {
          Serial.println("Error Occurred. Error #: " + String(Update.getError()));
        }

      }
    } else {
      // not enough space to begin OTA
      // Understand the partitions and
      // space availability
      if (debug == true)
      {
        Serial.println("Not enough space to begin OTA");
      }
      errore = 4;
      client.flush();
    }
  } else {

    if (debug == true)
    {
      Serial.println("There was no content in the response");
    }

    firm_tent ++;
    errore = 6;
    delay (300);

    switch (firm_tent) {

      case 1:
        ledflash (2, 50);
        delay (500);
        execOTA(bin2, mail_to);
        client.flush();
        break;
      case 2:
        ledflash (2, 50);
        delay (500);
        execOTA(bin3, mail_to);
        client.flush();
        break;
      case 3:
        ledflash (2, 50);
        delay (500);
        execOTA(bin4, mail_to);
        client.flush();
        break;
      case 4:
        ledflash (2, 50);
        delay (500);
        execOTA(bin4, mail_to);
        client.flush();
        break;
      default:
        esp_restart();
        break;

    }

  }
}

Code: Select all

const esp_partition_t my_new_nvs_partition = {
    .type = ESP_PARTITION_TYPE_DATA,
    .subtype = ESP_PARTITION_SUBTYPE_DATA_NVS,
    .address = 0x500000,
    .size = 0x10000,
    .label = "nvs2",
};
nvs_flash_init_partition_ptr(&my_new_nvs_partition);