peak_common_pipeline_base.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <peak_common/exceptions/peak_common_exceptions.hpp>
#include <peak_common/pipeline/peak_common_ipipeline.hpp>
 
#include <fstream>
#include <sstream>
#include <string>
 
namespace peak
{
namespace pipeline
{

class PipelineBase : public IPipeline
{
public:
    void ExportSettingsToFile(const std::string& filePath) const override;

    void ImportSettingsFromFile(const std::string& filePath) override;

    PEAK_COMMON_NO_DISCARD peak::common::Any operator<<(const peak::common::Any& input) override;

    PEAK_COMMON_NO_DISCARD peak::common::Any Process(const peak::common::Any& input) const override;
};
 
inline void PipelineBase::ExportSettingsToFile(const std::string& filePath) const
{
    std::ofstream stream;
    stream.exceptions(std::ios::badbit | std::ios::failbit);
 
    try
    {
        stream.open(filePath);
 
        stream << ExportSettingsToString();
    }
    catch (const std::ios_base::failure& e)
    {
        throw peak::common::IOException("Saving settings to the file " + filePath + " failed: " + e.what());
    }
}
 
inline void PipelineBase::ImportSettingsFromFile(const std::string& filePath)
{
    std::ifstream stream;
    stream.exceptions(std::ios::badbit | std::ios::failbit);
 
    try
    {
        stream.open(filePath);
 
        std::stringstream ss;
        ss << stream.rdbuf();
 
        ImportSettingsFromString(ss.str());
    }
    catch (const std::ios_base::failure& e)
    {
        throw peak::common::IOException("Loading settings from the file " + filePath + " failed: " + e.what());
    }
}
 
inline peak::common::Any PipelineBase::operator<<(const peak::common::Any& input)
{
    return Process(input);
}
 
inline peak::common::Any PipelineBase::Process(const peak::common::Any& input) const
{
    auto data = input;
 
    for (const auto& module : GetModules())
    {
        data = module->Process(data);
    }
 
    return data;
}
 
 
} // namespace pipeline 
} // namespace peak