PoolManager.h

#pragma once

#include <boost/lockfree/queue.hpp>
#include <iostream>
#include <json/json.h>
#include <libdevcore/Worker.h>
#include <libethcore/Farm.h>
#include <libethcore/Miner.h>

#include "PoolClient.h"

using namespace std;

namespace dev
{
	namespace eth
	{
		class PoolManager
		{
		public:
			PoolManager(boost::asio::io_service & io_service, PoolClient * client, Farm &farm, MinerType const & minerType, unsigned maxTries, unsigned failovertimeout);
			void addConnection(URI &conn);
			void clearConnections();
			Json::Value getConnectionsJson();
			void setActiveConnection(unsigned int idx);
			void removeConnection(unsigned int idx);
			void start();
			void stop();
			bool isConnected() { return p_client->isConnected(); };
			bool isRunning() { return m_running; };

		private:
			unsigned m_hashrateReportingTime = 60;
			unsigned m_hashrateReportingTimePassed = 0;
			unsigned m_failoverTimeout = 0;						// After this amount of time in minutes of mining on a failover pool return to "primary"

			void check_failover_timeout(const boost::system::error_code& ec);

			std::atomic<bool> m_running = { false };
			void workLoop();

			unsigned m_connectionAttempt = 0;
			unsigned m_maxConnectionAttempts = 0;
			unsigned m_activeConnectionIdx = 0;

			std::vector <URI> m_connections;
			std::thread m_workThread;

			h256 m_lastBoundary = h256();
			std::list<h256> m_headers;

			boost::asio::io_service::strand m_io_strand;
			boost::asio::deadline_timer m_failovertimer;
			PoolClient *p_client;
			Farm &m_farm;
			MinerType m_minerType;
			boost::lockfree::queue<std::chrono::steady_clock::time_point> m_submit_times;

			int m_lastEpoch = 0;

		};
	}
}