NamedPipeExporter.h

#pragma once

#include <string>
#include <Poco/Logger.h>

#include "core/Exporter.h"
#include "util/Loggable.h"

namespace BeeeOn {

class SensorDataFormatter;

class NamedPipeExporter :
        public Exporter,
        public Loggable {
public:
        NamedPipeExporter();
        ~NamedPipeExporter();

        bool ship(const SensorData &data) override;

        void setFilePath(const std::string &path);

        void setFormatter(SensorDataFormatter * formatter);

private:
        int openPipe();

        bool writeAndClose(int fd, const std::string &msg);

        std::string m_pipePath;
        SensorDataFormatter *m_formatter;
};

}