a1f4e57a21
* Update back end to add MQTT and WebSocket support * Update demo project to demonstrate MQTT and WebSockets * Update documentation to describe newly added and modified functionallity * Introduce separate MQTT pub/sub, HTTP get/post and WebSocket rx/tx classes * Significant reanaming - more accurate class names * Use PROGMEM_WWW as default * Update README documenting PROGMEM_WWW as default * Update README with API changes
25 lines
1004 B
C++
25 lines
1004 B
C++
#include <MqttStatus.h>
|
|
|
|
MqttStatus::MqttStatus(AsyncWebServer* server,
|
|
MqttSettingsService* mqttSettingsService,
|
|
SecurityManager* securityManager) :
|
|
_mqttSettingsService(mqttSettingsService) {
|
|
server->on(MQTT_STATUS_SERVICE_PATH,
|
|
HTTP_GET,
|
|
securityManager->wrapRequest(std::bind(&MqttStatus::mqttStatus, this, std::placeholders::_1),
|
|
AuthenticationPredicates::IS_AUTHENTICATED));
|
|
}
|
|
|
|
void MqttStatus::mqttStatus(AsyncWebServerRequest* request) {
|
|
AsyncJsonResponse* response = new AsyncJsonResponse(false, MAX_MQTT_STATUS_SIZE);
|
|
JsonObject root = response->getRoot();
|
|
|
|
root["enabled"] = _mqttSettingsService->isEnabled();
|
|
root["connected"] = _mqttSettingsService->isConnected();
|
|
root["client_id"] = _mqttSettingsService->getClientId();
|
|
root["disconnect_reason"] = (uint8_t)_mqttSettingsService->getDisconnectReason();
|
|
|
|
response->setLength();
|
|
request->send(response);
|
|
}
|