/* 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 . */ #include "common.h" int FacebookProto::RecvMsg(HANDLE hContact, PROTORECVEVENT *pre) { DBVARIANT dbv; if ( !db_get_s(hContact,m_szModuleName,FACEBOOK_KEY_ID,&dbv)) { ForkThread( &FacebookProto::MessagingWorker, this, new send_messaging(dbv.pszVal, FACEBOOK_RECV_MESSAGE )); db_free(&dbv); } CallService(MS_PROTO_CONTACTISTYPING, (WPARAM)hContact, (LPARAM)PROTOTYPE_CONTACTTYPING_OFF); return Proto_RecvMessage(hContact, pre); } void FacebookProto::SendMsgWorker(void *p) { if(p == NULL) return; // ScopedLock s( facy.send_message_lock_, 500 ); send_direct *data = static_cast(p); DBVARIANT dbv; if ( !isOnline( )) { ProtoBroadcastAck(m_szModuleName, data->hContact, ACKTYPE_MESSAGE, ACKRESULT_FAILED, data->msgid, (LPARAM)Translate("You cannot send messages when you are offline.")); } else if ( !db_get_s(data->hContact,m_szModuleName,FACEBOOK_KEY_ID,&dbv)) { //parseSmileys(data->msg, data->hContact); int retries = 5; std::string error_text = ""; bool result = false; while (!result && retries > 0) { result = facy.send_message(dbv.pszVal, data->msg, &error_text, retries % 2 == 0 ? MESSAGE_INBOX : MESSAGE_MERCURY); retries--; } if (result) { ProtoBroadcastAck(m_szModuleName,data->hContact,ACKTYPE_MESSAGE,ACKRESULT_SUCCESS, data->msgid,0); MessagingWorker( new send_messaging(dbv.pszVal, FACEBOOK_SEND_MESSAGE )); } else { char *err = mir_utf8decodeA(error_text.c_str()); ProtoBroadcastAck(m_szModuleName,data->hContact,ACKTYPE_MESSAGE,ACKRESULT_FAILED, data->msgid,(LPARAM)err); } db_free(&dbv); } delete data; } void FacebookProto::SendChatMsgWorker(void *p) { if(p == NULL) return; send_chat *data = static_cast(p); std::string err_message = ""; HANDLE hContact = ChatIDToHContact(data->chat_id); if (hContact) { std::string tid; DBVARIANT dbv; if (!db_get_s(hContact, m_szModuleName, FACEBOOK_KEY_TID, &dbv)) { tid = dbv.pszVal; db_free(&dbv); } else { std::string post_data = "threads[group_ids][0]=" + data->chat_id; post_data += "&fb_dtsg=" + (facy.dtsg_.length() ? facy.dtsg_ : "0"); post_data += "&__user=" + facy.self_.user_id; post_data += "&phstamp=0"; http::response resp = facy.flap( FACEBOOK_REQUEST_THREAD_INFO, &post_data ); facy.validate_response(&resp); tid = utils::text::source_get_value(&resp.data, 2, "\"thread_id\":\"", "\""); db_set_s(hContact, m_szModuleName, FACEBOOK_KEY_TID, tid.c_str()); Log(" Got thread info: %s = %s", data->chat_id.c_str(), tid.c_str()); } if (!tid.empty()) facy.send_message(tid, data->msg, &err_message, MESSAGE_TID); } delete data; } int FacebookProto::SendMsg(HANDLE hContact, int flags, const char *msg) { // TODO: msg comes as Unicode (retyped wchar_t*), why should we convert it as ANSI to UTF-8? o_O if ( flags & PREF_UNICODE ) msg = mir_utf8encode(msg); facy.msgid_ = (facy.msgid_ % 1024)+1; ForkThread( &FacebookProto::SendMsgWorker, this, new send_direct(hContact, msg, (HANDLE)facy.msgid_)); return facy.msgid_; } int FacebookProto::UserIsTyping(HANDLE hContact,int type) { if (hContact && isOnline()) ForkThread(&FacebookProto::SendTypingWorker, this, new send_typing(hContact, type)); return 0; } void FacebookProto::SendTypingWorker(void *p) { if(p == NULL) return; send_typing *typing = static_cast(p); // Dont send typing notifications to contacts, that are offline or not friends if ( db_get_w(typing->hContact,m_szModuleName,"Status", 0) == ID_STATUS_OFFLINE || db_get_b(typing->hContact, m_szModuleName, FACEBOOK_KEY_CONTACT_TYPE, 0) != FACEBOOK_CONTACT_FRIEND) return; // TODO RM: maybe better send typing optimalization facy.is_typing_ = (typing->status == PROTOTYPE_SELFTYPING_ON); SleepEx( 2000, true ); if ( !facy.is_typing_ == (typing->status == PROTOTYPE_SELFTYPING_ON)) { delete typing; return; } DBVARIANT dbv; if ( !db_get_s(typing->hContact,m_szModuleName,FACEBOOK_KEY_ID,&dbv)) { std::string data = "&source=mercury-chat"; data += (typing->status == PROTOTYPE_SELFTYPING_ON ? "&typ=1" : "&typ=0"); // PROTOTYPE_SELFTYPING_OFF data += "&to=" + std::string(dbv.pszVal); data += "&fb_dtsg=" + facy.dtsg_; data += "&lsd=&phstamp=0&__user=" + facy.self_.user_id; http::response resp = facy.flap( FACEBOOK_REQUEST_TYPING_SEND, &data ); db_free(&dbv); } delete typing; } void FacebookProto::MessagingWorker(void *p) { if (p == NULL) return; send_messaging *data = static_cast(p); if (data->type == FACEBOOK_RECV_MESSAGE) facy.chat_mark_read( data->user_id ); delete data; } void FacebookProto::parseSmileys(std::string message, HANDLE hContact) { if (!db_get_b(NULL,m_szModuleName,FACEBOOK_KEY_CUSTOM_SMILEYS, DEFAULT_CUSTOM_SMILEYS)) return; HANDLE nlc = NULL; std::string::size_type pos = 0; bool anything = false; while ((pos = message.find("[[", pos)) != std::string::npos) { std::string::size_type pos2 = message.find("]]", pos); if (pos2 == std::string::npos) break; std::string smiley = message.substr(pos, pos2+2-pos); pos = pos2; std::string url = "http://graph.facebook.com/%s/picture"; utils::text::replace_first(&url, "%s", smiley.substr(2, smiley.length()-4)); size_t slen = smiley.length(); size_t rlen = Netlib_GetBase64EncodedBufferSize(slen); char* buf = (char*)mir_alloc(rlen); NETLIBBASE64 nlb = { buf, (int)rlen, (PBYTE)smiley.c_str(), (int)slen }; CallService(MS_NETLIB_BASE64ENCODE, 0, LPARAM(&nlb)); std::string b64 = buf; b64 = utils::url::encode(b64); std::tstring filename = GetAvatarFolder() + L"\\smileys\\" + (TCHAR*)_A2T(b64.c_str()) + _T(".jpg"); FILE *f = _tfopen(filename.c_str(), _T("r")); if (f) { fclose(f); } else { facy.save_url(url, filename, nlc); } TCHAR *path = _tcsdup(filename.c_str()); SMADD_CONT cont; cont.cbSize = sizeof(SMADD_CONT); cont.hContact = hContact; cont.type = 1; cont.path = path; CallService(MS_SMILEYADD_LOADCONTACTSMILEYS, 0, (LPARAM)&cont); mir_free(path); //} } }