Program Listing for File Decoder.cpp

↰ Return to documentation for file (include/audioRender/MixMachine/MiniaudioObjects/Decoder.cpp)

#include "Decoder.hpp"
#include <filesystem>
#include <fstream>
#include "PDJE_LOG_SETTER.hpp"

Decoder::Decoder()
{
    ;
}

bool
Decoder::init(litedb& db, const SANITIZED_ORNOT& KeyOrPath)
{
    ma_decoder_config dconf = ma_decoder_config_init(ma_format_f32, CHANNEL, SAMPLERATE);

    if(KeyOrPath.find(".") != std::string::npos or KeyOrPath.find("/") != std::string::npos){
        fs::path songPath = fs::path(KeyOrPath).lexically_normal();
        if(!fs::exists(songPath)){
            critlog("failed to find music in findpath mode. Err from Decoder init. ErrPath: ");
            critlog(KeyOrPath);
            return false;
        }
        std::ifstream musicFile(songPath, std::ios::binary);
        std::vector<uint8_t> fileData {
            std::istreambuf_iterator<char>(musicFile),
            std::istreambuf_iterator<char>()
        };

        if(fileData.empty()){
            critlog("failed to read music binary data in findpath mode. Err from Decoder init. ErrPath: ");
            critlog(KeyOrPath);
            return false;

        }
        musicBinary = std::move(fileData);
    }
    else{
        std::string tempBinary;
        if(!db.KVGet(KeyOrPath, tempBinary)) {
            critlog("failed to get music from rocksdb. Err from Decoder init. ErrKey: ");
            critlog(KeyOrPath);
            return false;
        }

        musicBinary = std::vector<uint8_t>(tempBinary.begin(), tempBinary.end());
    }
    return ma_decoder_init_memory(musicBinary.data(), musicBinary.size(), &dconf, &dec) == MA_SUCCESS;
}

bool
Decoder::changePos(FRAME_POS Pos)
{
    bool chposRes = ma_decoder_seek_to_pcm_frame(&dec, Pos) == MA_SUCCESS;
    if(!chposRes){
        critlog("failed to change music play position. from Decoder changePos. ");
    }
    return chposRes;
}

bool
Decoder::getPos(FRAME_POS& pos)
{
    bool getPosRes = ma_decoder_get_cursor_in_pcm_frames(&dec, &pos) == MA_SUCCESS;
    if(!getPosRes){
        critlog("failed to get music play position. from Decoder getPos");
    }
    return getPosRes;
}

bool
Decoder::getRange(FRAME_POS numFrames, std::vector<float>& buffer)
{
    FRAME_POS BufferSize = numFrames * CHANNEL;
    if(buffer.size() < BufferSize){
        buffer.resize(BufferSize);
    }
    if(ma_decoder_read_pcm_frames(&dec, buffer.data(), numFrames, NULL) != MA_SUCCESS){
        critlog("failed to read pcm frames from musicData. from Decoder getRange");
        return false;
    }
    return true;
}

Decoder::~Decoder()
{
    ma_decoder_uninit(&dec);
}