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.
94 lines
2.3 KiB
94 lines
2.3 KiB
/*
|
|
|
|
WEBSERVER MODULE
|
|
|
|
Copyright (C) 2016-2019 by Xose Pérez <xose dot perez at gmail dot com>
|
|
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include "espurna.h"
|
|
|
|
#if WEB_SUPPORT
|
|
|
|
#include <functional>
|
|
#include <list>
|
|
#include <vector>
|
|
|
|
#include <ESPAsyncWebServer.h>
|
|
|
|
struct AsyncWebPrintConfig {
|
|
const char* const mimeType;
|
|
size_t backlogCountMax;
|
|
size_t backlogSizeMax;
|
|
decltype(millis()) backlogTimeout;
|
|
};
|
|
|
|
struct AsyncWebPrint : public Print {
|
|
|
|
enum class State {
|
|
None,
|
|
Sending,
|
|
Done,
|
|
Error
|
|
};
|
|
|
|
using BufferType = std::vector<uint8_t>;
|
|
|
|
// To be able to safely output data right from the request callback,
|
|
// we schedule a 'printer' task that will print into the request response buffer via AsyncChunkedResponse
|
|
// Note: implementation must be included in the header
|
|
template<typename CallbackType>
|
|
static void scheduleFromRequest(const AsyncWebPrintConfig& config, AsyncWebServerRequest*, CallbackType);
|
|
|
|
template<typename CallbackType>
|
|
static void scheduleFromRequest(AsyncWebServerRequest*, CallbackType);
|
|
|
|
State getState();
|
|
void setState(State);
|
|
|
|
// note: existing implementation only expects this to be available via AsyncWebPrint
|
|
#if defined(ARDUINO_ESP8266_RELEASE_2_3_0)
|
|
void flush();
|
|
#else
|
|
void flush() final override;
|
|
#endif
|
|
|
|
size_t write(uint8_t) final override;
|
|
size_t write(const uint8_t *buffer, size_t size) final override;
|
|
|
|
const char* const mimeType;
|
|
const size_t backlogCountMax;
|
|
const size_t backlogSizeMax;
|
|
const decltype(millis()) backlogTimeout;
|
|
|
|
protected:
|
|
|
|
std::list<BufferType> _buffers;
|
|
AsyncWebServerRequest* const _request;
|
|
State _state;
|
|
|
|
AsyncWebPrint(const AsyncWebPrintConfig&, AsyncWebServerRequest* req);
|
|
|
|
bool _addBuffer();
|
|
bool _exhaustBuffers();
|
|
void _prepareRequest();
|
|
|
|
};
|
|
|
|
using web_body_callback_f = std::function<bool(AsyncWebServerRequest*, uint8_t* data, size_t len, size_t index, size_t total)>;
|
|
using web_request_callback_f = std::function<bool(AsyncWebServerRequest*)>;
|
|
|
|
AsyncWebServer& webServer();
|
|
|
|
bool webAuthenticate(AsyncWebServerRequest *request);
|
|
void webLog(AsyncWebServerRequest *request);
|
|
|
|
void webBodyRegister(web_body_callback_f);
|
|
void webRequestRegister(web_request_callback_f);
|
|
|
|
uint16_t webPort();
|
|
void webSetup();
|
|
|
|
#endif // WEB_SUPPORT == 1
|