void AudioPipe::Execute()
{
    // 初始化
    bool ret = input_->Init();
    if (!ret)
    {
        last_error_ = "audio input init fail.";
        Log::Error(TAG, last_error_.c_str());
        return;
    }

    audio_config_t audio_cfg = input_->audio_config();
    output_->SetAudioConfig(audio_cfg);

    ret = output_->Init();
    if (!ret)
    {
        last_error_ = "audio output init fail.";
        Log::Error(TAG, last_error_.c_str());
        return;
    }

    input_->SetAudioListener(audio_listener_);
    output_->SetAudioListener(audio_listener_);

    if (pipe_listener_) 
    {
        Log::Info(TAG, "Pipe inited.");
        pipe_listener_(PipeAction::Inited);
    }

    // 处理数据
    // AudioInput使用Handle方法拉取数据；
    // AudioOutput使用WriteXxx方法推送数据；
    while (running_)
    {
        if (input_->isEOF()) 
        {
            Log::Info(TAG, "Input EOF.");
            break;
        }

        //--- STEP1：数据输入，从输入端取到原始数据
        sample_data_t input_data;
        if (!input_->Handle(input_data))
        { // 无数据
            Log::Info(TAG, "no data read.");
            continue;
        }

        audio_listener_->OnDataInput(input_data);

        sample_data_t output_data = input_data;

        // --- STEP2：数据加工，对数据进行处理，如变声，混音等
        if (!filter_set_.empty())
        {
            // 代码略...
        }

        audio_listener_->OnDataOutput(output_data);

        //--- STEP3：数据输出
        output_->WriteSamples(output_data);
    }

    Log::Info(TAG, "handle end.");
}

void MyBoard::InitAudioCodec() {
    Log::Info(TAG, "initial audio codec.");
    audio_codec_ = new AudioI2sSimplexSpeaker(SPK_BCLK_PIN, SPK_WS_PIN, SPK_DOUT_PIN);
}

void MyApplication::OnInit() {
    Display *display = Board::GetInstance().GetDisplay();
    display->Rotate(1);

    FileSystem *fsys = Board::GetInstance().GetFileSystem();
    std::string path = "/test.mp3";
    //std::string path = "/test.wav";
    if (!fsys->ExistsFile(path.c_str())) {
        std::string msg = "file " + path + " not found.";
        Log::Warn(TAG, msg.c_str());
        display->GetWindow()->SetText(1, msg);
        return;
    }

    display->GetWindow()->SetText(1, "Play file " + path);

    // 音频处理流
    // FileSource（文件源） -> Decoder（解码） -> I2sOutput（输出到喇叭）

    // 文件源
    AudioFileSource *file_source = new AudioFileSource(fsys, path);

    // 解码输入
    AudioDecodeInput *input = new AudioDecodeInput(file_source, "mp3");
    //AudioDecodeInput *input = new AudioDecodeInput(file_source, "wav");

    // I2S输出
    AudioCodec *audio_codec = Board::GetInstance().GetAudioCodec();
    AudioI2sOutput *output = new AudioI2sOutput(audio_codec);

    // 音频管道
    pipe_ = new AudioPipe();

    pipe_->SetPipeListener([](PipeAction action){
        AudioCodec *codec = Board::GetInstance().GetAudioCodec();
        if (action==PipeAction::Inited)
        {
            codec->SetOutputVolume(30); //0-100
            codec->Start();
        }
        else if (action==PipeAction::Ended)
        {
            codec->EnableOutput(false);
        }
    });

    // 启动管道
    pipe_->Start(input, output);
}