BluetoothA2DPSink.h

// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
 
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
// Copyright 2020 Phil Schatzmann
// Copyright 2015-2016 Espressif Systems (Shanghai) PTE LTD
 
#pragma once
#include "BluetoothA2DPCommon.h"
#if IS_VALID_PLATFORM
 
#include "BluetoothA2DPOutput.h"
#include "freertos/ringbuf.h"
 
// Comment out next line to deactivate warnings
#ifndef A2DP_I2S_AUDIOTOOLS
#warning "AudioTools library is not included first or installed"
#endif
 
#define APP_SIG_WORK_DISPATCH (0x01)
 
#ifndef BT_AV_TAG
#define BT_AV_TAG "BT_AV"
#endif
 
#if (A2DP_SPP_SUPPORT && ESP_IDF_VERSION >= ESP_IDF_VERSION_VAL(5, 0, 0))
#include "esp_spp_api.h"
#endif
 
#ifndef ESP_A2D_SBC_CIE_ALLOC_MTHD_SNR
#define ESP_A2D_SBC_CIE_ALLOC_MTHD_SNR (0x02)
#endif
 
/* @brief event for handler "bt_av_hdl_stack_up */
enum {
  BT_APP_EVT_STACK_UP = 0,
};
 
extern "C" void ccall_i2s_task_handler(void* arg);
extern "C" void ccall_audio_data_callback(const uint8_t* data, uint32_t len);
extern "C" void ccall_av_hdl_a2d_evt(uint16_t event, void* p_param);
extern "C" void ccall_av_hdl_avrc_evt(uint16_t event, void* p_param);
#if ESP_IDF_VERSION >= ESP_IDF_VERSION_VAL(5, 5, 0)
extern "C" void ccall_audio_encoded_callback(esp_a2d_conn_hdl_t conn_hdl,
                                             esp_a2d_audio_buff_t* audio_buf);
#endif
 
enum PinCodeRequest { Undefined, Confirm, Reply };
 
enum A2DPCodec {
  A2DP_CODEC_SBC,
  A2DP_CODEC_M12,
  A2DP_CODEC_AAC,
  A2DP_CODEC_ATRAC
};
 
// provide global ref for callbacks
class BluetoothA2DPSink;
extern BluetoothA2DPSink* actual_bluetooth_a2dp_sink;
 
class BluetoothA2DPSink : public BluetoothA2DPCommon {
  friend void ccall_i2s_task_handler(void* arg);
  friend void ccall_audio_data_callback(const uint8_t* data, uint32_t len);
  friend void ccall_av_hdl_a2d_evt(uint16_t event, void* p_param);
  friend void ccall_av_hdl_avrc_evt(uint16_t event, void* p_param);
#if ESP_IDF_VERSION >= ESP_IDF_VERSION_VAL(5, 5, 0)
  friend void ccall_audio_encoded_callback(esp_a2d_conn_hdl_t conn_hdl,
                                           esp_a2d_audio_buff_t* audio_buf);
#endif
 
 public:
  BluetoothA2DPSink();
 
  BluetoothA2DPSink(BluetoothA2DPOutput& out) : BluetoothA2DPSink() {
    set_output(out);
  }
 
#if A2DP_I2S_AUDIOTOOLS
  BluetoothA2DPSink(audio_tools::AudioOutput& output) : BluetoothA2DPSink() {
    set_output(output);
  }
  BluetoothA2DPSink(audio_tools::AudioStream& output) : BluetoothA2DPSink() {
    set_output(output);
  }
#endif
 
#ifdef ARDUINO
  BluetoothA2DPSink(Print& output) : BluetoothA2DPSink() { set_output(output); }
#endif
 
  virtual ~BluetoothA2DPSink();
 
#if A2DP_LEGACY_I2S_SUPPORT
  virtual void set_pin_config(i2s_pin_config_t pin_config) {
    out->set_pin_config(pin_config);
  }
 
  virtual void set_i2s_port(i2s_port_t i2s_num) { out->set_i2s_port(i2s_num); }
 
  virtual void set_i2s_config(i2s_config_t i2s_config) {
    out->set_i2s_config(i2s_config);
  }
 
  virtual void set_channels(i2s_channel_t channels) {
    set_mono_downmix(channels == I2S_CHANNEL_MONO);
  }
 
  virtual void set_bits_per_sample(int bps) { out->set_bits_per_sample(bps); }
 
#if ESP_IDF_VERSION < ESP_IDF_VERSION_VAL(5, 1, 1)
  virtual esp_err_t i2s_mclk_pin_select(const uint8_t pin) {
    return out->i2s_mclk_pin_select(pin);
  }
#endif
 
#endif
 
  void set_output(BluetoothA2DPOutput& output) { out = &output; }
 
