diff options
author | Robert Pösel <robyer@seznam.cz> | 2014-07-06 09:00:14 +0000 |
---|---|---|
committer | Robert Pösel <robyer@seznam.cz> | 2014-07-06 09:00:14 +0000 |
commit | 455353fb70882fb07e41b096ecde60a38ca265a3 (patch) | |
tree | 2d5eabdbd14d4e3cba1484be92c68f58fd3fa738 | |
parent | 95d43413eeef2a573d8e317088c8a0e108a3c3f7 (diff) |
Facebook: Delete "readers" map on logout
git-svn-id: http://svn.miranda-ng.org/main/trunk@9699 1316c22d-e87f-b044-9b9b-93d7a3e3ba9c
-rw-r--r-- | protocols/FacebookRM/src/connection.cpp | 451 |
1 files changed, 226 insertions, 225 deletions
diff --git a/protocols/FacebookRM/src/connection.cpp b/protocols/FacebookRM/src/connection.cpp index ecaf18c2a1..02699bc1e0 100644 --- a/protocols/FacebookRM/src/connection.cpp +++ b/protocols/FacebookRM/src/connection.cpp @@ -1,225 +1,226 @@ -/*
-
-Facebook plugin for Miranda Instant Messenger
-_____________________________________________
-
-Copyright © 2009-11 Michal Zelinka, 2011-13 Robert Pösel
-
-This program is free software: you can redistribute it and/or modify
-it under the terms of the GNU General Public License as published by
-the Free Software Foundation, either version 2 of the License, or
-(at your option) any later version.
-
-This program is distributed in the hope that it will be useful,
-but WITHOUT ANY WARRANTY; without even the implied warranty of
-MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-GNU General Public License for more details.
-
-You should have received a copy of the GNU General Public License
-along with this program. If not, see <http://www.gnu.org/licenses/>.
-
-*/
-
-#include "common.h"
-
-void FacebookProto::ChangeStatus(void*)
-{
- ScopedLock s(signon_lock_);
- ScopedLock b(facy.buddies_lock_);
-
- int new_status = m_iDesiredStatus;
- int old_status = m_iStatus;
-
- if (new_status == ID_STATUS_OFFLINE)
- { // Logout
- debugLogA("##### Beginning SignOff process");
-
- m_iStatus = facy.self_.status_id = ID_STATUS_OFFLINE;
- SetEvent(update_loop_lock_);
- Netlib_Shutdown(facy.hMsgCon);
-
- OnLeaveChat(NULL, NULL);
- SetAllContactStatuses(ID_STATUS_OFFLINE);
- ToggleStatusMenuItems(false);
- delSetting("LogonTS");
-
- ProtoBroadcastAck(0, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)old_status, m_iStatus);
-
- if (getByte(FACEBOOK_KEY_DISCONNECT_CHAT, DEFAULT_DISCONNECT_CHAT))
- facy.chat_state(false);
-
- facy.logout();
-
- facy.clear_cookies();
- facy.clear_notifications();
- facy.buddies.clear();
- facy.messages_ignore.clear();
- facy.pages.clear();
- facy.typers.clear();
-
- if (facy.hMsgCon)
- Netlib_CloseHandle(facy.hMsgCon);
- facy.hMsgCon = NULL;
-
- debugLogA("##### SignOff complete");
-
- return;
- }
- else if (old_status == ID_STATUS_OFFLINE)
- { // Login
- SYSTEMTIME t;
- GetLocalTime(&t);
- debugLogA("[%d.%d.%d] Using Facebook Protocol RM %s", t.wDay, t.wMonth, t.wYear, __VERSION_STRING_DOTS);
-
- debugLogA("***** Beginning SignOn process");
-
- m_iStatus = facy.self_.status_id = ID_STATUS_CONNECTING;
- ProtoBroadcastAck(0, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)old_status, m_iStatus);
-
- ResetEvent(update_loop_lock_);
-
- if (NegotiateConnection() && facy.home() && facy.reconnect())
- {
- // Load all friends
- ProcessFriendList(NULL);
-
- // Process friendship requests
- ForkThread(&FacebookProto::ProcessFriendRequests, NULL);
-
- // Get unread messages
- ForkThread(&FacebookProto::ProcessUnreadMessages, NULL);
-
- // Get notifications
- ForkThread(&FacebookProto::ProcessNotifications, NULL);
-
- // Load pages for post status dialog
- ForkThread(&FacebookProto::ProcessPages, NULL);
-
- setDword("LogonTS", (DWORD)time(NULL));
- ForkThread(&FacebookProto::UpdateLoop, NULL);
- ForkThread(&FacebookProto::MessageLoop, NULL);
-
- if (getByte(FACEBOOK_KEY_SET_MIRANDA_STATUS, DEFAULT_SET_MIRANDA_STATUS))
- ForkThread(&FacebookProto::SetAwayMsgWorker, NULL);
- }
- else {
- ProtoBroadcastAck(0, ACKTYPE_STATUS, ACKRESULT_FAILED, (HANDLE)old_status, m_iStatus);
-
- if (facy.hFcbCon)
- Netlib_CloseHandle(facy.hFcbCon);
- facy.hFcbCon = NULL;
-
- facy.clear_cookies();
-
- // Set to offline
- m_iStatus = m_iDesiredStatus = facy.self_.status_id = ID_STATUS_OFFLINE;
- ProtoBroadcastAck(0, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)old_status, m_iStatus);
-
- debugLogA("***** SignOn failed");
-
- return;
- }
-
- ToggleStatusMenuItems(true);
- debugLogA("***** SignOn complete");
- }
-
- facy.chat_state(m_iDesiredStatus != ID_STATUS_INVISIBLE);
-
- ForkThread(&FacebookProto::ProcessBuddyList, NULL);
-
- m_iStatus = facy.self_.status_id = m_iDesiredStatus;
- ProtoBroadcastAck(0, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)old_status, m_iStatus);
-
- debugLogA("***** ChangeStatus complete");
-}
-
-/** Return true on success, false on error. */
-bool FacebookProto::NegotiateConnection()
-{
- debugLogA("***** Negotiating connection with Facebook");
-
- DBVARIANT dbv = {0};
-
- ptrA username( getStringA(FACEBOOK_KEY_LOGIN));
- if (!username || !strlen(username)) {
- NotifyEvent(m_tszUserName,TranslateT("Please enter a username."),NULL,FACEBOOK_EVENT_CLIENT);
- return false;
- }
-
- ptrA password( getStringA(FACEBOOK_KEY_PASS));
- if (!password || !*password) {
- NotifyEvent(m_tszUserName,TranslateT("Please enter a password."),NULL,FACEBOOK_EVENT_CLIENT);
- return false;
- }
-
- password = mir_utf8encode(password);
-
- // Refresh last time of feeds update
- facy.last_feeds_update_ = ::time(NULL);
-
- // Get info about secured connection
- facy.https_ = getByte(FACEBOOK_KEY_FORCE_HTTPS, DEFAULT_FORCE_HTTPS) != 0;
-
- // Generate random clientid for this connection
- facy.chat_clientid_ = utils::text::rand_string(8, "0123456789abcdef");
-
- // Create default group for new contacts
- ptrT groupName( getTStringA(FACEBOOK_KEY_DEF_GROUP));
- if (groupName != NULL)
- Clist_CreateGroup(0, groupName);
-
- return facy.login(username, password);
-}
-
-void FacebookProto::UpdateLoop(void *)
-{
- time_t tim = ::time(NULL);
- debugLogA(">>>>> Entering Facebook::UpdateLoop[%d]", tim);
-
- for (int i = -1; !isOffline(); i = ++i % 50)
- {
- if (i != -1) {
- ProcessBuddyList(NULL);
-
- if (getByte(FACEBOOK_KEY_EVENT_FEEDS_ENABLE, DEFAULT_EVENT_FEEDS_ENABLE))
- ProcessFeeds(NULL);
- }
-
- if (i == 49)
- ProcessFriendRequests(NULL);
-
- debugLogA("***** FacebookProto::UpdateLoop[%d] going to sleep...", tim);
- if (WaitForSingleObjectEx(update_loop_lock_, GetPollRate() * 1000, true) != WAIT_TIMEOUT)
- break;
- debugLogA("***** FacebookProto::UpdateLoop[%d] waking up...", tim);
- }
-
- ResetEvent(update_loop_lock_);
- debugLogA("<<<<< Exiting FacebookProto::UpdateLoop[%d]", tim);
-}
-
-void FacebookProto::MessageLoop(void *)
-{
- time_t tim = ::time(NULL);
- debugLogA(">>>>> Entering Facebook::MessageLoop[%d]", tim);
-
- while (facy.channel())
- {
- if (isOffline())
- break;
- debugLogA("***** FacebookProto::MessageLoop[%d] refreshing...", tim);
- }
-
- debugLogA("<<<<< Exiting FacebookProto::MessageLoop[%d]", tim);
-}
-
-BYTE FacebookProto::GetPollRate()
-{
- BYTE poll_rate = getByte(FACEBOOK_KEY_POLL_RATE, FACEBOOK_DEFAULT_POLL_RATE);
-
- return (
- (poll_rate >= FACEBOOK_MINIMAL_POLL_RATE &&
- poll_rate <= FACEBOOK_MAXIMAL_POLL_RATE)
- ? poll_rate : FACEBOOK_DEFAULT_POLL_RATE);
-}
+/* + +Facebook plugin for Miranda Instant Messenger +_____________________________________________ + +Copyright � 2009-11 Michal Zelinka, 2011-13 Robert P�sel + +This program is free software: you can redistribute it and/or modify +it under the terms of the GNU General Public License as published by +the Free Software Foundation, either version 2 of the License, or +(at your option) any later version. + +This program is distributed in the hope that it will be useful, +but WITHOUT ANY WARRANTY; without even the implied warranty of +MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +GNU General Public License for more details. + +You should have received a copy of the GNU General Public License +along with this program. If not, see <http://www.gnu.org/licenses/>. + +*/ + +#include "common.h" + +void FacebookProto::ChangeStatus(void*) +{ + ScopedLock s(signon_lock_); + ScopedLock b(facy.buddies_lock_); + + int new_status = m_iDesiredStatus; + int old_status = m_iStatus; + + if (new_status == ID_STATUS_OFFLINE) + { // Logout + debugLogA("##### Beginning SignOff process"); + + m_iStatus = facy.self_.status_id = ID_STATUS_OFFLINE; + SetEvent(update_loop_lock_); + Netlib_Shutdown(facy.hMsgCon); + + OnLeaveChat(NULL, NULL); + SetAllContactStatuses(ID_STATUS_OFFLINE); + ToggleStatusMenuItems(false); + delSetting("LogonTS"); + + ProtoBroadcastAck(0, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)old_status, m_iStatus); + + if (getByte(FACEBOOK_KEY_DISCONNECT_CHAT, DEFAULT_DISCONNECT_CHAT)) + facy.chat_state(false); + + facy.logout(); + + facy.clear_cookies(); + facy.clear_notifications(); + facy.buddies.clear(); + facy.messages_ignore.clear(); + facy.pages.clear(); + facy.typers.clear(); + facy.readers.clear(); + + if (facy.hMsgCon) + Netlib_CloseHandle(facy.hMsgCon); + facy.hMsgCon = NULL; + + debugLogA("##### SignOff complete"); + + return; + } + else if (old_status == ID_STATUS_OFFLINE) + { // Login + SYSTEMTIME t; + GetLocalTime(&t); + debugLogA("[%d.%d.%d] Using Facebook Protocol RM %s", t.wDay, t.wMonth, t.wYear, __VERSION_STRING_DOTS); + + debugLogA("***** Beginning SignOn process"); + + m_iStatus = facy.self_.status_id = ID_STATUS_CONNECTING; + ProtoBroadcastAck(0, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)old_status, m_iStatus); + + ResetEvent(update_loop_lock_); + + if (NegotiateConnection() && facy.home() && facy.reconnect()) + { + // Load all friends + ProcessFriendList(NULL); + + // Process friendship requests + ForkThread(&FacebookProto::ProcessFriendRequests, NULL); + + // Get unread messages + ForkThread(&FacebookProto::ProcessUnreadMessages, NULL); + + // Get notifications + ForkThread(&FacebookProto::ProcessNotifications, NULL); + + // Load pages for post status dialog + ForkThread(&FacebookProto::ProcessPages, NULL); + + setDword("LogonTS", (DWORD)time(NULL)); + ForkThread(&FacebookProto::UpdateLoop, NULL); + ForkThread(&FacebookProto::MessageLoop, NULL); + + if (getByte(FACEBOOK_KEY_SET_MIRANDA_STATUS, DEFAULT_SET_MIRANDA_STATUS)) + ForkThread(&FacebookProto::SetAwayMsgWorker, NULL); + } + else { + ProtoBroadcastAck(0, ACKTYPE_STATUS, ACKRESULT_FAILED, (HANDLE)old_status, m_iStatus); + + if (facy.hFcbCon) + Netlib_CloseHandle(facy.hFcbCon); + facy.hFcbCon = NULL; + + facy.clear_cookies(); + + // Set to offline + m_iStatus = m_iDesiredStatus = facy.self_.status_id = ID_STATUS_OFFLINE; + ProtoBroadcastAck(0, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)old_status, m_iStatus); + + debugLogA("***** SignOn failed"); + + return; + } + + ToggleStatusMenuItems(true); + debugLogA("***** SignOn complete"); + } + + facy.chat_state(m_iDesiredStatus != ID_STATUS_INVISIBLE); + + ForkThread(&FacebookProto::ProcessBuddyList, NULL); + + m_iStatus = facy.self_.status_id = m_iDesiredStatus; + ProtoBroadcastAck(0, ACKTYPE_STATUS, ACKRESULT_SUCCESS, (HANDLE)old_status, m_iStatus); + + debugLogA("***** ChangeStatus complete"); +} + +/** Return true on success, false on error. */ +bool FacebookProto::NegotiateConnection() +{ + debugLogA("***** Negotiating connection with Facebook"); + + DBVARIANT dbv = {0}; + + ptrA username( getStringA(FACEBOOK_KEY_LOGIN)); + if (!username || !strlen(username)) { + NotifyEvent(m_tszUserName,TranslateT("Please enter a username."),NULL,FACEBOOK_EVENT_CLIENT); + return false; + } + + ptrA password( getStringA(FACEBOOK_KEY_PASS)); + if (!password || !*password) { + NotifyEvent(m_tszUserName,TranslateT("Please enter a password."),NULL,FACEBOOK_EVENT_CLIENT); + return false; + } + + password = mir_utf8encode(password); + + // Refresh last time of feeds update + facy.last_feeds_update_ = ::time(NULL); + + // Get info about secured connection + facy.https_ = getByte(FACEBOOK_KEY_FORCE_HTTPS, DEFAULT_FORCE_HTTPS) != 0; + + // Generate random clientid for this connection + facy.chat_clientid_ = utils::text::rand_string(8, "0123456789abcdef"); + + // Create default group for new contacts + ptrT groupName( getTStringA(FACEBOOK_KEY_DEF_GROUP)); + if (groupName != NULL) + Clist_CreateGroup(0, groupName); + + return facy.login(username, password); +} + +void FacebookProto::UpdateLoop(void *) +{ + time_t tim = ::time(NULL); + debugLogA(">>>>> Entering Facebook::UpdateLoop[%d]", tim); + + for (int i = -1; !isOffline(); i = ++i % 50) + { + if (i != -1) { + ProcessBuddyList(NULL); + + if (getByte(FACEBOOK_KEY_EVENT_FEEDS_ENABLE, DEFAULT_EVENT_FEEDS_ENABLE)) + ProcessFeeds(NULL); + } + + if (i == 49) + ProcessFriendRequests(NULL); + + debugLogA("***** FacebookProto::UpdateLoop[%d] going to sleep...", tim); + if (WaitForSingleObjectEx(update_loop_lock_, GetPollRate() * 1000, true) != WAIT_TIMEOUT) + break; + debugLogA("***** FacebookProto::UpdateLoop[%d] waking up...", tim); + } + + ResetEvent(update_loop_lock_); + debugLogA("<<<<< Exiting FacebookProto::UpdateLoop[%d]", tim); +} + +void FacebookProto::MessageLoop(void *) +{ + time_t tim = ::time(NULL); + debugLogA(">>>>> Entering Facebook::MessageLoop[%d]", tim); + + while (facy.channel()) + { + if (isOffline()) + break; + debugLogA("***** FacebookProto::MessageLoop[%d] refreshing...", tim); + } + + debugLogA("<<<<< Exiting FacebookProto::MessageLoop[%d]", tim); +} + +BYTE FacebookProto::GetPollRate() +{ + BYTE poll_rate = getByte(FACEBOOK_KEY_POLL_RATE, FACEBOOK_DEFAULT_POLL_RATE); + + return ( + (poll_rate >= FACEBOOK_MINIMAL_POLL_RATE && + poll_rate <= FACEBOOK_MAXIMAL_POLL_RATE) + ? poll_rate : FACEBOOK_DEFAULT_POLL_RATE); +} |