ViewVC Help

View File | Revision Log | Show Annotations | Download File | View Changeset | Root Listing

root/zoe/trunk/Publisher.cpp

Comparing trunk/Publisher.cpp (file contents):
Revision 23 by douglas, 2004-07-17T01:08:00-07:00 vs.
Revision 31 by douglas, 2004-07-20T00:11:56-07:00

#	Line 5 | Line 5
5		// $Id$
6
7		#include "Publisher.hpp"
8	+	#include "Rss.hpp"
9
10		Publisher::Publisher(const std::set<Buddy>& buddies, const Database& database,
11		bool start) : buddies(buddies), database(database), start(start)
#	Line 20 | Line 21 | int Publisher::publish()
21		cerr << bright << green << "Publisher::publish()\n" << reset;
22
23		// publish
24	+
25	+	while (true)
26	+	{
27	+	Stamp start, now;
28	+
29	+	update();
30	+
31	+	do
32	+	{
33	+	sleep(Minute(1));
34	+
35	+	now = Stamp();
36	+
37	+	cerr << bright << magenta << ext::String(now) << white << '<'
38	+	<< cyan << ext::String(start + Hour(1)) << '\n' << reset;
39	+	}
40	+	while (now < start + Hour(1));
41	+	}
42	+	}
43	+
44	+	void Publisher::update()
45	+	{
46	+	cerr << bright << yellow << "Publisher::update()\n" << reset;
47	+
48	+	Stamp stamp;
49	+	ext::Handle<dbi::Connection> db(dbi::Connect(database.driver, database.host,
50	+	database.user, database.password, database.db));
51	+
52	+	db->Execute("DELETE FROM messages WHERE stamp<'" + (stamp - Day(30)) + "'");
53	+
54	+	for (std::set<Buddy>::const_iterator buddy(buddies.begin()); buddy !=
55	+	buddies.end(); ++buddy)
56	+	{
57	+	ext::Handle<dbi::ResultSet> messages(db->Execute(ext::String("SELECT s")
58	+	+ "tamp, message FROM messages WHERE id='" +
59	+	lexical_cast<ext::String>(buddy->getId()) + "'"));
60	+	std::vector<AwayMessage> messages_;
61	+
62	+	while (messages->MoveNext())
63	+	messages_.push_back(AwayMessage(messages->GetString("message"),
64	+	messages->GetString("stamp")));
65	+
66	+	Rss rss(*buddy, messages_, stamp);
67	+	}
68		}

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines