feat(core): Initial Monolithic Firmware (v0.2)

- Implemented SystemIO dispatcher (Clean CLI + Binary Mux)
- Implemented Console with Command Registry (Click-like)
- Implemented NVS Config & Network Core (ESP-NOW)
- Added GatewayMgr for Coordinator role
- Added FactoryMgr for initial provisioning

Author: knoff

.clang-format

@@ -0,0 +1,21 @@
+BasedOnStyle: Google
+IndentWidth: 4
+TabWidth: 4
+UseTab: Never
+ColumnLimit: 120
+AccessModifierOffset: -4
+
+# Скобки
+BreakBeforeBraces: Attach
+AllowShortFunctionsOnASingleLine: Empty
+
+# Выравнивание
+AlignAfterOpenBracket: Align
+AlignOperands: true
+AlignTrailingComments: true
+
+# Указатели и ссылки (BaseManager* mgr, а не BaseManager *mgr)
+PointerAlignment: Left
+
+# Сортировка инклудов (SystemIO.h после CD_Defs.h, но до системных)
+SortIncludes: false

docs/architecture.md

@@ -1,7 +1,17 @@
 # Архитектура прошивки (Universal Firmware)
 
+**Версия:** 0.2 (Initial Core)
+**Тип:** Monolithic Firmware w/ Role Switching
+
 **Концепция:** One Binary to Rule Them All.
-Мы используем единый бинарный файл для всех типов устройств. Роль устройства определяется конфигурацией в NVS.
+Мы используем **Единую Прошивку** для всех устройств в сети (Координатор, Помпа, Бойлер, Весы).
+Роль устройства определяется при старте на основе конфигурации в **NVS** (`HU_TYPE_*`).
+
+## Ключевые преимущества
+
+- Одна точка сборки и тестирования.
+- Единый механизм OTA-обновлений (A/B Partitioning).
+- Возможность смены роли устройства "на лету" без программатора (через Console).
 
 ---
 
