raop_sink.c 5.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193
  1. #include <stdio.h>
  2. #include <string.h>
  3. #include <ctype.h>
  4. #include <stdlib.h>
  5. #include "mdns.h"
  6. #include "nvs.h"
  7. #include "tcpip_adapter.h"
  8. // IDF-V4++ #include "esp_netif.h"
  9. #include "esp_log.h"
  10. #include "esp_console.h"
  11. #include "esp_pthread.h"
  12. #include "esp_system.h"
  13. #include "freertos/timers.h"
  14. #include "platform_config.h"
  15. #include "raop.h"
  16. #include "audio_controls.h"
  17. #include "display.h"
  18. #include "accessors.h"
  19. #include "log_util.h"
  20. #include "trace.h"
  21. #ifndef CONFIG_AIRPLAY_NAME
  22. #define CONFIG_AIRPLAY_NAME "ESP32-AirPlay"
  23. #endif
  24. log_level raop_loglevel = lINFO;
  25. log_level util_loglevel;
  26. static log_level *loglevel = &raop_loglevel;
  27. static struct raop_ctx_s *raop;
  28. static raop_cmd_vcb_t cmd_handler_chain;
  29. static void raop_volume_up(bool pressed) {
  30. if (!pressed) return;
  31. raop_cmd(raop, RAOP_VOLUME_UP, NULL);
  32. LOG_INFO("AirPlay volume up");
  33. }
  34. static void raop_volume_down(bool pressed) {
  35. if (!pressed) return;
  36. raop_cmd(raop, RAOP_VOLUME_DOWN, NULL);
  37. LOG_INFO("AirPlay volume down");
  38. }
  39. static void raop_toggle(bool pressed) {
  40. if (!pressed) return;
  41. raop_cmd(raop, RAOP_TOGGLE, NULL);
  42. LOG_INFO("AirPlay play/pause");
  43. }
  44. static void raop_pause(bool pressed) {
  45. if (!pressed) return;
  46. raop_cmd(raop, RAOP_PAUSE, NULL);
  47. LOG_INFO("AirPlay pause");
  48. }
  49. static void raop_play(bool pressed) {
  50. if (!pressed) return;
  51. raop_cmd(raop, RAOP_PLAY, NULL);
  52. LOG_INFO("AirPlay play");
  53. }
  54. static void raop_stop(bool pressed) {
  55. if (!pressed) return;
  56. raop_cmd(raop, RAOP_STOP, NULL);
  57. LOG_INFO("AirPlay stop");
  58. }
  59. static void raop_prev(bool pressed) {
  60. if (!pressed) return;
  61. raop_cmd(raop, RAOP_PREV, NULL);
  62. LOG_INFO("AirPlay previous");
  63. }
  64. static void raop_next(bool pressed) {
  65. if (!pressed) return;
  66. raop_cmd(raop, RAOP_NEXT, NULL);
  67. LOG_INFO("AirPlay next");
  68. }
  69. const static actrls_t controls = {
  70. raop_volume_up, raop_volume_down, // volume up, volume down
  71. raop_toggle, raop_play, // toggle, play
  72. raop_pause, raop_stop, // pause, stop
  73. NULL, NULL, // rew, fwd
  74. raop_prev, raop_next, // prev, next
  75. NULL, NULL, NULL, NULL, // left, right, up, down
  76. raop_volume_down, raop_volume_up, raop_toggle// knob left, knob_right, knob push
  77. };
  78. /****************************************************************************************
  79. * Command handler
  80. */
  81. static bool cmd_handler(raop_event_t event, ...) {
  82. va_list args;
  83. va_start(args, event);
  84. // handle audio event and stop if forbidden
  85. if (!cmd_handler_chain(event, args)) {
  86. va_end(args);
  87. return false;
  88. }
  89. // now handle events for display
  90. switch(event) {
  91. case RAOP_SETUP:
  92. actrls_set(controls, false, NULL, actrls_ir_action);
  93. displayer_control(DISPLAYER_ACTIVATE, "AIRPLAY");
  94. break;
  95. case RAOP_PLAY:
  96. displayer_control(DISPLAYER_TIMER_RUN);
  97. break;
  98. case RAOP_FLUSH:
  99. displayer_control(DISPLAYER_TIMER_PAUSE);
  100. break;
  101. case RAOP_STOP:
  102. actrls_unset();
  103. displayer_control(DISPLAYER_SUSPEND);
  104. break;
  105. case RAOP_METADATA: {
  106. char *artist = va_arg(args, char*), *album = va_arg(args, char*), *title = va_arg(args, char*);
  107. displayer_metadata(artist, album, title);
  108. break;
  109. }
  110. case RAOP_PROGRESS: {
  111. int elapsed = va_arg(args, int), duration = va_arg(args, int);
  112. displayer_timer(DISPLAYER_ELAPSED, elapsed, duration);
  113. break;
  114. }
  115. default:
  116. break;
  117. }
  118. va_end(args);
  119. return true;
  120. }
  121. /****************************************************************************************
  122. * Airplay sink de-initialization
  123. */
  124. void raop_sink_deinit(void) {
  125. raop_delete(raop);
  126. mdns_free();
  127. }
  128. /****************************************************************************************
  129. * Airplay sink initialization
  130. */
  131. void raop_sink_init(raop_cmd_vcb_t cmd_cb, raop_data_cb_t data_cb) {
  132. const char *hostname;
  133. char sink_name[64-6] = CONFIG_AIRPLAY_NAME;
  134. tcpip_adapter_ip_info_t ipInfo;
  135. struct in_addr host;
  136. // get various IP info
  137. tcpip_adapter_get_ip_info(TCPIP_ADAPTER_IF_STA, &ipInfo);
  138. tcpip_adapter_get_hostname(TCPIP_ADAPTER_IF_STA, &hostname);
  139. host.s_addr = ipInfo.ip.addr;
  140. // initialize mDNS
  141. ESP_ERROR_CHECK( mdns_init() );
  142. ESP_ERROR_CHECK( mdns_hostname_set(hostname) );
  143. char * sink_name_buffer= (char *)config_alloc_get(NVS_TYPE_STR,"airplay_name");
  144. if(sink_name_buffer != NULL){
  145. memset(sink_name, 0x00, sizeof(sink_name));
  146. strncpy(sink_name,sink_name_buffer,sizeof(sink_name)-1 );
  147. free(sink_name_buffer);
  148. }
  149. LOG_INFO( "mdns hostname for ip %s set to: [%s] with servicename %s", inet_ntoa(host), hostname, sink_name);
  150. // create RAOP instance, latency is set by controller
  151. uint8_t mac[6];
  152. esp_read_mac(mac, ESP_MAC_WIFI_STA);
  153. cmd_handler_chain = cmd_cb;
  154. raop = raop_create(host, sink_name, mac, 0, cmd_handler, data_cb);
  155. }
  156. /****************************************************************************************
  157. * Airplay forced disconnection
  158. */
  159. void raop_disconnect(void) {
  160. LOG_INFO("forced disconnection");
  161. displayer_control(DISPLAYER_SHUTDOWN);
  162. // in case we can't communicate with AirPlay controller, abort session
  163. if (!raop_cmd(raop, RAOP_STOP, NULL)) raop_abort(raop);
  164. actrls_unset();
  165. }