0d39c5ca00
* Rename "serialize" and "deserialize" functions to "read" and "update" to reflect API in StatefulService * Move new definitions to StatefulService.h so it is obvious it is not general purpose * Update README
166 lines
6.2 KiB
C++
166 lines
6.2 KiB
C++
#ifndef HttpEndpoint_h
|
|
#define HttpEndpoint_h
|
|
|
|
#include <functional>
|
|
|
|
#include <AsyncJson.h>
|
|
#include <ESPAsyncWebServer.h>
|
|
|
|
#include <SecurityManager.h>
|
|
#include <StatefulService.h>
|
|
|
|
#define HTTP_ENDPOINT_ORIGIN_ID "http"
|
|
|
|
template <class T>
|
|
class HttpGetEndpoint {
|
|
public:
|
|
HttpGetEndpoint(JsonStateReader<T> stateReader,
|
|
StatefulService<T>* statefulService,
|
|
AsyncWebServer* server,
|
|
const String& servicePath,
|
|
SecurityManager* securityManager,
|
|
AuthenticationPredicate authenticationPredicate = AuthenticationPredicates::IS_ADMIN,
|
|
size_t bufferSize = DEFAULT_BUFFER_SIZE) :
|
|
_stateReader(stateReader), _statefulService(statefulService), _bufferSize(bufferSize) {
|
|
server->on(servicePath.c_str(),
|
|
HTTP_GET,
|
|
securityManager->wrapRequest(std::bind(&HttpGetEndpoint::fetchSettings, this, std::placeholders::_1),
|
|
authenticationPredicate));
|
|
}
|
|
|
|
HttpGetEndpoint(JsonStateReader<T> stateReader,
|
|
StatefulService<T>* statefulService,
|
|
AsyncWebServer* server,
|
|
const String& servicePath,
|
|
size_t bufferSize = DEFAULT_BUFFER_SIZE) :
|
|
_stateReader(stateReader), _statefulService(statefulService), _bufferSize(bufferSize) {
|
|
server->on(servicePath.c_str(), HTTP_GET, std::bind(&HttpGetEndpoint::fetchSettings, this, std::placeholders::_1));
|
|
}
|
|
|
|
protected:
|
|
JsonStateReader<T> _stateReader;
|
|
StatefulService<T>* _statefulService;
|
|
size_t _bufferSize;
|
|
|
|
void fetchSettings(AsyncWebServerRequest* request) {
|
|
AsyncJsonResponse* response = new AsyncJsonResponse(false, _bufferSize);
|
|
JsonObject jsonObject = response->getRoot().to<JsonObject>();
|
|
_statefulService->read(jsonObject, _stateReader);
|
|
|
|
response->setLength();
|
|
request->send(response);
|
|
}
|
|
};
|
|
|
|
template <class T>
|
|
class HttpPostEndpoint {
|
|
public:
|
|
HttpPostEndpoint(JsonStateReader<T> stateReader,
|
|
JsonStateUpdater<T> stateUpdater,
|
|
StatefulService<T>* statefulService,
|
|
AsyncWebServer* server,
|
|
const String& servicePath,
|
|
SecurityManager* securityManager,
|
|
AuthenticationPredicate authenticationPredicate = AuthenticationPredicates::IS_ADMIN,
|
|
size_t bufferSize = DEFAULT_BUFFER_SIZE) :
|
|
_stateReader(stateReader),
|
|
_stateUpdater(stateUpdater),
|
|
_statefulService(statefulService),
|
|
_updateHandler(
|
|
servicePath,
|
|
securityManager->wrapCallback(
|
|
std::bind(&HttpPostEndpoint::updateSettings, this, std::placeholders::_1, std::placeholders::_2),
|
|
authenticationPredicate),
|
|
bufferSize),
|
|
_bufferSize(bufferSize) {
|
|
_updateHandler.setMethod(HTTP_POST);
|
|
server->addHandler(&_updateHandler);
|
|
}
|
|
|
|
HttpPostEndpoint(JsonStateReader<T> stateReader,
|
|
JsonStateUpdater<T> stateUpdater,
|
|
StatefulService<T>* statefulService,
|
|
AsyncWebServer* server,
|
|
const String& servicePath,
|
|
size_t bufferSize = DEFAULT_BUFFER_SIZE) :
|
|
_stateReader(stateReader),
|
|
_stateUpdater(stateUpdater),
|
|
_statefulService(statefulService),
|
|
_updateHandler(servicePath,
|
|
std::bind(&HttpPostEndpoint::updateSettings, this, std::placeholders::_1, std::placeholders::_2),
|
|
bufferSize),
|
|
_bufferSize(bufferSize) {
|
|
_updateHandler.setMethod(HTTP_POST);
|
|
server->addHandler(&_updateHandler);
|
|
}
|
|
|
|
protected:
|
|
JsonStateReader<T> _stateReader;
|
|
JsonStateUpdater<T> _stateUpdater;
|
|
StatefulService<T>* _statefulService;
|
|
AsyncCallbackJsonWebHandler _updateHandler;
|
|
size_t _bufferSize;
|
|
|
|
void updateSettings(AsyncWebServerRequest* request, JsonVariant& json) {
|
|
if (!json.is<JsonObject>()) {
|
|
request->send(400);
|
|
return;
|
|
}
|
|
JsonObject jsonObject = json.as<JsonObject>();
|
|
StateUpdateResult outcome = _statefulService->updateWithoutPropagation(jsonObject, _stateUpdater);
|
|
if (outcome == StateUpdateResult::ERROR) {
|
|
request->send(400);
|
|
return;
|
|
}
|
|
if (outcome == StateUpdateResult::CHANGED) {
|
|
request->onDisconnect([this]() { _statefulService->callUpdateHandlers(HTTP_ENDPOINT_ORIGIN_ID); });
|
|
}
|
|
AsyncJsonResponse* response = new AsyncJsonResponse(false, _bufferSize);
|
|
jsonObject = response->getRoot().to<JsonObject>();
|
|
_statefulService->read(jsonObject, _stateReader);
|
|
response->setLength();
|
|
request->send(response);
|
|
}
|
|
};
|
|
|
|
template <class T>
|
|
class HttpEndpoint : public HttpGetEndpoint<T>, public HttpPostEndpoint<T> {
|
|
public:
|
|
HttpEndpoint(JsonStateReader<T> stateReader,
|
|
JsonStateUpdater<T> stateUpdater,
|
|
StatefulService<T>* statefulService,
|
|
AsyncWebServer* server,
|
|
const String& servicePath,
|
|
SecurityManager* securityManager,
|
|
AuthenticationPredicate authenticationPredicate = AuthenticationPredicates::IS_ADMIN,
|
|
size_t bufferSize = DEFAULT_BUFFER_SIZE) :
|
|
HttpGetEndpoint<T>(stateReader,
|
|
statefulService,
|
|
server,
|
|
servicePath,
|
|
securityManager,
|
|
authenticationPredicate,
|
|
bufferSize),
|
|
HttpPostEndpoint<T>(stateReader,
|
|
stateUpdater,
|
|
statefulService,
|
|
server,
|
|
servicePath,
|
|
securityManager,
|
|
authenticationPredicate,
|
|
bufferSize) {
|
|
}
|
|
|
|
HttpEndpoint(JsonStateReader<T> stateReader,
|
|
JsonStateUpdater<T> stateUpdater,
|
|
StatefulService<T>* statefulService,
|
|
AsyncWebServer* server,
|
|
const String& servicePath,
|
|
size_t bufferSize = DEFAULT_BUFFER_SIZE) :
|
|
HttpGetEndpoint<T>(stateReader, statefulService, server, servicePath, bufferSize),
|
|
HttpPostEndpoint<T>(stateReader, stateUpdater, statefulService, server, servicePath, bufferSize) {
|
|
}
|
|
};
|
|
|
|
#endif // end HttpEndpoint
|