fileRepository.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_FILEREPOSITORY_HPP
#define RTCTK_COMPONENTFRAMEWORK_FILEREPOSITORY_HPP
 
#include <exception>
#include <boost/filesystem.hpp>
#include <mal/utility/Uri.hpp>
#include <rtctk/componentFramework/repositoryIf.hpp>
 
namespace rtctk::componentFramework {
 
class InvalidArgumentException : public std::invalid_argument {
public:
    explicit InvalidArgumentException(const std::string& message);
};
 
class PathMissingException : public std::runtime_error {
public:
    explicit PathMissingException(const std::string& path);
};
 
class FileFormatError : public std::runtime_error {
public:
    explicit FileFormatError(const boost::filesystem::path& filepath);
};
 
class InvalidUriInFileError : public std::runtime_error {
public:
    explicit InvalidUriInFileError(const boost::filesystem::path& filepath, const std::string& uri);
};
 
class DirCreationError : public std::runtime_error {
public:
    explicit DirCreationError(const boost::filesystem::path& path);
};
 
class FileRepository : virtual public RepositoryIf {
public:
    FileRepository() = delete;
    FileRepository(const FileRepository&) = delete;
    FileRepository& operator=(const FileRepository&) = delete;
    FileRepository(FileRepository&&) = default;
    FileRepository& operator=(FileRepository&&) = default;
    explicit FileRepository(const ::elt::mal::Uri& datauri, const int dirdepth);
    virtual ~FileRepository();
    using RepositoryIf::CreateDataPoint;
    void CreateDataPoint(const DataPointPath& path, const std::string& type) override;
    using RepositoryIf::DeleteDataPoint;
    void DeleteDataPoint(const DataPointPath& path) override;
    using RepositoryIf::GetDataPointType;
    std::string GetDataPointType(const DataPointPath& path) const override;
    using RepositoryIf::GetDataPointSize;
    size_t GetDataPointSize(const DataPointPath& path) const override;
    using RepositoryIf::DataPointExists;
    bool DataPointExists(const DataPointPath& path) const override;
    using RepositoryIf::GetChildren;
    std::pair<StringList, StringList> GetChildren(const DataPointPath& path) const override;
    Response SendReadRequest(const Request& request) const override;
    Response SendWriteRequest(const Request& request) override;
 
    inline size_t get_fits_write_threshold() const {
        return m_fits_write_threshold;
    }
 
    inline void set_fits_write_threshold(size_t value) {
        m_fits_write_threshold = value;
    }
 
private:
    boost::filesystem::path m_datapath;
    std::string m_defaultfile;
    int m_dirdepth;
    size_t m_fits_write_threshold;
};
 
} // namespace rtctk::componentFramework
 
#endif // RTCTK_COMPONENTFRAMEWORK_FILEREPOSITORY_HPP