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 <contact@philw.dev>

1 files changed, 48 insertions, 45 deletions

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);
 }