// Syncify
//
// Douglas Thrift
//
// $Id$

#ifndef _Syncify_hpp_
#define _Syncify_hpp_

#include <menes/platform.hpp>

#ifdef MENES_PRAGMA_ONCE
#pragma once
#endif

#include <menes-api/console.hpp>
#include <menes-api/files.hpp>
#include <menes-api/locks.hpp>
#include <menes-api/path.hpp>
#include <menes-api/threads.hpp>
#include <menes-etl/fnbind.hpp>
#include <menes-ext/scopes.hpp>
#include <menes-ext/stack.hpp>
#include <menes-ext/string.hpp>
#include <menes-ext/threadset.hpp>
#include <menes-ios/helpers.hpp>

#include <queue>
#include <utility>

#include "Matcher/Matcher.hpp"

#include "Error.hpp"

struct Syncify
{
	Syncify(const ext::String& local, const ext::String& remote, const ext::String& pattern);
	~Syncify();
	struct Transfer
	{
		ext::String local, remote;
		Transfer() {}
		Transfer(const ext::String& local, const ext::String& remote) : local(local), remote(remote) {}
	};
	static ext::String program;
	static bool debug;
	Matcher pattern;
	std::queue<Transfer> transfers;
	api::ThreadMutex transfersLock;
	bool transfering;
	ext::ThreadPool<> transferers;
	void syncify(const api::Path& local, const ext::String& remote);
	int transfer();
};

#endif//_Syncify_hpp_