5#include <esp_http_server.h>
19class ListEntitiesIterator;
22namespace web_server_idf {
24#define F(string_literal) (string_literal)
25#define PGM_P const char *
26#define strncpy_P strncpy
47 void addHeader(
const char *name,
const char *value);
85 void print(
float value);
97 const char *
get_content_data()
const override {
return reinterpret_cast<const char *
>(this->data_); };
111 http_method
method()
const {
return static_cast<http_method
>(this->req_->method); }
112 std::string url()
const;
113 std::string host()
const;
117 bool authenticate(
const char *username,
const char *password)
const;
119 void requestAuthentication(
const char *realm =
nullptr)
const;
121 void redirect(
const std::string &url);
124 void send(
int code,
const char *content_type =
nullptr,
const char *content =
nullptr);
128 this->init_response_(res, code, content_type);
134 this->init_response_(res, code, content_type);
139 const size_t data_size) {
141 this->init_response_(res, code, content_type);
147 this->init_response_(res, 200, content_type);
152 bool hasParam(
const std::string &name) {
return this->getParam(name) !=
nullptr; }
157 bool hasArg(
const char *name) {
return this->hasParam(name); }
158 std::string
arg(
const std::string &name) {
159 auto *param = this->getParam(name);
161 return param->value();
166 operator httpd_req_t *()
const {
return this->req_; }
169 bool hasHeader(
const char *name)
const;
174 std::map<std::string, AsyncWebParameter *>
params_;
196 this->handlers_.push_back(handler);
202 httpd_handle_t server_{};
203 static esp_err_t request_handler(httpd_req_t *r);
204 static esp_err_t request_post_handler(httpd_req_t *r);
219 size_t len,
bool final) {}
259 bool try_send_nodefer(
const char *message,
const char *event =
nullptr, uint32_t
id = 0, uint32_t reconnect = 0);
260 void deferrable_send_state(
void *source,
const char *event_type,
message_generator_t *message_generator);
268 void process_deferred_queue_();
269 void process_buffer_();
271 static void destroy(
void *p);
273 httpd_handle_t hd_{};
278 std::string event_buffer_{
""};
294 return request->
method() == HTTP_GET && request->
url() == this->url_;
299 void onConnect(connect_handler_t cb) { this->on_connect_ = std::move(cb); }
301 void try_send_nodefer(
const char *message,
const char *event =
nullptr, uint32_t
id = 0, uint32_t reconnect = 0);
302 void deferrable_send_state(
void *source,
const char *event_type,
message_generator_t *message_generator);
304 bool empty() {
return this->count() == 0; }
306 size_t count()
const {
return this->sessions_.size(); }
311 connect_handler_t on_connect_{};
324 void addHeader(
const char *name,
const char *value) { this->headers_.emplace_back(name, value); }
333 std::vector<std::pair<std::string, std::string>>
headers_;
This class allows users to create a web server with their ESP nodes.
AsyncEventSource(std::string url, esphome::web_server::WebServer *ws)
bool canHandle(AsyncWebServerRequest *request) override
void onConnect(connect_handler_t cb)
std::set< AsyncEventSourceResponse * > sessions_
esphome::web_server::WebServer * web_server_
std::vector< DeferredEvent > deferred_queue_
esphome::web_server::WebServer * web_server_
AsyncEventSource * server_
std::unique_ptr< esphome::web_server::ListEntitiesIterator > entities_iterator_
void print(const char *str)
AsyncResponseStream(const AsyncWebServerRequest *req)
void print(const std::string &str)
void printf(const char *fmt,...) __attribute__((format(printf
size_t get_content_size() const override
const char * get_content_data() const override
virtual bool canHandle(AsyncWebServerRequest *request)
virtual void handleRequest(AsyncWebServerRequest *request)
virtual ~AsyncWebHandler()
virtual void handleUpload(AsyncWebServerRequest *request, const std::string &filename, size_t index, uint8_t *data, size_t len, bool final)
virtual void handleBody(AsyncWebServerRequest *request, uint8_t *data, size_t len, size_t index, size_t total)
virtual bool isRequestHandlerTrivial()
AsyncWebParameter(std::string value)
const std::string & value() const
AsyncWebServer(uint16_t port)
std::vector< AsyncWebHandler * > handlers_
AsyncWebHandler & addHandler(AsyncWebHandler *handler)
void onNotFound(std::function< void(AsyncWebServerRequest *request)> fn)
bool hasArg(const char *name)
std::map< std::string, AsyncWebParameter * > params_
size_t contentLength() const
AsyncWebServerResponse * beginResponse(int code, const char *content_type, const std::string &content)
std::string arg(const std::string &name)
AsyncWebServerResponse * beginResponse(int code, const char *content_type)
bool hasParam(const std::string &name)
http_method method() const
AsyncWebServerRequest(httpd_req_t *req)
AsyncResponseStream * beginResponseStream(const char *content_type)
AsyncWebServerResponse * beginResponse_P(int code, const char *content_type, const uint8_t *data, const size_t data_size)
AsyncWebServerRequest(httpd_req_t *req, std::string post_query)
const char * get_content_data() const override
size_t get_content_size() const override
AsyncWebServerResponseContent(const AsyncWebServerRequest *req, std::string content)
const char * get_content_data() const override
AsyncWebServerResponseEmpty(const AsyncWebServerRequest *req)
size_t get_content_size() const override
virtual ~AsyncWebServerResponse()
const AsyncWebServerRequest * req_
virtual const char * get_content_data() const =0
AsyncWebServerResponse(const AsyncWebServerRequest *req)
virtual size_t get_content_size() const =0
void addHeader(const char *name, const char *value)
AsyncWebServerResponseProgmem(const AsyncWebServerRequest *req, const uint8_t *data, const size_t size)
size_t get_content_size() const override
const char * get_content_data() const override
std::string(esphome::web_server::WebServer *, void *) message_generator_t
class esphome::web_server_idf::AsyncEventSourceResponse __attribute__
Providing packet encoding functions for exchanging data with a remote host.
message_generator_t * message_generator_
bool operator==(const DeferredEvent &test) const
DeferredEvent(void *source, message_generator_t *message_generator)
message_generator_t * message_generator_
friend class AsyncEventSourceResponse