iAudioTask.h

#pragma once
 
#include <map>
#include <list>
#include <vector>
#include <string>
#include <boost/system/error_code.hpp>
#include <mutex>
 
#include "audioTypes.h"
 
namespace dpyAudio {
 
enum AudioTaskStatus
{
    UNKNOWN_STATUS = 0, 
    QUEUED = 1, 
    PROCESSING = 2, 
    PROCESSED_OK = 3, 
    ERROR_BEFORE_PROCESSING = 4, 
    ERROR_WHILE_PROCESSING = 5, 
    ERROR_AFTER_PROCESSING = 6, 
    TASK_STOPPED = 7 
};
 
struct AudioTaskInformation {
   dpyAudio::Port port; 
   std::string audioFilePath = ""; 
   dpyAudio::AudioTaskStatus status = UNKNOWN_STATUS ; 
   dpyAudio::TaskType type = PLAY; 
   
   std::list<dpyAudio::AudioConfig> configurations; 
 
    AudioTaskInformation(): port("user", "", dpyAudio::NA_TYPE ), audioFilePath(""),status(dpyAudio::AudioTaskStatus::UNKNOWN_STATUS), type(dpyAudio::TaskType::PLAY) {
    }
 
    AudioTaskInformation(dpyAudio::Port p, std::string a, dpyAudio::AudioTaskStatus s,  dpyAudio::TaskType t, std::list<dpyAudio::AudioConfig> c): port(p), audioFilePath(a), status(s), type(t), configurations(c) {
    }
 
};
 
}
 
 
class AudioTaskObserver
{
public:
    virtual void AudioTaskStatusChange(const int taskId,const dpyAudio::TaskType type, const dpyAudio::AudioTaskStatus& status) = 0;
    virtual ~AudioTaskObserver()
    {
    }
};
 
class IAudioTask
{
private:
    dpyAudio::TaskType mType; 
    dpyAudio::AudioTaskStatus mStatus; 
    dpyAudio::AudioTaskInformation mAudioTaskInformation; 
    int mTaskId;   
    std::vector<AudioTaskObserver*> mObserversList; 
    static int mTaskCounter;
    std::mutex mMutex; 
 
    std::list<dpyAudio::AudioConfig> mConfigurations;
 
    int mVolume = 100;
 
protected:
    virtual void releaseResources();
    
public:
    boost::system::error_code subscribe(AudioTaskObserver* observer);
    boost::system::error_code unsubscribe(AudioTaskObserver* observer);
 
    static void setTaskCounter(int taskCounter);
    static int getTaskCounter();
 
    IAudioTask(dpyAudio::TaskType type, dpyAudio::Port port,std::string audioFilePath, std::list<dpyAudio::AudioConfig> configurations);
    virtual ~IAudioTask();
    void setStatus(dpyAudio::AudioTaskStatus status);
    void asyncSetStatus(dpyAudio::AudioTaskStatus status);
 
    inline dpyAudio::AudioTaskStatus getStatus() const {
        return mStatus;
    }
 
    inline dpyAudio::AudioTaskInformation getAudioTaskInformation() const {
        return mAudioTaskInformation;
    }
 
    inline int getId() const
    {
        return mTaskId;
    }
 
    inline dpyAudio::TaskType getType() const
    {
        return mType;
    }
 
    inline std::list<dpyAudio::AudioConfig> getConfiguration() const {
        return mConfigurations;
    }
 
    inline int getVolume() const {
        return mVolume;
    }
 
};