EmbAJAXOutputDriverESPAsync.h

 
#ifndef EMBAJAXOUTPUTDRIVERESPASYNC_H
#define EMBAJAXOUTPUTDRIVERESPASYNC_H
 
#if defined (EMBAJAX_OUTUPUTDRIVER_IMPLEMENTATION)
#error Duplicate definition of output driver. Fix your include-directives.
#endif
#define EMBAJAX_OUTUPUTDRIVER_IMPLEMENTATION
 
// For EmbAJAXPage. Important to include after defining EMBAJAX_OUTUPUTDRIVER_IMPLEMENTATION
#include "EmbAJAX.h"
 
#include <ESPAsyncWebServer.h>
 
#define EmbAJAXOutputDriverWebServerClass AsyncWebServer
 
class EmbAJAXOutputDriverESPAsync : public EmbAJAXOutputDriverBase {
public:
    EmbAJAXOutputDriverESPAsync(EmbAJAXOutputDriverWebServerClass *server) {
        EmbAJAXBase::setDriver(this);
        _server = server;
        _request = 0;
    }
    void printHeader(bool html) override {
        _response = _request->beginResponseStream(html ? "text/html" : "text/json");
    }
    void printContent(const char *content) override {
        _response->print(content);
    }
    const char* getArg(const char* name, char* buf, int buflen) override {
        _request->arg(name).toCharArray (buf, buflen);
        return buf;
    }
    void installPage(EmbAJAXPageBase *page, const char *path, void (*change_callback)()=0) override {
        _server->on(path, [=](AsyncWebServerRequest* request) {
             _request = request;
             _response = 0;
             if (_request->method() == HTTP_POST) {  // AJAX request
                 page->handleRequest(change_callback);
             } else {  // Page load
                 page->printPage();
             }
             _request->send(_response);
             _request = 0;
        });
    }
    void loopHook() override {};
private:
    EmbAJAXOutputDriverWebServerClass *_server;
    AsyncWebServerRequest *_request;
    AsyncResponseStream *_response;
};
 
typedef EmbAJAXOutputDriverESPAsync EmbAJAXOutputDriver;
 
#endif