");
std::string::size_type pos = 0;
std::string::size_type pos2 = 0;
bool last = false;
while (!last) {
std::string req;
if ((pos2 = reqs.find("
");
std::string time = utils::text::source_get_value2(&get, "seenrequesttime=", "&\"");
facebook_user *fbu = new facebook_user();
fbu->real_name = utils::text::source_get_value(&req, 2, "class=\"actor\">", "user_id = utils::text::source_get_value(&get, 2, "id=", "&");
if (fbu->user_id.length() && fbu->real_name.length())
{
HANDLE hContact = AddToContactList(fbu, FACEBOOK_CONTACT_APPROVE, false, fbu->real_name.c_str());
DBWriteContactSettingByte(hContact, m_szModuleName, FACEBOOK_KEY_CONTACT_TYPE, FACEBOOK_CONTACT_APPROVE);
bool seen = false;
DBVARIANT dbv;
if (!DBGetContactSettingString(hContact, m_szModuleName, "RequestTime", &dbv)) {
seen = !strcmp(dbv.pszVal, time.c_str());
DBFreeVariant(&dbv);
}
if (!seen) {
// This is new request
DBWriteContactSettingString(hContact, m_szModuleName, "RequestTime", time.c_str());
//blob is: uin( DWORD ), hContact( HANDLE ), nick( ASCIIZ ), first( ASCIIZ ), last( ASCIIZ ), email( ASCIIZ ), reason( ASCIIZ )
//blob is: 0( DWORD ), hContact( HANDLE ), nick( ASCIIZ ), ""( ASCIIZ ), ""( ASCIIZ ), ""( ASCIIZ ), ""( ASCIIZ )
DBEVENTINFO dbei = {0};
dbei.cbSize = sizeof( DBEVENTINFO );
dbei.szModule = m_szModuleName;
dbei.timestamp = ::time( NULL );
dbei.flags = 0; //DBEF_UTF;
dbei.eventType = EVENTTYPE_AUTHREQUEST;
dbei.cbBlob = (DWORD)(sizeof( DWORD )+ sizeof( HANDLE ) + fbu->real_name.length() + 5);
PBYTE pCurBlob = dbei.pBlob = ( PBYTE ) mir_alloc( dbei.cbBlob );
*(PDWORD)pCurBlob = 0; pCurBlob += sizeof(DWORD); // UID
*(PHANDLE)pCurBlob = hContact; pCurBlob += sizeof(HANDLE); // Contact Handle
strcpy((char*)pCurBlob, fbu->real_name.c_str()); pCurBlob += fbu->real_name.length()+1; // Nickname
*pCurBlob = '\0'; pCurBlob++; // First Name
*pCurBlob = '\0'; pCurBlob++; // Last Name
*pCurBlob = '\0'; pCurBlob++; // E-mail
*pCurBlob = '\0'; // Reason
CallService(MS_DB_EVENT_ADD, (WPARAM)NULL, (LPARAM)&dbei);
LOG(" (New) Friendship request from: %s (%s) [%s]", fbu->real_name.c_str(), fbu->user_id.c_str(), time.c_str());
} else {
LOG(" (Old) Friendship request from: %s (%s) [%s]", fbu->real_name.c_str(), fbu->user_id.c_str(), time.c_str());
}
} else {
LOG(" !!! Wrong friendship request");
LOG(req.c_str());
}
}
facy.handle_success( "friendRequests" );
}
void FacebookProto::ProcessFeeds( void* data )
{
if ( data == NULL )
return;
std::string* resp = (std::string*)data;
if (!isOnline())
goto exit;
CODE_BLOCK_TRY
LOG("***** Starting processing feeds");
std::vector< facebook_newsfeed* > news;
std::string::size_type pos = 0;
UINT limit = 0;
*resp = utils::text::slashu_to_utf8(*resp);
*resp = utils::text::source_get_value(resp, 2, "\"html\":\"", ">\"");
while ( ( pos = resp->find( "
find( "
length();
std::string post = resp->substr( pos, pos2 - pos );
pos += 5;
std::string post_header = utils::text::source_get_value(&post, 4, "
", "<\\/h6>");
std::string post_message = utils::text::source_get_value(&post, 3, "", "<\\/h6>");
std::string post_link = utils::text::source_get_value(&post, 3, "", "<\\/span>");
std::string post_attach = utils::text::source_get_value(&post, 4, "", "
") + 5;
post_message = post_header.substr(pos2, post_header.length() - pos2) + post_message;
post_header = post_header.substr(0, pos2);
// append attachement to message (if any)
post_message += utils::text::trim( post_attach );
facebook_newsfeed* nf = new facebook_newsfeed;
nf->title = utils::text::trim(
utils::text::special_expressions_decode(
utils::text::remove_html( post_header ) ) );
nf->user_id = utils::text::source_get_value( &post_header, 2, "user.php?id=", "\\\"" );
nf->link = utils::text::special_expressions_decode(
utils::text::source_get_value( &post_link, 2, "href=\\\"", "\\\">" ) );
nf->text = utils::text::trim(
utils::text::special_expressions_decode(
utils::text::remove_html(
utils::text::edit_html( post_message ) ) ) );
if ( !nf->title.length() || !nf->text.length() )
{
delete nf;
continue;
}
if (nf->text.length() > 500)
{
nf->text = nf->text.substr(0, 500);
nf->text += "...";
}
news.push_back( nf );
pos++;
limit++;
}
for(std::vector::size_type i=0; ititle.c_str(), news[i]->text.c_str());
TCHAR* szTitle = mir_a2t_cp(news[i]->title.c_str(), CP_UTF8);
TCHAR* szText = mir_a2t_cp(news[i]->text.c_str(), CP_UTF8);
TCHAR* szUrl = mir_a2t_cp(news[i]->link.c_str(), CP_UTF8);
NotifyEvent(szTitle,szText,this->ContactIDToHContact(news[i]->user_id),FACEBOOK_EVENT_NEWSFEED, szUrl);
mir_free(szTitle);
mir_free(szText);
// mir_free(szUrl); // URL is free'd in popup procedure
delete news[i];
}
news.clear();
this->facy.last_feeds_update_ = ::time(NULL);
LOG("***** Feeds processed");
CODE_BLOCK_CATCH
LOG("***** Error processing feeds: %s", e.what());
CODE_BLOCK_END
exit:
delete resp;
}
void FacebookProto::SearchAckThread(void *targ)
{
facy.handle_entry( "searchAckThread" );
int count = 0;
char *arg = mir_utf8encodeT((TCHAR*)targ);
std::string search = utils::url::encode( arg );
std::string ssid;
while (count < 50 && !isOffline())
{
std::string get_data = search + "&s=" + utils::conversion::to_string(&count, UTILS_CONV_UNSIGNED_NUMBER);
if (!ssid.empty())
get_data += "&ssid=" + ssid;
// Get notifications
http::response resp = facy.flap( FACEBOOK_REQUEST_SEARCH, NULL, &get_data );
// Process result data
facy.validate_response(&resp);
if (resp.code == HTTP_CODE_OK)
{
std::string items = utils::text::source_get_value(&resp.data, 3, "", "