forked from xiaozhi/xiaozhi-esp32
b7db68457c
* Upgrade component version * update fonts component version * Handle OTA error code * Update project version to 2.1.0 and add device state machine implementation - Upgrade esp-wifi-connect to 3.0.0, allowing reconfiguring wifi without rebooting - Introduce device state machine with state change notification in new files - Remove obsolete device state event files - Update application logic to utilize new state machine - Minor adjustments in various board implementations for state handling * fix compile errors * Refactor power saving mode implementation to use PowerSaveLevel enumeration - Updated Application class to replace SetPowerSaveMode with SetPowerSaveLevel, allowing for LOW_POWER and PERFORMANCE settings. - Modified various board implementations to align with the new power save level structure. - Ensured consistent handling of power save levels across different board files, enhancing code maintainability and clarity. * Refactor power save level checks across multiple board implementations - Updated the condition for power save level checks in various board files to ensure that the power save timer only wakes up when the level is not set to LOW_POWER. - Improved consistency in handling power save levels, enhancing code clarity and maintainability. * Refactor EnterWifiConfigMode calls in board implementations - Updated calls to EnterWifiConfigMode to use the appropriate instance reference (self or board) across multiple board files. - Improved code consistency and clarity in handling device state during WiFi configuration mode entry. * Add cellular modem event handling and improve network status updates - Introduced new network events for cellular modem operations, including detecting, registration errors, and timeouts. - Enhanced the Application class to handle different network states and update the display status accordingly. - Refactored Ml307Board to implement a callback mechanism for network events, improving modularity and responsiveness. - Updated dual_network_board and board headers to support new network event callbacks, ensuring consistent handling across board implementations. * update esp-wifi-connect version * Update WiFi configuration tool messages across multiple board implementations to clarify user actions
66 lines
1.6 KiB
C++
66 lines
1.6 KiB
C++
#ifndef MQTT_PROTOCOL_H
|
|
#define MQTT_PROTOCOL_H
|
|
|
|
|
|
#include "protocol.h"
|
|
#include <mqtt.h>
|
|
#include <udp.h>
|
|
#include <cJSON.h>
|
|
#include <mbedtls/aes.h>
|
|
#include <freertos/FreeRTOS.h>
|
|
#include <freertos/event_groups.h>
|
|
#include <esp_timer.h>
|
|
|
|
#include <functional>
|
|
#include <string>
|
|
#include <map>
|
|
#include <mutex>
|
|
#include <memory>
|
|
#include <atomic>
|
|
|
|
#define MQTT_PING_INTERVAL_SECONDS 90
|
|
#define MQTT_RECONNECT_INTERVAL_MS 60000
|
|
|
|
#define MQTT_PROTOCOL_SERVER_HELLO_EVENT (1 << 0)
|
|
|
|
class MqttProtocol : public Protocol {
|
|
public:
|
|
MqttProtocol();
|
|
~MqttProtocol();
|
|
|
|
bool Start() override;
|
|
bool SendAudio(std::unique_ptr<AudioStreamPacket> packet) override;
|
|
bool OpenAudioChannel() override;
|
|
void CloseAudioChannel() override;
|
|
bool IsAudioChannelOpened() const override;
|
|
|
|
private:
|
|
// Alive flag for safe scheduled callbacks - set to false in destructor
|
|
std::shared_ptr<std::atomic<bool>> alive_ = std::make_shared<std::atomic<bool>>(true);
|
|
|
|
EventGroupHandle_t event_group_handle_;
|
|
|
|
std::string publish_topic_;
|
|
|
|
std::mutex channel_mutex_;
|
|
std::unique_ptr<Mqtt> mqtt_;
|
|
std::unique_ptr<Udp> udp_;
|
|
mbedtls_aes_context aes_ctx_;
|
|
std::string aes_nonce_;
|
|
std::string udp_server_;
|
|
int udp_port_;
|
|
uint32_t local_sequence_;
|
|
uint32_t remote_sequence_;
|
|
esp_timer_handle_t reconnect_timer_;
|
|
|
|
bool StartMqttClient(bool report_error=false);
|
|
void ParseServerHello(const cJSON* root);
|
|
std::string DecodeHexString(const std::string& hex_string);
|
|
|
|
bool SendText(const std::string& text) override;
|
|
std::string GetHelloMessage();
|
|
};
|
|
|
|
|
|
#endif // MQTT_PROTOCOL_H
|