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 51 by douglas, 2004-08-23T15:03:41-07:00

#	Line 5 | Line 5
5		// $Id$
6
7		#include "Publisher.hpp"
8	+	#include "Rss.hpp"
9	+	#include "Atom.hpp"
10
11	<	Publisher::Publisher(const std::set<Buddy>& buddies, const Database& database,
12	<	bool start) : buddies(buddies), database(database), start(start)
11	>	Publisher::Publisher(const std::set<Buddy>& buddies, const Database& database, bool start) : buddies(buddies),
12	>	database(database), start(start)
13		{
14	<	if (start)
13	<	{
14	<	publisher.Spawn(etl::Bind<0>(&Publisher::publish, this));
15	<	}
14	>	if (start) publish();
15		}
16
17	<	int Publisher::publish()
17	>	void Publisher::publish()
18		{
19	<	cerr << bright << green << "Publisher::publish()\n" << reset;
19	>	cerr << bright << yellow << "Started updating feeds at " << Stamp()
20	>	<< ".\n" << reset;
21	>
22	>	Stamp stamp;
23	>	ext::Handle<dbi::Connection> db(dbi::Connect(database.driver, database.host,
24	>	database.user, database.password, database.db));
25	>
26	>	db->Execute("DELETE FROM messages WHERE stamp<'"
27	>	+ ext::String(stamp - Day(30)) + "'");
28	>
29	>	for (std::set<Buddy>::const_iterator buddy(buddies.begin());
30	>	buddy != buddies.end(); ++buddy)
31	>	{
32	>	ext::Handle<dbi::ResultSet> messages(db->Execute("SELECT stamp, message"
33	>	" FROM messages WHERE id='"
34	>	+ lexical_cast<ext::String>(buddy->getId()) + "'"));
35	>	std::set<AwayMessage, std::greater<AwayMessage> > messages_;
36	>
37	>	while (messages->MoveNext())
38	>	messages_.insert(AwayMessage(messages->GetString("message"),
39	>	messages->GetString("stamp")));
40	>
41	>	ext::String display(buddy->getDisplay(database));
42	>	Rss rss(*buddy, display, messages_.begin(), messages_.end(), stamp);
43	>	Atom atom(*buddy, display, messages_.begin(), messages_.end(), stamp);
44	>
45	>	cerr << bright << yellow << "Updated feeds for " << blue << *buddy
46	>	<< yellow << ".\n" << reset;
47	>	}
48
49	<	// publish
49	>	cerr << bright << yellow << "Finished updating feeds at " << Stamp()
50	>	<< ".\n" << reset;
51		}

Diff Legend

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