You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
267 lines
7.0 KiB
267 lines
7.0 KiB
/*
|
|
|
|
ASYNC CLIENT OTA MODULE
|
|
|
|
Copyright (C) 2016-2019 by Xose Pérez <xose dot perez at gmail dot com>
|
|
|
|
*/
|
|
|
|
#if OTA_CLIENT == OTA_CLIENT_ASYNCTCP
|
|
|
|
// -----------------------------------------------------------------------------
|
|
// Terminal and MQTT OTA command handlers
|
|
// -----------------------------------------------------------------------------
|
|
|
|
#if TERMINAL_SUPPORT || OTA_MQTT_SUPPORT
|
|
|
|
#include <Schedule.h>
|
|
#include <ESPAsyncTCP.h>
|
|
|
|
#include "mqtt.h"
|
|
#include "ota.h"
|
|
#include "system.h"
|
|
#include "terminal.h"
|
|
|
|
#include "libs/URL.h"
|
|
|
|
const char OTA_REQUEST_TEMPLATE[] PROGMEM =
|
|
"GET %s HTTP/1.1\r\n"
|
|
"Host: %s\r\n"
|
|
"User-Agent: ESPurna\r\n"
|
|
"Connection: close\r\n\r\n";
|
|
|
|
struct ota_client_t {
|
|
enum state_t {
|
|
HEADERS,
|
|
DATA,
|
|
END
|
|
};
|
|
|
|
ota_client_t() = delete;
|
|
ota_client_t(const ota_client_t&) = delete;
|
|
|
|
ota_client_t(URL&& url);
|
|
|
|
bool connect();
|
|
|
|
state_t state = HEADERS;
|
|
size_t size = 0;
|
|
|
|
const URL url;
|
|
AsyncClient client;
|
|
};
|
|
|
|
std::unique_ptr<ota_client_t> _ota_client = nullptr;
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
void _otaClientDisconnect() {
|
|
DEBUG_MSG_P(PSTR("[OTA] Disconnected\n"));
|
|
_ota_client = nullptr;
|
|
}
|
|
|
|
void _otaClientOnDisconnect(void* arg, AsyncClient* client) {
|
|
DEBUG_MSG_P(PSTR("\n"));
|
|
otaFinalize(reinterpret_cast<ota_client_t*>(arg)->size, CUSTOM_RESET_OTA, true);
|
|
schedule_function(_otaClientDisconnect);
|
|
}
|
|
|
|
void _otaClientOnTimeout(void*, AsyncClient * client, uint32_t) {
|
|
client->close(true);
|
|
}
|
|
|
|
void _otaClientOnError(void*, AsyncClient* client, err_t error) {
|
|
DEBUG_MSG_P(PSTR("[OTA] ERROR: %s\n"), client->errorToString(error));
|
|
}
|
|
|
|
void _otaClientOnData(void* arg, AsyncClient* client, void* data, size_t len) {
|
|
|
|
ota_client_t* ota_client = reinterpret_cast<ota_client_t*>(arg);
|
|
auto* ptr = (char *) data;
|
|
|
|
// TODO: check status
|
|
// TODO: check for 3xx, discover `Location:` header and schedule
|
|
// another _otaClientFrom(location_header_url)
|
|
if (_ota_client->state == ota_client_t::HEADERS) {
|
|
ptr = (char *) strnstr((char *) data, "\r\n\r\n", len);
|
|
if (!ptr) {
|
|
return;
|
|
}
|
|
auto diff = ptr - ((char *) data);
|
|
|
|
_ota_client->state = ota_client_t::DATA;
|
|
len -= diff + 4;
|
|
if (!len) {
|
|
return;
|
|
}
|
|
ptr += 4;
|
|
}
|
|
|
|
if (ota_client->state == ota_client_t::DATA) {
|
|
|
|
if (!ota_client->size) {
|
|
|
|
// Check header before anything is written to the flash
|
|
if (!otaVerifyHeader((uint8_t *) ptr, len)) {
|
|
DEBUG_MSG_P(PSTR("[OTA] ERROR: No magic byte / invalid flash config"));
|
|
client->close(true);
|
|
ota_client->state = ota_client_t::END;
|
|
return;
|
|
}
|
|
|
|
// XXX: In case of non-chunked response, really parse headers and specify size via content-length value
|
|
Update.runAsync(true);
|
|
if (!Update.begin((ESP.getFreeSketchSpace() - 0x1000) & 0xFFFFF000)) {
|
|
otaPrintError();
|
|
client->close(true);
|
|
return;
|
|
}
|
|
|
|
}
|
|
|
|
// We can enter this callback even after client->close()
|
|
if (!Update.isRunning()) {
|
|
return;
|
|
}
|
|
|
|
if (Update.write((uint8_t *) ptr, len) != len) {
|
|
otaPrintError();
|
|
client->close(true);
|
|
ota_client->state = ota_client_t::END;
|
|
return;
|
|
}
|
|
|
|
ota_client->size += len;
|
|
otaProgress(ota_client->size);
|
|
|
|
delay(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
void _otaClientOnConnect(void* arg, AsyncClient* client) {
|
|
|
|
ota_client_t* ota_client = reinterpret_cast<ota_client_t*>(arg);
|
|
|
|
#if ASYNC_TCP_SSL_ENABLED
|
|
const auto check = getSetting("otaScCheck", OTA_SECURE_CLIENT_CHECK);
|
|
if ((check == SECURE_CLIENT_CHECK_FINGERPRINT) && (443 == _ota_url->port)) {
|
|
uint8_t fp[20] = {0};
|
|
sslFingerPrintArray(getSetting("otaFP", OTA_FINGERPRINT).c_str(), fp);
|
|
SSL * ssl = client->getSSL();
|
|
if (ssl_match_fingerprint(ssl, fp) != SSL_OK) {
|
|
DEBUG_MSG_P(PSTR("[OTA] Warning: certificate fingerpint doesn't match\n"));
|
|
client->close(true);
|
|
return;
|
|
}
|
|
}
|
|
#endif
|
|
|
|
// Disabling EEPROM rotation to prevent writing to EEPROM after the upgrade
|
|
eepromRotate(false);
|
|
|
|
DEBUG_MSG_P(PSTR("[OTA] Downloading %s\n"), ota_client->url.path.c_str());
|
|
char buffer[strlen_P(OTA_REQUEST_TEMPLATE) + ota_client->url.path.length() + ota_client->url.host.length()];
|
|
snprintf_P(buffer, sizeof(buffer), OTA_REQUEST_TEMPLATE, ota_client->url.path.c_str(), ota_client->url.host.c_str());
|
|
client->write(buffer);
|
|
}
|
|
|
|
ota_client_t::ota_client_t(URL&& url) :
|
|
url(std::move(url))
|
|
{
|
|
client.setRxTimeout(5);
|
|
client.onError(_otaClientOnError, nullptr);
|
|
client.onTimeout(_otaClientOnTimeout, nullptr);
|
|
client.onDisconnect(_otaClientOnDisconnect, this);
|
|
client.onData(_otaClientOnData, this);
|
|
client.onConnect(_otaClientOnConnect, this);
|
|
}
|
|
|
|
bool ota_client_t::connect() {
|
|
#if ASYNC_TCP_SSL_ENABLED
|
|
return client.connect(url.host.c_str(), url.port, 443 == url.port);
|
|
#else
|
|
return client.connect(url.host.c_str(), url.port);
|
|
#endif
|
|
}
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
void _otaClientFrom(const String& url) {
|
|
|
|
if (_ota_client) {
|
|
DEBUG_MSG_P(PSTR("[OTA] Already connected\n"));
|
|
return;
|
|
}
|
|
|
|
URL _url(url);
|
|
if (!_url.protocol.equals("http") && !_url.protocol.equals("https")) {
|
|
DEBUG_MSG_P(PSTR("[OTA] Incorrect URL specified\n"));
|
|
return;
|
|
}
|
|
|
|
_ota_client = std::make_unique<ota_client_t>(std::move(_url));
|
|
if (!_ota_client->connect()) {
|
|
DEBUG_MSG_P(PSTR("[OTA] Connection failed\n"));
|
|
}
|
|
|
|
}
|
|
|
|
#endif // TERMINAL_SUPPORT || OTA_MQTT_SUPPORT
|
|
|
|
#if TERMINAL_SUPPORT
|
|
|
|
void _otaClientInitCommands() {
|
|
|
|
terminalRegisterCommand(F("OTA"), [](Embedis* e) {
|
|
if (e->argc < 2) {
|
|
terminalError(F("OTA <url>"));
|
|
} else {
|
|
_otaClientFrom(String(e->argv[1]));
|
|
terminalOK();
|
|
}
|
|
});
|
|
|
|
}
|
|
|
|
#endif // TERMINAL_SUPPORT
|
|
|
|
#if OTA_MQTT_SUPPORT
|
|
|
|
void _otaClientMqttCallback(unsigned int type, const char * topic, const char * payload) {
|
|
|
|
if (type == MQTT_CONNECT_EVENT) {
|
|
mqttSubscribe(MQTT_TOPIC_OTA);
|
|
}
|
|
|
|
if (type == MQTT_MESSAGE_EVENT) {
|
|
String t = mqttMagnitude((char *) topic);
|
|
if (t.equals(MQTT_TOPIC_OTA)) {
|
|
DEBUG_MSG_P(PSTR("[OTA] Initiating from URL: %s\n"), payload);
|
|
_otaClientFrom(payload);
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
#endif // OTA_MQTT_SUPPORT
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
void otaClientSetup() {
|
|
|
|
// Backwards compatibility
|
|
moveSetting("otafp", "otaFP");
|
|
|
|
#if TERMINAL_SUPPORT
|
|
_otaClientInitCommands();
|
|
#endif
|
|
|
|
#if (MQTT_SUPPORT && OTA_MQTT_SUPPORT)
|
|
mqttRegister(_otaClientMqttCallback);
|
|
#endif
|
|
|
|
}
|
|
|
|
#endif // OTA_CLIENT == OTA_CLIENT_ASYNCTCP
|