--- trunk/Publisher.cpp	2004/07/17 06:37:41	21
+++ trunk/Publisher.cpp	2004/07/20 07:40:43	32
@@ -5,6 +5,7 @@
 // $Id$
 
 #include "Publisher.hpp"
+#include "Rss.hpp"
 
 Publisher::Publisher(const std::set<Buddy>& buddies, const Database& database,
 	bool start) : buddies(buddies), database(database), start(start)
@@ -17,7 +18,48 @@ Publisher::Publisher(const std::set<Budd
 
 int Publisher::publish()
 {
-	cerr << "Publisher::publish()\n";
+	cerr << bright << green << "Publisher::publish()\n" << reset;
 
 	// publish
+
+	while (true)
+	{
+		Stamp start, now;
+
+		update();
+
+		do
+		{
+			sleep(Minute(1));
+
+			now = Stamp();
+		}
+		while (now < start + Hour(1));
+	}
+}
+
+void Publisher::update()
+{
+	cerr << bright << yellow << "Publisher::update()\n" << reset;
+
+	Stamp stamp;
+	ext::Handle<dbi::Connection> db(dbi::Connect(database.driver, database.host,
+		database.user, database.password, database.db));
+
+	db->Execute("DELETE FROM messages WHERE stamp<'" + (stamp - Day(30)) + "'");
+
+	for (std::set<Buddy>::const_iterator buddy(buddies.begin()); buddy !=
+		buddies.end(); ++buddy)
+	{
+		ext::Handle<dbi::ResultSet> messages(db->Execute(ext::String("SELECT s")
+			+ "tamp, message FROM messages WHERE id='" +
+			lexical_cast<ext::String>(buddy->getId()) + "'"));
+		std::vector<AwayMessage> messages_;
+
+		while (messages->MoveNext())
+			messages_.push_back(AwayMessage(messages->GetString("message"),
+			messages->GetString("stamp")));
+
+		Rss rss(*buddy, messages_, stamp);
+	}
 }