Skip to content

Commit cf39b66

Browse files
committed
Update example curl plugin with latest interface
1 parent 7848dd1 commit cf39b66

File tree

4 files changed

+398
-337
lines changed

4 files changed

+398
-337
lines changed

examples/plugin_libcurl/CMakeLists.txt

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ add_compile_options(-Wall)
99

1010
add_library(plugin_libcurl SHARED
1111
vendor/flashmq_plugin.h
12+
vendor/flashmq_public.h
1213

1314
src/pluginstate.h
1415
src/curl_functions.h

examples/plugin_libcurl/src/plugin_libcurl.cpp

Lines changed: 13 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -128,8 +128,9 @@ void flashmq_plugin_poll_event_received(void *thread_data, int fd, uint32_t even
128128
}
129129

130130

131-
AuthResult flashmq_plugin_login_check(void *thread_data, const std::string &clientid, const std::string &username, const std::string &password,
132-
const std::vector<std::pair<std::string, std::string>> *userProperties, const std::weak_ptr<Client> &client)
131+
AuthResult flashmq_plugin_login_check(
132+
void *thread_data, const std::string &clientid, const std::string &username, const std::string &password,
133+
const std::vector<std::pair<std::string, std::string>> *userProperties, const std::weak_ptr<Client> &client)
133134
{
134135
(void)clientid;
135136
(void)userProperties;
@@ -173,14 +174,18 @@ AuthResult flashmq_plugin_login_check(void *thread_data, const std::string &clie
173174
}
174175

175176
AuthResult flashmq_plugin_acl_check(
176-
void *thread_data, const AclAccess access, const std::string &clientid, const std::string &username,
177-
const std::string &topic, const std::vector<std::string> &subtopics, const std::string &shareName,
178-
std::string_view payload, const uint8_t qos, const bool retain,
179-
const std::optional<std::string> &correlationData, const std::optional<std::string> &responseTopic,
180-
const std::vector<std::pair<std::string, std::string>> *userProperties)
177+
void *thread_data, const AclAccess access, const std::string &clientid, const std::string &username,
178+
const std::string &topic, const std::vector<std::string> &subtopics, const std::string &shareName,
179+
std::string_view payload, const uint8_t qos, const bool retain,
180+
const std::optional<std::string> &correlationData, const std::optional<std::string> &responseTopic,
181+
const std::optional<std::string> &contentType,
182+
const std::optional<std::chrono::time_point<std::chrono::steady_clock>> expiresAt,
183+
const std::vector<std::pair<std::string, std::string>> *userProperties)
181184
{
182185
(void)thread_data; (void)access; (void)clientid; (void)username; (void)topic; (void)subtopics; (void)shareName;
183-
(void)payload; (void)qos; (void)retain; (void)correlationData; (void)responseTopic; (void)userProperties;
186+
(void)payload; (void)qos; (void)retain; (void)correlationData; (void)responseTopic;
187+
(void)contentType; (void) expiresAt; (void)userProperties;
188+
184189

185190
return AuthResult::success;
186191
}

0 commit comments

Comments
 (0)