return mqtt tx stack size;

added json template for SYSTEM service;
checked POST over MQTT functionality;
This commit is contained in:
Bogdan Pilyugin 2023-02-05 15:44:04 +02:00
parent 0d98979611
commit 8da969e5df
3 changed files with 16 additions and 3 deletions

View File

@ -51,7 +51,7 @@ HTTP_IO_RESULT HTTPPostApp(httpd_req_t *req, const char *filename, char *PostDat
const char *pt = filename + 1; const char *pt = filename + 1;
#if HTTP_SERVER_DEBUG_LEVEL > 0 #if HTTP_SERVER_DEBUG_LEVEL > 0
ESP_LOGI(TAG, "URI for POST processing:%s", req->uri); //ESP_LOGI(TAG, "URI for POST processing:%s", req->uri);
ESP_LOGI(TAG, "Filename:%s", pt); ESP_LOGI(TAG, "Filename:%s", pt);
ESP_LOGI(TAG, "DATA for POST processing:%s", PostData); ESP_LOGI(TAG, "DATA for POST processing:%s", PostData);
#endif #endif

View File

@ -273,7 +273,7 @@ static void start_mqtt()
esp_mqtt_client_register_event(mqtt[i].mqtt, ESP_EVENT_ANY_ID, mqtt[i].system_event_handler, &mqtt[i].mqtt); esp_mqtt_client_register_event(mqtt[i].mqtt, ESP_EVENT_ANY_ID, mqtt[i].system_event_handler, &mqtt[i].mqtt);
esp_mqtt_client_register_event(mqtt[i].mqtt, ESP_EVENT_ANY_ID, mqtt[i].user_event_handler, &mqtt[i].mqtt); esp_mqtt_client_register_event(mqtt[i].mqtt, ESP_EVENT_ANY_ID, mqtt[i].user_event_handler, &mqtt[i].mqtt);
esp_mqtt_client_start(mqtt[i].mqtt); esp_mqtt_client_start(mqtt[i].mqtt);
xTaskCreate(MQTTTaskTransmit, "MQTTTaskTransmit", 1024 * 1, (void*) &mqtt[i].mqtt_index, 3, NULL); xTaskCreate(MQTTTaskTransmit, "MQTTTaskTransmit", 1024 * 2, (void*) &mqtt[i].mqtt_index, 3, NULL);
} }
} }
} }

View File

@ -33,6 +33,17 @@
* } * }
*/ */
/*
{
"messid":12345,
"api":"2.0",
"request":"GET",
"url":"api/status.json",
"postdata":"param1=value&param2=value",
"reload":"true"
}
*/
#include "MQTT.h" #include "MQTT.h"
#include "jWrite.h" #include "jWrite.h"
#include "jRead.h" #include "jRead.h"
@ -45,7 +56,7 @@
#define MAX_JSON_MESSAGE 256 //max size of mqtt message to publish #define MAX_JSON_MESSAGE 256 //max size of mqtt message to publish
#define MAX_FILE_PUBLISH 4096 //bufer for mqtt data publish #define MAX_FILE_PUBLISH 4096 //bufer for mqtt data publish
#define MAX_DYNVAR_LENTH 64 #define MAX_DYNVAR_LENTH 64
#define MAX_FILENAME_LENTH 15 #define MAX_FILENAME_LENTH 32
#define MAX_ERROR_MESSAGE 32 #define MAX_ERROR_MESSAGE 32
#define MAX_ERROR_JSON 256 #define MAX_ERROR_JSON 256
#define MAX_MESSAGE_ID 15 #define MAX_MESSAGE_ID 15
@ -345,8 +356,10 @@ void SystemDataHandler(char *data, uint32_t len, int idx)
goto api_json_err; goto api_json_err;
} }
ESP_LOGW(TAG, "URL=%s, DATA=%s", URL, POST_DATA);
HTTPPostApp(NULL, URL, POST_DATA); HTTPPostApp(NULL, URL, POST_DATA);
jRead(data, "{'reload'", &result); jRead(data, "{'reload'", &result);
if (result.elements == 1 && !memcmp("true", result.pValue, result.bytelen)) if (result.elements == 1 && !memcmp("true", result.pValue, result.bytelen))
{ {