|
|
@@ -15,17 +15,13 @@
|
|
|
#include <sys/unistd.h>
|
|
|
#include <sys/stat.h>
|
|
|
|
|
|
-#ifdef __cplusplus
|
|
|
-extern "C" {
|
|
|
-#endif
|
|
|
-#include <dirent.h>
|
|
|
-#ifdef __cplusplus
|
|
|
-}
|
|
|
-#endif
|
|
|
-
|
|
|
#include "esp_err.h"
|
|
|
#include "esp_log.h"
|
|
|
|
|
|
+#include <iostream>
|
|
|
+#include <sys/types.h>
|
|
|
+#include <dirent.h>
|
|
|
+
|
|
|
#include "esp_vfs.h"
|
|
|
#include <esp_spiffs.h>
|
|
|
#include "esp_http_server.h"
|
|
|
@@ -38,17 +34,17 @@ extern "C" {
|
|
|
#include "server_help.h"
|
|
|
#include "md5.h"
|
|
|
#ifdef ENABLE_MQTT
|
|
|
- #include "interface_mqtt.h"
|
|
|
-#endif //ENABLE_MQTT
|
|
|
+#include "interface_mqtt.h"
|
|
|
+#endif // ENABLE_MQTT
|
|
|
#include "server_GPIO.h"
|
|
|
|
|
|
#include "Helper.h"
|
|
|
-#include "miniz.h"
|
|
|
#include "basic_auth.h"
|
|
|
|
|
|
static const char *TAG = "OTA FILE";
|
|
|
|
|
|
-struct file_server_data {
|
|
|
+struct file_server_data
|
|
|
+{
|
|
|
/* Base path of file storage */
|
|
|
char base_path[ESP_VFS_PATH_MAX + 1];
|
|
|
|
|
|
@@ -56,14 +52,6 @@ struct file_server_data {
|
|
|
char scratch[SERVER_FILER_SCRATCH_BUFSIZE];
|
|
|
};
|
|
|
|
|
|
-#include <iostream>
|
|
|
-#include <sys/types.h>
|
|
|
-#include <dirent.h>
|
|
|
-
|
|
|
-using namespace std;
|
|
|
-
|
|
|
-string SUFFIX_ZW = "_tmp";
|
|
|
-
|
|
|
static esp_err_t send_logfile(httpd_req_t *req, bool send_full_file);
|
|
|
static esp_err_t send_datafile(httpd_req_t *req, bool send_full_file);
|
|
|
|
|
|
@@ -71,7 +59,7 @@ esp_err_t get_numbers_file_handler(httpd_req_t *req)
|
|
|
{
|
|
|
std::string ret = flowctrl.getNumbersName();
|
|
|
|
|
|
-// ESP_LOGI(TAG, "Result get_numbers_file_handler: %s", ret.c_str());
|
|
|
+ // ESP_LOGI(TAG, "Result get_numbers_file_handler: %s", ret.c_str());
|
|
|
|
|
|
httpd_resp_set_hdr(req, "Access-Control-Allow-Origin", "*");
|
|
|
httpd_resp_set_type(req, "text/plain");
|
|
|
@@ -88,7 +76,7 @@ esp_err_t get_data_file_handler(httpd_req_t *req)
|
|
|
|
|
|
std::string _filename, _fileext;
|
|
|
size_t pos = 0;
|
|
|
-
|
|
|
+
|
|
|
const char verz_name[] = "/sdcard/log/data";
|
|
|
ESP_LOGD(TAG, "Suche data files in /sdcard/log/data");
|
|
|
|
|
|
@@ -96,13 +84,14 @@ esp_err_t get_data_file_handler(httpd_req_t *req)
|
|
|
httpd_resp_set_type(req, "text/plain");
|
|
|
|
|
|
DIR *dir = opendir(verz_name);
|
|
|
- while ((entry = readdir(dir)) != NULL)
|
|
|
+ while ((entry = readdir(dir)) != NULL)
|
|
|
{
|
|
|
_filename = std::string(entry->d_name);
|
|
|
ESP_LOGD(TAG, "File: %s", _filename.c_str());
|
|
|
|
|
|
// ignore all files with starting dot (hidden files)
|
|
|
- if (_filename.rfind(".", 0) == 0) {
|
|
|
+ if (_filename.rfind(".", 0) == 0)
|
|
|
+ {
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
@@ -131,7 +120,7 @@ esp_err_t get_tflite_file_handler(httpd_req_t *req)
|
|
|
|
|
|
std::string _filename, _fileext;
|
|
|
size_t pos = 0;
|
|
|
-
|
|
|
+
|
|
|
const char verz_name[] = "/sdcard/config";
|
|
|
ESP_LOGD(TAG, "Suche TFLITE in /sdcard/config/");
|
|
|
|
|
|
@@ -139,13 +128,14 @@ esp_err_t get_tflite_file_handler(httpd_req_t *req)
|
|
|
httpd_resp_set_type(req, "text/plain");
|
|
|
|
|
|
DIR *dir = opendir(verz_name);
|
|
|
- while ((entry = readdir(dir)) != NULL)
|
|
|
+ while ((entry = readdir(dir)) != NULL)
|
|
|
{
|
|
|
_filename = std::string(entry->d_name);
|
|
|
ESP_LOGD(TAG, "File: %s", _filename.c_str());
|
|
|
|
|
|
// ignore all files with starting dot (hidden files)
|
|
|
- if (_filename.rfind(".", 0) == 0) {
|
|
|
+ if (_filename.rfind(".", 0) == 0)
|
|
|
+ {
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
@@ -186,7 +176,8 @@ static esp_err_t http_resp_dir_html(httpd_req_t *req, const char *dirpath, const
|
|
|
|
|
|
file_server_data *server_data = (file_server_data *)req->user_ctx;
|
|
|
|
|
|
- if ((strlen(dirpath_corrected) - 1) > strlen(server_data->base_path)) {
|
|
|
+ if ((strlen(dirpath_corrected) - 1) > strlen(server_data->base_path))
|
|
|
+ {
|
|
|
// if dirpath is not mountpoint, the last "\" needs to be removed
|
|
|
dirpath_corrected[strlen(dirpath_corrected) - 1] = '\0';
|
|
|
}
|
|
|
@@ -200,7 +191,8 @@ static esp_err_t http_resp_dir_html(httpd_req_t *req, const char *dirpath, const
|
|
|
strlcpy(entrypath, dirpath, sizeof(entrypath));
|
|
|
ESP_LOGD(TAG, "entrypath: <%s>", entrypath);
|
|
|
|
|
|
- if (!pdir) {
|
|
|
+ if (!pdir)
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to stat dir: " + std::string(dirpath) + "!");
|
|
|
// Respond with 404 Not Found
|
|
|
httpd_resp_send_err(req, HTTPD_404_NOT_FOUND, get404());
|
|
|
@@ -244,7 +236,8 @@ static esp_err_t http_resp_dir_html(httpd_req_t *req, const char *dirpath, const
|
|
|
"<col width=\"800px\"><col width=\"300px\"><col width=\"300px\"><col width=\"100px\">"
|
|
|
"<thead><tr><th>Name</th><th>Type</th><th>Size</th>");
|
|
|
|
|
|
- if (!readonly) {
|
|
|
+ if (!readonly)
|
|
|
+ {
|
|
|
httpd_resp_sendstr_chunk(req, "<th><form method=\"post\" action=\"");
|
|
|
httpd_resp_sendstr_chunk(req, _zw.c_str());
|
|
|
httpd_resp_sendstr_chunk(req, "\"><button type=\"submit\">DELETE ALL!</button></form></th></tr>");
|
|
|
@@ -253,27 +246,34 @@ static esp_err_t http_resp_dir_html(httpd_req_t *req, const char *dirpath, const
|
|
|
httpd_resp_sendstr_chunk(req, "</thead><tbody>\n");
|
|
|
|
|
|
// Iterate over all files / folders and fetch their names and sizes
|
|
|
- while ((entry = readdir(pdir)) != NULL) {
|
|
|
+ while ((entry = readdir(pdir)) != NULL)
|
|
|
+ {
|
|
|
// wlan.ini soll nicht angezeigt werden!
|
|
|
- if (strcmp("wlan.ini", entry->d_name) != 0) {
|
|
|
+ if (strcmp("wlan.ini", entry->d_name) != 0)
|
|
|
+ {
|
|
|
entrytype = (entry->d_type == DT_DIR ? "directory" : "file");
|
|
|
|
|
|
strlcpy(entrypath + dirpath_len, entry->d_name, sizeof(entrypath) - dirpath_len);
|
|
|
ESP_LOGD(TAG, "Entrypath: %s", entrypath);
|
|
|
|
|
|
- if (stat(entrypath, &entry_stat) == -1) {
|
|
|
+ if (stat(entrypath, &entry_stat) == -1)
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to stat " + std::string(entrytype) + ": " + std::string(entry->d_name));
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
- if (entry->d_type == DT_DIR) {
|
|
|
+ if (entry->d_type == DT_DIR)
|
|
|
+ {
|
|
|
strcpy(entrysize, "-\0");
|
|
|
}
|
|
|
- else {
|
|
|
- if (entry_stat.st_size >= 1024) {
|
|
|
+ else
|
|
|
+ {
|
|
|
+ if (entry_stat.st_size >= 1024)
|
|
|
+ {
|
|
|
sprintf(entrysize, "%ld KiB", entry_stat.st_size / 1024); // kBytes
|
|
|
}
|
|
|
- else {
|
|
|
+ else
|
|
|
+ {
|
|
|
sprintf(entrysize, "%ld B", entry_stat.st_size); // Bytes
|
|
|
}
|
|
|
}
|
|
|
@@ -286,7 +286,8 @@ static esp_err_t http_resp_dir_html(httpd_req_t *req, const char *dirpath, const
|
|
|
httpd_resp_sendstr_chunk(req, uripath);
|
|
|
httpd_resp_sendstr_chunk(req, entry->d_name);
|
|
|
|
|
|
- if (entry->d_type == DT_DIR) {
|
|
|
+ if (entry->d_type == DT_DIR)
|
|
|
+ {
|
|
|
httpd_resp_sendstr_chunk(req, "/");
|
|
|
}
|
|
|
|
|
|
@@ -297,7 +298,8 @@ static esp_err_t http_resp_dir_html(httpd_req_t *req, const char *dirpath, const
|
|
|
httpd_resp_sendstr_chunk(req, "</td><td>");
|
|
|
httpd_resp_sendstr_chunk(req, entrysize);
|
|
|
|
|
|
- if (!readonly) {
|
|
|
+ if (!readonly)
|
|
|
+ {
|
|
|
httpd_resp_sendstr_chunk(req, "</td><td>");
|
|
|
httpd_resp_sendstr_chunk(req, "<form method=\"post\" action=\"/delete");
|
|
|
httpd_resp_sendstr_chunk(req, uripath);
|
|
|
@@ -322,19 +324,23 @@ static esp_err_t http_resp_dir_html(httpd_req_t *req, const char *dirpath, const
|
|
|
return ESP_OK;
|
|
|
}
|
|
|
|
|
|
-static esp_err_t logfileact_get_full_handler(httpd_req_t *req) {
|
|
|
+static esp_err_t logfileact_get_full_handler(httpd_req_t *req)
|
|
|
+{
|
|
|
return send_logfile(req, true);
|
|
|
}
|
|
|
|
|
|
-static esp_err_t logfileact_get_last_part_handler(httpd_req_t *req) {
|
|
|
+static esp_err_t logfileact_get_last_part_handler(httpd_req_t *req)
|
|
|
+{
|
|
|
return send_logfile(req, false);
|
|
|
}
|
|
|
|
|
|
-static esp_err_t datafileact_get_full_handler(httpd_req_t *req) {
|
|
|
+static esp_err_t datafileact_get_full_handler(httpd_req_t *req)
|
|
|
+{
|
|
|
return send_datafile(req, true);
|
|
|
}
|
|
|
|
|
|
-static esp_err_t datafileact_get_last_part_handler(httpd_req_t *req) {
|
|
|
+static esp_err_t datafileact_get_last_part_handler(httpd_req_t *req)
|
|
|
+{
|
|
|
return send_datafile(req, false);
|
|
|
}
|
|
|
|
|
|
@@ -342,7 +348,7 @@ static esp_err_t send_datafile(httpd_req_t *req, bool send_full_file)
|
|
|
{
|
|
|
LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "data_get_last_part_handler");
|
|
|
FILE *fd = NULL;
|
|
|
- //struct stat file_stat;
|
|
|
+ // struct stat file_stat;
|
|
|
ESP_LOGD(TAG, "uri: %s", req->uri);
|
|
|
|
|
|
std::string currentfilename = LogFile.GetCurrentFileNameData();
|
|
|
@@ -350,7 +356,8 @@ static esp_err_t send_datafile(httpd_req_t *req, bool send_full_file)
|
|
|
ESP_LOGD(TAG, "uri: %s, filename: %s, filepath: %s", req->uri, currentfilename.c_str(), currentfilename.c_str());
|
|
|
|
|
|
fd = fopen(currentfilename.c_str(), "r");
|
|
|
- if (!fd) {
|
|
|
+ if (!fd)
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to read file: " + currentfilename + "!");
|
|
|
/* Respond with 404 Error */
|
|
|
httpd_resp_send_err(req, HTTPD_404_NOT_FOUND, get404());
|
|
|
@@ -359,30 +366,36 @@ static esp_err_t send_datafile(httpd_req_t *req, bool send_full_file)
|
|
|
|
|
|
httpd_resp_set_hdr(req, "Access-Control-Allow-Origin", "*");
|
|
|
|
|
|
-// ESP_LOGI(TAG, "Sending file: %s (%ld bytes)...", &filename, file_stat.st_size);
|
|
|
+ // ESP_LOGI(TAG, "Sending file: %s (%ld bytes)...", &filename, file_stat.st_size);
|
|
|
set_content_type_from_file(req, currentfilename.c_str());
|
|
|
|
|
|
- if (!send_full_file) { // Send only last part of file
|
|
|
+ if (!send_full_file)
|
|
|
+ { // Send only last part of file
|
|
|
ESP_LOGD(TAG, "Sending last %d bytes of the actual datafile!", LOGFILE_LAST_PART_BYTES);
|
|
|
|
|
|
/* Adapted from https://www.geeksforgeeks.org/implement-your-own-tail-read-last-n-lines-of-a-huge-file/ */
|
|
|
- if (fseek(fd, 0, SEEK_END)) {
|
|
|
+ if (fseek(fd, 0, SEEK_END))
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to get to end of file!");
|
|
|
return ESP_FAIL;
|
|
|
}
|
|
|
- else {
|
|
|
+ else
|
|
|
+ {
|
|
|
long pos = ftell(fd); // Number of bytes in the file
|
|
|
ESP_LOGI(TAG, "File contains %ld bytes", pos);
|
|
|
|
|
|
- if (fseek(fd, pos - std::min((long)LOGFILE_LAST_PART_BYTES, pos), SEEK_SET)) { // Go LOGFILE_LAST_PART_BYTES bytes back from EOF
|
|
|
+ if (fseek(fd, pos - std::min((long)LOGFILE_LAST_PART_BYTES, pos), SEEK_SET))
|
|
|
+ { // Go LOGFILE_LAST_PART_BYTES bytes back from EOF
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to go back " + to_string(std::min((long)LOGFILE_LAST_PART_BYTES, pos)) + " bytes within the file!");
|
|
|
return ESP_FAIL;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/* Find end of line */
|
|
|
- while (1) {
|
|
|
- if (fgetc(fd) == '\n') {
|
|
|
+ while (1)
|
|
|
+ {
|
|
|
+ if (fgetc(fd) == '\n')
|
|
|
+ {
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
@@ -391,12 +404,14 @@ static esp_err_t send_datafile(httpd_req_t *req, bool send_full_file)
|
|
|
/* Retrieve the pointer to scratch buffer for temporary storage */
|
|
|
char *chunk = ((struct file_server_data *)req->user_ctx)->scratch;
|
|
|
size_t chunksize;
|
|
|
- do {
|
|
|
+ do
|
|
|
+ {
|
|
|
/* Read file in chunks into the scratch buffer */
|
|
|
chunksize = fread(chunk, 1, SERVER_FILER_SCRATCH_BUFSIZE, fd);
|
|
|
|
|
|
/* Send the buffer contents as HTTP response chunk */
|
|
|
- if (httpd_resp_send_chunk(req, chunk, chunksize) != ESP_OK) {
|
|
|
+ if (httpd_resp_send_chunk(req, chunk, chunksize) != ESP_OK)
|
|
|
+ {
|
|
|
fclose(fd);
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "File sending failed!");
|
|
|
/* Abort sending file */
|
|
|
@@ -422,10 +437,10 @@ static esp_err_t send_logfile(httpd_req_t *req, bool send_full_file)
|
|
|
{
|
|
|
LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "log_get_last_part_handler");
|
|
|
FILE *fd = NULL;
|
|
|
- //struct stat file_stat;
|
|
|
+ // struct stat file_stat;
|
|
|
ESP_LOGI(TAG, "uri: %s", req->uri);
|
|
|
|
|
|
- const char* filename = "";
|
|
|
+ const char *filename = "";
|
|
|
|
|
|
std::string currentfilename = LogFile.GetCurrentFileName();
|
|
|
|
|
|
@@ -435,7 +450,8 @@ static esp_err_t send_logfile(httpd_req_t *req, bool send_full_file)
|
|
|
LogFile.CloseLogFileAppendHandle();
|
|
|
|
|
|
fd = fopen(currentfilename.c_str(), "r");
|
|
|
- if (!fd) {
|
|
|
+ if (!fd)
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to read file: " + currentfilename + "!");
|
|
|
/* Respond with 404 Error */
|
|
|
httpd_resp_send_err(req, HTTPD_404_NOT_FOUND, get404());
|
|
|
@@ -444,30 +460,36 @@ static esp_err_t send_logfile(httpd_req_t *req, bool send_full_file)
|
|
|
|
|
|
httpd_resp_set_hdr(req, "Access-Control-Allow-Origin", "*");
|
|
|
|
|
|
-// ESP_LOGI(TAG, "Sending file: %s (%ld bytes)...", &filename, file_stat.st_size);
|
|
|
+ // ESP_LOGI(TAG, "Sending file: %s (%ld bytes)...", &filename, file_stat.st_size);
|
|
|
set_content_type_from_file(req, filename);
|
|
|
|
|
|
- if (!send_full_file) { // Send only last part of file
|
|
|
+ if (!send_full_file)
|
|
|
+ { // Send only last part of file
|
|
|
ESP_LOGD(TAG, "Sending last %d bytes of the actual logfile!", LOGFILE_LAST_PART_BYTES);
|
|
|
|
|
|
/* Adapted from https://www.geeksforgeeks.org/implement-your-own-tail-read-last-n-lines-of-a-huge-file/ */
|
|
|
- if (fseek(fd, 0, SEEK_END)) {
|
|
|
+ if (fseek(fd, 0, SEEK_END))
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to get to end of file!");
|
|
|
return ESP_FAIL;
|
|
|
}
|
|
|
- else {
|
|
|
+ else
|
|
|
+ {
|
|
|
long pos = ftell(fd); // Number of bytes in the file
|
|
|
ESP_LOGI(TAG, "File contains %ld bytes", pos);
|
|
|
|
|
|
- if (fseek(fd, pos - std::min((long)LOGFILE_LAST_PART_BYTES, pos), SEEK_SET)) { // Go LOGFILE_LAST_PART_BYTES bytes back from EOF
|
|
|
+ if (fseek(fd, pos - std::min((long)LOGFILE_LAST_PART_BYTES, pos), SEEK_SET))
|
|
|
+ { // Go LOGFILE_LAST_PART_BYTES bytes back from EOF
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to go back " + to_string(std::min((long)LOGFILE_LAST_PART_BYTES, pos)) + " bytes within the file!");
|
|
|
return ESP_FAIL;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/* Find end of line */
|
|
|
- while (1) {
|
|
|
- if (fgetc(fd) == '\n') {
|
|
|
+ while (1)
|
|
|
+ {
|
|
|
+ if (fgetc(fd) == '\n')
|
|
|
+ {
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
@@ -476,12 +498,14 @@ static esp_err_t send_logfile(httpd_req_t *req, bool send_full_file)
|
|
|
/* Retrieve the pointer to scratch buffer for temporary storage */
|
|
|
char *chunk = ((struct file_server_data *)req->user_ctx)->scratch;
|
|
|
size_t chunksize;
|
|
|
- do {
|
|
|
+ do
|
|
|
+ {
|
|
|
/* Read file in chunks into the scratch buffer */
|
|
|
chunksize = fread(chunk, 1, SERVER_FILER_SCRATCH_BUFSIZE, fd);
|
|
|
|
|
|
/* Send the buffer contents as HTTP response chunk */
|
|
|
- if (httpd_resp_send_chunk(req, chunk, chunksize) != ESP_OK) {
|
|
|
+ if (httpd_resp_send_chunk(req, chunk, chunksize) != ESP_OK)
|
|
|
+ {
|
|
|
fclose(fd);
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "File sending failed!");
|
|
|
/* Abort sending file */
|
|
|
@@ -513,14 +537,15 @@ static esp_err_t download_get_handler(httpd_req_t *req)
|
|
|
ESP_LOGD(TAG, "uri: %s", req->uri);
|
|
|
|
|
|
const char *filename = get_path_from_uri(filepath, ((struct file_server_data *)req->user_ctx)->base_path,
|
|
|
- req->uri + sizeof("/fileserver") - 1, sizeof(filepath));
|
|
|
+ req->uri + sizeof("/fileserver") - 1, sizeof(filepath));
|
|
|
|
|
|
ESP_LOGD(TAG, "uri: %s, filename: %s, filepath: %s", req->uri, filename, filepath);
|
|
|
|
|
|
-// filename = get_path_from_uri(filepath, ((struct file_server_data *)req->user_ctx)->base_path,
|
|
|
-// req->uri, sizeof(filepath));
|
|
|
+ // filename = get_path_from_uri(filepath, ((struct file_server_data *)req->user_ctx)->base_path,
|
|
|
+ // req->uri, sizeof(filepath));
|
|
|
|
|
|
- if (!filename) {
|
|
|
+ if (!filename)
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Filename is too long");
|
|
|
/* Respond with 414 Error */
|
|
|
httpd_resp_send_err(req, HTTPD_414_URI_TOO_LONG, "Filename too long");
|
|
|
@@ -528,18 +553,22 @@ static esp_err_t download_get_handler(httpd_req_t *req)
|
|
|
}
|
|
|
|
|
|
/* If name has trailing '/', respond with directory contents */
|
|
|
- if (filename[strlen(filename) - 1] == '/') {
|
|
|
+ if (filename[strlen(filename) - 1] == '/')
|
|
|
+ {
|
|
|
bool readonly = false;
|
|
|
size_t buf_len = httpd_req_get_url_query_len(req) + 1;
|
|
|
- if (buf_len > 1) {
|
|
|
+ if (buf_len > 1)
|
|
|
+ {
|
|
|
char buf[buf_len];
|
|
|
- if (httpd_req_get_url_query_str(req, buf, buf_len) == ESP_OK) {
|
|
|
+ if (httpd_req_get_url_query_str(req, buf, buf_len) == ESP_OK)
|
|
|
+ {
|
|
|
ESP_LOGI(TAG, "Found URL query => %s", buf);
|
|
|
char param[32];
|
|
|
/* Get value of expected key from query string */
|
|
|
- if (httpd_query_key_value(buf, "readonly", param, sizeof(param)) == ESP_OK) {
|
|
|
+ if (httpd_query_key_value(buf, "readonly", param, sizeof(param)) == ESP_OK)
|
|
|
+ {
|
|
|
ESP_LOGI(TAG, "Found URL query parameter => readonly=%s", param);
|
|
|
- readonly = (strcmp(param,"true") == 0);
|
|
|
+ readonly = (strcmp(param, "true") == 0);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -550,7 +579,8 @@ static esp_err_t download_get_handler(httpd_req_t *req)
|
|
|
|
|
|
std::string testwlan = toUpper(std::string(filename));
|
|
|
|
|
|
- if ((stat(filepath, &file_stat) == -1) || (testwlan.compare("/WLAN.INI") == 0 )) { // wlan.ini soll nicht angezeigt werden!
|
|
|
+ if ((stat(filepath, &file_stat) == -1) || (testwlan.compare("/WLAN.INI") == 0))
|
|
|
+ { // wlan.ini soll nicht angezeigt werden!
|
|
|
|
|
|
/* If file not present on SPIFFS check if URI
|
|
|
* corresponds to one of the hardcoded paths */
|
|
|
@@ -561,7 +591,8 @@ static esp_err_t download_get_handler(httpd_req_t *req)
|
|
|
}
|
|
|
|
|
|
fd = fopen(filepath, "r");
|
|
|
- if (!fd) {
|
|
|
+ if (!fd)
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to read file: " + std::string(filepath) + "!");
|
|
|
/* Respond with 404 Error */
|
|
|
httpd_resp_send_err(req, HTTPD_404_NOT_FOUND, get404());
|
|
|
@@ -576,14 +607,16 @@ static esp_err_t download_get_handler(httpd_req_t *req)
|
|
|
/* Retrieve the pointer to scratch buffer for temporary storage */
|
|
|
char *chunk = ((struct file_server_data *)req->user_ctx)->scratch;
|
|
|
size_t chunksize;
|
|
|
- do {
|
|
|
+ do
|
|
|
+ {
|
|
|
/* Read file in chunks into the scratch buffer */
|
|
|
chunksize = fread(chunk, 1, SERVER_FILER_SCRATCH_BUFSIZE, fd);
|
|
|
|
|
|
/* Send buffer contents as HTTP chunk. If empty this functions as a
|
|
|
* last-chunk message, signaling end-of-response, to the HTTP client.
|
|
|
* See RFC 2616, section 3.6.1 for details on Chunked Transfer Encoding. */
|
|
|
- if (httpd_resp_send_chunk(req, chunk, chunksize) != ESP_OK) {
|
|
|
+ if (httpd_resp_send_chunk(req, chunk, chunksize) != ESP_OK)
|
|
|
+ {
|
|
|
fclose(fd);
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "File sending failed!");
|
|
|
/* Abort sending file */
|
|
|
@@ -619,21 +652,24 @@ static esp_err_t upload_post_handler(httpd_req_t *req)
|
|
|
/* Note sizeof() counts NULL termination hence the -1 */
|
|
|
const char *filename = get_path_from_uri(filepath, ((struct file_server_data *)req->user_ctx)->base_path,
|
|
|
req->uri + sizeof("/upload") - 1, sizeof(filepath));
|
|
|
- if (!filename) {
|
|
|
+ if (!filename)
|
|
|
+ {
|
|
|
/* Respond with 413 Error */
|
|
|
httpd_resp_send_err(req, HTTPD_414_URI_TOO_LONG, "Filename too long");
|
|
|
return ESP_FAIL;
|
|
|
}
|
|
|
|
|
|
/* Filename cannot have a trailing '/' */
|
|
|
- if (filename[strlen(filename) - 1] == '/') {
|
|
|
+ if (filename[strlen(filename) - 1] == '/')
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Invalid filename: " + string(filename));
|
|
|
/* Respond with 400 Bad Request */
|
|
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST, "Invalid filename");
|
|
|
return ESP_FAIL;
|
|
|
}
|
|
|
|
|
|
- if (stat(filepath, &file_stat) == 0) {
|
|
|
+ if (stat(filepath, &file_stat) == 0)
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "File already exists: " + string(filepath));
|
|
|
/* Respond with 400 Bad Request */
|
|
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST, "File already exists");
|
|
|
@@ -641,19 +677,20 @@ static esp_err_t upload_post_handler(httpd_req_t *req)
|
|
|
}
|
|
|
|
|
|
/* File cannot be larger than a limit */
|
|
|
- if (req->content_len > MAX_FILE_SIZE) {
|
|
|
+ if (req->content_len > MAX_FILE_SIZE)
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "File too large: " + to_string(req->content_len) + " bytes");
|
|
|
/* Respond with 400 Bad Request */
|
|
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST,
|
|
|
- "File size must be less than "
|
|
|
- MAX_FILE_SIZE_STR "!");
|
|
|
+ "File size must be less than " MAX_FILE_SIZE_STR "!");
|
|
|
/* Return failure to close underlying connection else the
|
|
|
* incoming file content will keep the socket busy */
|
|
|
return ESP_FAIL;
|
|
|
}
|
|
|
|
|
|
fd = fopen(filepath, "w");
|
|
|
- if (!fd) {
|
|
|
+ if (!fd)
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to create file: " + string(filepath));
|
|
|
/* Respond with 500 Internal Server Error */
|
|
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Failed to create file");
|
|
|
@@ -670,12 +707,15 @@ static esp_err_t upload_post_handler(httpd_req_t *req)
|
|
|
* the size of the file being uploaded */
|
|
|
int remaining = req->content_len;
|
|
|
|
|
|
- while (remaining > 0) {
|
|
|
+ while (remaining > 0)
|
|
|
+ {
|
|
|
|
|
|
ESP_LOGI(TAG, "Remaining size: %d", remaining);
|
|
|
/* Receive the file part by part into a buffer */
|
|
|
- if ((received = httpd_req_recv(req, buf, MIN(remaining, SERVER_FILER_SCRATCH_BUFSIZE))) <= 0) {
|
|
|
- if (received == HTTPD_SOCK_ERR_TIMEOUT) {
|
|
|
+ if ((received = httpd_req_recv(req, buf, MIN(remaining, SERVER_FILER_SCRATCH_BUFSIZE))) <= 0)
|
|
|
+ {
|
|
|
+ if (received == HTTPD_SOCK_ERR_TIMEOUT)
|
|
|
+ {
|
|
|
/* Retry if timeout occurred */
|
|
|
continue;
|
|
|
}
|
|
|
@@ -692,7 +732,8 @@ static esp_err_t upload_post_handler(httpd_req_t *req)
|
|
|
}
|
|
|
|
|
|
/* Write buffer content to file on storage */
|
|
|
- if (received && (received != fwrite(buf, 1, received, fd))) {
|
|
|
+ if (received && (received != fwrite(buf, 1, received, fd)))
|
|
|
+ {
|
|
|
/* Couldn't write everything to file!
|
|
|
* Storage may be full? */
|
|
|
fclose(fd);
|
|
|
@@ -715,11 +756,13 @@ static esp_err_t upload_post_handler(httpd_req_t *req)
|
|
|
ESP_LOGI(TAG, "File reception completed");
|
|
|
|
|
|
string s = req->uri;
|
|
|
- if (isInString(s, "?md5")) {
|
|
|
+ if (isInString(s, "?md5"))
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_INFO, TAG, "Calculate and return MD5 sum...");
|
|
|
-
|
|
|
+
|
|
|
fd = fopen(filepath, "r");
|
|
|
- if (!fd) {
|
|
|
+ if (!fd)
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to open file for reading: " + string(filepath));
|
|
|
/* Respond with 500 Internal Server Error */
|
|
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Failed to open file for reading");
|
|
|
@@ -734,7 +777,8 @@ static esp_err_t upload_post_handler(httpd_req_t *req)
|
|
|
md5File(fd, result);
|
|
|
fclose(fd);
|
|
|
|
|
|
- for (int i = 0; i < sizeof(result); i++) {
|
|
|
+ for (int i = 0; i < sizeof(result); i++)
|
|
|
+ {
|
|
|
snprintf(hex, sizeof(hex), "%02x", result[i]);
|
|
|
md5hex.append(hex);
|
|
|
}
|
|
|
@@ -745,13 +789,14 @@ static esp_err_t upload_post_handler(httpd_req_t *req)
|
|
|
|
|
|
httpd_resp_sendstr(req, response.c_str());
|
|
|
}
|
|
|
- else { // Return file server page
|
|
|
+ else
|
|
|
+ { // Return file server page
|
|
|
std::string directory = std::string(filepath);
|
|
|
size_t zw = directory.find("/");
|
|
|
size_t found = zw;
|
|
|
while (zw != std::string::npos)
|
|
|
{
|
|
|
- zw = directory.find("/", found+1);
|
|
|
+ zw = directory.find("/", found + 1);
|
|
|
if (zw != std::string::npos)
|
|
|
found = zw;
|
|
|
}
|
|
|
@@ -760,7 +805,7 @@ static esp_err_t upload_post_handler(httpd_req_t *req)
|
|
|
ESP_LOGD(TAG, "Directory: %s, start_fn: %d, found: %d", directory.c_str(), start_fn, found);
|
|
|
directory = directory.substr(start_fn, found - start_fn + 1);
|
|
|
directory = "/fileserver" + directory;
|
|
|
- // ESP_LOGD(TAG, "Directory danach 2: %s", directory.c_str());
|
|
|
+ // ESP_LOGD(TAG, "Directory danach 2: %s", directory.c_str());
|
|
|
|
|
|
/* Redirect onto root to see the updated file list */
|
|
|
if (strcmp(filename, "/config/config.ini") == 0 ||
|
|
|
@@ -773,11 +818,12 @@ static esp_err_t upload_post_handler(httpd_req_t *req)
|
|
|
strcmp(filename, "/img_tmp/ref0_org.jpg") == 0 ||
|
|
|
strcmp(filename, "/img_tmp/ref1.jpg") == 0 ||
|
|
|
strcmp(filename, "/img_tmp/ref1_org.jpg") == 0 ||
|
|
|
- strcmp(filename, "/img_tmp/reference.jpg") == 0 )
|
|
|
- {
|
|
|
+ strcmp(filename, "/img_tmp/reference.jpg") == 0)
|
|
|
+ {
|
|
|
httpd_resp_set_status(req, HTTPD_200); // Avoid reloading of folder content
|
|
|
}
|
|
|
- else {
|
|
|
+ else
|
|
|
+ {
|
|
|
httpd_resp_set_status(req, "303 See Other"); // Reload folder content after upload
|
|
|
}
|
|
|
|
|
|
@@ -795,20 +841,20 @@ static esp_err_t delete_post_handler(httpd_req_t *req)
|
|
|
char filepath[FILE_PATH_MAX];
|
|
|
struct stat file_stat;
|
|
|
|
|
|
-//////////////////////////////////////////////////////////////
|
|
|
+ //////////////////////////////////////////////////////////////
|
|
|
char _query[200];
|
|
|
- char _valuechar[30];
|
|
|
+ char _valuechar[30];
|
|
|
std::string fn = "/sdcard/firmware/";
|
|
|
std::string _task;
|
|
|
std::string directory;
|
|
|
- std::string zw;
|
|
|
+ std::string zw;
|
|
|
|
|
|
httpd_resp_set_hdr(req, "Access-Control-Allow-Origin", "*");
|
|
|
|
|
|
if (httpd_req_get_url_query_str(req, _query, 200) == ESP_OK)
|
|
|
{
|
|
|
ESP_LOGD(TAG, "Query: %s", _query);
|
|
|
-
|
|
|
+
|
|
|
if (httpd_query_key_value(_query, "task", _valuechar, 30) == ESP_OK)
|
|
|
{
|
|
|
LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "task is found: " + string(_valuechar));
|
|
|
@@ -821,55 +867,60 @@ static esp_err_t delete_post_handler(httpd_req_t *req)
|
|
|
/* Skip leading "/delete" from URI to get filename */
|
|
|
/* Note sizeof() counts NULL termination hence the -1 */
|
|
|
const char *filename = get_path_from_uri(filepath, ((struct file_server_data *)req->user_ctx)->base_path,
|
|
|
- req->uri + sizeof("/delete") - 1, sizeof(filepath));
|
|
|
- if (!filename) {
|
|
|
+ req->uri + sizeof("/delete") - 1, sizeof(filepath));
|
|
|
+ if (!filename)
|
|
|
+ {
|
|
|
/* Respond with 414 Error */
|
|
|
httpd_resp_send_err(req, HTTPD_414_URI_TOO_LONG, "Filename too long");
|
|
|
return ESP_FAIL;
|
|
|
}
|
|
|
zw = std::string(filename);
|
|
|
- zw = zw.substr(0, zw.length()-1);
|
|
|
+ zw = zw.substr(0, zw.length() - 1);
|
|
|
directory = "/fileserver" + zw + "/";
|
|
|
zw = "/sdcard" + zw;
|
|
|
ESP_LOGD(TAG, "Directory to delete: %s", zw.c_str());
|
|
|
|
|
|
delete_all_in_directory(zw);
|
|
|
-// directory = std::string(filepath);
|
|
|
-// directory = "/fileserver" + directory;
|
|
|
+ // directory = std::string(filepath);
|
|
|
+ // directory = "/fileserver" + directory;
|
|
|
ESP_LOGD(TAG, "Location after delete directory content: %s", directory.c_str());
|
|
|
/* Redirect onto root to see the updated file list */
|
|
|
-// httpd_resp_set_status(req, "303 See Other");
|
|
|
-// httpd_resp_set_hdr(req, "Location", directory.c_str());
|
|
|
-// httpd_resp_sendstr(req, "File deleted successfully");
|
|
|
-// return ESP_OK;
|
|
|
+ // httpd_resp_set_status(req, "303 See Other");
|
|
|
+ // httpd_resp_set_hdr(req, "Location", directory.c_str());
|
|
|
+ // httpd_resp_sendstr(req, "File deleted successfully");
|
|
|
+ // return ESP_OK;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
/* Skip leading "/delete" from URI to get filename */
|
|
|
/* Note sizeof() counts NULL termination hence the -1 */
|
|
|
const char *filename = get_path_from_uri(filepath, ((struct file_server_data *)req->user_ctx)->base_path,
|
|
|
- req->uri + sizeof("/delete") - 1, sizeof(filepath));
|
|
|
- if (!filename) {
|
|
|
+ req->uri + sizeof("/delete") - 1, sizeof(filepath));
|
|
|
+ if (!filename)
|
|
|
+ {
|
|
|
/* Respond with 500 Internal Server Error */
|
|
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Filename too long");
|
|
|
return ESP_FAIL;
|
|
|
}
|
|
|
|
|
|
/* Filename cannot have a trailing '/' */
|
|
|
- if (filename[strlen(filename) - 1] == '/') {
|
|
|
+ if (filename[strlen(filename) - 1] == '/')
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Invalid filename: " + string(filename));
|
|
|
/* Respond with 400 Bad Request */
|
|
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST, "Invalid filename");
|
|
|
return ESP_FAIL;
|
|
|
}
|
|
|
|
|
|
- if (strcmp(filename, "wlan.ini") == 0) {
|
|
|
+ if (strcmp(filename, "wlan.ini") == 0)
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to delete protected file : " + string(filename));
|
|
|
httpd_resp_send_err(req, HTTPD_403_FORBIDDEN, "Not allowed to delete wlan.ini");
|
|
|
return ESP_FAIL;
|
|
|
}
|
|
|
|
|
|
- if (stat(filepath, &file_stat) == -1) { // File does not exist
|
|
|
+ if (stat(filepath, &file_stat) == -1)
|
|
|
+ { // File does not exist
|
|
|
/* This is ok, we would delete it anyway */
|
|
|
LogFile.WriteToFile(ESP_LOG_INFO, TAG, "File does not exist: " + string(filename));
|
|
|
}
|
|
|
@@ -884,7 +935,7 @@ static esp_err_t delete_post_handler(httpd_req_t *req)
|
|
|
size_t found = zw;
|
|
|
while (zw != std::string::npos)
|
|
|
{
|
|
|
- zw = directory.find("/", found+1);
|
|
|
+ zw = directory.find("/", found + 1);
|
|
|
if (zw != std::string::npos)
|
|
|
found = zw;
|
|
|
}
|
|
|
@@ -894,7 +945,7 @@ static esp_err_t delete_post_handler(httpd_req_t *req)
|
|
|
directory = directory.substr(start_fn, found - start_fn + 1);
|
|
|
directory = "/fileserver" + directory;
|
|
|
ESP_LOGD(TAG, "Directory danach 4: %s", directory.c_str());
|
|
|
-
|
|
|
+
|
|
|
//////////////////////////////////////////////////////////////
|
|
|
|
|
|
/* Redirect onto root to see the updated file list */
|
|
|
@@ -908,11 +959,12 @@ static esp_err_t delete_post_handler(httpd_req_t *req)
|
|
|
strcmp(filename, "/img_tmp/ref0_org.jpg") == 0 ||
|
|
|
strcmp(filename, "/img_tmp/ref1.jpg") == 0 ||
|
|
|
strcmp(filename, "/img_tmp/ref1_org.jpg") == 0 ||
|
|
|
- strcmp(filename, "/img_tmp/reference.jpg") == 0 )
|
|
|
- {
|
|
|
+ strcmp(filename, "/img_tmp/reference.jpg") == 0)
|
|
|
+ {
|
|
|
httpd_resp_set_status(req, HTTPD_200); // Avoid reloading of folder content
|
|
|
}
|
|
|
- else {
|
|
|
+ else
|
|
|
+ {
|
|
|
httpd_resp_set_status(req, "303 See Other"); // Reload folder content after upload
|
|
|
}
|
|
|
}
|
|
|
@@ -928,328 +980,118 @@ void delete_all_in_directory(std::string _directory)
|
|
|
DIR *dir = opendir(_directory.c_str());
|
|
|
std::string filename;
|
|
|
|
|
|
- if (!dir) {
|
|
|
+ if (!dir)
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to stat dir: " + _directory);
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
/* Iterate over all files / folders and fetch their names and sizes */
|
|
|
- while ((entry = readdir(dir)) != NULL) {
|
|
|
- if (!(entry->d_type == DT_DIR)){
|
|
|
- if (strcmp("wlan.ini", entry->d_name) != 0){ // auf wlan.ini soll nicht zugegriffen werden !!!
|
|
|
+ while ((entry = readdir(dir)) != NULL)
|
|
|
+ {
|
|
|
+ if (!(entry->d_type == DT_DIR))
|
|
|
+ {
|
|
|
+ if (strcmp("wlan.ini", entry->d_name) != 0)
|
|
|
+ { // auf wlan.ini soll nicht zugegriffen werden !!!
|
|
|
filename = _directory + "/" + std::string(entry->d_name);
|
|
|
LogFile.WriteToFile(ESP_LOG_INFO, TAG, "Deleting file: " + filename);
|
|
|
/* Delete file */
|
|
|
- unlink(filename.c_str());
|
|
|
+ unlink(filename.c_str());
|
|
|
}
|
|
|
};
|
|
|
}
|
|
|
closedir(dir);
|
|
|
}
|
|
|
|
|
|
-std::string unzip_new(std::string _in_zip_file, std::string _html_tmp, std::string _html_final, std::string _target_bin, std::string _main, bool _initial_setup)
|
|
|
-{
|
|
|
- int i, sort_iter;
|
|
|
- mz_bool status;
|
|
|
- size_t uncomp_size;
|
|
|
- mz_zip_archive zip_archive;
|
|
|
- void* p;
|
|
|
- char archive_filename[64];
|
|
|
- std::string zw, ret = "";
|
|
|
- std::string directory = "";
|
|
|
-
|
|
|
- ESP_LOGD(TAG, "miniz.c version: %s", MZ_VERSION);
|
|
|
- ESP_LOGD(TAG, "Zipfile: %s", _in_zip_file.c_str());
|
|
|
-
|
|
|
- // Now try to open the archive.
|
|
|
- memset(&zip_archive, 0, sizeof(zip_archive));
|
|
|
- status = mz_zip_reader_init_file(&zip_archive, _in_zip_file.c_str(), 0);
|
|
|
- if (!status)
|
|
|
- {
|
|
|
- ESP_LOGD(TAG, "mz_zip_reader_init_file() failed!");
|
|
|
- return ret;
|
|
|
- }
|
|
|
-
|
|
|
- // Get and print information about each file in the archive.
|
|
|
- int numberoffiles = (int)mz_zip_reader_get_num_files(&zip_archive);
|
|
|
- LogFile.WriteToFile(ESP_LOG_INFO, TAG, "Files to be extracted: " + to_string(numberoffiles));
|
|
|
-
|
|
|
- sort_iter = 0;
|
|
|
- {
|
|
|
- memset(&zip_archive, 0, sizeof(zip_archive));
|
|
|
- status = mz_zip_reader_init_file(&zip_archive, _in_zip_file.c_str(), sort_iter ? MZ_ZIP_FLAG_DO_NOT_SORT_CENTRAL_DIRECTORY : 0);
|
|
|
- if (!status)
|
|
|
- {
|
|
|
- ESP_LOGD(TAG, "mz_zip_reader_init_file() failed!");
|
|
|
- return ret;
|
|
|
- }
|
|
|
-
|
|
|
- for (i = 0; i < numberoffiles; i++)
|
|
|
- {
|
|
|
- mz_zip_archive_file_stat file_stat;
|
|
|
- mz_zip_reader_file_stat(&zip_archive, i, &file_stat);
|
|
|
- sprintf(archive_filename, file_stat.m_filename);
|
|
|
-
|
|
|
- if (!file_stat.m_is_directory) {
|
|
|
- // Try to extract all the files to the heap.
|
|
|
- p = mz_zip_reader_extract_file_to_heap(&zip_archive, archive_filename, &uncomp_size, 0);
|
|
|
- if (!p)
|
|
|
- {
|
|
|
- LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "mz_zip_reader_extract_file_to_heap() failed on file " + string(archive_filename));
|
|
|
- mz_zip_reader_end(&zip_archive);
|
|
|
- return ret;
|
|
|
- }
|
|
|
-
|
|
|
- // Save to File.
|
|
|
- zw = std::string(archive_filename);
|
|
|
- ESP_LOGD(TAG, "Rohfilename: %s", zw.c_str());
|
|
|
-
|
|
|
- if (toUpper(zw) == "FIRMWARE.BIN")
|
|
|
- {
|
|
|
- zw = _target_bin + zw;
|
|
|
- ret = zw;
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- std::string _dir = getDirectory(zw);
|
|
|
- if ((_dir == "config-initial") && !_initial_setup)
|
|
|
- {
|
|
|
- continue;
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- _dir = "config";
|
|
|
- std::string _s1 = "config-initial";
|
|
|
- FindReplace(zw, _s1, _dir);
|
|
|
- }
|
|
|
-
|
|
|
- if (_dir.length() > 0)
|
|
|
- {
|
|
|
- zw = _main + zw;
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- zw = _html_tmp + zw;
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- // files in the html folder shall be redirected to the temporary html folder
|
|
|
- if (zw.find(_html_final) == 0) {
|
|
|
- FindReplace(zw, _html_final, _html_tmp);
|
|
|
- }
|
|
|
-
|
|
|
- string filename_zw = zw + SUFFIX_ZW;
|
|
|
-
|
|
|
- ESP_LOGI(TAG, "File to extract: %s, Temp. Filename: %s", zw.c_str(), filename_zw.c_str());
|
|
|
-
|
|
|
- std::string folder = filename_zw.substr(0, filename_zw.find_last_of('/'));
|
|
|
- MakeDir(folder);
|
|
|
-
|
|
|
- // extrahieren in zwischendatei
|
|
|
- DeleteFile(filename_zw);
|
|
|
-
|
|
|
- FILE* fpTargetFile = fopen(filename_zw.c_str(), "wb");
|
|
|
- uint writtenbytes = fwrite(p, 1, (uint)uncomp_size, fpTargetFile);
|
|
|
- fclose(fpTargetFile);
|
|
|
-
|
|
|
- bool isokay = true;
|
|
|
-
|
|
|
- if (writtenbytes == (uint)uncomp_size)
|
|
|
- {
|
|
|
- isokay = true;
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- isokay = false;
|
|
|
- LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "ERROR in writting extracted file (function fwrite) extracted file \"" +
|
|
|
- string(archive_filename) + "\", size " + to_string(uncomp_size));
|
|
|
- }
|
|
|
-
|
|
|
- DeleteFile(zw);
|
|
|
- if (!isokay)
|
|
|
- LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "ERROR in fwrite \"" + string(archive_filename) + "\", size " + to_string(uncomp_size));
|
|
|
- isokay = isokay && RenameFile(filename_zw, zw);
|
|
|
- if (!isokay)
|
|
|
- LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "ERROR in Rename \"" + filename_zw + "\" to \"" + zw);
|
|
|
-
|
|
|
- if (isokay)
|
|
|
- LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "Successfully extracted file \"" + string(archive_filename) + "\", size " + to_string(uncomp_size));
|
|
|
- else
|
|
|
- {
|
|
|
- LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "ERROR in extracting file \"" + string(archive_filename) + "\", size " + to_string(uncomp_size));
|
|
|
- ret = "ERROR";
|
|
|
- }
|
|
|
- mz_free(p);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- // Close the archive, freeing any resources it was using
|
|
|
- mz_zip_reader_end(&zip_archive);
|
|
|
- }
|
|
|
-
|
|
|
- ESP_LOGD(TAG, "Success.");
|
|
|
- return ret;
|
|
|
-}
|
|
|
-
|
|
|
-void unzip(std::string _in_zip_file, std::string _target_directory){
|
|
|
- int i, sort_iter;
|
|
|
- mz_bool status;
|
|
|
- size_t uncomp_size;
|
|
|
- mz_zip_archive zip_archive;
|
|
|
- void* p;
|
|
|
- char archive_filename[64];
|
|
|
- std::string zw;
|
|
|
-// static const char* s_Test_archive_filename = "testhtml.zip";
|
|
|
-
|
|
|
- ESP_LOGD(TAG, "miniz.c version: %s", MZ_VERSION);
|
|
|
- ESP_LOGD(TAG, "Zipfile: %s", _in_zip_file.c_str());
|
|
|
- ESP_LOGD(TAG, "Target Dir: %s", _target_directory.c_str());
|
|
|
-
|
|
|
- // Now try to open the archive.
|
|
|
- memset(&zip_archive, 0, sizeof(zip_archive));
|
|
|
- status = mz_zip_reader_init_file(&zip_archive, _in_zip_file.c_str(), 0);
|
|
|
- if (!status)
|
|
|
- {
|
|
|
- LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "mz_zip_reader_init_file() failed!");
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- // Get and print information about each file in the archive.
|
|
|
- int numberoffiles = (int)mz_zip_reader_get_num_files(&zip_archive);
|
|
|
- for (sort_iter = 0; sort_iter < 2; sort_iter++)
|
|
|
- {
|
|
|
- memset(&zip_archive, 0, sizeof(zip_archive));
|
|
|
- status = mz_zip_reader_init_file(&zip_archive, _in_zip_file.c_str(), sort_iter ? MZ_ZIP_FLAG_DO_NOT_SORT_CENTRAL_DIRECTORY : 0);
|
|
|
- if (!status)
|
|
|
- {
|
|
|
- LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "mz_zip_reader_init_file() failed!");
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- for (i = 0; i < numberoffiles; i++)
|
|
|
- {
|
|
|
- mz_zip_archive_file_stat file_stat;
|
|
|
- mz_zip_reader_file_stat(&zip_archive, i, &file_stat);
|
|
|
- sprintf(archive_filename, file_stat.m_filename);
|
|
|
-
|
|
|
- // Try to extract all the files to the heap.
|
|
|
- p = mz_zip_reader_extract_file_to_heap(&zip_archive, archive_filename, &uncomp_size, 0);
|
|
|
- if (!p)
|
|
|
- {
|
|
|
- LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "mz_zip_reader_extract_file_to_heap() failed!");
|
|
|
- mz_zip_reader_end(&zip_archive);
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- // Save to File.
|
|
|
- zw = std::string(archive_filename);
|
|
|
- zw = _target_directory + zw;
|
|
|
- ESP_LOGD(TAG, "File to extract: %s", zw.c_str());
|
|
|
- FILE* fpTargetFile = fopen(zw.c_str(), "wb");
|
|
|
- fwrite(p, 1, (uint)uncomp_size, fpTargetFile);
|
|
|
- fclose(fpTargetFile);
|
|
|
-
|
|
|
- ESP_LOGD(TAG, "Successfully extracted file \"%s\", size %u", archive_filename, (uint)uncomp_size);
|
|
|
- // ESP_LOGD(TAG, "File data: \"%s\"", (const char*)p);
|
|
|
-
|
|
|
- // We're done.
|
|
|
- mz_free(p);
|
|
|
- }
|
|
|
-
|
|
|
- // Close the archive, freeing any resources it was using
|
|
|
- mz_zip_reader_end(&zip_archive);
|
|
|
- }
|
|
|
-
|
|
|
- ESP_LOGD(TAG, "Success.");
|
|
|
-}
|
|
|
-
|
|
|
void register_server_file_uri(httpd_handle_t server, const char *base_path)
|
|
|
{
|
|
|
static struct file_server_data *server_data = NULL;
|
|
|
|
|
|
/* Validate file storage base path */
|
|
|
- if (!base_path) {
|
|
|
-// if (!base_path || strcmp(base_path, "/spiffs") != 0) {
|
|
|
+ if (!base_path)
|
|
|
+ {
|
|
|
+ // if (!base_path || strcmp(base_path, "/spiffs") != 0) {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "File server base_path not set");
|
|
|
-// return ESP_ERR_INVALID_ARG;
|
|
|
+ // return ESP_ERR_INVALID_ARG;
|
|
|
}
|
|
|
|
|
|
- if (server_data) {
|
|
|
+ if (server_data)
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "File server already started");
|
|
|
-// return ESP_ERR_INVALID_STATE;
|
|
|
+ // return ESP_ERR_INVALID_STATE;
|
|
|
}
|
|
|
|
|
|
/* Allocate memory for server data */
|
|
|
- server_data = (file_server_data *) calloc(1, sizeof(struct file_server_data));
|
|
|
- if (!server_data) {
|
|
|
+ server_data = (file_server_data *)calloc(1, sizeof(struct file_server_data));
|
|
|
+ if (!server_data)
|
|
|
+ {
|
|
|
LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to allocate memory for server data");
|
|
|
-// return ESP_ERR_NO_MEM;
|
|
|
+ // return ESP_ERR_NO_MEM;
|
|
|
}
|
|
|
strlcpy(server_data->base_path, base_path,
|
|
|
sizeof(server_data->base_path));
|
|
|
|
|
|
/* URI handler for getting uploaded files */
|
|
|
-// char zw[sizeof(serverprefix)+1];
|
|
|
-// strcpy(zw, serverprefix);
|
|
|
-// zw[strlen(serverprefix)] = '*';
|
|
|
-// zw[strlen(serverprefix)+1] = '\0';
|
|
|
-// ESP_LOGD(TAG, "zw: %s", zw);
|
|
|
+ // char zw[sizeof(serverprefix)+1];
|
|
|
+ // strcpy(zw, serverprefix);
|
|
|
+ // zw[strlen(serverprefix)] = '*';
|
|
|
+ // zw[strlen(serverprefix)+1] = '\0';
|
|
|
+ // ESP_LOGD(TAG, "zw: %s", zw);
|
|
|
httpd_uri_t file_download = {
|
|
|
- .uri = "/fileserver*", // Match all URIs of type /path/to/file
|
|
|
- .method = HTTP_GET,
|
|
|
+ .uri = "/fileserver*", // Match all URIs of type /path/to/file
|
|
|
+ .method = HTTP_GET,
|
|
|
.handler = APPLY_BASIC_AUTH_FILTER(download_get_handler),
|
|
|
- .user_ctx = server_data // Pass server data as context
|
|
|
+ .user_ctx = server_data // Pass server data as context
|
|
|
};
|
|
|
httpd_register_uri_handler(server, &file_download);
|
|
|
|
|
|
httpd_uri_t file_datafileact = {
|
|
|
- .uri = "/datafileact", // Match all URIs of type /path/to/file
|
|
|
- .method = HTTP_GET,
|
|
|
+ .uri = "/datafileact", // Match all URIs of type /path/to/file
|
|
|
+ .method = HTTP_GET,
|
|
|
.handler = APPLY_BASIC_AUTH_FILTER(datafileact_get_full_handler),
|
|
|
- .user_ctx = server_data // Pass server data as context
|
|
|
+ .user_ctx = server_data // Pass server data as context
|
|
|
};
|
|
|
httpd_register_uri_handler(server, &file_datafileact);
|
|
|
|
|
|
httpd_uri_t file_datafile_last_part_handle = {
|
|
|
- .uri = "/data", // Match all URIs of type /path/to/file
|
|
|
- .method = HTTP_GET,
|
|
|
+ .uri = "/data", // Match all URIs of type /path/to/file
|
|
|
+ .method = HTTP_GET,
|
|
|
.handler = APPLY_BASIC_AUTH_FILTER(datafileact_get_last_part_handler),
|
|
|
- .user_ctx = server_data // Pass server data as context
|
|
|
+ .user_ctx = server_data // Pass server data as context
|
|
|
};
|
|
|
httpd_register_uri_handler(server, &file_datafile_last_part_handle);
|
|
|
|
|
|
httpd_uri_t file_logfileact = {
|
|
|
- .uri = "/logfileact", // Match all URIs of type /path/to/file
|
|
|
- .method = HTTP_GET,
|
|
|
+ .uri = "/logfileact", // Match all URIs of type /path/to/file
|
|
|
+ .method = HTTP_GET,
|
|
|
.handler = APPLY_BASIC_AUTH_FILTER(logfileact_get_full_handler),
|
|
|
- .user_ctx = server_data // Pass server data as context
|
|
|
+ .user_ctx = server_data // Pass server data as context
|
|
|
};
|
|
|
httpd_register_uri_handler(server, &file_logfileact);
|
|
|
|
|
|
httpd_uri_t file_logfile_last_part_handle = {
|
|
|
- .uri = "/log", // Match all URIs of type /path/to/file
|
|
|
- .method = HTTP_GET,
|
|
|
+ .uri = "/log", // Match all URIs of type /path/to/file
|
|
|
+ .method = HTTP_GET,
|
|
|
.handler = APPLY_BASIC_AUTH_FILTER(logfileact_get_last_part_handler),
|
|
|
- .user_ctx = server_data // Pass server data as context
|
|
|
+ .user_ctx = server_data // Pass server data as context
|
|
|
};
|
|
|
httpd_register_uri_handler(server, &file_logfile_last_part_handle);
|
|
|
|
|
|
/* URI handler for uploading files to server */
|
|
|
httpd_uri_t file_upload = {
|
|
|
- .uri = "/upload/*", // Match all URIs of type /upload/path/to/file
|
|
|
- .method = HTTP_POST,
|
|
|
+ .uri = "/upload/*", // Match all URIs of type /upload/path/to/file
|
|
|
+ .method = HTTP_POST,
|
|
|
.handler = APPLY_BASIC_AUTH_FILTER(upload_post_handler),
|
|
|
- .user_ctx = server_data // Pass server data as context
|
|
|
+ .user_ctx = server_data // Pass server data as context
|
|
|
};
|
|
|
httpd_register_uri_handler(server, &file_upload);
|
|
|
|
|
|
/* URI handler for deleting files from server */
|
|
|
httpd_uri_t file_delete = {
|
|
|
- .uri = "/delete/*", // Match all URIs of type /delete/path/to/file
|
|
|
- .method = HTTP_POST,
|
|
|
+ .uri = "/delete/*", // Match all URIs of type /delete/path/to/file
|
|
|
+ .method = HTTP_POST,
|
|
|
.handler = APPLY_BASIC_AUTH_FILTER(delete_post_handler),
|
|
|
- .user_ctx = server_data // Pass server data as context
|
|
|
+ .user_ctx = server_data // Pass server data as context
|
|
|
};
|
|
|
httpd_register_uri_handler(server, &file_delete);
|
|
|
}
|