31 |
|
|
32 |
|
int Collector::collect() |
33 |
|
{ |
34 |
< |
cerr << "Collector::collect()\n"; |
34 |
> |
cerr << bright << green << "Collector::collect()\n" << reset; |
35 |
|
|
36 |
|
net::Oscar::Session session; |
37 |
|
net::Oscar::AuthTool auth(session); |
84 |
|
|
85 |
|
void Collector::status(const net::Oscar::UserInfo& user) |
86 |
|
{ |
87 |
< |
Stamp stamp; |
88 |
< |
Buddy buddy(user); |
87 |
> |
Buddy buddy(*buddies.find(user)); |
88 |
> |
AwayMessage message(buddy, *info); |
89 |
|
|
90 |
< |
cerr << red << ext::String(stamp) << ' ' << blue << ext::String(buddy) |
91 |
< |
<< '\n' << reset; |
90 |
> |
if (!ext::String(message).IsEmpty()) // XXX |
91 |
> |
{ |
92 |
> |
ext::Handle<dbi::Connection> db(dbi::Connect(database.driver, |
93 |
> |
database.host, database.user, database.password, database.db)); |
94 |
> |
|
95 |
> |
db->Execute("INSERT INTO messages (stamp, message, id) VALUES ('" + |
96 |
> |
message.getStamp() + "', '" + db->Escape(message) + "', '" + |
97 |
> |
buddy.getId() + "')"); |
98 |
> |
} |
99 |
|
} |
100 |
|
|
101 |
|
void Collector::receive(const ext::String& buddy, const ext::String& message) |