#include <Core/Core.h>
#include <Core/SSH/SSH.h>

using namespace Upp;

constexpr const char *path = "/pub/example/";
constexpr const int   MAXDOWNLOAD = 4;

CONSOLE_APP_MAIN
{
	StdLogSetup(LOG_COUT|LOG_FILE);
	// Ssh::Trace();
	
	SshSession session;
	if(!session.Timeout(10000).Compression().Connect("demo:password@test.rebex.net:22")) {
		RLOG(session.GetErrorDesc());
		return;
	}
	
	SFtp browser(session);
	SFtp::DirList ls;
	
	// Get a remote dir listing.
	if(!browser.ListDir(path, ls)) {
		RLOG(browser.GetErrorDesc());
		return;
	}

	// Filter the dir list.
	auto files =  FilterRange(ls, [](const SFtp::DirEntry& e) { return e.IsFile() && e.GetSize() <= 65536; });
	
	// Download the files, using worker threads in parallel.
	CoFor(min(files.GetCount(), MAXDOWNLOAD), [&](int i){
		const SFtp::DirEntry& e = files[i];
		String fpath = AppendFileName(path, e.GetName());
		RLOG("Downloading " << fpath);
		SFtp sftp(session);
		String file = sftp.LoadFile(fpath);
		if(sftp.IsError())
			RLOG(Format("Worker #%d: %s", sftp.GetId(), sftp.GetErrorDesc()));
		else
			RLOG("File " << e.GetName() << " is successfully downloaded.");
	});
}