diff options
author | George Hazan <ghazan@miranda.im> | 2017-12-28 20:30:32 +0300 |
---|---|---|
committer | George Hazan <ghazan@miranda.im> | 2017-12-28 20:30:32 +0300 |
commit | 8ae09e329384682579d59fc92cd7ed5de37e1351 (patch) | |
tree | b5b4db8ae2f9796d222fcf6324346e86d8cd2dba /protocols/FacebookRM/src/process.cpp | |
parent | 6872a9a9b1f032ede5471a8a03abc76e7c7259d9 (diff) |
Facebook:
- fixes problems with decoding attachments;
- major rework of class structure;
- version bump
Diffstat (limited to 'protocols/FacebookRM/src/process.cpp')
-rw-r--r-- | protocols/FacebookRM/src/process.cpp | 20 |
1 files changed, 8 insertions, 12 deletions
diff --git a/protocols/FacebookRM/src/process.cpp b/protocols/FacebookRM/src/process.cpp index fb02f5c868..eb856d06f3 100644 --- a/protocols/FacebookRM/src/process.cpp +++ b/protocols/FacebookRM/src/process.cpp @@ -62,7 +62,7 @@ void FacebookProto::ProcessFriendList(void*) bool loadAllContacts = getBool(FACEBOOK_KEY_LOAD_ALL_CONTACTS, DEFAULT_LOAD_ALL_CONTACTS); bool pagesAlwaysOnline = getBool(FACEBOOK_KEY_PAGES_ALWAYS_ONLINE, DEFAULT_PAGES_ALWAYS_ONLINE); - facebook_json_parser(this).parse_friends(&resp.data, &friends, loadAllContacts); + ParseFriends(&resp.data, &friends, loadAllContacts); // Check and update old contacts for (MCONTACT hContact = db_find_first(m_szModuleName); hContact; hContact = db_find_next(hContact, m_szModuleName)) { @@ -193,7 +193,7 @@ void FacebookProto::ProcessUnreadMessages(void*) try { std::vector<std::string> threads; - facebook_json_parser(this).parse_unread_threads(&resp.data, &threads); + ParseUnreadThreads(&resp.data, &threads); ForkThread(&FacebookProto::ProcessUnreadMessage, new std::vector<std::string>(threads)); @@ -243,7 +243,7 @@ void FacebookProto::ProcessUnreadMessage(void *pParam) if (resp.code == HTTP_CODE_OK) { try { std::vector<facebook_message> messages; - facebook_json_parser(this).parse_thread_messages(&resp.data, &messages, false); + ParseThreadMessages(&resp.data, &messages, false); ReceiveMessages(messages, true); debugLogA("*** Unread messages processed"); @@ -308,7 +308,7 @@ void FacebookProto::LoadLastMessages(void *pParam) try { std::vector<facebook_message> messages; - facebook_json_parser(this).parse_thread_messages(&resp.data, &messages, false); + ParseThreadMessages(&resp.data, &messages, false); ReceiveMessages(messages, true); debugLogA("*** Thread messages processed"); @@ -365,9 +365,7 @@ void FacebookProto::LoadHistory(void *pParam) int messagesCount = -1; int unreadCount = -1; - facebook_json_parser* p = new facebook_json_parser(this); - if (p->parse_messages_count(&resp.data, &messagesCount, &unreadCount) == EXIT_FAILURE) { - delete p; + if (ParseMessagesCount(&resp.data, &messagesCount, &unreadCount) == EXIT_FAILURE) { facy.handle_error("LoadHistory"); return; } @@ -411,7 +409,7 @@ void FacebookProto::LoadHistory(void *pParam) try { messages.clear(); - p->parse_history(&resp.data, &messages, &firstTimestamp); + ParseHistory(&resp.data, &messages, &firstTimestamp); // Receive messages std::string previousFirstMessageId = firstMessageId; @@ -484,8 +482,6 @@ void FacebookProto::LoadHistory(void *pParam) } } - delete p; - facy.handle_success("LoadHistory"); // Enable marking messages as read for this contact @@ -972,7 +968,7 @@ void FacebookProto::ProcessMessages(void* data) try { std::vector<facebook_message> messages; - facebook_json_parser(this).parse_messages(resp, &messages, &facy.notifications); + ParseMessages(resp, &messages, &facy.notifications); ReceiveMessages(messages); @@ -1031,7 +1027,7 @@ void FacebookProto::ProcessNotifications(void *p) try { size_t numNotifications = facy.notifications.size(); - facebook_json_parser(this).parse_notifications(&resp.data, &facy.notifications); + ParseNotifications(&resp.data, &facy.notifications); if (manuallyTriggered) { numNotifications = facy.notifications.size() - numNotifications; |