main.cpp 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816
  1. #include <iostream>
  2. #include <string>
  3. #include <vector>
  4. #include <regex>
  5. #include "esp_psram.h"
  6. #include "esp_pm.h"
  7. #include "psram.h"
  8. #include "esp_chip_info.h"
  9. // SD-Card ////////////////////
  10. #include "sdcard_init.h"
  11. #include "esp_vfs_fat.h"
  12. #include "ffconf.h"
  13. #include "driver/sdmmc_host.h"
  14. ///////////////////////////////
  15. #include "ClassLogFile.h"
  16. #include "connect_wlan.h"
  17. #include "read_wlanini.h"
  18. #include "server_main.h"
  19. #include "MainFlowControl.h"
  20. #include "server_file.h"
  21. #include "server_ota.h"
  22. #include "time_sntp.h"
  23. #include "configFile.h"
  24. #include "server_main.h"
  25. #include "server_camera.h"
  26. #ifdef ENABLE_MQTT
  27. #include "server_mqtt.h"
  28. #endif //ENABLE_MQTT
  29. #include "Helper.h"
  30. #include "statusled.h"
  31. #include "sdcard_check.h"
  32. #include "../../include/defines.h"
  33. #ifdef ENABLE_SOFTAP
  34. #include "softAP.h"
  35. #endif //ENABLE_SOFTAP
  36. #ifdef DISABLE_BROWNOUT_DETECTOR
  37. #include "soc/soc.h"
  38. #include "soc/rtc_cntl_reg.h"
  39. #endif
  40. #ifdef DEBUG_ENABLE_SYSINFO
  41. #if ESP_IDF_VERSION >= ESP_IDF_VERSION_VAL( 4, 0, 0 )
  42. #include "esp_sys.h"
  43. #endif
  44. #endif //DEBUG_ENABLE_SYSINFO
  45. // define `gpio_pad_select_gpip` for newer versions of IDF
  46. #if (ESP_IDF_VERSION >= ESP_IDF_VERSION_VAL(4, 3, 0))
  47. #include "esp_rom_gpio.h"
  48. #define gpio_pad_select_gpio esp_rom_gpio_pad_select_gpio
  49. #endif
  50. #ifdef USE_HIMEM_IF_AVAILABLE
  51. #include "esp32/himem.h"
  52. #ifdef DEBUG_HIMEM_MEMORY_CHECK
  53. #include "himem_memory_check.h"
  54. #endif
  55. #endif
  56. //#ifdef CONFIG_HEAP_TRACING_STANDALONE
  57. #if defined HEAP_TRACING_MAIN_WIFI || defined HEAP_TRACING_MAIN_START
  58. #include <esp_heap_trace.h>
  59. #define NUM_RECORDS 300
  60. static heap_trace_record_t trace_record[NUM_RECORDS]; // This buffer must be in internal RAM
  61. #endif
  62. extern const char* GIT_TAG;
  63. extern const char* GIT_REV;
  64. extern const char* GIT_BRANCH;
  65. extern const char* BUILD_TIME;
  66. extern std::string getFwVersion(void);
  67. extern std::string getHTMLversion(void);
  68. extern std::string getHTMLcommit(void);
  69. std::vector<std::string> splitString(const std::string& str);
  70. void migrateConfiguration(void);
  71. bool setCpuFrequency(void);
  72. static const char *TAG = "MAIN";
  73. #define MOUNT_POINT "/sdcard"
  74. bool Init_NVS_SDCard()
  75. {
  76. esp_err_t ret = nvs_flash_init();
  77. if (ret == ESP_ERR_NVS_NO_FREE_PAGES) {
  78. ESP_ERROR_CHECK(nvs_flash_erase());
  79. ret = nvs_flash_init();
  80. }
  81. ESP_LOGD(TAG, "Using SDMMC peripheral");
  82. sdmmc_host_t host = SDMMC_HOST_DEFAULT();
  83. host.max_freq_khz = SDMMC_FREQ_HIGHSPEED;
  84. // This initializes the slot without card detect (CD) and write protect (WP) signals.
  85. // Modify slot_config.gpio_cd and slot_config.gpio_wp if your board has these signals.
  86. sdmmc_slot_config_t slot_config = SDMMC_SLOT_CONFIG_DEFAULT();
  87. // Set bus width to use:
  88. #ifdef __SD_USE_ONE_LINE_MODE__
  89. slot_config.width = 1;
  90. #else
  91. slot_config.width = 4;
  92. #endif
  93. // Enable internal pullups on enabled pins. The internal pullups
  94. // are insufficient however, please make sure 10k external pullups are
  95. // connected on the bus. This is for debug / example purpose only.
  96. slot_config.flags |= SDMMC_SLOT_FLAG_INTERNAL_PULLUP;
  97. // Der PullUp des GPIO13 wird durch slot_config.flags |= SDMMC_SLOT_FLAG_INTERNAL_PULLUP;
  98. // nicht gesetzt, da er eigentlich nicht benötigt wird,
  99. // dies führt jedoch bei schlechten Kopien des AI_THINKER Boards
  100. // zu Problemen mit der SD Initialisierung und eventuell sogar zur reboot-loops.
  101. // Um diese Probleme zu kompensieren, wird der PullUp manuel gesetzt.
  102. gpio_set_pull_mode(GPIO_NUM_13, GPIO_PULLUP_ONLY); // HS2_D3
  103. // Options for mounting the filesystem.
  104. // If format_if_mount_failed is set to true, SD card will be partitioned and
  105. // formatted in case when mounting fails.
  106. esp_vfs_fat_sdmmc_mount_config_t mount_config = {
  107. .format_if_mount_failed = false,
  108. .max_files = 12, // previously -> 2022-09-21: 5, 2023-01-02: 7
  109. .allocation_unit_size = 0, // 0 = auto
  110. .disk_status_check_enable = 0
  111. };
  112. sdmmc_card_t* card;
  113. const char mount_point[] = MOUNT_POINT;
  114. // Use settings defined above to initialize SD card and mount FAT filesystem.
  115. // Note: esp_vfs_fat_sdmmc_mount is an all-in-one convenience function.
  116. // Please check its source code and implement error recovery when developing
  117. // production applications.
  118. ret = esp_vfs_fat_sdmmc_mount_mh(mount_point, &host, &slot_config, &mount_config, &card);
  119. if (ret != ESP_OK) {
  120. if (ret == ESP_FAIL) {
  121. ESP_LOGE(TAG, "Failed to mount FAT filesystem on SD card. Check SD card filesystem (only FAT supported) or try another card");
  122. StatusLED(SDCARD_INIT, 1, true);
  123. }
  124. else if (ret == 263) { // Error code: 0x107 --> usually: SD not found
  125. ESP_LOGE(TAG, "SD card init failed. Check if SD card is properly inserted into SD card slot or try another card");
  126. StatusLED(SDCARD_INIT, 2, true);
  127. }
  128. else {
  129. ESP_LOGE(TAG, "SD card init failed. Check error code or try another card");
  130. StatusLED(SDCARD_INIT, 3, true);
  131. }
  132. return false;
  133. }
  134. //sdmmc_card_print_info(stdout, card); // With activated CONFIG_NEWLIB_NANO_FORMAT --> capacity not printed correctly anymore
  135. SaveSDCardInfo(card);
  136. return true;
  137. }
  138. extern "C" void app_main(void)
  139. {
  140. //#ifdef CONFIG_HEAP_TRACING_STANDALONE
  141. #if defined HEAP_TRACING_MAIN_WIFI || defined HEAP_TRACING_MAIN_START
  142. //register a buffer to record the memory trace
  143. ESP_ERROR_CHECK( heap_trace_init_standalone(trace_record, NUM_RECORDS) );
  144. #endif
  145. TickType_t xDelay;
  146. #ifdef DISABLE_BROWNOUT_DETECTOR
  147. WRITE_PERI_REG(RTC_CNTL_BROWN_OUT_REG, 0); //disable brownout detector
  148. #endif
  149. #ifdef HEAP_TRACING_MAIN_START
  150. ESP_ERROR_CHECK( heap_trace_start(HEAP_TRACE_LEAKS) );
  151. #endif
  152. // ********************************************
  153. // Highlight start of app_main
  154. // ********************************************
  155. ESP_LOGI(TAG, "\n\n\n\n================ Start app_main =================");
  156. // Init SD card
  157. // ********************************************
  158. if (!Init_NVS_SDCard())
  159. {
  160. ESP_LOGE(TAG, "Device init aborted!");
  161. return; // No way to continue without working SD card!
  162. }
  163. // SD card: Create log directories (if not already existing)
  164. // ********************************************
  165. LogFile.CreateLogDirectories(); // mandatory for logging + image saving
  166. // ********************************************
  167. // Highlight start of logfile logging
  168. // Default Log Level: INFO -> Everything which needs to be logged during boot should be have level INFO, WARN OR ERROR
  169. // ********************************************
  170. LogFile.WriteToFile(ESP_LOG_INFO, TAG, "=================================================");
  171. LogFile.WriteToFile(ESP_LOG_INFO, TAG, "==================== Start ======================");
  172. LogFile.WriteToFile(ESP_LOG_INFO, TAG, "=================================================");
  173. // Init external PSRAM
  174. // ********************************************
  175. esp_err_t PSRAMStatus = esp_psram_init();
  176. if (PSRAMStatus == ESP_FAIL) { // ESP_FAIL -> Failed to init PSRAM
  177. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "PSRAM init failed (" + std::to_string(PSRAMStatus) + ")! PSRAM not found or defective");
  178. setSystemStatusFlag(SYSTEM_STATUS_PSRAM_BAD);
  179. StatusLED(PSRAM_INIT, 1, true);
  180. }
  181. else { // ESP_OK -> PSRAM init OK --> continue to check PSRAM size
  182. size_t psram_size = esp_psram_get_size(); // size_t psram_size = esp_psram_get_size(); // comming in IDF 5.0
  183. LogFile.WriteToFile(ESP_LOG_INFO, TAG, "PSRAM size: " + std::to_string(psram_size) + " byte (" + std::to_string(psram_size/1024/1024) +
  184. "MB / " + std::to_string(psram_size/1024/1024*8) + "MBit)");
  185. // Check PSRAM size
  186. // ********************************************
  187. if (psram_size < (4*1024*1024)) { // PSRAM is below 4 MBytes (32Mbit)
  188. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "PSRAM size >= 4MB (32Mbit) is mandatory to run this application");
  189. setSystemStatusFlag(SYSTEM_STATUS_PSRAM_BAD);
  190. StatusLED(PSRAM_INIT, 2, true);
  191. }
  192. else { // PSRAM size OK --> continue to check heap size
  193. size_t _hsize = getESPHeapSize();
  194. LogFile.WriteToFile(ESP_LOG_INFO, TAG, "Total heap: " + std::to_string(_hsize) + " byte");
  195. // Check heap memory
  196. // ********************************************
  197. if (_hsize < 4000000) { // Check available Heap memory for a bit less than 4 MB (a test on a good device showed 4187558 bytes to be available)
  198. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Total heap >= 4000000 byte is mandatory to run this application");
  199. setSystemStatusFlag(SYSTEM_STATUS_HEAP_TOO_SMALL);
  200. StatusLED(PSRAM_INIT, 3, true);
  201. }
  202. else { // HEAP size OK --> continue to reserve shared memory block and check camera init
  203. /* Allocate static PSRAM memory regions */
  204. if (! reserve_psram_shared_region()) {
  205. setSystemStatusFlag(SYSTEM_STATUS_HEAP_TOO_SMALL);
  206. StatusLED(PSRAM_INIT, 3, true);
  207. }
  208. else { // OK
  209. // Init camera
  210. // ********************************************
  211. PowerResetCamera();
  212. esp_err_t camStatus = Camera.InitCam();
  213. Camera.LightOnOff(false);
  214. xDelay = 2000 / portTICK_PERIOD_MS;
  215. ESP_LOGD(TAG, "After camera initialization: sleep for: %ldms", (long) xDelay * CONFIG_FREERTOS_HZ/portTICK_PERIOD_MS);
  216. vTaskDelay( xDelay );
  217. // Check camera init
  218. // ********************************************
  219. if (camStatus != ESP_OK) { // Camera init failed, retry to init
  220. char camStatusHex[33];
  221. sprintf(camStatusHex,"0x%02x", camStatus);
  222. LogFile.WriteToFile(ESP_LOG_WARN, TAG, "Camera init failed (" + std::string(camStatusHex) + "), retrying...");
  223. PowerResetCamera();
  224. camStatus = Camera.InitCam();
  225. Camera.LightOnOff(false);
  226. xDelay = 2000 / portTICK_PERIOD_MS;
  227. ESP_LOGD(TAG, "After camera initialization: sleep for: %ldms", (long) xDelay * CONFIG_FREERTOS_HZ/portTICK_PERIOD_MS);
  228. vTaskDelay( xDelay );
  229. if (camStatus != ESP_OK) { // Camera init failed again
  230. sprintf(camStatusHex,"0x%02x", camStatus);
  231. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Camera init failed (" + std::string(camStatusHex) +
  232. ")! Check camera module and/or proper electrical connection");
  233. setSystemStatusFlag(SYSTEM_STATUS_CAM_BAD);
  234. StatusLED(CAM_INIT, 1, true);
  235. }
  236. }
  237. else { // ESP_OK -> Camera init OK --> continue to perform camera framebuffer check
  238. // Camera framebuffer check
  239. // ********************************************
  240. if (!Camera.testCamera()) {
  241. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Camera framebuffer check failed");
  242. // Easiest would be to simply restart here and try again,
  243. // how ever there seem to be systems where it fails at startup but still work correctly later.
  244. // Therefore we treat it still as successed! */
  245. setSystemStatusFlag(SYSTEM_STATUS_CAM_FB_BAD);
  246. StatusLED(CAM_INIT, 2, false);
  247. }
  248. Camera.LightOnOff(false); // make sure flashlight is off before start of flow
  249. // Print camera infos
  250. // ********************************************
  251. char caminfo[50];
  252. sensor_t * s = esp_camera_sensor_get();
  253. sprintf(caminfo, "PID: 0x%02x, VER: 0x%02x, MIDL: 0x%02x, MIDH: 0x%02x", s->id.PID, s->id.VER, s->id.MIDH, s->id.MIDL);
  254. LogFile.WriteToFile(ESP_LOG_INFO, TAG, "Camera info: " + std::string(caminfo));
  255. }
  256. }
  257. }
  258. }
  259. }
  260. // SD card: basic R/W check
  261. // ********************************************
  262. int iSDCardStatus = SDCardCheckRW();
  263. if (iSDCardStatus < 0) {
  264. if (iSDCardStatus <= -1 && iSDCardStatus >= -2) { // write error
  265. StatusLED(SDCARD_CHECK, 1, true);
  266. }
  267. else if (iSDCardStatus <= -3 && iSDCardStatus >= -5) { // read error
  268. StatusLED(SDCARD_CHECK, 2, true);
  269. }
  270. else if (iSDCardStatus == -6) { // delete error
  271. StatusLED(SDCARD_CHECK, 3, true);
  272. }
  273. setSystemStatusFlag(SYSTEM_STATUS_SDCARD_CHECK_BAD); // reduced web interface going to be loaded
  274. }
  275. // Migrate parameter in config.ini to new naming (firmware 15.0 and newer)
  276. // ********************************************
  277. migrateConfiguration();
  278. // Init time (as early as possible, but SD card needs to be initialized)
  279. // ********************************************
  280. setupTime(); // NTP time service: Status of time synchronization will be checked after every round (server_tflite.cpp)
  281. // Set CPU Frequency
  282. // ********************************************
  283. setCpuFrequency();
  284. // SD card: Create further mandatory directories (if not already existing)
  285. // Correct creation of these folders will be checked with function "SDCardCheckFolderFilePresence"
  286. // ********************************************
  287. MakeDir("/sdcard/firmware"); // mandatory for OTA firmware update
  288. MakeDir("/sdcard/img_tmp"); // mandatory for setting up alignment marks
  289. MakeDir("/sdcard/demo"); // mandatory for demo mode
  290. // Check for updates
  291. // ********************************************
  292. CheckOTAUpdate();
  293. CheckUpdate();
  294. // Start SoftAP for initial remote setup
  295. // Note: Start AP if no wlan.ini and/or config.ini available, e.g. SD card empty; function does not exit anymore until reboot
  296. // ********************************************
  297. #ifdef ENABLE_SOFTAP
  298. CheckStartAPMode();
  299. #endif
  300. // SD card: Check presence of some mandatory folders / files
  301. // ********************************************
  302. if (!SDCardCheckFolderFilePresence()) {
  303. StatusLED(SDCARD_CHECK, 4, true);
  304. setSystemStatusFlag(SYSTEM_STATUS_FOLDER_CHECK_BAD); // reduced web interface going to be loaded
  305. }
  306. // Check version information
  307. // ********************************************
  308. std::string versionFormated = getFwVersion() + ", Date/Time: " + std::string(BUILD_TIME) + \
  309. ", Web UI: " + getHTMLversion();
  310. if (std::string(GIT_TAG) != "") { // We are on a tag, add it as prefix
  311. versionFormated = "Tag: '" + std::string(GIT_TAG) + "', " + versionFormated;
  312. }
  313. LogFile.WriteToFile(ESP_LOG_INFO, TAG, versionFormated);
  314. if (getHTMLcommit().substr(0, 7) == "?")
  315. LogFile.WriteToFile(ESP_LOG_WARN, TAG, std::string("Failed to read file html/version.txt to parse Web UI version"));
  316. if (getHTMLcommit().substr(0, 7) != std::string(GIT_REV).substr(0, 7)) { // Compare the first 7 characters of both hashes
  317. LogFile.WriteToFile(ESP_LOG_WARN, TAG, "Web UI version (" + getHTMLcommit() + ") does not match firmware version (" + std::string(GIT_REV) + ")");
  318. LogFile.WriteToFile(ESP_LOG_WARN, TAG, "Recommendation: Repeat installation using AI-on-the-edge-device__update__*.zip");
  319. }
  320. // Check reboot reason
  321. // ********************************************
  322. CheckIsPlannedReboot();
  323. if (!getIsPlannedReboot() && (esp_reset_reason() == ESP_RST_PANIC)) { // If system reboot was not triggered by user and reboot was caused by execption
  324. LogFile.WriteToFile(ESP_LOG_WARN, TAG, "Reset reason: " + getResetReason());
  325. LogFile.WriteToFile(ESP_LOG_WARN, TAG, "Device was rebooted due to a software exception! Log level is set to DEBUG until the next reboot. "
  326. "Flow init is delayed by 5 minutes to check the logs or do an OTA update");
  327. LogFile.WriteToFile(ESP_LOG_WARN, TAG, "Keep device running until crash occurs again and check logs after device is up again");
  328. LogFile.setLogLevel(ESP_LOG_DEBUG);
  329. }
  330. else {
  331. LogFile.WriteToFile(ESP_LOG_INFO, TAG, "Reset reason: " + getResetReason());
  332. }
  333. #ifdef HEAP_TRACING_MAIN_START
  334. ESP_ERROR_CHECK( heap_trace_stop() );
  335. heap_trace_dump();
  336. #endif
  337. #ifdef HEAP_TRACING_MAIN_WIFI
  338. ESP_ERROR_CHECK( heap_trace_start(HEAP_TRACE_LEAKS) );
  339. #endif
  340. // Read WLAN parameter and start WIFI
  341. // ********************************************
  342. int iWLANStatus = LoadWlanFromFile(WLAN_CONFIG_FILE);
  343. if (iWLANStatus == 0) {
  344. LogFile.WriteToFile(ESP_LOG_INFO, TAG, "WLAN config loaded, init WIFI...");
  345. if (wifi_init_sta() != ESP_OK) {
  346. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "WIFI init failed. Device init aborted!");
  347. StatusLED(WLAN_INIT, 3, true);
  348. return;
  349. }
  350. }
  351. else if (iWLANStatus == -1) { // wlan.ini not available, potentially empty or content not readable
  352. StatusLED(WLAN_INIT, 1, true);
  353. return; // No way to continue without reading the wlan.ini
  354. }
  355. else if (iWLANStatus == -2) { // SSID or password not configured
  356. StatusLED(WLAN_INIT, 2, true);
  357. return; // No way to continue with empty SSID or password!
  358. }
  359. xDelay = 2000 / portTICK_PERIOD_MS;
  360. ESP_LOGD(TAG, "main: sleep for: %ldms", (long) xDelay * CONFIG_FREERTOS_HZ/portTICK_PERIOD_MS);
  361. vTaskDelay( xDelay );
  362. // manual reset the time
  363. // ********************************************
  364. if (!time_manual_reset_sync())
  365. {
  366. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "Manual Time Sync failed during startup" );
  367. }
  368. // Set log level for wifi component to WARN level (default: INFO; only relevant for serial console)
  369. // ********************************************
  370. esp_log_level_set("wifi", ESP_LOG_WARN);
  371. #ifdef HEAP_TRACING_MAIN_WIFI
  372. ESP_ERROR_CHECK( heap_trace_stop() );
  373. heap_trace_dump();
  374. #endif
  375. #ifdef DEBUG_ENABLE_SYSINFO
  376. #if ESP_IDF_VERSION >= ESP_IDF_VERSION_VAL( 4, 0, 0 )
  377. LogFile.WriteToFile(ESP_LOG_INFO, TAG, "Device Info : " + get_device_info() );
  378. ESP_LOGD(TAG, "Device infos %s", get_device_info().c_str());
  379. #endif
  380. #endif //DEBUG_ENABLE_SYSINFO
  381. #ifdef USE_HIMEM_IF_AVAILABLE
  382. #ifdef DEBUG_HIMEM_MEMORY_CHECK
  383. LogFile.WriteToFile(ESP_LOG_INFO, TAG, "Himem mem check : " + himem_memory_check() );
  384. ESP_LOGD(TAG, "Himem mem check %s", himem_memory_check().c_str());
  385. #endif
  386. #endif
  387. // Print Device info
  388. // ********************************************
  389. esp_chip_info_t chipInfo;
  390. esp_chip_info(&chipInfo);
  391. LogFile.WriteToFile(ESP_LOG_INFO, TAG, "Device info: CPU cores: " + std::to_string(chipInfo.cores) +
  392. ", Chip revision: " + std::to_string(chipInfo.revision));
  393. // Print SD-Card info
  394. // ********************************************
  395. LogFile.WriteToFile(ESP_LOG_INFO, TAG, "SD card info: Name: " + getSDCardName() + ", Capacity: " +
  396. getSDCardCapacity() + "MB, Free: " + getSDCardFreePartitionSpace() + "MB");
  397. xDelay = 2000 / portTICK_PERIOD_MS;
  398. ESP_LOGD(TAG, "main: sleep for: %ldms", (long) xDelay * CONFIG_FREERTOS_HZ/portTICK_PERIOD_MS);
  399. vTaskDelay( xDelay );
  400. // Start webserver + register handler
  401. // ********************************************
  402. ESP_LOGD(TAG, "starting servers");
  403. server = start_webserver();
  404. register_server_camera_uri(server);
  405. register_server_main_flow_task_uri(server);
  406. register_server_file_uri(server, "/sdcard");
  407. register_server_ota_sdcard_uri(server);
  408. #ifdef ENABLE_MQTT
  409. register_server_mqtt_uri(server);
  410. #endif //ENABLE_MQTT
  411. gpio_handler_create(server);
  412. ESP_LOGD(TAG, "Before reg server main");
  413. register_server_main_uri(server, "/sdcard");
  414. // Only for testing purpose
  415. //setSystemStatusFlag(SYSTEM_STATUS_CAM_FB_BAD);
  416. //setSystemStatusFlag(SYSTEM_STATUS_PSRAM_BAD);
  417. // Check main init + start TFlite task
  418. // ********************************************
  419. if (getSystemStatus() == 0) { // No error flag is set
  420. LogFile.WriteToFile(ESP_LOG_INFO, TAG, "Initialization completed successfully");
  421. InitializeFlowTask();
  422. }
  423. else if (isSetSystemStatusFlag(SYSTEM_STATUS_CAM_FB_BAD) || // Non critical errors occured, we try to continue...
  424. isSetSystemStatusFlag(SYSTEM_STATUS_NTP_BAD)) {
  425. LogFile.WriteToFile(ESP_LOG_WARN, TAG, "Initialization completed with non-critical errors!");
  426. InitializeFlowTask();
  427. }
  428. else { // Any other error is critical and makes running the flow impossible. Init is going to abort.
  429. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Initialization failed. Flow task start aborted. Loading reduced web interface...");
  430. }
  431. }
  432. void migrateConfiguration(void) {
  433. bool migrated = false;
  434. if (!FileExists(CONFIG_FILE)) {
  435. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Config file seems to be missing!");
  436. return;
  437. }
  438. std::string section = "";
  439. std::ifstream ifs(CONFIG_FILE);
  440. std::string content((std::istreambuf_iterator<char>(ifs)), (std::istreambuf_iterator<char>()));
  441. /* Split config file it array of lines */
  442. std::vector<std::string> configLines = splitString(content);
  443. /* Process each line */
  444. for (int i = 0; i < configLines.size(); i++) {
  445. //ESP_LOGI(TAG, "Line %d: %s", i, configLines[i].c_str());
  446. if (configLines[i].find("[") != std::string::npos) { // Start of new section
  447. section = configLines[i];
  448. replaceString(section, ";", "", false); // Remove possible semicolon (just for the string comparison)
  449. //ESP_LOGI(TAG, "New section: %s", section.c_str());
  450. }
  451. /* Migrate parameters as needed
  452. * For the boolean parameters, we make them enabled all the time now:
  453. * 1. If they where disabled, set them to their default value
  454. * 2. Enable them
  455. * Notes:
  456. * The migration has some simplifications:
  457. * - Case Sensitiveness must be like in the initial config.ini
  458. * - No Whitespace after a semicollon
  459. * - Only one whitespace before/after the equal sign
  460. */
  461. if (section == "[MakeImage]") {
  462. migrated = migrated | replaceString(configLines[i], "[MakeImage]", "[TakeImage]"); // Rename the section itself
  463. }
  464. if (section == "[MakeImage]" || section == "[TakeImage]") {
  465. migrated = migrated | replaceString(configLines[i], "LogImageLocation", "RawImagesLocation");
  466. migrated = migrated | replaceString(configLines[i], "LogfileRetentionInDays", "RawImagesRetention");
  467. migrated = migrated | replaceString(configLines[i], ";Demo = true", ";Demo = false"); // Set it to its default value
  468. migrated = migrated | replaceString(configLines[i], ";Demo", "Demo"); // Enable it
  469. migrated = migrated | replaceString(configLines[i], ";FixedExposure = true", ";FixedExposure = false"); // Set it to its default value
  470. migrated = migrated | replaceString(configLines[i], ";FixedExposure", "FixedExposure"); // Enable it
  471. }
  472. if (section == "[Alignment]") {
  473. migrated = migrated | replaceString(configLines[i], ";InitialMirror = true", ";InitialMirror = false"); // Set it to its default value
  474. migrated = migrated | replaceString(configLines[i], ";InitialMirror", "InitialMirror"); // Enable it
  475. migrated = migrated | replaceString(configLines[i], ";FlipImageSize = true", ";FlipImageSize = false"); // Set it to its default value
  476. migrated = migrated | replaceString(configLines[i], ";FlipImageSize", "FlipImageSize"); // Enable it
  477. }
  478. if (section == "[Digits]") {
  479. migrated = migrated | replaceString(configLines[i], "LogImageLocation", "ROIImagesLocation");
  480. migrated = migrated | replaceString(configLines[i], "LogfileRetentionInDays", "ROIImagesRetention");
  481. }
  482. if (section == "[Analog]") {
  483. migrated = migrated | replaceString(configLines[i], "LogImageLocation", "ROIImagesLocation");
  484. migrated = migrated | replaceString(configLines[i], "LogfileRetentionInDays", "ROIImagesRetention");
  485. migrated = migrated | replaceString(configLines[i], "ExtendedResolution", ";UNUSED_PARAMETER"); // This parameter is no longer used
  486. }
  487. if (section == "[PostProcessing]") {
  488. migrated = migrated | replaceString(configLines[i], ";PreValueUse = true", ";PreValueUse = false"); // Set it to its default value
  489. migrated = migrated | replaceString(configLines[i], ";PreValueUse", "PreValueUse"); // Enable it
  490. /* AllowNegativeRates has a <NUMBER> as prefix! */
  491. if (isInString(configLines[i], "AllowNegativeRates") && isInString(configLines[i], ";")) { // It is the parameter "AllowNegativeRates" and it is commented out
  492. migrated = migrated | replaceString(configLines[i], "true", "false"); // Set it to its default value
  493. migrated = migrated | replaceString(configLines[i], ";", ""); // Enable it
  494. }
  495. /* IgnoreLeadingNaN has a <NUMBER> as prefix! */
  496. if (isInString(configLines[i], "IgnoreLeadingNaN") && isInString(configLines[i], ";")) { // It is the parameter "IgnoreLeadingNaN" and it is commented out
  497. migrated = migrated | replaceString(configLines[i], "true", "false"); // Set it to its default value
  498. migrated = migrated | replaceString(configLines[i], ";", ""); // Enable it
  499. }
  500. /* ExtendedResolution has a <NUMBER> as prefix! */
  501. if (isInString(configLines[i], "ExtendedResolution") && isInString(configLines[i], ";")) { // It is the parameter "ExtendedResolution" and it is commented out
  502. migrated = migrated | replaceString(configLines[i], "true", "false"); // Set it to its default value
  503. migrated = migrated | replaceString(configLines[i], ";", ""); // Enable it
  504. }
  505. migrated = migrated | replaceString(configLines[i], ";ErrorMessage = true", ";ErrorMessage = false"); // Set it to its default value
  506. migrated = migrated | replaceString(configLines[i], ";ErrorMessage", "ErrorMessage"); // Enable it
  507. migrated = migrated | replaceString(configLines[i], ";CheckDigitIncreaseConsistency = true", ";CheckDigitIncreaseConsistency = false"); // Set it to its default value
  508. migrated = migrated | replaceString(configLines[i], ";CheckDigitIncreaseConsistency", "CheckDigitIncreaseConsistency"); // Enable it
  509. }
  510. if (section == "[MQTT]") {
  511. migrated = migrated | replaceString(configLines[i], "SetRetainFlag", "RetainMessages"); // First rename it, enable it with its default value
  512. migrated = migrated | replaceString(configLines[i], ";RetainMessages = true", ";RetainMessages = false"); // Set it to its default value
  513. migrated = migrated | replaceString(configLines[i], ";RetainMessages", "RetainMessages"); // Enable it
  514. migrated = migrated | replaceString(configLines[i], ";HomeassistantDiscovery = true", ";HomeassistantDiscovery = false"); // Set it to its default value
  515. migrated = migrated | replaceString(configLines[i], ";HomeassistantDiscovery", "HomeassistantDiscovery"); // Enable it
  516. if (configLines[i].rfind("Topic", 0) != std::string::npos) // only if string starts with "Topic" (Was the naming in very old version)
  517. {
  518. migrated = migrated | replaceString(configLines[i], "Topic", "MainTopic");
  519. }
  520. }
  521. if (section == "[InfluxDB]") {
  522. /* Fieldname has a <NUMBER> as prefix! */
  523. if (isInString(configLines[i], "Fieldname")) { // It is the parameter "Fieldname"
  524. migrated = migrated | replaceString(configLines[i], "Fieldname", "Field"); // Rename it to Field
  525. }
  526. }
  527. if (section == "[InfluxDBv2]") {
  528. /* Fieldname has a <NUMBER> as prefix! */
  529. if (isInString(configLines[i], "Fieldname")) { // It is the parameter "Fieldname"
  530. migrated = migrated | replaceString(configLines[i], "Fieldname", "Field"); // Rename it to Field
  531. }
  532. /* Database got renamed to Bucket! */
  533. if (isInString(configLines[i], "Database")) { // It is the parameter "Database"
  534. migrated = migrated | replaceString(configLines[i], "Database", "Bucket"); // Rename it to Bucket
  535. }
  536. }
  537. if (section == "[GPIO]") {
  538. }
  539. if (section == "[DataLogging]") {
  540. migrated = migrated | replaceString(configLines[i], "DataLogRetentionInDays", "DataFilesRetention");
  541. /* DataLogActive is true by default! */
  542. migrated = migrated | replaceString(configLines[i], ";DataLogActive = false", ";DataLogActive = true"); // Set it to its default value
  543. migrated = migrated | replaceString(configLines[i], ";DataLogActive", "DataLogActive"); // Enable it
  544. }
  545. if (section == "[AutoTimer]") {
  546. migrated = migrated | replaceString(configLines[i], "Intervall", "Interval");
  547. migrated = migrated | replaceString(configLines[i], ";AutoStart = true", ";AutoStart = false"); // Set it to its default value
  548. migrated = migrated | replaceString(configLines[i], ";AutoStart", "AutoStart"); // Enable it
  549. }
  550. if (section == "[Debug]") {
  551. migrated = migrated | replaceString(configLines[i], "Logfile ", "LogLevel "); // Whitespace needed so it does not match `LogfileRetentionInDays`
  552. /* LogLevel (resp. LogFile) was originally a boolean, but we switched it to an int
  553. * For both cases (true/false), we set it to level 2 (WARNING) */
  554. migrated = migrated | replaceString(configLines[i], "LogLevel = true", "LogLevel = 2");
  555. migrated = migrated | replaceString(configLines[i], "LogLevel = false", "LogLevel = 2");
  556. migrated = migrated | replaceString(configLines[i], "LogfileRetentionInDays", "LogfilesRetention");
  557. }
  558. if (section == "[System]") {
  559. migrated = migrated | replaceString(configLines[i], "RSSIThreashold", "RSSIThreshold");
  560. migrated = migrated | replaceString(configLines[i], "AutoAdjustSummertime", ";UNUSED_PARAMETER"); // This parameter is no longer used
  561. migrated = migrated | replaceString(configLines[i], ";SetupMode = true", ";SetupMode = false"); // Set it to its default value
  562. migrated = migrated | replaceString(configLines[i], ";SetupMode", "SetupMode"); // Enable it
  563. }
  564. }
  565. if (migrated) { // At least one replacement happened
  566. if (! RenameFile(CONFIG_FILE, CONFIG_FILE_BACKUP)) {
  567. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to create backup of Config file!");
  568. return;
  569. }
  570. FILE* pfile = fopen(CONFIG_FILE, "w");
  571. for (int i = 0; i < configLines.size(); i++) {
  572. fwrite(configLines[i].c_str() , configLines[i].length(), 1, pfile);
  573. fwrite("\n" , 1, 1, pfile);
  574. }
  575. fclose(pfile);
  576. LogFile.WriteToFile(ESP_LOG_INFO, TAG, "Config file migrated. Saved backup to " + string(CONFIG_FILE_BACKUP));
  577. }
  578. }
  579. std::vector<std::string> splitString(const std::string& str) {
  580. std::vector<std::string> tokens;
  581. std::stringstream ss(str);
  582. std::string token;
  583. while (std::getline(ss, token, '\n')) {
  584. tokens.push_back(token);
  585. }
  586. return tokens;
  587. }
  588. /*bool replace_all(std::string& s, std::string const& toReplace, std::string const& replaceWith) {
  589. std::string buf;
  590. std::size_t pos = 0;
  591. std::size_t prevPos;
  592. bool found = false;
  593. // Reserves rough estimate of final size of string.
  594. buf.reserve(s.size());
  595. while (true) {
  596. prevPos = pos;
  597. pos = s.find(toReplace, pos);
  598. if (pos == std::string::npos) {
  599. break;
  600. }
  601. found = true;
  602. buf.append(s, prevPos, pos - prevPos);
  603. buf += replaceWith;
  604. pos += toReplace.size();
  605. }
  606. buf.append(s, prevPos, s.size() - prevPos);
  607. s.swap(buf);
  608. return found;
  609. }*/
  610. bool setCpuFrequency(void) {
  611. ConfigFile configFile = ConfigFile(CONFIG_FILE);
  612. string cpuFrequency = "160";
  613. esp_pm_config_esp32_t pm_config;
  614. if (!configFile.ConfigFileExists()){
  615. LogFile.WriteToFile(ESP_LOG_WARN, TAG, "No ConfigFile defined - exit setCpuFrequency()!");
  616. return false;
  617. }
  618. std::vector<std::string> splitted;
  619. std::string line = "";
  620. bool disabledLine = false;
  621. bool eof = false;
  622. /* Load config from config file */
  623. while ((!configFile.GetNextParagraph(line, disabledLine, eof) ||
  624. (line.compare("[System]") != 0)) && !eof) {}
  625. if (eof) {
  626. return false;
  627. }
  628. if (disabledLine) {
  629. return false;
  630. }
  631. while (configFile.getNextLine(&line, disabledLine, eof) &&
  632. !configFile.isNewParagraph(line)) {
  633. splitted = ZerlegeZeile(line);
  634. if (toUpper(splitted[0]) == "CPUFREQUENCY") {
  635. cpuFrequency = splitted[1];
  636. break;
  637. }
  638. }
  639. if (esp_pm_get_configuration(&pm_config) != ESP_OK) {
  640. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to read CPU Frequency!");
  641. return false;
  642. }
  643. if (cpuFrequency == "160") { // 160 is the default
  644. // No change needed
  645. }
  646. else if (cpuFrequency == "240") {
  647. pm_config.max_freq_mhz = 240;
  648. pm_config.min_freq_mhz = pm_config.max_freq_mhz;
  649. if (esp_pm_configure(&pm_config) != ESP_OK) {
  650. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Failed to set new CPU frequency!");
  651. return false;
  652. }
  653. }
  654. else {
  655. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Unknown CPU frequency: " + cpuFrequency + "! "
  656. "It must be 160 or 240!");
  657. return false;
  658. }
  659. if (esp_pm_get_configuration(&pm_config) == ESP_OK) {
  660. LogFile.WriteToFile(ESP_LOG_INFO, TAG, string("CPU frequency: ") + to_string(pm_config.max_freq_mhz) + " MHz");
  661. }
  662. return true;
  663. }