AudioI2sSph0645::AudioI2sSph0645(gpio_num_t mic_sck, gpio_num_t mic_ws, gpio_num_t mic_din, gpio_num_t mclk) 
{  
    i2s_driver_ = new I2sDriver();
    i2s_driver_->setPins(mic_sck, mic_ws, -1, mic_din, mclk);
}

bool AudioI2sSph0645::Init(const audio_config_t &config)
{
    Log::Info(TAG, "Init...");
    AudioI2sCodec::Init(config);
    
    uint32_t sample_rate = 16000;

    if (!i2s_driver_->begin(I2S_MODE_STD, sample_rate, I2S_DATA_BIT_WIDTH_32BIT, I2S_SLOT_MODE_MONO, I2S_STD_SLOT_LEFT)) {
        Log::Error(TAG, "Failed to initialize I2S!");
        return false;
    }

    // 对于SPH0645LM4H型号的麦克风，配置一个32bit->16bit的转换程序
    i2s_driver_->configureRX(sample_rate, I2S_DATA_BIT_WIDTH_32BIT, I2S_SLOT_MODE_MONO, I2S_RX_TRANSFORM_32_TO_16);

    Log::Info(TAG, "i2s initialize success.");
    return true;
}

audio_config_t AudioI2sSph0645::audio_config() 
{
    audio_config_t cfg = {
        .rate = (sample_rate_t)i2s_driver_->rxSampleRate(),
        .bits = (sample_bits_t)i2s_driver_->rxDataWidth(),
        .channels = (channels_t)i2s_driver_->rxSlotMode()
    };
    return cfg;
}

void MyBoard::InitAudioCodec() {
    Log::Info(TAG, "initial audio codec.");
    audio_codec_ = new AudioI2sSph0645(MIC_BCLK_PIN, MIC_WS_PIN, MIC_DIN_PIN);
}

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

    FileSystem *fsys = Board::GetInstance().GetFileSystem();
    std::string filepath = "/test001.wav";

    display->GetWindow()->SetText(1, "Recording to file: " + filepath);

    // 音频处理流
    // I2sInput（麦克风输入） -> Encoder（编码） -> FileOutput（输出到文件）

    uint16_t samples_msec = 500; // 0.5s

    // I2S输入
    AudioCodec *audio_codec = Board::GetInstance().GetAudioCodec();
    AudioI2sInput *input = new AudioI2sInput(audio_codec, samples_msec);

    // 编码输出
    AudioEncoderOutput *output = new AudioEncoderOutput(fsys, filepath, "wav");
    audio_config_t output_config = {
        .rate = SAMPLE_RATE_16K,
        .bits = SAMPLE_BITS_16,   // 32bit -> 16bit
        .channels = CHANNELS_1
    };
    output->SetAudioConfig(output_config);

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

    // 事件监听
    pipe_->SetPipeListener([this,input](PipeAction action){
        AudioCodec *codec = Board::GetInstance().GetAudioCodec();
        if (action==PipeAction::Begin)
        {
            codec->EnableInput(true); // 使能输入
        }
        else if (action==PipeAction::Ended)
        {
            codec->EnableInput(false);
            Display *display = Board::GetInstance().GetDisplay();
            display->GetWindow()->SetText(3, "Record msec: " + std::to_string(input->duration_ms()));
            display->GetWindow()->SetText(4, "Audio pipe ended.");
        }
        else if (action==PipeAction::Processing) 
        {
            Log::Info(TAG, "audio processing...");

            info_count_++;
            if (info_count_ % 10 == 0) 
            {  // 取整
                int n = (info_count_ / 10) % 2;
                Display *display = Board::GetInstance().GetDisplay();
                display->GetWindow()->SetText(3, info_text_[n]);
            }
        }
        else if (action==PipeAction::Error)
        {
            Display *display = Board::GetInstance().GetDisplay();
            display->GetWindow()->SetText(4, pipe_->last_error());
        }
    });

    // 启动管道
    pipe_->Start(input, output);
    Log::Info(TAG, "Audio pipe started.");
}