/** * @file example_audio.c * @brief example_audio module is used to * @version 0.1 * @copyright Copyright (c) 2021-2025 Tuya Inc. All Rights Reserved. */ #include "tuya_cloud_types.h" #include "tal_api.h" #include "tuya_ringbuf.h" #include "tkl_output.h" #include "tkl_memory.h" #include "board_com_api.h" #include "tdl_audio_manage.h" #if defined(ENABLE_BUTTON) && (ENABLE_BUTTON == 1) #include "tdl_button_manage.h" #endif /*********************************************************** ************************macro define************************ ***********************************************************/ // Maximum recordable duration, unit ms #define EXAMPLE_RECORD_DURATION_MS (3 * 1000) /*********************************************************** ***********************typedef define*********************** ***********************************************************/ typedef enum { RECORDER_STATUS_IDLE = 0, RECORDER_STATUS_START, RECORDER_STATUS_RECORDING, RECORDER_STATUS_END, RECORDER_STATUS_PLAYING, } RECORDER_STATUS_E; /*********************************************************** ***********************variable define********************** ***********************************************************/ static RECORDER_STATUS_E sg_recorder_status = RECORDER_STATUS_IDLE; static TDL_AUDIO_HANDLE_T sg_audio_hdl = NULL; static TDL_AUDIO_INFO_T sg_audio_info = {0}; static TUYA_RINGBUFF_T sg_recorder_pcm_rb = NULL; /*********************************************************** ***********************function define********************** ***********************************************************/ #if defined(ENABLE_BUTTON) && (ENABLE_BUTTON == 1) static void __button_function_cb(char *name, TDL_BUTTON_TOUCH_EVENT_E event, void *argc) { switch (event) { case TDL_BUTTON_PRESS_DOWN: { PR_NOTICE("%s: single click", name); if (sg_recorder_status == RECORDER_STATUS_IDLE) { sg_recorder_status = RECORDER_STATUS_START; } else { PR_WARN("Please wait status IDLE"); } } break; case TDL_BUTTON_PRESS_UP: { PR_NOTICE("%s: release", name); if (sg_recorder_status == RECORDER_STATUS_RECORDING) { sg_recorder_status = RECORDER_STATUS_END; } } break; default: break; } } #endif static void __example_play_from_recorder_rb(void) { if (NULL == sg_recorder_pcm_rb || NULL == sg_audio_hdl ||\ 0 == sg_audio_info.frame_size) { return; } uint32_t data_len = tuya_ring_buff_used_size_get(sg_recorder_pcm_rb); if (data_len == 0) { PR_NOTICE("No data in recorder ring buffer"); return; } uint32_t out_len = 0; uint8_t *frame_buf = tkl_system_psram_malloc(sg_audio_info.frame_size); if (NULL == frame_buf) { PR_ERR("tkl_system_psram_malloc failed"); return; } do { memset(frame_buf, 0, sg_audio_info.frame_size); out_len = 0; data_len = tuya_ring_buff_used_size_get(sg_recorder_pcm_rb); if (data_len == 0) { PR_NOTICE("No data in recorder ring buffer"); break; } if (data_len >sg_audio_info.frame_size) { tuya_ring_buff_read(sg_recorder_pcm_rb, frame_buf, sg_audio_info.frame_size); out_len = sg_audio_info.frame_size; } else { tuya_ring_buff_read(sg_recorder_pcm_rb, frame_buf, data_len); out_len = data_len; } tdl_audio_play(sg_audio_hdl, frame_buf, out_len); } while (1); if (frame_buf) { tkl_system_psram_free(frame_buf); frame_buf = NULL; } } static void __example_get_audio_frame(TDL_AUDIO_FRAME_FORMAT_E type, TDL_AUDIO_STATUS_E status,\ uint8_t *data, uint32_t len) { if (RECORDER_STATUS_RECORDING != sg_recorder_status) { return; } if (sg_recorder_pcm_rb) { uint32_t free_size = tuya_ring_buff_free_size_get(sg_recorder_pcm_rb); if (free_size < len) { PR_WARN("recorder ring buffer overflow, free_size:%u, need_size:%u", free_size, len); return; } tuya_ring_buff_write(sg_recorder_pcm_rb, data, len); } return; } static OPERATE_RET __example_audio_open(void) { OPERATE_RET rt = OPRT_OK; uint32_t buf_len = 0; TUYA_CALL_ERR_RETURN(tdl_audio_find(AUDIO_CODEC_NAME, &sg_audio_hdl)); TUYA_CALL_ERR_RETURN(tdl_audio_open(sg_audio_hdl, __example_get_audio_frame)); TUYA_CALL_ERR_RETURN(tdl_audio_get_info(sg_audio_hdl, &sg_audio_info)); if(0 == sg_audio_info.frame_size || 0 == sg_audio_info.sample_tm_ms) { PR_ERR("get audio info err"); return OPRT_INVALID_PARM; } buf_len = (EXAMPLE_RECORD_DURATION_MS / sg_audio_info.sample_tm_ms) * sg_audio_info.frame_size; TUYA_CALL_ERR_RETURN(tuya_ring_buff_create(buf_len, \ OVERFLOW_PSRAM_STOP_TYPE, &sg_recorder_pcm_rb)); tdl_audio_volume_set(sg_audio_hdl, 60); PR_NOTICE("__example_audio_open success"); return OPRT_OK; } /** * @brief user_main * * @return int */ int user_main() { OPERATE_RET rt = OPRT_OK; tal_log_init(TAL_LOG_LEVEL_DEBUG, 1024, (TAL_LOG_OUTPUT_CB)tkl_log_output); PR_NOTICE("Application information:"); PR_NOTICE("Project name: %s", PROJECT_NAME); PR_NOTICE("App version: %s", PROJECT_VERSION); PR_NOTICE("Compile time: %s", __DATE__); PR_NOTICE("TuyaOpen version: %s", OPEN_VERSION); PR_NOTICE("TuyaOpen commit-id: %s", OPEN_COMMIT); PR_NOTICE("Platform chip: %s", PLATFORM_CHIP); PR_NOTICE("Platform board: %s", PLATFORM_BOARD); PR_NOTICE("Platform commit-id: %s", PLATFORM_COMMIT); /*hardware register*/ TUYA_CALL_ERR_LOG(board_register_hardware()); TUYA_CALL_ERR_LOG(__example_audio_open()); #if defined(ENABLE_BUTTON) && (ENABLE_BUTTON == 1) // button create TDL_BUTTON_CFG_T button_cfg = {.long_start_valid_time = 3000, .long_keep_timer = 1000, .button_debounce_time = 50, .button_repeat_valid_count = 0, .button_repeat_valid_time = 500}; TDL_BUTTON_HANDLE button_hdl = NULL; TUYA_CALL_ERR_LOG(tdl_button_create(BUTTON_NAME, &button_cfg, &button_hdl)); tdl_button_event_register(button_hdl, TDL_BUTTON_PRESS_DOWN, __button_function_cb); tdl_button_event_register(button_hdl, TDL_BUTTON_PRESS_UP, __button_function_cb); #endif while(1) { switch(sg_recorder_status) { case RECORDER_STATUS_START: PR_NOTICE("Start recording"); sg_recorder_status = RECORDER_STATUS_RECORDING; break; case RECORDER_STATUS_RECORDING: break; case RECORDER_STATUS_END: PR_NOTICE("End recording"); sg_recorder_status = RECORDER_STATUS_PLAYING; break; case RECORDER_STATUS_PLAYING: PR_NOTICE("Start playing"); __example_play_from_recorder_rb(); PR_NOTICE("End playing"); sg_recorder_status = RECORDER_STATUS_IDLE; break; case RECORDER_STATUS_IDLE: tuya_ring_buff_reset(sg_recorder_pcm_rb); default: break; } tal_system_sleep(10); } } /** * @brief main * * @param argc * @param argv * @return void */ #if OPERATING_SYSTEM == SYSTEM_LINUX void main(int argc, char *argv[]) { user_main(); } #else /* Tuya thread handle */ static THREAD_HANDLE ty_app_thread = NULL; /** * @brief task thread * * @param[in] arg:Parameters when creating a task * @return none */ static void tuya_app_thread(void *arg) { user_main(); tal_thread_delete(ty_app_thread); ty_app_thread = NULL; } void tuya_app_main(void) { THREAD_CFG_T thrd_param = {4096, 4, "tuya_app_main"}; tal_thread_create_and_start(&ty_app_thread, NULL, NULL, tuya_app_thread, NULL, &thrd_param); } #endif