filechannel.hpp

Go to the documentation of this file.

#pragma once
#include "channel.hpp"
#include <fstream>

namespace fileChannel {

  class FileChannel: public channeling::Channel {
    std::fstream _file;                             
    int openPipe(const std::string& filename);

    std::future<void> activate() override;
    const messaging::message_ptr parse(const char* line) const override;
    static const channeling::ChannelCreatorImpl<FileChannel> creator;
  public:
    explicit FileChannel(Hub::Hub* hub, const std::string& config);
    ~FileChannel();

    std::string type() const override { return "file"; };

  protected:
    void incoming(const messaging::message_ptr&& msg) override;
  };
  const channeling::ChannelCreatorImpl<FileChannel> FileChannel::creator("file");
}