  BluetoothA2DPOutput* get_output() { return out; }
 
#ifdef ARDUINO
  void set_output(Print& output) {
    static BluetoothA2DPOutputPrint s_out;
    out = &s_out;
    out->set_output(output);
  }
#endif
 
#if A2DP_I2S_AUDIOTOOLS
  void set_output(audio_tools::AudioOutput& output) { out->set_output(output); }
  void set_output(audio_tools::AudioStream& output) { out->set_output(output); }
#endif
 
  virtual void start(const char* name, bool auto_reconect);
 
  virtual void start(const char* name);
 
  virtual void end(bool release_memory = false);
 
  virtual esp_a2d_mct_t get_audio_type();
 
#if ESP_IDF_VERSION >= ESP_IDF_VERSION_VAL(5, 5, 0)
  bool set_codec(A2DPCodec codec,
                 void (*encoded_cb)(const uint8_t* data, size_t len) = nullptr);
#endif
 
  virtual void set_avrc_connection_state_callback(void (*callback)(bool)) {
    this->avrc_connection_state_callback = callback;
  }
 
  virtual void set_avrc_metadata_callback(void (*callback)(uint8_t,
                                                           const uint8_t*)) {
    this->avrc_metadata_callback = callback;
  }
 
#if ESP_IDF_VERSION >= ESP_IDF_VERSION_VAL(4, 0, 0)
  virtual void set_avrc_rn_playstatus_callback(
      void (*callback)(esp_avrc_playback_stat_t playback)) {
    this->avrc_rn_playstatus_callback = callback;
  }
  virtual void set_avrc_rn_play_pos_callback(
      void (*callback)(uint32_t play_pos), uint32_t notif_interval = 10) {
    this->avrc_rn_play_pos_callback = callback;
    this->notif_interval_s = std::max(notif_interval, (uint32_t)1);
  }
  virtual void set_avrc_rn_track_change_callback(
      void (*callback)(uint8_t* id)) {
    this->avrc_rn_track_change_callback = callback;
  }
#endif
 
  virtual void set_sample_rate_callback(void (*callback)(uint16_t rate)) {
    this->sample_rate_callback = callback;
  }
 
  virtual void set_stream_reader(void (*callBack)(const uint8_t*, uint32_t),
                                 bool i2s_output = true);
 
  virtual void set_raw_stream_reader(void (*callBack)(const uint8_t*,
                                                      uint32_t));
 
  virtual void set_on_data_received(void (*callBack)());
 
  virtual void set_address_validator(
      bool (*callBack)(esp_bd_addr_t remote_bda)) {
    address_validator = callBack;
  }
 
  virtual bool is_avrc_connected();
 
  virtual void set_volume(uint8_t volume);
 
  virtual int get_volume();
 
  virtual void set_on_volumechange(void (*callBack)(int));
 
  virtual void set_avrc_rn_volumechange(void (*callBack)(int));
 
  virtual void set_avrc_rn_volumechange_completed(void (*callBack)(int));
 
  virtual void play();
  virtual void pause();
  virtual void stop();
  virtual void next();
  virtual void previous();
  virtual void fast_forward();
  virtual void rewind();
  virtual void volume_up();
  virtual void volume_down();
 
  virtual void set_mono_downmix(bool enabled) {
    volume_control()->set_mono_downmix(enabled);
  }
 
  virtual uint16_t sample_rate() { return m_sample_rate; }
 
  virtual uint16_t channels() { return m_channels; }
 
  virtual void activate_pin_code(bool active);
 
  virtual void confirm_pin_code();
 
  virtual void confirm_pin_code(int code);
 
  virtual int pin_code() { return pin_code_int; }
 
  virtual void set_avrc_metadata_attribute_mask(int flags) {
    avrc_metadata_flags = flags;
  }
 
  virtual void set_swap_lr_channels(bool swap) { swap_left_right = swap; }
 
  virtual void set_auto_reconnect(bool reconnect,
                                  int count = AUTOCONNECT_TRY_NUM) {
    reconnect_status = reconnect ? AutoReconnect : NoReconnect;
    try_reconnect_max_count = count;
  }
 
  virtual esp_bd_addr_t* get_current_peer_address() { return &peer_bd_addr; }
 
  void set_rssi_active(bool active) { rssi_active = active; }
 
  bool update_rssi() {
    if (!rssi_active) return false;
    return esp_bt_gap_read_rssi_delta(*get_current_peer_address()) == ESP_OK;
  }
 
  esp_bt_gap_cb_param_t::read_rssi_delta_param get_last_rssi() {
    return last_rssi_delta;
  }
 
  void set_rssi_callback(
      void (*callback)(esp_bt_gap_cb_param_t::read_rssi_delta_param& rssi)) {
    rssi_callback = callback;
  }
 
