GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-22 17:50:36 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix mqtt api read function

Browse Source 
Fix mqtt plugin to check error code when handling NEU_MQTT_OP_READ,
  so that the plugin could send back an error message.
This commit is contained in:
eeff
2021-12-22 17:20:05 +08:00
committed by Parker Liu
parent f41559bd73
commit daee5c2592
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/mqtt/command/read_write.c
+12 -4
View File
@@ -206,11 +206,20 @@ char *command_read_once_response(neu_plugin_t * plugin,
neu_int_val_t * int_val;
neu_data_val_t *val_err;
int32_t error;
int32_t errcode = 0;
char * json_str = NULL;
int_val = neu_fixed_array_get(array, 0);
val_err = int_val->val;
neu_dvalue_get_errorcode(val_err, &error);
neu_dvalue_get_errorcode(val_err, &errcode);
if (0 != errcode) {
neu_json_error_resp_t error = { errcode };
neu_json_encode_with_mqtt(&error, neu_json_encode_error_resp,
parse_header, neu_json_encode_mqtt_resp,
&json_str);
return json_str;
}
neu_json_read_resp_t json;
memset(&json, 0, sizeof(neu_json_read_resp_t));
@@ -219,8 +228,7 @@ char *command_read_once_response(neu_plugin_t * plugin,
return NULL;
}
char *json_str = NULL;
rc = neu_json_encode_with_mqtt(&json, neu_json_encode_read_resp,
rc = neu_json_encode_with_mqtt(&json, neu_json_encode_read_resp,
parse_header, neu_json_encode_mqtt_resp,
&json_str);
clean_read_response_json_object(&json);