@@ -29,6 +39,29 @@ src/
 └── console/           # Обработчик текстовых команд (CD-ADB)
 ```
 
+Проект разделен на изолированные слои.
+
+### Level 0: HAL (Hardware Abstraction)
+
+- **SystemIO (`src/hal/SystemIO`):** - Единый диспетчер UART.
+  - Разделяет поток на **Текстовые команды** (CLI) и **Бинарные фреймы** (Mesh).
+  - Обеспечивает "чистый" вывод логов без разрыва строки ввода консоли.
+
+### Level 1: Core (Ядро)
+
+- **NVSConfig (`src/core/NVSConfig`):** Хранение `DeviceType`, `LogicalID` и калибровок.
+- **Network (`src/core/Network`):** Обертка над ESP-NOW. Управляет очередями пакетов.
+- **Console (`src/console/Console`):** - Реализация CD-ADB (Command Line Interface).
+  - Паттерн **Command Registry**: модули регистрируют свои команды (`ping`, `status`) динамически.
+
+### Level 2: Managers (Бизнес-логика)
+
+Каждый тип устройства реализуется как класс-наследник `BaseManager`.
+
+- **FactoryMgr:** Режим по умолчанию. Мигает светодиодом, ждет конфигурации.
+- **GatewayMgr:** Работает на Координаторе. Мост `Serial <-> ESP-NOW`.
+- **ActuatorMgr (TODO):** Управление моторами и PID.
+
 ## 2. Концепция "Менеджеров" (Hub Architecture)
 
 Устройство (ESP32) выступает хостом для одного или нескольких функциональных блоков (**Managers**).
@@ -47,7 +80,23 @@ src/
 
 ---
 
-## 3. Производственный процесс
+## 3. Взаимодействие (Data Flow)
+
+### Сценарий: CLI Команда
+
+1. Пользователь вводит `ping` в Serial Monitor.
+2. `SystemIO` накапливает байты в буфер. По `\n` вызывает коллбек `Console`.
+3. `Console` ищет `ping` в реестре команд.
+4. Вызывается лямбда, зарегистрированная в `GatewayMgr`.
+5. Лямбда отправляет пакет в `Network`.
+
+### Сценарий: Логирование
+
+1. Любой модуль вызывает макрос `LOG_INF("Data: %d", val)`.
+2. Макрос вызывает `SystemIO::log()`.
+3. `SystemIO` стирает текущую строку ввода (`\r\033[K`), печатает лог, затем восстанавливает приглашение `>`.
+
+## 4. Производственный процесс
 
 ### Этап 1: Flash (Чистая плата)
 

platformio.ini

@@ -32,3 +32,14 @@ lib_deps =
   cd-protocol
   ; knolleary/PubSubClient @ ^2.8
   ; marvinroger/AsyncMqttClient @ ^0.9.0
+
+; Фильтры монитора
+; direct: вывод как есть
+; send_on_enter: отправляет текст только по нажатию Enter (решает проблему "разрыва" ввода логами)
+monitor_filters = direct, send_on_enter
+
+; Включить локальное эхо (ты видишь, что пишешь)
+monitor_echo = yes
+
+; Обработка конца строки (CRLF)
+monitor_eol = LF

src/CD_Defs.h

@@ -1,11 +1,14 @@
 #pragma once
 #include <Arduino.h>
-#include <headunit_protocol.h> // Из lib/cd-protocol
+#include <headunit_protocol.h>  // Из lib/cd-protocol
 
 // Глобальные пины (по умолчанию для DevKit V1)
 #define PIN_LED_BUILTIN 2
 
+// Forward declaration, чтобы не инклудить хедер сюда
+class SystemIO;
+
 // Логирование (обертка для удобства)
-#define LOG_INF(fmt, ...) Serial.printf("[INF] " fmt "\n", ##__VA_ARGS__)
-#define LOG_ERR(fmt, ...) Serial.printf("[ERR] " fmt "\n", ##__VA_ARGS__)
-#define LOG_WRN(fmt, ...) Serial.printf("[WRN] " fmt "\n", ##__VA_ARGS__)
+#define LOG_INF(fmt, ...) SystemIO::log("INF", fmt, ##__VA_ARGS__)
+#define LOG_ERR(fmt, ...) SystemIO::log("ERR", fmt, ##__VA_ARGS__)
+#define LOG_WRN(fmt, ...) SystemIO::log("WRN", fmt, ##__VA_ARGS__)

src/console/Console.cpp

@@ -0,0 +1,97 @@
+#include "Console.h"
+#include "../hal/SystemIO.h"
+#include "../core/NVSConfig.h"
+
+std::vector<ConsoleCommand> Console::_commands;
+
+void Console::begin() {
+    LOG_INF("CD-ADB Shell Ready. Type 'help'.");
+
+    SystemIO::onTextCommand([](String cmd) {
+        // 1. Сбрасываем флаг перед запуском команды
+        SystemIO::resetOutputFlag();
+        // 2. Выполняем команду
+        Console::processCommand(cmd);
+        // 3. Проверяем: если команда промолчала, нужно восстановить промпт вручную
+        if (!SystemIO::wasOutputProduced()) {
+            SystemIO::showPrompt();
+        }
+    });
+
+    // Регистрация системных команд (Bootstrap)
+    registerCommand("help", printHelp, "Show help");
+    registerCommand("reboot", cmd_reboot, "System restart");
+    registerCommand("nvs", cmd_nvs, "Config tool: nvs <info|set_type|set_id>");
+
+    SystemIO::showPrompt();
+}
+
+void Console::registerCommand(String name, CmdHandler handler, String help) {
+    _commands.push_back({name, handler, help});
+}
+
+void Console::processCommand(String input) {
+    if (input.length() == 0) return;
+
+    // Разделяем "cmd" и "args"
+    int spaceIdx = input.indexOf(' ');
+    String cmdName = (spaceIdx == -1) ? input : input.substring(0, spaceIdx);
+    String args = (spaceIdx == -1) ? "" : input.substring(spaceIdx + 1);
+
+    cmdName.toLowerCase();
+
+    // Поиск в реестре
+    bool found = false;
+    for (const auto& cmd : _commands) {
+        if (cmd.name == cmdName) {
+            cmd.handler(args);
+            found = true;
+            break;
+        }
+    }
+
+    if (!found) {
+        SystemIO::println("Unknown command: '%s'. Type 'help'.", cmdName.c_str());
+    }
+}
+
+void Console::printHelp(String args) {
+    SystemIO::println("--- Available Commands ---");
+    // Выравнивание для красоты
+    for (const auto& cmd : _commands) {
+        // Простой форматированный вывод
+        // Можно заморочиться с паддингом, но пока так
+        char buf[64];
+        snprintf(buf, sizeof(buf), "  %-10s : %s", cmd.name.c_str(), cmd.help.c_str());
+        SystemIO::println(buf);
+    }
+    SystemIO::println("--------------------------");
+}
+
+void Console::cmd_reboot(String args) {
+    LOG_WRN("Rebooting...");
+    delay(500);
+    ESP.restart();
+}
+
+void Console::cmd_nvs(String args) {
+    // Логика NVS без изменений, только аргументы приходят готовые
+    if (args == "info") {
+        SystemIO::println("Type: 0x%02X, ID: 0x%02X, Rev: %d", NVSConfig::getDeviceType(), NVSConfig::getLogicalID(),
+                          NVSConfig::getHardwareRevision());
+    } else if (args.startsWith("set_type ")) {
+        int val = args.substring(9).toInt();
+        NVSConfig::setDeviceType((hu_device_type_t)val);
+        LOG_INF("Type set to %d. Rebooting...", val);
+        delay(1000);
+        ESP.restart();
+    } else if (args.startsWith("set_id ")) {
+        int val = args.substring(7).toInt();
+        NVSConfig::setLogicalID(val);
+        LOG_INF("ID set to %d.", val);
+    } else {
+        SystemIO::println("Usage: nvs <info|set_type|set_id>");
+    }
+}
+
+void Console::update() {}  // Заглушка

src/console/Console.h

@@ -0,0 +1,32 @@
+#pragma once
+#include "../CD_Defs.h"
+#include <vector>
+#include <functional>
+
+// Тип обработчика: получает строку аргументов (все, что после команды)
+using CmdHandler = std::function<void(String args)>;
+
+struct ConsoleCommand {
+    String name;
+    CmdHandler handler;
+    String help;
+};
+
+class Console {
+public:
+    static void begin();
+    static void update();  // Не нужен в loop, но пока оставим для совместимости API
+
+    // API для модулей (аналог @click.command)
+    static void registerCommand(String name, CmdHandler handler, String help);
+
+private:
+    static void processCommand(String cmd);
+    static void printHelp(String args);
+
+    // Обработчики команд
+    static void cmd_nvs(String args);
+    static void cmd_reboot(String args);
+
+    static std::vector<ConsoleCommand> _commands;
+};

src/core/NVSConfig.cpp

@@ -1,41 +1,42 @@
 #include "NVSConfig.h"
+#include "../hal/SystemIO.h"
 
 Preferences NVSConfig::prefs;
 
 void NVSConfig::begin() {
-  // Открываем namespace "cd-config".
-  // false = read/write режим (нам нужно уметь писать ID)
-  prefs.begin("cd-config", false);
-  LOG_INF("NVS Initialized");
+    // Открываем namespace "cd-config".
+    // false = read/write режим (нам нужно уметь писать ID)
+    prefs.begin("cd-config", false);
+    LOG_INF("NVS Initialized");
 }
 
 void NVSConfig::resetToFactory() {
-  prefs.clear();
-  LOG_WRN("NVS Cleared (Factory Reset)");
+    prefs.clear();
+    LOG_WRN("NVS Cleared (Factory Reset)");
 }
 
 hu_device_type_t NVSConfig::getDeviceType() {
-  // Читаем байт, приводим к enum.
-  // Если ключа нет - возвращаем HU_TYPE_UNKNOWN (0)
-  return (hu_device_type_t)prefs.getUChar("dev_type", HU_TYPE_UNKNOWN);
+    // Читаем байт, приводим к enum.
+    // Если ключа нет - возвращаем HU_TYPE_UNKNOWN (0)
+    return (hu_device_type_t)prefs.getUChar("dev_type", HU_TYPE_UNKNOWN);
 }
 
 uint8_t NVSConfig::getLogicalID() {
-  // Если ID не назначен, возвращаем UNASSIGNED (0xFE)
-  return prefs.getUChar("log_id", HU_ADDR_UNASSIGNED);
+    // Если ID не назначен, возвращаем UNASSIGNED (0xFE)
+    return prefs.getUChar("log_id", HU_ADDR_UNASSIGNED);
 }
 
 uint8_t NVSConfig::getHardwareRevision() {
-  // Версия железа, по умолчанию 1
-  return prefs.getUChar("hw_rev", 1);
+    // Версия железа, по умолчанию 1
+    return prefs.getUChar("hw_rev", 1);
 }
 
 void NVSConfig::setDeviceType(hu_device_type_t type) {
-  prefs.putUChar("dev_type", (uint8_t)type);
-  LOG_INF("Device Type set to: 0x%02X", type);
+    prefs.putUChar("dev_type", (uint8_t)type);
+    LOG_INF("Device Type set to: 0x%02X", type);
 }
 
 void NVSConfig::setLogicalID(uint8_t id) {
-  prefs.putUChar("log_id", id);
-  LOG_INF("Logical ID set to: 0x%02X", id);
+    prefs.putUChar("log_id", id);
+    LOG_INF("Logical ID set to: 0x%02X", id);
 }

src/core/Network.cpp

@@ -0,0 +1,76 @@
+#include "Network.h"
+#include "../hal/SystemIO.h"
+
+QueueHandle_t Network::_rxQueue;
+uint8_t Network::_myMac[6];
+
+void Network::begin(uint8_t logicalID) {
+    // 1. Инициализация WiFi в режиме Station
+    WiFi.mode(WIFI_STA);
+    WiFi.disconnect();
+
+    // Получаем MAC
+    WiFi.macAddress(_myMac);
+    LOG_INF("Network Init. MAC: %02X:%02X:%02X:%02X:%02X:%02X", _myMac[0], _myMac[1], _myMac[2], _myMac[3], _myMac[4],
+            _myMac[5]);
+
+    // 2. Инициализация ESP-NOW
+    if (esp_now_init() != ESP_OK) {
+        LOG_ERR("Error initializing ESP-NOW");
+        return;
+    }
+
+    // 3. Создаем очередь (FreeRTOS)
+    _rxQueue = xQueueCreate(NETWORK_RX_QUEUE_SIZE, sizeof(Packet));
+
+    // 4. Регистрируем коллбеки
+    esp_now_register_recv_cb(OnDataRecv);
+    esp_now_register_send_cb(OnDataSent);
+
+    // 5. Добавляем Broadcast пира (чтобы можно было слать всем)
+    esp_now_peer_info_t peerInfo = {};
+    memset(peerInfo.peer_addr, 0xFF, 6);  // Broadcast addr
+    peerInfo.channel = 0;
+    peerInfo.encrypt = false;
+
+    if (esp_now_add_peer(&peerInfo) != ESP_OK) {
+        LOG_ERR("Failed to add broadcast peer");
+    }
+}
+
+void Network::update() {
+    // Тут можно добавить логику перепосылки, если нужно
+}
+
+bool Network::sendBroadcast(const uint8_t *data, size_t len) {
+    uint8_t broadcastAddr[] = {0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF};
+    esp_err_t result = esp_now_send(broadcastAddr, (uint8_t *)data, len);
+    return result == ESP_OK;
+}
+
+bool Network::readPacket(Packet &pkt) {
+    if (!_rxQueue) return false;
+    return xQueueReceive(_rxQueue, &pkt, 0) == pdTRUE;
+}
+
+// ISR Context! Не использовать тяжелые операции
+void Network::OnDataRecv(const uint8_t *mac, const uint8_t *incomingData, int len) {
+    if (len > sizeof(Packet::data)) return;  // Overflow protection
+
+    Packet pkt;
+    memcpy(pkt.mac, mac, 6);
+    memcpy(pkt.data, incomingData, len);
+    pkt.len = len;
+
+    // Пушим в очередь (из ISR)
+    xQueueSendFromISR(_rxQueue, &pkt, NULL);
+}
+
+void Network::OnDataSent(const uint8_t *mac_addr, esp_now_send_status_t status) {
+    // Можно добавить дебаг, но будет спамить
+    // LOG_INF("Last Packet Send Status: %s", status == ESP_NOW_SEND_SUCCESS ? "OK" : "FAIL");
+}
+
+uint8_t *Network::getMacAddress() {
+    return _myMac;
+}