@@ -156,8 +156,9 @@ void flashmq_plugin_periodic_event(void *thread_data);
156156 *
157157 * [Can optionally be implemented by plugin]
158158 */
159- bool flashmq_plugin_alter_subscription (void *thread_data, const std::string &clientid, std::string &topic, const std::vector<std::string> &subtopics,
160- uint8_t &qos, const std::vector<std::pair<std::string, std::string>> *userProperties);
159+ bool flashmq_plugin_alter_subscription (
160+ void *thread_data, const std::string &clientid, std::string &topic, const std::vector<std::string> &subtopics,
161+ uint8_t &qos, const std::vector<std::pair<std::string, std::string>> *userProperties);
161162
162163/* *
163164 * @brief flashmq_plugin_alter_publish allows changing of the non-const arguments.
@@ -170,9 +171,10 @@ bool flashmq_plugin_alter_subscription(void *thread_data, const std::string &cli
170171 *
171172 * [Can optionally be implemented by plugin]
172173 */
173- bool flashmq_plugin_alter_publish (void *thread_data, const std::string &clientid, std::string &topic, const std::vector<std::string> &subtopics,
174- std::string_view payload, uint8_t &qos, bool &retain, const std::optional<std::string> &correlationData,
175- const std::optional<std::string> &responseTopic, std::vector<std::pair<std::string, std::string>> *userProperties);
174+ bool flashmq_plugin_alter_publish (
175+ void *thread_data, const std::string &clientid, std::string &topic, const std::vector<std::string> &subtopics,
176+ std::string_view payload, uint8_t &qos, bool &retain, const std::optional<std::string> &correlationData,
177+ const std::optional<std::string> &responseTopic, std::vector<std::pair<std::string, std::string>> *userProperties);
176178
177179/* *
178180 * @brief flashmq_plugin_login_check is called on login of a client.
@@ -194,8 +196,9 @@ bool flashmq_plugin_alter_publish(void *thread_data, const std::string &clientid
194196 *
195197 * [Must be implemented by plugin]
196198 */
197- AuthResult flashmq_plugin_login_check (void *thread_data, const std::string &clientid, const std::string &username, const std::string &password,
198- const std::vector<std::pair<std::string, std::string>> *userProperties, const std::weak_ptr<Client> &client);
199+ AuthResult flashmq_plugin_login_check (
200+ void *thread_data, const std::string &clientid, const std::string &username, const std::string &password,
201+ const std::vector<std::pair<std::string, std::string>> *userProperties, const std::weak_ptr<Client> &client);
199202
200203/* *
201204 * @brief flashmq_plugin_client_disconnected Called when clients disconnect or their keep-alive expire.
@@ -215,9 +218,10 @@ void flashmq_plugin_client_disconnected(void *thread_data, const std::string &cl
215218 *
216219 * [Can optionally be implemented by plugin]
217220 */
218- void flashmq_plugin_on_unsubscribe (void *thread_data, const std::weak_ptr<Session> &session, const std::string &clientid,
219- const std::string &username, const std::string &topic, const std::vector<std::string> &subtopics,
220- const std::string &shareName, const std::vector<std::pair<std::string, std::string>> *userProperties);
221+ void flashmq_plugin_on_unsubscribe (
222+ void *thread_data, const std::weak_ptr<Session> &session, const std::string &clientid,
223+ const std::string &username, const std::string &topic, const std::vector<std::string> &subtopics,
224+ const std::string &shareName, const std::vector<std::pair<std::string, std::string>> *userProperties);
221225
222226/* *
223227 * @brief flashmq_plugin_acl_check is called on publish, deliver and subscribe.
@@ -244,11 +248,12 @@ void flashmq_plugin_on_unsubscribe(void *thread_data, const std::weak_ptr<Sessio
244248 *
245249 * [Must be implemented by plugin]
246250 */
247- AuthResult flashmq_plugin_acl_check (void *thread_data, const AclAccess access, const std::string &clientid, const std::string &username,
248- const std::string &topic, const std::vector<std::string> &subtopics, const std::string &shareName,
249- std::string_view payload, const uint8_t qos, const bool retain,
250- const std::optional<std::string> &correlationData, const std::optional<std::string> &responseTopic,
251- const std::vector<std::pair<std::string, std::string>> *userProperties);
251+ AuthResult flashmq_plugin_acl_check (
252+ void *thread_data, const AclAccess access, const std::string &clientid, const std::string &username,
253+ const std::string &topic, const std::vector<std::string> &subtopics, const std::string &shareName,
254+ std::string_view payload, const uint8_t qos, const bool retain,
255+ const std::optional<std::string> &correlationData, const std::optional<std::string> &responseTopic,
256+ const std::vector<std::pair<std::string, std::string>> *userProperties);
252257
253258/* *
254259 * @brief flashmq_plugin_extended_auth can be used to implement MQTT 5 extended auth. This is optional.
@@ -265,9 +270,10 @@ AuthResult flashmq_plugin_acl_check(void *thread_data, const AclAccess access, c
265270 *
266271 * [Can optionally be implemented by plugin]
267272 */
268- AuthResult flashmq_plugin_extended_auth (void *thread_data, const std::string &clientid, ExtendedAuthStage stage, const std::string &authMethod,
269- const std::string &authData, const std::vector<std::pair<std::string, std::string>> *userProperties, std::string &returnData,
270- std::string &username, const std::weak_ptr<Client> &client);
273+ AuthResult flashmq_plugin_extended_auth (
274+ void *thread_data, const std::string &clientid, ExtendedAuthStage stage, const std::string &authMethod,
275+ const std::string &authData, const std::vector<std::pair<std::string, std::string>> *userProperties, std::string &returnData,
276+ std::string &username, const std::weak_ptr<Client> &client);
271277
272278/* *
273279 * @brief Is called when the socket watched by 'flashmq_poll_add_fd()' has an event.
0 commit comments