AbstractPipe.h

#pragma once
 
#include <memory>
#include <vector>
#include <string>
 
namespace UCILoader {
 
    class PipeClosedException : public std::exception {
    public:
        const char* what() const noexcept override {
            return "Couldn't finish I/O operation because the underlying pipe was closed";
        }
    };
 
    class AbstractPipeReader {
    public:
        virtual ~AbstractPipeReader() noexcept {};
 
        virtual size_t poll(char* buffer, size_t buffer_size) = 0;
 
        virtual bool isOpen() const = 0;
    };
    
    class AbstractPipeWriter {
    public:
        virtual ~AbstractPipeWriter() noexcept {};
 
        virtual void write(const char* buffer, size_t buffer_size) = 0;
 
        virtual bool isOpen() const = 0;
    };
    
    class PipeScanner {
        static const size_t _InternalBufferSize = 256;
        const size_t _PollingIntervalMilliseconds = 2;
        char internalBuffer[_InternalBufferSize];
        size_t currentBufferSize = 0;
        size_t currentBufferPosition = 0;
 
        std::shared_ptr<AbstractPipeReader> source;
 
        bool scanInternalBuffer(std::string& result);
        
        void pollPipe();
 
    public:
 
        PipeScanner(std::shared_ptr<AbstractPipeReader> source) : source(source) {};
 
        std::string getLine();
 
    };
}