File_Receiver.h

#pragma once

#include <Base_Receiver.h>
#include <Base_Configurator.h>
#include <fstream>

#ifndef RAW_FILES_PATH
#define RAW_FILES_PATH std::string(std::getenv("HOME")).append("/BIAS/config/RawTestFiles")
#endif

namespace inaf::oasbo::Receivers {

class FileReceiver: public BaseReceiver {
protected:
	FileReceiver(std::string source, int rate);
	FileReceiver(std::string source);
	FileReceiver();
	std::ifstream *ifile = nullptr;
	ssize_t filesize = 0;
	std::vector<std::string> filesToProcess;
	size_t filesCount = 0;
	int openNextFile();
	void resetPacket(PacketLib::BasePacket &pack, int bytes);
	std::string resolveEnvVar(std::string path);

public:
	int rate;

	~FileReceiver();

	std::string getHost() override;
	void setHost(std::string host) override;

	int connectToClient() override;
	int closeConnectionToClient() override;
	bool isConnectedToClient() const override;
	int receiveFromClient(PacketLib::BasePacket&) override;

	friend class FileReceiverBuilder;
};
class FileReceiverBuilder {
protected:
	FileReceiver *rcv;
	std::string sourceFile;
public:
	std::string config_target { "filereceiver" };
	std::string source_key { "source" };
	std::string rate_key { "rate" };

	FileReceiverBuilder();
	~FileReceiverBuilder();
	void reset();
	FileReceiverBuilder* configFrom(Configurators::BaseConfigurator &conf);
	FileReceiverBuilder* setSource(std::string source);
	FileReceiverBuilder* setRate(int rate);
	FileReceiver* getReceiver();
};
}