LiveRecordingSimulator.h

#include "httplib/httplib.h"
#include "json/json.h"
#include <iostream>
#include <ctime>
#include <map>
#include <string>
#include <chrono>
#include "elma.h"
#include "client.h"
#include <stdlib.h>
#include <stdexcept>
#include <math.h>
#include <stdio.h>
#include "AudioFile.h"
#include <fstream>
#include <vector>
#include "channel.h"

using namespace std;
using namespace elma;

class LiveRecordingSimulator : public Process {

    public:
    
    LiveRecordingSimulator(std::string filename, int buffer_size):Process("live recording simulator") 
    {
        audioFile.load (filename);
        bit_depth = audioFile.getBitDepth();
        sample_rate = audioFile.getSampleRate();
        bs = buffer_size;
        split_audio_into_packets();
    };

    void init() {}
    void start() {
        emit(Event("set bit depth", bit_depth));
        emit(Event("set sample rate", sample_rate));
    }
    void update() {
        if (i < left_data_packets.size()){
            channel("left audio").send(left_data_packets[i]);
            channel("right audio").send(right_data_packets[i]);
            i++;
        }
    }
    void stop() {}

    void split_audio_into_packets();

    private:
    int i = 0;
    AudioFile<double> audioFile;
    double bit_depth;
    double sample_rate;
    vector<json> left_data_packets;
    vector<json> right_data_packets;
    int bs;
};

void LiveRecordingSimulator::split_audio_into_packets(){

    int buffer_size_counter = 0;
    json left_buffer;
    json right_buffer;

    for (int i = 0; i < audioFile.getNumSamplesPerChannel(); i++){
        if(buffer_size_counter < bs){
            left_buffer.push_back(audioFile.samples[0][i]);
            right_buffer.push_back(audioFile.samples[1][i]);
            buffer_size_counter++;
        } else {
            left_data_packets.push_back(left_buffer);
            right_data_packets.push_back(right_buffer);
            left_buffer.clear();
            right_buffer.clear();
            buffer_size_counter = 0;
        }
    }

    // Add the last data packet
    left_data_packets.push_back(left_buffer);
    right_data_packets.push_back(right_buffer);
    left_buffer.clear();
    right_buffer.clear();
    buffer_size_counter = 0;

}