mirror of
https://github.com/jomjol/AI-on-the-edge-device.git
synced 2025-12-06 11:36:51 +03:00
648 lines
23 KiB
C++
648 lines
23 KiB
C++
/* HTTP File Server Example
|
|
|
|
This example code is in the Public Domain (or CC0 licensed, at your option.)
|
|
|
|
Unless required by applicable law or agreed to in writing, this
|
|
software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
|
|
CONDITIONS OF ANY KIND, either express or implied.
|
|
*/
|
|
|
|
|
|
#include "server_file.h"
|
|
|
|
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
#include <string>
|
|
#include <sys/param.h>
|
|
#include <sys/unistd.h>
|
|
#include <sys/stat.h>
|
|
#include <dirent.h>
|
|
|
|
#include "esp_err.h"
|
|
#include "esp_log.h"
|
|
|
|
#include "esp_vfs.h"
|
|
#include "esp_spiffs.h"
|
|
#include "esp_http_server.h"
|
|
|
|
#include "ClassLogFile.h"
|
|
|
|
#include "server_help.h"
|
|
|
|
#include "Helper.h"
|
|
#include "miniz.h"
|
|
|
|
/* Max length a file path can have on storage */
|
|
// #define FILE_PATH_MAX (ESP_VFS_PATH_MAX + CONFIG_SPIFFS_OBJ_NAME_LEN)
|
|
#define FILE_PATH_MAX (255)
|
|
|
|
/* Max size of an individual file. Make sure this
|
|
* value is same as that set in upload_script.html */
|
|
#define MAX_FILE_SIZE (2000*1024) // 200 KB
|
|
#define MAX_FILE_SIZE_STR "2000KB"
|
|
|
|
/* Scratch buffer size */
|
|
#define SCRATCH_BUFSIZE 8192
|
|
|
|
struct file_server_data {
|
|
/* Base path of file storage */
|
|
char base_path[ESP_VFS_PATH_MAX + 1];
|
|
|
|
/* Scratch buffer for temporary storage during file transfer */
|
|
char scratch[SCRATCH_BUFSIZE];
|
|
};
|
|
|
|
static const char *TAG = "file_server";
|
|
|
|
/* Handler to redirect incoming GET request for /index.html to /
|
|
* This can be overridden by uploading file with same name */
|
|
static esp_err_t index_html_get_handler(httpd_req_t *req)
|
|
{
|
|
httpd_resp_set_status(req, "307 Temporary Redirect");
|
|
httpd_resp_set_hdr(req, "Location", "/");
|
|
httpd_resp_send(req, NULL, 0); // Response body can be empty
|
|
return ESP_OK;
|
|
}
|
|
|
|
/* Handler to respond with an icon file embedded in flash.
|
|
* Browsers expect to GET website icon at URI /favicon.ico.
|
|
* This can be overridden by uploading file with same name */
|
|
static esp_err_t favicon_get_handler(httpd_req_t *req)
|
|
{
|
|
extern const unsigned char favicon_ico_start[] asm("_binary_favicon_ico_start");
|
|
extern const unsigned char favicon_ico_end[] asm("_binary_favicon_ico_end");
|
|
const size_t favicon_ico_size = (favicon_ico_end - favicon_ico_start);
|
|
httpd_resp_set_type(req, "image/x-icon");
|
|
httpd_resp_send(req, (const char *)favicon_ico_start, favicon_ico_size);
|
|
/* Respond with an empty chunk to signal HTTP response completion */
|
|
httpd_resp_send_chunk(req, NULL, 0);
|
|
return ESP_OK;
|
|
}
|
|
|
|
/* Send HTTP response with a run-time generated html consisting of
|
|
* a list of all files and folders under the requested path.
|
|
* In case of SPIFFS this returns empty list when path is any
|
|
* string other than '/', since SPIFFS doesn't support directories */
|
|
static esp_err_t http_resp_dir_html(httpd_req_t *req, const char *dirpath)
|
|
{
|
|
char entrypath[FILE_PATH_MAX];
|
|
char entrysize[16];
|
|
const char *entrytype;
|
|
|
|
struct dirent *entry;
|
|
struct stat entry_stat;
|
|
|
|
char dirpath_corrected[FILE_PATH_MAX];
|
|
strcpy(dirpath_corrected, dirpath);
|
|
|
|
file_server_data * server_data = (file_server_data *) req->user_ctx;
|
|
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';
|
|
|
|
DIR *dir = opendir(dirpath_corrected);
|
|
|
|
const size_t dirpath_len = strlen(dirpath);
|
|
printf("Dirpath: <%s>, Pathlength: %d\n", dirpath, dirpath_len);
|
|
|
|
/* Retrieve the base path of file storage to construct the full path */
|
|
strlcpy(entrypath, dirpath, sizeof(entrypath));
|
|
printf("entrypath: <%s>\n", entrypath);
|
|
|
|
if (!dir) {
|
|
ESP_LOGE(TAG, "Failed to stat dir : %s", dirpath);
|
|
/* Respond with 404 Not Found */
|
|
httpd_resp_send_err(req, HTTPD_404_NOT_FOUND, "Directory does not exist");
|
|
return ESP_FAIL;
|
|
}
|
|
|
|
/* Send HTML file header */
|
|
httpd_resp_sendstr_chunk(req, "<!DOCTYPE html><html><body>");
|
|
|
|
/* Get handle to embedded file upload script */
|
|
extern const unsigned char upload_script_start[] asm("_binary_upload_script_html_start");
|
|
extern const unsigned char upload_script_end[] asm("_binary_upload_script_html_end");
|
|
const size_t upload_script_size = (upload_script_end - upload_script_start);
|
|
|
|
/* Add file upload form and script which on execution sends a POST request to /upload */
|
|
httpd_resp_send_chunk(req, (const char *)upload_script_start, upload_script_size);
|
|
|
|
|
|
/////////////////////////////////////////////////
|
|
/*
|
|
FILE *fd = fopen("/sdcard/html/file_server_upload_script.html", "r");
|
|
char *chunk = ((struct file_server_data *)req->user_ctx)->scratch;
|
|
size_t chunksize;
|
|
do {
|
|
chunksize = fread(chunk, 1, SCRATCH_BUFSIZE, fd);
|
|
if (httpd_resp_send_chunk(req, chunk, chunksize) != ESP_OK) {
|
|
fclose(fd);
|
|
ESP_LOGE(TAG, "File sending failed!");
|
|
return ESP_FAIL;
|
|
}
|
|
} while (chunksize != 0);
|
|
fclose(fd);
|
|
ESP_LOGI(TAG, "File sending complete");
|
|
httpd_resp_send_chunk(req, NULL, 0);
|
|
*/
|
|
///////////////////////////////
|
|
|
|
|
|
/* Send file-list table definition and column labels */
|
|
httpd_resp_sendstr_chunk(req,
|
|
"<table class=\"fixed\" border=\"1\">"
|
|
"<col width=\"800px\" /><col width=\"300px\" /><col width=\"300px\" /><col width=\"100px\" />"
|
|
"<thead><tr><th>Name</th><th>Type</th><th>Size (Bytes)</th><th>Delete</th></tr></thead>"
|
|
"<tbody>");
|
|
|
|
/* Iterate over all files / folders and fetch their names and sizes */
|
|
while ((entry = readdir(dir)) != NULL) {
|
|
if (strcmp("wlan.ini", entry->d_name) != 0 ) // wlan.ini soll nicht angezeigt werden!
|
|
{
|
|
entrytype = (entry->d_type == DT_DIR ? "directory" : "file");
|
|
|
|
strlcpy(entrypath + dirpath_len, entry->d_name, sizeof(entrypath) - dirpath_len);
|
|
printf("Entrypath: %s\n", entrypath);
|
|
if (stat(entrypath, &entry_stat) == -1) {
|
|
ESP_LOGE(TAG, "Failed to stat %s : %s", entrytype, entry->d_name);
|
|
continue;
|
|
}
|
|
sprintf(entrysize, "%ld", entry_stat.st_size);
|
|
ESP_LOGI(TAG, "Found %s : %s (%s bytes)", entrytype, entry->d_name, entrysize);
|
|
|
|
/* Send chunk of HTML file containing table entries with file name and size */
|
|
httpd_resp_sendstr_chunk(req, "<tr><td><a href=\"");
|
|
httpd_resp_sendstr_chunk(req, req->uri);
|
|
httpd_resp_sendstr_chunk(req, entry->d_name);
|
|
if (entry->d_type == DT_DIR) {
|
|
httpd_resp_sendstr_chunk(req, "/");
|
|
}
|
|
httpd_resp_sendstr_chunk(req, "\">");
|
|
httpd_resp_sendstr_chunk(req, entry->d_name);
|
|
httpd_resp_sendstr_chunk(req, "</a></td><td>");
|
|
httpd_resp_sendstr_chunk(req, entrytype);
|
|
httpd_resp_sendstr_chunk(req, "</td><td>");
|
|
httpd_resp_sendstr_chunk(req, entrysize);
|
|
httpd_resp_sendstr_chunk(req, "</td><td>");
|
|
httpd_resp_sendstr_chunk(req, "<form method=\"post\" action=\"/delete");
|
|
httpd_resp_sendstr_chunk(req, req->uri + strlen("/fileserver"));
|
|
httpd_resp_sendstr_chunk(req, entry->d_name);
|
|
httpd_resp_sendstr_chunk(req, "\"><button type=\"submit\">Delete</button></form>");
|
|
httpd_resp_sendstr_chunk(req, "</td></tr>\n");
|
|
}
|
|
}
|
|
closedir(dir);
|
|
|
|
/* Finish the file list table */
|
|
httpd_resp_sendstr_chunk(req, "</tbody></table>");
|
|
|
|
/* Send remaining chunk of HTML file to complete it */
|
|
httpd_resp_sendstr_chunk(req, "</body></html>");
|
|
|
|
/* Send empty chunk to signal HTTP response completion */
|
|
httpd_resp_sendstr_chunk(req, NULL);
|
|
return ESP_OK;
|
|
}
|
|
|
|
#define IS_FILE_EXT(filename, ext) \
|
|
(strcasecmp(&filename[strlen(filename) - sizeof(ext) + 1], ext) == 0)
|
|
|
|
|
|
/* Handler to download a file kept on the server */
|
|
static esp_err_t download_get_handler(httpd_req_t *req)
|
|
{
|
|
LogFile.WriteToFile("download_get_handler");
|
|
char filepath[FILE_PATH_MAX];
|
|
FILE *fd = NULL;
|
|
struct stat file_stat;
|
|
printf("uri: %s\n", 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));
|
|
|
|
printf("uri: %s, filename: %s, filepath: %s\n", req->uri, filename, filepath);
|
|
|
|
// filename = get_path_from_uri(filepath, ((struct file_server_data *)req->user_ctx)->base_path,
|
|
// req->uri, sizeof(filepath));
|
|
|
|
if (!filename) {
|
|
ESP_LOGE(TAG, "Filename is too long");
|
|
/* Respond with 500 Internal Server Error */
|
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Filename too long");
|
|
return ESP_FAIL;
|
|
}
|
|
|
|
/* If name has trailing '/', respond with directory contents */
|
|
if (filename[strlen(filename) - 1] == '/') {
|
|
return http_resp_dir_html(req, filepath);
|
|
}
|
|
|
|
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 file not present on SPIFFS check if URI
|
|
* corresponds to one of the hardcoded paths */
|
|
ESP_LOGE(TAG, "Failed to stat file : %s", filepath);
|
|
/* Respond with 404 Not Found */
|
|
httpd_resp_send_err(req, HTTPD_404_NOT_FOUND, "File does not exist");
|
|
return ESP_FAIL;
|
|
}
|
|
|
|
fd = fopen(filepath, "r");
|
|
if (!fd) {
|
|
ESP_LOGE(TAG, "Failed to read existing file : %s", filepath);
|
|
/* Respond with 500 Internal Server Error */
|
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Failed to read existing file");
|
|
return ESP_FAIL;
|
|
}
|
|
|
|
esp_err_t res = httpd_resp_set_hdr(req, "Access-Control-Allow-Origin", "*");
|
|
|
|
ESP_LOGI(TAG, "Sending file : %s (%ld bytes)...", filename, file_stat.st_size);
|
|
set_content_type_from_file(req, filename);
|
|
|
|
/* Retrieve the pointer to scratch buffer for temporary storage */
|
|
char *chunk = ((struct file_server_data *)req->user_ctx)->scratch;
|
|
size_t chunksize;
|
|
do {
|
|
/* Read file in chunks into the scratch buffer */
|
|
chunksize = fread(chunk, 1, SCRATCH_BUFSIZE, fd);
|
|
|
|
/* Send the buffer contents as HTTP response chunk */
|
|
if (httpd_resp_send_chunk(req, chunk, chunksize) != ESP_OK) {
|
|
fclose(fd);
|
|
ESP_LOGE(TAG, "File sending failed!");
|
|
/* Abort sending file */
|
|
httpd_resp_sendstr_chunk(req, NULL);
|
|
/* Respond with 500 Internal Server Error */
|
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Failed to send file");
|
|
return ESP_FAIL;
|
|
}
|
|
|
|
/* Keep looping till the whole file is sent */
|
|
} while (chunksize != 0);
|
|
|
|
/* Close file after sending complete */
|
|
fclose(fd);
|
|
ESP_LOGI(TAG, "File sending complete");
|
|
|
|
/* Respond with an empty chunk to signal HTTP response completion */
|
|
httpd_resp_send_chunk(req, NULL, 0);
|
|
return ESP_OK;
|
|
}
|
|
|
|
/* Handler to upload a file onto the server */
|
|
static esp_err_t upload_post_handler(httpd_req_t *req)
|
|
{
|
|
LogFile.WriteToFile("upload_post_handler");
|
|
char filepath[FILE_PATH_MAX];
|
|
FILE *fd = NULL;
|
|
struct stat file_stat;
|
|
|
|
/* Skip leading "/upload" 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("/upload") - 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] == '/') {
|
|
ESP_LOGE(TAG, "Invalid filename : %s", filename);
|
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Invalid filename");
|
|
return ESP_FAIL;
|
|
}
|
|
|
|
if (stat(filepath, &file_stat) == 0) {
|
|
ESP_LOGE(TAG, "File already exists : %s", filepath);
|
|
/* Respond with 400 Bad Request */
|
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST, "File already exists");
|
|
return ESP_FAIL;
|
|
}
|
|
|
|
/* File cannot be larger than a limit */
|
|
if (req->content_len > MAX_FILE_SIZE) {
|
|
ESP_LOGE(TAG, "File too large : %d bytes", req->content_len);
|
|
/* Respond with 400 Bad Request */
|
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST,
|
|
"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) {
|
|
ESP_LOGE(TAG, "Failed to create file : %s", filepath);
|
|
/* Respond with 500 Internal Server Error */
|
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Failed to create file");
|
|
return ESP_FAIL;
|
|
}
|
|
|
|
ESP_LOGI(TAG, "Receiving file : %s...", filename);
|
|
|
|
/* Retrieve the pointer to scratch buffer for temporary storage */
|
|
char *buf = ((struct file_server_data *)req->user_ctx)->scratch;
|
|
int received;
|
|
|
|
/* Content length of the request gives
|
|
* the size of the file being uploaded */
|
|
int remaining = req->content_len;
|
|
|
|
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, SCRATCH_BUFSIZE))) <= 0) {
|
|
if (received == HTTPD_SOCK_ERR_TIMEOUT) {
|
|
/* Retry if timeout occurred */
|
|
continue;
|
|
}
|
|
|
|
/* In case of unrecoverable error,
|
|
* close and delete the unfinished file*/
|
|
fclose(fd);
|
|
unlink(filepath);
|
|
|
|
ESP_LOGE(TAG, "File reception failed!");
|
|
/* Respond with 500 Internal Server Error */
|
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Failed to receive file");
|
|
return ESP_FAIL;
|
|
}
|
|
|
|
/* Write buffer content to file on storage */
|
|
if (received && (received != fwrite(buf, 1, received, fd))) {
|
|
/* Couldn't write everything to file!
|
|
* Storage may be full? */
|
|
fclose(fd);
|
|
unlink(filepath);
|
|
|
|
ESP_LOGE(TAG, "File write failed!");
|
|
/* Respond with 500 Internal Server Error */
|
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Failed to write file to storage");
|
|
return ESP_FAIL;
|
|
}
|
|
|
|
/* Keep track of remaining size of
|
|
* the file left to be uploaded */
|
|
remaining -= received;
|
|
}
|
|
|
|
/* Close file upon upload completion */
|
|
fclose(fd);
|
|
ESP_LOGI(TAG, "File reception complete");
|
|
|
|
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);
|
|
if (zw != std::string::npos)
|
|
found = zw;
|
|
}
|
|
|
|
int start_fn = strlen(((struct file_server_data *)req->user_ctx)->base_path);
|
|
printf("Directory: %s, start_fn: %d, found: %d\n", directory.c_str(), start_fn, found);
|
|
directory = directory.substr(start_fn, found - start_fn + 1);
|
|
printf("Directory danach: %s\n", directory.c_str());
|
|
|
|
directory = "/fileserver" + directory;
|
|
printf("Directory danach: %s\n", 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());
|
|
|
|
/* 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 uploaded successfully");
|
|
return ESP_OK;
|
|
}
|
|
|
|
/* Handler to delete a file from the server */
|
|
static esp_err_t delete_post_handler(httpd_req_t *req)
|
|
{
|
|
LogFile.WriteToFile("delete_post_handler");
|
|
char filepath[FILE_PATH_MAX];
|
|
struct stat file_stat;
|
|
|
|
|
|
/* 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) {
|
|
/* 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] == '/') {
|
|
ESP_LOGE(TAG, "Invalid filename : %s", filename);
|
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Invalid filename");
|
|
return ESP_FAIL;
|
|
}
|
|
|
|
if (stat(filepath, &file_stat) == -1) {
|
|
ESP_LOGE(TAG, "File does not exist : %s", filename);
|
|
/* Respond with 400 Bad Request */
|
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST, "File does not exist");
|
|
return ESP_FAIL;
|
|
}
|
|
|
|
ESP_LOGI(TAG, "Deleting file : %s", filename);
|
|
/* Delete file */
|
|
unlink(filepath);
|
|
|
|
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);
|
|
if (zw != std::string::npos)
|
|
found = zw;
|
|
}
|
|
|
|
int start_fn = strlen(((struct file_server_data *)req->user_ctx)->base_path);
|
|
printf("Directory: %s, start_fn: %d, found: %d\n", directory.c_str(), start_fn, found);
|
|
directory = directory.substr(start_fn, found - start_fn + 1);
|
|
printf("Directory danach: %s\n", directory.c_str());
|
|
|
|
directory = "/fileserver" + directory;
|
|
printf("Directory danach: %s\n", 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;
|
|
}
|
|
|
|
|
|
void delete_all_in_directory(std::string _directory)
|
|
{
|
|
struct dirent *entry;
|
|
DIR *dir = opendir(_directory.c_str());
|
|
std::string filename;
|
|
|
|
if (!dir) {
|
|
ESP_LOGE(TAG, "Failed to stat dir : %s", _directory.c_str());
|
|
return;
|
|
}
|
|
|
|
/* Iterate over all files / folders and fetch their names and sizes */
|
|
while ((entry = readdir(dir)) != NULL) {
|
|
if (!(entry->d_type == DT_DIR)){
|
|
filename = _directory + std::string(entry->d_name);
|
|
ESP_LOGI(TAG, "Deleting file : %s", filename.c_str());
|
|
/* Delete file */
|
|
unlink(filename.c_str());
|
|
};
|
|
}
|
|
closedir(dir);
|
|
}
|
|
|
|
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;
|
|
const int N = 50;
|
|
char data[2048];
|
|
char archive_filename[64];
|
|
std::string zw;
|
|
// static const char* s_Test_archive_filename = "testhtml.zip";
|
|
|
|
printf("miniz.c version: %s\n", MZ_VERSION);
|
|
|
|
// 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)
|
|
{
|
|
printf("mz_zip_reader_init_file() failed!\n");
|
|
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)
|
|
{
|
|
printf("mz_zip_reader_init_file() failed!\n");
|
|
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)
|
|
{
|
|
printf("mz_zip_reader_extract_file_to_heap() failed!\n");
|
|
mz_zip_reader_end(&zip_archive);
|
|
return;
|
|
}
|
|
|
|
// Save to File.
|
|
zw = std::string(archive_filename);
|
|
zw = _target_directory + zw;
|
|
printf("Filename to extract: %s", zw.c_str());
|
|
FILE* fpTargetFile = fopen(zw.c_str(), "wb");
|
|
fwrite(p, 1, (uint)uncomp_size, fpTargetFile);
|
|
fclose(fpTargetFile);
|
|
|
|
printf("Successfully extracted file \"%s\", size %u\n", archive_filename, (uint)uncomp_size);
|
|
// printf("File data: \"%s\"\n", (const char*)p);
|
|
|
|
// We're done.
|
|
mz_free(p);
|
|
}
|
|
|
|
// Close the archive, freeing any resources it was using
|
|
mz_zip_reader_end(&zip_archive);
|
|
}
|
|
|
|
printf("Success.\n");
|
|
}
|
|
|
|
|
|
|
|
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) {
|
|
ESP_LOGE(TAG, "File server base_path not set");
|
|
// return ESP_ERR_INVALID_ARG;
|
|
}
|
|
|
|
if (server_data) {
|
|
ESP_LOGE(TAG, "File server already started");
|
|
// 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) {
|
|
ESP_LOGE(TAG, "Failed to allocate memory for server data");
|
|
// 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';
|
|
// printf("zw: %s\n", zw);
|
|
httpd_uri_t file_download = {
|
|
.uri = "/fileserver*", // Match all URIs of type /path/to/file
|
|
.method = HTTP_GET,
|
|
.handler = download_get_handler,
|
|
.user_ctx = server_data // Pass server data as context
|
|
};
|
|
httpd_register_uri_handler(server, &file_download);
|
|
|
|
/* 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,
|
|
.handler = upload_post_handler,
|
|
.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,
|
|
.handler = delete_post_handler,
|
|
.user_ctx = server_data // Pass server data as context
|
|
};
|
|
httpd_register_uri_handler(server, &file_delete);
|
|
|
|
}
|