POCO Fanatic

#include <Poco/URI.h>
#include <Poco/Format.h>
#include <Poco/URIStreamOpener.h>
#include <Poco/Net/HTTPStreamFactory.h>
#include <Poco/Net/FTPStreamFactory.h>
#include <Poco/StreamCopier.h>
#include <Poco/TemporaryFile.h>
#include <Poco/Path.h>
#include <Poco/Thread.h>
 
#include <sstream>
#include <fstream>
 
#include "ScopedLogMessage.h"
#include "PrepareConsoleLogger.h"
 
void TestURIStreamOpener(ScopedLogMessage& msg, const Poco::URI& uri)
{
	msg.Message(Poco::format(" --- %s ---", uri.toString()));
	if("ftp" == uri.getScheme())
	{
		std::string password;
		std::string user(uri.getUserInfo());
		if("" == user)
		{
			user = "anonymous";
			password = Poco::Net::FTPStreamFactory::getAnonymousPassword();
		}
		else
		{
			Poco::Net::FTPPasswordProvider* pProvider = Poco::Net::FTPStreamFactory::getPasswordProvider();
			if(NULL != pProvider)
			{
				password = pProvider->password(user, uri.getAuthority());
			}
		}
		msg.Message(Poco::format("     (user=%s, password=%s)", user, password));
	}
	try
	{
		std::auto_ptr<std::istream> pStr(Poco::URIStreamOpener::defaultOpener().open(uri));
		std::stringstream ss;
		Poco::StreamCopier::copyStream(*pStr.get(), ss);
 
		Poco::Thread* p_thread = Poco::Thread::current();
		int threadID = (0 == p_thread) ? 0:p_thread->id();
 
		msg.Message(Poco::format(" <start>\n%s[%d]  <end>", ss.str(), threadID));
	}
	catch(Poco::Exception& exc)
	{
		msg.Message(Poco::format("    %s", exc.displayText()));
	}
}
 
int main(int /*argc*/, char** /*argv*/)
{
	PrepareConsoleLogger logger(Poco::Logger::ROOT, Poco::Message::PRIO_INFORMATION);
 
	ScopedLogMessage msg("URIStreamOpenerTest ", "start", "end");
 
	Poco::Net::HTTPStreamFactory::registerFactory();
	Poco::Net::FTPStreamFactory::registerFactory();
 
	// HTTP
	Poco::URI uriHTTP("http://poco.roundsquare.net/downloads/test.txt");
	TestURIStreamOpener(msg, uriHTTP);
 
	// FTP
	Poco::URI uriFTP("ftp://ftp.iij.ad.jp/pub/linux/debian/dists/README");
	TestURIStreamOpener(msg, uriFTP);
 
	// file
	Poco::TemporaryFile tempFile;
	std::string path = tempFile.path();
	std::ofstream ostr(path.c_str());
	ostr << "Hello, world!" << std::endl;
	ostr.close();
	Poco::URI uriFile;
	uriFile.setScheme("file");
	uriFile.setPath(Poco::Path(path).toString(Poco::Path::PATH_UNIX));
	TestURIStreamOpener(msg, uriFile);
 
	return 0;
}

[0] URIStreamOpenerTest start
[0]  --- http://poco.roundsquare.net/downloads/test.txt ---
[0]  <start>
---  This is a sample text file for HTTPClientSessionTest  ---
[0]  <end>
[0]  --- ftp://ftp.iij.ad.jp/pub/linux/debian/dists/README ---
[0]      (user=anonymous, password=poco@localhost)
[0]  <start>
This directory, dists, is the canonical way to access the distributions.
Each distribution can be accessed by name or state from here.
 
oldstable, or etch  - the released Debian 4.0r9.
stable, or lenny    - the released Debian 5.0.4.
oldstable-proposed-updates  - possible updates to Debian 4.0.  See the README there.
proposed-updates    - possible updates to Debian 5.0.  See the README there.
testing, or squeeze - the development version of the next release.
unstable, or sid    - untested candidate packages for future releases.
[0]  <end>
[0]  --- file:///var/folders/iR/iRcZrcWkGCe6fDFVNkPVjE+++TI/-Tmp-/tmp3929aaaaaa ---
[0]  <start>
Hello, world!
[0]  <end>
[0] URIStreamOpenerTest end