  void set_peer_name_callback(void (*callback)(char* peer_name)) {
    peer_name_callback = callback;
  }
 
  void set_reconnect_delay(int delay) { reconnect_delay = delay; }
 
#if A2DP_SPP_SUPPORT
  void set_spp_active(bool flag) { spp_active = flag; }
 
#if (ESP_IDF_VERSION >= ESP_IDF_VERSION_VAL(5, 0, 0))
  void set_spp_config(esp_spp_cfg_t cfg) { spp_cfg = cfg; }
#endif
#endif
 
  void set_output_active(bool flag) { is_i2s_active = flag; }
 
  void set_output_active_by_state(bool active) { is_output_active_by_state = active;}
 
  bool is_output_active() { return is_i2s_active; }
 
  void set_max_write_size(int size) { max_write_size = size; }
 
  void set_max_write_delay_ms(int delay) { max_write_delay_ms = delay; }
 
#if ESP_IDF_VERSION >= ESP_IDF_VERSION_VAL(4, 0, 0)
  bool is_avrc_peer_rn_cap(esp_avrc_rn_event_ids_t cmd) {
    return esp_avrc_rn_evt_bit_mask_operation(ESP_AVRC_BIT_MASK_OP_TEST,
                                              &s_avrc_peer_rn_cap, cmd);
  }
  bool is_avrc_peer_rn_cap_available() { return s_avrc_peer_rn_cap.bits != 0; }
 
  virtual const char* get_peer_name() { return get_connected_source_name(); }
 
#endif
 
 protected:
  BluetoothA2DPOutputDefault out_default;
  BluetoothA2DPOutput* out = &out_default;
 
  volatile bool is_i2s_active = false;
  // activate output via BluetoothA2DPOutput
  bool is_output = true;
  bool is_output_active_by_state = true;
  uint16_t m_sample_rate = 44100;  // set default rate
  // number of PCM channels negotiated (1=mono,2=stereo). Default 2.
  uint8_t m_channels = 2;
  uint32_t m_pkt_cnt = 0;
  // esp_a2d_audio_state_t m_audio_state = ESP_A2D_AUDIO_STATE_STOPPED;
  esp_a2d_mct_t audio_type;
  char pin_code_str[20] = {0};
  int connection_rety_count = 0;
#if A2DP_SPP_SUPPORT
  bool spp_active = false;
#if (ESP_IDF_VERSION < ESP_IDF_VERSION_VAL(5, 0, 0))
  esp_spp_mode_t esp_spp_mode = ESP_SPP_MODE_CB;
#else
  esp_spp_cfg_t spp_cfg = BT_SPP_DEFAULT_CONFIG();
#endif
#endif
  _lock_t s_volume_lock;
  uint8_t s_volume = 0;
  bool s_volume_notify;
  int pin_code_int = 0;
  PinCodeRequest pin_code_request = Undefined;
  bool is_pin_code_active = false;
  bool avrc_connection_state = false;
  int avrc_metadata_flags =
      ESP_AVRC_MD_ATTR_TITLE | ESP_AVRC_MD_ATTR_ARTIST |
      ESP_AVRC_MD_ATTR_ALBUM | ESP_AVRC_MD_ATTR_TRACK_NUM |
      ESP_AVRC_MD_ATTR_NUM_TRACKS | ESP_AVRC_MD_ATTR_GENRE;
  void (*bt_volumechange)(int) = nullptr;
  void (*bt_dis_connected)() = nullptr;
  void (*bt_connected)() = nullptr;
  void (*data_received)() = nullptr;
  void (*stream_reader)(const uint8_t*, uint32_t) = nullptr;
  void (*encoded_stream_reader)(const uint8_t*, size_t) = nullptr;
  void (*raw_stream_reader)(const uint8_t*, uint32_t) = nullptr;
  void (*avrc_connection_state_callback)(bool connected) = nullptr;
  void (*avrc_metadata_callback)(uint8_t, const uint8_t*) = nullptr;
#if ESP_IDF_VERSION >= ESP_IDF_VERSION_VAL(4, 0, 0)
  void (*avrc_rn_playstatus_callback)(esp_avrc_playback_stat_t) = nullptr;
  void (*avrc_rn_track_change_callback)(uint8_t*) = nullptr;
  void (*avrc_rn_play_pos_callback)(uint32_t) = nullptr;
  uint32_t notif_interval_s = 10;
#endif
  void (*avrc_rn_volchg_complete_callback)(int) = nullptr;
  bool (*address_validator)(esp_bd_addr_t remote_bda) = nullptr;
  void (*sample_rate_callback)(uint16_t rate) = nullptr;
  bool swap_left_right = false;
  int try_reconnect_max_count = AUTOCONNECT_TRY_NUM;
 
