From 01713bbe20d2cf5aafbe5eb32721d3e4fc5823d8 Mon Sep 17 00:00:00 2001 From: Filip Wandzio Date: Fri, 5 Sep 2025 03:30:24 +0200 Subject: Standarize the project directory for monorepo-like developer experience Move the clang formatter to the root of the three so all nested projects could use it Provide README for all other projects Refactor the code in rtt agregator Signed-off-by: Filip Wandzio --- firmware/src/mqtt.c | 93 +++++++++++++++++++++++++++-------------------------- 1 file changed, 48 insertions(+), 45 deletions(-) (limited to 'firmware/src/mqtt.c') diff --git a/firmware/src/mqtt.c b/firmware/src/mqtt.c index 716feec..90451bc 100644 --- a/firmware/src/mqtt.c +++ b/firmware/src/mqtt.c @@ -27,59 +27,62 @@ static esp_mqtt_client_handle_t client; static void mqtt_event_handler(void *handler_args, esp_event_base_t base, - int32_t event_id, void *event_data) { - esp_mqtt_event_handle_t event = event_data; + int32_t event_id, void *event_data) +{ + esp_mqtt_event_handle_t event = event_data; - switch (event->event_id) { - case MQTT_EVENT_CONNECTED: - printf("MQTT connected!\n"); - esp_mqtt_client_subscribe(event->client, SUB_TOPIC, 1); - break; + switch (event->event_id) { + case MQTT_EVENT_CONNECTED: + printf("MQTT connected!\n"); + esp_mqtt_client_subscribe(event->client, SUB_TOPIC, 1); + break; - case MQTT_EVENT_DATA: { - char topic[event->topic_len + 1]; - char data[event->data_len + 1]; - memcpy(topic, event->topic, event->topic_len); - topic[event->topic_len] = '\0'; - memcpy(data, event->data, event->data_len); - data[event->data_len] = '\0'; + case MQTT_EVENT_DATA: { + char topic[event->topic_len + 1]; + char data[event->data_len + 1]; + memcpy(topic, event->topic, event->topic_len); + topic[event->topic_len] = '\0'; + memcpy(data, event->data, event->data_len); + data[event->data_len] = '\0'; - printf("MQTT Msg received\nTopic: %s\nData: %s\n", topic, data); + printf("MQTT Msg received\nTopic: %s\nData: %s\n", topic, data); - char *endptr; - long long sent = strtoll(data, &endptr, 10); - if (endptr != data) { - long long now = esp_timer_get_time() / 1000ULL; - long long rtt = now - sent; - printf("RTT: %lld ms\n", rtt); - } - break; - } + char *endptr; + long long sent = strtoll(data, &endptr, 10); + if (endptr != data) { + long long now = esp_timer_get_time() / 1000ULL; + long long rtt = now - sent; + printf("RTT: %lld ms\n", rtt); + } + break; + } - default: - break; - } + default: + break; + } } -static void publisher_task(void *pvParameters) { - while (1) { - char buf[BUFFER_SIZE]; - snprintf(buf, BUFFER_SIZE, "%lld", - (long long)(esp_timer_get_time() / 1000ULL)); - esp_mqtt_client_publish(client, PUB_TOPIC, buf, 0, 1, 0); - vTaskDelay(pdMS_TO_TICKS(PUBLISH_INTERVAL_MS)); - } +static void publisher_task(void *pvParameters) +{ + while (1) { + char buf[BUFFER_SIZE]; + snprintf(buf, BUFFER_SIZE, "%lld", + (long long)(esp_timer_get_time() / 1000ULL)); + esp_mqtt_client_publish(client, PUB_TOPIC, buf, 0, 1, 0); + vTaskDelay(pdMS_TO_TICKS(PUBLISH_INTERVAL_MS)); + } } -void mqtt_app_start(void) { - esp_mqtt_client_config_t mqtt_cfg = { - .broker.address.uri = MQTT_URI, - }; - client = esp_mqtt_client_init(&mqtt_cfg); - esp_mqtt_client_register_event(client, ESP_EVENT_ANY_ID, mqtt_event_handler, - NULL); - esp_mqtt_client_start(client); +void mqtt_app_start(void) +{ + esp_mqtt_client_config_t mqtt_cfg = { + .broker.address.uri = MQTT_URI, + }; + client = esp_mqtt_client_init(&mqtt_cfg); + esp_mqtt_client_register_event(client, ESP_EVENT_ANY_ID, + mqtt_event_handler, NULL); + esp_mqtt_client_start(client); - xTaskCreate(publisher_task, "publisher_task", PUBLISHER_TASK_STACK_SIZE, NULL, - PUBLISHER_TASK_PRIORITY, NULL); + xTaskCreate(publisher_task, "publisher_task", PUBLISHER_TASK_STACK_SIZE, + NULL, PUBLISHER_TASK_PRIORITY, NULL); } -- cgit v1.2.3