cmd_squeezelite.c 4.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159
  1. #include <stdio.h>
  2. #include <string.h>
  3. #include "application_name.h"
  4. #include "esp_log.h"
  5. #include "esp_console.h"
  6. #include "../cmd_system.h"
  7. #include "argtable3/argtable3.h"
  8. #include "freertos/FreeRTOS.h"
  9. #include "freertos/event_groups.h"
  10. #include "pthread.h"
  11. #include "platform_esp32.h"
  12. #include "platform_config.h"
  13. #include "esp_app_format.h"
  14. #include "tools.h"
  15. #include "messaging.h"
  16. extern esp_err_t process_recovery_ota(const char * bin_url, char * bin_buffer, uint32_t length);
  17. static const char * TAG = "squeezelite_cmd";
  18. #define SQUEEZELITE_THREAD_STACK_SIZE (8*1024)
  19. const __attribute__((section(".rodata_desc"))) esp_app_desc_t esp_app_desc = {
  20. .magic_word = ESP_APP_DESC_MAGIC_WORD,
  21. .version = PROJECT_VER,
  22. .project_name = CONFIG_PROJECT_NAME,
  23. .idf_ver = IDF_VER,
  24. #ifdef CONFIG_BOOTLOADER_APP_SECURE_VERSION
  25. .secure_version = CONFIG_BOOTLOADER_APP_SECURE_VERSION,
  26. #else
  27. .secure_version = 0,
  28. #endif
  29. #ifdef CONFIG_APP_COMPILE_TIME_DATE
  30. .time = __TIME__,
  31. .date = __DATE__,
  32. #else
  33. .time = "",
  34. .date = "",
  35. #endif
  36. };
  37. extern int squeezelite_main(int argc, char **argv);
  38. static int launchsqueezelite(int argc, char **argv);
  39. /** Arguments used by 'squeezelite' function */
  40. static struct {
  41. struct arg_str *parameters;
  42. struct arg_end *end;
  43. } squeezelite_args;
  44. static struct {
  45. int argc;
  46. char ** argv;
  47. } thread_parms ;
  48. #define ADDITIONAL_SQUEEZELITE_ARGS 5
  49. static void squeezelite_thread(void *arg){
  50. ESP_LOGV(TAG ,"Number of args received: %u",thread_parms.argc );
  51. ESP_LOGV(TAG ,"Values:");
  52. for(int i = 0;i<thread_parms.argc; i++){
  53. ESP_LOGV(TAG ," %s",thread_parms.argv[i]);
  54. }
  55. ESP_LOGI(TAG ,"Calling squeezelite");
  56. int ret = squeezelite_main(thread_parms.argc, thread_parms.argv);
  57. cmd_send_messaging("cfg-audio-tmpl",ret > 1 ? MESSAGING_ERROR : MESSAGING_WARNING,"squeezelite exited with error code %d\n", ret);
  58. if (ret <= 1) {
  59. int wait = 60;
  60. wait_for_commit();
  61. cmd_send_messaging("cfg-audio-tmpl",MESSAGING_ERROR,"Rebooting in %d sec\n", wait);
  62. vTaskDelay( pdMS_TO_TICKS(wait * 1000));
  63. esp_restart();
  64. } else {
  65. cmd_send_messaging("cfg-audio-tmpl",MESSAGING_ERROR,"Correct command line and reboot\n");
  66. vTaskSuspend(NULL);
  67. }
  68. ESP_LOGV(TAG, "Exited from squeezelite's main(). Freeing argv structure.");
  69. for(int i=0;i<thread_parms.argc;i++) free(thread_parms.argv[i]);
  70. free(thread_parms.argv);
  71. }
  72. static int launchsqueezelite(int argc, char **argv) {
  73. static DRAM_ATTR StaticTask_t xTaskBuffer __attribute__ ((aligned (4)));
  74. static EXT_RAM_ATTR StackType_t xStack[SQUEEZELITE_THREAD_STACK_SIZE] __attribute__ ((aligned (4)));
  75. static bool isRunning = false;
  76. if (isRunning) {
  77. ESP_LOGE(TAG,"Squeezelite already running. Exiting!");
  78. return -1;
  79. }
  80. ESP_LOGV(TAG ,"Begin");
  81. isRunning = true;
  82. ESP_LOGV(TAG, "Parameters:");
  83. for(int i = 0;i<argc; i++){
  84. ESP_LOGV(TAG, " %s",argv[i]);
  85. }
  86. ESP_LOGV(TAG,"Saving args in thread structure");
  87. thread_parms.argc=0;
  88. thread_parms.argv = malloc_init_external(sizeof(char**)*(argc+ADDITIONAL_SQUEEZELITE_ARGS));
  89. for(int i=0;i<argc;i++){
  90. ESP_LOGD(TAG ,"assigning parm %u : %s",i,argv[i]);
  91. thread_parms.argv[thread_parms.argc++]=strdup(argv[i]);
  92. }
  93. if(argc==1){
  94. // There isn't a default configuration that would actually work
  95. // if no parameter is passed.
  96. ESP_LOGV(TAG ,"Adding argv value at %u. Prev value: %s",thread_parms.argc,thread_parms.argv[thread_parms.argc-1]);
  97. thread_parms.argv[thread_parms.argc++]=strdup("-?");
  98. }
  99. ESP_LOGD(TAG,"Starting Squeezelite Thread");
  100. xTaskCreateStaticPinnedToCore(squeezelite_thread, "squeezelite", SQUEEZELITE_THREAD_STACK_SIZE,
  101. NULL, CONFIG_ESP32_PTHREAD_TASK_PRIO_DEFAULT, xStack, &xTaskBuffer, CONFIG_PTHREAD_TASK_CORE_DEFAULT);
  102. ESP_LOGD(TAG ,"Back to console thread!");
  103. return 0;
  104. }
  105. void register_squeezelite() {
  106. squeezelite_args.parameters = arg_str0(NULL, NULL, "<parms>", "command line for squeezelite. -h for help, --defaults to launch with default values.");
  107. squeezelite_args.end = arg_end(1);
  108. const esp_console_cmd_t launch_squeezelite = {
  109. .command = "squeezelite",
  110. .help = "Starts squeezelite",
  111. .hint = NULL,
  112. .func = &launchsqueezelite,
  113. .argtable = &squeezelite_args
  114. };
  115. ESP_ERROR_CHECK( esp_console_cmd_register(&launch_squeezelite) );
  116. }
  117. esp_err_t start_ota(const char * bin_url, char * bin_buffer, uint32_t length) {
  118. if(!bin_url){
  119. ESP_LOGE(TAG,"missing URL parameter. Unable to start OTA");
  120. return ESP_ERR_INVALID_ARG;
  121. }
  122. ESP_LOGW(TAG, "Called to update the firmware from url: %s",bin_url);
  123. if(config_set_value(NVS_TYPE_STR, "fwurl", bin_url) != ESP_OK){
  124. ESP_LOGE(TAG,"Failed to save the OTA url into nvs cache");
  125. return ESP_FAIL;
  126. }
  127. if(!wait_for_commit()){
  128. ESP_LOGW(TAG,"Unable to commit configuration. ");
  129. }
  130. ESP_LOGW(TAG, "Rebooting to recovery to complete the installation");
  131. return guided_factory();
  132. return ESP_OK;
  133. }