/* Copyright (c) 2013-24 Miranda NG team (https://miranda-ng.org) 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 version 2 of the License. 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 "stdafx.h" static const char *szGiftTypes[] = { "thumb_256", "thumb_96", "thumb_48" }; static const char *szVKUrls[] = { "http://vk.com/", "https://vk.com/", "http://new.vk.com/", "https://new.vk.com/", "http://m.vk.com/", "https://m.vk.com/" }; static const char *szAttachmentMasks[] = { "wall%d_%d", "wall-%d_%d", "video%d_%d", "video-%d_%d", "photo%d_%d", "photo-%d_%d", "audio%d_%d", "audio-%d_%d", "doc%d_%d", "doc-%d_%d", "market-%d_%d", "market%d_%d", "story%d_%d", "story-%d_%d" }; static const char *szVKLinkParam[] = { "?z=", "?w=", "&z=", "&w=" }; static const wchar_t* wszVKStickerUrlMask = L"https://vk.com/sticker/1-%d-%d%s"; JSONNode nullNode(JSON_NULL); bool IsEmpty(LPCWSTR str) { return (str == nullptr || str[0] == 0); } bool IsEmpty(LPCSTR str) { return (str == nullptr || str[0] == 0); } bool wlstrstr(wchar_t *_s1, wchar_t *_s2) { wchar_t s1[1024], s2[1024]; wcsncpy_s(s1, _s1, _TRUNCATE); CharLowerBuff(s1, _countof(s1)); wcsncpy_s(s2, _s2, _TRUNCATE); CharLowerBuff(s2, _countof(s2)); return wcsstr(s1, s2) != nullptr; } ///////////////////////////////////////////////////////////////////////////////////////// static IconItem iconList[] = { { LPGEN("Notification icon"), "notification", IDI_NOTIFICATION }, { LPGEN("Read message icon"), "read", IDI_READMSG }, { LPGEN("Visit profile icon"), "profile", IDI_VISITPROFILE }, { LPGEN("Load server history icon"), "history", IDI_HISTORY }, { LPGEN("Add to friend list icon"), "addfriend", IDI_FRIENDADD }, { LPGEN("Delete from friend list icon"), "delfriend", IDI_FRIENDDEL }, { LPGEN("Report abuse icon"), "abuse", IDI_ABUSE }, { LPGEN("Ban user icon"), "ban", IDI_BAN }, { LPGEN("Broadcast icon"), "broadcast", IDI_BROADCAST }, { LPGEN("Status icon"), "status", IDI_STATUS }, { LPGEN("Wall message icon"), "wall", IDI_WALL }, { LPGEN("Mark messages as read icon"), "markread", IDI_MARKMESSAGESASREAD }, { LPGEN("Forward icon"), "forward", IDI_FORWARD }, { LPGEN("Reload messages icon"), "reload", IDI_RELOADMESSAGE } }; void InitIcons() { g_plugin.registerIcon("Protocols/VKontakte", iconList, "VKontakte"); } ///////////////////////////////////////////////////////////////////////////////////////// char* ExpUrlEncode(const char *szUrl, bool strict) { const char szHexDigits[] = "0123456789ABCDEF"; if (szUrl == nullptr) return nullptr; const uint8_t *s; int outputLen; for (outputLen = 0, s = (const uint8_t*)szUrl; *s; s++) if ((*s & 0x80 && !strict) || // UTF-8 multibyte ('0' <= *s && *s <= '9') || //0-9 ('A' <= *s && *s <= 'Z') || //ABC...XYZ ('a' <= *s && *s <= 'z') || //abc...xyz *s == '~' || *s == '-' || *s == '_' || *s == '.' || *s == ' ') outputLen++; else outputLen += 3; char *szOutput = (char*)mir_alloc(outputLen + 1); if (szOutput == nullptr) return nullptr; char *d = szOutput; for (s = (const uint8_t*)szUrl; *s; s++) if ((*s & 0x80 && !strict) || // UTF-8 multibyte ('0' <= *s && *s <= '9') || //0-9 ('A' <= *s && *s <= 'Z') || //ABC...XYZ ('a' <= *s && *s <= 'z') || //abc...xyz *s == '~' || *s == '-' || *s == '_' || *s == '.') *d++ = *s; else if (*s == ' ') *d++ = '+'; else { *d++ = '%'; *d++ = szHexDigits[*s >> 4]; *d++ = szHexDigits[*s & 0xF]; } *d = '\0'; return szOutput; } ///////////////////////////////////////////////////////////////////////////////////////// void CVkProto::CheckUpdate() { if (getByte("Compatibility") < 1) { for (auto &cc : AccContacts()) { VKUserID_t iUserId = getDword(cc, "vk_chat_id", VK_INVALID_USER); if (iUserId != VK_INVALID_USER) { WriteVKUserID(cc, iUserId); delSetting(cc, "vk_chat_id"); delSetting(cc, "ChatRoomID"); } } setByte("Compatibility", 1); } if (getByte("Iint64IDCompatibility") < 1) { for (auto& cc : AccContacts()) { char szID[40]; _ltoa(ReadVKUserID(cc), szID, 10); db_unset(cc, m_szModuleName, "ID"); setString(cc, "ID", szID); } setByte("Iint64IDCompatibility", 1); bIint64IDCompatibility = true; } } //////////////////////// bIint64IDCompatibility ///////////////////////////////////////// void CVkProto::WriteQSWord(MCONTACT hContact, const char *szParam, uint64_t uValue) { if (!bIint64IDCompatibility) db_unset(hContact, m_szModuleName, szParam); char szValue[40]; _ltoa(uValue, szValue, 10); setString(hContact, szParam, szValue); } uint64_t CVkProto::ReadQSWord(MCONTACT hContact, const char* szParam, uint64_t uDefaultValue) { if (!bIint64IDCompatibility) { uint64_t uValue = getDword(hContact, szParam, uDefaultValue); if (uValue != uDefaultValue) { WriteQSWord(hContact, szParam, uValue); return uValue; } } ptrA szValue(getStringA(hContact, szParam)); return szValue ? strtol(szValue, nullptr, 10) : uDefaultValue; } VKUserID_t CVkProto::ReadVKUserIDFromString(MCONTACT hContact) { ptrA szID(getStringA(hContact, "ID")); return szID ? strtol(szID, nullptr, 10) : VK_INVALID_USER; } VKUserID_t CVkProto::ReadVKUserID(MCONTACT hContact) { if (bIint64IDCompatibility) return ReadVKUserIDFromString(hContact); VKUserID_t iUserId = getDword(hContact, "ID", VK_INVALID_USER); return iUserId ? iUserId : ReadVKUserIDFromString(hContact); } void CVkProto::WriteVKUserID(MCONTACT hContact, VKUserID_t iUserId) { if (bIint64IDCompatibility || iUserId > 0xFFFFFFFF) { char szID[40]; _ltoa(iUserId, szID, 10); setString(hContact, "ID", szID); } else setDword(hContact, "ID", iUserId); } VKPeerType CVkProto::GetVKPeerType(VKUserID_t iPeerId) { if (VK_INVALID_USER == iPeerId) return VKPeerType::vkPeerError; if (iPeerId == VK_FEED_USER) return VKPeerType::vkPeerFeed; if (iPeerId < VK_INVALID_USER) return VKPeerType::vkPeerGroup; if ((iPeerId < VK_USERID_MAX1) || (iPeerId >= VK_USERID_MIN2 && iPeerId < VK_USERID_MAX2)) return VKPeerType::vkPeerUser; if (iPeerId > VK_CHAT_MIN && iPeerId < VK_CHAT_MAX) return VKPeerType::vkPeerMUC; return VKPeerType::vkPeerError; } ///////////////////////////////////////////////////////////////////////////////////////// void CVkProto::ClearAccessToken() { debugLogA("CVkProto::ClearAccessToken"); setDword("LastAccessTokenTime", (uint32_t)time(0)); m_szAccessToken = nullptr; delSetting("AccessToken"); ShutdownSession(); } wchar_t* CVkProto::GetUserStoredPassword() { debugLogA("CVkProto::GetUserStoredPassword"); ptrA szRawPass(getStringA("Password")); return (szRawPass != nullptr) ? mir_utf8decodeW(szRawPass) : nullptr; } void CVkProto::SetAllContactStatuses(int iStatus) { debugLogA("CVkProto::SetAllContactStatuses (%d)", iStatus); for (auto &hContact : AccContacts()) { if (isChatRoom(hContact)) SetChatStatus(hContact, iStatus); else if (getWord(hContact, "Status") != iStatus) setWord(hContact, "Status", iStatus); if (iStatus == ID_STATUS_OFFLINE) { SetMirVer(hContact, -1); db_unset(hContact, m_szModuleName, "ListeningTo"); } } } ///////////////////////////////////////////////////////////////////////////////////////// MCONTACT CVkProto::FindTempUser(VKUserID_t iUserId, int iWait) { MCONTACT hContact = FindUser(iUserId); if (hContact == 0) { hContact = FindUser(iUserId, true); RetrieveUserInfo(iUserId); Contact::Hide(hContact); Contact::RemoveFromList(hContact); db_set_dw(hContact, "Ignore", "Mask1", 0); if (iWait) Sleep(iWait); } return hContact; } MCONTACT CVkProto::FindUser(VKUserID_t dwUserid, bool bCreate) { if (!dwUserid) return 0; for (auto &hContact : AccContacts()) { if (isChatRoom(hContact)) continue; VKUserID_t dbUserid = ReadVKUserID(hContact); if (dbUserid == VK_INVALID_USER) continue; if (dbUserid == dwUserid) return hContact; } if (!bCreate) return 0; MCONTACT hNewContact = db_add_contact(); Proto_AddToContact(hNewContact, m_szModuleName); WriteVKUserID(hNewContact, dwUserid); Clist_SetGroup(hNewContact, m_vkOptions.pwszDefaultGroup); if (GetVKPeerType(dwUserid) == VKPeerType::vkPeerGroup) setByte(hNewContact, "IsGroup", 1); return hNewContact; } MCONTACT CVkProto::FindChat(VKUserID_t iUserId) { if (!iUserId) return 0; for (auto &hContact : AccContacts()) { if (!isChatRoom(hContact)) continue; VKUserID_t dbUserid = ReadVKUserID(hContact); if (dbUserid == VK_INVALID_USER) continue; if (dbUserid == iUserId) return hContact; } return 0; } bool CVkProto::IsGroupUser(MCONTACT hContact) { if (getBool(hContact, "IsGroup", false)) return true; VKUserID_t iUserId = ReadVKUserID(hContact); return GetVKPeerType(iUserId) == VKPeerType::vkPeerGroup; } ///////////////////////////////////////////////////////////////////////////////////////// JSONNode& CVkProto::CheckJsonResponse(AsyncHttpRequest *pReq, MHttpResponse *reply, JSONNode &root) { debugLogA("CVkProto::CheckJsonResponse"); if (!reply || reply->body.IsEmpty()) return nullNode; root = JSONNode::parse(reply->body); if (!CheckJsonResult(pReq, root)) return nullNode; return root["response"]; } bool CVkProto::CheckJsonResult(AsyncHttpRequest *pReq, const JSONNode &jnNode) { debugLogA("CVkProto::CheckJsonResult"); if (!jnNode) { if (pReq) pReq->m_iErrorCode = VKERR_NO_JSONNODE; return false; } const JSONNode &jnError = jnNode["error"]; const JSONNode &jnErrorCode = jnError["error_code"]; const JSONNode &jnRedirectUri = jnError["redirect_uri"]; if (!jnError || !jnErrorCode) return true; int iErrorCode = jnErrorCode.as_int(); debugLogA("CVkProto::CheckJsonResult %d", iErrorCode); if (!pReq) return (iErrorCode == 0); pReq->m_iErrorCode = iErrorCode; switch (iErrorCode) { case VKERR_AUTHORIZATION_FAILED: ConnectionFailed(LOGINERR_WRONGPASSWORD); break; case VKERR_ACCESS_DENIED: if ((jnError["error_msg"] && jnError["error_msg"].as_mstring() == L"Access denied: can't set typing activity for this peer") || (pReq->m_szUrl.Find("messages.setActivity.json") > -1) ) { debugLogA("CVkProto::CheckJsonResult VKERR_ACCESS_DENIED (can't set typing activity) - ignore"); break; } if (time(0) - getDword("LastAccessTokenTime", 0) > 60 * 60 * 24) { debugLogA("CVkProto::CheckJsonResult VKERR_ACCESS_DENIED (AccessToken fail?)"); ClearAccessToken(); return false; } debugLogA("CVkProto::CheckJsonResult VKERR_ACCESS_DENIED"); MsgPopup(TranslateT("Access denied! Data will not be sent or received."), TranslateT("Error"), true); break; case VKERR_CAPTCHA_NEEDED: ApplyCaptcha(pReq, jnError); break; case VKERR_VALIDATION_REQUIRED: // Validation Required MsgPopup(TranslateT("You have to validate your account before you can use VK in Miranda NG"), TranslateT("Error"), true); if (jnRedirectUri) { T2Utf szRedirectUri(jnRedirectUri.as_mstring()); AsyncHttpRequest *pRedirectReq = new AsyncHttpRequest(this, REQUEST_GET, szRedirectUri, false, &CVkProto::OnOAuthAuthorize); pRedirectReq->m_bApiReq = false; pRedirectReq->bIsMainConn = true; Push(pRedirectReq); } break; case VKERR_FLOOD_CONTROL: pReq->m_iRetry = 0; __fallthrough; case VKERR_UNKNOWN: case VKERR_TOO_MANY_REQ_PER_SEC: case VKERR_INTERNAL_SERVER_ERR: if (pReq->m_iRetry > 0) { pReq->bNeedsRestart = true; Sleep(1000); //Pause for fix err debugLogA("CVkProto::CheckJsonResult Retry = %d", pReq->m_iRetry); pReq->m_iRetry--; } else { CMStringW wszMsg(FORMAT, TranslateT("Error %d. Data will not be sent or received."), iErrorCode); MsgPopup(wszMsg, TranslateT("Error"), true); debugLogA("CVkProto::CheckJsonResult SendError"); } break; case VKERR_INVALID_PARAMETERS: MsgPopup(TranslateT("One of the parameters specified was missing or invalid"), TranslateT("Error"), true); break; case VKERR_ACC_WALL_POST_DENIED: MsgPopup(TranslateT("Access to adding post denied"), TranslateT("Error"), true); break; case VKERR_CANT_SEND_USER_ON_BLACKLIST: MsgPopup(TranslateT("Can't send messages for users from blacklist"), TranslateT("Error"), true); break; case VKERR_CANT_SEND_USER_WITHOUT_DIALOGS: MsgPopup(TranslateT("Can't send messages for users without dialogs"), TranslateT("Error"), true); break; case VKERR_CANT_SEND_YOU_ON_BLACKLIST: MsgPopup(TranslateT("Can't send messages to this user due to their privacy settings"), TranslateT("Error"), true); break; case VKERR_MESSAGE_IS_TOO_LONG: MsgPopup(TranslateT("Message is too long"), TranslateT("Error"), true); break; case VKERR_COULD_NOT_SAVE_FILE: case VKERR_INVALID_ALBUM_ID: case VKERR_INVALID_SERVER: case VKERR_INVALID_HASH: case VKERR_INVALID_AUDIO: case VKERR_AUDIO_DEL_COPYRIGHT: case VKERR_INVALID_FILENAME: case VKERR_INVALID_FILESIZE: case VKERR_HIMSELF_AS_FRIEND: case VKERR_YOU_ON_BLACKLIST: case VKERR_USER_ON_BLACKLIST: break; // See also CVkProto::SendFileFailed } return (iErrorCode == 0); } void CVkProto::OnReceiveSmth(MHttpResponse *reply, AsyncHttpRequest *pReq) { JSONNode jnRoot; const JSONNode &jnResponse = CheckJsonResponse(pReq, reply, jnRoot); debugLogA("CVkProto::OnReceiveSmth %d", jnResponse.as_int()); } ///////////////////////////////////////////////////////////////////////////////////////// // Quick & dirty form parser static CMStringA getAttr(char *szSrc, LPCSTR szAttrName) { char *pEnd = strchr(szSrc, '>'); if (pEnd == nullptr) return ""; *pEnd = 0; char *p1 = strstr(szSrc, szAttrName); if (p1 == nullptr) { *pEnd = '>'; return ""; } p1 += mir_strlen(szAttrName); if (p1[0] != '=' || p1[1] != '\"') { *pEnd = '>'; return ""; } p1 += 2; char *p2 = strchr(p1, '\"'); *pEnd = '>'; if (p2 == nullptr) return ""; return CMStringA(p1, (int)(p2 - p1)); } bool CVkProto::AutoFillForm(char *pBody, CMStringA &szAction, CMStringA& szResult) { debugLogA("CVkProto::AutoFillForm"); szResult.Empty(); char *pFormBeg = strstr(pBody, "
"); if (pFormEnd == nullptr) return false; *pFormEnd = 0; szAction = getAttr(pFormBeg, "action"); CMStringA result; char *pFieldBeg = pFormBeg; while (true) { if ((pFieldBeg = strstr(pFieldBeg + 1, ""); if (pPhonePref && sscanf(pPhonePref, "%[^<]", szPrefixTel) == 1) { pPhonePref = strstr(pPhonePref + 1, " "); if (pPhonePref && sscanf(pPhonePref, " %[^<]", szSufixTel) == 1) { wszTitle.Format(TranslateT("Enter the missing digits between %s and %s of the phone number linked to your account"), ptrW(mir_a2u(szPrefixTel)).get(), ptrW(mir_a2u(szSufixTel)).get()); MessageBoxW(nullptr, wszTitle, TranslateT("Attention!"), MB_ICONWARNING | MB_OK); } } value = RunConfirmationCode(wszTitle); if (value.IsEmpty()) return false; } if (!result.IsEmpty()) result.AppendChar('&'); result += name + "="; result += mir_urlEncode(value); } } szResult = result; debugLogA("CVkProto::AutoFillForm result = \"%s\"", szResult.c_str()); return true; } CMStringW CVkProto::RunConfirmationCode(LPCWSTR pwszTitle) { ENTER_STRING pForm = {}; pForm.type = 0; CMStringW wszTitle(FORMAT, L"%s: %s", m_tszUserName, IsEmpty(pwszTitle) ? TranslateT("Enter confirmation code") : pwszTitle); pForm.caption = wszTitle; pForm.szModuleName = m_szModuleName; pForm.szDataPrefix = "confirmcode_"; return (!EnterString(&pForm)) ? CMStringW() : CMStringW(ptrW(pForm.ptszResult)); } CMStringW CVkProto::RunRenameNick(LPCWSTR pwszOldName) { ENTER_STRING pForm = {}; pForm.type = 0; pForm.caption = TranslateT("Enter new nickname"); pForm.ptszInitVal = pwszOldName; pForm.szModuleName = m_szModuleName; pForm.szDataPrefix = "renamenick_"; return (!EnterString(&pForm)) ? CMStringW() : CMStringW(ptrW(pForm.ptszResult)); } ///////////////////////////////////////////////////////////////////////////////////////// void CVkProto::GrabCookies(MHttpResponse *nhr, CMStringA szDefDomain) { debugLogA("CVkProto::GrabCookies"); for (auto &hdr : *nhr) { if (_stricmp(hdr->szName, "Set-cookie")) continue; CMStringA szValue = hdr->szValue, szCookieName, szCookieVal, szDomain; int iStart = 0; while (true) { bool bFirstToken = (iStart == 0); CMStringA szToken = szValue.Tokenize(";", iStart).Trim(); if (iStart == -1) break; if (bFirstToken) { int iStart2 = 0; szCookieName = szToken.Tokenize("=", iStart2); szCookieVal = szToken.Tokenize("=", iStart2); } else if (!strncmp(szToken, "domain=", 7)) szDomain = szToken.Mid(7); } if (szDomain.IsEmpty() && !szDefDomain.IsEmpty()) szDomain = szDefDomain; if (!szCookieName.IsEmpty() && !szDomain.IsEmpty()) { bool bFound = false; for (auto &it : m_cookies) if (it->m_name == szCookieName) { bFound = true; if (szCookieVal == "DELETED") m_cookies.remove(it); else it->m_value = szCookieVal; break; } if (!bFound && szCookieVal != "DELETED") m_cookies.insert(new CVkCookie(szCookieName, szCookieVal, szDomain)); } } } void CVkProto::ApplyCookies(AsyncHttpRequest *pReq) { debugLogA("CVkProto::ApplyCookies"); CMStringA szCookie; for (auto &it : m_cookies) { if (!strstr(pReq->m_szUrl, it->m_domain)) continue; if (!szCookie.IsEmpty()) szCookie.Append("; "); szCookie.Append(it->m_name); szCookie.AppendChar('='); szCookie.Append(it->m_value); } if (!szCookie.IsEmpty()) pReq->AddHeader("Cookie", szCookie); } ///////////////////////////////////////////////////////////////////////////////////////// bool CVkProto::IsAuthContactLater(MCONTACT hContact) { if (hContact == 0 || hContact == INVALID_CONTACT_ID || isChatRoom(hContact) || IsGroupUser(hContact) || getDword(hContact, "ReqAuthTime") == 0 || getBool(hContact, "friend")) return false; if (time(0) - getDword(hContact, "ReqAuthTime") >= m_vkOptions.iReqAuthTimeLater) { db_unset(hContact, m_szModuleName, "ReqAuthTime"); return false; } return true; } bool CVkProto::AddAuthContactLater(MCONTACT hContact) { if (hContact == 0 || hContact == INVALID_CONTACT_ID || isChatRoom(hContact) || IsGroupUser(hContact) || getDword(hContact, "ReqAuthTime") != 0 || getBool(hContact, "friend")) return false; setDword(hContact, "ReqAuthTime", (uint32_t)time(0)); return true; } void __cdecl CVkProto::DBAddAuthRequestThread(void *p) { CVkDBAddAuthRequestThreadParam *param = (CVkDBAddAuthRequestThreadParam *)p; if (param->hContact == 0 || param->hContact == INVALID_CONTACT_ID || !IsOnline()) return; for (int i = 0; i < MAX_RETRIES && IsEmpty(ptrW(db_get_wsa(param->hContact, m_szModuleName, "Nick"))); i++) { Sleep(1500); if (!IsOnline()) return; } DBAddAuthRequest(param->hContact, param->bAdded); delete param; } void CVkProto::DBAddAuthRequest(const MCONTACT hContact, bool added) { debugLogA("CVkProto::DBAddAuthRequest"); DB::AUTH_BLOB blob(hContact, T2Utf(ptrW(db_get_wsa(hContact, m_szModuleName, "Nick"))), T2Utf(ptrW(db_get_wsa(hContact, m_szModuleName, "FirstName"))), T2Utf(ptrW(db_get_wsa(hContact, m_szModuleName, "LastName"))), nullptr, nullptr); DBEVENTINFO dbei = {}; dbei.szModule = m_szModuleName; dbei.timestamp = (uint32_t)time(0); dbei.flags = DBEF_UTF; dbei.eventType = added ? EVENTTYPE_ADDED : EVENTTYPE_AUTHREQUEST; dbei.cbBlob = blob.size(); dbei.pBlob = blob; db_event_add(hContact, &dbei); debugLogA("CVkProto::DBAddAuthRequest %s", blob.get_nick() ? blob.get_nick() : ""); } MCONTACT CVkProto::MContactFromDbEvent(MEVENT hDbEvent) { debugLogA("CVkProto::MContactFromDbEvent"); if (!hDbEvent || !IsOnline()) return INVALID_CONTACT_ID; char body[2]; DBEVENTINFO dbei = {}; dbei.cbBlob = sizeof(uint32_t) * 2; dbei.pBlob = body; if (db_event_get(hDbEvent, &dbei)) return INVALID_CONTACT_ID; if (dbei.eventType != EVENTTYPE_AUTHREQUEST || mir_strcmp(dbei.szModule, m_szModuleName)) return INVALID_CONTACT_ID; MCONTACT hContact = DbGetAuthEventContact(&dbei); db_unset(hContact, m_szModuleName, "ReqAuthTime"); return hContact; } ///////////////////////////////////////////////////////////////////////////////////////// void CVkProto::SetMirVer(MCONTACT hContact, int iPlatform) { if (hContact == 0 || hContact == INVALID_CONTACT_ID) return; if (iPlatform == -1) { db_unset(hContact, m_szModuleName, "MirVer"); return; } CMStringW MirVer, OldMirVer(ptrW(db_get_wsa(hContact, m_szModuleName, "MirVer"))); bool bSetFlag = true; switch (iPlatform) { case VK_APP_ID: MirVer = L"Miranda NG VKontakte"; break; case 2386311: MirVer = L"QIP 2012 VKontakte"; break; case 1: MirVer = L"VKontakte (Mobile)"; break; case 3087106: // iPhone case 3140623: case 2: MirVer = L"VKontakte (iPhone)"; break; case 3682744: // iPad case 3: MirVer = L"VKontakte (iPad)"; break; case 2685278: // Android - Kate MirVer = L"Kate Mobile (Android)"; break; case 2890984: // Android case 2274003: case 4: MirVer = L"VKontakte (Android)"; break; case 3059453: // Windows Phone case 2424737: case 3502561: case 5: MirVer = L"VKontakte (WPhone)"; break; case 3584591: // Windows 8.x case 6: MirVer = L"VKontakte (Windows)"; break; case 7: MirVer = L"VKontakte (Website)"; break; case 5027722: MirVer = L"VK Messenger"; break; case 4894723: MirVer = L"Phoenix Lite"; break; case 4994316: MirVer = L"Phoenix Full"; break; default: MirVer = L"VKontakte (Other)"; bSetFlag = OldMirVer.IsEmpty(); } if (OldMirVer == MirVer) return; if (bSetFlag) setWString(hContact, "MirVer", MirVer); } ///////////////////////////////////////////////////////////////////////////////////////// void CVkProto::ContactTypingThread(void *p) { debugLogA("CVkProto::ContactTypingThread"); MCONTACT hContact = (UINT_PTR)p; CallService(MS_PROTO_CONTACTISTYPING, hContact, 5); Sleep(4500); CallService(MS_PROTO_CONTACTISTYPING, hContact); if (!g_bMessageState) { Sleep(1500); SetSrmmReadStatus(hContact); } } int CVkProto::IsHystoryMessageExist(MCONTACT hContact) { if (!hContact) return 0; DB::ECPTR pCursor(DB::Events(hContact)); while (MEVENT hDbEvent = pCursor.FetchNext()) { DBEVENTINFO dbei = {}; db_event_get(hDbEvent, &dbei); if (dbei.eventType != VK_USER_DEACTIVATE_ACTION) return 1; } return -1; } int CVkProto::OnProcessSrmmEvent(WPARAM uType, LPARAM lParam) { debugLogA("CVkProto::OnProcessSrmmEvent"); auto *pDlg = (CSrmmBaseDialog *)lParam; CMStringA szProto(Proto_GetBaseAccountName(pDlg->m_hContact)); if (szProto.IsEmpty() || szProto != m_szModuleName) return 0; if (uType == MSG_WINDOW_EVT_OPENING && !g_bMessageState) SetSrmmReadStatus(pDlg->m_hContact); if (uType == MSG_WINDOW_EVT_OPENING && m_vkOptions.bLoadLastMessageOnMsgWindowsOpen && IsHystoryMessageExist(pDlg->m_hContact) != 1) { m_bNotifyForEndLoadingHistory = false; if (!getBool(pDlg->m_hContact, "ActiveHistoryTask")) { setByte(pDlg->m_hContact, "ActiveHistoryTask", 1); GetServerHistory(pDlg->m_hContact, 0, MAXHISTORYMIDSPERONE, 0, 0, true); } } return 0; } void CVkProto::SetSrmmReadStatus(MCONTACT hContact) { time_t tTime = getDword(hContact, "LastMsgReadTime"); if (!tTime) return; wchar_t ttime[64]; _locale_t locale = _create_locale(LC_ALL, ""); _wcsftime_l(ttime, _countof(ttime), L"%X - %x", localtime(&tTime), locale); _free_locale(locale); Srmm_SetStatusText(hContact, CMStringW(FORMAT, TranslateT("Message read: %s"), ttime), g_plugin.getIcon(IDI_READMSG)); } void CVkProto::MarkDialogAsRead(MCONTACT hContact) { debugLogA("CVkProto::MarkDialogAsRead"); if (!IsOnline()) return; VKUserID_t iUserId = ReadVKUserID(hContact); if (iUserId == VK_INVALID_USER || iUserId == VK_FEED_USER) return; MEVENT hDBEvent = db_event_firstUnread(hContact); while (hDBEvent != 0) { DBEVENTINFO dbei = {}; if (!db_event_get(hDBEvent, &dbei) && !mir_strcmp(m_szModuleName, dbei.szModule)) { db_event_markRead(hContact, hDBEvent, true); Clist_RemoveEvent(-1, hDBEvent); } hDBEvent = db_event_next(hContact, hDBEvent); } } char* CVkProto::GetStickerId(const char *szMsg, int &iStickerId) { iStickerId = 0; char *szRetMsg = nullptr; int iRes = 0; const char *szTmpMsg = strstr(szMsg, "[sticker"); if (szTmpMsg) iRes = sscanf(szTmpMsg, "[sticker:%d]", &iStickerId) == 1 ? 1 : sscanf(szTmpMsg, "[sticker-%d]", &iStickerId); if (iRes == 1) { char HeadMsg[32] = { 0 }; mir_snprintf(HeadMsg, "[sticker:%d]", iStickerId); size_t retLen = mir_strlen(HeadMsg); if (retLen < mir_strlen(szMsg)) { CMStringA szRMsg(szMsg, int(mir_strlen(szMsg) - mir_strlen(szTmpMsg))); szRMsg.Append(&szTmpMsg[retLen]); szRetMsg = mir_strdup(szRMsg.Trim()); } } return szRetMsg; } uint8_t CVkProto::GetContactType(MCONTACT hContact) { if (hContact == INVALID_CONTACT_ID) return 0; if (isChatRoom(hContact)) return VKContactType::vkContactMUCUser; if (IsGroupUser(hContact)) return VKContactType::vkContactGroupUser; VKUserID_t iUserId = ReadVKUserID(hContact); if (!hContact || iUserId == m_iMyUserId) return VKContactType::vkContactSelf; if (iUserId == VK_FEED_USER) return 0; return VKContactType::vkContactNormal; } const char* FindVKUrls(const char *Msg) { if (IsEmpty(Msg)) return nullptr; const char *pos = nullptr; for (int i = 0; i < _countof(szVKUrls) && !pos; i++) { pos = strstr(Msg, szVKUrls[i]); if (pos) pos += mir_strlen(szVKUrls[i]); } if (pos >= (Msg + mir_strlen(Msg))) pos = nullptr; return pos; } CMStringA CVkProto::GetAttachmentsFromMessage(const char *szMsg) { if (IsEmpty(szMsg)) return CMStringA(); const char *pos = FindVKUrls(szMsg); if (!pos) return CMStringA(); const char *nextpos = FindVKUrls(pos); const char *pos2 = nullptr; for (int i = 0; i < _countof(szVKLinkParam) && !pos2; i++) { pos2 = strstr(pos, szVKLinkParam[i]); if (pos2 && (!nextpos || pos2 < nextpos)) pos = pos2 + mir_strlen(szVKLinkParam[i]); } if (pos >= (szMsg + mir_strlen(szMsg))) return CMStringA(); int iRes = 0, iOwner = 0, iId = 0; for (auto &it : szAttachmentMasks) { iRes = sscanf(pos, it, &iOwner, &iId); if (iRes == 2) { CMStringA szAttachment(FORMAT, it, iOwner, iId); CMStringA szAttachment2; if (nextpos) szAttachment2 = GetAttachmentsFromMessage(pos + szAttachment.GetLength()); if (!szAttachment2.IsEmpty()) szAttachment += "," + szAttachment2; return szAttachment; } else if (iRes == 1) break; } return GetAttachmentsFromMessage(pos); } int CVkProto::OnDbSettingChanged(WPARAM hContact, LPARAM lParam) { DBCONTACTWRITESETTING *cws = (DBCONTACTWRITESETTING*)lParam; if (hContact != 0) return 0; if (strcmp(cws->szModule, "ListeningTo")) return 0; CMStringA szListeningTo(m_szModuleName); szListeningTo += "Enabled"; if (!strcmp(cws->szSetting, szListeningTo)) { MusicSendMetod iOldMusicSendMetod = (MusicSendMetod)getByte("OldMusicSendMetod", sendBroadcastAndStatus); if (cws->value.bVal == 0) setByte("OldMusicSendMetod", m_vkOptions.iMusicSendMetod); else db_unset(0, m_szModuleName, "OldMusicSendMetod"); m_vkOptions.iMusicSendMetod = cws->value.bVal == 0 ? sendNone : iOldMusicSendMetod; setByte("MusicSendMetod", m_vkOptions.iMusicSendMetod); } return 0; } ///////////////////////////////////////////////////////////////////////////////////////// CMStringW CVkProto::SpanVKNotificationType(CMStringW& wszType, VKObjType& vkFeedback, VKObjType& vkParent) { CVKNotification vkNotification[] = { // type, parent, feedback, string for translate { L"group", vkInvite, vkNull, TranslateT("has invited you to a group") }, { L"page", vkInvite, vkNull, TranslateT("has invited you to subscribe to a page") }, { L"event", vkInvite, vkNull, TranslateT("invites you to event") }, { L"follow", vkNull, vkUsers, L"" }, { L"friend_accepted", vkNull, vkUsers, L"" }, { L"mention", vkNull, vkPost, L"" }, { L"wall", vkNull, vkPost, L"" }, { L"wall_publish", vkNull, vkPost, L"" }, { L"comment_post", vkPost, vkComment, TranslateT("commented on your post") }, { L"comment_photo", vkPhoto, vkComment, TranslateT("commented on your photo") }, { L"comment_video", vkVideo, vkComment, TranslateT("commented on your video") }, { L"reply_comment", vkComment, vkComment, TranslateT("replied to your comment") }, { L"reply_comment_photo", vkComment, vkComment, TranslateT("replied to your comment to photo") }, { L"reply_comment_video", vkComment, vkComment, TranslateT("replied to your comment to video") }, { L"reply_topic", vkTopic, vkComment, TranslateT("replied to your topic") }, { L"like_post", vkPost, vkUsers, TranslateT("liked your post") }, { L"like_comment", vkComment, vkUsers, TranslateT("liked your comment") }, { L"like_photo", vkPhoto, vkUsers, TranslateT("liked your photo") }, { L"like_video", vkVideo, vkUsers, TranslateT("liked your video") }, { L"like_comment_photo", vkComment, vkUsers, TranslateT("liked your comment to photo") }, { L"like_comment_video", vkComment, vkUsers, TranslateT("liked your comment to video") }, { L"like_comment_topic", vkComment, vkUsers, TranslateT("liked your comment to topic") }, { L"copy_post", vkPost, vkCopy, TranslateT("shared your post") }, { L"copy_photo", vkPhoto, vkCopy, TranslateT("shared your photo") }, { L"copy_video", vkVideo, vkCopy, TranslateT("shared your video") }, { L"mention_comments", vkPost, vkComment, L"mentioned you in comment" }, { L"mention_comment_photo", vkPhoto, vkComment, L"mentioned you in comment to photo" }, { L"mention_comment_video", vkVideo, vkComment, L"mentioned you in comment to video" } }; CMStringW wszRes; vkFeedback = vkParent = vkNull; for (auto &it : vkNotification) if (wszType == it.pwszType) { vkFeedback = it.vkFeedback; vkParent = it.vkParent; wszRes = it.pwszTranslate; break; } return wszRes; } CMStringW CVkProto::GetVkPhotoItem(const JSONNode &jnPhoto, BBCSupport iBBC, MCONTACT hContact, VKMessageID_t iMessageId) { CMStringW wszRes; if (!jnPhoto) return wszRes; CVKImageSizeItem vkSizes[9]; CMStringW wszPriorSize = L"smpqrxyzw", wszPreviewLink; int iMaxSize = 0; int iPreviewHeight = 300; for (auto& it : jnPhoto["sizes"]) { int iIndex = wszPriorSize.Find(it["type"].as_mstring()); if (iIndex < 0) continue; if (iIndex > iMaxSize) iMaxSize = iIndex; vkSizes[iIndex].wszUrl = it["url"].as_mstring(); vkSizes[iIndex].iSizeH = it["height"].as_int(); vkSizes[iIndex].iSizeW = it["width"].as_int(); } switch (m_vkOptions.iIMGBBCSupport) { case imgNo: wszPreviewLink = L""; break; case imgPreview300: wszPreviewLink = vkSizes[wszPriorSize.Find(L"q")].wszUrl.IsEmpty() ? (vkSizes[wszPriorSize.Find(L"x")].wszUrl.IsEmpty() ? vkSizes[wszPriorSize.Find(L"o")].wszUrl : vkSizes[wszPriorSize.Find(L"x")].wszUrl) : vkSizes[wszPriorSize.Find(L"q")].wszUrl; iPreviewHeight = vkSizes[wszPriorSize.Find(L"q")].wszUrl.IsEmpty() ? (vkSizes[wszPriorSize.Find(L"x")].wszUrl.IsEmpty() ? vkSizes[wszPriorSize.Find(L"o")].iSizeH : vkSizes[wszPriorSize.Find(L"x")].iSizeH) : vkSizes[wszPriorSize.Find(L"q")].iSizeH; iPreviewHeight = min(320, iPreviewHeight); break; case imgFullSize: wszPreviewLink = vkSizes[iMaxSize].wszUrl; iPreviewHeight = vkSizes[iMaxSize].iSizeH; break; case imgPreview130: wszPreviewLink = vkSizes[wszPriorSize.Find(L"m")].wszUrl; iPreviewHeight = vkSizes[wszPriorSize.Find(L"m")].iSizeH; break; case imgPreview604: wszPreviewLink = vkSizes[wszPriorSize.Find(L"x")].wszUrl.IsEmpty() ? vkSizes[wszPriorSize.Find(L"m")].wszUrl : vkSizes[wszPriorSize.Find(L"x")].wszUrl; iPreviewHeight = vkSizes[wszPriorSize.Find(L"x")].wszUrl.IsEmpty() ? vkSizes[wszPriorSize.Find(L"m")].iSizeH : vkSizes[wszPriorSize.Find(L"x")].iSizeH; break; } wszRes.AppendFormat(L"%s (%dx%d)", TranslateT("Photo"), vkSizes[iMaxSize].iSizeW, vkSizes[iMaxSize].iSizeH ); if (m_vkOptions.bBBCNewStorySupport) wszPreviewLink = GetVkFileItem(wszPreviewLink, hContact, iMessageId); CMStringW wszImg; CMStringW wszPreviewHeight(FORMAT, L" height=%d", iPreviewHeight); if (m_vkOptions.iIMGBBCSupport && iBBC != bbcNo) wszImg = m_vkOptions.bBBCNewStorySupport ? SetBBCString(wszRes, bbcAdvanced, vkbbcImgE, (!wszPreviewLink.IsEmpty() ? wszPreviewLink + wszPreviewHeight : L"")) : SetBBCString((!wszPreviewLink.IsEmpty() ? wszPreviewLink : (!vkSizes[iMaxSize].wszUrl.IsEmpty() ? vkSizes[iMaxSize].wszUrl : L"")), bbcBasic, vkbbcImg); wszRes = wszImg + SetBBCString(wszRes, iBBC, vkbbcUrl, vkSizes[iMaxSize].wszUrl) + L"\n"; CMStringW wszText(jnPhoto["text"].as_mstring()); if (!wszText.IsEmpty()) wszRes += wszText + L"\n"; return wszRes; } CMStringW CVkProto::GetVkPhotoForVideoItem(const JSONNode& Images, MCONTACT hContact, VKMessageID_t iMessageId) { CMStringW wszRes; if (!Images || !m_vkOptions.bBBCNewStorySupport) return wszRes; int iMaxSize = 0; for (auto& it : Images) { int iSize = it["width"].as_int(); if (iMaxSize < iSize) wszRes = it["url"].as_mstring(); if (iMaxSize > 300) break; } wszRes = GetVkFileItem(wszRes, hContact, iMessageId); return wszRes.IsEmpty() ? wszRes : SetBBCString(wszRes, bbcAdvanced, vkbbcImg, wszRes); } CMStringW CVkProto::SetBBCString(LPCWSTR pwszString, BBCSupport iBBC, VKBBCType bbcType, LPCWSTR wszAddString) { CVKBBCItem bbcItem[] = { { vkbbcB, bbcNo, L"%s" }, { vkbbcB, bbcBasic, L"[b]%s[/b]" }, { vkbbcB, bbcAdvanced, L"[b]%s[/b]" }, { vkbbcI, bbcNo, L"%s" }, { vkbbcI, bbcBasic, L"[i]%s[/i]" }, { vkbbcI, bbcAdvanced, L"[i]%s[/i]" }, { vkbbcS, bbcNo, L"%s" }, { vkbbcS, bbcBasic, L"[s]%s[/s]" }, { vkbbcS, bbcAdvanced, L"[s]%s[/s]" }, { vkbbcU, bbcNo, L"%s" }, { vkbbcU, bbcBasic, L"[u]%s[/u]" }, { vkbbcU, bbcAdvanced, L"[u]%s[/u]" }, { vkbbcCode, bbcNo, L"%s" }, { vkbbcCode, bbcBasic, L"%s" }, { vkbbcCode, bbcAdvanced, L"[code]%s[/code]"}, { vkbbcImg, bbcNo, L"%s" }, { vkbbcImg, bbcBasic, L"[img]%s[/img]" }, { vkbbcImg, bbcAdvanced, L"[img]%s[/img]" }, { vkbbcUrl, bbcNo, L"%s (%s)" }, { vkbbcUrl, bbcBasic, L"[i]%s[/i] (%s)" }, { vkbbcUrl, bbcAdvanced, L"[url=%s]%s[/url]" }, { vkbbcImgE, bbcNo, L"%s (%s)" }, { vkbbcImgE, bbcBasic, L"[i]%s[/i] (%s)" }, { vkbbcImgE, bbcAdvanced, L"[img=%s]%s[/img]" }, { vkbbcSize, bbcNo, L"%s" }, { vkbbcSize, bbcBasic, L"%s" }, { vkbbcSize, bbcAdvanced, L"[size=%s]%s[/size]" }, { vkbbcColor, bbcNo, L"%s" }, { vkbbcColor, bbcBasic, L"%s" }, { vkbbcColor, bbcAdvanced, L"[color=%s]%s[/color]" }, }; if (IsEmpty(pwszString)) return CMStringW(); wchar_t *pwszFormat = nullptr; for (auto &it : bbcItem) if (it.vkBBCType == bbcType && it.vkBBCSettings == iBBC) { pwszFormat = it.pwszTempate; break; } CMStringW res; if (pwszFormat == nullptr) return CMStringW(pwszString); if ((bbcType == vkbbcUrl || bbcType == vkbbcImgE) && iBBC != bbcAdvanced) res.AppendFormat(pwszFormat, pwszString, wszAddString ? wszAddString : L""); else if (iBBC == bbcAdvanced && bbcType >= vkbbcUrl) res.AppendFormat(pwszFormat, wszAddString ? wszAddString : L"", pwszString); else res.AppendFormat(pwszFormat, pwszString); return res; } CMStringW& CVkProto::ClearFormatNick(CMStringW& wszText) { int iNameEnd = wszText.Find(L"],"), iNameBeg = wszText.Find(L"|"); if (iNameEnd != -1 && iNameBeg != -1 && iNameBeg < iNameEnd) { CMStringW wszName = wszText.Mid(iNameBeg + 1, iNameEnd - iNameBeg - 1); CMStringW wszBody = wszText.Mid(iNameEnd + 2); if (!wszName.IsEmpty() && !wszBody.IsEmpty()) wszText = wszName + L"," + wszBody; } return wszText; } ///////////////////////////////////////////////////////////////////////////////////////// CMStringW CVkProto::GetAttachmentDescr(const JSONNode &jnAttachments, BBCSupport iBBC, MCONTACT hContact, VKMessageID_t iMessageId) { debugLogA("CVkProto::GetAttachmentDescr"); CMStringW res; if (!jnAttachments || jnAttachments.as_array().empty()) { debugLogA("CVkProto::GetAttachmentDescr pAttachments == nullptr"); return res; } res += SetBBCString(TranslateT("Attachments:"), iBBC, vkbbcB); res.AppendChar('\n'); for (auto& jnAttach : jnAttachments) { res.AppendChar('\t'); CMStringW wszType(jnAttach["type"].as_mstring()); if (wszType == L"photo") { const JSONNode& jnPhoto = jnAttach["photo"]; if (!jnPhoto) continue; res += GetVkPhotoItem(jnPhoto, iBBC, hContact, iMessageId); } else if (wszType == L"audio") { const JSONNode& jnAudio = jnAttach["audio"]; if (!jnAudio) continue; CMStringW wszArtist(jnAudio["artist"].as_mstring()); CMStringW wszTitle(jnAudio["title"].as_mstring()); CMStringW wszUrl(jnAudio["url"].as_mstring()); CMStringW wszAudio(FORMAT, L"%s - %s", wszArtist.c_str(), wszTitle.c_str()); int iParamPos = wszUrl.Find(L"?"); if (m_vkOptions.bShortenLinksForAudio && iParamPos != -1) wszUrl = wszUrl.Left(iParamPos); res.AppendFormat(L"%s: %s", SetBBCString(TranslateT("Audio"), iBBC, vkbbcB).c_str(), SetBBCString(wszAudio, iBBC, vkbbcUrl, wszUrl).c_str()); } else if (wszType == L"audio_message") { const JSONNode& jnAudioMessage = jnAttach["audio_message"]; if (!jnAudioMessage) continue; if (m_vkOptions.bFilterAudioMessages) return L"== FilterAudioMessages =="; CMStringW wszUrl(jnAudioMessage["link_mp3"].as_mstring()); CMStringW wszTranscriptText(jnAudioMessage["transcript"].as_mstring()); res.AppendFormat(L"%s", SetBBCString(TranslateT("Audio message"), iBBC, vkbbcUrl, wszUrl).c_str()); if (!wszTranscriptText.IsEmpty()) res.AppendFormat(L"\n%s: %s", SetBBCString(TranslateT("Transcription"), iBBC, vkbbcB).c_str(), wszTranscriptText.c_str()); } else if (wszType == L"graffiti") { const JSONNode& jnGraffiti = jnAttach["graffiti"]; if (!jnGraffiti) continue; CMStringW wszUrl(jnGraffiti["url"].as_mstring()); res.AppendFormat(L"%s\n\t%s", SetBBCString(TranslateT("Graffiti"), iBBC, vkbbcUrl, wszUrl).c_str(), SetBBCString(wszUrl, bbcBasic, vkbbcImg).c_str() ); } else if (wszType == L"video") { const JSONNode& jnVideo = jnAttach["video"]; if (!jnVideo) continue; CMStringW wszTitle(jnVideo["title"].as_mstring()); int iVideoId = jnVideo["id"].as_int(); VKUserID_t iOwnerId = jnVideo["owner_id"].as_int(); CMStringW wszUrl(FORMAT, L"https://vk.com/video%d_%d", iOwnerId, iVideoId); if (jnVideo["image"]) { CMStringW wszPreviewImage = GetVkPhotoForVideoItem(jnVideo["image"], hContact, iMessageId); if (!wszPreviewImage.IsEmpty()) res.Append(wszPreviewImage); } res.AppendFormat(L"%s: %s", SetBBCString(TranslateT("Video"), iBBC, vkbbcB).c_str(), SetBBCString(wszTitle.IsEmpty() ? TranslateT("Link") : wszTitle, iBBC, vkbbcUrl, wszUrl).c_str()); } else if (wszType == L"doc") { const JSONNode& jnDoc = jnAttach["doc"]; if (!jnDoc) continue; if (jnDoc["type"].as_int() == 5 && m_vkOptions.bFilterAudioMessages) return L"== FilterAudioMessages =="; CMStringW wszTitle(jnDoc["title"].as_mstring()); CMStringW wszUrl(jnDoc["url"].as_mstring()); res.AppendFormat(L"%s: %s", jnDoc["type"].as_int() == 5 ? SetBBCString(TranslateT("Audio message"), iBBC, vkbbcB).c_str() : SetBBCString(TranslateT("Document"), iBBC, vkbbcB).c_str(), SetBBCString(wszTitle.IsEmpty() ? TranslateT("Link") : wszTitle, iBBC, vkbbcUrl, wszUrl).c_str()); } else if (wszType == L"wall") { const JSONNode& jnWall = jnAttach["wall"]; if (!jnWall) continue; CMStringW wszText(jnWall["text"].as_mstring()); int iWallId = jnWall["id"].as_int(); VKUserID_t iFromId = jnWall["from_id"].as_int(); CMStringW wszUrl(FORMAT, L"https://vk.com/wall%d_%d", iFromId, iWallId); res.AppendFormat(L"%s: %s", SetBBCString(TranslateT("Wall post"), iBBC, vkbbcUrl, wszUrl).c_str(), wszText.IsEmpty() ? L" " : wszText.c_str()); const JSONNode& jnCopyHystory = jnWall["copy_history"]; if (jnCopyHystory) { for (auto& jnCopyHystoryItem : jnCopyHystory) { CMStringW wszCHText(jnCopyHystoryItem["text"].as_mstring()); int iCHid = jnCopyHystoryItem["id"].as_int(); VKUserID_t iCHfromID = jnCopyHystoryItem["from_id"].as_int(); CMStringW wszCHUrl(FORMAT, L"https://vk.com/wall%d_%d", iCHfromID, iCHid); wszCHText.Replace(L"\n", L"\n\t\t"); res.AppendFormat(L"\n\t\t%s: %s", SetBBCString(TranslateT("Wall post"), iBBC, vkbbcUrl, wszCHUrl).c_str(), wszCHText.IsEmpty() ? L" " : wszCHText.c_str()); const JSONNode& jnSubAttachments = jnCopyHystoryItem["attachments"]; if (jnSubAttachments) { debugLogA("CVkProto::GetAttachmentDescr SubAttachments"); CMStringW wszAttachmentDescr = GetAttachmentDescr(jnSubAttachments, iBBC, hContact, iMessageId); wszAttachmentDescr.Replace(L"\n", L"\n\t\t"); wszAttachmentDescr.Replace(L"== FilterAudioMessages ==", L""); res += L"\n\t\t" + wszAttachmentDescr; } } } const JSONNode& jnSubAttachments = jnWall["attachments"]; if (jnSubAttachments) { debugLogA("CVkProto::GetAttachmentDescr SubAttachments"); CMStringW wszAttachmentDescr = GetAttachmentDescr(jnSubAttachments, iBBC, hContact, iMessageId); wszAttachmentDescr.Replace(L"\n", L"\n\t"); wszAttachmentDescr.Replace(L"== FilterAudioMessages ==", L""); res += L"\n\t" + wszAttachmentDescr; } } else if (wszType == L"wall_reply") { const JSONNode& jnWallReply = jnAttach["wall_reply"]; if (!jnWallReply) continue; CMStringW wszText(jnWallReply["text"].as_mstring()); int iWallReplyId = jnWallReply["id"].as_int(); VKUserID_t iFromId = jnWallReply["from_id"].as_int(); VKUserID_t iFromOwnerId = jnWallReply["owner_id"].as_int(); int iPostOwnerId = jnWallReply["post_id"].as_int(); int iThreadId = jnWallReply["reply_to_comment"].as_int(); CMStringW wszUrl(FORMAT, L"https://vk.com/wall%d_%d?reply=%d&thread=%d", iFromOwnerId, iPostOwnerId, iWallReplyId, iThreadId); CMStringW wszFromNick, wszFromUrl; MCONTACT hFromContact = FindUser(iFromId); if (hFromContact || iFromId == m_iMyUserId) wszFromNick = ptrW(db_get_wsa(hFromContact, m_szModuleName, "Nick")); else wszFromNick = TranslateT("(Unknown contact)"); wszFromUrl = UserProfileUrl(iFromId); res.AppendFormat(L"%s %s %s: %s", SetBBCString(TranslateT("Wall reply"), iBBC, vkbbcUrl, wszUrl).c_str(), TranslateT("from"), SetBBCString(wszFromNick, iBBC, vkbbcUrl, wszFromUrl).c_str(), wszText.IsEmpty() ? L" " : wszText.c_str()); const JSONNode& jnSubAttachments = jnWallReply["attachments"]; if (jnSubAttachments) { debugLogA("CVkProto::GetAttachmentDescr SubAttachments"); CMStringW wszAttachmentDescr = GetAttachmentDescr(jnSubAttachments, iBBC, hContact, iMessageId); wszAttachmentDescr.Replace(L"\n", L"\n\t"); wszAttachmentDescr.Replace(L"== FilterAudioMessages ==", L""); res += L"\n\t" + wszAttachmentDescr; } } else if (wszType == L"story") { const JSONNode& jnStory = jnAttach["story"]; if (!jnStory) continue; int iStoryId = jnStory["id"].as_int(); VKUserID_t iOwnerID = jnStory["owner_id"].as_int(); CMStringW wszUrl(FORMAT, L"https://vk.com/story%d_%d", iOwnerID, iStoryId); res.AppendFormat(L"%s", SetBBCString(TranslateT("Story"), iBBC, vkbbcUrl, wszUrl).c_str()); CMStringW wszStoryType(jnStory["type"].as_mstring()); if (wszStoryType == L"photo") { const JSONNode& jnPhoto = jnStory["photo"]; if (!jnPhoto) continue; res += L"\n\t"; res += GetVkPhotoItem(jnPhoto, iBBC, hContact, iMessageId); } else if (wszStoryType == L"video") { const JSONNode& jnVideo = jnStory["video"]; if (!jnVideo) continue; CMStringW wszTitle(jnVideo["title"].as_mstring()); int iVideoId = jnVideo["id"].as_int(); VKUserID_t iOwnerId = jnVideo["owner_id"].as_int(); CMStringW wszVideoUrl(FORMAT, L"https://vk.com/video%d_%d", iOwnerId, iVideoId); res.AppendFormat(L"\n\t%s: %s", SetBBCString(TranslateT("Video"), iBBC, vkbbcB).c_str(), SetBBCString(wszTitle.IsEmpty() ? TranslateT("Link") : wszTitle, iBBC, vkbbcUrl, wszVideoUrl).c_str()); } } else if (wszType == L"sticker") { const JSONNode& jnSticker = jnAttach["sticker"]; if (!jnSticker) continue; res.Empty(); // sticker is not really an attachment, so we don't want all that heading info CMStringW wszLink, wszLink128, wszLinkLast, wszUrl; const JSONNode& jnImages = jnSticker[m_vkOptions.bStickerBackground ? "images_with_background" : "images"]; int iStickerId = jnSticker["sticker_id"].as_int(); wszLink.AppendFormat(wszVKStickerUrlMask, iStickerId, (int)m_vkOptions.iStickerSize ? (int)m_vkOptions.iStickerSize : 128, m_vkOptions.bStickerBackground ? L"b" : L"" ); for (auto& jnImage : jnImages) { if (jnImage["width"].as_int() == (int)m_vkOptions.iStickerSize) { wszLink = jnImage["url"].as_mstring(); break; } if (jnImage["width"].as_int() == 128) // default size wszLink128 = jnImage["url"].as_mstring(); wszLinkLast = jnImage["url"].as_mstring(); } wszUrl = wszLink.IsEmpty() ? (wszLink128.IsEmpty() ? wszLinkLast : wszLink128) : wszLink; if (!m_vkOptions.bStikersAsSmileys) res += SetBBCString(wszUrl, iBBC, vkbbcImg); else if (m_vkOptions.bUseStikersAsStaticSmileys) res.AppendFormat(L"[sticker:%d]", iStickerId); else { if (ServiceExists(MS_SMILEYADD_REPLACESMILEYS)) { CMStringW wszPath(FORMAT, L"%s\\%S\\Stickers", VARSW(L"%miranda_avatarcache%").get(), m_szModuleName); CreateDirectoryTreeW(wszPath); bool bSuccess = false; MFilePath wszFileName; wszFileName.Format(L"%s\\[sticker-%d].png", wszPath.c_str(), iStickerId); if (GetFileAttributesW(wszFileName) == INVALID_FILE_ATTRIBUTES) { MHttpRequest req(REQUEST_GET); req.flags = NLHRF_NODUMP | NLHRF_SSL | NLHRF_HTTP11 | NLHRF_REDIRECT; req.m_szUrl = T2Utf(wszUrl).get(); NLHR_PTR pReply(Netlib_DownloadFile(m_hNetlibUser, &req, wszFileName)); if (pReply && pReply->resultCode == 200) bSuccess = true; } else bSuccess = true; if (bSuccess) { res.AppendFormat(L"[sticker-%d]", iStickerId); SmileyAdd_LoadContactSmileys(SMADD_FILE, m_szModuleName, wszFileName); } else res += SetBBCString(TranslateT("Sticker"), iBBC, vkbbcUrl, wszUrl); } } } else if (wszType == L"link") { const JSONNode& jnLink = jnAttach["link"]; if (!jnLink) continue; CMStringW wszUrl(jnLink["url"].as_mstring()); CMStringW wszTitle(jnLink["title"].as_mstring()); CMStringW wszCaption(jnLink["caption"].as_mstring()); CMStringW wszDescription(jnLink["description"].as_mstring()); res.AppendFormat(L"%s: %s", SetBBCString(TranslateT("Link"), iBBC, vkbbcB).c_str(), SetBBCString(wszTitle.IsEmpty() ? TranslateT("Link") : wszTitle, iBBC, vkbbcUrl, wszUrl).c_str()); if (!wszCaption.IsEmpty()) res.AppendFormat(L"\n\t%s", SetBBCString(wszCaption, iBBC, vkbbcI).c_str()); if (jnLink["photo"]) res.AppendFormat(L"\n\t%s", GetVkPhotoItem(jnLink["photo"], iBBC, hContact, iMessageId).c_str()); if (!wszDescription.IsEmpty()) res.AppendFormat(L"\n\t%s", wszDescription.c_str()); } else if (wszType == L"market") { const JSONNode& jnMarket = jnAttach["market"]; int id = jnMarket["id"].as_int(); VKUserID_t iOwnerID = jnMarket["owner_id"].as_int(); CMStringW wszTitle(jnMarket["title"].as_mstring()); CMStringW wszDescription(jnMarket["description"].as_mstring()); CMStringW wszPhoto(jnMarket["thumb_photo"].as_mstring()); CMStringW wszUrl(FORMAT, L"https://vk.com/%s%d?w=product%d_%d", iOwnerID > 0 ? L"id" : L"club", iOwnerID > 0 ? iOwnerID : (-1) * iOwnerID, iOwnerID, id); res.AppendFormat(L"%s: %s", SetBBCString(TranslateT("Product"), iBBC, vkbbcB).c_str(), SetBBCString(wszTitle.IsEmpty() ? TranslateT("Link") : wszTitle, iBBC, vkbbcUrl, wszUrl).c_str()); if (!wszPhoto.IsEmpty()) res.AppendFormat(L"\n\t%s: %s", SetBBCString(TranslateT("Photo"), iBBC, vkbbcB).c_str(), SetBBCString(wszPhoto, iBBC, vkbbcImg).c_str()); if (jnMarket["price"] && jnMarket["price"]["text"]) res.AppendFormat(L"\n\t%s: %s", SetBBCString(TranslateT("Price"), iBBC, vkbbcB).c_str(), jnMarket["price"]["text"].as_mstring().c_str()); if (!wszDescription.IsEmpty()) res.AppendFormat(L"\n\t%s", wszDescription.c_str()); } else if (wszType == L"gift") { const JSONNode& jnGift = jnAttach["gift"]; if (!jnGift) continue; CMStringW wszLink; for (auto& it : szGiftTypes) { const JSONNode& n = jnGift[it]; if (n) { wszLink = n.as_mstring(); break; } } if (wszLink.IsEmpty()) continue; res += SetBBCString(TranslateT("Gift"), iBBC, vkbbcUrl, wszLink); if (m_vkOptions.iIMGBBCSupport && iBBC != bbcNo) res.AppendFormat(L"\n\t%s", SetBBCString(wszLink, iBBC, vkbbcImg).c_str()); } else { res.AppendFormat(TranslateT("Unsupported or unknown attachment type: %s"), SetBBCString(wszType, iBBC, vkbbcB).c_str()); const JSONNode& jnUnknown = jnAttach[jnAttach["type"].as_string().c_str()]; CMStringW wszText(jnUnknown["text"].as_mstring()); if (!wszText.IsEmpty()) res.AppendFormat(L"\n%s: %s", TranslateT("Text"), wszText.c_str()); } res.AppendChar('\n'); } return res; } CMStringW CVkProto::GetFwdMessage(const JSONNode& jnMsg, const JSONNode& jnFUsers, OBJLIST& vkUsers, BBCSupport iBBC) { VKUserID_t iUserId = jnMsg["from_id"].as_int(); CMStringW wszBody(jnMsg["text"].as_mstring()); CVkUserInfo* vkUser = vkUsers.find((CVkUserInfo*)&iUserId); CMStringW wszNick, wszUrl; MCONTACT hContact = FindUser(iUserId); VKMessageID_t iMessageId = jnMsg["id"].as_int(); if (vkUser) { wszNick = vkUser->m_wszUserNick; wszUrl = vkUser->m_wszLink; } else { if (hContact || iUserId == m_iMyUserId) wszNick = ptrW(db_get_wsa(hContact, m_szModuleName, "Nick")); else wszNick = TranslateT("(Unknown contact)"); wszUrl = UserProfileUrl(iUserId); } time_t datetime = (time_t)jnMsg["date"].as_int(); wchar_t ttime[64]; _locale_t locale = _create_locale(LC_ALL, ""); _wcsftime_l(ttime, _countof(ttime), L"%x %X", localtime(&datetime), locale); _free_locale(locale); const JSONNode& jnFwdMessages = jnMsg["fwd_messages"]; if (jnFwdMessages && !jnFwdMessages.empty()) { CMStringW wszFwdMessages = GetFwdMessages(jnFwdMessages, jnFUsers, iBBC == bbcNo ? iBBC : m_vkOptions.BBCForAttachments()); if (!wszBody.IsEmpty()) wszFwdMessages = L"\n" + wszFwdMessages; wszBody += wszFwdMessages; } const JSONNode& jnAttachments = jnMsg["attachments"]; if (jnAttachments && !jnAttachments.empty()) { CMStringW wszAttachmentDescr = GetAttachmentDescr(jnAttachments, iBBC == bbcNo ? iBBC : m_vkOptions.BBCForAttachments(), hContact, iMessageId); if (wszAttachmentDescr != L"== FilterAudioMessages ==") { if (!wszBody.IsEmpty()) wszAttachmentDescr = L"\n" + wszAttachmentDescr; wszBody += wszAttachmentDescr; } } wszBody.Replace(L"\n", L"\n\t"); wchar_t tcSplit = m_vkOptions.bSplitFormatFwdMsg ? '\n' : ' '; CMStringW wszMes(FORMAT, L"%s %s%c%s %s:\n\n%s\n", SetBBCString(TranslateT("Message from"), iBBC, vkbbcB).c_str(), SetBBCString(wszNick, iBBC, vkbbcUrl, wszUrl).c_str(), tcSplit, SetBBCString(TranslateT("at"), iBBC, vkbbcB).c_str(), ttime, wszBody.c_str()); return wszMes; } CMStringW CVkProto::GetFwdMessages(const JSONNode &jnMessages, const JSONNode &jnFUsers, BBCSupport iBBC) { CMStringW res; debugLogA("CVkProto::GetFwdMessages"); if (!jnMessages) { debugLogA("CVkProto::GetFwdMessages pMessages == nullptr"); return res; } OBJLIST vkUsers(2, NumericKeySortT); for (auto &jnUser : jnFUsers) { VKUserID_t iUserId = jnUser["id"].as_int(); CMStringW wszNick(jnUser["name"].as_mstring()); if (!wszNick.IsEmpty()) iUserId *= -1; else wszNick.AppendFormat(L"%s %s", jnUser["first_name"].as_mstring().c_str(), jnUser["last_name"].as_mstring().c_str()); CVkUserInfo *vkUser = new CVkUserInfo(jnUser["id"].as_int(), false, wszNick, UserProfileUrl(iUserId), FindUser(iUserId)); vkUsers.insert(vkUser); } if (jnMessages.type() == JSON_ARRAY) for (auto& jnMsg : jnMessages.as_array()) { if (!res.IsEmpty()) res.AppendChar('\n'); res += GetFwdMessage(jnMsg, jnFUsers, vkUsers, iBBC); } else res = GetFwdMessage(jnMessages, jnFUsers, vkUsers, iBBC); res.AppendChar('\n'); vkUsers.destroy(); return res; } ///////////////////////////////////////////////////////////////////////////////////////// void CVkProto::SetInvisible(MCONTACT hContact) { debugLogA("CVkProto::SetInvisible %d", ReadVKUserID(hContact)); if (getWord(hContact, "Status", ID_STATUS_OFFLINE) == ID_STATUS_OFFLINE) { setWord(hContact, "Status", ID_STATUS_INVISIBLE); SetMirVer(hContact, 1); db_set_dw(hContact, "BuddyExpectator", "LastStatus", ID_STATUS_INVISIBLE); debugLogA("CVkProto::SetInvisible %d set ID_STATUS_INVISIBLE", ReadVKUserID(hContact)); } time_t tNow = time(0); db_set_dw(hContact, "BuddyExpectator", "LastSeen", (uint32_t)tNow); setDword(hContact, "InvisibleTS", (uint32_t)tNow); } CMStringW CVkProto::RemoveBBC(CMStringW& wszSrc) { static const wchar_t *wszSimpleBBCodes[][2] = { { L"[b]", L"[/b]" }, { L"[u]", L"[/u]" }, { L"[i]", L"[/i]" }, { L"[s]", L"[/s]" }, }; static const wchar_t *wszParamBBCodes[][2] = { { L"[url=", L"[/url]" }, { L"[img=", L"[/img]" }, { L"[size=", L"[/size]" }, { L"[color=", L"[/color]" }, }; CMStringW wszRes(wszSrc); CMStringW wszLow(wszSrc); wszLow.MakeLower(); for (auto &it : wszSimpleBBCodes) { CMStringW wszOpenTag(it[0]); CMStringW wszCloseTag(it[1]); int lenOpen = wszOpenTag.GetLength(); int lenClose = wszCloseTag.GetLength(); int posOpen = 0; int posClose = 0; while (true) { if ((posOpen = wszLow.Find(wszOpenTag, posOpen)) < 0) break; if ((posClose = wszLow.Find(wszCloseTag, posOpen + lenOpen)) < 0) break; wszLow.Delete(posOpen, lenOpen); wszLow.Delete(posClose - lenOpen, lenClose); wszRes.Delete(posOpen, lenOpen); wszRes.Delete(posClose - lenOpen, lenClose); } } for (auto &it : wszParamBBCodes) { CMStringW wszOpenTag(it[0]); CMStringW wszCloseTag(it[1]); int lenOpen = wszOpenTag.GetLength(); int lenClose = wszCloseTag.GetLength(); int posOpen = 0; int posOpen2 = 0; int posClose = 0; while (true) { if ((posOpen = wszLow.Find(wszOpenTag, posOpen)) < 0) break; if ((posOpen2 = wszLow.Find(L"]", posOpen + lenOpen)) < 0) break; if ((posClose = wszLow.Find(wszCloseTag, posOpen2 + 1)) < 0) break; wszLow.Delete(posOpen, posOpen2 - posOpen + 1); wszLow.Delete(posClose - posOpen2 + posOpen - 1, lenClose); wszRes.Delete(posOpen, posOpen2 - posOpen + 1); wszRes.Delete(posClose - posOpen2 + posOpen - 1, lenClose); } } return wszRes; } void CVkProto::ShowCaptchaInBrowser(HBITMAP hBitmap) { wchar_t wszTempDir[MAX_PATH]; if (!GetEnvironmentVariable(L"TEMP", wszTempDir, MAX_PATH)) return; CMStringW wszHTMLPath(FORMAT, L"%s\\miranda_captcha.html", wszTempDir); FILE *pFile = _wfopen(wszHTMLPath, L"w"); if (pFile == nullptr) return; FIBITMAP *dib = FreeImage_CreateDIBFromHBITMAP(hBitmap); FIMEMORY *hMem = FreeImage_OpenMemory(nullptr, 0); FreeImage_SaveToMemory(FIF_PNG, dib, hMem, 0); uint8_t *buf = nullptr; uint32_t bufLen; FreeImage_AcquireMemory(hMem, &buf, &bufLen); ptrA base64(mir_base64_encode(buf, bufLen)); FreeImage_CloseMemory(hMem); FreeImage_Unload(dib); CMStringA szHTML(FORMAT, "", base64); fwrite(szHTML, 1, szHTML.GetLength(), pFile); fclose(pFile); wszHTMLPath = L"file://" + wszHTMLPath; Utils_OpenUrlW(wszHTMLPath); } void CVkProto::AddVkDeactivateEvent(MCONTACT hContact, CMStringW& wszType) { debugLogW(L"CVkProto::AddVkDeactivateEvent hContact=%d, wszType=%s bShowVkDeactivateEvents=<%d,%d,%d>", hContact, wszType.c_str(), (int)m_vkOptions.bShowVkDeactivateEvents, (int)getBool(hContact, "ShowVkDeactivateEvents", true), (int)(!Contact::IsHidden(hContact))); CVKDeactivateEvent vkDeactivateEvent[] = { { L"", Translate("User restored control over own page") }, { L"deleted", Translate("User was deactivated (deleted)") }, { L"banned", Translate("User was deactivated (banned)") } }; int iDEIdx = -1; for (int i = 0; i < _countof(vkDeactivateEvent); i++) if (wszType == vkDeactivateEvent[i].wszType) { iDEIdx = i; break; } if (iDEIdx == -1) return; DBEVENTINFO dbei = {}; dbei.szModule = m_szModuleName; dbei.timestamp = time(0); dbei.eventType = VK_USER_DEACTIVATE_ACTION; ptrA pszDescription(mir_utf8encode(vkDeactivateEvent[iDEIdx].szDescription)); dbei.cbBlob = (uint32_t)mir_strlen(pszDescription) + 1; dbei.pBlob = mir_strdup(pszDescription); dbei.flags = DBEF_UTF | ( ( m_vkOptions.bShowVkDeactivateEvents && getBool(hContact, "ShowVkDeactivateEvents", true) && (!Contact::IsHidden(hContact)) ) ? 0 : DBEF_READ); db_event_add(hContact, &dbei); } MEVENT CVkProto::GetMessageFromDb(VKMessageID_t iMessageId, time_t& tTimeStamp, CMStringW& wszMsg) { char szMid[40]; _ltoa(iMessageId, szMid, 10); return GetMessageFromDb(szMid, tTimeStamp, wszMsg); } MEVENT CVkProto::GetMessageFromDb(const char *szMessageId, time_t& tTimeStamp, CMStringW& wszMsg) { if (szMessageId == nullptr) return 0; MEVENT hDbEvent = db_event_getById(m_szModuleName, szMessageId); if (!hDbEvent) return 0; DB::EventInfo dbei(hDbEvent); wszMsg = ptrW(mir_utf8decodeW((char*)dbei.pBlob)); tTimeStamp = dbei.timestamp; return hDbEvent; } int CVkProto::DeleteContact(MCONTACT hContact) { setByte(hContact, "SilentDelete", 1); return db_delete_contact(hContact, CDF_FROM_SERVER); } bool CVkProto::IsMessageExist(VKMessageID_t iMessageId, VKMesType vkType) { char szMid[40]; _ltoa(iMessageId, szMid, 10); MEVENT hDbEvent = db_event_getById(m_szModuleName, szMid); if (!hDbEvent) return false; if (vkType == vkALL) return true; DBEVENTINFO dbei = {}; if(db_event_get(hDbEvent, &dbei)) return false; return ((vkType == vkOUT) == (bool)(dbei.flags & DBEF_SENT)); } CMStringW CVkProto::UserProfileUrl(VKUserID_t iUserId) { if (GetVKPeerType(iUserId) == VKPeerType::vkPeerError) return CMStringW(L"https://vk.com/"); if (GetVKPeerType(iUserId) == VKPeerType::vkPeerFeed) return CMStringW(L"https://vk.com/feed"); if (GetVKPeerType(iUserId) == VKPeerType::vkPeerMUC) return CMStringW(L"https://vk.com/im?sel=c%d", iUserId - VK_CHAT_MIN); bool bIsUser = GetVKPeerType(iUserId) == VKPeerType::vkPeerUser; return CMStringW(FORMAT, L"https://vk.com/%s%d", bIsUser ? L"id" : L"club", bIsUser ? iUserId : -1 * iUserId); }