  // RSSI support
  esp_bt_gap_cb_param_t::read_rssi_delta_param last_rssi_delta;
  bool rssi_active = false;
  void (*rssi_callback)(esp_bt_gap_cb_param_t::read_rssi_delta_param& rssi) =
      nullptr;
  void (*peer_name_callback)(char* peer_name) = nullptr;
  int reconnect_delay = 1000;
  int max_write_size = A2DP_I2S_MAX_WRITE_SIZE;
  int max_write_delay_ms = A2DP_I2S_MAX_WRITE_DELAY_MS;
 
#if ESP_IDF_VERSION >= ESP_IDF_VERSION_VAL(4, 0, 0)
  esp_avrc_rn_evt_cap_mask_t s_avrc_peer_rn_cap = {0};
  char remote_name[ESP_BT_GAP_MAX_BDNAME_LEN + 1];
#endif
#if ESP_IDF_VERSION >= ESP_IDF_VERSION_VAL(5, 5, 0)
  A2DPCodec desired_codec = A2DP_CODEC_SBC;
  esp_a2d_mcc_t mcc{};
#endif
 
  void app_gap_callback(esp_bt_gap_cb_event_t event,
                        esp_bt_gap_cb_param_t* param) override;
  void app_rc_ct_callback(esp_avrc_ct_cb_event_t event,
                          esp_avrc_ct_cb_param_t* param) override;
  void app_a2d_callback(esp_a2d_cb_event_t event,
                        esp_a2d_cb_param_t* param) override;
  void av_hdl_stack_evt(uint16_t event, void* p_param) override;
 
  virtual int init_bluetooth();
  virtual bool app_work_dispatch(app_callback_t p_cback, uint16_t event,
                                 void* p_params, int param_len);
  virtual void app_alloc_meta_buffer(esp_avrc_ct_cb_param_t* param);
  virtual void av_new_track();
  virtual void av_playback_changed();
  virtual void av_play_pos_changed();
  // execute AVRC command
  virtual void execute_avrc_command(int cmd);
 
  virtual const char* last_bda_nvs_name() { return "last_bda"; }
 
  virtual bool is_reconnect(esp_a2d_disc_rsn_t type) {
    bool result = is_autoreconnect_allowed &&
                  (reconnect_status == AutoReconnect ||
                   reconnect_status == IsReconnecting) &&
                  has_last_connection();
    ESP_LOGI(BT_AV_TAG, "is_reconnect: %s", result ? "true" : "false");
    return result;
  }
 
  // Callback for music stream
  virtual void audio_data_callback(const uint8_t* data, uint32_t len);
  // a2dp event handler
  virtual void av_hdl_a2d_evt(uint16_t event, void* p_param);
  // avrc event handler
  virtual void av_hdl_avrc_evt(uint16_t event, void* p_param);
 
  // split up long handlers
  virtual void handle_connection_state(uint16_t event, void* p_param);
  virtual void handle_audio_state(uint16_t event, void* p_param);
  virtual void handle_audio_cfg(uint16_t event, void* p_param);
  virtual void handle_avrc_connection_state(bool connected);
 
#if ESP_IDF_VERSION >= ESP_IDF_VERSION_VAL(4, 0, 0)
  virtual const char* get_connected_source_name();
  virtual void volume_set_by_local_host(uint8_t volume);
  virtual void volume_set_by_controller(uint8_t volume);
  virtual void av_notify_evt_handler(uint8_t event_id,
                                     esp_avrc_rn_param_t* event_parameter);
  virtual void app_rc_tg_callback(esp_avrc_tg_cb_event_t event,
                                  esp_avrc_tg_cb_param_t* param) override;
  virtual void av_hdl_avrc_tg_evt(uint16_t event, void* p_param) override;
#else
  virtual void av_notify_evt_handler(uint8_t event_id,
                                     uint32_t event_parameter);
#endif
 
  virtual void init_i2s();
 
  virtual size_t write_audio(const uint8_t* data, size_t size) {
    return i2s_write_data(data, size);
  }
 
  size_t i2s_write_data(const uint8_t* data, size_t item_size);
 
  virtual void i2s_task_handler(void* arg) {}
  virtual void bt_i2s_task_start_up(void) {}
  virtual void bt_i2s_task_shut_down(void) {}
 
  esp_err_t esp_a2d_connect(esp_bd_addr_t peer) override {
    return esp_a2d_sink_connect(peer);
  }
  esp_err_t esp_a2d_disconnect(esp_bd_addr_t remote_bda) override {
    return esp_a2d_sink_disconnect(remote_bda);
  }
 
  void set_scan_mode_connectable_default() override {
    set_scan_mode_connectable(true);
  }
 
  virtual void set_i2s_active(bool active);
 
  virtual bool isSource() { return false; }
 
  bool is_encoded_output() { return encoded_stream_reader != nullptr; }
};
 
#endif  // platform