// Blog
//
// Douglas Thrift
//
// $Id$

#include <cxx/standard.hh>

#include <dbi/connection.hpp>
#include <dbi/driver.hpp>
#include <dbi/resultset.hpp>

#include "Blog.hpp"

Blog::Blog(const cse::String &sitemap, const cse::String &base, ext::Queue<Url> &queue, api::ThreadMutex &queueLock, const _R<BlogCommand> &command) : CommandRunner(sitemap, queue, queueLock)
{
	api::Cout << _B("Blog") << ios::NewLine;

	Entries(command->root, /*_S<ios::String>() << base << command->path*/_B("http://www.douglasthrift.net/blog/"));
}

void Blog::Entries(const api::Path &directory, const cse::String &base)
{
	{
		cse::String blog(client.GetProperty(_B("GoogleTron:Blog"), directory.GetPath()));

		if (blog != _B("MovableType"))
			throw ext::NotImplementedException(_S<ios::String>(_B("unknown blog ")) << blog);
	}

	_R<dbi::Driver> driver(dbi::GetDriver(client.GetProperty(_B("GoogleTron:Driver"), directory.GetPath())));
	_R<dbi::Connection> connection(driver->Connect(client.GetProperty(_B("GoogleTron:Host"), directory.GetPath()), client.GetProperty(_B("GoogleTron:User"), directory.GetPath()), GetPassword(directory), client.GetProperty(_B("GoogleTron:Database"), directory.GetPath())));
	int32_t id;

	{
		_R<dbi::ResultSet> set(connection->Parse(_B("SELECT blog_id FROM mt_blog WHERE blog_site_url = ?"))->Execute(base));

		if (set->MoveNext())
			id = set->Get<int32_t>(0);
		else
			throw ext::StringException(_S<ios::String>("no blog ") << base);
	}
}