5dd4d5b452
This allows individual callback functions for each subscribed topic. Allows easier implementation of further mqtt functions
31 lines
901 B
C++
31 lines
901 B
C++
// SPDX-License-Identifier: GPL-2.0-or-later
|
|
#pragma once
|
|
|
|
#include <cstdint>
|
|
#include <espMqttClient.h>
|
|
#include <string>
|
|
#include <vector>
|
|
|
|
struct cb_filter_t {
|
|
std::string topic;
|
|
uint8_t qos;
|
|
espMqttClientTypes::OnMessageCallback cb;
|
|
};
|
|
|
|
class MqttSubscribeParser {
|
|
public:
|
|
void register_callback(const std::string& topic, uint8_t qos, const espMqttClientTypes::OnMessageCallback& cb);
|
|
void unregister_callback(const std::string& topic);
|
|
void handle_message(const espMqttClientTypes::MessageProperties& properties, const char* topic, const uint8_t* payload, size_t len, size_t index, size_t total);
|
|
std::vector<cb_filter_t> get_callbacks();
|
|
|
|
private:
|
|
int mosquitto_topic_matches_sub(const char* sub, const char* topic, bool* result);
|
|
|
|
std::vector<cb_filter_t> _callbacks;
|
|
|
|
enum mosq_err_t {
|
|
MOSQ_ERR_SUCCESS = 0,
|
|
MOSQ_ERR_INVAL = 3,
|
|
};
|
|
}; |